Tranga/Jobs/JobBoss.cs

@@ -14,7 +14,6 @@ public class JobBoss : GlobalBase
         this.jobs = new();
         LoadJobsList(connectors);
         this.mangaConnectorJobQueue = new();
-        Log($"Next job in {jobs.MinBy(job => job.nextExecution)?.nextExecution.Subtract(DateTime.Now)} {jobs.MinBy(job => job.nextExecution)?.id}");
     }
 
     public void AddJob(Job job)
@@ -162,21 +161,18 @@ public class JobBoss : GlobalBase
             cachedPublications.Add(ncJob.manga);
     }
 
-    public void ExportJob(Job job)
-    {
-        string jobFilePath = Path.Join(settings.jobsFolderPath, $"{job.id}.json");
-        string jobStr = JsonConvert.SerializeObject(job);
-        while(IsFileInUse(jobFilePath))
-            Thread.Sleep(10);
-        Log($"Exporting Job {jobFilePath}");
-        File.WriteAllText(jobFilePath, jobStr);
-    }
-
     public void ExportJobsList()
     {
         Log("Exporting Jobs");
         foreach (Job job in this.jobs)
-            ExportJob(job);
+        {
+            string jobFilePath = Path.Join(settings.jobsFolderPath, $"{job.id}.json");
+            string jobStr = JsonConvert.SerializeObject(job);
+            while(IsFileInUse(jobFilePath))
+                Thread.Sleep(10);
+            Log($"Exporting Job {jobFilePath}");
+            File.WriteAllText(jobFilePath, jobStr);
+        }
 
         //Remove files with jobs not in this.jobs-list
         Regex idRex = new (@"(.*)\.json");
@@ -223,13 +219,14 @@ public class JobBoss : GlobalBase
                 }
                 queueHead.ResetProgress();
                 jobQueue.Dequeue();
-                ExportJob(queueHead);
+                ExportJobsList();
                 Log($"Next job in {jobs.MinBy(job => job.nextExecution)?.nextExecution.Subtract(DateTime.Now)} {jobs.MinBy(job => job.nextExecution)?.id}");
             }else if (queueHead.progressToken.state is ProgressToken.State.Standby)
             {
                 Job[] subJobs = jobQueue.Peek().ExecuteReturnSubTasks().ToArray();
                 AddJobs(subJobs);
                 AddJobsToQueue(subJobs);
+                ExportJobsList();
             }
         }
     }