Method apiRequest

backend/api/mcp/tool_http.go:24–66

apiRequest executes an HTTP POST to an internal Bytebase API endpoint. It handles URL building, auth forwarding, Connect-RPC headers, and JSON marshaling.

(ctx context.Context, path string, body any)

// apiRequest executes an HTTP POST to an internal Bytebase API endpoint.
// It handles URL building, auth forwarding, Connect-RPC headers, and JSON marshaling.
func (s *Server) apiRequest(ctx context.Context, path string, body any) (*apiResponse, error) {
	var bodyBytes []byte
	var err error
	if body != nil {
		bodyBytes, err = json.Marshal(body)
		if err != nil {
			return nil, errors.Wrap(err, "failed to marshal request body")
		}
	} else {
		bodyBytes = []byte("{}")
	}

	url := fmt.Sprintf("http://localhost:%d%s", s.profile.Port, path)
	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(bodyBytes))
	if err != nil {
		return nil, errors.Wrap(err, "failed to create HTTP request")
	}

	httpReq.Header.Set("Content-Type", "application/json")
	httpReq.Header.Set("Connect-Protocol-Version", "1")

	if token := getAccessToken(ctx); token != "" {
		httpReq.Header.Set("Authorization", "Bearer "+token)
	}

	client := &http.Client{Timeout: 30 * time.Second}
	resp, err := client.Do(httpReq)
	if err != nil {
		return nil, errors.Wrap(err, "failed to execute API request")
	}
	defer resp.Body.Close()

	respBody, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, errors.Wrap(err, "failed to read response body")
	}

	return &apiResponse{
		Status:  resp.StatusCode,
		Body:    json.RawMessage(respBody),
		Headers: resp.Header,
	}, nil
}

// parseError extracts the error message from an API error response body.
func parseError(body json.RawMessage) string {