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

Prove native QUIC against the released Aetheria daemon

Browse source
This commit is contained in:
Meta Vens 2026-07-19 23:30:44 +01:00
commit 63dfe1f792
7 changed files with 70 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
TestProject/Assets/Tests/PlayMode/GameCult.EveUnity.GenericClient.PlayModeTests.asmdef
View file

@ -16,6 +16,7 @@
"GameCult.Caching.dll",
"GameCult.Caching.MessagePack.dll",
"GameCult.Mesh.dll",
"GameCult.Mesh.Quic.Native.dll",
"GameCult.Networking.dll"
],
"autoReferenced": false,

32
TestProject/Assets/Tests/PlayMode/GenericWorldCaptureTests.cs
View file

@ -3,6 +3,8 @@ using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using GameCult.Caching;
using GameCult.Caching.MessagePack;
using GameCult.Eve.Surface;
@ -10,6 +12,7 @@ using GameCult.Eve.UnityUIToolkit;
using GameCult.Eve.UnityScene;
using GameCult.Eve.UnityScene.Fields;
using GameCult.Mesh;
using GameCult.Mesh.Quic.Native;
using NUnit.Framework;
using UnityEngine;
using UnityEngine.Rendering;
@ -305,6 +308,18 @@ namespace GameCult.EveUnity.GenericClient.PlayModeTests
Assert.That(provider.Selection.VerseId, Is.Not.Empty);
Assert.That(provider.Selection.ProviderId, Is.Not.Empty);
Assert.That(provider.Selection.SurfaceId, Is.Not.Empty);
var quicProof = ReceiveAdvertisedRealtimeFrameAsync(
rendezvousEndpoint,
provider.Selection.VerseId);
var quicDeadline = Time.realtimeSinceStartup + 15f;
while (!quicProof.IsCompleted && Time.realtimeSinceStartup < quicDeadline)
yield return new WaitForSecondsRealtime(0.05f);
if (!quicProof.IsCompleted)
throw new TimeoutException("Timed out receiving advertised CultMesh QUIC state in Unity.");
var quicFrame = quicProof.GetAwaiter().GetResult();
Assert.That(quicFrame.Delivery, Is.EqualTo(CultMeshRealtimeDelivery.LatestOnly));
Assert.That(quicFrame.BodyId, Is.Not.Empty);
Assert.That(quicFrame.SchemaId, Is.Not.Empty);
Assert.That(provider.CurrentAssetBodyTransportKind, Is.Null,
"Publishing the provider catalog eagerly transferred an asset bundle.");
host = root.AddComponent<EveUnityPlayableWorldClientHost>();
@ -1166,6 +1181,23 @@ namespace GameCult.EveUnity.GenericClient.PlayModeTests
}
}
private static async Task<CultMeshRealtimeFrame> ReceiveAdvertisedRealtimeFrameAsync(
string rendezvousEndpoint,
string verseId)
{
using var timeout = new CancellationTokenSource(TimeSpan.FromSeconds(15));
using var client = new CultMeshClient(new CultMeshClientOptions
{
RendezvousEndpoints = new[] { rendezvousEndpoint },
RealtimeConnectors = new ICultMeshRealtimeTransportConnector[]
{
new CultMeshNativeQuicRealtimeTransportConnector()
}
});
using var session = await client.ConnectRealtimeAsync(verseId, timeout.Token);
return await session.ReceiveAsync(timeout.Token);
}
private static void WriteWitnessFacts(
string witnessProfile,
string gameplayScenario,