type DiscordSendEmbeds,

} from "../send.shared.js";

import { resolveDiscordChannelId } from "../targets.js";

import { createDiscordActionOptions } from "./runtime.shared.js";

export const discordMessagingActionRuntime = {

createThreadDiscord,

throw new Error("Discord messaging actions require a resolved runtime config.");

}

const cfgOptions = { cfg };

const withOpts = (extra?: Record<string, unknown>) =>

createDiscordActionOptions({ cfg, accountId, extra });

const resolvedReactionAccountId = accountId ?? resolveDefaultDiscordAccountId(cfg);

const resolveReactionChannelId = async () => {

const target =

required: true,

label: "stickerIds",

});

await discordMessagingActionRuntime.sendStickerDiscord(to, stickerIds, {

...cfgOptions,

...(accountId ? { accountId } : {}),

content,

});

await discordMessagingActionRuntime.sendStickerDiscord(to, stickerIds, withOpts({ content }));

return jsonResult({ ok: true });

}

case "poll": {

await discordMessagingActionRuntime.sendPollDiscord(

to,

{ question, options: answers, maxSelections, durationHours },

{ ...cfgOptions, ...(accountId ? { accountId } : {}), content },

withOpts({ content }),

);

return jsonResult({ ok: true });

}

throw new Error("Discord permissions are disabled.");

}

const channelId = resolveChannelId();

const permissions = accountId

? await discordMessagingActionRuntime.fetchChannelPermissionsDiscord(channelId, {

...cfgOptions,

accountId,

})

: await discordMessagingActionRuntime.fetchChannelPermissionsDiscord(channelId, cfgOptions);

const permissions = await discordMessagingActionRuntime.fetchChannelPermissionsDiscord(

channelId,

withOpts(),

);

return jsonResult({ ok: true, permissions });

}

case "fetchMessage": {

"Discord message fetch requires guildId, channelId, and messageId (or a valid messageLink).",

);

}

const message = accountId

? await discordMessagingActionRuntime.fetchMessageDiscord(channelId, messageId, {

...cfgOptions,

accountId,

})

: await discordMessagingActionRuntime.fetchMessageDiscord(channelId, messageId, cfgOptions);

const message = await discordMessagingActionRuntime.fetchMessageDiscord(

channelId,

messageId,

withOpts(),

);

