/** Tests block reply pipeline buffering, dedupe, and final flush behavior. */

import { MAX_TIMER_TIMEOUT_MS } from "@openclaw/normalization-core/number-coercion";

import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";

import { getReplyPayloadMetadata, setReplyPayloadMetadata } from "../reply-payload.js";

import {

expect(pipeline.hasSentPayload({ text: "summary" })).toBe(false);

});

it("clamps oversized delivery timeouts before arming timers", async () => {

vi.useFakeTimers();

const setTimeoutSpy = vi.spyOn(globalThis, "setTimeout");

const observedTimeouts: number[] = [];

const pipeline = createBlockReplyPipeline({

onBlockReply: async (_payload, options) => {

observedTimeouts.push(options?.timeoutMs ?? 0);

await waitForAbort(options?.abortSignal);

},

timeoutMs: MAX_TIMER_TIMEOUT_MS + 1,

});

pipeline.enqueue({ text: "slow block" });

const flushing = pipeline.flush({ force: true });

await Promise.resolve();

expect(setTimeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);

expect(observedTimeouts).toEqual([MAX_TIMER_TIMEOUT_MS]);

await vi.advanceTimersByTimeAsync(MAX_TIMER_TIMEOUT_MS);

await flushing;

expect(pipeline.isAborted()).toBe(true);

setTimeoutSpy.mockRestore();

});

});

// Buffers streaming reply blocks before coalesced final delivery.

import { clampPositiveTimerTimeoutMs } from "@openclaw/normalization-core/number-coercion";

import {

hasOutboundReplyContent,

resolveSendableOutboundReplyParts,

}

};

function resolveBlockReplyTimeoutMs(timeoutMs: number): number {

return clampPositiveTimerTimeoutMs(timeoutMs) ?? 0;

}

/** Creates the ordered block reply delivery pipeline for streamed payloads. */

export function createBlockReplyPipeline(params: {

onBlockReply: (

coalescing?: BlockStreamingCoalescing;

buffer?: BlockReplyBuffer;

}): BlockReplyPipeline {

const { onBlockReply, timeoutMs, coalescing, buffer } = params;

const { onBlockReply, coalescing, buffer } = params;

const timeoutMs = resolveBlockReplyTimeoutMs(params.timeoutMs);

const sentKeys = new Set<string>();

const sentContentKeys = new Set<string>();

const sentMediaUrls = new Set<string>();