( mcpUrl: string, bearer: string, sessionId: string, body: unknown, abortController?: AbortController, )
| 183 | }; |
| 184 | |
| 185 | const startPostCapture = async ( |
| 186 | mcpUrl: string, |
| 187 | bearer: string, |
| 188 | sessionId: string, |
| 189 | body: unknown, |
| 190 | abortController?: AbortController, |
| 191 | ): Promise<SseCapture> => { |
| 192 | const response = await fetch(mcpUrl, { |
| 193 | method: "POST", |
| 194 | headers: mcpHeaders(bearer, sessionId), |
| 195 | body: JSON.stringify(body), |
| 196 | ...(abortController ? { signal: abortController.signal } : {}), |
| 197 | }); |
| 198 | expect(response.status, "POST tools/call opens an SSE response").toBe(200); |
| 199 | return new SseCapture(response, abortController); |
| 200 | }; |
| 201 | |
| 202 | const delayedCode = (marker: string, delayMs: number): string => |
| 203 | [ |
no test coverage detected