aboutsummaryrefslogtreecommitdiff
path: root/refstore/chain
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-25 14:31:16 +0000
committerGravatar Runxi Yu2026-03-25 14:31:16 +0000
commit48ff647cf4a8bb8f23fcd6b8616f56a8ef72b980 (patch)
treeae199c38042adaa544d5f7d31351661d5831381e /refstore/chain
parent*: objectstore -> object/store (diff)
signatureNo signature
*: refstore -> ref/store
Diffstat (limited to 'refstore/chain')
-rw-r--r--refstore/chain/chain.go12
-rw-r--r--refstore/chain/close.go8
-rw-r--r--refstore/chain/list.go40
-rw-r--r--refstore/chain/new.go13
-rw-r--r--refstore/chain/resolve.go64
5 files changed, 0 insertions, 137 deletions
diff --git a/refstore/chain/chain.go b/refstore/chain/chain.go
deleted file mode 100644
index 0feb97c3..00000000
--- a/refstore/chain/chain.go
+++ /dev/null
@@ -1,12 +0,0 @@
-// Package chain provides a wrapper reference storage backend to query a chain
-// of backends.
-package chain
-
-import "codeberg.org/lindenii/furgit/refstore"
-
-// Chain queries multiple reference stores in order.
-//
-// Chain borrows its backend stores.
-type Chain struct {
- backends []refstore.ReadingStore
-}
diff --git a/refstore/chain/close.go b/refstore/chain/close.go
deleted file mode 100644
index 6bd74565..00000000
--- a/refstore/chain/close.go
+++ /dev/null
@@ -1,8 +0,0 @@
-package chain
-
-// Close releases wrapper-local resources.
-//
-// Chain borrows its backends, so Close does not close them.
-//
-// Repeated calls to Close are undefined behavior.
-func (chain *Chain) Close() error { return nil }
diff --git a/refstore/chain/list.go b/refstore/chain/list.go
deleted file mode 100644
index c577ca85..00000000
--- a/refstore/chain/list.go
+++ /dev/null
@@ -1,40 +0,0 @@
-package chain
-
-import (
- "fmt"
-
- "codeberg.org/lindenii/furgit/ref"
-)
-
-// List lists references from every backend and deduplicates by ref name.
-//
-// First-seen wins, so earlier backends have precedence.
-func (chain *Chain) List(pattern string) ([]ref.Ref, error) {
- var refs []ref.Ref
-
- seen := map[string]struct{}{}
-
- for i, backend := range chain.backends {
- listed, err := backend.List(pattern)
- if err != nil {
- return nil, fmt.Errorf("refstore: backend %d list: %w", i, err)
- }
-
- for _, entry := range listed {
- if entry == nil {
- continue
- }
-
- name := entry.Name()
- if _, ok := seen[name]; ok {
- continue
- }
-
- seen[name] = struct{}{}
-
- refs = append(refs, entry)
- }
- }
-
- return refs, nil
-}
diff --git a/refstore/chain/new.go b/refstore/chain/new.go
deleted file mode 100644
index f8bdcb13..00000000
--- a/refstore/chain/new.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package chain
-
-import "codeberg.org/lindenii/furgit/refstore"
-
-// New creates an ordered reference store chain.
-//
-// The provided backends must be non-nil and distinct.
-// Chain borrows the provided backends and does not close them in Close.
-func New(backends ...refstore.ReadingStore) *Chain {
- return &Chain{
- backends: append([]refstore.ReadingStore(nil), backends...),
- }
-}
diff --git a/refstore/chain/resolve.go b/refstore/chain/resolve.go
deleted file mode 100644
index 97dee24b..00000000
--- a/refstore/chain/resolve.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package chain
-
-import (
- "errors"
- "fmt"
-
- "codeberg.org/lindenii/furgit/ref"
- "codeberg.org/lindenii/furgit/refstore"
-)
-
-// Resolve resolves a reference from the first backend that has it.
-//
-//nolint:ireturn
-func (chain *Chain) Resolve(name string) (ref.Ref, error) {
- for i, backend := range chain.backends {
- resolved, err := backend.Resolve(name)
- if err == nil {
- return resolved, nil
- }
-
- if errors.Is(err, refstore.ErrReferenceNotFound) {
- continue
- }
-
- return nil, fmt.Errorf("refstore: backend %d resolve: %w", i, err)
- }
-
- return nil, refstore.ErrReferenceNotFound
-}
-
-// ResolveToDetached resolves symbolic references through Resolve until detached.
-//
-// It intentionally does not call backend ResolveToDetached. This allows symbolic
-// references to cross backends in the chain.
-func (chain *Chain) ResolveToDetached(name string) (ref.Detached, error) {
- cur := name
-
- seen := map[string]struct{}{}
- for {
- if _, ok := seen[cur]; ok {
- return ref.Detached{}, fmt.Errorf("refstore: symbolic reference cycle at %q", cur)
- }
-
- seen[cur] = struct{}{}
-
- resolved, err := chain.Resolve(cur)
- if err != nil {
- return ref.Detached{}, err
- }
-
- switch resolved := resolved.(type) {
- case ref.Detached:
- return resolved, nil
- case ref.Symbolic:
- if resolved.Target == "" {
- return ref.Detached{}, fmt.Errorf("refstore: symbolic reference %q has empty target", resolved.Name())
- }
-
- cur = resolved.Target
- default:
- return ref.Detached{}, fmt.Errorf("refstore: unsupported reference type %T", resolved)
- }
- }
-}