( sockets: WebSocket[], sessionIds: string[], updatesPerSession: number, options: CliOptions, )
| 381 | } |
| 382 | |
| 383 | async function sendSnapshotUpdates( |
| 384 | sockets: WebSocket[], |
| 385 | sessionIds: string[], |
| 386 | updatesPerSession: number, |
| 387 | options: CliOptions, |
| 388 | ) { |
| 389 | for (let updateIndex = 1; updateIndex <= updatesPerSession; updateIndex += 1) { |
| 390 | for (let sessionIndex = 0; sessionIndex < sockets.length; sessionIndex += 1) { |
| 391 | sockets[sessionIndex]!.send( |
| 392 | JSON.stringify({ |
| 393 | type: "snapshot", |
| 394 | sessionId: sessionIds[sessionIndex], |
| 395 | snapshot: makeSnapshot(sessionIds[sessionIndex]!, updateIndex, options), |
| 396 | }), |
| 397 | ); |
| 398 | } |
| 399 | } |
| 400 | |
| 401 | // Give the daemon event loop one turn to process the burst before API reads sample the state. |
| 402 | await Bun.sleep(0); |
| 403 | } |
| 404 | |
| 405 | async function postSessionApi(port: number, body: Record<string, unknown>) { |
| 406 | const response = await fetch(`http://127.0.0.1:${port}${HUNK_SESSION_API_PATH}`, { |
no test coverage detected