syncthing debug
This commit is contained in:
		
							
								
								
									
										9
									
								
								main.go
									
									
									
									
									
								
							
							
						
						
									
										9
									
								
								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 {
 | 
			
		||||
 | 
			
		||||
		Reference in New Issue
	
	Block a user