fix(telegram): route polling diagnostics away from errors

galiniliev · galiniliev · commit 8d19cc435b0d · 2026-05-16T23:04:53.000-07:00
diff --git a/extensions/telegram/src/monitor.test.ts b/extensions/telegram/src/monitor.test.ts
@@ -472,6 +472,19 @@ describe("monitorTelegramProvider (grammY)", () => {
     expect(runOptions?.runner?.retryInterval).toBe("exponential");
   });
 
+  it("logs polling startup diagnostics without using the error channel", async () => {
+    const runtime = {
+      log: vi.fn(),
+      error: vi.fn(),
+      exit: vi.fn(),
+    };
+
+    await monitorWithAutoAbort({ runtime });
+
+    expect(runtime.log).toHaveBeenCalledWith(expect.stringContaining("polling cycle started"));
+    expect(runtime.error).not.toHaveBeenCalled();
+  });
+
   it("requires mention in groups by default", async () => {
     for (const v of Object.values(api)) {
       if (typeof v === "function" && "mockReset" in v) {
diff --git a/extensions/telegram/src/monitor.ts b/extensions/telegram/src/monitor.ts
@@ -108,7 +108,8 @@ async function loadTelegramMonitorWebhookRuntime() {
 }
 
 export async function monitorTelegramProvider(opts: MonitorTelegramOpts = {}) {
-  const log = opts.runtime?.error ?? console.error;
+  const log = (line: string) => (opts.runtime?.log ?? console.log)(line);
+  const logError = (line: string) => (opts.runtime?.error ?? console.error)(line);
   let pollingSession: TelegramPollingSessionInstance | undefined;
 
   const handlePollingNetworkFailure = (err: unknown, label: string) => {
@@ -231,7 +232,7 @@ export async function monitorTelegramProvider(opts: MonitorTelegramOpts = {}) {
           try {
             await deleteTelegramUpdateOffset({ accountId: account.accountId });
           } catch (err) {
-            (opts.runtime?.error ?? console.error)(
+            logError(
               `telegram: failed to delete stale update offset after rotation: ${String(err)}`,
             );
           }
@@ -261,9 +262,7 @@ export async function monitorTelegramProvider(opts: MonitorTelegramOpts = {}) {
             botToken: token,
           });
         } catch (err) {
-          (opts.runtime?.error ?? console.error)(
-            `telegram: failed to persist update offset: ${String(err)}`,
-          );
+          logError(`telegram: failed to persist update offset: ${String(err)}`);
         }
       };
 
