(args: { onMessage: unknown })
| 7369 | } |
| 7370 | |
| 7371 | async function connectMockSocket(args: { onMessage: unknown }) { |
| 7372 | if (mockWebsocketSendMutexWedged) { |
| 7373 | return new Promise<number>(() => {}); |
| 7374 | } |
| 7375 | |
| 7376 | const wsId = nextSocketId++; |
| 7377 | const handler = resolveHandler(args.onMessage); |
| 7378 | |
| 7379 | mockSockets.set(wsId, { |
| 7380 | handler, |
| 7381 | subscriptions: new Map(), |
| 7382 | }); |
| 7383 | |
| 7384 | window.setTimeout(() => { |
| 7385 | sendWsText(handler, ["AUTH", `mock-challenge-${wsId}`]); |
| 7386 | }, 0); |
| 7387 | |
| 7388 | return wsId; |
| 7389 | } |
| 7390 | |
| 7391 | async function sendToRealSocket(args: { |
| 7392 | id: number; |
no test coverage detected