} from "./inbound-dedupe.js";

import { materializeDiscordInboundJob, type DiscordInboundJob } from "./inbound-job.js";

import type { RuntimeEnv } from "./message-handler.preflight.types.js";

import { processDiscordMessage } from "./message-handler.process.js";

import { deliverDiscordReply } from "./reply-delivery.js";

import type { DiscordMonitorStatusSink } from "./status.js";

import { resolveDiscordReplyDeliveryPlan } from "./threading.js";

import { normalizeDiscordInboundWorkerTimeoutMs, runDiscordTaskWithTimeout } from "./timeouts.js";

type ProcessDiscordMessage = typeof import("./message-handler.process.js").processDiscordMessage;

type DeliverDiscordReply = typeof import("./reply-delivery.js").deliverDiscordReply;

type DiscordInboundWorkerParams = {

runtime: RuntimeEnv;

setStatus?: DiscordMonitorStatusSink;

};

export type DiscordInboundWorkerTestingHooks = {

processDiscordMessage?: typeof processDiscordMessage;

deliverDiscordReply?: typeof deliverDiscordReply;

processDiscordMessage?: ProcessDiscordMessage;

deliverDiscordReply?: DeliverDiscordReply;

};

let messageProcessRuntimePromise:

| Promise<typeof import("./message-handler.process.js")>

| undefined;

let replyDeliveryRuntimePromise: Promise<typeof import("./reply-delivery.js")> | undefined;

async function loadMessageProcessRuntime() {

messageProcessRuntimePromise ??= import("./message-handler.process.js");

return await messageProcessRuntimePromise;

}

async function loadReplyDeliveryRuntime() {

replyDeliveryRuntimePromise ??= import("./reply-delivery.js");

return await replyDeliveryRuntimePromise;

}

function formatDiscordRunContextSuffix(job: DiscordInboundJob): string {

const channelId = job.payload.messageChannelId?.trim();

const messageId = job.payload.data?.message?.id?.trim();

let finalReplyStarted = false;

let createdThreadId: string | undefined;

let sessionKey: string | undefined;

const processDiscordMessageImpl = params.testing?.processDiscordMessage ?? processDiscordMessage;

const processDiscordMessageImpl =

params.testing?.processDiscordMessage ??

(await loadMessageProcessRuntime()).processDiscordMessage;

try {

await runDiscordTaskWithTimeout({

run: async (abortSignal) => {

contextSuffix: string;

createdThreadId?: string;

sessionKey?: string;

deliverDiscordReplyImpl?: typeof deliverDiscordReply;

deliverDiscordReplyImpl?: DeliverDiscordReply;

}) {

const messageChannelId = params.job.payload.messageChannelId?.trim();

const messageId = params.job.payload.message?.id?.trim();

});

try {

await (params.deliverDiscordReplyImpl ?? deliverDiscordReply)({

const deliverDiscordReplyImpl =

params.deliverDiscordReplyImpl ?? (await loadReplyDeliveryRuntime()).deliverDiscordReply;

await deliverDiscordReplyImpl({

cfg: params.job.payload.cfg,

replies: [{ text: "Discord inbound worker timed out.", isError: true }],

target: deliveryPlan.deliverTarget,