Add files

TaskRunner/Program.cs

@@ -1,12 +1,46 @@
 using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Threading.Tasks;
+using CommandLine;
+using CommandLine.Text;
 
 namespace TaskRunner
 {
-    class Program
+    public class Options
     {
-        static void Main(string[] args)
+        [Option("server", HelpText="Task source server", Required = true)]
+        public string server { get; set; }
+
+        [HelpOption]
+        public string GetUsage()
         {
-            Console.WriteLine("Hello World!");
+            return HelpText.AutoBuild(this, (HelpText current) => HelpText.DefaultParsingErrorsHandler(this, current));
+        }
+    }
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            MainAsync(args).Wait();
+        }
+
+        static async Task MainAsync(string[] args)
+        {
+            var options = new Options();
+            if (Parser.Default.ParseArguments(args, options))
+            {
+                Console.WriteLine($"Waiting for tasks from server: {options.server}");
+                var server = new ServerApi(new Uri(options.server));
+                var task = await server.GetTask();
+                Console.WriteLine(task);
+                var taskManager = new TaskManager();
+                await taskManager.RunFfmpeg();
+            } else {
+                Console.WriteLine(options.GetUsage());
+            }
+            
         }
     }
 }

TaskRunner/ServerAPI.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using System.Net.Http;
+
+
+namespace TaskRunner
+{
+    public class ServerApi
+    {
+        public Uri serverUri;
+        private readonly HttpClient client = new HttpClient();
+
+        public ServerApi(Uri serverUri)
+        {
+            this.serverUri = serverUri;
+            client.BaseAddress = serverUri;
+        }
+
+        public async Task<string> GetTask()
+        {
+            var resp = await client.GetStringAsync("get");
+            return resp;
+        }
+    }
+}

TaskRunner/TaskManager.cs

@@ -0,0 +1,36 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace TaskRunner
+{
+    public class TaskManager
+    {
+        public Task RunFfmpeg()
+        {
+            var task = new TaskCompletionSource<bool>();
+            var process = new Process
+            {
+                StartInfo =
+                {
+                    FileName = "ping",
+                    Arguments = "google.com -t",
+                    RedirectStandardOutput = true,
+                    UseShellExecute = false
+                },
+                EnableRaisingEvents = true
+            };
+            process.OutputDataReceived += (sender, a) => Console.WriteLine(a.Data);
+            process.Start();
+            process.BeginOutputReadLine();
+            process.Exited += (sender, args) =>
+            {
+                task.SetResult(true);
+                process.Dispose();
+            };
+            return task.Task;
+        }
+    }
+}

TaskRunner/TaskRunner.csproj

@@ -5,4 +5,8 @@
     <TargetFramework>netcoreapp2.0</TargetFramework>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="CommandLineParser" Version="1.9.71" />
+  </ItemGroup>
+
 </Project>