Rework integration project

Author: ethanhann

src/InEngine.Commands/AlwaysSucceed.cs

@@ -9,6 +9,7 @@ public class AlwaysSucceed : AbstractCommand
     {
         public override void Run()
         {
+            Info("Ths command always succeeds.");
         }
     }
 }

src/InEngine.Commands/CommandsPlugin.cs

@@ -1,5 +1,9 @@
-using CommandLine;
+using System;
+using System.Collections.Generic;
+using CommandLine;
 using InEngine.Core;
+using InEngine.Core.Commands;
+using InEngine.Core.Scheduling;
 
 namespace InEngine.Commands
 {
@@ -10,5 +14,29 @@ public class CommandsPlugin : AbstractPlugin
 
         [VerbOption("succeed", HelpText = "A null operation command. Literally does nothing.")]
         public AlwaysSucceed Null { get; set; }
+
+        public override void Schedule(ISchedule schedule)
+        {
+            schedule.Command(new Echo { VerbatimText = "Core Echo command." })
+                    .EverySecond()
+                    .Before(x => Console.WriteLine("Before"))
+                    .After(x => Console.WriteLine("After"))
+                    .PingBefore("http://www.google.com")
+                    .PingAfter("http://www.google.com")
+                    .WriteOutputTo("AlwaysSucceedWrite.log")
+                    .AppendOutputTo("AlwaysSucceedAppend.log")
+                    .EmailOutputTo("example@inengine.net");
+
+            schedule.Command(new[] {
+                new Echo { VerbatimText = "Chain Link 1" },
+                new Echo { VerbatimText = "Chain Link 2" },
+            }).EverySecond();
+
+            schedule.Command(new List<AbstractCommand> {
+                new Echo { VerbatimText = "Chain Link A" },
+                new AlwaysFail(),
+                new Echo { VerbatimText = "Chain Link C" },
+            }).EverySecond();
+        }
     }
 }

src/InEngine.Core/ServerHost.cs

@@ -1,27 +1,26 @@
 using System;
+using InEngine.Core.IO;
 using InEngine.Core.Queuing;
 using InEngine.Core.Scheduling;
 
 namespace InEngine.Core
 {
-    public class ServerHost : IDisposable
+    public class ServerHost : IDisposable, IHasMailSettings, IHasQueueSettings
     {
         public SuperScheduler SuperScheduler { get; set; }
         public Dequeue Dequeue { get; set; }
-        public InEngineSettings InEngineSettings { get; set; }
+        public MailSettings MailSettings { get; set; }
+        public QueueSettings QueueSettings { get; set; }
 
-        public ServerHost()
+        public void Start()
         {
             SuperScheduler = new SuperScheduler();
-            SuperScheduler.Initialize(InEngineSettings.Mail);
+            SuperScheduler.Initialize(MailSettings);
             Dequeue = new Dequeue() {
-                QueueSettings = InEngineSettings.Queue,
-                MailSettings = InEngineSettings.Mail,
+                QueueSettings = QueueSettings,
+                MailSettings = MailSettings,
             };
-        }
 
-        public void Start()
-        {
             SuperScheduler.Start();
             StartDequeueAsync();
         }

src/InEngine.IntegrationTest/InEngine.IntegrationTest.csproj

@@ -43,7 +43,6 @@
     <Compile Include="Program.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="QueuingTest.cs" />
-    <Compile Include="SchedulingTest.cs" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\InEngine.Core\InEngine.Core.csproj">

src/InEngine.IntegrationTest/Program.cs

@@ -1,4 +1,5 @@
 using System;
+using InEngine.Core;
 
 namespace InEngine.IntegrationTest
 {
@@ -7,14 +8,21 @@ class MainClass
         public static void Main(string[] args)
         {
             Console.WriteLine("------------------------------------------------------------");
-            Console.WriteLine("Queuing Integration Tests");
+            Console.WriteLine("Queue Integration Tests");
             Console.WriteLine("------------------------------------------------------------");
             new QueuingTest().Run();
 
             Console.WriteLine("------------------------------------------------------------");
-            Console.WriteLine("Scheduling Integration Tests");
+            Console.WriteLine("Start Server...");
             Console.WriteLine("------------------------------------------------------------");
-            new SchedulingTest().Run();
+            var settings = InEngineSettings.Make();
+            var serverHost = new ServerHost() {
+                MailSettings = settings.Mail,
+                QueueSettings = settings.Queue,
+            };
+            serverHost.Start();
+            Console.ReadLine();
+            serverHost.Dispose();
         }
     }   
 }

src/InEngine.IntegrationTest/QueuingTest.cs

@@ -29,11 +29,7 @@ public override void Run()
                 QueueSettings = settings.Queue,
                 MailSettings = settings.Mail,
             }.Run();
-            var consume = new Consume { 
-                Count = 1000,
-                QueueSettings = settings.Queue,
-                MailSettings = settings.Mail,
-            };
+ 
 
             Enqueue.Command(() => Console.WriteLine("Core lambda command."))
                    .Dispatch();
@@ -82,8 +78,6 @@ public override void Run()
             Enqueue.Commands(Enumerable.Range(0, 10).Select(x => new AlwaysSucceed() as AbstractCommand).ToList())
                    .Dispatch();
 
-            consume.Run();
-
             var queueWriteIntegrationTest = "queueWriteIntegrationTest.txt";
             var queueAppendIntegrationTest = "queueAppendIntegrationTest.txt";
             File.Delete(queueWriteIntegrationTest);
@@ -98,8 +92,6 @@ public override void Run()
                    .WriteOutputTo(queueWriteIntegrationTest)
                    .AppendOutputTo(queueAppendIntegrationTest)
                    .Dispatch();
-
-            consume.Run();
         }
     }
 }

src/InEngine.IntegrationTest/SchedulingTest.cs

@@ -1,8 +1,10 @@
 {
   "InEngine": {
     "Plugins": {
+      "InEngine.Commands": ""
     },
     "ExecWhitelist": {
+      "ls":  "/bin/ls"
     },
     "Mail": {
       "Host": "localhost",

src/InEngine.IntegrationTest/appsettings.json

@@ -27,8 +27,10 @@ static void Main(string[] args)
         /// </summary>
         public static void RunServer()
         {
+            var settings = InEngineSettings.Make();
             ServerHost = new ServerHost() {
-                InEngineSettings = InEngineSettings.Make()
+                MailSettings = settings.Mail,
+                QueueSettings = settings.Queue,
             };
             if (Type.GetType("Mono.Runtime") != null) {
                 ServerHost.Start();

src/InEngine/Program.cs

@@ -1,10 +1,8 @@
 {
   "InEngine": {
     "Plugins": {
-      "InEngine.Commands": ""
     },
     "ExecWhitelist": {
-      "ls": "/bin/ls"
     },
     "Mail": {
       "Host": "localhost",