commitgraph: Move out of format/

1 files changed, 79 insertions, 0 deletions

diff --git a/commitgraph/read/hash.go b/commitgraph/read/hash.go
new file mode 100644
index 00000000..e9543eac
--- /dev/null
+++ b/commitgraph/read/hash.go
@@ -0,0 +1,79 @@
+package read
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+
+	"codeberg.org/lindenii/furgit/objectid"
+)
+
+// HashVersion returns the commit-graph hash version.
+func (reader *Reader) HashVersion() uint8 {
+	return reader.hashVersion
+}
+
+func validateChainBaseHashes(algo objectid.Algorithm, chain []string, idx int, graph *layer) error {
+	if idx == 0 {
+		if len(graph.chunkBaseGraphs) != 0 {
+			return &MalformedError{Path: graph.path, Reason: "unexpected BASE chunk in first graph"}
+		}
+
+		return nil
+	}
+
+	hashSize := algo.Size()
+
+	expectedLen := idx * hashSize
+	if len(graph.chunkBaseGraphs) != expectedLen {
+		return &MalformedError{
+			Path:   graph.path,
+			Reason: fmt.Sprintf("BASE chunk length %d does not match expected %d", len(graph.chunkBaseGraphs), expectedLen),
+		}
+	}
+
+	for i := range idx {
+		start := i * hashSize
+		end := start + hashSize
+
+		baseHash, err := objectid.FromBytes(algo, graph.chunkBaseGraphs[start:end])
+		if err != nil {
+			return err
+		}
+
+		if baseHash.String() != chain[i] {
+			return &MalformedError{
+				Path:   graph.path,
+				Reason: fmt.Sprintf("BASE chunk mismatch at index %d", i),
+			}
+		}
+	}
+
+	return nil
+}
+
+func verifyTrailerHash(data []byte, algo objectid.Algorithm, path string) error {
+	hashSize := algo.Size()
+	if len(data) < hashSize {
+		return &MalformedError{Path: path, Reason: "file too short for trailer"}
+	}
+
+	hashImpl, err := algo.New()
+	if err != nil {
+		return err
+	}
+
+	_, err = io.Copy(hashImpl, bytes.NewReader(data[:len(data)-hashSize]))
+	if err != nil {
+		return err
+	}
+
+	got := hashImpl.Sum(nil)
+
+	want := data[len(data)-hashSize:]
+	if !bytes.Equal(got, want) {
+		return &MalformedError{Path: path, Reason: "trailer hash mismatch"}
+	}
+
+	return nil
+}