From 21e4b54f38c0155a3ee0660def803d5362ffab39 Mon Sep 17 00:00:00 2001 From: Tordarus Date: Thu, 16 Jan 2025 13:16:12 +0100 Subject: [PATCH] syncthing debug --- main.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/main.go b/main.go index 6e2bbbf..2570db7 100644 --- a/main.go +++ b/main.go @@ -66,6 +66,15 @@ func main() { }) filesByGroup := channel.FlatMap(groupedFiles, func(key string, _ struct{}) string { return key }) + + filesByGroup = channel.MapSuccessive(filesByGroup, func(s string) string { + fmt.Println("GROUPED", s) + fmt.Println("EXISTS", Exists(s)) + fmt.Println("SymlinkFilesOnly", SymlinkFilesOnly(s)) + fmt.Println("VideosOnly", VideosOnly(s)) + return s + }) + filteredFiles := channel.Filter(filesByGroup, Or(Not(Exists), And(SymlinkFilesOnly, VideosOnly))) filteredFiles = channel.MapSuccessive(filteredFiles, func(s string) string {