object,store/packed{,/internal/ingest}: Move from format/packfile/ingest

1 files changed, 0 insertions, 68 deletions

diff --git a/format/packfile/ingest/ingest.go b/format/packfile/ingest/ingest.go
deleted file mode 100644
index be65ff5f..00000000
--- a/format/packfile/ingest/ingest.go
+++ /dev/null
@@ -1,68 +0,0 @@
-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)
-}