Merge pull request #58 from julien-wff/feat-pause-jobs-software-detected

Feat pause jobs software detected

EasyGUI/Controls/SettingsPopup.xaml.cs

@@ -226,8 +226,13 @@ private void ValidateButton_OnClick(object sender, RoutedEventArgs e)
             Application.Restart();
             Process.GetCurrentProcess().Kill();
         }
+
+        // Invoke reload config event
+        ReloadConfig?.Invoke(this, EventArgs.Empty);
     }
 
+    public event EventHandler? ReloadConfig;
+
     private void SettingsPopup_OnLoaded(object sender, RoutedEventArgs e)
     {
         UpdateProperties();

EasyGUI/MainWindow.xaml

@@ -33,6 +33,7 @@
             Visibility="Collapsed" />
         <controls:SettingsPopup
             x:Name="SettingsPopup"
-            Visibility="Collapsed" />
+            Visibility="Collapsed"
+            ReloadConfig="SettingsPopup_OnReloadConfig"/>
     </Grid>
 </Window>

EasyGUI/MainWindow.xaml.cs

@@ -168,4 +168,9 @@ private void UpdateJob(Job job)
         Jobs.Remove(job);
         Jobs.Insert(jobIndex, job);
     }
+
+    private void SettingsPopup_OnReloadConfig(object? sender, EventArgs e)
+    {
+        _jobManager.ReloadConfig();
+    }
 }

EasyLib/EasyLib.csproj

@@ -7,7 +7,9 @@
     </PropertyGroup>
 
     <ItemGroup>
+        <PackageReference Include="Microsoft.Windows.Compatibility" Version="8.0.0"/>
         <PackageReference Include="Newtonsoft.Json" Version="13.0.3"/>
+        <PackageReference Include="System.Management" Version="8.0.0"/>
     </ItemGroup>
 
 </Project>

EasyLib/Events/ProcessStartEvent.cs

@@ -0,0 +1,68 @@
+using System.Management;
+
+namespace EasyLib.Events;
+
+public class ProcessStartEvent
+{
+    private readonly JobManager _jobManager;
+    private readonly ManagementEventWatcher _processStartEvent;
+    private readonly ManagementEventWatcher _processStopEvent;
+    private int _numberOfRunningProcesses;
+
+    /// <summary>
+    /// create the start and stop event for a process and bind the event to the job manager
+    /// </summary>
+    /// <param name="processName"></param>
+    /// <param name="jobManager"></param>
+    public ProcessStartEvent(string? processName, JobManager jobManager)
+    {
+        // check if system is running Windows
+        _jobManager = jobManager;
+#pragma warning disable CA1416
+        _processStartEvent =
+            new ManagementEventWatcher(
+                new WqlEventQuery($"SELECT * FROM Win32_ProcessStartTrace WHERE ProcessName = '{processName}'"));
+        _processStartEvent.EventArrived += ProcessStarted;
+        // on stop
+        _processStopEvent = new ManagementEventWatcher(new WqlEventQuery(
+            $"SELECT * FROM Win32_ProcessStopTrace WHERE ProcessName = '{processName}'"));
+        _processStopEvent.EventArrived += ProcessStopped;
+        _processStartEvent.Start();
+        _processStopEvent.Start();
+#pragma warning restore CA1416
+    }
+
+    private void ProcessStarted(object sender, EventArrivedEventArgs e)
+    {
+        if (_numberOfRunningProcesses == 0)
+        {
+            _jobManager.PauseAllJobs();
+            Interlocked.Increment(ref _numberOfRunningProcesses);
+        }
+        else
+        {
+            Interlocked.Increment(ref _numberOfRunningProcesses);
+        }
+    }
+
+    private void ProcessStopped(object sender, EventArrivedEventArgs e)
+    {
+        if (_numberOfRunningProcesses == 1)
+        {
+            _jobManager.ResumeAllJobs();
+            Interlocked.Decrement(ref _numberOfRunningProcesses);
+        }
+        else
+        {
+            Interlocked.Decrement(ref _numberOfRunningProcesses);
+        }
+    }
+
+    public void Stop()
+    {
+#pragma warning disable CA1416
+        _processStopEvent.Stop();
+        _processStartEvent.Stop();
+#pragma warning restore CA1416
+    }
+}

