Method callTool

web/lib/api/files.ts:129–169

(name: string, args: Record<string, unknown>)

  }

  async callTool(name: string, args: Record<string, unknown>): Promise<string> {
    await this.initialize();

    const res = await fetch(`${getBaseUrl()}/mcp`, {
      method: "POST",
      headers: this.buildHeaders(),
      body: JSON.stringify({
        jsonrpc: "2.0",
        id: nanoid(),
        method: "tools/call",
        params: { name, arguments: args },
      } satisfies McpRequest),
    });

    // Session expired — reinitialize once and retry
    if (res.status === 400 || res.status === 404) {
      this.sessionId = null;
      this.initPromise = null;
      await this.initialize();
      return this.callTool(name, args);
    }

    if (!res.ok) {
      throw new ApiError(res.status, `MCP tool "${name}" failed`);
    }

    const contentType = res.headers.get("content-type") ?? "";
    if (contentType.includes("text/event-stream")) {
      return this.parseSseResponse(res);
    }

    const json = (await res.json()) as McpResponse<McpToolResult>;
    if (json.error) {
      throw new ApiError(500, json.error.message);
    }
    const toolResult = json.result;
    if (toolResult?.isError) {
      throw new ApiError(500, toolResult.content[0]?.text ?? "Tool error");
    }
    return toolResult?.content?.[0]?.text ?? "";
  }
}

const mcpClient = new McpClient();