Write Uncompressed to file

pkg/module/parse/template_to_module.go

@@ -16,7 +16,9 @@ import (
 	"github.com/kyma-project/lifecycle-manager/pkg/log"
 	"github.com/kyma-project/lifecycle-manager/pkg/module/common"
 	"github.com/kyma-project/lifecycle-manager/pkg/templatelookup"
+	"io"
 	machineryruntime "k8s.io/apimachinery/pkg/runtime"
+	"os"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	logf "sigs.k8s.io/controller-runtime/pkg/log"
 )
@@ -273,20 +275,22 @@ func ReadAssociatedResourcesField(ctx context.Context, layer img.Layer) ([]strin
 		return nil, fmt.Errorf("failed to pull associated resources layer, %w", err)
 	}
 
-	blobReadCompressed, err := imgLayer.Compressed()
-	if err != nil {
-		return nil, fmt.Errorf("failed fetching blob for layer %s: %w", imageRef, err)
-	}
-	logf.FromContext(ctx).V(log.InfoLevel).Info(fmt.Sprintf("Compressed: %v", blobReadCompressed))
-	defer blobReadCompressed.Close()
-
 	blobReadUncompressed, err := imgLayer.Uncompressed()
 	if err != nil {
 		return nil, fmt.Errorf("failed fetching blob for layer %s: %w", imageRef, err)
 	}
 	logf.FromContext(ctx).V(log.InfoLevel).Info(fmt.Sprintf("Uncompressed====: %v", blobReadUncompressed))
 	defer blobReadUncompressed.Close()
 
+	outFile, err := os.Create("test.yaml")
+	if err != nil {
+		return nil, fmt.Errorf("file create failed for layer %s: %w", imageRef, err)
+	}
+	if _, err := io.Copy(outFile, blobReadUncompressed); err != nil {
+		return nil, fmt.Errorf("file copy storage failed for layer %s: %w", imageRef, err)
+	}
+	err = io.Closer(outFile).Close()
+
 	// filePath := fmt.Sprintf("%s/%s:%s/%s", associatedResources.Repo, associatedResources.Name, descriptorVersion,
 	// 	img.AssociatedResourcesLayer)
 	// associatedResourcesContent, err := os.ReadFile(filePath)