diff --git a/main.go b/main.go index 02595a7..e0e1902 100644 --- a/main.go +++ b/main.go @@ -32,7 +32,7 @@ func main() { if *debug { log.SetFlags(log.Lmicroseconds | log.Lshortfile) - logFile, err := os.Create("main.log") + logFile, err := os.Create("cln.log") if err != nil { log.Printf("Error creating log file: %v", err) os.Exit(1) diff --git a/sync.yaml b/sync.yaml index fac5f43..8b8b261 100644 --- a/sync.yaml +++ b/sync.yaml @@ -1,10 +1,2 @@ -- source: main.go - target: test/main.go - -- source: README.md - target: test/README.md - -- source: sync.yaml - target: test/sync.yaml - - +- source: * + target: test/ \ No newline at end of file diff --git a/util.go b/util.go index 6a456fa..065d9d3 100644 --- a/util.go +++ b/util.go @@ -104,7 +104,7 @@ func GetSyncFilesRecursively(input string, output chan string, status chan error dirCount) case <-done: // Final progress update - fmt.Printf("\rFiles processed: %d; Folders processed: %d; Completed successfully\n", + fmt.Printf("\nFiles processed: %d; Folders processed: %d; Completed successfully\n", atomic.LoadInt32(&filesProcessed), atomic.LoadInt32(&foldersProcessed)) return @@ -115,6 +115,8 @@ func GetSyncFilesRecursively(input string, output chan string, status chan error allDone := make(chan struct{}) go func() { + // WTF is this waitgroup? + // Nowhere is it added... var wg sync.WaitGroup go func() { @@ -126,7 +128,7 @@ func GetSyncFilesRecursively(input string, output chan string, status chan error return } } - time.Sleep(50 * time.Millisecond) + time.Sleep(50 * time.Millisecond) } }() @@ -171,7 +173,7 @@ func processDirectory(directory string, directories chan<- string, output chan<- if file.IsDir() { directories <- filepath.Join(directory, file.Name()) } else { - if FileRegex.MatchString(file.Name()) || IsYAMLSyncFile(file.Name()) { + if IsYAMLSyncFile(file.Name()) { output <- filepath.Join(directory, file.Name()) } atomic.AddInt32(filesProcessed, 1)