fix: issue with image cleanup

The API for Target has to be changed: the cleanup needs the image name (not the id).

internal/kubernetes/kubernetes.go

@@ -82,9 +82,9 @@ func (client *KubeClient) listPods(namespace, labelSelector string) []corev1.Pod
 	return list.Items
 }
 
-func (client *KubeClient) LoadImageInfos(namespaces []corev1.Namespace, podLabelSelector string) (map[string]ContainerImage, []string) {
+func (client *KubeClient) LoadImageInfos(namespaces []corev1.Namespace, podLabelSelector string) (map[string]ContainerImage, []ContainerImage) {
 	images := map[string]ContainerImage{}
-	allImages := []string{}
+	allImages := []ContainerImage{}
 
 	for _, ns := range namespaces {
 		pods := client.listPods(ns.Name, podLabelSelector)
@@ -119,11 +119,17 @@ func (client *KubeClient) LoadImageInfos(namespaces []corev1.Namespace, podLabel
 
 						img.Pods = append(img.Pods, pod)
 						images[c.ImageID] = img
+						allImages = append(allImages, img)
 					} else {
 						logrus.Debugf("Skip image %s", c.ImageID)
+						allImages = append(allImages, ContainerImage{
+							Image:      c.Image,
+							ImageID:    c.ImageID,
+							Auth:       pullSecrets,
+							LegacyAuth: legacy,
+							Pods:       []corev1.Pod{},
+						})
 					}
-
-					allImages = append(allImages, c.ImageID)
 				}
 			}
 		}

internal/target/dtrack_target.go

@@ -103,7 +103,7 @@ func (g *DependencyTrackTarget) ProcessSbom(image kubernetes.ContainerImage, sbo
 	return nil
 }
 
-func (g *DependencyTrackTarget) Cleanup(allImages []string) {
+func (g *DependencyTrackTarget) Cleanup(allImages []kubernetes.ContainerImage) {
 	client, _ := dtrack.NewClient(g.baseUrl, dtrack.WithAPIKey(g.apiKey))
 
 	var (
@@ -113,9 +113,9 @@ func (g *DependencyTrackTarget) Cleanup(allImages []string) {
 
 	allImageRefs := make([]parser.Reference, len(allImages))
 	for _, image := range allImages {
-		ref, err := parser.Parse(image)
+		ref, err := parser.Parse(image.Image)
 		if err != nil {
-			logrus.WithError(err).Errorf("Could not parse image %s", image)
+			logrus.WithError(err).Errorf("Could not parse image %s", image.Image)
 			continue
 		}
 		allImageRefs = append(allImageRefs, *ref)
@@ -136,7 +136,7 @@ func (g *DependencyTrackTarget) Cleanup(allImages []string) {
 
 			// Image used in current cluster
 			for _, image := range allImages {
-				if image == currentImageName {
+				if image.Image == currentImageName {
 					continue projectLoop
 				}
 			}

internal/target/git_target.go

@@ -99,7 +99,7 @@ func (g *GitTarget) ProcessSbom(image kubernetes.ContainerImage, sbom string) er
 	return g.gitAccount.CommitAll(g.workingTree, fmt.Sprintf("Created new SBOM for image %s", imageID))
 }
 
-func (g *GitTarget) Cleanup(allImages []string) {
+func (g *GitTarget) Cleanup(allImages []kubernetes.ContainerImage) {
 	logrus.Debug("Start to remove old SBOMs")
 	ignoreDirs := []string{".git"}
 
@@ -114,10 +114,10 @@ func (g *GitTarget) Cleanup(allImages []string) {
 	}
 }
 
-func (g *GitTarget) mapToFiles(allImages []string) []string {
+func (g *GitTarget) mapToFiles(allImages []kubernetes.ContainerImage) []string {
 	paths := []string{}
 	for _, img := range allImages {
-		paths = append(paths, g.imageIDToFilePath(img))
+		paths = append(paths, g.imageIDToFilePath(img.ImageID))
 	}
 
 	return paths

internal/target/target.go

@@ -8,5 +8,5 @@ type Target interface {
 	Initialize()
 	ValidateConfig() error
 	ProcessSbom(image kubernetes.ContainerImage, sbom string) error
-	Cleanup(allImages []string)
+	Cleanup(allImages []kubernetes.ContainerImage)
 }