list files

Signed-off-by: Daniil Antoshin <[email protected]>

Author: danilrwx

images/dvcr-artifact/pkg/datasource/filesystem-datasource.go

@@ -20,6 +20,7 @@ import (
 	"fmt"
 	"io"
 	"os"
+	"time"
 
 	"github.com/google/uuid"
 )
@@ -33,6 +34,24 @@ type FilesystemDataSource struct {
 func NewFilesystemDataSource() (*FilesystemDataSource, error) {
 	filesystemImagePath := "/tmp/fs/disk.img"
 
+	files, err := os.ReadDir("/tmp/fs")
+	if err != nil {
+		return nil, fmt.Errorf("can not read directory /tmp/fs: %w", err)
+	}
+
+	for _, file := range files {
+		if file.IsDir() {
+			continue
+		}
+		filesystemImagePath = file.Name()
+		fmt.Printf("filesystemImagePath: %s\n", filesystemImagePath)
+		break
+	}
+
+	for {
+		time.Sleep(10 * time.Second)
+	}
+
 	file, err := os.Open(filesystemImagePath)
 	if err != nil {
 		return nil, fmt.Errorf("can not get open image %s: %w", filesystemImagePath, err)

images/virtualization-artifact/pkg/controller/cvi/internal/source/object_ref_vd.go

@@ -112,7 +112,7 @@ func (ds ObjectRefVirtualDisk) Sync(ctx context.Context, cvi *v1alpha2.ClusterVi
 		cvi.Status.Progress = ds.statService.GetProgress(cvi.GetUID(), pod, cvi.Status.Progress)
 		cvi.Status.Target.RegistryURL = ds.statService.GetDVCRImageName(pod)
 
-		var pvc *corev1.PersistentVolumeClaim
+		pvc := &corev1.PersistentVolumeClaim{}
 		err := ds.client.Get(ctx, types.NamespacedName{Name: vdRef.Status.Target.PersistentVolumeClaim, Namespace: vdRef.Namespace}, pvc)
 		if err != nil {
 			return reconcile.Result{}, err

images/virtualization-artifact/pkg/controller/vi/internal/source/object_ref_vd.go

@@ -114,13 +114,14 @@ func (ds ObjectRefVirtualDisk) StoreToDVCR(ctx context.Context, vi *v1alpha2.Vir
 		vi.Status.Progress = ds.statService.GetProgress(vi.GetUID(), pod, vi.Status.Progress)
 		vi.Status.Target.RegistryURL = ds.statService.GetDVCRImageName(pod)
 
-		pvc, err := ds.diskService.GetPersistentVolumeClaim(ctx, supgen)
+		pvc := &corev1.PersistentVolumeClaim{}
+		err := ds.client.Get(ctx, types.NamespacedName{Name: vdRef.Status.Target.PersistentVolumeClaim, Namespace: vdRef.Namespace}, pvc)
 		if err != nil {
 			return reconcile.Result{}, err
 		}
 
 		var envSettings *importer.Settings
-		if pvc.Spec.VolumeMode != nil {
+		if pvc != nil && pvc.Spec.VolumeMode != nil {
 			envSettings = ds.getEnvSettings(vi, supgen, pvc.Spec.VolumeMode)
 		} else {
 			envSettings = ds.getEnvSettings(vi, supgen, ptr.To(corev1.PersistentVolumeBlock))

images/virtualization-artifact/pkg/controller/vi/internal/source/step/create_pod_step.go

@@ -93,7 +93,7 @@ func (s CreatePodStep) Take(ctx context.Context, vi *v1alpha2.VirtualImage) (*re
 	podSettings := s.importer.GetPodSettingsWithPVC(ownerRef, supgen, pvcKey.Name, pvcKey.Namespace)
 
 	var envSettings *importer.Settings
-	if s.pvc.Spec.VolumeMode != nil {
+	if s.pvc != nil && s.pvc.Spec.VolumeMode != nil {
 		envSettings = s.getEnvSettings(vi, supgen, s.pvc.Spec.VolumeMode)
 	} else {
 		envSettings = s.getEnvSettings(vi, supgen, ptr.To(corev1.PersistentVolumeBlock))