77 lines
2.6 KiB
TypeScript
77 lines
2.6 KiB
TypeScript
import { isRecord } from "openclaw/plugin-sdk/text-runtime";
|
|
import { fetchWithTimeout } from "openclaw/plugin-sdk/text-runtime";
|
|
import type {
|
|
AuditTelegramGroupMembershipParams,
|
|
TelegramGroupMembershipAudit,
|
|
TelegramGroupMembershipAuditEntry,
|
|
} from "./audit.js";
|
|
import { resolveTelegramFetch } from "./fetch.js";
|
|
import { makeProxyFetch } from "./proxy.js";
|
|
|
|
const TELEGRAM_API_BASE = "https://api.telegram.org";
|
|
|
|
type TelegramApiOk<T> = { ok: true; result: T };
|
|
type TelegramApiErr = { ok: false; description?: string };
|
|
type TelegramGroupMembershipAuditData = Omit<TelegramGroupMembershipAudit, "elapsedMs">;
|
|
|
|
export async function auditTelegramGroupMembershipImpl(
|
|
params: AuditTelegramGroupMembershipParams,
|
|
): Promise<TelegramGroupMembershipAuditData> {
|
|
const proxyFetch = params.proxyUrl ? makeProxyFetch(params.proxyUrl) : undefined;
|
|
const fetcher = resolveTelegramFetch(proxyFetch, { network: params.network });
|
|
const base = `${TELEGRAM_API_BASE}/bot${params.token}`;
|
|
const groups: TelegramGroupMembershipAuditEntry[] = [];
|
|
|
|
for (const chatId of params.groupIds) {
|
|
try {
|
|
const url = `${base}/getChatMember?chat_id=${encodeURIComponent(chatId)}&user_id=${encodeURIComponent(String(params.botId))}`;
|
|
const res = await fetchWithTimeout(url, {}, params.timeoutMs, fetcher);
|
|
const json = (await res.json()) as TelegramApiOk<{ status?: string }> | TelegramApiErr;
|
|
if (!res.ok || !isRecord(json) || !json.ok) {
|
|
const desc =
|
|
isRecord(json) && !json.ok && typeof json.description === "string"
|
|
? json.description
|
|
: `getChatMember failed (${res.status})`;
|
|
groups.push({
|
|
chatId,
|
|
ok: false,
|
|
status: null,
|
|
error: desc,
|
|
matchKey: chatId,
|
|
matchSource: "id",
|
|
});
|
|
continue;
|
|
}
|
|
const status = isRecord((json as TelegramApiOk<unknown>).result)
|
|
? ((json as TelegramApiOk<{ status?: string }>).result.status ?? null)
|
|
: null;
|
|
const ok = status === "creator" || status === "administrator" || status === "member";
|
|
groups.push({
|
|
chatId,
|
|
ok,
|
|
status,
|
|
error: ok ? null : "bot not in group",
|
|
matchKey: chatId,
|
|
matchSource: "id",
|
|
});
|
|
} catch (err) {
|
|
groups.push({
|
|
chatId,
|
|
ok: false,
|
|
status: null,
|
|
error: err instanceof Error ? err.message : String(err),
|
|
matchKey: chatId,
|
|
matchSource: "id",
|
|
});
|
|
}
|
|
}
|
|
|
|
return {
|
|
ok: groups.every((g) => g.ok),
|
|
checkedGroups: groups.length,
|
|
unresolvedGroups: 0,
|
|
hasWildcardUnmentionedGroups: false,
|
|
groups,
|
|
};
|
|
}
|