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

Poll advertised entity views for live updates

Browse source
This commit is contained in:
Meta Vens 2026-07-14 00:45:39 +01:00
commit 474cadac1c
2 changed files with 39 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -57,6 +57,9 @@ namespace GameCult.Eve.UnityScene
private EveAdvertisedSurface? _advertisedSurface;
private CultMeshBodyPublicationResolver? _bodyResolver;
private DateTime _nextReceiptPollUtc;
private DateTime _nextEntityViewPollUtc;
private long _lastQueuedEntityViewEpoch = -1;
private long _lastQueuedEntityViewSequence = -1;
public EveUnityCultMeshLiveProviderTransport(
string replicaPath,
@ -133,6 +136,7 @@ namespace GameCult.Eve.UnityScene
public void PumpLiveEvents()
{
PollCurrentEntityView();
while (_liveDocuments.TryDequeue(out var document))
{
if (document is EveEntitySoaViewDocument entityView)
@ -145,6 +149,36 @@ namespace GameCult.Eve.UnityScene
PollPendingReceipts();
}
private void PollCurrentEntityView()
{
if (DateTime.UtcNow < _nextEntityViewPollUtc)
return;
_nextEntityViewPollUtc = DateTime.UtcNow.AddMilliseconds(250);
var lowered = new EveUnitySceneSurfaceLowerer()
.Lower(CurrentSurfaceDocument.SurfaceDocument, CurrentSurfaceDocument.AdvertisedSurface);
var pointer = lowered.PlayableWorld?.EntityViewPointerId ?? "";
if (string.IsNullOrWhiteSpace(pointer))
return;
var current = _snapshot!
.FetchDocumentsAsync<EveEntitySoaViewDocument>(
recordKeys: new[] { pointer },
schemaIds: new[] { EveEntitySoaViewDocument.SchemaId })
.GetAwaiter().GetResult().FirstOrDefault();
if (current != null)
QueueEntityView(current);
}
private void QueueEntityView(EveEntitySoaViewDocument document)
{
if (document.ProducerEpoch < _lastQueuedEntityViewEpoch ||
(document.ProducerEpoch == _lastQueuedEntityViewEpoch &&
document.Sequence <= _lastQueuedEntityViewSequence))
return;
_lastQueuedEntityViewEpoch = document.ProducerEpoch;
_lastQueuedEntityViewSequence = document.Sequence;
_liveDocuments.Enqueue(document);
}
private void PollPendingReceipts()
{
if (_pendingCommandIds.Count == 0 || DateTime.UtcNow < _nextReceiptPollUtc)
@ -509,7 +543,7 @@ namespace GameCult.Eve.UnityScene
schemaIds: new[] { EveEntitySoaViewDocument.SchemaId })
.GetAwaiter().GetResult().FirstOrDefault();
if (current != null)
_liveDocuments.Enqueue(current);
QueueEntityView(current);
}
_subscriptions.SubscribeAsync(
"eve-unity-surface",
@ -530,7 +564,9 @@ namespace GameCult.Eve.UnityScene
private void OnReplicatedDocumentChanged(CultNetReplicatedDocumentChange change)
{
if (change.Document is EveEntitySoaViewDocument or EveSurfaceDocument or EveCommandReceiptDocument)
if (change.Document is EveEntitySoaViewDocument entityView)
QueueEntityView(entityView);
else if (change.Document is EveSurfaceDocument or EveCommandReceiptDocument)
_liveDocuments.Enqueue(change.Document);
}

2
packages/org.gamecult.eve.unity-scene/package.json
View file

@ -1,7 +1,7 @@
{
"name": "org.gamecult.eve.unity-scene",
"displayName": "Eve Unity Scene Lowering",
"version": "0.3.14",
"version": "0.3.15",
"unity": "2021.3",
"description": "Provider-agnostic Unity scene shell for gamecult.eve.surface.v1 interactive world surfaces.",
"dependencies": {