feat: support OCI index with duplicate filenames by deduplicatin…

pkg/downloader/downloader.go

@@ -459,7 +459,11 @@ func (d *OciDownloader) Download(opts *DownloadOptions) error {
 				if utils.IsTar(cacheTarPath) {
 					err = utils.UnTarDir(cacheTarPath, localFullPath)
 				} else {
-					err = utils.ExtractTarball(cacheTarPath, localFullPath)
+					if err = utils.ExtractTarball(cacheTarPath, localFullPath); err == nil {
+						if derr := oci.DedupePulledFiles(localFullPath); derr != nil {
+							return derr
+						}
+					}
 				}
 				if err != nil {
 					return err
@@ -485,7 +489,12 @@ func (d *OciDownloader) Download(opts *DownloadOptions) error {
 			if utils.IsTar(tarPath) {
 				err = utils.UnTarDir(tarPath, localPath)
 			} else {
-				err = utils.ExtractTarball(tarPath, localPath)
+				// after extracting multiple packages, dedupe any same-named files
+				if err = utils.ExtractTarball(tarPath, localPath); err == nil {
+						if derr := oci.DedupePulledFiles(localPath); derr != nil {
+							return derr
+						}
+					}
 			}
 			if err != nil {
 				return fmt.Errorf("failed to untar the kcl package tar from '%s' into '%s'", tarPath, localPath)
@@ -499,39 +508,45 @@ func (d *OciDownloader) Download(opts *DownloadOptions) error {
 				}
 			}
 		}
-	} else if !opts.Offline {
-		reporter.ReportMsgTo(
-			fmt.Sprintf(
-				"downloading '%s:%s' from '%s/%s:%s'",
-				ociSource.Repo, ociSource.Tag, ociSource.Reg, ociSource.Repo, ociSource.Tag,
-			),
-			opts.LogWriter,
-		)
+		} else if !opts.Offline {
+			reporter.ReportMsgTo(
+				fmt.Sprintf(
+					"downloading '%s:%s' from '%s/%s:%s'",
+					ociSource.Repo, ociSource.Tag, ociSource.Reg, ociSource.Repo, ociSource.Tag,
+				),
+				opts.LogWriter,
+			)
 
-		err = ociCli.Pull(localPath, ociSource.Tag)
-		if err != nil {
-			return err
-		}
-		tarPath, err := utils.FindPkgArchive(localPath)
-		if err != nil {
-			return err
-		}
-		if utils.IsTar(tarPath) {
-			err = utils.UnTarDir(tarPath, localPath)
-		} else {
-			err = utils.ExtractTarball(tarPath, localPath)
-		}
-		if err != nil {
-			return fmt.Errorf("failed to untar the kcl package tar from '%s' into '%s'", tarPath, localPath)
-		}
+			// pull & extract
+			err = ociCli.Pull(localPath, ociSource.Tag)
+			if err != nil {
+				return err
+			}
+			tarPath, err := utils.FindPkgArchive(localPath)
+			if err != nil {
+				return err
+			}
+			if utils.IsTar(tarPath) {
+				err = utils.UnTarDir(tarPath, localPath)
+			} else {
+				// after extracting multiple packages, dedupe any same-named files
+				if err = utils.ExtractTarball(tarPath, localPath); err == nil {
+					if derr := oci.DedupePulledFiles(localPath); derr != nil {
+						return derr
+					}
+				}
+			}
+			if err != nil {
+				return fmt.Errorf("failed to untar the kcl package tar from '%s' into '%s'", tarPath, localPath)
+			}
 
-		// After untar the downloaded kcl package tar file, remove the tar file.
-		if utils.DirExists(tarPath) {
-			rmErr := os.Remove(tarPath)
-			if rmErr != nil {
-				return fmt.Errorf("failed to remove the downloaded kcl package tar file '%s'", tarPath)
+			// After untar the downloaded kcl package tar file, remove the tar file.
+			if utils.DirExists(tarPath) {
+				rmErr := os.Remove(tarPath)
+				if rmErr != nil {
+					return fmt.Errorf("failed to remove the downloaded kcl package tar file '%s'", tarPath)
+				}
 			}
-		}
 
 	}
 

pkg/oci/oci.go

@@ -268,6 +268,49 @@ func (ociClient *OciClient) Pull(localPath, tag string) error {
 		)
 	}
 
+	if err := DedupePulledFiles(localPath); err != nil {
+		return reporter.NewErrorEvent(reporter.FailedGetPkg, err, "failed to dedupe pulled OCI files")
+	}
+
+	return nil
+}
+
+// DedupePulledFiles renames any files in dir that share the same name by appending
+// a numeric suffix (e.g. pkg.kcl, pkg-2.kcl, pkg-3.kcl).
+func DedupePulledFiles(dir string) error {
+	entries, err := os.ReadDir(dir)
+	if err != nil {
+		return err
+	}
+
+	// count how many of each name we have
+	counts := make(map[string]int)
+	for _, e := range entries {
+		if e.IsDir() {
+			continue
+		}
+		counts[e.Name()]++
+	}
+
+	// for any name that appears more than once, rename them with -1, -2, …
+	seen := make(map[string]int)
+	for _, e := range entries {
+		if e.IsDir() {
+			continue
+		}
+		name := e.Name()
+		if counts[name] > 1 {
+			seen[name]++
+			ext := filepath.Ext(name)
+			base := strings.TrimSuffix(name, ext)
+			newName := fmt.Sprintf("%s-%d%s", base, seen[name], ext)
+			oldPath := filepath.Join(dir, name)
+			newPath := filepath.Join(dir, newName)
+			if err := os.Rename(oldPath, newPath); err != nil {
+				return err
+			}
+		}
+	}
 	return nil
 }