fix(mothership): end a transport outage only after the whole poll iteration succeeds

Author: waleedlatif1

apps/sim/lib/mothership/transport/receiver.test.ts

@@ -291,6 +291,14 @@ describe('outbound receiver backoff', () => {
     expect(logger().info).toHaveBeenCalledOnce()
   })
 
+  it('keeps backing off while polls succeed but their batches cannot be read', async () => {
+    const malformed = () => Response.json({ requests: 'not a list' })
+    const delays = await delaysFor(Array.from({ length: 5 }, () => malformed))
+    expect(delays[4]).toBeGreaterThanOrEqual(3200)
+    expect(logger().warn).toHaveBeenCalledOnce()
+    expect(logger().info).not.toHaveBeenCalled()
+  })
+
   it('warns again, and backs off from the start, when an outage turns into a refused key', async () => {
     const delays = await delaysFor([lost, lost, lost, refused(401), refused(401)])
     expect(delays[3]).toBeLessThanOrEqual(36_000)

apps/sim/lib/mothership/transport/receiver.ts

@@ -102,10 +102,6 @@ export async function receiveSimControls(
         }
         throw new Error(`Transport poll refused (HTTP ${response.status})`)
       }
-      if (outage) {
-        logger.info('Sim transport reconnected')
-        outage = undefined
-      }
       phase = 'parse'
       const batch = SimChannelBatchEnvelope.parse(await response.json())
       const controls = batch.requests.flatMap((raw) => receiveControl(raw) ?? [])
@@ -130,6 +126,11 @@ export async function receiveSimControls(
       )
       const failed = replies.find((reply) => reply.status === 'rejected')
       if (failed?.status === 'rejected') throw failed.reason
+      // Only a whole iteration (poll, batch, replies) ends an outage.
+      if (outage) {
+        logger.info('Sim transport reconnected')
+        outage = undefined
+      }
     } catch (error) {
       if (signal.aborted) return
       const keyRefused = error instanceof TransportKeyRefused