import { createBlockReplyCoalescer } from "./block-reply-coalescer.js";

import type { BlockStreamingCoalescing } from "./block-streaming.js";

/** Streaming block reply pipeline that tracks sent content and media. */

export type BlockReplyPipeline = {

enqueue: (payload: ReplyPayload) => void;

flush: (options?: { force?: boolean }) => Promise<void>;

getSentMediaUrls: () => readonly string[];

};

/** Optional buffering strategy used before payloads enter block delivery. */

export type BlockReplyBuffer = {

shouldBuffer: (payload: ReplyPayload) => boolean;

onEnqueue?: (payload: ReplyPayload) => void;

finalize?: (payload: ReplyPayload) => ReplyPayload;

};

/** Buffers audio payloads so final delivery can preserve voice presentation. */

export function createAudioAsVoiceBuffer(params: {

isAudioPayload: (payload: ReplyPayload) => boolean;

}): BlockReplyBuffer {

};

}

/** Creates a stable duplicate key for a complete outbound payload. */

export function createBlockReplyPayloadKey(payload: ReplyPayload): string {

const reply = resolveSendableOutboundReplyParts(payload);

return JSON.stringify({

});

}

/** Creates a duplicate key that ignores reply target for final suppression. */

export function createBlockReplyContentKey(payload: ReplyPayload): string {

const reply = resolveSendableOutboundReplyParts(payload);

// Content-only key used for final-payload suppression after block streaming.

}

};

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

export function createBlockReplyPipeline(params: {

onBlockReply: (

payload: ReplyPayload,

}

pendingKeys.add(payloadKey);

// Preserve outbound order by chaining sends; abort after timeout to avoid stale blocks.

const timeoutError = new Error(`block reply delivery timed out after ${timeoutMs}ms`);

const abortController = new AbortController();

sendChain = sendChain