[fix](trx-frontend-http): restore decode history from the stored records #36
@@ -7424,7 +7424,7 @@ function connectDecode() {
|
||||
return;
|
||||
}
|
||||
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);
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -6366,7 +6366,12 @@ function connectDecode() {
|
||||
}
|
||||
if (data.type === "group") {
|
||||
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);
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user