Unified · Split
| @@ -87,12 +87,10 @@ const connectClient = (input: { · 86 unmodified lines | |||
| 87 | 87 | ||
| 88 | yield* Effect.tryPromise({ | 88 | yield* Effect.tryPromise({ |
| 89 | try: () => client.connect(transportInstance), | 89 | try: () => client.connect(transportInstance), |
| 90 | catch: (cause) => | 90 | catch: () => |
| 91 | new McpConnectionError({ | 91 | new McpConnectionError({ |
| 92 | transport: input.transport, | 92 | transport: input.transport, |
| 93 | message: `Failed connecting via ${input.transport}: ${ | 93 | message: `Failed connecting via ${input.transport}`, |
| 94 | cause instanceof Error ? cause.message : String(cause) | ||
| 95 | }`, | ||
| 96 | }), | 94 | }), |
| 97 | }).pipe( | 95 | }).pipe( |
| 98 | Effect.withSpan("plugin.mcp.connection.handshake", { | 96 | Effect.withSpan("plugin.mcp.connection.handshake", { |
| @@ -124,12 +122,10 @@ export const createMcpConnector = (input: ConnectorInput): McpConnector => { · 25 unmodified lines | |||
| 124 | // `node:child_process`) is only loaded when stdio is actually used. | 122 | // `node:child_process`) is only loaded when stdio is actually used. |
| 125 | const { createStdioTransport } = yield* Effect.tryPromise({ | 123 | const { createStdioTransport } = yield* Effect.tryPromise({ |
| 126 | try: () => import("./stdio-connector"), | 124 | try: () => import("./stdio-connector"), |
| 127 | catch: (cause) => | 125 | catch: () => |
| 128 | new McpConnectionError({ | 126 | new McpConnectionError({ |
| 129 | transport: "stdio", | 127 | transport: "stdio", |
| 130 | message: `Failed to load stdio transport module: ${ | 128 | message: "Failed to load stdio transport module", |
| 131 | cause instanceof Error ? cause.message : String(cause) | ||
| 132 | }`, | ||
| 133 | }), | 129 | }), |
| 134 | }); | 130 | }); |
| 135 | 131 | ||