75 lines
2.3 KiB
TypeScript
75 lines
2.3 KiB
TypeScript
import {
|
|
resolveToolsBySender,
|
|
type GroupToolPolicyBySenderConfig,
|
|
type GroupToolPolicyConfig,
|
|
} from "openclaw/plugin-sdk/channel-policy";
|
|
import { type ChannelGroupContext } from "openclaw/plugin-sdk/channel-runtime";
|
|
import { normalizeHyphenSlug } from "openclaw/plugin-sdk/core";
|
|
import { inspectSlackAccount } from "./account-inspect.js";
|
|
|
|
type SlackChannelPolicyEntry = {
|
|
requireMention?: boolean;
|
|
tools?: GroupToolPolicyConfig;
|
|
toolsBySender?: GroupToolPolicyBySenderConfig;
|
|
};
|
|
|
|
function resolveSlackChannelPolicyEntry(
|
|
params: ChannelGroupContext,
|
|
): SlackChannelPolicyEntry | undefined {
|
|
const account = inspectSlackAccount({
|
|
cfg: params.cfg,
|
|
accountId: params.accountId,
|
|
});
|
|
const channels = (account.channels ?? {}) as Record<string, SlackChannelPolicyEntry>;
|
|
if (Object.keys(channels).length === 0) {
|
|
return undefined;
|
|
}
|
|
const channelId = params.groupId?.trim();
|
|
const groupChannel = params.groupChannel;
|
|
const channelName = groupChannel?.replace(/^#/, "");
|
|
const normalizedName = normalizeHyphenSlug(channelName);
|
|
const candidates = [
|
|
channelId ?? "",
|
|
channelName ? `#${channelName}` : "",
|
|
channelName ?? "",
|
|
normalizedName,
|
|
].filter(Boolean);
|
|
for (const candidate of candidates) {
|
|
if (candidate && channels[candidate]) {
|
|
return channels[candidate];
|
|
}
|
|
}
|
|
return channels["*"];
|
|
}
|
|
|
|
function resolveSenderToolsEntry(
|
|
entry: SlackChannelPolicyEntry | undefined,
|
|
params: ChannelGroupContext,
|
|
): GroupToolPolicyConfig | undefined {
|
|
if (!entry) {
|
|
return undefined;
|
|
}
|
|
const senderPolicy = resolveToolsBySender({
|
|
toolsBySender: entry.toolsBySender,
|
|
senderId: params.senderId,
|
|
senderName: params.senderName,
|
|
senderUsername: params.senderUsername,
|
|
senderE164: params.senderE164,
|
|
});
|
|
return senderPolicy ?? entry.tools;
|
|
}
|
|
|
|
export function resolveSlackGroupRequireMention(params: ChannelGroupContext): boolean {
|
|
const resolved = resolveSlackChannelPolicyEntry(params);
|
|
if (typeof resolved?.requireMention === "boolean") {
|
|
return resolved.requireMention;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
export function resolveSlackGroupToolPolicy(
|
|
params: ChannelGroupContext,
|
|
): GroupToolPolicyConfig | undefined {
|
|
return resolveSenderToolsEntry(resolveSlackChannelPolicyEntry(params), params);
|
|
}
|