From 8d738fe39d66072e6866ce8ac3f0128bb3ae357f Mon Sep 17 00:00:00 2001
From: Tommy Parnell <tommy@terribledev.io>
Date: Wed, 11 Jan 2017 21:29:21 -0500
Subject: [PATCH] add worker df

---
 Worker/Dockerfile | 12 ++++++++++++
 Worker/Program.cs | 19 +++++++++++++------
 2 files changed, 25 insertions(+), 6 deletions(-)
 create mode 100644 Worker/Dockerfile

diff --git a/Worker/Dockerfile b/Worker/Dockerfile
new file mode 100644
index 0000000..c39dd98
--- /dev/null
+++ b/Worker/Dockerfile
@@ -0,0 +1,12 @@
+FROM microsoft/dotnet:1.1.0-sdk-projectjson
+
+WORKDIR /dotnetapp
+
+# copy project.json and restore as distinct layers
+COPY project.json .
+RUN dotnet restore
+
+# copy and build everything else
+COPY . .
+RUN dotnet build -C Release
+ENTRYPOINT ["dotnet", "run", "-C", "Release"]
\ No newline at end of file
diff --git a/Worker/Program.cs b/Worker/Program.cs
index bf8c52a..d215470 100644
--- a/Worker/Program.cs
+++ b/Worker/Program.cs
@@ -17,12 +17,19 @@ namespace Worker
         {
             while(true)
             {
-                var bytes = await httpclient.GetByteArrayAsync("http://gen/8");
-                var results = await httpclient.PostAsync("http://hashr/hashme",  new ByteArrayContent(bytes));
-                results.EnsureSuccessStatusCode();
-                var hashResults = await results.Content.ReadAsStringAsync();
-                var dbResult = await httpclient.GetStringAsync($"http://store/store?dt={DateTime.Now.ToString()}");
-                await Task.Delay(1000);
+                try
+                {
+                    var bytes = await httpclient.GetByteArrayAsync("http://gen/8");
+                    var results = await httpclient.PostAsync("http://hashr/hashme",  new ByteArrayContent(bytes));
+                    results.EnsureSuccessStatusCode();
+                    var hashResults = await results.Content.ReadAsStringAsync();
+                    var dbResult = await httpclient.GetStringAsync($"http://store/store?dt={DateTime.Now.ToString()}");
+                    await Task.Delay(1000);
+                }
+                catch(Exception e)
+                {
+                    Console.WriteLine(e.Message);
+                }
             }
         }
     }