fix(telegram): recover stale ingress claims after restart

zerone0x · zerone0x · commit b1e2bd62b564 · 2026-05-20T20:06:37.000Z
diff --git a/extensions/telegram/src/polling-session.test.ts b/extensions/telegram/src/polling-session.test.ts
@@ -891,7 +891,7 @@ describe("TelegramPollingSession", () => {
     });
   });
 
-  it("keeps claims owned by another live process blocked", async () => {
+  it("recovers restart-stale claims that reused the current process pid", async () => {
     await withTempSpool(async (tempDir) => {
       const interruptedUpdate = topicUpdate(42, 10, "active topic 10 turn");
       await writeSpooledTestUpdates(tempDir, [
@@ -916,7 +916,7 @@ describe("TelegramPollingSession", () => {
           receivedAt: interrupted.receivedAt,
           update: interruptedUpdate,
           claim: {
-            processId: "other-process",
+            processId: "previous-gateway-instance",
             processPid: process.pid,
             claimedAt: Date.now(),
           },
@@ -930,10 +930,10 @@ describe("TelegramPollingSession", () => {
         shouldRecover: (claim) => !isTelegramSpooledUpdateClaimOwnedByOtherLiveProcess(claim),
       });
 
-      expect(recovered).toBe(0);
-      expect(await pendingUpdateIds(tempDir)).toEqual([43]);
+      expect(recovered).toBe(1);
+      expect(await pendingUpdateIds(tempDir)).toEqual([42, 43]);
       expect((await fs.readdir(tempDir)).toSorted()).toEqual([
-        "0000000000000042.json.processing",
+        "0000000000000042.json",
         "0000000000000043.json",
       ]);
     });
diff --git a/extensions/telegram/src/telegram-ingress-spool.test.ts b/extensions/telegram/src/telegram-ingress-spool.test.ts
@@ -242,7 +242,7 @@ describe("Telegram ingress spool", () => {
     });
   });
 
-  it("does not treat stale claims with reused pids as live-owned", () => {
+  it("does not treat current-pid claims from older process identities as live-owned", () => {
     const now = Date.now();
     expect(
       isTelegramSpooledUpdateClaimOwnedByOtherLiveProcess({
@@ -254,7 +254,7 @@ describe("Telegram ingress spool", () => {
         claim: {
           processId: "other-process",
           processPid: process.pid,
-          claimedAt: now - TELEGRAM_SPOOLED_UPDATE_PROCESSING_STALE_MS - 1,
+          claimedAt: now,
         },
       }),
     ).toBe(false);
diff --git a/extensions/telegram/src/telegram-ingress-spool.ts b/extensions/telegram/src/telegram-ingress-spool.ts
@@ -181,6 +181,7 @@ export function isTelegramSpooledUpdateClaimOwnedByOtherLiveProcess(
   return Boolean(
     claim.claim &&
     claim.claim.processId !== TELEGRAM_SPOOLED_UPDATE_PROCESS_ID &&
+    claim.claim.processPid !== process.pid &&
     isFreshClaimOwner(claim.claim) &&
     processExists(claim.claim.processPid),
   );
