}

}

let mockedNativeStreaming = false;

let mockedBlockStreamingEnabled: boolean | undefined = false;

let capturedReplyOptions: { disableBlockStreaming?: boolean } | undefined;

let mockedDispatchSequence: Array<{

kind: "tool" | "block" | "final";

payload: { text: string; isError?: boolean; mediaUrl?: string; mediaUrls?: string[] };

}));

vi.mock("openclaw/plugin-sdk/channel-streaming", () => ({

resolveChannelStreamingBlockEnabled: () => false,

resolveChannelStreamingBlockEnabled: () => mockedBlockStreamingEnabled,

resolveChannelStreamingNativeTransport: () => mockedNativeStreaming,

resolveChannelStreamingPreviewToolProgress: () => true,

}));

markDispatchIdle: () => {},

}),

dispatchInboundMessage: async (params: {

replyOptions?: { disableBlockStreaming?: boolean };

dispatcher: {

deliver: (

payload: { text: string; isError?: boolean; mediaUrl?: string; mediaUrls?: string[] },

info: { kind: "tool" | "block" | "final" },

) => Promise<void>;

};

}) => {

capturedReplyOptions = params.replyOptions;

for (const entry of mockedDispatchSequence) {

await params.dispatcher.deliver(entry.payload, { kind: entry.kind });

}

startSlackStreamMock.mockReset();

stopSlackStreamMock.mockReset();

mockedNativeStreaming = false;

mockedBlockStreamingEnabled = false;

capturedReplyOptions = undefined;

mockedDispatchSequence = [{ kind: "final", payload: { text: FINAL_REPLY_TEXT } }];

createSlackDraftStreamMock.mockReturnValue(createDraftStreamStub());

);

});

it("suppresses block streaming when Slack draft preview streaming is active", async () => {

mockedBlockStreamingEnabled = true;

await dispatchPreparedSlackMessage(createPreparedSlackMessage());

expect(capturedReplyOptions?.disableBlockStreaming).toBe(true);

});

it("keeps same-content tool and final payloads distinct after preview fallback", async () => {

mockedDispatchSequence = [

{ kind: "tool", payload: { text: SAME_TEXT } },