Method Run

coderd/x/chatd/mcpclient/mcpclient.go:586–623

(
	ctx context.Context,
	params fantasy.ToolCall,
)

}

func (t *mcpToolWrapper) Run(
	ctx context.Context,
	params fantasy.ToolCall,
) (fantasy.ToolResponse, error) {
	input := params.Input
	if t.modelIntent {
		input = unwrapModelIntent(input)
	}

	var args map[string]any
	if input != "" {
		if err := json.Unmarshal(
			[]byte(input), &args,
		); err != nil {
			return fantasy.NewTextErrorResponse(
				"invalid JSON input: " + err.Error(),
			), nil
		}
	}

	callCtx, cancel := context.WithTimeout(ctx, toolCallTimeout)
	defer cancel()

	result, err := t.client.CallTool(
		callCtx,
		mcp.CallToolRequest{
			Params: mcp.CallToolParams{
				Name:      t.originalName,
				Arguments: args,
			},
		},
	)
	if err != nil {
		return fantasy.NewTextErrorResponse(err.Error()), nil
	}

	return convertCallResult(result), nil
}

func (t *mcpToolWrapper) ProviderOptions() fantasy.ProviderOptions {
	return t.providerOptions