Add MySql result loader

Author: sixeyed

result/dotnet/Result/Data/IResultData.cs

@@ -0,0 +1,9 @@
+using Result.Models;
+
+namespace Result.Data
+{
+    public interface IResultData
+    {
+        ResultsModel GetResults();
+    }
+}

result/dotnet/Result/Data/MySqlResultData.cs

@@ -0,0 +1,40 @@
+using System.Linq;
+using Dapper;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using MySql.Data.MySqlClient;
+using Result.Models;
+
+namespace Result.Data
+{
+    public class MySqlResultData : IResultData
+    {
+        private readonly string _connectionString;
+        private readonly ILogger _logger;
+
+        public MySqlResultData(IConfiguration config, ILogger<MySqlResultData> logger)
+        {
+            _connectionString = config.GetConnectionString("ResultData");
+            _logger = logger;
+        }
+
+        public ResultsModel GetResults()
+        {
+            var model = new ResultsModel();            
+            using (var connection = new MySqlConnection(_connectionString))
+            {                
+                var results = connection.Query("SELECT vote, COUNT(id) AS count FROM votes GROUP BY vote ORDER BY vote");
+                if (results.Any(x => x.vote == "a"))
+                {
+                    model.OptionA = results.First(x => x.vote == "a").count;
+                }
+                if (results.Any(x => x.vote == "b"))
+                {
+                    model.OptionB = results.First(x => x.vote == "b").count;
+                }
+                model.VoteCount = model.OptionA + model.OptionB;
+            }
+            return model;
+        }
+    }
+}

result/dotnet/Result/Pages/Index.cshtml

@@ -39,7 +39,7 @@
     <div id="result">
         <span id="totalVotes">No votes yet</span>
     </div>
-    <script src="~/lib/signalr/dist/browser/signalr.js"></script>
+    <script src="~/lib/signalr/dist/browser/signalr.min.js"></script>
     <script src="~/js/results.js"></script>
 </body>
 </html>

result/dotnet/Result/Result.csproj

@@ -5,7 +5,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Dapper" Version="1.50.5" />
     <PackageReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="MySql.Data" Version="8.0.12" />
   </ItemGroup>
 
 </Project>

result/dotnet/Result/Startup.cs

@@ -3,6 +3,7 @@
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Result.Data;
 using Result.Hubs;
 using Result.Timers;
 
@@ -21,7 +22,9 @@ public void ConfigureServices(IServiceCollection services)
         {
             services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
             services.AddSignalR();
-            services.AddSingleton<PublishResultsTimer>();
+
+            services.AddTransient<IResultData, MySqlResultData>()
+                    .AddSingleton<PublishResultsTimer>();
         }
 
         public void Configure(IApplicationBuilder app, IHostingEnvironment env)

result/dotnet/Result/Timers/PublishResultsTimer.cs

@@ -1,22 +1,21 @@
-using System;
-using System.Timers;
+using System.Timers;
 using Microsoft.AspNetCore.SignalR;
 using Microsoft.Extensions.Configuration;
+using Result.Data;
 using Result.Hubs;
-using Result.Models;
 
 namespace Result.Timers
 {
     public class PublishResultsTimer
     {        
         private readonly IHubContext<ResultsHub> _hubContext;
+        private readonly IResultData _resultData;
         private readonly Timer _timer;
-        //TODO- temp
-        private static Random _Random = new Random();
 
-        public PublishResultsTimer(IHubContext<ResultsHub> hubContext, IConfiguration configuration)
+        public PublishResultsTimer(IHubContext<ResultsHub> hubContext, IResultData resultData, IConfiguration configuration)
         {
             _hubContext = hubContext;
+            _resultData = resultData;
             var publishMilliseconds = configuration.GetValue<int>("ResultsTimer:PublishMilliseconds");
             _timer = new Timer(publishMilliseconds)
             {
@@ -35,12 +34,7 @@ public void Start()
 
         private void PublishResults(object sender, ElapsedEventArgs e)
         {
-            var model = new ResultsModel
-            {
-                OptionA = _Random.Next(0, 100),
-                OptionB = _Random.Next(0, 100)                
-            };
-            model.VoteCount = model.OptionA + model.OptionB;
+            var model = _resultData.GetResults();
             _hubContext.Clients.All.SendAsync("UpdateResults", model);
         }
     }

result/dotnet/Result/appsettings.json

@@ -4,7 +4,10 @@
     "OptionB": "Dogs"
   },
   "ResultsTimer": {
-    "PublishMilliseconds":  1500
+    "PublishMilliseconds": 2500
+  },
+  "ConnectionStrings": {
+    "ResultData": "Server=mysql;Port=4000;Database=votes;User=root;SslMode=None"
   },
   "Logging": {
     "LogLevel": {

result/dotnet/Result/wwwroot/favicon.ico

@@ -18,8 +18,8 @@ connection.on("UpdateResults", function (results) {
 
     var bg1 = document.getElementById('background-stats-1');
     var bg2 = document.getElementById('background-stats-2');
-    bg1.style.width = percentages.a + "%";
-    bg2.style.width = percentages.b + "%";
+    bg1.style.width = (percentages.a-0.2) + "%";
+    bg2.style.width = (percentages.b-0.2) + "%";
 });
 
 connection.start().catch(function (err) {