brought worker service back to barebones

Author: humblelistener

WorkerService/Dockerfile

@@ -1,7 +1,11 @@
-FROM microsoft/dotnet:1.1.0-sdk-projectjson
-
-COPY . ./app
-WORKDIR ./app
-RUN dotnet restore
+FROM microsoft/dotnet:1.1.2-sdk
+
+COPY . /app
+
+WORKDIR /app
+
+RUN dotnet restore
+
+RUN dotnet build -c Release
 
 CMD ["dotnet", "run"]

WorkerService/Environment.cs

@@ -1,86 +1,35 @@
-using System.Reflection;
-using System.Threading.Tasks;
-using Amazon;
-using Amazon.DynamoDBv2;
-using Amazon.Kinesis;
+using System;
+using System.IO;
 using Microsoft.Extensions.Configuration;
 using Serilog;
-using WorkerService.EventProcessors;
-using KinesisNet;
 using static System.Threading.Thread;
 using static System.Threading.Timeout;
 
 namespace WorkerService
 {
     public class Program
     {
-        private static Environment environment;
-        private static KManager kManager;
 
         public static void Main(string[] args)
         {
-            Log.Logger = new LoggerConfiguration()
-                .MinimumLevel.Debug()
-                .WriteTo.LiterateConsole()
-                .CreateLogger();
-
-            Log.Debug("Testing debug logging");
+            var configuration = new ConfigurationBuilder()
+                .AddEnvironmentVariables()
+                .AddCommandLine(args)
+                .SetBasePath(Path.Combine(AppContext.BaseDirectory))
+                .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
+                .Build();
 
-            environment = new Environment
-            (
-                System.Environment.GetEnvironmentVariable("REGION"),
-                System.Environment.GetEnvironmentVariable("DC"),
-                System.Environment.GetEnvironmentVariable("ENV"),
-                typeof(Program)
-                .GetTypeInfo()
-                .Assembly
-                .GetCustomAttribute<AssemblyInformationalVersionAttribute>()
-                .InformationalVersion
-            );
 
-            Log.Information("{@Environment}", environment);
+            var logger = new LoggerConfiguration()
+                .ReadFrom.Configuration(configuration)
+                .CreateLogger();
 
-            Log.Information("Starting configuration");
+            Log.Logger = logger;
 
-            var configuration = new ConfigurationBuilder()
-                                    .AddEnvironmentVariables()
-                                    .AddCommandLine(args)
-                                    .Build();
+            Console.WriteLine("Hello World");
 
-            StartListeningForEvents();
-
-            Log.Information("Going to sleep... zzzzz");
             // sleep indefinitely
             Sleep(Infinite);
-
-            StopListeningToEvents();
-        }
-
-        private static void StopListeningToEvents()
-        {
-            kManager.Consumer.Stop();
-        }
-
-        public static void StartListeningForEvents()
-        {
-            Log.Debug("Entering StartListeningForEvents");
-            var kinesisStreamName = "RoleStream.LIVE";
-            var kinesisWorkerId = Assembly.GetEntryAssembly().GetName().Name + "-" + environment.Env;
-
-            Log.Information("KManager variables:");
-            Log.Information($"  StreamName: {kinesisStreamName}");
-            Log.Information($"  WorkerId: {kinesisWorkerId}");
-
-            Log.Debug("Creating Dyanmo client");
-            var dynamoClient = new AmazonDynamoDBClient(new AmazonDynamoDBConfig{RegionEndpoint = RegionEndpoint.GetBySystemName(environment.AwsRegion)});
-            Log.Debug("Creating Kinesis client");
-            var kinesisClient = new AmazonKinesisClient(new AmazonKinesisConfig{ RegionEndpoint = RegionEndpoint.GetBySystemName(environment.AwsRegion )});
-
-            Log.Debug("Starting Kmanager");
-            kManager = new KManager(dynamoClient, kinesisClient, kinesisStreamName, kinesisWorkerId);
-
-            Log.Debug("Starting consumer");
-            Task.Run(() => kManager.Consumer.Start(new RolesEventProcessor()));
         }
     }
 }

WorkerService/EventProcessors/RolesEventProcessor.cs

@@ -10,20 +10,21 @@
     <RuntimeFrameworkVersion>1.1.1</RuntimeFrameworkVersion>
   </PropertyGroup>
 
+  <ItemGroup>
+    <Content Include="appsettings.json">
+      <CopyToPublishDirectory>PreserveNewest</CopyToPublishDirectory>
+    </Content>
+  </ItemGroup>
+
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.Configuration.EnvironmentVariables" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Configuration.CommandLine" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Configuration.FileExtensions" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="1.1.2" />
     <PackageReference Include="AWSSDK.DynamoDBv2" Version="3.3.4.13" />
     <PackageReference Include="AWSSDK.Kinesis" Version="3.3.2.4" />
-    <PackageReference Include="Serilog" Version="2.4.0" />
-    <PackageReference Include="Serilog.Sinks.Literate" Version="2.1.0" />
-    <PackageReference Include="SeriLog.LogSanitizingFormatter" Version="1.0.1" />
-  </ItemGroup>
-
-  <ItemGroup>
-    <ProjectReference Include="..\KinesisNet\KinesisNet.csproj" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="1.1.1" />
+    <PackageReference Include="Serilog.Settings.Configuration" Version="2.4.0" />
   </ItemGroup>
 
 </Project>

WorkerService/Program.cs

@@ -0,0 +1,10 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Verbose",
+      "System": "Warning",
+      "Microsoft": "Warning"
+    }
+  }
+}