Flesh out execution life cycle actions

Author: ethanhann

src/InEngine.Core/AbstractCommand.cs

@@ -1,15 +1,17 @@
 using System;
 using System.Linq;
+using InEngine.Core.Exceptions;
 using InEngine.Core.IO;
 using InEngine.Core.Scheduling;
 using Konsole;
 using Quartz;
+using RestSharp;
 
 namespace InEngine.Core
 {
     abstract public class AbstractCommand : ICommand, IFailed, IJob, IWrite
     {
-        public LifecycleActions LifecycleActions { get; set; }
+        public ExecutionLifeCycle ExecutionLifeCycle { get; set; }
         public Write Write { get; set; }
         public ProgressBar ProgressBar { get; internal set; }
         public string Name { get; set; }
@@ -22,7 +24,7 @@ protected AbstractCommand()
             Name = GetType().FullName;
             SchedulerGroup = GetType().AssemblyQualifiedName;
             Write = new Write();
-            LifecycleActions = new LifecycleActions();
+            ExecutionLifeCycle = new ExecutionLifeCycle();
         }
 
         public virtual void Run()
@@ -57,9 +59,9 @@ public void Execute(IJobExecutionContext context)
 
             try
             {
-                LifecycleActions.BeforeAction?.Invoke(this);
+                ExecutionLifeCycle.FirePreActions(this);
                 Run();
-                LifecycleActions.AfterAction?.Invoke(this);
+                ExecutionLifeCycle.FirePostActions(this);
             }
             catch (Exception exception)
             {
@@ -124,6 +126,16 @@ public IWrite Newline(int count = 1)
         {
             return Write.Newline(count);
         }
+
+        public string FlushBuffer()
+        {
+            return Write.FlushBuffer();
+        }
+
+        public void ToFile(string path, string text, bool shouldAppend = false)
+        {
+            Write.ToFile(path, text, shouldAppend);
+        }
         #endregion
     }
 }

src/InEngine.Core/Exceptions/LifecycleActionFailedException.cs

@@ -0,0 +1,10 @@
+using System;
+
+namespace InEngine.Core.Exceptions
+{
+    public class LifecycleActionFailedException : Exception
+    {
+        public LifecycleActionFailedException(string message, Exception exception) : base(message, exception)
+        {}
+    }
+}

src/InEngine.Core/IO/Http.cs

@@ -0,0 +1,12 @@
+using RestSharp;
+
+namespace InEngine.Core.IO
+{
+    public class Http
+    {
+        public string Get(string url)
+        {
+            return new RestClient(url).Execute(new RestRequest(string.Empty, Method.GET)).Content;
+        }
+    }
+}

src/InEngine.Core/IO/IWrite.cs

@@ -16,5 +16,8 @@ public interface IWrite
         IWrite ErrorText(string val);
         IWrite Text(string val);
         IWrite ColoredText(string val, ConsoleColor consoleColor);
+
+        string FlushBuffer();
+        void ToFile(string path, string text, bool shouldAppend = false);
     }
 }

src/InEngine.Core/IO/Mail.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Net.Mail;
+
+namespace InEngine.Core.IO
+{
+    public class Mail
+    {
+        public string Host { get; set; }
+        public int Port { get; set; }
+
+        public void Send(string fromAddress, string toAddress, string subject, string body)
+        {
+            new SmtpClient() {
+                Host = Host,
+                Port = Port
+            }.Send(new MailMessage(fromAddress, toAddress, subject, body));
+        }
+    }
+}

src/InEngine.Core/IO/Write.cs

@@ -1,13 +1,20 @@
 using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading;
 
 namespace InEngine.Core.IO
 {
     public class Write : IWrite
     {
+        static Mutex mutexLock = new Mutex();
+
         public ConsoleColor InfoColor { get; set; } = ConsoleColor.Green;
         public ConsoleColor WarningColor { get; set; } = ConsoleColor.Yellow;
         public ConsoleColor ErrorColor { get; set; } = ConsoleColor.Red;
         public ConsoleColor LineColor { get; set; } = ConsoleColor.White;
+        public List<string> Buffer { get; set; } = new List<string>();
 
         public IWrite Newline(int count = 1)
         {
@@ -38,9 +45,12 @@ public IWrite Line(string val)
 
         public IWrite ColoredLine(string val, ConsoleColor consoleColor)
         {
+            mutexLock.WaitOne();
             Console.ForegroundColor = consoleColor;
             Console.WriteLine(val);
             Console.ResetColor();
+            mutexLock.ReleaseMutex();
+            Buffer.Add(val);
             return this;
         }
 
@@ -66,10 +76,30 @@ public IWrite Text(string val)
 
         public IWrite ColoredText(string val, ConsoleColor consoleColor)
         {
+            mutexLock.WaitOne();
             Console.ForegroundColor = consoleColor;
             Console.Write(val);
             Console.ResetColor();
+            mutexLock.ReleaseMutex();
+            Buffer.Add(val);
             return this;
         }
+
+        public string FlushBuffer()
+        {
+            var str = string.Join("\n", Buffer);
+            Buffer.Clear();
+            return str;
+        }
+
+        public void ToFile(string path, string text, bool shouldAppend = false)
+        {
+            if (!File.Exists(path))
+                File.Create(path);
+            if (shouldAppend)
+                File.AppendAllText(path, text);
+            else
+                File.WriteAllText(path, text);
+        }
     }
 }

src/InEngine.Core/InEngine.Core.csproj

@@ -27,6 +27,7 @@
     <PackageReference Include="StackExchange.Redis" Version="1.2.4" />
     <PackageReference Include="Goblinfactory.Konsole" Version="3.1.0" />
     <PackageReference Include="EntityFramework" Version="6.2.0" />
+    <PackageReference Include="RestSharp" Version="106.1.0" />
   </ItemGroup>
   <ItemGroup>
     <Folder Include="Scheduling\" />

src/InEngine.Core/InEngineSettings.cs

@@ -11,6 +11,7 @@ public class InEngineSettings
         public static string ConfigurationFile { get; set; } = "appsettings.json";
         public List<string> Plugins { get; set; } = new List<string>();
         public QueueSettings Queue { get; set; }
+        public MailSettings Mail { get; set; }
 
         public static InEngineSettings Make()
         {

src/InEngine.Core/MailSettings.cs

@@ -0,0 +1,10 @@
+using System;
+namespace InEngine.Core
+{
+    public class MailSettings
+    {
+        public string Host { get; set; }
+        public int Port { get; set; }
+        public string From { get; set; }
+    }
+}

src/InEngine.Core/Queuing/Commands/Consume.cs

@@ -13,10 +13,10 @@ public class Consume : AbstractCommand
 
         public override void Run()
         {
-            var broker = Queue.Make(UseSecondaryQueue);
+            var queue = Queue.Make(UseSecondaryQueue);
             var shouldConsume = true;
             while (shouldConsume)
-                shouldConsume = broker.Consume() && ShouldConsumeAll;
+                shouldConsume = queue.Consume() && ShouldConsumeAll;
         }
 
         public override void Failed(Exception exception)