From 403c6e90755f7a694573d9788fb78c4a71add15e Mon Sep 17 00:00:00 2001
From: Jannis Braun <151788261+TheZwiss@users.noreply.github.com>
Date: Sat, 2 May 2026 17:52:05 +0200
Subject: [PATCH] fix(web): orchestrator dispatches eager-upload bubbles via
 pendingMessageStore subscribe

---
 .../web/src/stores/pendingMessageRehydrate.ts | 23 +++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/packages/web/src/stores/pendingMessageRehydrate.ts b/packages/web/src/stores/pendingMessageRehydrate.ts
index 5e319ca9..1d456fe4 100644
--- a/packages/web/src/stores/pendingMessageRehydrate.ts
+++ b/packages/web/src/stores/pendingMessageRehydrate.ts
@@ -52,6 +52,29 @@ export function startPendingMessageOrchestrator(): void {
     }
   });
 
+  // 3b. Also re-check when pendingMessageStore mutates (e.g., new bubble appended
+  //     AFTER boot, with all transfers already completed — eager-upload path).
+  //     Without this, a bubble that becomes ready by virtue of pendingMessageStore
+  //     changing — not transferStore — is never dispatched.
+  let lastBubblesSig = '';
+  usePendingMessageStore.subscribe((s) => {
+    const sig = Array.from(s.bubbles.values())
+      .flat()
+      .map((b) => `${b.clientId}|${b.state}|${b.retryCount}`)
+      .sort()
+      .join(',');
+    if (sig === lastBubblesSig) return;
+    lastBubblesSig = sig;
+
+    const fresh = usePendingMessageStore.getState().listReadyForDeferredSend();
+    for (const b of fresh) {
+      if (!sentClientIds.has(b.clientId)) {
+        sentClientIds.add(b.clientId);
+        void deferredSend(b);
+      }
+    }
+  });
+
   // 4. Auto-retry on `online`: bump+resend bubbles that failed once with no
   //    prior retries (network-induced failure most likely). Uses the
   //    failed-retryable query — listReadyForDeferredSend gates state==='sending'