EasyLib/Job/Job.cs

@@ -1,4 +1,3 @@
-using System.Diagnostics;
 using EasyLib.Enums;
 using EasyLib.Events;
 using EasyLib.Files;
@@ -23,9 +22,10 @@ public class Job(
     JobState state = JobState.End) : IJobStatusPublisher, IJobStatusSubscriber
 {
     public static readonly Semaphore MaxSizeFileCopying = new Semaphore(1, 1);
-    public static ulong CurrentPriorityRunning = 0;
     public static readonly EventWaitHandle NotifyWaitingJobs = new EventWaitHandle(initialState: false, ManualReset);
 
+    public static ulong CurrentPriorityRunning;
+
     /// <summary>
     /// Create a job instance from a JsonJob object
     /// </summary>
@@ -111,6 +111,8 @@ public JsonJob ToJsonJob()
     /// <returns>True if the job is started correctly</returns>
     public bool Resume()
     {
+        CancellationToken.Dispose();
+        CancellationToken = new CancellationTokenSource();
         return Start(true);
     }
 
@@ -136,17 +138,6 @@ private bool Start(bool resume)
             return false;
         }
 
-        // Wait for the company software to be closed
-        if (ConfigManager.Instance.CheckProcessRunning())
-        {
-            var processName = Path.GetFileNameWithoutExtension(ConfigManager.Instance.CompanySoftwareProcessPath);
-            var processes = Process.GetProcessesByName(processName);
-            foreach (var process in processes)
-            {
-                process.WaitForExit();
-            }
-        }
-
         // Reset the job stats if the job is not resumed
         if (!resume)
         {
@@ -241,14 +232,13 @@ public bool Cancel()
         return true;
     }
 
-    private bool _resetJobStats()
+    private void _resetJobStats()
     {
         FilesCount = 0;
         FilesSizeBytes = 0;
         FilesCopied = 0;
         FilesBytesCopied = 0;
         State = JobState.End;
-        return true;
     }
 
     private void _notifySubscribersForChangeState(JobState subState)

EasyLib/JobManager.cs

@@ -26,6 +26,8 @@ public partial class JobManager : IJobStatusSubscriber, IJobStatusPublisher
     /// </summary>
     private readonly List<IJobStatusSubscriber> _subscribers = new();
 
+    private ProcessStartEvent _pauseJobEvent;
+
 
     public JobManager(bool ramOnly = false)
     {
@@ -34,6 +36,8 @@ public JobManager(bool ramOnly = false)
         {
             FetchJobs();
         }
+
+        _pauseJobEvent = new ProcessStartEvent(ConfigManager.Instance.CompanySoftwareProcessPath, this);
     }
 
     public void Subscribe(IJobStatusSubscriber subscriber)
@@ -279,6 +283,14 @@ public void PauseJob(Job.Job job)
         StateManager.Instance.WriteJobs(_jobs);
     }
 
+    public void PauseAllJobs()
+    {
+        foreach (var job in _jobs)
+        {
+            PauseJob(job);
+        }
+    }
+
     public JobCheckRule CheckJobRules(int id, string name, string source, string destination, bool testEmpty = true)
     {
         if (!Path.IsPathFullyQualified(source))
@@ -336,8 +348,29 @@ public JobCheckRule CheckJobRules(int id, string name, string source, string des
 
     public void ResumeJob(Job.Job job)
     {
-        job.Subscribe(this);
         job.Resume();
-        job.Unsubscribe(this);
+    }
+
+    public void ResumeAllJobs()
+    {
+        foreach (var job in _jobs)
+        {
+            if (job.State != JobState.End)
+            {
+                job.Resume();
+            }
+        }
+    }
+
+    public bool ReloadConfig()
+    {
+        if (Environment.OSVersion.Platform == PlatformID.Win32NT) // only on Windows can run this feature
+        {
+            _pauseJobEvent.Stop();
+            _pauseJobEvent = new ProcessStartEvent(ConfigManager.Instance.CompanySoftwareProcessPath, this);
+            return true;
+        }
+
+        return false;
     }
 }