use connection strings for redis

BinaryDad.Coding/BinaryDad.Coding.csproj

@@ -6,7 +6,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.SignalR.StackExchangeRedis" Version="8.0.1" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.15.1" />
+    <PackageReference Include="StackExchange.Redis" Version="2.7.17" />
   </ItemGroup>
 
 </Project>

BinaryDad.Coding/Hubs/CodeHub.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.SignalR;
+using Microsoft.Extensions.Caching.Distributed;
 using System;
 using System.Threading.Tasks;
 
@@ -6,33 +7,58 @@ namespace BinaryDad.Coding.Hubs
 {
     public class CodeHub : Hub
     {
-        public Task UpdateCode(string user, int index, string code, bool isTeacher)
+        private readonly IDistributedCache _cache;
+
+        public CodeHub(IDistributedCache cache)
         {
+            _cache = cache;
+        }
+
+        public async Task UpdateCode(string user, int index, string code, bool isTeacher)
+        {
+            Console.WriteLine($"Received code from {user} with index {index}");
+
             if (index == 0)
             {
-                Users.Sessions[Context.ConnectionId].Html = code;
+                await _cache.SetStringAsync($"html-{Context.ConnectionId}", code);
+
+                //if (Users.Sessions.TryGetValue(Context.ConnectionId, out User value))
+                //{
+                //    value.Html = code;
+                //}
             }
             else if (index == 1)
             {
-                Users.Sessions[Context.ConnectionId].Css = code;
+                await _cache.SetStringAsync($"css-{Context.ConnectionId}", code);
+
+                //if (Users.Sessions.TryGetValue(Context.ConnectionId, out User value))
+                //{
+                //    value.Css = code;
+                //}
             }
 
             // only send to all if it's a teacher
             if (isTeacher)
             {
-                return Clients.All.SendAsync("ReceiveCode", user, index, code);
-            }
+                Console.WriteLine($"Sending code from {user}");
 
-            return null;
+                await Clients.Others.SendAsync("ReceiveCode", user, index, code);
+            }
         }
 
         public async Task SaveName(string name, string color)
         {
-            Users.Sessions[Context.ConnectionId].Id = Context.ConnectionId;
-            Users.Sessions[Context.ConnectionId].Name = name;
-            Users.Sessions[Context.ConnectionId].Color = string.IsNullOrWhiteSpace(color) ? "white" : color;
+            await _cache.SetStringAsync($"name-{Context.ConnectionId}", name);
+            await _cache.SetStringAsync($"color-{Context.ConnectionId}", string.IsNullOrWhiteSpace(color) ? "white" : color);
 
-            await Clients.All.SendAsync("UsersList", Users.Sessions);
+            //if (!Users.Sessions.ContainsKey(Context.ConnectionId))
+            //{
+            //    Users.Sessions[Context.ConnectionId].Id = Context.ConnectionId;
+            //    Users.Sessions[Context.ConnectionId].Name = name;
+            //    Users.Sessions[Context.ConnectionId].Color = string.IsNullOrWhiteSpace(color) ? "white" : color;
+            //}
+
+            await Clients.Others.SendAsync("UsersList", Users.Sessions);
         }
 
         public override async Task OnConnectedAsync()
@@ -42,16 +68,19 @@ namespace BinaryDad.Coding.Hubs
                 Name = string.Empty
             };
 
-            await Clients.All.SendAsync("UsersList", Users.Sessions);
+            await Clients.Others.SendAsync("UsersList", Users.Sessions);
 
             await base.OnConnectedAsync();
         }
 
         public override async Task OnDisconnectedAsync(Exception exception)
+        {
+            if (Users.Sessions.ContainsKey(Context.ConnectionId))
             {
                 Users.Sessions.Remove(Context.ConnectionId);
+            }
 
-            await Clients.All.SendAsync("UsersList", Users.Sessions);
+            await Clients.Others.SendAsync("UsersList", Users.Sessions);
 
             await base.OnDisconnectedAsync(exception);
         }

BinaryDad.Coding/Properties/launchSettings.json

