package repository import ( "errors" "fmt" "os" objectid "codeberg.org/lindenii/furgit/object/id" objectstore "codeberg.org/lindenii/furgit/object/store" objectloose "codeberg.org/lindenii/furgit/object/store/loose" objectmix "codeberg.org/lindenii/furgit/object/store/mix" objectpacked "codeberg.org/lindenii/furgit/object/store/packed" ) // openObjectStore opens the roots and object stores of both // the loose and packed stores for a particular repo root and // object ID hashing algorithm. // // Since real object store implementations do not take ownership of // the roots given to them, and since composite object stores do not // take ownership of the object stores that they consist of, all // of them are returned and should be closed by the caller. // //nolint:ireturn func openObjectStore( root *os.Root, algo objectid.Algorithm, ) ( objects objectstore.ReadingStore, objectsRoot *os.Root, objectsPackRoot *os.Root, objectsLoose *objectloose.Store, objectsPacked *objectpacked.Store, err error, ) { objectsRoot, err = root.OpenRoot("objects") if err != nil { return nil, nil, nil, nil, nil, fmt.Errorf("repository: open objects: %w", err) } objectsLoose, err = objectloose.New(objectsRoot, algo) if err != nil { _ = objectsRoot.Close() return nil, nil, nil, nil, nil, err } backends := []objectstore.ReadingStore{objectsLoose} objectsPackRoot, err = objectsRoot.OpenRoot("pack") if err == nil { objectsPacked, err = objectpacked.New( objectsPackRoot, algo, objectpacked.Options{RefreshPolicy: objectpacked.RefreshPolicyNever}, ) if err != nil { _ = objectsPackRoot.Close() _ = objectsLoose.Close() _ = objectsRoot.Close() return nil, nil, nil, nil, nil, err } backends = append(backends, objectsPacked) } else if !errors.Is(err, os.ErrNotExist) { _ = objectsLoose.Close() _ = objectsRoot.Close() return nil, nil, nil, nil, nil, fmt.Errorf("repository: open objects/pack: %w", err) } objects = objectmix.New(backends...) return objects, objectsRoot, objectsPackRoot, objectsLoose, objectsPacked, nil } // Objects returns the configured object store. // // Labels: Life-Parent, Close-No. // //nolint:ireturn func (repo *Repository) Objects() objectstore.ReadingStore { return repo.objects }