vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-03 05:12:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf(memory): lazy-load telegram message context runtime

Browse Source
This commit is contained in:
Vincent Koc
2026-04-02 14:44:14 +09:00
parent 16c5bd466c
commit 93fa6920b4
2 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
extensions/telegram/src/bot-message-context.runtime.ts Normal file
View File

@@ -0,0 +1,4 @@
export { createStatusReactionController } from "openclaw/plugin-sdk/channel-feedback";
export { recordChannelActivity } from "openclaw/plugin-sdk/channel-runtime";
export { loadConfig } from "openclaw/plugin-sdk/config-runtime";
export { ensureConfiguredBindingRouteReady } from "openclaw/plugin-sdk/conversation-runtime";

20
extensions/telegram/src/bot-message-context.ts
View File

@@ -1,15 +1,11 @@
import type { ReactionTypeEmoji } from "@grammyjs/types";
import { resolveAckReaction } from "openclaw/plugin-sdk/agent-runtime";
import {
createStatusReactionController,
shouldAckReaction as shouldAckReactionGate,
type StatusReactionController,
} from "openclaw/plugin-sdk/channel-feedback";
import { logInboundDrop } from "openclaw/plugin-sdk/channel-inbound";
import { recordChannelActivity } from "openclaw/plugin-sdk/channel-runtime";
import { loadConfig } from "openclaw/plugin-sdk/config-runtime";
import type { TelegramDirectConfig, TelegramGroupConfig } from "openclaw/plugin-sdk/config-runtime";
import { ensureConfiguredBindingRouteReady } from "openclaw/plugin-sdk/conversation-runtime";
import { deriveLastRoutePolicy } from "openclaw/plugin-sdk/routing";
import { DEFAULT_ACCOUNT_ID, resolveThreadSessionKeys } from "openclaw/plugin-sdk/routing";
import { logVerbose } from "openclaw/plugin-sdk/runtime-env";
@@ -45,6 +41,15 @@ export type {
TelegramMediaRef,
} from "./bot-message-context.types.js";
type TelegramMessageContextRuntime = typeof import("./bot-message-context.runtime.js");
let telegramMessageContextRuntimePromise: Promise<TelegramMessageContextRuntime> | undefined;
async function loadTelegramMessageContextRuntime() {
telegramMessageContextRuntimePromise ??= import("./bot-message-context.runtime.js");
return await telegramMessageContextRuntimePromise;
}
type TelegramMessageContextPayload = Awaited<ReturnType<typeof buildTelegramInboundContextPayload>>;
type TelegramReactionApi = (
chatId: BuildTelegramMessageContextParams["primaryCtx"]["message"]["chat"]["id"],
@@ -141,7 +146,7 @@ export const buildTelegramMessageContext = async ({
? (groupConfig.dmPolicy ?? dmPolicy)
: dmPolicy;
// Fresh config for bindings lookup; other routing inputs are payload-derived.
const freshCfg = (loadFreshConfig ?? loadConfig)();
const freshCfg = loadFreshConfig?.() ?? (await loadTelegramMessageContextRuntime()).loadConfig();
let { route, configuredBinding, configuredBindingSessionKey } = resolveTelegramConversationRoute({
cfg: freshCfg,
accountId: account.accountId,
@@ -264,6 +269,7 @@ export const buildTelegramMessageContext = async ({
if (!configuredBinding) {
return true;
}
const { ensureConfiguredBindingRouteReady } = await loadTelegramMessageContextRuntime();
const ensured = await ensureConfiguredBindingRouteReady({
cfg: freshCfg,
bindingResolution: configuredBinding,
@@ -322,7 +328,7 @@ export const buildTelegramMessageContext = async ({
baseRequireMention,
);
recordChannelActivity({
(await loadTelegramMessageContextRuntime()).recordChannelActivity({
channel: "telegram",
accountId: account.accountId,
direction: "inbound",
@@ -393,7 +399,7 @@ export const buildTelegramMessageContext = async ({
let allowedStatusReactionEmojisPromise: Promise<Set<TelegramReactionEmoji> | null> | null = null;
const statusReactionController: StatusReactionController | null =
statusReactionsEnabled && msg.message_id
? createStatusReactionController({
? (await loadTelegramMessageContextRuntime()).createStatusReactionController({
enabled: true,
adapter: {
setReaction: async (emoji: string) => {