@@ -8,16 +8,10 @@
     }
   },
   "profiles": {
-    "IIS Express": {
-      "commandName": "IISExpress",
-      "launchBrowser": true,
-      "environmentVariables": {
-        "ASPNETCORE_ENVIRONMENT": "Development"
-      }
-    },
     "BinaryDad.Coding": {
       "commandName": "Project",
       "launchBrowser": true,
+      "hotReloadEnabled": false,
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"
       },

BinaryDad.Coding/Startup.cs

@@ -5,6 +5,9 @@ using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
+using StackExchange.Redis;
+using System;
+using System.Net;
 
 namespace BinaryDad.Coding
 {
@@ -21,7 +24,37 @@ namespace BinaryDad.Coding
         public void ConfigureServices(IServiceCollection services)
         {
             services.AddMvc();
-            services.AddSignalR();
+            services.AddSignalR().AddStackExchangeRedis(options =>
+            {
+                options.ConnectionFactory = async writer =>
+                {
+                    var config = new ConfigurationOptions
+                    {
+                        AbortOnConnectFail = false
+                    };
+
+                    config.EndPoints.Add(Configuration.GetConnectionString("Redis"));
+                    config.SetDefaultPorts();
+
+                    var connection = await ConnectionMultiplexer.ConnectAsync(config, writer);
+                    connection.ConnectionFailed += (_, e) =>
+                    {
+                        Console.WriteLine("Connection to Redis failed.");
+                        Console.WriteLine(e.ToString());
+                    };
+
+                    if (!connection.IsConnected)
+                    {
+                        Console.WriteLine("Did not connect to Redis.");
+                    }
+                    else
+                    {
+                        Console.WriteLine("Connected to Redis.");
+                    }
+
+                    return connection;
+                };
+            });
 
             services.AddHttpsRedirection(options =>
             {

BinaryDad.Coding/Users.cs

@@ -1,5 +1,7 @@
-using System;
+using Microsoft.Extensions.Caching.Distributed;
+using System;
 using System.Collections.Generic;
+using System.Threading.Tasks;
 
 namespace BinaryDad.Coding
 {
@@ -7,4 +9,26 @@ namespace BinaryDad.Coding
     {
         public static readonly IDictionary<string, User> Sessions = new Dictionary<string, User>(StringComparer.OrdinalIgnoreCase);
     }
+
+    public class UserCache
+    {
+        private readonly IDistributedCache _cache;
+
+        public UserCache(IDistributedCache cache) 
+        {
+            _cache = cache;
+        }
+        
+        public async Task<User> GetUser(string connectionId)
+        {
+            var user = new User();
+
+            user.Id = connectionId;
+            user.Name = await _cache.GetStringAsync($"name-{connectionId}");
+            user.Color = await _cache.GetStringAsync($"color-{connectionId}");
+
+            return user;
+        }
+
+    }
 }

BinaryDad.Coding/appsettings.Development.json

@@ -6,5 +6,8 @@
       "Microsoft": "Warning",
       "Microsoft.Hosting.Lifetime": "Information"
     }
+  },
+  "ConnectionStrings": {
+    "Redis": "cluster.home.lan:6379"
   }
 }

BinaryDad.Coding/appsettings.json

@@ -6,5 +6,8 @@
       "Microsoft.Hosting.Lifetime": "Information"
     }
   },
-  "AllowedHosts": "*"
+  "AllowedHosts": "*",
+  "ConnectionStrings": {
+    "Redis": "redis:6379"
+  }
 }

BinaryDad.Coding/wwwroot/js/hub.js

@@ -14,6 +14,7 @@
     let isTeacher = window.location.hash === '#4ELQcUq7UnFGghAZCVr4Chr9JmtncigfkGu5WSf9';
 
     let isLive = false;
+    let editorLock = false;
 
     let isLiveMode = function () {
 
@@ -73,9 +74,13 @@
 
         if (!isTeacher && isLive) {
 
+            editorLock = true;
+
             let editor = ace.edit($editors[index]);
 
             editor.session.setValue(code);
+
+            editorLock = false;
         }
     });
 
@@ -100,7 +105,10 @@
             let editor = ace.edit(e);
 
             editor.session.on('change', function () {
+
+                if (!editorLock) {
                     updateCode(editor, i);
+                };
             });
 
             // send initial code

docker.sh

@@ -1,2 +1,2 @@
-sudo docker build -f BinaryDad.Coding/Dockerfile . -t binarydad/coding:latest
-sudo docker push binarydad/coding:latest
+sudo docker build -f BinaryDad.Coding/Dockerfile . -t binarydad/coding:redis
+sudo docker push binarydad/coding:redis