ExtractTgzToTempFs

pkg/contexts/ocm/accessmethods/mvn/method_test.go

@@ -21,7 +21,7 @@ const (
 	FAILPATH = "/testdata"
 )
 
-var _ = Describe("Method", func() {
+var _ = Describe("accessmethods.mvn.AccessSpec tests", func() {
 	var env *Builder
 	var cv ocm.ComponentVersionAccess
 

pkg/contexts/ocm/blobhandler/handlers/generic/mvn/blobhandler.go

@@ -9,7 +9,6 @@ import (
 	"net/http"
 	"strings"
 
-	"github.com/mandelsoft/vfs/pkg/osfs"
 	"github.com/mandelsoft/vfs/pkg/vfs"
 	"github.com/opencontainers/go-digest"
 
@@ -80,16 +79,11 @@ func (b *artifactHandler) StoreBlob(blob cpi.BlobAccess, resourceType string, hi
 	}
 	defer blobReader.Close()
 
-	tempFs, err := osfs.NewTempFileSystem()
+	tempFs, err := tarutils.ExtractTgzToTempFs(blobReader)
 	if err != nil {
 		return nil, err
 	}
 	defer vfs.Cleanup(tempFs)
-	err = tarutils.ExtractTarToFs(tempFs, blobReader)
-	// err = tarutils.ExtractTarToFs(tempFs, compression.AutoDecompress(blobReader)) // ???
-	if err != nil {
-		return nil, err
-	}
 	files, err := tarutils.ListSortedFilesInDir(tempFs, "", false)
 	if err != nil {
 		return nil, err

pkg/utils/tarutils/extract.go

@@ -51,6 +51,31 @@ func ExtractTarToFs(fs vfs.FileSystem, in io.Reader) error {
 	return err
 }
 
+// UnzipTarToFs tries to decompress the input stream and then writes the tar stream to a filesystem.
+func UnzipTarToFs(fs vfs.FileSystem, in io.Reader) error {
+	r, _, err := compression.AutoDecompress(in)
+	if err != nil {
+		return err
+	}
+	defer r.Close()
+	err = ExtractTarToFs(fs, r)
+	if err != nil {
+		return err
+	}
+	return err
+}
+
+// ExtractTgzToTempFs extracts a tar.gz archive to a temporary filesystem.
+// You should call vfs.Cleanup on the returned filesystem to clean up the temporary files.
+func ExtractTgzToTempFs(in io.Reader) (vfs.FileSystem, error) {
+	fs, err := osfs.NewTempFileSystem()
+	if err != nil {
+		return nil, err
+	}
+
+	return fs, UnzipTarToFs(fs, in)
+}
+
 func ExtractTarToFsWithInfo(fs vfs.FileSystem, in io.Reader) (fcnt int64, bcnt int64, err error) {
 	tr := tar.NewReader(in)
 	for {