(body: unknown)
| 380 | } |
| 381 | |
| 382 | function getRequestRunContext(body: unknown) { |
| 383 | if (!body || typeof body !== 'object') return {} |
| 384 | |
| 385 | const threadId = |
| 386 | 'threadId' in body && typeof body.threadId === 'string' |
| 387 | ? body.threadId |
| 388 | : undefined |
| 389 | const runId = |
| 390 | 'runId' in body && typeof body.runId === 'string' ? body.runId : undefined |
| 391 | |
| 392 | return { |
| 393 | ...(threadId ? { threadId } : {}), |
| 394 | ...(runId ? { runId } : {}), |
| 395 | } |
| 396 | } |
| 397 | |
| 398 | async function* createErrorStream( |
| 399 | error: unknown, |