Clean working directory

cmd/smelter/smelt.go

@@ -91,6 +91,10 @@ func Smelt(configs []utils.Config) {
 		for _, config := range configs {
 			configMap[config.Name] = config
 		}
+		// cleanup any previous smelts
+		if err := utils.CleanupDir("working"); err != nil {
+			log.Fatal(err)
+		}
 		// Ensure the working/pre directory exists
 		preDir := "working/pre"
 		if _, err := os.Stat(preDir); os.IsNotExist(err) {

cmd/utils/utils.go

@@ -394,3 +394,27 @@ func IsClusterScoped(resourceName, apiVersion string) bool {
 	}
 	return false
 }
+
+func CleanupDir(dir string) error {
+	if _, err := os.Stat(dir); os.IsNotExist(err) {
+		return nil
+	}
+	err := filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+		if !info.IsDir() && info.Name() != ".gitkeep" {
+			err := os.Remove(path)
+			if err != nil {
+				log.Errorf("Error deleting file %s: %v", path, err)
+			} else {
+				log.Debugf("Deleted file %s", path)
+			}
+		}
+		return nil
+	})
+	if err != nil {
+		return fmt.Errorf("error cleaning %s directory: %v", dir, err)
+	}
+	return nil
+}