Merge pull request #3 from conductor-oss/feature/csharp-worker

C# worker template

Author: mp-orkes

csharp/worker/core/README.md

@@ -0,0 +1,20 @@
+# Conductor C# Worker
+
+Follow the instructions below to set up and run a C# worker, orchestrated by Conductor. 
+
+### Run the worker
+
+```shell
+dotnet run
+```
+
+### Conductor documentation
+
+* [Core Concepts](https://orkes.io/content/core-concepts)
+* [Using Workers](https://orkes.io/content/developer-guides/using-workers)
+
+
+### Additional resources
+* [Orkes Conductor - Developer Edition](https://developer.orkescloud.com/)
+* [Join the community in Slack](https://orkes-conductor.slack.com) and [Discourse](https://community.orkes.io)
+* [Contribute to the Conductor OSS project](https://github.com/conductor-oss/conductor)

csharp/worker/core/Worker.cs

@@ -0,0 +1,50 @@
+using Conductor.Client.Authentication;
+using Conductor.Client.Worker;
+using Conductor.Client.Models;
+using Conductor.Client.Extensions;
+using Conductor.Client;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+namespace Orkes.Workers
+{
+    [WorkerTask]
+    public class MyWorker
+    {
+        [WorkerTask(taskType: "{{taskname}}", batchSize: 5, pollIntervalMs: 500, workerId: "csharp-worker")]
+        public static TaskResult MyTask(Conductor.Client.Models.Task task)
+        {
+            var inputData = task.InputData;
+            var result = task.ToTaskResult();
+            result.OutputData = new Dictionary<string, object>
+            {
+                ["message"] = "Hello " + inputData.GetValueOrDefault("name", null)
+            };
+            return result;
+        }
+
+        public static void Main(string[] args)
+        {
+            var conf = new Configuration
+            {
+                BasePath = "{{server_url}}",
+                AuthenticationSettings = new OrkesAuthenticationSettings("{{auth_key}}", "{{auth_secret}}")
+            };
+
+            var host = WorkflowTaskHost.CreateWorkerHost(conf, LogLevel.Debug);
+            host.Start();
+
+            Console.WriteLine("Press Ctrl+C to exit.");
+            var evt = new ManualResetEvent(false);
+            Console.CancelKeyPress += (sender, e) =>
+            {
+                e.Cancel = true;
+                Console.WriteLine("Ctrl+C pressed. Shutting down...");
+                evt.Set();
+            };
+
+            evt.WaitOne();
+            host.StopAsync();
+        }
+    }
+}

csharp/worker/core/bp.json

@@ -0,0 +1,22 @@
+{
+  "files": [
+    {
+      "name": "Worker.cs",
+      "fields": [
+        {
+          "name": "taskname",
+          "prompt": "Enter a task name:"
+        }
+      ]
+    },
+    {
+      "name": "worker.csproj"
+    },
+    {
+      "name": "worker.sln"
+    },
+    {
+      "name": "README.md"
+    }
+  ]
+}

csharp/worker/core/worker.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="conductor-csharp" Version="1.1.1" />
+  </ItemGroup>
+
+</Project>

csharp/worker/core/worker.sln

@@ -0,0 +1,24 @@
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.5.002.0
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "worker", "worker.csproj", "{471891A0-13E5-4A18-9EC7-770FD81806D5}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{471891A0-13E5-4A18-9EC7-770FD81806D5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{471891A0-13E5-4A18-9EC7-770FD81806D5}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{471891A0-13E5-4A18-9EC7-770FD81806D5}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{471891A0-13E5-4A18-9EC7-770FD81806D5}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {DC1F001E-EEE2-4C54-9A2B-1A5B86C8F33C}
+	EndGlobalSection
+EndGlobal

manifest.json

@@ -1,5 +1,20 @@
 {
   "languages": [
+    {
+      "name": "C#",
+      "frameworks": [
+        {
+          "name": "core",
+          "templates": [
+            {
+              "name": "basic-worker",
+              "description": "Basic C# worker with Conductor SDK",
+              "path": "csharp/worker/core"
+            }
+          ]
+        }
+      ]
+    },
     {
       "name": "Go",
       "frameworks": [