Quick fixie

Author: hhvrc

API/Program.cs

@@ -1,3 +1,4 @@
+using MessagePack;
 using Microsoft.AspNetCore.Http.Connections;
 using Microsoft.Extensions.Options;
 using OpenShock.API.Realtime;
@@ -9,6 +10,7 @@
 using OpenShock.Common.DeviceControl;
 using OpenShock.Common.Extensions;
 using OpenShock.Common.Hubs;
+using OpenShock.Common.JsonSerialization;
 using OpenShock.Common.Options;
 using OpenShock.Common.Services;
 using OpenShock.Common.Services.Device;
@@ -38,7 +40,20 @@
 
 builder.Services.AddSignalR()
     .AddOpenShockStackExchangeRedis(options => { options.Configuration = redisConfig; })
-    .AddMessagePackProtocol();
+    .AddJsonProtocol(options =>
+    {
+        options.PayloadSerializerOptions.PropertyNameCaseInsensitive = true;
+        options.PayloadSerializerOptions.Converters.Add(new SemVersionJsonConverter());
+    })
+    .AddMessagePackProtocol(options =>
+    {
+        options.SerializerOptions = MessagePackSerializerOptions.Standard.WithResolver(
+            MessagePack.Resolvers.CompositeResolver.Create(
+                MessagePack.Resolvers.NativeGuidResolver.Instance,
+                MessagePack.Resolvers.StandardResolver.Instance
+            ))
+            .WithSecurity(MessagePackSecurity.UntrustedData);
+    });
 
 builder.Services.AddScoped<IDeviceService, DeviceService>();
 builder.Services.AddScoped<IControlSender, ControlSender>();

LiveControlGateway/Program.cs

@@ -1,7 +1,9 @@
+using MessagePack;
 using Microsoft.Extensions.Options;
 using OpenShock.Common;
 using OpenShock.Common.DeviceControl;
 using OpenShock.Common.Extensions;
+using OpenShock.Common.JsonSerialization;
 using OpenShock.Common.Services;
 using OpenShock.Common.Services.Device;
 using OpenShock.Common.Services.Ota;
@@ -26,7 +28,20 @@
 
 builder.Services.AddSignalR()
     .AddOpenShockStackExchangeRedis(options => { options.Configuration = redisConfig; })
-    .AddMessagePackProtocol();
+    .AddJsonProtocol(options =>
+    {
+        options.PayloadSerializerOptions.PropertyNameCaseInsensitive = true;
+        options.PayloadSerializerOptions.Converters.Add(new SemVersionJsonConverter());
+    })
+    .AddMessagePackProtocol(options =>
+    {
+        options.SerializerOptions = MessagePackSerializerOptions.Standard.WithResolver(
+                MessagePack.Resolvers.CompositeResolver.Create(
+                    MessagePack.Resolvers.NativeGuidResolver.Instance,
+                    MessagePack.Resolvers.StandardResolver.Instance
+                ))
+            .WithSecurity(MessagePackSecurity.UntrustedData);
+    });
 
 builder.Services.AddScoped<IDeviceService, DeviceService>();
 builder.Services.AddScoped<IControlSender, ControlSender>();