serversdown/seismo-relay
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(protocol): update extra chunk fetching logic to stop at silence detection

Browse Source
This commit is contained in:
Brian Harrison
2026-04-23 18:28:14 -04:00
parent ecd980d345
commit fa887b85d9
2 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
minimateplus/protocol.py
+20 -15
View File
@@ -652,13 +652,12 @@ class MiniMateProtocol:
# and primes the device to return a valid footer in the termination
# response. Without it, termination returns an empty ack with no
# footer bytes (confirmed 2026-04-23 from HxD comparison).
# Download extra chunks until we find the footer chunk (contains
# 0x0e 0x08 near its end) or hit the extra_chunks_after_metadata
# cap. The footer bytes are embedded in the last meaningful data
# chunk, NOT in the termination response. For short events (1-sec)
# the footer is in extra chunk 1. For longer events it is in a
# later chunk. Confirmed 2026-04-23 from BW file comparison.
log.debug("5A A5[%d] metadata found — fetching extra chunks until footer found",
# Download extra chunks until we hit post-event silence (all-FF
# ADC values) or the cap. The device returns the footer in the
# termination response only when we stop at the right point —
# right after the last real data chunk, before silence starts.
# Silence detection: >80% of payload bytes are 0xFF.
log.debug("5A A5[%d] metadata found — fetching extra chunks until silence",
chunk_num)
for _extra_n in range(extra_chunks_after_metadata):
chunk_num += 1
@@ -667,20 +666,26 @@ class MiniMateProtocol:
self._send(build_5a_frame(_BULK_CHUNK_OFFSET, params))
try:
extra = self._recv_one(expected_sub=rsp_sub, timeout=10.0)
log.debug("5A A5[%d] extra chunk page_key=0x%04X data_len=%d has_footer=%s",
chunk_num, extra.page_key, len(extra.data),
b'\x0e\x08' in extra.data[-50:])
payload = extra.data[7:] # skip 7-byte frame header
ff_ratio = payload.count(0xFF) / max(len(payload), 1)
is_silence = ff_ratio > 0.8
log.debug(
"5A A5[%d] extra chunk page_key=0x%04X data_len=%d "
"ff_ratio=%.2f silence=%s",
chunk_num, extra.page_key, len(extra.data),
ff_ratio, is_silence,
)
if extra.page_key == 0x0000:
if include_terminator:
frames_data.append(extra)
return frames_data
frames_data.append(extra)
# Stop as soon as we find the footer marker in the tail
# of this chunk — the body is complete.
if b'\x0e\x08' in extra.data[-50:]:
log.debug("5A A5[%d] footer marker found — stopping extra chunks",
if is_silence:
# Don't include the silence chunk — terminate here.
# The termination response will contain the footer.
log.debug("5A A5[%d] silence detected — stopping before this chunk",
chunk_num)
break
frames_data.append(extra)
except TimeoutError:
log.debug("5A extra chunk %d timed out — end of stream", _extra_n + 1)
break