Function addWebSocket

services/session-ingest/src/dos/UserConnectionDO.test.ts:168–177

Create a web WebSocket and add it to the context.

(
  mockCtx: ReturnType<typeof createMockCtx>,
  connectionId = 'web-1',
  subscribedSessions: string[] = []
)

  };
}

/** Drain microtasks so waitUntil-scheduled async IIFEs settle. */
async function flushAsync(): Promise<void> {
  await new Promise<void>(resolve => {
    setTimeout(resolve, 0);
  });
  await new Promise<void>(resolve => {
    setTimeout(resolve, 0);
  });
}

// ---------------------------------------------------------------------------
// Helpers