aboutsummaryrefslogtreecommitdiff
path: root/repository
diff options
context:
space:
mode:
Diffstat (limited to 'repository')
-rw-r--r--repository/open.go212
-rw-r--r--repository/repository.go201
2 files changed, 212 insertions, 201 deletions
diff --git a/repository/open.go b/repository/open.go
new file mode 100644
index 00000000..5879f6ee
--- /dev/null
+++ b/repository/open.go
@@ -0,0 +1,212 @@
+package repository
+
+import (
+ "errors"
+ "fmt"
+ "os"
+
+ "codeberg.org/lindenii/furgit/config"
+ "codeberg.org/lindenii/furgit/objectid"
+ "codeberg.org/lindenii/furgit/objectstore"
+ objectchain "codeberg.org/lindenii/furgit/objectstore/chain"
+ objectloose "codeberg.org/lindenii/furgit/objectstore/loose"
+ objectpacked "codeberg.org/lindenii/furgit/objectstore/packed"
+ "codeberg.org/lindenii/furgit/refstore"
+ refchain "codeberg.org/lindenii/furgit/refstore/chain"
+ refloose "codeberg.org/lindenii/furgit/refstore/loose"
+ refpacked "codeberg.org/lindenii/furgit/refstore/packed"
+ reftable "codeberg.org/lindenii/furgit/refstore/reftable"
+)
+
+// Open opens a repository and wires object/ref stores from its on-disk format.
+//
+// Open borrows root during construction and does not close it.
+func Open(root *os.Root) (repo *Repository, err error) {
+ repo = &Repository{}
+
+ defer func() {
+ if err != nil {
+ _ = repo.Close()
+ }
+ }()
+
+ cfg, err := parseRepositoryConfig(root)
+ if err != nil {
+ return nil, err
+ }
+
+ repo.config = cfg
+
+ algo, err := detectObjectAlgorithm(cfg)
+ if err != nil {
+ return nil, err
+ }
+
+ repo.algo = algo
+
+ objects, objectsLooseForWritingOnly, err := openObjectStore(root, algo)
+ if err != nil {
+ return nil, err
+ }
+
+ repo.objects = objects
+ repo.objectsLooseForWritingOnly = objectsLooseForWritingOnly
+
+ refs, err := openRefStore(root, algo)
+ if err != nil {
+ return nil, err
+ }
+
+ repo.refs = refs
+
+ return repo, nil
+}
+
+func parseRepositoryConfig(root *os.Root) (*config.Config, error) {
+ configFile, err := root.Open("config")
+ if err != nil {
+ return nil, fmt.Errorf("repository: open config: %w", err)
+ }
+
+ defer func() { _ = configFile.Close() }()
+
+ cfg, err := config.ParseConfig(configFile)
+ if err != nil {
+ return nil, fmt.Errorf("repository: parse config: %w", err)
+ }
+
+ return cfg, nil
+}
+
+func detectObjectAlgorithm(cfg *config.Config) (objectid.Algorithm, error) {
+ algoName := cfg.Lookup("extensions", "", "objectformat").Value
+ if algoName == "" {
+ algoName = objectid.AlgorithmSHA1.String()
+ }
+
+ algo, ok := objectid.ParseAlgorithm(algoName)
+ if !ok {
+ return objectid.AlgorithmUnknown, fmt.Errorf("repository: unsupported object format %q", algoName)
+ }
+
+ return algo, nil
+}
+
+func openObjectStore(root *os.Root, algo objectid.Algorithm) (objectstore.Store, *objectloose.Store, error) {
+ objectsRoot, err := root.OpenRoot("objects")
+ if err != nil {
+ return nil, nil, fmt.Errorf("repository: open objects: %w", err)
+ }
+
+ looseStore, err := objectloose.New(objectsRoot, algo)
+ if err != nil {
+ return nil, nil, err
+ }
+
+ backends := []objectstore.Store{looseStore}
+
+ packRoot, err := objectsRoot.OpenRoot("pack")
+ if err == nil {
+ var packedStore *objectpacked.Store
+
+ packedStore, err = objectpacked.New(packRoot, algo)
+ if err != nil {
+ _ = looseStore.Close()
+
+ return nil, nil, err
+ }
+
+ backends = append(backends, packedStore)
+ } else if !errors.Is(err, os.ErrNotExist) {
+ _ = looseStore.Close()
+
+ return nil, nil, fmt.Errorf("repository: open objects/pack: %w", err)
+ }
+
+ objectsChain := objectchain.New(backends...)
+
+ objectsRootForWriting, err := root.OpenRoot("objects")
+ if err != nil {
+ _ = objectsChain.Close()
+
+ return nil, nil, fmt.Errorf("repository: open objects for loose writing: %w", err)
+ }
+
+ objectsLooseForWritingOnly, err := objectloose.New(objectsRootForWriting, algo)
+ if err != nil {
+ _ = objectsRootForWriting.Close()
+ _ = objectsChain.Close()
+
+ return nil, nil, err
+ }
+
+ return objectsChain, objectsLooseForWritingOnly, nil
+}
+
+func openRefStore(root *os.Root, algo objectid.Algorithm) (out refstore.Store, err error) {
+ hasReftable, err := hasReftableStack(root)
+ if err != nil {
+ return nil, err
+ }
+
+ if hasReftable {
+ reftableRoot, err := root.OpenRoot("reftable")
+ if err != nil {
+ return nil, fmt.Errorf("repository: open reftable: %w", err)
+ }
+
+ reftableStore, err := reftable.New(reftableRoot, algo)
+ if err != nil {
+ _ = reftableRoot.Close()
+
+ return nil, err
+ }
+
+ return reftableStore, nil
+ }
+
+ looseRoot, err := root.OpenRoot(".")
+ if err != nil {
+ return nil, fmt.Errorf("repository: open root for loose refs: %w", err)
+ }
+
+ looseStore, err := refloose.New(looseRoot, algo)
+ if err != nil {
+ _ = looseRoot.Close()
+
+ return nil, err
+ }
+
+ backends := []refstore.Store{looseStore}
+
+ _, err = root.Stat("packed-refs")
+ if err == nil {
+ packedStore, packedErr := refpacked.New(root, algo)
+ if packedErr != nil {
+ _ = looseStore.Close()
+
+ return nil, packedErr
+ }
+
+ backends = append(backends, packedStore)
+ } else if !errors.Is(err, os.ErrNotExist) {
+ _ = looseStore.Close()
+
+ return nil, fmt.Errorf("repository: stat packed-refs: %w", err)
+ }
+
+ return refchain.New(backends...), nil
+}
+
+func hasReftableStack(root *os.Root) (bool, error) {
+ _, err := root.Stat("reftable/tables.list")
+ if err == nil {
+ return true, nil
+ }
+
+ if errors.Is(err, os.ErrNotExist) {
+ return false, nil
+ }
+
+ return false, fmt.Errorf("repository: stat reftable/tables.list: %w", err)
+}
diff --git a/repository/repository.go b/repository/repository.go
index 9927264a..02945456 100644
--- a/repository/repository.go
+++ b/repository/repository.go
@@ -3,20 +3,12 @@ package repository
import (
"errors"
- "fmt"
- "os"
"codeberg.org/lindenii/furgit/config"
"codeberg.org/lindenii/furgit/objectid"
"codeberg.org/lindenii/furgit/objectstore"
- objectchain "codeberg.org/lindenii/furgit/objectstore/chain"
objectloose "codeberg.org/lindenii/furgit/objectstore/loose"
- objectpacked "codeberg.org/lindenii/furgit/objectstore/packed"
"codeberg.org/lindenii/furgit/refstore"
- refchain "codeberg.org/lindenii/furgit/refstore/chain"
- refloose "codeberg.org/lindenii/furgit/refstore/loose"
- refpacked "codeberg.org/lindenii/furgit/refstore/packed"
- reftable "codeberg.org/lindenii/furgit/refstore/reftable"
)
// Repository is a thin composition root for repository-local stores.
@@ -32,50 +24,6 @@ type Repository struct {
refs refstore.Store
}
-// Open opens a repository and wires object/ref stores from its on-disk format.
-//
-// Open borrows root during construction and does not close it.
-func Open(root *os.Root) (repo *Repository, err error) {
- repo = &Repository{}
-
- defer func() {
- if err != nil {
- _ = repo.Close()
- }
- }()
-
- cfg, err := parseRepositoryConfig(root)
- if err != nil {
- return nil, err
- }
-
- repo.config = cfg
-
- algo, err := detectObjectAlgorithm(cfg)
- if err != nil {
- return nil, err
- }
-
- repo.algo = algo
-
- objects, objectsLooseForWritingOnly, err := openObjectStore(root, algo)
- if err != nil {
- return nil, err
- }
-
- repo.objects = objects
- repo.objectsLooseForWritingOnly = objectsLooseForWritingOnly
-
- refs, err := openRefStore(root, algo)
- if err != nil {
- return nil, err
- }
-
- repo.refs = refs
-
- return repo, nil
-}
-
// Algorithm returns the repository object ID algorithm.
func (repo *Repository) Algorithm() objectid.Algorithm {
return repo.algo
@@ -127,152 +75,3 @@ func (repo *Repository) Close() error {
return errors.Join(errs...)
}
-
-func parseRepositoryConfig(root *os.Root) (*config.Config, error) {
- configFile, err := root.Open("config")
- if err != nil {
- return nil, fmt.Errorf("repository: open config: %w", err)
- }
-
- defer func() { _ = configFile.Close() }()
-
- cfg, err := config.ParseConfig(configFile)
- if err != nil {
- return nil, fmt.Errorf("repository: parse config: %w", err)
- }
-
- return cfg, nil
-}
-
-func detectObjectAlgorithm(cfg *config.Config) (objectid.Algorithm, error) {
- algoName := cfg.Lookup("extensions", "", "objectformat").Value
- if algoName == "" {
- algoName = objectid.AlgorithmSHA1.String()
- }
-
- algo, ok := objectid.ParseAlgorithm(algoName)
- if !ok {
- return objectid.AlgorithmUnknown, fmt.Errorf("repository: unsupported object format %q", algoName)
- }
-
- return algo, nil
-}
-
-func openObjectStore(root *os.Root, algo objectid.Algorithm) (objectstore.Store, *objectloose.Store, error) {
- objectsRoot, err := root.OpenRoot("objects")
- if err != nil {
- return nil, nil, fmt.Errorf("repository: open objects: %w", err)
- }
-
- looseStore, err := objectloose.New(objectsRoot, algo)
- if err != nil {
- return nil, nil, err
- }
-
- backends := []objectstore.Store{looseStore}
-
- packRoot, err := objectsRoot.OpenRoot("pack")
- if err == nil {
- var packedStore *objectpacked.Store
-
- packedStore, err = objectpacked.New(packRoot, algo)
- if err != nil {
- _ = looseStore.Close()
-
- return nil, nil, err
- }
-
- backends = append(backends, packedStore)
- } else if !errors.Is(err, os.ErrNotExist) {
- _ = looseStore.Close()
-
- return nil, nil, fmt.Errorf("repository: open objects/pack: %w", err)
- }
-
- objectsChain := objectchain.New(backends...)
-
- objectsRootForWriting, err := root.OpenRoot("objects")
- if err != nil {
- _ = objectsChain.Close()
-
- return nil, nil, fmt.Errorf("repository: open objects for loose writing: %w", err)
- }
-
- objectsLooseForWritingOnly, err := objectloose.New(objectsRootForWriting, algo)
- if err != nil {
- _ = objectsRootForWriting.Close()
- _ = objectsChain.Close()
-
- return nil, nil, err
- }
-
- return objectsChain, objectsLooseForWritingOnly, nil
-}
-
-func openRefStore(root *os.Root, algo objectid.Algorithm) (out refstore.Store, err error) {
- hasReftable, err := hasReftableStack(root)
- if err != nil {
- return nil, err
- }
-
- if hasReftable {
- reftableRoot, err := root.OpenRoot("reftable")
- if err != nil {
- return nil, fmt.Errorf("repository: open reftable: %w", err)
- }
-
- reftableStore, err := reftable.New(reftableRoot, algo)
- if err != nil {
- _ = reftableRoot.Close()
-
- return nil, err
- }
-
- return reftableStore, nil
- }
-
- looseRoot, err := root.OpenRoot(".")
- if err != nil {
- return nil, fmt.Errorf("repository: open root for loose refs: %w", err)
- }
-
- looseStore, err := refloose.New(looseRoot, algo)
- if err != nil {
- _ = looseRoot.Close()
-
- return nil, err
- }
-
- backends := []refstore.Store{looseStore}
-
- _, err = root.Stat("packed-refs")
- if err == nil {
- packedStore, packedErr := refpacked.New(root, algo)
- if packedErr != nil {
- _ = looseStore.Close()
-
- return nil, packedErr
- }
-
- backends = append(backends, packedStore)
- } else if !errors.Is(err, os.ErrNotExist) {
- _ = looseStore.Close()
-
- return nil, fmt.Errorf("repository: stat packed-refs: %w", err)
- }
-
- return refchain.New(backends...), nil
-}
-
-func hasReftableStack(root *os.Root) (bool, error) {
- _, err := root.Stat("reftable/tables.list")
- if err == nil {
- return true, nil
- }
-
- if errors.Is(err, os.ErrNotExist) {
- return false, nil
- }
-
- return false, fmt.Errorf("repository: stat reftable/tables.list: %w", err)
-}
generated by cgit v1.3.1-10-gc9f91 (git 2.54.0) at 2026-05-25 14:20:27 +0000