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

Tests: the Mesh same-schema read serves only owned rows; the unowned put answer must try to send

Browse source 
Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-09-30 06:23:09 +02:00
commit 6e406879be
2 changed files with 29 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

26
tests/GameCult.Mesh.Tests/CultMeshStreamingTests.cs
View file

@ -938,6 +938,32 @@ public sealed class CultMeshStreamingTests
await act.Should().ThrowAsync<NotSupportedException>();
}
// A database serves only what its shards own, including when a handle reads a same-schema instance of another CLR type
// out of the cache behind it.
[TestCase("tests.mesh_note.v1", true)]
[TestCase("tests.unrelated.v1", false)]
public async Task DocumentHandle_ReadsASameSchemaInstanceOnlyWhenAShardOwnsIt(string ownedSchemaId, bool served)
{
var cache = new CultCache();
var key = new CultRecordKey("note:one");
await cache.UpsertAsync(new MeshNoteDocument { Schema = "tests.mesh_note.v1", Text = "cached" }, new CultRecordHandle<MeshNoteDocument>(key));
var database = new CultNetDatabase(cache, new CultNetDatabaseOptions
{
RuntimeId = "reader",
Shards = new[] { new CultNetShardDescriptor("notes", "reader", epoch: 1, isPrimary: true, schemaIds: new[] { ownedSchemaId }) }
});
var handle = CultMesh.Document<MeshNoteAliasDocument>(database, key, CultMesh.Verse("starbridge", "reader"));
if (served)
{
(await handle.LatestAsync()).Text.Should().Be("cached");
}
else
{
await FluentActions.Awaiting(() => handle.LatestAsync()).Should().ThrowAsync<KeyNotFoundException>();
}
}
[Test]
public async Task DocumentHandle_SubmitsPredictionsThroughCultNetDatabase()
{

5
tests/GameCult.Networking.Tests/CultNetJournalTests.cs
View file

@ -727,7 +727,7 @@ namespace GameCult.Networking.Tests
// CultNetErrorMessage carrying the refusal. The handler is reached through its private delegate with an
// uninitialized peer, as the R-AM test does; the send then fails on that peer, after the failure was logged.
[Test]
public async Task TheServerAnswersARemotePutOfASchemaNoShardOwnsWithAnApplicationRejection()
public void TheServerAnswersARemotePutOfASchemaNoShardOwnsWithAnApplicationRejection()
{
var (database, cache, _, unowned) = OwnedNothingOfNote();
using var server = new Server(cache, ServerSecurityOptions.Development());
@ -739,7 +739,8 @@ namespace GameCult.Networking.Tests
.GetValue(databaseServer)!;
var peer = (CultNetServerPeer)System.Runtime.CompilerServices.RuntimeHelpers.GetUninitializedObject(typeof(CultNetServerPeer));
try { await handler(UnownedPut(database), peer); } catch (Exception) { }
// The handler answers the peer with the refusal; the uninitialized peer cannot send, which is how the test knows it tried.
Assert.CatchAsync(async () => await handler(UnownedPut(database), peer));
Assert.That(logger.Warnings, Has.Some.Contains("raw put refused").And.Contains(unowned));
Assert.That(logger.Errors, Is.Empty, "a refusal is not a fault");