refactor(telegram): localize private implementation types (#100975)

vincentkoc · web-flow · commit e311943700ae · 2026-07-06T08:37:16.000-07:00
diff --git a/extensions/telegram/src/allowed-updates.ts b/extensions/telegram/src/allowed-updates.ts
@@ -1,7 +1,7 @@
 // Telegram plugin module implements allowed updates behavior.
 import { API_CONSTANTS } from "grammy";
 
-export type TelegramUpdateType = (typeof API_CONSTANTS.ALL_UPDATE_TYPES)[number];
+type TelegramUpdateType = (typeof API_CONSTANTS.ALL_UPDATE_TYPES)[number];
 
 export const DEFAULT_TELEGRAM_UPDATE_TYPES: ReadonlyArray<TelegramUpdateType> =
   API_CONSTANTS.DEFAULT_UPDATE_TYPES;
diff --git a/extensions/telegram/src/approval-handler.runtime.ts b/extensions/telegram/src/approval-handler.runtime.ts
@@ -36,14 +36,14 @@ type TelegramPendingDelivery = {
   buttons: ReturnType<typeof resolveTelegramInlineButtons>;
 };
 
-export type TelegramExecApprovalHandlerDeps = {
+type TelegramExecApprovalHandlerDeps = {
   nowMs?: () => number;
   sendTyping?: typeof sendTypingTelegram;
   sendMessage?: typeof sendMessageTelegram;
   editReplyMarkup?: typeof editMessageReplyMarkupTelegram;
 };
 
-export type TelegramApprovalHandlerContext = {
+type TelegramApprovalHandlerContext = {
   token: string;
   deps?: TelegramExecApprovalHandlerDeps;
 };
diff --git a/extensions/telegram/src/bot-info-cache.ts b/extensions/telegram/src/bot-info-cache.ts
@@ -19,7 +19,7 @@ type TelegramBotInfoCacheState = {
   botInfo: TelegramBotInfo;
 };
 
-export type CachedTelegramBotInfo = {
+type CachedTelegramBotInfo = {
   botInfo: TelegramBotInfo;
   fetchedAt: string;
 };
diff --git a/extensions/telegram/src/bot-message-context.session.ts b/extensions/telegram/src/bot-message-context.session.ts
@@ -58,7 +58,7 @@ import {
 } from "./group-history-window.js";
 import type { TelegramReplyChainEntry } from "./message-cache.js";
 
-export type TelegramInboundContextPayload = BuiltChannelInboundEventContext & {
+type TelegramInboundContextPayload = BuiltChannelInboundEventContext & {
   From: string;
   To: string;
   ChatType: string;
diff --git a/extensions/telegram/src/bot-message-dispatch.ts b/extensions/telegram/src/bot-message-dispatch.ts
@@ -246,9 +246,7 @@ type DispatchTelegramMessageParams = {
   suppressFailureFallback?: boolean;
 };
 
-export type TelegramDispatchResult =
-  | { kind: "completed" }
-  | { kind: "failed-retryable"; error: unknown };
+type TelegramDispatchResult = { kind: "completed" } | { kind: "failed-retryable"; error: unknown };
 
 type TelegramReasoningLevel = "off" | "on" | "stream";
 
diff --git a/extensions/telegram/src/conversation-route.ts b/extensions/telegram/src/conversation-route.ts
@@ -37,7 +37,7 @@ export type TelegramConversationBindingMode =
     }
   | { kind: "plugin-owned-runtime" };
 
-export type TelegramConversationRouteResult = {
+type TelegramConversationRouteResult = {
   route: TelegramResolvedRoute;
   bindingMode: TelegramConversationBindingMode;
 };
diff --git a/extensions/telegram/src/exec-approval-resolver.ts b/extensions/telegram/src/exec-approval-resolver.ts
@@ -3,7 +3,7 @@ import { resolveApprovalOverGateway } from "openclaw/plugin-sdk/approval-gateway
 import type { ExecApprovalReplyDecision } from "openclaw/plugin-sdk/approval-reply-runtime";
 import type { OpenClawConfig } from "openclaw/plugin-sdk/config-contracts";
 
-export type ResolveTelegramExecApprovalParams = {
+type ResolveTelegramExecApprovalParams = {
   cfg: OpenClawConfig;
   approvalId: string;
   decision: ExecApprovalReplyDecision;
diff --git a/extensions/telegram/src/format.ts b/extensions/telegram/src/format.ts
@@ -24,7 +24,7 @@ const TELEGRAM_RICH_NESTING_LIMIT = 16;
 
 export type TelegramRichHtmlDegradationReason = "table-ascii";
 
-export type TelegramOutboundRichHtmlNormalization = {
+type TelegramOutboundRichHtmlNormalization = {
   html: string;
   degradationReasons: readonly TelegramRichHtmlDegradationReason[];
 };
@@ -803,7 +803,7 @@ function normalizeTelegramLegacyHtmlTables(html: string): string {
   });
 }
 
-export function limitTelegramRichHtmlNesting(html: string, maxDepth: number): string {
+function limitTelegramRichHtmlNesting(html: string, maxDepth: number): string {
   const normalizedMaxDepth = Math.max(1, Math.floor(maxDepth));
   const stack: Array<{ name: string; kept: boolean }> = [];
   let keptDepth = 0;
diff --git a/extensions/telegram/src/inbound-event-delivery.ts b/extensions/telegram/src/inbound-event-delivery.ts
@@ -1,7 +1,7 @@
 // Telegram plugin module implements inbound event delivery behavior.
 import { stripTelegramInternalPrefixes } from "./targets.js";
 
-export type TelegramInboundEventDeliveryEnd = () => void;
+type TelegramInboundEventDeliveryEnd = () => void;
 
 type ActiveInboundEvent = {
   outboundTo: string;
@@ -39,7 +39,7 @@ function telegramDeliveryTargetsMatch(expected: string, actual: string): boolean
   );
 }
 
-export function resolveTelegramInboundEventDeliveryCorrelationKey(
+function resolveTelegramInboundEventDeliveryCorrelationKey(
   sessionKey: string | undefined,
   inboundEventKind?: string,
 ): string | undefined {
diff --git a/extensions/telegram/src/message-cache.ts b/extensions/telegram/src/message-cache.ts
@@ -24,12 +24,12 @@ export type TelegramCachedMessageNode = Omit<TelegramReplyChainEntry, "messageId
   sourceMessage: Message;
 };
 
-export type TelegramConversationContextNode = {
+type TelegramConversationContextNode = {
   node: TelegramCachedMessageNode;
   isReplyTarget?: boolean;
 };
 
-export type TelegramMessageCache = {
+type TelegramMessageCache = {
   record: (params: {
     accountId: string;
     chatId: string | number;
@@ -96,7 +96,7 @@ export const TELEGRAM_MESSAGE_CACHE_PERSISTENT_NAMESPACE = "telegram.message-cac
 const PERSISTENT_BUCKET_KEY = `plugin-state:${TELEGRAM_MESSAGE_CACHE_PERSISTENT_NAMESPACE}`;
 const persistedMessageCacheBuckets = new Map<string, TelegramMessageCacheBucket>();
 
-export type PersistedTelegramMessageCacheValue = {
+type PersistedTelegramMessageCacheValue = {
   sourceMessage: Message;
   threadId?: string;
 };
diff --git a/extensions/telegram/src/message-dispatch-dedupe.ts b/extensions/telegram/src/message-dispatch-dedupe.ts
@@ -8,18 +8,18 @@ export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_TTL_MS = 7 * 24 * 60 * 60 * 1000;
 export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_NAMESPACE = "global";
 export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_NAMESPACE_PREFIX = "telegram.message-dispatch-dedupe";
 export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_STATE_PLUGIN_ID = "telegram-message-dispatch-dedupe";
-export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_MEMORY_MAX_ENTRIES = 50_000;
+const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_MEMORY_MAX_ENTRIES = 50_000;
 export const TELEGRAM_MESSAGE_DISPATCH_DEDUPE_STATE_MAX_ENTRIES = 50_000;
 
 export type TelegramMessageDispatchReplayGuard = ClaimableDedupe &
   Required<Pick<ClaimableDedupe, "forget">>;
 
-export type TelegramMessageDispatchClaim =
+type TelegramMessageDispatchClaim =
   | { kind: "claimed"; key: string }
   | { kind: "duplicate" }
   | { kind: "invalid" };
 
-export type TelegramMessageDispatchReplayForgetFailure = {
+type TelegramMessageDispatchReplayForgetFailure = {
   key: string;
   error?: unknown;
 };
diff --git a/extensions/telegram/src/network-config.ts b/extensions/telegram/src/network-config.ts
@@ -5,12 +5,11 @@ import type { TelegramNetworkConfig } from "openclaw/plugin-sdk/config-contracts
 import { isTruthyEnvValue, isWSL2Sync } from "openclaw/plugin-sdk/runtime-env";
 import { normalizeOptionalLowercaseString } from "openclaw/plugin-sdk/string-coerce-runtime";
 
-export const TELEGRAM_DISABLE_AUTO_SELECT_FAMILY_ENV =
-  "OPENCLAW_TELEGRAM_DISABLE_AUTO_SELECT_FAMILY";
-export const TELEGRAM_ENABLE_AUTO_SELECT_FAMILY_ENV = "OPENCLAW_TELEGRAM_ENABLE_AUTO_SELECT_FAMILY";
+const TELEGRAM_DISABLE_AUTO_SELECT_FAMILY_ENV = "OPENCLAW_TELEGRAM_DISABLE_AUTO_SELECT_FAMILY";
+const TELEGRAM_ENABLE_AUTO_SELECT_FAMILY_ENV = "OPENCLAW_TELEGRAM_ENABLE_AUTO_SELECT_FAMILY";
 export const TELEGRAM_DNS_RESULT_ORDER_ENV = "OPENCLAW_TELEGRAM_DNS_RESULT_ORDER";
 
-export type TelegramAutoSelectFamilyDecision = {
+type TelegramAutoSelectFamilyDecision = {
   value: boolean | null;
   source?: string;
 };
@@ -25,7 +24,7 @@ function isWSL2SyncCached(): boolean {
   return wsl2SyncCache;
 }
 
-export type TelegramDnsResultOrderDecision = {
+type TelegramDnsResultOrderDecision = {
   value: string | null;
   source?: string;
 };
diff --git a/extensions/telegram/src/network-errors.ts b/extensions/telegram/src/network-errors.ts
@@ -141,7 +141,7 @@ export function isTelegramMisdirectedRequestError(err: unknown): boolean {
   return false;
 }
 
-export type TelegramNetworkErrorContext =
+type TelegramNetworkErrorContext =
   | "polling"
   | "send"
   | "webhook"
@@ -150,7 +150,7 @@ export type TelegramNetworkErrorContext =
   | "edit"
   | "action"
   | "unknown";
-export type TelegramNetworkErrorOrigin = {
+type TelegramNetworkErrorOrigin = {
   method?: string | null;
   url?: string | null;
 };
diff --git a/extensions/telegram/src/outbound-adapter.ts b/extensions/telegram/src/outbound-adapter.ts
@@ -32,7 +32,7 @@ import { loadTelegramSendModule, type TelegramSendModule } from "./send-runtime.
 import { normalizeTelegramOutboundTarget, parseTelegramTarget } from "./targets.js";
 
 export const TELEGRAM_TEXT_CHUNK_LIMIT = 4000;
-export const TELEGRAM_POLL_OPTION_LIMIT = 10;
+const TELEGRAM_POLL_OPTION_LIMIT = 10;
 
 type TelegramSendFn = typeof import("./send.js").sendMessageTelegram;
 type TelegramSendOpts = Parameters<TelegramSendFn>[2];
@@ -121,7 +121,7 @@ async function resolveTelegramOutboundSendContext(
   return { outboundTo, send, baseOpts };
 }
 
-export type CreateTelegramOutboundAdapterOptions = {
+type CreateTelegramOutboundAdapterOptions = {
   resolveSend?: ResolveTelegramSendFn;
   loadSendModule?: LoadTelegramSendModuleFn;
   beforeDeliverPayload?: ChannelOutboundAdapter["beforeDeliverPayload"];
diff --git a/extensions/telegram/src/outbound-message-context.ts b/extensions/telegram/src/outbound-message-context.ts
@@ -10,7 +10,7 @@ type TelegramPromptContextChannelData = {
   promptContextTimestampMs?: unknown;
 };
 
-export type TelegramOutboundPromptContextMessage = {
+type TelegramOutboundPromptContextMessage = {
   message_id?: number;
   chat?: { id?: string | number; type?: string; title?: string; username?: string };
   date?: number;
diff --git a/extensions/telegram/src/polling-lease.ts b/extensions/telegram/src/polling-lease.ts
@@ -16,7 +16,7 @@ type TelegramPollingLeaseEntry = {
 
 type TelegramPollingLeaseRegistry = Map<string, TelegramPollingLeaseEntry>;
 
-export type TelegramPollingLease = {
+type TelegramPollingLease = {
   tokenFingerprint: string;
   waitedForPrevious: boolean;
   replacedStoppingPrevious: boolean;
diff --git a/extensions/telegram/src/progress-summary.ts b/extensions/telegram/src/progress-summary.ts
@@ -11,7 +11,7 @@
 // prefix: Discord wraps the line in its `-#` small-text syntax, which Telegram
 // markdown has no analog for, so the Telegram line is emitted plain.
 
-export type TelegramProgressSummaryCounters = {
+type TelegramProgressSummaryCounters = {
   reasoningSteps: number;
   commentaryNotes: number;
   toolCalls: number;
@@ -27,7 +27,7 @@ export type TelegramProgressSummaryCounters = {
 // the next tool call, or the summary flush — because some models (e.g. deepseek)
 // do not emit a reliable thinking_end per burst, so counting on the end event
 // alone undercounts.
-export type TelegramProgressSummaryTracker = {
+type TelegramProgressSummaryTracker = {
   /** A reasoning delta arrived; opens (or keeps open) the current burst. */
   noteReasoningActivity(): void;
   /** Reasoning-end fired; close and count the current burst if one is open. */
diff --git a/extensions/telegram/src/rich-message.ts b/extensions/telegram/src/rich-message.ts
@@ -26,8 +26,8 @@ type TelegramRichMessageReplyMarkup =
   | ForceReply;
 
 export const TELEGRAM_RICH_TEXT_LIMIT = 32_768;
-export const TELEGRAM_RICH_BLOCK_LIMIT = 500;
-export const TELEGRAM_RICH_MEDIA_LIMIT = 50;
+const TELEGRAM_RICH_BLOCK_LIMIT = 500;
+const TELEGRAM_RICH_MEDIA_LIMIT = 50;
 
 export type TelegramInputRichMessage =
   | {
@@ -43,14 +43,14 @@ export type TelegramInputRichMessage =
       skip_entity_detection?: boolean;
     };
 
-export type TelegramInputRichHtmlMessage = Extract<TelegramInputRichMessage, { html: string }>;
+type TelegramInputRichHtmlMessage = Extract<TelegramInputRichMessage, { html: string }>;
 
 type TelegramRichMessageOptions = {
   skipEntityDetection?: boolean;
   tableMode?: MarkdownTableMode;
 };
 
-export type TelegramRichTextMode = "markdown" | "html";
+type TelegramRichTextMode = "markdown" | "html";
 
 export type TelegramRichTextChunk = {
   text: string;
@@ -60,7 +60,7 @@ export type TelegramRichTextChunk = {
   degradationReasons: readonly TelegramRichHtmlDegradationReason[];
 };
 
-export type TelegramRichMessagePlan = {
+type TelegramRichMessagePlan = {
   richMessage: TelegramInputRichHtmlMessage;
   degradationReasons: readonly TelegramRichHtmlDegradationReason[];
 };
diff --git a/extensions/telegram/src/rich-plain-fallback.ts b/extensions/telegram/src/rich-plain-fallback.ts
@@ -10,24 +10,22 @@ const RICH_ENTITY_INVALID_RE =
   /RICH_MESSAGE_(?:EMAIL|URL|MENTION|HASHTAG|CASHTAG|BOT_COMMAND|PHONE|BANK_CARD)_INVALID/i;
 const PARSE_ERR_RE = /can't parse entities|parse entities|find end of the entity/i;
 
-export type TelegramPlainFallbackTrigger = "rich-entity-invalid" | "html-parse";
+type TelegramPlainFallbackTrigger = "rich-entity-invalid" | "html-parse";
 
-export type TelegramPlainFallbackPlan = {
+type TelegramPlainFallbackPlan = {
   plainText: string;
   chunks: string[];
 };
 
-export function isTelegramRichEntityInvalidError(err: unknown): boolean {
+function isTelegramRichEntityInvalidError(err: unknown): boolean {
   return RICH_ENTITY_INVALID_RE.test(formatErrorMessage(err));
 }
 
 export function isTelegramHtmlParseError(err: unknown): boolean {
   return PARSE_ERR_RE.test(formatErrorMessage(err));
 }
 
-export function getTelegramPlainFallbackTrigger(
-  err: unknown,
-): TelegramPlainFallbackTrigger | undefined {
+function getTelegramPlainFallbackTrigger(err: unknown): TelegramPlainFallbackTrigger | undefined {
   if (isTelegramRichEntityInvalidError(err)) {
     return "rich-entity-invalid";
   }
diff --git a/extensions/telegram/src/send.ts b/extensions/telegram/src/send.ts
@@ -2195,7 +2195,7 @@ type TelegramCreateForumTopicOpts = {
   iconCustomEmojiId?: string;
 };
 
-export type TelegramCreateForumTopicResult = {
+type TelegramCreateForumTopicResult = {
   topicId: number;
   name: string;
   chatId: string;
diff --git a/extensions/telegram/src/sendchataction-401-backoff.ts b/extensions/telegram/src/sendchataction-401-backoff.ts
@@ -13,7 +13,7 @@ import {
   readTelegramRetryAfterMs,
 } from "./network-errors.js";
 
-export type TelegramSendChatActionLogger = (message: string) => void;
+type TelegramSendChatActionLogger = (message: string) => void;
 
 type ChatAction =
   | "typing"
@@ -50,7 +50,7 @@ export type TelegramSendChatActionHandler = {
   reset: () => void;
 };
 
-export type CreateTelegramSendChatActionHandlerParams = {
+type CreateTelegramSendChatActionHandlerParams = {
   sendChatActionFn: SendChatActionFn;
   logger: TelegramSendChatActionLogger;
   maxConsecutive401?: number;
diff --git a/extensions/telegram/src/sequential-key.ts b/extensions/telegram/src/sequential-key.ts
@@ -126,10 +126,7 @@ function isTelegramActiveRunControlLaneText(params: {
   return command ? TELEGRAM_ACTIVE_RUN_CONTROL_COMMAND_KEYS.has(command.key) : false;
 }
 
-export function isTelegramControlLaneText(params: {
-  rawText?: string;
-  botUsername?: string;
-}): boolean {
+function isTelegramControlLaneText(params: { rawText?: string; botUsername?: string }): boolean {
   if (
     isAbortRequestText(
       params.rawText,
diff --git a/extensions/telegram/src/session-transcript-context.ts b/extensions/telegram/src/session-transcript-context.ts
@@ -3,15 +3,15 @@ import {
   type SessionRecentConversationText,
 } from "openclaw/plugin-sdk/session-store-runtime";
 
-export type TelegramSessionTranscriptPromptMessage = {
+type TelegramSessionTranscriptPromptMessage = {
   message_id?: string;
   sender: string;
   timestamp_ms?: number;
   body: string;
   source_channel?: string;
 };
 
-export type BuildTelegramSessionTranscriptPromptMessagesParams = {
+type BuildTelegramSessionTranscriptPromptMessagesParams = {
   agentId: string;
   beforeTimestampMs?: number;
   limit: number;
diff --git a/extensions/telegram/src/telegram-ingress-worker.runtime.ts b/extensions/telegram/src/telegram-ingress-worker.runtime.ts
@@ -40,13 +40,13 @@ type PendingSpoolRequests = Map<
   }
 >;
 
-export type TelegramIngressRuntimePort = {
+type TelegramIngressRuntimePort = {
   postMessage(message: TelegramIngressWorkerMessage): void;
   onMessage(listener: (message: TelegramIngressWorkerCommand) => void): void;
   close(): void;
 };
 
-export type TelegramIngressRuntimeDeps = {
+type TelegramIngressRuntimeDeps = {
   fetch?: typeof fetch;
   closeTransport?: () => Promise<void>;
 };
diff --git a/extensions/telegram/src/telegram-ingress-worker.ts b/extensions/telegram/src/telegram-ingress-worker.ts
@@ -64,7 +64,7 @@ export type TelegramIngressWorkerOptions = {
   proxy?: string;
 };
 
-export type TelegramIngressWorkerHandle = {
+type TelegramIngressWorkerHandle = {
   onMessage(listener: (message: TelegramIngressWorkerMessage) => void): () => void;
   ackSpooledUpdate?(
     requestId: string,
diff --git a/extensions/telegram/src/telegram-reply-fence.ts b/extensions/telegram/src/telegram-reply-fence.ts

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ export type TelegramConversationBindingMode =`
`37`	`37`	`}`
`38`	`38`	`\| { kind: "plugin-owned-runtime" };`
`39`	`39`
`40`		`-export type TelegramConversationRouteResult = {`
	`40`	`+type TelegramConversationRouteResult = {`
`41`	`41`	`route: TelegramResolvedRoute;`
`42`	`42`	`bindingMode: TelegramConversationBindingMode;`
`43`	`43`	`};`