( mcpUrl: string, bearer: string, sessionId: string, body: unknown, abortController?: AbortController, )
| 221 | }; |
| 222 | |
| 223 | const startPostCapture = async ( |
| 224 | mcpUrl: string, |
| 225 | bearer: string, |
| 226 | sessionId: string, |
| 227 | body: unknown, |
| 228 | abortController?: AbortController, |
| 229 | ): Promise<SseCapture> => { |
| 230 | const response = await fetch(mcpUrl, { |
| 231 | method: "POST", |
| 232 | headers: mcpHeaders(bearer, sessionId), |
| 233 | body: JSON.stringify(body), |
| 234 | ...(abortController ? { signal: abortController.signal } : {}), |
| 235 | }); |
| 236 | expect(response.status, "POST tools/call opens an SSE response").toBe(200); |
| 237 | return new SseCapture(response, abortController); |
| 238 | }; |
| 239 | |
| 240 | const delayedCode = (marker: string, delayMs: number): string => |
| 241 | [ |
no test coverage detected