sjg/trx-rs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[fix](trx-frontend-http): restore decode history from the stored records #36

Merged
sjg merged 1 commits from fix/decode-history-replay into main 2026-08-03 18:39:37 +02:00
Conversation 0 Commits 1 Files Changed 2
+7 -2
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/trx-client/trx-frontend/trx-frontend-http/assets/web/generated/app.js
+1 -1
View File
@@ -7424,7 +7424,7 @@ function connectDecode() {
return; return;
} }
if (data.type === "group") { if (data.type === "group") {
const messages = Array.isArray(data.messages) ? data.messages.filter((message) => isRecord2(message) && typeof message.type === "string") : []; const messages = Array.isArray(data.messages) ? data.messages.filter((message) => isRecord2(message)) : [];
enqueueDecodeHistoryGroup(typeof data.kind === "string" ? data.kind : "", messages); enqueueDecodeHistoryGroup(typeof data.kind === "string" ? data.kind : "", messages);
return; return;
} }
src/trx-client/trx-frontend/trx-frontend-http/frontend/src/app.ts
+6 -1
View File
@@ -6366,7 +6366,12 @@ function connectDecode() {
} }
if (data.type === "group") { if (data.type === "group") {
const messages = Array.isArray(data.messages) const messages = Array.isArray(data.messages)
? data.messages.filter((message): message is DecodeMessage => isRecord(message) && typeof message.type === "string") // Stored records carry only decoder fields — an AIS entry has mmsi,
// lat, lon and so on, and no `type`. That field identifies live SSE
// frames; history is already grouped, and the group's kind is
// delivered alongside these messages, so requiring it here discarded
// every restored record silently.
? data.messages.filter((message): message is DecodeMessage => isRecord(message))
: []; : [];
enqueueDecodeHistoryGroup(typeof data.kind === "string" ? data.kind : "", messages); enqueueDecodeHistoryGroup(typeof data.kind === "string" ? data.kind : "", messages);
return; return;