File size: 2,687 Bytes
eb3f11e | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 | // Thread command registration, including channel-specific create request normalization.
import type { Command } from "commander";
import { getChannelPlugin } from "../../../channels/plugins/index.js";
import type { ChannelMessageActionName } from "../../../channels/plugins/types.public.js";
import { resolveMessageSecretScope } from "../../message-secret-scope.js";
import type { MessageCliHelpers } from "./helpers.js";
function resolveThreadCreateRequest(opts: Record<string, unknown>) {
const { channel } = resolveMessageSecretScope(opts);
if (channel) {
const request = getChannelPlugin(channel)?.actions?.resolveCliActionRequest?.({
action: "thread-create",
args: opts,
});
if (request) {
return {
action: request.action,
params: request.args,
};
}
}
return {
action: "thread-create" as ChannelMessageActionName,
params: opts,
};
}
/** Register thread create/list/reply commands. */
export function registerMessageThreadCommands(message: Command, helpers: MessageCliHelpers) {
const thread = message.command("thread").description("Thread actions");
helpers
.withMessageBase(
helpers.withRequiredMessageTarget(
thread
.command("create")
.description("Create a thread")
.requiredOption("--thread-name <name>", "Thread name"),
),
)
.option("--message-id <id>", "Message id (optional)")
.option("-m, --message <text>", "Initial thread message text")
.option("--auto-archive-min <n>", "Thread auto-archive minutes")
.action(async (opts) => {
const request = resolveThreadCreateRequest(opts);
await helpers.runMessageAction(request.action, request.params);
});
helpers
.withMessageBase(
thread
.command("list")
.description("List threads")
.requiredOption("--guild-id <id>", "Guild id"),
)
.option("--channel-id <id>", "Channel id")
.option("--include-archived", "Include archived threads", false)
.option("--before <id>", "Read/search before id")
.option("--limit <n>", "Result limit")
.action((opts) => helpers.runMessageAction("thread-list", opts));
helpers
.withMessageBase(
helpers.withRequiredMessageTarget(
thread
.command("reply")
.description("Reply in a thread")
.requiredOption("-m, --message <text>", "Message body"),
),
)
.option(
"--media <path-or-url>",
"Attach media (image/audio/video/document). Accepts local paths or URLs.",
)
.option("--reply-to <id>", "Reply-to message id")
.action((opts) => helpers.runMessageAction("thread-reply", opts));
}
|