Method handleToolsCall

pkg/mcpserver/server.go:122–166

handleToolsCall 处理 tools/call 请求

(w http.ResponseWriter, ctx context.Context, req *cloud.MCPRequest)

// handleToolsCall 处理 tools/call 请求
func (s *Server) handleToolsCall(w http.ResponseWriter, ctx context.Context, req *cloud.MCPRequest) {
	params := req.Params
	if params.Name == "" {
		writeError(w, req.ID, -32602, "tool name is required", nil)
		return
	}

	tool, err := s.registry.Create(params.Name, nil)
	if err != nil {
		writeError(w, req.ID, -32601, "tool not found: "+params.Name, err)
		return
	}

	var tc *tools.ToolContext
	if s.contextFactory != nil {
		tc = s.contextFactory(ctx)
	}

	// 使用 Executor 执行工具
	result := s.executor.Execute(ctx, &tools.ExecuteRequest{
		Tool:    tool,
		Input:   params.Arguments,
		Context: tc,
	})

	if result.Error != nil {
		writeError(w, req.ID, -32000, "tool execution failed", result.Error)
		return
	}

	// MCPResponse.Result 是任意 JSON, 这里直接编码为 raw message
	raw, err := json.Marshal(result.Output)
	if err != nil {
		writeError(w, req.ID, -32001, "marshal tool result failed", err)
		return
	}

	mcpResp := cloud.MCPResponse{
		JSONRPC: "2.0",
		ID:      req.ID,
		Result:  raw,
	}

	writeJSON(w, http.StatusOK, mcpResp)
}

func writeJSON(w http.ResponseWriter, status int, v any) {
	w.Header().Set("Content-Type", "application/json; charset=utf-8")