Merge pull request #192 from covexo/test-sync

Test sync

Author: FabianKramm

Gopkg.lock

@@ -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)
 			}
 
@@ -369,7 +369,7 @@ func (d *downstream) createFolders(createFolders []*fileInformation) {
 
 	for _, element := range createFolders {
 		if element.IsDirectory {
-			if numCreateFolders <= 3 {
+			if numCreateFolders <= 3 || d.config.verbose {
 				d.config.Logln("[Downstream] Create folder: " + element.Name)
 			}
 

pkg/devspace/sync/downstream.go

@@ -50,13 +50,16 @@ type SyncConfig struct {
 	upstream   *upstream
 	downstream *downstream
 
-	silent   bool
+	silent  bool
+	verbose bool
+
 	stopOnce sync.Once
 	stopped  bool
 
 	// Used for testing
 	testing   bool
 	errorChan chan error
+	readyChan chan bool
 }
 
 // Logf prints the given information to the synclog with context data
@@ -76,7 +79,11 @@ func (s *SyncConfig) Logln(line interface{}) {
 		if s.Pod != nil {
 			syncLog.WithKey("pod", s.Pod.Name).WithKey("local", s.WatchPath).WithKey("container", s.DestPath).Info(line)
 		} else {
-			syncLog.WithKey("local", s.WatchPath).WithKey("container", s.DestPath).Info(line)
+			syncLog.
+				WithKey("local",
+					s.WatchPath).
+				WithKey("container", s.DestPath).
+				Info(line)
 		}
 	}
 }
@@ -224,6 +231,10 @@ func (s *SyncConfig) startUpstream() {
 
 	defer notify.Stop(s.upstream.events)
 
+	if s.readyChan != nil {
+		s.readyChan <- true
+	}
+
 	err = s.upstream.mainLoop()
 	if err != nil {
 		s.Error(err)