trade-message-center/apps/chrome-extension/src/onetalk/main-page/message-observer/index.ts

// 分发 OneTalk WebSocket 帧到消息解析分支

import { isObjectRecord } from "../../../lib/guards.ts";
import { parseNewMessages } from "./new.ts";
import type { OneTalkPageWindow } from "../model.ts";
import { createParsedMessageBatch, type OneTalkParsedMessageBatch } from "./model.ts";
import type { OneTalkQuoteSourceIndex } from "./quote-source-index.ts";

/** 识别响应帧并委派到历史或新消息解析器。 */
export const parseOneTalkMessages = (
    pageWindow: OneTalkPageWindow,
    data: unknown,
    quoteSources?: OneTalkQuoteSourceIndex,
): OneTalkParsedMessageBatch => {
    if (typeof data !== "string") return createParsedMessageBatch([]);

    let frame: unknown;
    try {
        frame = JSON.parse(data);
    } catch {
        return createParsedMessageBatch([]);
    }

    if (!isObjectRecord(frame) || frame.code !== 200) return createParsedMessageBatch([]);

    // History responses are consumed once through the SDK history adapter. Observing the raw
    // WebSocket response as well creates a second source of truth whose wrapper lacks SDK-only
    // classification fields (for example the one-hour system-notice marker).
    if (isObjectRecord(frame.body) && Array.isArray(frame.body.userMessageModels))
        return createParsedMessageBatch([]);

    return Array.isArray(frame.body)
        ? createParsedMessageBatch(parseNewMessages(frame.body, pageWindow, quoteSources))
        : createParsedMessageBatch([]);
};