track job completion and handle initial full sync

Author: andreaskueffel

FileSyncApp/Program.cs

@@ -99,7 +99,7 @@ static void RunProgram()
             }
 
             log.LogInformation("reading config file {A}", "config.json");
-            Dictionary<string, IFileJobOptions> readJobOptions=new Dictionary<string, IFileJobOptions>();
+            Dictionary<string, IFileJobOptions> readJobOptions = new Dictionary<string, IFileJobOptions>();
             try
             {
                 readJobOptions = JsonConvert.DeserializeObject<Dictionary<string, IFileJobOptions>>(File.ReadAllText("config.json"), jsonSettings);
@@ -109,17 +109,20 @@ static void RunProgram()
                 log.LogCritical(exc, "exception reading config file {A}", "config.json");
                 return;
             }
-            
+
             foreach (var jobOption in readJobOptions)
             {
-
                 jobOption.Value.Logger = LoggerFactory.CreateLogger(jobOption.Key);
                 Jobs.Add(jobOption.Key, FileSyncJob.CreateJob(jobOption.Value));
             }
             JobsReady?.Invoke(null, EventArgs.Empty);
+            Dictionary<IFileJob, bool> jobsDone = new Dictionary<IFileJob, bool>();
             foreach (var job in Jobs)
             {
+                jobsDone.Add(job.Value, false);
+                job.Value.JobFinished += (s, e) => { jobsDone[(IFileJob)s] = true; if (jobsDone.All(x => x.Value)) if (!File.Exists("fullsync.done")) File.Create("fullsync.done"); };
                 job.Value.StartJob();
+
             }
             log.LogInformation("Press Ctrl+C to exit");
             while (keepRunning)

FileSyncLibNet/FileSyncJob/FileSyncJob.cs

@@ -18,6 +18,7 @@ public class FileSyncJob : IFileJob
         private readonly Timer timer;
         private readonly ISyncProvider syncProvider;
         private volatile bool v_jobRunning = false;
+        public static bool InitialFullSync { get; set; } = false;
 
         private FileSyncJob(IFileJobOptions fileSyncJobOptions)
         {

FileSyncLibNet/SyncProviders/AbstractProvider.cs

@@ -117,6 +117,11 @@ public override void SyncSourceToDest()
                     DateTimeOffset.MinValue :
                     DateTimeOffset.Now - jobOptions.MaxAge - jobOptions.Interval;
             }
+            if (!System.IO.File.Exists("fullsync.done"))
+            {
+                logger.LogWarning("fullsync.done not found, syncing all files for initial run");
+                minimumLastWriteTime = DateTimeOffset.MinValue;
+            }
 
             bool error_occured = false;
             try