vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-26 00:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: simplify telegram status snapshots

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-22 23:27:21 +00:00
parent f0ab31366c
commit 2cfc7bca10
1 changed files with 14 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
extensions/telegram/src/channel.ts
View File

@@ -20,7 +20,10 @@ import {
resolveThreadSessionKeys,
type RoutePeer,
} from "openclaw/plugin-sdk/routing";
import { createDefaultChannelRuntimeState } from "openclaw/plugin-sdk/status-helpers";
import {
createComputedAccountStatusAdapter,
createDefaultChannelRuntimeState,
} from "openclaw/plugin-sdk/status-helpers";
import { parseTelegramTopicConversation } from "../runtime-api.js";
import {
buildTokenChannelStatusSummary,
@@ -449,7 +452,7 @@ export const telegramPlugin = createChatChannelPlugin({
listGroups: async (params) => listTelegramDirectoryGroupsFromConfig(params),
}),
actions: telegramMessageActions,
status: {
status: createComputedAccountStatusAdapter<ResolvedTelegramAccount, TelegramProbe, unknown>({
defaultRuntime: createDefaultChannelRuntimeState(DEFAULT_ACCOUNT_ID),
collectStatusIssues: collectTelegramStatusIssues,
buildChannelSummary: ({ snapshot }) => buildTokenChannelStatusSummary(snapshot),
@@ -515,7 +518,7 @@ export const telegramPlugin = createChatChannelPlugin({
});
return { ...audit, unresolvedGroups, hasWildcardUnmentionedGroups };
},
buildAccountSnapshot: ({ account, cfg, runtime, probe, audit }) => {
resolveAccountSnapshot: ({ account, cfg, runtime, audit }) => {
const configuredFromStatus = resolveConfiguredFromCredentialStatuses(account);
const ownerAccountId = findTelegramTokenOwnerAccountId({
cfg,
@@ -542,20 +545,16 @@ export const telegramPlugin = createChatChannelPlugin({
name: account.name,
enabled: account.enabled,
configured,
...projectCredentialSnapshotFields(account),
running: runtime?.running ?? false,
lastStartAt: runtime?.lastStartAt ?? null,
lastStopAt: runtime?.lastStopAt ?? null,
lastError: runtime?.lastError ?? duplicateTokenReason,
mode: runtime?.mode ?? (account.config.webhookUrl ? "webhook" : "polling"),
probe,
audit,
allowUnmentionedGroups,
lastInboundAt: runtime?.lastInboundAt ?? null,
lastOutboundAt: runtime?.lastOutboundAt ?? null,
extra: {
...projectCredentialSnapshotFields(account),
lastError: runtime?.lastError ?? duplicateTokenReason,
mode: runtime?.mode ?? (account.config.webhookUrl ? "webhook" : "polling"),
audit,
allowUnmentionedGroups,
},
};
},
},
}),
gateway: {
startAccount: async (ctx) => {
const account = ctx.account;