Make queue consumption truly async

Author: ethanhann

src/InEngine.Core/InEngine.Core.csproj

@@ -3,7 +3,7 @@
     <TargetFramework>net6.0</TargetFramework>
   </PropertyGroup>
   <PropertyGroup>
-    <Version>4.0.1</Version>
+    <Version>5.0.0</Version>
     <FileVersion>5.0.0</FileVersion>
     <Authors>Ethan Hann</Authors>
     <Description>Plugin-based queuing and scheduling command server.</Description>

src/InEngine.Core/ServerHost.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Threading.Tasks;
 using InEngine.Core.IO;
 using InEngine.Core.Queuing;
 using InEngine.Core.Scheduling;
@@ -13,7 +14,7 @@ public class ServerHost : IDisposable, IHasMailSettings, IHasQueueSettings
     public QueueSettings QueueSettings { get; set; }
     private bool isDisposed; 
 
-    public void Start()
+    public async Task StartAsync()
     {
         SuperScheduler = new SuperScheduler();
         SuperScheduler.Initialize(MailSettings);
@@ -24,11 +25,9 @@ public void Start()
         };
 
         SuperScheduler.Start();
-        StartDequeueAsync();
+        await Dequeue.StartAsync();
     }
 
-    public async void StartDequeueAsync() => await Dequeue.StartAsync();
-
     public void Dispose()
     {
         Dispose(true);

src/InEngine/ArgumentInterpreter.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Threading.Tasks;
 using CommandLine;
 using InEngine.Core;
 using InEngine.Core.Exceptions;
@@ -21,7 +22,7 @@ public ArgumentInterpreter()
         CliLogo = resources.cliLogo;
     }
 
-    public void Interpret(string[] args)
+    public async Task Interpret(string[] args)
     {
         var pluginAssemblies = PluginAssembly.Load<AbstractPlugin>();
         var parser = new Parser(with => {
@@ -42,7 +43,7 @@ public void Interpret(string[] args)
         {
             Write.Info(CliLogo);
             Write.Line("Starting...").Newline();
-            Program.RunServer();
+            await Program.RunServerAsync();
             ExitWithSuccess();
         }
 

src/InEngine/Program.cs

@@ -1,5 +1,6 @@
 using System;
 using System.IO;
+using System.Threading.Tasks;
 using InEngine.Core;
 
 namespace InEngine;
@@ -8,17 +9,17 @@ public static class Program
 {
     public static ServerHost ServerHost { get; set; }
 
-    private static void Main(string[] args)
+    private static async Task Main(string[] args)
     {
         /*
          * Set current working directory as services use the system directory by default.
          * Also, allow running the CLI from a different directory than the application root.
          */
         Directory.SetCurrentDirectory(AppDomain.CurrentDomain.BaseDirectory);
-        new ArgumentInterpreter().Interpret(args);
+        await new ArgumentInterpreter().Interpret(args);
     }
 
-    public static void RunServer()
+    public static async Task RunServerAsync()
     {
         var settings = InEngineSettings.Make();
         ServerHost = new ServerHost
@@ -27,7 +28,7 @@ public static void RunServer()
             QueueSettings = settings.Queue,
         };
 
-        ServerHost.Start();
+        await ServerHost.StartAsync();
         Console.WriteLine(resources.foregroundServerInputPrompt);
         Console.ReadLine();
         ServerHost.Dispose();