mirror of
https://github.com/openclaw/openclaw.git
synced 2026-05-09 19:54:32 +00:00
refactor(telegram): share account config helpers
This commit is contained in:
@@ -3,9 +3,12 @@ import type { OpenClawConfig } from "../config/config.js";
|
|||||||
import { hasConfiguredSecretInput, normalizeSecretInputString } from "../config/types.secrets.js";
|
import { hasConfiguredSecretInput, normalizeSecretInputString } from "../config/types.secrets.js";
|
||||||
import type { TelegramAccountConfig } from "../config/types.telegram.js";
|
import type { TelegramAccountConfig } from "../config/types.telegram.js";
|
||||||
import { resolveAccountWithDefaultFallback } from "../plugin-sdk/account-resolution.js";
|
import { resolveAccountWithDefaultFallback } from "../plugin-sdk/account-resolution.js";
|
||||||
import { resolveAccountEntry } from "../routing/account-lookup.js";
|
|
||||||
import { DEFAULT_ACCOUNT_ID, normalizeAccountId } from "../routing/session-key.js";
|
import { DEFAULT_ACCOUNT_ID, normalizeAccountId } from "../routing/session-key.js";
|
||||||
import { resolveDefaultTelegramAccountId } from "./accounts.js";
|
import {
|
||||||
|
mergeTelegramAccountConfig,
|
||||||
|
resolveDefaultTelegramAccountId,
|
||||||
|
resolveTelegramAccountConfig,
|
||||||
|
} from "./accounts.js";
|
||||||
|
|
||||||
export type TelegramCredentialStatus = "available" | "configured_unavailable" | "missing";
|
export type TelegramCredentialStatus = "available" | "configured_unavailable" | "missing";
|
||||||
|
|
||||||
@@ -20,31 +23,6 @@ export type InspectedTelegramAccount = {
|
|||||||
config: TelegramAccountConfig;
|
config: TelegramAccountConfig;
|
||||||
};
|
};
|
||||||
|
|
||||||
function resolveTelegramAccountConfig(
|
|
||||||
cfg: OpenClawConfig,
|
|
||||||
accountId: string,
|
|
||||||
): TelegramAccountConfig | undefined {
|
|
||||||
const normalized = normalizeAccountId(accountId);
|
|
||||||
return resolveAccountEntry(cfg.channels?.telegram?.accounts, normalized);
|
|
||||||
}
|
|
||||||
|
|
||||||
function mergeTelegramAccountConfig(cfg: OpenClawConfig, accountId: string): TelegramAccountConfig {
|
|
||||||
const {
|
|
||||||
accounts: _ignored,
|
|
||||||
defaultAccount: _ignoredDefaultAccount,
|
|
||||||
groups: channelGroups,
|
|
||||||
...base
|
|
||||||
} = (cfg.channels?.telegram ?? {}) as TelegramAccountConfig & {
|
|
||||||
accounts?: unknown;
|
|
||||||
defaultAccount?: unknown;
|
|
||||||
};
|
|
||||||
const account = resolveTelegramAccountConfig(cfg, accountId) ?? {};
|
|
||||||
const configuredAccountIds = Object.keys(cfg.channels?.telegram?.accounts ?? {});
|
|
||||||
const isMultiAccount = configuredAccountIds.length > 1;
|
|
||||||
const groups = account.groups ?? (isMultiAccount ? undefined : channelGroups);
|
|
||||||
return { ...base, ...account, groups };
|
|
||||||
}
|
|
||||||
|
|
||||||
function inspectTokenFile(pathValue: unknown): {
|
function inspectTokenFile(pathValue: unknown): {
|
||||||
token: string;
|
token: string;
|
||||||
tokenSource: "tokenFile" | "none";
|
tokenSource: "tokenFile" | "none";
|
||||||
|
|||||||
@@ -97,7 +97,7 @@ export function resolveDefaultTelegramAccountId(cfg: OpenClawConfig): string {
|
|||||||
return ids[0] ?? DEFAULT_ACCOUNT_ID;
|
return ids[0] ?? DEFAULT_ACCOUNT_ID;
|
||||||
}
|
}
|
||||||
|
|
||||||
function resolveAccountConfig(
|
export function resolveTelegramAccountConfig(
|
||||||
cfg: OpenClawConfig,
|
cfg: OpenClawConfig,
|
||||||
accountId: string,
|
accountId: string,
|
||||||
): TelegramAccountConfig | undefined {
|
): TelegramAccountConfig | undefined {
|
||||||
@@ -105,7 +105,10 @@ function resolveAccountConfig(
|
|||||||
return resolveAccountEntry(cfg.channels?.telegram?.accounts, normalized);
|
return resolveAccountEntry(cfg.channels?.telegram?.accounts, normalized);
|
||||||
}
|
}
|
||||||
|
|
||||||
function mergeTelegramAccountConfig(cfg: OpenClawConfig, accountId: string): TelegramAccountConfig {
|
export function mergeTelegramAccountConfig(
|
||||||
|
cfg: OpenClawConfig,
|
||||||
|
accountId: string,
|
||||||
|
): TelegramAccountConfig {
|
||||||
const {
|
const {
|
||||||
accounts: _ignored,
|
accounts: _ignored,
|
||||||
defaultAccount: _ignoredDefaultAccount,
|
defaultAccount: _ignoredDefaultAccount,
|
||||||
@@ -115,7 +118,7 @@ function mergeTelegramAccountConfig(cfg: OpenClawConfig, accountId: string): Tel
|
|||||||
accounts?: unknown;
|
accounts?: unknown;
|
||||||
defaultAccount?: unknown;
|
defaultAccount?: unknown;
|
||||||
};
|
};
|
||||||
const account = resolveAccountConfig(cfg, accountId) ?? {};
|
const account = resolveTelegramAccountConfig(cfg, accountId) ?? {};
|
||||||
|
|
||||||
// In multi-account setups, channel-level `groups` must NOT be inherited by
|
// In multi-account setups, channel-level `groups` must NOT be inherited by
|
||||||
// accounts that don't have their own `groups` config. A bot that is not a
|
// accounts that don't have their own `groups` config. A bot that is not a
|
||||||
@@ -138,7 +141,7 @@ export function createTelegramActionGate(params: {
|
|||||||
const accountId = normalizeAccountId(params.accountId);
|
const accountId = normalizeAccountId(params.accountId);
|
||||||
return createAccountActionGate({
|
return createAccountActionGate({
|
||||||
baseActions: params.cfg.channels?.telegram?.actions,
|
baseActions: params.cfg.channels?.telegram?.actions,
|
||||||
accountActions: resolveAccountConfig(params.cfg, accountId)?.actions,
|
accountActions: resolveTelegramAccountConfig(params.cfg, accountId)?.actions,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user