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

Complete generic Unity client state handoff

Browse source
This commit is contained in:
Meta Vens 2026-07-12 22:23:53 +01:00
commit 93551237fa
3 changed files with 32 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

29
packages/org.gamecult.eve.unity-scene/Runtime/CultMesh/EveUnityCultMeshLiveProviderTransport.cs
View file

@ -4,6 +4,8 @@ using System.IO;
using System.Linq;
using System.Security.Cryptography;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
using GameCult.Caching;
using GameCult.Caching.MessagePack;
using GameCult.Eve.Surface;
@ -348,13 +350,20 @@ namespace GameCult.Eve.UnityScene
{
var bytes = new byte[checked((int)manifest.SizeBytes)];
var references = manifest.Chunks.OrderBy(chunk => chunk.Offset).ToArray();
for (var index = 0; index < references.Length; index += 2)
var batches = references.Select((reference, index) => new { reference, index })
.GroupBy(value => value.index / 2)
.Select(group => group.Select(value => value.reference).ToArray())
.ToArray();
using var concurrency = new SemaphoreSlim(2, 2);
var downloads = batches.Select(async batch =>
{
var batch = references.Skip(index).Take(2).ToArray();
var chunks = batch.Select(reference => _mesh
.ReadAsync<CultMeshCdnArtifactChunk>(_endpointId, reference.RecordKey)
.GetAwaiter().GetResult())
.ToArray();
await concurrency.WaitAsync().ConfigureAwait(false);
try
{
var chunks = await _mesh.ReadManyAsync<CultMeshCdnArtifactChunk>(
_endpointId,
batch.Select(reference => reference.RecordKey).ToArray())
.ConfigureAwait(false);
foreach (var reference in batch)
{
var chunk = chunks.FirstOrDefault(candidate =>
@ -365,7 +374,13 @@ namespace GameCult.Eve.UnityScene
throw new InvalidDataException($"Provider asset chunk '{reference.RecordKey}' size did not match its manifest.");
Buffer.BlockCopy(chunk.Payload, 0, bytes, checked((int)reference.Offset), reference.SizeBytes);
}
}
}
finally
{
concurrency.Release();
}
}).ToArray();
Task.WhenAll(downloads).GetAwaiter().GetResult();
return bytes;
}

7
packages/org.gamecult.eve.unity-scene/Runtime/CultMesh/EveUnityCultMeshPlayableWorldProvider.cs
View file

@ -92,6 +92,8 @@ namespace GameCult.Eve.UnityScene
Bridge.Refresh();
else
Bridge.Connect();
_transport?.PumpLiveEvents();
DrainEntityViews();
}
public void Submit(EveSurfaceCommandRequest request)
@ -134,6 +136,11 @@ namespace GameCult.Eve.UnityScene
{
CompleteDiscoveryOnMainThread();
_transport?.PumpLiveEvents();
DrainEntityViews();
}
private void DrainEntityViews()
{
EveEntitySoaViewDocument? latest = null;
while (_pendingEntityViews.TryDequeue(out var next)) latest = next;
if (latest == null) return;

6
packages/org.gamecult.eve.unity-scene/Runtime/CultMesh/EveUnityCultMeshProviderDiscovery.cs
View file

@ -41,9 +41,9 @@ namespace GameCult.Eve.UnityScene
{
if (string.IsNullOrWhiteSpace(rendezvousEndpoint))
throw new ArgumentException("Rendezvous endpoint must be non-empty.", nameof(rendezvousEndpoint));
var endpointId = !string.IsNullOrWhiteSpace(verseId) ? verseId : providerId;
if (string.IsNullOrWhiteSpace(endpointId))
throw new ArgumentException("Provider or Verse identity must be supplied for CultMesh discovery.", nameof(providerId));
var endpointId = !string.IsNullOrWhiteSpace(verseId)
? verseId
: !string.IsNullOrWhiteSpace(providerId) ? providerId : "eve.providers";
var mesh = new CultMeshClient(new CultMeshClientOptions
{