41 lines
1.4 KiB
TypeScript
41 lines
1.4 KiB
TypeScript
import { mapAllowFromEntries } from "openclaw/plugin-sdk/channel-config-helpers";
|
|
import {
|
|
listInspectedDirectoryEntriesFromSources,
|
|
type DirectoryConfigParams,
|
|
} from "openclaw/plugin-sdk/directory-runtime";
|
|
import { inspectTelegramAccount, type InspectedTelegramAccount } from "../api.js";
|
|
|
|
export async function listTelegramDirectoryPeersFromConfig(params: DirectoryConfigParams) {
|
|
return listInspectedDirectoryEntriesFromSources({
|
|
...params,
|
|
kind: "user",
|
|
inspectAccount: (cfg, accountId) =>
|
|
inspectTelegramAccount({ cfg, accountId }) as InspectedTelegramAccount | null,
|
|
resolveSources: (account) => [
|
|
mapAllowFromEntries(account.config.allowFrom),
|
|
Object.keys(account.config.dms ?? {}),
|
|
],
|
|
normalizeId: (entry) => {
|
|
const trimmed = entry.replace(/^(telegram|tg):/i, "").trim();
|
|
if (!trimmed) {
|
|
return null;
|
|
}
|
|
if (/^-?\d+$/.test(trimmed)) {
|
|
return trimmed;
|
|
}
|
|
return trimmed.startsWith("@") ? trimmed : `@${trimmed}`;
|
|
},
|
|
});
|
|
}
|
|
|
|
export async function listTelegramDirectoryGroupsFromConfig(params: DirectoryConfigParams) {
|
|
return listInspectedDirectoryEntriesFromSources({
|
|
...params,
|
|
kind: "group",
|
|
inspectAccount: (cfg, accountId) =>
|
|
inspectTelegramAccount({ cfg, accountId }) as InspectedTelegramAccount | null,
|
|
resolveSources: (account) => [Object.keys(account.config.groups ?? {})],
|
|
normalizeId: (entry) => entry.trim() || null,
|
|
});
|
|
}
|