From bba3096a82e4a95ff2a8845d56b900398a114da0 Mon Sep 17 00:00:00 2001
From: remilia <remilia@flandre.net>
Date: Tue, 13 May 2025 21:03:48 +0800
Subject: [PATCH] fix command

---
 flandre/launcher.py | 30 ++++++++++++++++++++++++++++--
 1 file changed, 28 insertions(+), 2 deletions(-)

diff --git a/flandre/launcher.py b/flandre/launcher.py
index 9494434..ba58c14 100644
--- a/flandre/launcher.py
+++ b/flandre/launcher.py
@@ -1,3 +1,4 @@
+import hashlib
 import importlib
 import logging
 import multiprocessing
@@ -217,8 +218,8 @@ def device_upload(name, file: TextIOWrapper):
     dd.set_name_and_file_only(name, file.read())
 
 
-@device.command('recvtest')
-def device_recv_test():
+@device.command('recvplot')
+def device_recvplot():
     ctx = zmq.Context()
     pull = ctx.socket(zmq.PULL)
     pull.connect(C.live_push_socket)
@@ -235,6 +236,31 @@ def device_recv_test():
         print((ts - last_ts)/10**6,flush=True)
         last_ts = ts
 
+def b2b(b):
+    return hashlib.blake2b(b, digest_size=4).hexdigest()
+
+@device.command('recvzero')
+def device_recvzero():
+    ctx = zmq.Context()
+    pull = ctx.socket(zmq.PULL)
+    pull.connect(C.live_push_socket)
+    last_ts = 0
+    last_sequence_id = 0
+    last_b = b''
+    first = True
+    while True:
+        b = pull.recv()
+        ts, sequence_id, encoder, buffer = b2t(b)
+        if ts==last_ts:
+            print('tszero', sequence_id, encoder, (ts - last_ts)/10**6,flush=True)
+            print(b2b(b),b2b(last_b))
+        if sequence_id==last_sequence_id:
+            print('szero', sequence_id, encoder,flush=True)
+            print(b2b(b),b2b(last_b))
+        last_ts = ts
+        last_sequence_id = sequence_id
+        last_b = b
+
 
 if __name__ == '__main__':
     entrypoint()