// ─── Types ───────────────────────────────────────────────────────────────────

export const MATTERMOST_SLASH_POST_METHOD = "P";

export type MattermostSlashCommandConfig = {

/** Enable native slash commands. "auto" resolves to false for now (opt-in). */

native: boolean | "auto";

trigger: string;

teamId: string;

token: string;

url: string;

/** True when this process created the command and should delete it on shutdown. */

managed: boolean;

};

type MattermostCommandCreate = {

team_id: string;

trigger: string;

method: "P" | "G";

method: typeof MATTERMOST_SLASH_POST_METHOD | "G";

url: string;

description?: string;

auto_complete: boolean;

id: string;

team_id: string;

trigger: string;

method: "P" | "G";

method: typeof MATTERMOST_SLASH_POST_METHOD | "G";

url: string;

description?: string;

auto_complete: boolean;

auto_complete_desc?: string;

auto_complete_hint?: string;

};

type MattermostCommandResponse = {

export type MattermostCommandResponse = {

id: string;

token: string;

team_id: string;

export async function listMattermostCommands(

client: MattermostClient,

teamId: string,

init?: Pick<RequestInit, "signal">,

): Promise<MattermostCommandResponse[]> {

return await client.request<MattermostCommandResponse[]>(

`/commands?team_id=${encodeURIComponent(teamId)}&custom_only=true`,

init,

);

}

/**

* Get a custom slash command by id.

*/

export async function getMattermostCommand(

client: MattermostClient,

commandId: string,

init?: Pick<RequestInit, "signal">,

): Promise<MattermostCommandResponse> {

return await client.request<MattermostCommandResponse>(

`/commands/${encodeURIComponent(commandId)}`,

init,

);

}

const existingCmd = ownedCommands[0];

// Already registered with the correct callback URL

if (existingCmd && existingCmd.url === callbackUrl) {

const existingNeedsUpdate = existingCmd

? existingCmd.url !== callbackUrl || existingCmd.method !== MATTERMOST_SLASH_POST_METHOD

: false;

// Already registered with the correct callback URL and method.

if (existingCmd && !existingNeedsUpdate) {

log?.(`mattermost: command /${spec.trigger} already registered (id=${existingCmd.id})`);

registered.push({

id: existingCmd.id,

trigger: spec.trigger,

teamId,

token: existingCmd.token,

url: callbackUrl,

managed: false,

});

continue;

}

// Exists but points to a different URL: attempt to reconcile by updating

// (useful during callback URL migrations).

if (existingCmd && existingCmd.url !== callbackUrl) {

// Exists but has drifted critical callback fields: attempt to reconcile by

// updating (useful during callback URL migrations or method drift).

if (existingCmd && existingNeedsUpdate) {

log?.(

`mattermost: command /${spec.trigger} exists with different callback URL; updating (id=${existingCmd.id})`,

`mattermost: command /${spec.trigger} exists with different callback settings; updating (id=${existingCmd.id})`,

);

try {

const updated = await updateMattermostCommand(client, {

id: existingCmd.id,

team_id: teamId,

trigger: spec.trigger,

method: "P",

method: MATTERMOST_SLASH_POST_METHOD,

url: callbackUrl,

description: spec.description,

auto_complete: spec.autoComplete,

trigger: spec.trigger,

teamId,

token: updated.token,

url: callbackUrl,

managed: false,

});

continue;

const created = await createMattermostCommand(client, {

team_id: teamId,

trigger: spec.trigger,

method: "P",

method: MATTERMOST_SLASH_POST_METHOD,

url: callbackUrl,

description: spec.description,

auto_complete: spec.autoComplete,

trigger: spec.trigger,

teamId,

token: created.token,

url: callbackUrl,

managed: true,

});

} catch (err) {

return args ? `/${commandName} ${args}` : `/${commandName}`;

}

export function normalizeSlashCommandTrigger(command: string): string {

return command.replace(/^\//, "").trim();

}

// ─── Config resolution ───────────────────────────────────────────────────────

const DEFAULT_CALLBACK_PATH = "/api/channels/mattermost/command";