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

import {

buildDiscordMediaPayload,

resolveReferencedReplyMediaList,

resolveDiscordMessageText,

type DiscordMediaInfo,

} from "./message-utils.js";

import { buildDirectLabel, buildGuildLabel, resolveReplyContext } from "./reply-context.js";

import { resolveDiscordAutoThreadReplyPlan, resolveDiscordThreadStarter } from "./threading.js";

import {

DISCORD_ATTACHMENT_IDLE_TIMEOUT_MS,

DISCORD_ATTACHMENT_TOTAL_TIMEOUT_MS,

} from "./timeouts.js";

function normalizeDiscordDmOwnerEntry(entry: string): string | undefined {

const normalized = normalizeDiscordAllowList([entry], ["discord:", "user:", "pk:"]);

const candidate = normalized?.ids.values().next().value;

return typeof candidate === "string" && /^\d+$/.test(candidate) ? candidate : undefined;

}

function isContextAborted(abortSignal?: AbortSignal): boolean {

return Boolean(abortSignal?.aborted);

}

export async function buildDiscordMessageProcessContext(params: {

ctx: DiscordMessagePreflightContext;

text: string;

discordConfig,

accountId,

runtime,

mediaMaxBytes,

discordRestFetch,

abortSignal,

guildHistories,

historyLimit,

replyToMode,

if (replyContext && !filteredReplyContext && isGuildMessage) {

logVerbose(`discord: drop reply context (mode=${contextVisibilityMode})`);

}

const mediaListForContext = [...mediaList];

if (filteredReplyContext) {

const referencedReplyMediaList = await resolveReferencedReplyMediaList(message, mediaMaxBytes, {

fetchImpl: discordRestFetch,

ssrfPolicy: cfg.browser?.ssrfPolicy,

readIdleTimeoutMs: DISCORD_ATTACHMENT_IDLE_TIMEOUT_MS,

totalTimeoutMs: DISCORD_ATTACHMENT_TOTAL_TIMEOUT_MS,

abortSignal,

});

if (!isContextAborted(abortSignal)) {

mediaListForContext.push(...referencedReplyMediaList);

}

}

if (forumContextLine) {

combinedBody = `${combinedBody}\n${forumContextLine}`;

}

parentSessionKey = undefined;

}

}

const mediaPayload = buildDiscordMediaPayload(mediaList);

const mediaPayload = buildDiscordMediaPayload(mediaListForContext);

const preflightAudioIndex =

preflightAudioTranscript === undefined

? -1

: mediaList.findIndex((media) => media.contentType?.startsWith("audio/"));

: mediaListForContext.findIndex((media) => media.contentType?.startsWith("audio/"));

const threadKeys = resolveThreadSessionKeys({

baseSessionKey,

threadId: threadChannel ? messageChannelId : undefined,