fix(sdk): catch async throws from bridged frames so the queue keeps draining

Meteor's _streamHandlers.onMessage returns a Promise. Sync try/catch
around the bridge call doesn't catch throws inside _process_updated
("No callback invoker for method N" when a stale frame arrives) — the
throw escapes as an unhandled rejection and stops Meteor's frame queue,
so the next login's result never gets processed and the page stays
on /login.

Revert the prior _methodInvokers gating (it dropped legitimate login
result frames in the same cycle) and instead capture the async
rejection at the bridge boundary so individual bad frames don't poison
subsequent ones.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: ggazzo

apps/meteor/client/meteor/overrides/ddpSdkCollectionBridge.ts

@@ -39,12 +39,6 @@ const SUBSCRIPTION_LIFECYCLE_FRAMES = new Set(['ready', 'nosub']);
 // bridge so SDK's own callAsync flows aren't surfaced into Meteor.
 const isSdkInternalId = (id: unknown): boolean => typeof id === 'string' && id.startsWith('rc-ddp-client-');
 
-const getMeteorMethodInvokers = (): Record<string, unknown> => {
-	return (Meteor.connection as unknown as { _methodInvokers?: Record<string, unknown> })._methodInvokers ?? {};
-};
-
-const meteorHasInvoker = (id: unknown): boolean => typeof id === 'string' && id in getMeteorMethodInvokers();
-
 const shouldBridgeToMeteor = (frame: ParsedDdpFrame): boolean => {
 	if (!frame || typeof frame.msg !== 'string') return false;
 
@@ -53,29 +47,15 @@ const shouldBridgeToMeteor = (frame: ParsedDdpFrame): boolean => {
 	}
 
 	if (frame.msg === 'result') {
-		if (isSdkInternalId(frame.id)) return false;
-		// Drop result frames whose Meteor invoker is gone — feeding them
-		// surfaces as "Received method result but no methods outstanding" and
-		// can race with `updated` to leave Meteor's _processOneDataMessage in a
-		// half-processed state (force-logout cycles invalidate the in-flight
-		// method's invoker before its result returns over the SDK socket).
-		return meteorHasInvoker(frame.id);
+		return !isSdkInternalId(frame.id);
 	}
 	if (frame.msg === 'updated') {
 		const methods = Array.isArray(frame.methods) ? (frame.methods as unknown[]) : [];
-		if (methods.length === 0) return false;
 		// If any of the methodIds in the `updated` frame is SDK-internal, drop
 		// the whole frame: Meteor processes every id and would throw on the
 		// first miss. In practice an `updated` frame carries ids from a single
 		// originating method call, so this is all-or-nothing anyway.
-		if (methods.some(isSdkInternalId)) return false;
-		// Same defence as for `result` — bridge only when Meteor still has an
-		// invoker for every methodId. Without this, `_process_updated` throws
-		// "No callback invoker for method N" out of an async generator and the
-		// throw escapes the try/catch below as an unhandled rejection,
-		// aborting Meteor's frame queue (the next login's result never lands,
-		// userId stays null, and the page is stuck on /login).
-		return methods.every(meteorHasInvoker);
+		return methods.length > 0 && !methods.some(isSdkInternalId);
 	}
 
 	return false;
@@ -89,12 +69,24 @@ export const installDdpSdkCollectionBridge = (): void => {
 	ddp.onMessage((frame) => {
 		if (!shouldBridgeToMeteor(frame)) return;
 
-		// Guard against frames that would collide with Meteor's own subscription
-		// ids. DDPSDK generates its own ids (rc-ddp-client-<n>); Meteor.connection's
-		// invokers ignore frames whose id is not in its tables, so a plain
-		// re-feed is safe.
+		// `_streamHandlers.onMessage` returns a Promise (the message handler is an
+		// async generator). A throw inside the inner `_process_updated` /
+		// `_process_result` (e.g. "No callback invoker for method N" when a
+		// stale frame arrives after a force-logout cycle invalidates the
+		// invoker) would otherwise escape this scope as an unhandled rejection,
+		// aborting Meteor's frame queue and leaving subsequent login result
+		// frames unprocessed. Wrap the call so both sync throws and async
+		// rejections are contained — Meteor keeps draining the queue even when
+		// individual frames hit dead invokers.
 		try {
-			Meteor.connection._streamHandlers.onMessage(DDPCommon.stringifyDDP(frame as Parameters<typeof DDPCommon.stringifyDDP>[0]));
+			const result = Meteor.connection._streamHandlers.onMessage(
+				DDPCommon.stringifyDDP(frame as Parameters<typeof DDPCommon.stringifyDDP>[0]),
+			) as unknown;
+			if (result && typeof (result as Promise<unknown>).then === 'function') {
+				(result as Promise<unknown>).catch((err) => {
+					console.warn('[ddpSdk] bridge frame drop (async)', frame.msg, err);
+				});
+			}
 		} catch (err) {
 			console.warn('[ddpSdk] bridge frame drop', frame.msg, err);
 		}