@@ -1503,14 +1503,25 @@ describe("dispatchTelegramMessage draft streaming", () => {
15031503const groupHistories = new Map([
15041504[historyKey, [{ sender: "Alice", body: "side chatter", timestamp: 1 }]],
15051505]);
1506-dispatchReplyWithBufferedBlockDispatcher.mockResolvedValue({
1507-queuedFinal: false,
1508-counts: { block: 0, final: 0, tool: 0 },
1509-sourceReplyDeliveryMode: "message_tool_only",
1506+const statusReactionController = createStatusReactionController();
1507+loadSessionStore.mockReturnValue({
1508+"agent:main:telegram:group:-100123": { reasoningLevel: "stream" },
1509+});
1510+dispatchReplyWithBufferedBlockDispatcher.mockImplementation(async ({ replyOptions }) => {
1511+await replyOptions?.onReasoningStream?.({ text: "<think>ambient reasoning</think>" });
1512+await replyOptions?.onToolStart?.({ name: "exec", phase: "start" });
1513+await replyOptions?.onCompactionStart?.();
1514+await replyOptions?.onCompactionEnd?.();
1515+return {
1516+queuedFinal: false,
1517+counts: { block: 0, final: 0, tool: 0 },
1518+sourceReplyDeliveryMode: "message_tool_only",
1519+};
15101520});
1511152115121522await dispatchWithContext({
15131523context: createContext({
1524+statusReactionController: statusReactionController as never,
15141525ctxPayload: {
15151526InboundTurnKind: "room_event",
15161527SessionKey: "agent:main:telegram:group:-100123",
@@ -1539,14 +1550,23 @@ describe("dispatchTelegramMessage draft streaming", () => {
15391550sourceReplyDeliveryMode?: string;
15401551suppressTyping?: boolean;
15411552allowProgressCallbacksWhenSourceDeliverySuppressed?: boolean;
1553+onReasoningStream?: unknown;
1554+onCompactionStart?: unknown;
1555+onCompactionEnd?: unknown;
15421556};
15431557};
15441558expect(dispatchParams.replyOptions?.sourceReplyDeliveryMode).toBe("message_tool_only");
15451559expect(dispatchParams.replyOptions?.suppressTyping).toBe(true);
15461560expect(dispatchParams.replyOptions?.allowProgressCallbacksWhenSourceDeliverySuppressed).toBe(
15471561false,
15481562);
1563+expect(dispatchParams.replyOptions?.onReasoningStream).toBeUndefined();
1564+expect(dispatchParams.replyOptions?.onCompactionStart).toBeUndefined();
1565+expect(dispatchParams.replyOptions?.onCompactionEnd).toBeUndefined();
15491566expect(createTelegramDraftStream).not.toHaveBeenCalled();
1567+expect(statusReactionController.setTool).not.toHaveBeenCalled();
1568+expect(statusReactionController.setCompacting).not.toHaveBeenCalled();
1569+expect(statusReactionController.setThinking).not.toHaveBeenCalled();
15501570expect(deliverReplies).not.toHaveBeenCalled();
15511571expect(groupHistories.get(historyKey)).toHaveLength(1);
15521572});
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。