Rework Options

Author: ethanhann

src/InEngine.Commands/Options.cs renamed to src/InEngine.Commands/CommandsPlugin.cs

@@ -1,21 +1,14 @@
 using CommandLine;
-using CommandLine.Text;
 using InEngine.Core;
 
 namespace InEngine.Commands
 {
-    public class Options : IOptions
+    public class CommandsPlugin : AbstractPlugin
     {
         [VerbOption("fail", HelpText = "Always fail. Useful for end-to-end testing.")]
         public AlwaysFail AlwaysFail { get; set; }
 
         [VerbOption("succeed", HelpText = "A null operation command. Literally does nothing.")]
         public AlwaysSucceed Null { get; set; }
-
-        [HelpVerbOption]
-        public string GetUsage(string verb)
-        {
-            return HelpText.AutoBuild(this, verb);
-        }
     }
 }

src/InEngine.Commands/Sample/Options.cs renamed to src/InEngine.Commands/Sample/RegisterCommands.cs

@@ -1,11 +1,9 @@
 using CommandLine;
-using CommandLine.Text;
-using InEngine.Commands.Sample;
 using InEngine.Core;
 
-namespace InEngine.Commands
+namespace InEngine.Commands.Sample
 {
-    public class MoreOptions : IOptions
+    public class RegisterCommands : AbstractPlugin
     {
         [VerbOption("sample:show-progress", HelpText = "A sample command to demonstrate the progress bar.")]
         public ShowProgress ShowProgress { get; set; }
@@ -15,11 +13,5 @@ public class MoreOptions : IOptions
 
         [VerbOption("sample:minimal")]
         public Minimal Minimal { get; set; }
-
-        [HelpVerbOption]
-        public string GetUsage(string verb)
-        {
-            return HelpText.AutoBuild(this, verb);
-        }
     }
 }

src/InEngine.Core/AbstractPlugin.cs

@@ -0,0 +1,15 @@
+using System;
+using CommandLine;
+using CommandLine.Text;
+
+namespace InEngine.Core
+{
+    public class AbstractPlugin : IPluginType
+    {
+        [HelpVerbOption]
+        public virtual string GetUsage(string verb)
+        {
+            return HelpText.AutoBuild(this, verb);
+        }
+    }
+}

src/InEngine.Core/Commands/Options.cs renamed to src/InEngine.Core/Commands/CommandsPlugin.cs

@@ -1,20 +1,13 @@
 using CommandLine;
-using CommandLine.Text;
 
 namespace InEngine.Core.Commands
 {
-    public class Options : IOptions
+    public class CommandPlugin : AbstractPlugin
     {
         [VerbOption("echo", HelpText= "Echo some text to the console. Useful for end-to-end testing.")]
         public Echo Echo { get; set; }
 
         [VerbOption("proc", HelpText = "Launch an arbitrary process.")]
         public SystemProcess SystemProcess { get; set; }
-
-        [HelpVerbOption]
-        public string GetUsage(string verb)
-        {
-            return HelpText.AutoBuild(this, verb);
-        }
     }
 }

src/InEngine.Core/IOptions.cs

@@ -82,7 +82,7 @@ public AbstractCommand CreateCommandFromClass(string fullCommandName)
         public AbstractCommand CreateCommandFromVerb(string verbName)
         {
             var commandClassNames = new List<string>();
-            var optionsList = Make<IOptions>();
+            var optionsList = Make<AbstractPlugin>();
 
             foreach (var options in optionsList)
                 foreach (var property in options.GetType().GetProperties())

src/InEngine.Core/Plugin.cs

@@ -1,10 +1,9 @@
 using CommandLine;
 using CommandLine.Text;
-using InEngine.Core.Queuing.Commands;
 
-namespace InEngine.Core.Queuing
+namespace InEngine.Core.Queuing.Commands
 {
-    public class Options : IOptions
+    public class RegisterCommands : AbstractPlugin
     {
         [VerbOption("queue:publish", HelpText = "Publish a command commandEnvelope to a queue.")]
         public Publish Publish { get; set; }
@@ -23,11 +22,5 @@ public class Options : IOptions
 
         [VerbOption("queue:peek", HelpText = "Peek at messages in the primary or secondary queues.")]
         public Peek Peek { get; set; }
-
-        [HelpVerbOption]
-        public string GetUsage(string verb)
-        {
-            return HelpText.AutoBuild(this, verb);
-        }
     }
 }

src/InEngine.Core/Queuing/Options.cs renamed to src/InEngine.Core/Queuing/Commands/RegisterCommands.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Linq;
+using InEngine.Core.Queuing.Commands;
+using InEngine.Core.Scheduling;
+
+namespace InEngine.Core.Queuing
+{
+    public class QueuingPlugin : AbstractPlugin
+    {
+        public void Schedule(ISchedule schedule)
+        {
+            var queueSettings = InEngineSettings.Make().Queue;
+            ScheduleQueueConsumerJobs(schedule, queueSettings.PrimaryQueueConsumers);
+            ScheduleQueueConsumerJobs(schedule, queueSettings.SecondaryQueueConsumers, true);
+        }
+
+        void ScheduleQueueConsumerJobs(ISchedule schedule, int consumers, bool useSecondaryQueue = false)
+        {
+            if (consumers < 0)
+                throw new ArgumentOutOfRangeException(nameof(consumers), consumers, "The number of queue consumers must be 0 or greater.");
+
+            foreach (var index in Enumerable.Range(0, consumers).ToList())
+                schedule.Command(new Consume()
+                {
+                    ScheduleId = $"{(useSecondaryQueue ? "secondary" : "primary")}:{index.ToString()}",
+                    UseSecondaryQueue = useSecondaryQueue
+                })
+                .EverySecond();
+        }
+    }
+}

src/InEngine.Core/Queuing/QueuingPlugin.cs

@@ -0,0 +1,10 @@
+using CommandLine;
+
+namespace InEngine.Core.Scheduling
+{
+    public class CommandsPlugin : AbstractPlugin
+    {
+        [VerbOption("schedule:list", HelpText = "List all scheduled jobs.")]
+        public ListScheduledCommands ListScheduledCommands { get; set; }
+    }
+}