Show what sync is doing

Author: FabianKramm

pkg/devspace/sync/downstream.go

@@ -216,7 +216,7 @@ func (d *downstream) downloadFiles(files []*fileInformation) (string, error) {
 
 	// Each file is represented in one line
 	for _, element := range files {
-		if lenFiles <= 3 {
+		if lenFiles <= 3 || d.config.verbose {
 			d.config.Logf("[Downstream] Download file %s, size: %d", element.Name, element.Size)
 		}
 
@@ -335,7 +335,7 @@ func (d *downstream) removeFilesAndFolders(removeFiles map[string]*fileInformati
 		absFilepath := filepath.Join(d.config.WatchPath, key)
 
 		if shouldRemoveLocal(absFilepath, value, d.config) {
-			if numRemoveFiles <= 3 {
+			if numRemoveFiles <= 3 || d.config.verbose {
 				d.config.Logf("[Downstream] Remove %s", key)
 			}
 

pkg/devspace/sync/sync_config.go

@@ -50,7 +50,9 @@ type SyncConfig struct {
 	upstream   *upstream
 	downstream *downstream
 
-	silent   bool
+	silent  bool
+	verbose bool
+
 	stopOnce sync.Once
 	stopped  bool
 

pkg/devspace/sync/sync_config_test.go

@@ -34,6 +34,7 @@ func createTestSyncClient(testLocalPath, testRemotePath string) *SyncConfig {
 		DestPath:  testRemotePath,
 
 		testing: true,
+		verbose: true,
 	}
 }
 

pkg/devspace/sync/upstream.go

@@ -251,6 +251,17 @@ func (u *upstream) applyCreates(files []*fileInformation) error {
 		return errors.Trace(err)
 	}
 
+	// Print changes
+	if u.config.verbose {
+		for _, c := range writtenFiles {
+			if c.IsDirectory {
+				u.config.Logf("[Upstream] Create Folder %s", c.Name)
+			} else {
+				u.config.Logf("[Upstream] Create File %s", c.Name)
+			}
+		}
+	}
+
 	return u.uploadArchive(f, strconv.Itoa(int(stat.Size())), writtenFiles)
 }
 
@@ -356,6 +367,11 @@ func (u *upstream) applyRemoves(files []*fileInformation) error {
 				} else {
 					delete(fileMap, relativePath)
 				}
+
+				// Print changes
+				if u.config.verbose {
+					u.config.Logf("[Upstream] Remove %s", relativePath)
+				}
 			}
 		}