import { channelRouteIdentityKey } from "../../../channels/route/ref.js";

import { resolveGlobalDedupeCache } from "../../../infra/dedupe.js";

import { normalizeOptionalString } from "../../../shared/string-coerce.js";

import { applyQueueDropPolicy, shouldSkipQueueItem } from "../../../utils/queue-helpers.js";

maxSize: 10_000,

});

function followupRouteIdentityKey(run: FollowupRun): string {

return channelRouteIdentityKey({

channel: run.originatingChannel,

to: run.originatingTo,

accountId: run.originatingAccountId,

threadId: run.originatingThreadId,

});

}

function buildRecentMessageIdKey(run: FollowupRun, queueKey: string): string | undefined {

const messageId = normalizeOptionalString(run.messageId);

if (!messageId) {

return undefined;

}

// Use JSON tuple serialization to avoid delimiter-collision edge cases when

// channel/to/account values contain "|" characters.

return JSON.stringify([

"queue",

queueKey,

run.originatingChannel ?? "",

run.originatingTo ?? "",

run.originatingAccountId ?? "",

run.originatingThreadId == null ? "" : String(run.originatingThreadId),

messageId,

]);

return JSON.stringify(["queue", queueKey, followupRouteIdentityKey(run), messageId]);

}

function isRunAlreadyQueued(

run: FollowupRun,

items: FollowupRun[],

allowPromptFallback = false,

): boolean {

const hasSameRouting = (item: FollowupRun) =>

item.originatingChannel === run.originatingChannel &&

item.originatingTo === run.originatingTo &&

item.originatingAccountId === run.originatingAccountId &&

item.originatingThreadId === run.originatingThreadId;

const routeKey = followupRouteIdentityKey(run);

const hasSameRouting = (item: FollowupRun) => followupRouteIdentityKey(item) === routeKey;

const messageId = normalizeOptionalString(run.messageId);

if (messageId) {