Function invokeMcpTool

packages/plugins/mcp/src/sdk/invoke.ts:235–287

(
  input: InvokeMcpToolInput,
)

}

export const invokeMcpTool = (
  input: InvokeMcpToolInput,
): Effect.Effect<
  unknown,
  McpConnectionError | McpInvocationError | McpOAuthReauthorizationRequired
> =>
  Effect.gen(function* () {
    const args = argsRecord(input.args);
    const use = (connection: McpConnection) =>
      useConnection(connection, input.toolName, args, input.elicit, input.onToolListChanged);

    if (input.connectionPool && input.connectionPoolKey) {
      return yield* input.connectionPool.withConnection(
        input.connectionPoolKey,
        input.connector.pipe(
          Effect.withSpan("plugin.mcp.connection.acquire", {
            attributes: { "plugin.mcp.transport": input.transport },
          }),
        ),
        use,
      );
    }

    const connection = yield* Effect.acquireRelease(
      input.connector.pipe(
        Effect.withSpan("plugin.mcp.connection.acquire", {
          attributes: { "plugin.mcp.transport": input.transport },
        }),
      ),
      (conn) =>
        Effect.ignore(
          Effect.tryPromise({
            try: () => conn.close(),
            catch: () =>
              new McpConnectionError({
                transport: input.transport,
                message: "Failed to close MCP connection",
              }),
          }),
        ),
    );

    return yield* use(connection);
  }).pipe(
    Effect.scoped,
    Effect.withSpan("plugin.mcp.invoke", {
      attributes: {
        "mcp.tool.name": input.toolName,
        "plugin.mcp.tool_id": input.toolId,
        "plugin.mcp.transport": input.transport,
      },
    }),
  );