format/pack/ingest: Init

1 files changed, 71 insertions, 0 deletions

diff --git a/format/pack/ingest/state.go b/format/pack/ingest/state.go
new file mode 100644
index 00000000..7033a6f6
--- /dev/null
+++ b/format/pack/ingest/state.go
@@ -0,0 +1,71 @@
+package ingest
+
+import (
+	"io"
+	"os"
+
+	"codeberg.org/lindenii/furgit/objectid"
+	"codeberg.org/lindenii/furgit/objectstore"
+)
+
+const (
+	defaultDeltaBaseCacheMaxBytes = 32 << 20
+)
+
+// ingestState holds mutable state for one Ingest call.
+type ingestState struct {
+	src         io.Reader
+	destination *os.Root
+	algo        objectid.Algorithm
+	fixThin     bool
+	writeRev    bool
+	base        objectstore.Store
+
+	packFile    *os.File
+	packTmpName string
+	idxFile     *os.File
+	idxTmpName  string
+	revFile     *os.File
+	revTmpName  string
+
+	stream *streamCopier
+
+	records             []objectRecord
+	ofsDeltas           []ofsDeltaRef
+	refDeltas           []refDeltaRef
+	unresolvedRefDeltas []int
+	offsetToRecord      map[uint64]int
+	objectToRecord      map[string]int
+
+	baseCache *deltaBaseCache
+	packHash  objectid.ObjectID
+
+	objectCountHeader uint32
+	thinFixed         bool
+}
+
+// newIngestState constructs one call-local ingest state.
+func newIngestState(
+	src io.Reader,
+	destination *os.Root,
+	algo objectid.Algorithm,
+	fixThin bool,
+	writeRev bool,
+	base objectstore.Store,
+) (*ingestState, error) {
+	if algo.Size() == 0 {
+		return nil, objectid.ErrInvalidAlgorithm
+	}
+
+	return &ingestState{
+		src:            src,
+		destination:    destination,
+		algo:           algo,
+		fixThin:        fixThin,
+		writeRev:       writeRev,
+		base:           base,
+		offsetToRecord: make(map[uint64]int),
+		objectToRecord: make(map[string]int),
+		baseCache:      newDeltaBaseCache(defaultDeltaBaseCacheMaxBytes),
+	}, nil
+}