add upload entry purge

Author: shokakucarrier

pkg/buildtest/run.go

@@ -257,6 +257,29 @@ func prepareMigrateEntriesByFolo(targetIndyURL, migrateTargetIndyHost, packageTy
 	newBuildId string, foloRecord common.TrackedContent) map[string][]string {
 	targetIndy := normIndyURL(targetIndyURL)
 	result := make(map[string][]string)
+	for _, up := range foloRecord.Uploads {
+		broken := false
+		migratePath := setHostname(up.LocalUrl, migrateTargetIndyHost)
+		fmt.Printf("[%s] Deleting %s\n", time.Now().Format(DATA_TIME), migratePath)
+		broken = !delArtifact(migratePath)
+
+		if strings.HasPrefix(up.StoreKey, "maven:hosted:build-") {
+			migratePath, _ = url.JoinPath("http://"+migrateTargetIndyHost, "/api/content", packageType, "/hosted/pnc-builds", up.Path)
+			fmt.Printf("[%s] Deleting %s\n", time.Now().Format(DATA_TIME), migratePath)
+			broken = !delArtifact(migratePath)
+			migratePath, _ = url.JoinPath("http://"+migrateTargetIndyHost, "/api/content", packageType, "/remote/mrrc-ga-rh", up.Path)
+			fmt.Printf("[%s] Deleting %s\n", time.Now().Format(DATA_TIME), migratePath)
+			broken = !delArtifact(migratePath)
+		}
+
+		if broken {
+			fmt.Printf("[%s] Deletion failed for %s\n", time.Now().Format(DATA_TIME), migratePath)
+		}
+	}
+
+	fmt.Printf("Waiting 30s...\n")
+	time.Sleep(30 * time.Second) // wait for Indy event handled
+
 	for _, down := range foloRecord.Downloads {
 		var p string
 		downUrl := ""