mirror of
https://github.com/PR0M3TH3AN/SeedPass.git
synced 2025-09-08 15:28:44 +00:00
Merge pull request #527 from PR0M3TH3AN/codex/update-dummyrelayclient-to-support-created_at
Update dummy relay events with timestamps
This commit is contained in:
@@ -1,4 +1,6 @@
|
|||||||
import sys
|
import sys
|
||||||
|
import time
|
||||||
|
import json
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
sys.path.append(str(Path(__file__).resolve().parents[1]))
|
sys.path.append(str(Path(__file__).resolve().parents[1]))
|
||||||
@@ -183,11 +185,18 @@ class DummyRelayClient:
|
|||||||
if isinstance(event, DummyEvent):
|
if isinstance(event, DummyEvent):
|
||||||
event.id = eid
|
event.id = eid
|
||||||
if event.kind == KIND_MANIFEST:
|
if event.kind == KIND_MANIFEST:
|
||||||
|
try:
|
||||||
|
data = json.loads(event.content())
|
||||||
|
event.delta_since = data.get("delta_since")
|
||||||
|
except Exception:
|
||||||
|
event.delta_since = None
|
||||||
self.manifests.append(event)
|
self.manifests.append(event)
|
||||||
elif event.kind == KIND_SNAPSHOT_CHUNK:
|
elif event.kind == KIND_SNAPSHOT_CHUNK:
|
||||||
ident = event.tags[0] if event.tags else str(self.counter)
|
ident = event.tags[0] if event.tags else str(self.counter)
|
||||||
self.chunks[ident] = event
|
self.chunks[ident] = event
|
||||||
elif event.kind == KIND_DELTA:
|
elif event.kind == KIND_DELTA:
|
||||||
|
if not hasattr(event, "created_at"):
|
||||||
|
event.created_at = int(time.time())
|
||||||
self.deltas.append(event)
|
self.deltas.append(event)
|
||||||
return DummySendResult(eid)
|
return DummySendResult(eid)
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user