vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 20:30:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(telegram): simplify inbound watch log formatting

Browse Source
This commit is contained in:
Ayaan Zaidi
2026-05-08 18:17:45 +05:30
parent 227e252a58
commit 12e885da5f
2 changed files with 15 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -45,6 +45,13 @@ type FinalizedTelegramInboundContext = ReturnType<
typeof import("./bot-message-context.session.runtime.js").finalizeInboundContext
>;
export type TelegramInboundContextPayload = FinalizedTelegramInboundContext & {
From: string;
To: string;
ChatType: string;
RawBody: string;
};
type TelegramMessageContextSessionRuntime =
typeof import("./bot-message-context.session.runtime.js");
@@ -175,7 +182,7 @@ export async function buildTelegramInboundContextPayload(params: {
topicName?: string;
sessionRuntime?: TelegramMessageContextSessionRuntimeOverrides;
}): Promise<{
ctxPayload: FinalizedTelegramInboundContext;
ctxPayload: TelegramInboundContextPayload;
skillFilter: string[] | undefined;
turn: {
storePath: string;

25
extensions/telegram/src/bot-message.ts
View File

@@ -23,21 +23,16 @@ import type { TelegramReplyChainEntry } from "./message-cache.js";
const telegramInboundLog = createSubsystemLogger("gateway/channels/telegram").child("inbound");
export function formatTelegramInboundLogLine(params: {
from?: string;
to?: string;
chatType?: string;
body?: string;
from: string;
to: string;
chatType: string;
body: string;
mediaType?: string;
}): string {
const from = params.from || "unknown";
const to = params.to || "telegram";
const chatType = params.chatType || "direct";
const kindLabel = params.mediaType ? `, ${params.mediaType}` : "";
const length = (params.body ?? "").length;
return `Inbound message ${from} -> ${to} (${chatType}${kindLabel}, ${length} chars)`;
return `Inbound message ${params.from} -> ${params.to} (${params.chatType}${kindLabel}, ${params.body.length} chars)`;
}
/** Dependencies injected once when creating the message processor. */
type TelegramMessageProcessorDeps = Omit<
BuildTelegramMessageContextParams,
"primaryCtx" | "allMedia" | "storeAllowFrom" | "options"
@@ -142,11 +137,7 @@ export const createTelegramMessageProcessor = (deps: TelegramMessageProcessorDep
? `@${context.primaryCtx.me.username}`
: context.ctxPayload.To,
chatType: context.ctxPayload.ChatType,
body:
context.ctxPayload.RawBody ??
context.ctxPayload.BodyForCommands ??
context.ctxPayload.BodyForAgent ??
context.ctxPayload.Body,
body: context.ctxPayload.RawBody,
mediaType: allMedia[0]?.contentType,
}),
);
@@ -177,9 +168,7 @@ export const createTelegramMessageProcessor = (deps: TelegramMessageProcessorDep
"Something went wrong while processing your request. Please try again.",
buildTelegramThreadParams(context.threadSpec),
);
} catch {
// Best-effort fallback; delivery may fail if the bot was blocked or the chat is invalid.
}
} catch {}
}
};
};