format/pack/ingest: Init

1 files changed, 49 insertions, 0 deletions

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