Add v2 core code

Author: ethanhann

src/InEngine.Commands/InEngine.Commands.csproj

@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
+    <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
+    <ProjectGuid>{74CA3917-E2F3-4C75-96AF-156BC52C4C5E}</ProjectGuid>
+    <OutputType>Library</OutputType>
+    <RootNamespace>InEngine.Commands</RootNamespace>
+    <AssemblyName>InEngine.Commands</AssemblyName>
+    <TargetFrameworkVersion>v4.6.2</TargetFrameworkVersion>
+  </PropertyGroup>
+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
+    <DebugSymbols>true</DebugSymbols>
+    <DebugType>full</DebugType>
+    <Optimize>false</Optimize>
+    <OutputPath>bin\Debug</OutputPath>
+    <DefineConstants>DEBUG;</DefineConstants>
+    <ErrorReport>prompt</ErrorReport>
+    <WarningLevel>4</WarningLevel>
+    <ConsolePause>false</ConsolePause>
+  </PropertyGroup>
+  <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
+    <Optimize>true</Optimize>
+    <OutputPath>bin\Release</OutputPath>
+    <ErrorReport>prompt</ErrorReport>
+    <WarningLevel>4</WarningLevel>
+    <ConsolePause>false</ConsolePause>
+  </PropertyGroup>
+  <ItemGroup>
+    <Reference Include="System" />
+    <Reference Include="System.ComponentModel.DataAnnotations" />
+  </ItemGroup>
+  <ItemGroup>
+    <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="Sample\Minimal.cs" />
+    <Compile Include="Sample\ShowProgress.cs" />
+    <Compile Include="Sample\SayHello.cs" />
+  </ItemGroup>
+  <ItemGroup>
+    <Folder Include="Sample\" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\InEngine.Core\InEngine.Core.csproj">
+      <Project>{1C604C4F-3F98-483C-89E3-C951BE03366A}</Project>
+      <Name>InEngine.Core</Name>
+    </ProjectReference>
+  </ItemGroup>
+  <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
+</Project>

src/InEngine.Commands/Properties/AssemblyInfo.cs

@@ -0,0 +1,26 @@
+using System.Reflection;
+using System.Runtime.CompilerServices;
+
+// Information about this assembly is defined by the following attributes. 
+// Change them to the values specific to your project.
+
+[assembly: AssemblyTitle("InEngine.Commands")]
+[assembly: AssemblyDescription("")]
+[assembly: AssemblyConfiguration("")]
+[assembly: AssemblyCompany("")]
+[assembly: AssemblyProduct("")]
+[assembly: AssemblyCopyright("${AuthorCopyright}")]
+[assembly: AssemblyTrademark("")]
+[assembly: AssemblyCulture("")]
+
+// The assembly version has the format "{Major}.{Minor}.{Build}.{Revision}".
+// The form "{Major}.{Minor}.*" will automatically update the build and revision,
+// and "{Major}.{Minor}.{Build}.*" will update just the revision.
+
+[assembly: AssemblyVersion("1.0.*")]
+
+// The following attributes are used to specify the signing key for the assembly, 
+// if desired. See the Mono documentation for more information about signing.
+
+//[assembly: AssemblyDelaySign(false)]
+//[assembly: AssemblyKeyFile("")]

src/InEngine.Commands/Sample/Minimal.cs

@@ -0,0 +1,19 @@
+using InEngine.Core;
+
+namespace InEngine.Commands.Sample
+{
+    /*
+     * At a minimum, a command must implement the ICommand interface.
+     *
+     * A command result must be returned from the Run method.
+     * The command result has an optional message. This is especially helpful
+     * when the command does not finish successfully.
+     */
+    public class Minimal : ICommand
+    {
+        public CommandResult Run()
+        {
+            return new CommandResult(true);
+        }
+    }
+}

src/InEngine.Commands/Sample/SayHello.cs

@@ -0,0 +1,14 @@
+using InEngine.Core;
+using System;
+
+namespace InEngine.Commands.Sample
+{
+    public class SayHello : AbstractCommand
+    {
+        public override CommandResult Run()
+        {
+            Console.WriteLine("hello...");
+            return new CommandResult(true);
+        }
+    }
+}

