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

C#: receipt ids capped at 256 bytes and held as digests; limit refusals remembered, no slot freed; required fields refused with fixed text; RUDP server advertises no receipt frames
Some checks failed
CultMesh QUIC native / Build win32-x64 (pull_request) Has been skipped
Details
CultMesh QUIC native / Build linux-x64 (pull_request) Has been skipped
Details
CultMesh QUIC native / Release native binaries (pull_request) Has been skipped
Details
CultMesh portability and performance / ubuntu-latest reactive semantics and leases (pull_request) Has been cancelled
Details
CultMesh QUIC native / Verify committed binaries match SHA256SUMS (pull_request) Has been cancelled
Details

Browse source 
Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
Libby 2026-11-08 15:07:23 +00:00
commit c4d1efe000
4 changed files with 360 additions and 40 deletions
Download patch file Download diff file Expand all files Collapse all files

23
src/GameCult.Networking/CultNetDatabaseServer.cs
View file

@ -416,9 +416,17 @@ namespace GameCult.Networking
private async Task HandlePutAsync(CultNetDocumentPutRawMessage message, CultNetServerPeer peer)
{
var write = BeginReceipted(peer, "put", message.MessageId, message.Document?.SchemaId, message.Document?.RecordKey, message.Document?.Payload);
if (write != null && !write.HasId)
var idRefusal = write?.IdRefusal;
if (idRefusal != null)
{
write.Refused(CultNetErrorMessage.ForMessageInvalid("messageId", "a write needs a messageId"));
write!.Refused(idRefusal);
return;
}
var missing = message.Document == null ? "document" : message.Document.SchemaId == null ? "schemaId" : null;
if (missing != null)
{
Refuse(peer, write, CultNetErrorMessage.ForMessageInvalid(missing, $"{missing} is required"));
return;
}
@ -484,9 +492,16 @@ namespace GameCult.Networking
private async Task HandleDeleteAsync(CultNetDocumentDeleteMessage message, CultNetServerPeer peer)
{
var write = BeginReceipted(peer, "delete", message.MessageId, message.SchemaId, message.RecordKey, null);
if (write != null && !write.HasId)
var idRefusal = write?.IdRefusal;
if (idRefusal != null)
{
write.Refused(CultNetErrorMessage.ForMessageInvalid("messageId", "a write needs a messageId"));
write!.Refused(idRefusal);
return;
}
if (message.SchemaId == null)
{
Refuse(peer, write, CultNetErrorMessage.ForMessageInvalid("schemaId", "schemaId is required"));
return;
}