GameCult/CultLib
Watch
9
0
Fork
You've already forked CultLib
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

Use CultNet binding schema ids for raw records

Browse source
This commit is contained in:
Meta Vens 2026-05-16 09:16:43 +01:00
commit bb1437dc58
2 changed files with 26 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

42
src/GameCult.Networking/CultNetDocumentRegistry.cs
View file

@ -74,6 +74,7 @@ namespace GameCult.Networking
/// </summary>
public static CultNetDocumentBinding ForDocument<T>(
CultDocumentRegistry? registry = null,
string? schemaId = null,
Func<T, byte[]>? payloadSerializer = null,
Func<byte[], T>? payloadDeserializer = null)
where T : class
@ -81,7 +82,7 @@ namespace GameCult.Networking
var descriptor = (registry ?? CultDocumentRegistry.Shared).GetRequired<T>();
return new CultNetDocumentBinding(
typeof(T),
descriptor.SchemaId,
string.IsNullOrWhiteSpace(schemaId) ? descriptor.SchemaId : schemaId!,
document =>
{
var typed = (T)document;
@ -185,7 +186,7 @@ namespace GameCult.Networking
MessageId = RequireNonEmpty(messageId, nameof(messageId)),
Document = new CultNetRawDocumentRecord
{
SchemaId = descriptor.SchemaId,
SchemaId = binding.SchemaId,
RecordKey = handle.Key.Value,
StoredAt = storedAt,
PayloadEncoding = "messagepack",
@ -235,9 +236,19 @@ namespace GameCult.Networking
foreach (var document in cache.AllEntries)
{
var descriptor = _documents.GetRequired(document.GetType());
var binding = GetByDocumentType(document.GetType()) ??
new CultNetDocumentBinding(
document.GetType(),
descriptor.SchemaId,
value => CultDocumentMessagePackSerialization.SerializeUntyped(value, value.GetType()),
payload => CultDocumentMessagePackSerialization.DeserializeUntyped(document.GetType(), payload));
if (requestedSchemaIds != null && !requestedSchemaIds.Contains(descriptor.SchemaId))
{
continue;
if (!requestedSchemaIds.Contains(binding.SchemaId))
{
continue;
}
}
var handleMethod = typeof(CultCache)
@ -260,16 +271,9 @@ namespace GameCult.Networking
continue;
}
var binding = GetByDocumentType(document.GetType()) ??
new CultNetDocumentBinding(
document.GetType(),
descriptor.SchemaId,
value => CultDocumentMessagePackSerialization.SerializeUntyped(value, value.GetType()),
payload => CultDocumentMessagePackSerialization.DeserializeUntyped(document.GetType(), payload));
documents.Add(new CultNetRawDocumentRecord
{
SchemaId = descriptor.SchemaId,
SchemaId = binding.SchemaId,
RecordKey = key,
StoredAt = storedAt,
PayloadEncoding = "messagepack",
@ -301,13 +305,15 @@ namespace GameCult.Networking
}
ValidateRawDocumentRecord(message.Document);
var descriptor = _documents.GetRequiredBySchemaId(message.Document.SchemaId);
var binding = GetBySchemaId(message.Document.SchemaId) ??
new CultNetDocumentBinding(
descriptor.DocumentType,
descriptor.SchemaId,
value => CultDocumentMessagePackSerialization.SerializeUntyped(value, value.GetType()),
payload => CultDocumentMessagePackSerialization.DeserializeUntyped(descriptor.DocumentType, payload));
var binding = GetBySchemaId(message.Document.SchemaId);
var descriptor = binding != null
? _documents.GetRequired(binding.DocumentType)
: _documents.GetRequiredBySchemaId(message.Document.SchemaId);
binding ??= new CultNetDocumentBinding(
descriptor.DocumentType,
descriptor.SchemaId,
value => CultDocumentMessagePackSerialization.SerializeUntyped(value, value.GetType()),
payload => CultDocumentMessagePackSerialization.DeserializeUntyped(descriptor.DocumentType, payload));
var document = binding.PayloadDeserializer(message.Document.Payload);
var addMethod = typeof(CultCache).GetMethod(nameof(CultCache.AddAsync))!

2
tests/GameCult.Networking.InteropPeer/Program.cs
View file

@ -56,6 +56,7 @@ static async Task ServeAsync(ServeConfig config)
var schemaRegistration = LoadSchemaRegistration(config.SchemaPath);
var documentRegistry = new CultNetDocumentRegistry()
.Register(CultNetDocumentBinding.ForDocument<CultNetInteropNote>(
schemaId: schemaRegistration.SchemaId,
payloadSerializer: SerializeInteropNotePayload,
payloadDeserializer: DeserializeInteropNotePayload));
@ -172,6 +173,7 @@ static async Task DialAsync(DialConfig config)
var cache = new CultCache();
var documentRegistry = new CultNetDocumentRegistry()
.Register(CultNetDocumentBinding.ForDocument<CultNetInteropNote>(
schemaId: schemaRegistration.SchemaId,
payloadSerializer: SerializeInteropNotePayload,
payloadDeserializer: DeserializeInteropNotePayload));