64 lines
1.9 KiB
TypeScript
64 lines
1.9 KiB
TypeScript
import { normalizeGroupActivation } from "../../../auto-reply/group-activation.js";
|
|
import type { loadConfig } from "../../../config/config.js";
|
|
import {
|
|
resolveChannelGroupPolicy,
|
|
resolveChannelGroupRequireMention,
|
|
} from "../../../config/group-policy.js";
|
|
import {
|
|
loadSessionStore,
|
|
resolveGroupSessionKey,
|
|
resolveStorePath,
|
|
} from "../../../config/sessions.js";
|
|
|
|
export function resolveGroupPolicyFor(cfg: ReturnType<typeof loadConfig>, conversationId: string) {
|
|
const groupId = resolveGroupSessionKey({
|
|
From: conversationId,
|
|
ChatType: "group",
|
|
Provider: "whatsapp",
|
|
})?.id;
|
|
const whatsappCfg = cfg.channels?.whatsapp as
|
|
| { groupAllowFrom?: string[]; allowFrom?: string[] }
|
|
| undefined;
|
|
const hasGroupAllowFrom = Boolean(
|
|
whatsappCfg?.groupAllowFrom?.length || whatsappCfg?.allowFrom?.length,
|
|
);
|
|
return resolveChannelGroupPolicy({
|
|
cfg,
|
|
channel: "whatsapp",
|
|
groupId: groupId ?? conversationId,
|
|
hasGroupAllowFrom,
|
|
});
|
|
}
|
|
|
|
export function resolveGroupRequireMentionFor(
|
|
cfg: ReturnType<typeof loadConfig>,
|
|
conversationId: string,
|
|
) {
|
|
const groupId = resolveGroupSessionKey({
|
|
From: conversationId,
|
|
ChatType: "group",
|
|
Provider: "whatsapp",
|
|
})?.id;
|
|
return resolveChannelGroupRequireMention({
|
|
cfg,
|
|
channel: "whatsapp",
|
|
groupId: groupId ?? conversationId,
|
|
});
|
|
}
|
|
|
|
export function resolveGroupActivationFor(params: {
|
|
cfg: ReturnType<typeof loadConfig>;
|
|
agentId: string;
|
|
sessionKey: string;
|
|
conversationId: string;
|
|
}) {
|
|
const storePath = resolveStorePath(params.cfg.session?.store, {
|
|
agentId: params.agentId,
|
|
});
|
|
const store = loadSessionStore(storePath);
|
|
const entry = store[params.sessionKey];
|
|
const requireMention = resolveGroupRequireMentionFor(params.cfg, params.conversationId);
|
|
const defaultActivation = !requireMention ? "always" : "mention";
|
|
return normalizeGroupActivation(entry?.groupActivation) ?? defaultActivation;
|
|
}
|