return jsonResult({

ok: true,

message: normalizeMessage(message),

after: readStringParam(params, "after"),

around: readStringParam(params, "around"),

};

const messages = accountId

? await discordMessagingActionRuntime.readMessagesDiscord(channelId, query, {

...cfgOptions,

accountId,

})

: await discordMessagingActionRuntime.readMessagesDiscord(channelId, query, cfgOptions);

const messages = await discordMessagingActionRuntime.readMessagesDiscord(

channelId,

query,

withOpts(),

);

return jsonResult({

ok: true,

messages: messages.map((message) => normalizeMessage(message)),

to,

payload,

{

...cfgOptions,

...(accountId ? { accountId } : {}),

...withOpts(),

silent,

replyTo: replyTo ?? undefined,

sessionKey: sessionKey ?? undefined,

}

assertMediaNotDataUrl(mediaUrl);

const result = await discordMessagingActionRuntime.sendVoiceMessageDiscord(to, mediaUrl, {

...cfgOptions,

...(accountId ? { accountId } : {}),

...withOpts(),

replyTo,

silent,

});

return jsonResult({ ok: true, result, voiceMessage: true });

}

const result = await discordMessagingActionRuntime.sendMessageDiscord(to, content ?? "", {

...cfgOptions,

...(accountId ? { accountId } : {}),

...withOpts(),

mediaUrl,

filename: filename ?? undefined,

mediaLocalRoots: options?.mediaLocalRoots,

const content = readStringParam(params, "content", {

required: true,

});

const message = accountId

? await discordMessagingActionRuntime.editMessageDiscord(

channelId,

messageId,

{ content },

{ ...cfgOptions, accountId },

)

: await discordMessagingActionRuntime.editMessageDiscord(

channelId,

messageId,

{ content },

cfgOptions,

);

const message = await discordMessagingActionRuntime.editMessageDiscord(

channelId,

messageId,

{ content },

withOpts(),

);

return jsonResult({ ok: true, message });

}

case "deleteMessage": {

const messageId = readStringParam(params, "messageId", {

required: true,

});

if (accountId) {

await discordMessagingActionRuntime.deleteMessageDiscord(channelId, messageId, {

...cfgOptions,

accountId,

});

} else {

await discordMessagingActionRuntime.deleteMessageDiscord(channelId, messageId, cfgOptions);

}

await discordMessagingActionRuntime.deleteMessageDiscord(channelId, messageId, withOpts());

return jsonResult({ ok: true });

}

case "threadCreate": {

content,

appliedTags: appliedTags ?? undefined,

};

const thread = accountId

? await discordMessagingActionRuntime.createThreadDiscord(channelId, payload, {

...cfgOptions,

accountId,

})

: await discordMessagingActionRuntime.createThreadDiscord(channelId, payload, cfgOptions);

const thread = await discordMessagingActionRuntime.createThreadDiscord(

channelId,

payload,

withOpts(),

);

return jsonResult({ ok: true, thread });

}

case "threadList": {

const includeArchived = readBooleanParam(params, "includeArchived");

const before = readStringParam(params, "before");

const limit = readNumberParam(params, "limit");

const threads = accountId

? await discordMessagingActionRuntime.listThreadsDiscord(

{

guildId,

channelId,

includeArchived,

before,

limit,

},

{ ...cfgOptions, accountId },

)

: await discordMessagingActionRuntime.listThreadsDiscord(

{

guildId,

channelId,

includeArchived,

before,

limit,

},

cfgOptions,

);

const threads = await discordMessagingActionRuntime.listThreadsDiscord(

{

guildId,

channelId,

includeArchived,

before,

limit,

},

withOpts(),

);

return jsonResult({ ok: true, threads });

}

case "threadReply": {

`channel:${channelId}`,

content,

{

...cfgOptions,

...(accountId ? { accountId } : {}),

...withOpts(),

mediaUrl,

mediaLocalRoots: options?.mediaLocalRoots,

mediaReadFile: options?.mediaReadFile,

const messageId = readStringParam(params, "messageId", {

required: true,

});

if (accountId) {

await discordMessagingActionRuntime.pinMessageDiscord(channelId, messageId, {

...cfgOptions,

accountId,

});

} else {

await discordMessagingActionRuntime.pinMessageDiscord(channelId, messageId, cfgOptions);

}

await discordMessagingActionRuntime.pinMessageDiscord(channelId, messageId, withOpts());

return jsonResult({ ok: true });

}

case "unpinMessage": {

const messageId = readStringParam(params, "messageId", {

required: true,

});

if (accountId) {

await discordMessagingActionRuntime.unpinMessageDiscord(channelId, messageId, {

...cfgOptions,

accountId,

});

} else {

await discordMessagingActionRuntime.unpinMessageDiscord(channelId, messageId, cfgOptions);

}

await discordMessagingActionRuntime.unpinMessageDiscord(channelId, messageId, withOpts());

return jsonResult({ ok: true });

}

case "listPins": {

if (!isActionEnabled("pins")) {

throw new Error("Discord pins are disabled.");

}

const channelId = resolveChannelId();

const pins = accountId

? await discordMessagingActionRuntime.listPinsDiscord(channelId, {

...cfgOptions,

accountId,

})

: await discordMessagingActionRuntime.listPinsDiscord(channelId, cfgOptions);

const pins = await discordMessagingActionRuntime.listPinsDiscord(channelId, withOpts());

return jsonResult({ ok: true, pins: pins.map((pin) => normalizeMessage(pin)) });

}

case "searchMessages": {

const limit = readNumberParam(params, "limit");

const channelIdList = [...(channelIds ?? []), ...(channelId ? [channelId] : [])];

const authorIdList = [...(authorIds ?? []), ...(authorId ? [authorId] : [])];

const results = accountId

? await discordMessagingActionRuntime.searchMessagesDiscord(

{

guildId,

content,

channelIds: channelIdList.length ? channelIdList : undefined,

authorIds: authorIdList.length ? authorIdList : undefined,

limit,

},

{ ...cfgOptions, accountId },

)

: await discordMessagingActionRuntime.searchMessagesDiscord(

{

guildId,

content,

channelIds: channelIdList.length ? channelIdList : undefined,

authorIds: authorIdList.length ? authorIdList : undefined,

limit,

},

cfgOptions,

);

const results = await discordMessagingActionRuntime.searchMessagesDiscord(

{

guildId,

content,

channelIds: channelIdList.length ? channelIdList : undefined,

authorIds: authorIdList.length ? authorIdList : undefined,

limit,

},

withOpts(),

);

if (!results || typeof results !== "object") {

return jsonResult({ ok: true, results });

}