Revert DTO, Changed messagepackprotocol again.

This commit is contained in:
cake
2025-12-06 23:39:24 +01:00
parent c9d3cb0d50
commit e21f9c36a4

View File

@@ -1,4 +1,6 @@
using AspNetCoreRateLimit; using AspNetCoreRateLimit;
using LightlessSync.API.Data;
using LightlessSync.API.Dto.Group;
using LightlessSync.API.SignalR; using LightlessSync.API.SignalR;
using LightlessSyncServer.Configuration; using LightlessSyncServer.Configuration;
using LightlessSyncServer.Controllers; using LightlessSyncServer.Controllers;
@@ -126,6 +128,8 @@ public class Startup
services.AddSingleton<IUserIdProvider, IdBasedUserIdProvider>(); services.AddSingleton<IUserIdProvider, IdBasedUserIdProvider>();
services.AddSingleton<ConcurrencyFilter>(); services.AddSingleton<ConcurrencyFilter>();
var msgpackOptions = MessagePackSerializerOptions.Standard.WithCompression(MessagePackCompression.Lz4Block).WithResolver(ContractlessStandardResolver.Instance);
var signalRServiceBuilder = services.AddSignalR(hubOptions => var signalRServiceBuilder = services.AddSignalR(hubOptions =>
{ {
hubOptions.MaximumReceiveMessageSize = long.MaxValue; hubOptions.MaximumReceiveMessageSize = long.MaxValue;
@@ -137,20 +141,10 @@ public class Startup
hubOptions.AddFilter<ConcurrencyFilter>(); hubOptions.AddFilter<ConcurrencyFilter>();
}).AddMessagePackProtocol(opt => }).AddMessagePackProtocol(opt =>
{ {
var resolver = CompositeResolver.Create( opt.SerializerOptions = msgpackOptions;
StandardResolverAllowPrivate.Instance,
BuiltinResolver.Instance,
AttributeFormatterResolver.Instance,
DynamicEnumAsStringResolver.Instance,
DynamicGenericResolver.Instance,
DynamicUnionResolver.Instance,
DynamicObjectResolver.Instance,
PrimitiveObjectResolver.Instance,
StandardResolver.Instance);
opt.SerializerOptions = MessagePackSerializerOptions.Standard var dummy = new GroupPruneSettingsDto(new GroupData("TEST-GID", null), true, 14);
.WithCompression(MessagePackCompression.Lz4Block) MessagePackSerializer.Serialize(dummy, msgpackOptions);
.WithResolver(resolver);
}); });
@@ -171,7 +165,7 @@ public class Startup
KeyPrefix = "", KeyPrefix = "",
Hosts = new RedisHost[] Hosts = new RedisHost[]
{ {
new RedisHost(){ Host = address, Port = port }, new(){ Host = address, Port = port },
}, },
AllowAdmin = true, AllowAdmin = true,
ConnectTimeout = options.ConnectTimeout, ConnectTimeout = options.ConnectTimeout,