src/InEngine.Commands/Sample/ShowProgress.cs

@@ -0,0 +1,31 @@
+using InEngine.Core;
+
+namespace InEngine.Commands.Sample
+{
+    /*
+     * The AbstractCommand class adds functionality, including a logger and a 
+     * progress bar.
+     */
+    public class ShowProgress : AbstractCommand
+    {
+        /*
+         * Note that the override keyword is necessary in the Run method 
+         * signature as the base class method is virtual.
+         */
+        public override CommandResult Run()
+        {
+            // Define the ticks (aka steps) for the command...
+            var maxTicks = 100000;
+            SetProgressBarMaxTicks(maxTicks);
+
+            // Do some work...
+            for (var i = 0; i <= maxTicks;i++)
+            {
+                // Update the command's progress
+                UpdateProgress(i);
+            }
+
+            return new CommandResult(true);
+        }
+    }
+}

src/InEngine.Core/AbstractCommand.cs

@@ -0,0 +1,42 @@
+using Konsole;
+using NLog;
+using Quartz;
+
+namespace InEngine.Core
+{
+    abstract public class AbstractCommand : ICommand, IJob
+    {
+        public IJobExecutionContext JobExecutionContext { get; set; }
+        public Logger Logger { get; internal set; }
+        public ProgressBar ProgressBar { get; internal set; }
+        string _name;
+        public string Name
+        {
+            get { return _name; }
+            set
+            {
+                _name = value;
+                Logger = LogManager.GetLogger(_name);
+            }
+        }
+
+        protected AbstractCommand()
+        {
+            Name = GetType().FullName;
+        }
+
+        public virtual CommandResult Run()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void SetProgressBarMaxTicks(int maxTicks) => ProgressBar = new ProgressBar(maxTicks);
+        public void UpdateProgress(int tick) => ProgressBar.Refresh(tick, Name);
+
+        public void Execute(IJobExecutionContext context)
+        {
+            JobExecutionContext = context;
+            Run();
+        }
+    }
+}

src/InEngine.Core/CommandResult.cs

@@ -0,0 +1,14 @@
+namespace InEngine.Core
+{
+    public class CommandResult
+    {
+        public bool IsSuccessful { get; set; }
+        public string Message { get; set; }
+
+        public CommandResult(bool isSuccssful, string message = "")
+        {
+            IsSuccessful = isSuccssful;
+            Message = message;
+        }
+    }
+}

src/InEngine.Core/Config.cs

@@ -0,0 +1,26 @@
+using System;
+using System.Configuration;
+using InEngine.Core.Queue;
+
+namespace InEngine.Core
+{
+    public class Config
+    {
+        public static string QueueName { get { return GetString("QueueName", "InEngine:Queue"); } set => throw new NotImplementedException(); }
+        public static string RedisHost { get { return GetString("RedisHost", "localhost"); } set => throw new NotImplementedException(); }
+        public static int RedisPort { get { return GetInt("RedisDb", 6379); } set => throw new NotImplementedException(); }
+        public static int RedisDb { get { return GetInt("RedisDb", 0); } set => throw new NotImplementedException(); }
+        public static string RedisPassword { get { return GetString("RedisHist"); } set => throw new NotImplementedException(); }
+
+        public static int GetInt(string key, int defaultValue = 0)
+        {
+            var val = ConfigurationManager.AppSettings[key];
+            return val == null ? defaultValue : Convert.ToInt32(val);
+        }
+
+        public static string GetString(string key, string defaultValue = "")
+        {
+            return ConfigurationManager.AppSettings[key] ?? defaultValue;
+        }
+    }
+}

src/InEngine.Core/Exceptions/CommandFailedException.cs

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

src/InEngine.Core/ICommand.cs

@@ -0,0 +1,7 @@
+namespace InEngine.Core
+{
+    public interface ICommand
+    {
+        CommandResult Run();
+    }
+}