fix: add file to the temp list also on the first check

Author: Matrix86

dropbox.go

@@ -142,9 +142,10 @@ func (w *DropboxWatcher) sync(firstSync bool) {
 
 	fileList := make(map[string]*DropboxObject, 0)
 	err := w.enumerateFiles(w.watchDir, func(obj *DropboxObject) bool {
+		// Store the files to check the deleted one
+		fileList[obj.Key] = obj
+
 		if !firstSync {
-			// Store the files to check the deleted one
-			fileList[obj.Key] = obj
 			// Check if the object is cached by Key
 			cached := w.getCachedObject(obj)
 			// Object has been cached previously by Key

gdrive.go

@@ -128,10 +128,10 @@ func (w *GDriveWatcher) sync(firstSync bool) {
 	fileList := make(map[string]*GDriveObject, 0)
 
 	err := w.enumerateFiles(w.watchDir, func(obj *GDriveObject) bool {
+		// Store the files to check the deleted one
+		fileList[obj.ID] = obj
 		// With the first sync we need to cache all the files
 		if !firstSync {
-			// Store the files to check the deleted one
-			fileList[obj.ID] = obj
 			// Check if the object is cached by Key
 			cached := w.getCachedObject(obj)
 			// Object has been cached previously by Key

local.go

@@ -233,9 +233,9 @@ func (w *LocalWatcher) sync(firstSync bool) {
 			FileMode:     fi.Mode(),
 		}
 
-		if !firstSync {
-			fileList[walkPath] = obj
+		fileList[walkPath] = obj
 
+		if !firstSync {
 			// Check if the object is cached by Key
 			cached := w.getCachedObject(obj)
 			// Object has been cached previously by Key
@@ -276,18 +276,16 @@ func (w *LocalWatcher) sync(firstSync bool) {
 		return
 	}
 
-	if len(fileList) != 0 {
-		for k, o := range w.cache {
-			if _, found := fileList[k]; !found {
-				// file not found in the list...deleting it
-				delete(w.cache, k)
-				event := Event{
-					Key:    o.Key,
-					Type:   FileDeleted,
-					Object: o,
-				}
-				w.Events <- event
+	for k, o := range w.cache {
+		if _, found := fileList[k]; !found {
+			// file not found in the list...deleting it
+			delete(w.cache, k)
+			event := Event{
+				Key:    o.Key,
+				Type:   FileDeleted,
+				Object: o,
 			}
+			w.Events <- event
 		}
 	}
 }

s3.go

@@ -168,10 +168,10 @@ func (u *S3Watcher) sync(firstSync bool) {
 			return true // continue
 		}
 
-		if !firstSync {
-			// Store the files to check the deleted one
-			fileList[upd.Key] = upd
+		// Store the files to check the deleted one
+		fileList[upd.Key] = upd
 
+		if !firstSync {
 			// Check if the object is cached by Key
 			cached := u.getCachedObject(upd)
 			// Object has been cached previously by Key
@@ -212,16 +212,18 @@ func (u *S3Watcher) sync(firstSync bool) {
 		return
 	}
 
-	for k, o := range u.cache {
-		if _, found := fileList[k]; !found {
-			// file not found in the list...deleting it
-			delete(u.cache, k)
-			event := Event{
-				Key:    o.Key,
-				Type:   FileDeleted,
-				Object: o,
+	if !firstSync {
+		for k, o := range u.cache {
+			if _, found := fileList[k]; !found {
+				// file not found in the list...deleting it
+				delete(u.cache, k)
+				event := Event{
+					Key:    o.Key,
+					Type:   FileDeleted,
+					Object: o,
+				}
+				u.Events <- event
 			}
-			u.Events <- event
 		}
 	}
 }