import {

applyQueueDropPolicy,

applyQueueRuntimeSettings,

buildQueueSummaryPrompt,

clearQueueSummaryState,

drainCollectItemIfNeeded,

drainCollectQueueStep,

drainNextQueueItem,

hasCrossChannelItems,

previewQueueSummaryPrompt,

});

});

it("buildQueueSummaryPrompt clears state after rendering", () => {

const state = {

dropPolicy: "summarize" as const,

droppedCount: 1,

summaryLines: ["line"],

};

const prompt = buildQueueSummaryPrompt({

state,

noun: "announce",

});

expect(prompt).toContain("[Queue overflow] Dropped 1 announce due to cap.");

expect(state).toEqual({

dropPolicy: "summarize",

droppedCount: 0,

summaryLines: [],

});

});

it("clearQueueSummaryState resets summary counters", () => {

const state = {

dropPolicy: "summarize" as const,

});

});

describe("drainCollectItemIfNeeded", () => {

describe("drainCollectQueueStep", () => {

it("skips when neither force mode nor cross-channel routing is active", async () => {

const seen: number[] = [];

const items = [1];

const collectState = { forceIndividualCollect: false };

const result = await drainCollectItemIfNeeded({

forceIndividualCollect: false,

const result = await drainCollectQueueStep({

collectState,

isCrossChannel: false,

items,

run: async (item) => {

it("drains one item in force mode", async () => {

const seen: number[] = [];

const items = [1, 2];

const collectState = { forceIndividualCollect: true };

const result = await drainCollectItemIfNeeded({

forceIndividualCollect: true,

const result = await drainCollectQueueStep({

collectState,

isCrossChannel: false,

items,

run: async (item) => {

});

it("switches to force mode and returns empty when cross-channel with no queued item", async () => {

let forced = false;

const collectState = { forceIndividualCollect: false };

const result = await drainCollectItemIfNeeded({

forceIndividualCollect: false,

const result = await drainCollectQueueStep({

collectState,

isCrossChannel: true,

setForceIndividualCollect: (next) => {

forced = next;

},

items: [],

run: async () => {},

});

expect(result).toBe("empty");

expect(forced).toBe(true);

expect(collectState.forceIndividualCollect).toBe(true);

});

});