1 files changed, 68 insertions, 0 deletions
diff --git a/format/packfile/ingest/ingest.go b/format/packfile/ingest/ingest.go
new file mode 100644
index 00000000..be65ff5f
--- /dev/null
+++ b/format/packfile/ingest/ingest.go
@@ -0,0 +1,68 @@
+package ingest
+
+import (
+	"fmt"
+)
+
+// ingest initializes transaction state and executes the ingest pipeline.
+func ingest(state *ingestState) (out Result, err error) {
+	err = openTemporaryArtifacts(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	defer func() {
+		_ = closeTemporaryArtifacts(state)
+		if err != nil {
+			rollbackTemporaryArtifacts(state)
+		}
+	}()
+
+	err = streamPackAndScan(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	err = resolveAll(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	err = maybeFixThin(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	if state.thinFixed {
+		err = resolveAll(state)
+		if err != nil {
+			return Result{}, err
+		}
+	}
+
+	if len(state.unresolvedRefDeltas) > 0 {
+		return Result{}, &ThinPackUnresolvedError{Count: len(state.unresolvedRefDeltas)}
+	}
+
+	err = verifyResolvedRecords(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	err = state.packFile.Sync()
+	if err != nil {
+		return Result{}, &DestinationWriteError{Op: fmt.Sprintf("sync pack: %v", err)}
+	}
+
+	err = writeIdx(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	err = writeRev(state)
+	if err != nil {
+		return Result{}, err
+	}
+
+	return finalizeArtifacts(state)
+}