reachability: Refactor v0.1.41

1 files changed, 64 insertions, 0 deletions

diff --git a/reachability/helpers.go b/reachability/helpers.go
new file mode 100644
index 00000000..1368a3f1
--- /dev/null
+++ b/reachability/helpers.go
@@ -0,0 +1,64 @@
+package reachability
+
+import (
+	"errors"
+	"fmt"
+
+	"codeberg.org/lindenii/furgit/objectid"
+	"codeberg.org/lindenii/furgit/objectstore"
+	"codeberg.org/lindenii/furgit/objecttype"
+)
+
+func validateDomain(domain Domain) error {
+	switch domain {
+	case DomainCommits, DomainObjects:
+		return nil
+	default:
+		return fmt.Errorf("reachability: invalid domain %d", domain)
+	}
+}
+
+func containsOID(set map[objectid.ObjectID]struct{}, id objectid.ObjectID) bool {
+	if len(set) == 0 {
+		return false
+	}
+	_, ok := set[id]
+	return ok
+}
+
+// The following helpers exist because we don't have unified error handling across the entire project.
+// This will be fixed later.
+
+func (walk *Walk) readHeaderType(id objectid.ObjectID) (objecttype.Type, error) {
+	return walk.reachability.readHeaderType(id)
+}
+
+func (r *Reachability) readHeaderType(id objectid.ObjectID) (objecttype.Type, error) {
+	ty, _, err := r.store.ReadHeader(id)
+	if err != nil {
+		if errors.Is(err, objectstore.ErrObjectNotFound) {
+			return objecttype.TypeInvalid, &ErrObjectMissing{OID: id}
+		}
+		return objecttype.TypeInvalid, err
+	}
+	return ty, nil
+}
+
+func (walk *Walk) readBytesContent(id objectid.ObjectID) ([]byte, error) {
+	content, err := walk.reachability.readBytesContent(id)
+	if err != nil {
+		return nil, err
+	}
+	return content, nil
+}
+
+func (r *Reachability) readBytesContent(id objectid.ObjectID) ([]byte, error) {
+	_, content, err := r.store.ReadBytesContent(id)
+	if err != nil {
+		if errors.Is(err, objectstore.ErrObjectNotFound) {
+			return nil, &ErrObjectMissing{OID: id}
+		}
+		return nil, err
+	}
+	return content, nil
+}