Unified · Split
| @@ -117,13 +117,13 @@ export const resolveHeaders = ( · 116 unmodified lines | ||
| 117 | 117 | typeof value === "string" |
| 118 | 118 | ? Effect.succeed({ name, value }) |
| 119 | 119 | : secrets.get(value.secretId).pipe( |
| 120 | − Effect.mapError((err) => | |
| 121 | − "_tag" in err && err._tag === "SecretOwnedByConnectionError" | |
| 122 | − ? new OpenApiInvocationError({ | |
| 123 | − message: `Failed to resolve secret "${value.secretId}" for header "${name}"`, | |
| 124 | − statusCode: Option.none(), | |
| 125 | − }) | |
| 126 | − : err, | |
| 120 | + Effect.catchTag("SecretOwnedByConnectionError", () => | |
| 121 | + Effect.fail( | |
| 122 | + new OpenApiInvocationError({ | |
| 123 | + message: `Failed to resolve secret "${value.secretId}" for header "${name}"`, | |
| 124 | + statusCode: Option.none(), | |
| 125 | + }), | |
| 126 | + ), | |
| 127 | 127 | ), |
| 128 | 128 | Effect.flatMap((secret) => |
| 129 | 129 | secret === null |
| @@ -585,7 +585,7 @@ export const invoke = Effect.fn("OpenApi.invoke")(function* ( · 455 unmodified lines | ||
| 585 | 585 | Effect.mapError( |
| 586 | 586 | (err) => |
| 587 | 587 | new OpenApiInvocationError({ |
| 588 | − message: `HTTP request failed: ${err.message}`, | |
| 588 | + message: "HTTP request failed", | |
| 589 | 589 | statusCode: Option.none(), |
| 590 | 590 | cause: err, |
| 591 | 591 | }), |
| @@ -600,9 +600,9 @@ export const invoke = Effect.fn("OpenApi.invoke")(function* ( · 8 unmodified lines | ||
| 600 | 600 | |
| 601 | 601 | const contentType = response.headers["content-type"] ?? null; |
| 602 | 602 | const mapBodyError = Effect.mapError( |
| 603 | − (err: { readonly message?: string }) => | |
| 603 | + (err: unknown) => | |
| 604 | 604 | new OpenApiInvocationError({ |
| 605 | − message: `Failed to read response body: ${err.message ?? String(err)}`, | |
| 605 | + message: "Failed to read response body", | |
| 606 | 606 | statusCode: Option.some(status), |
| 607 | 607 | cause: err, |
| 608 | 608 | }), |