Method CallAPI

cmd/event/runtime.go:21–62

(ctx context.Context, method, path string, body interface{})

}

func (r *consumeRuntime) CallAPI(ctx context.Context, method, path string, body interface{}) (json.RawMessage, error) {
	resp, err := r.client.DoAPI(ctx, client.RawApiRequest{
		Method: method,
		URL:    path,
		Data:   body,
		As:     r.accessIdentity,
	})
	if err != nil {
		if _, ok := errs.ProblemOf(err); ok {
			return nil, err
		}
		return nil, errs.NewNetworkError(errs.SubtypeNetworkTransport,
			"api %s %s: %s", method, path, err).WithCause(err)
	}
	// Non-JSON HTTP errors (gateway text/plain 404 etc.) skip OAPI envelope parsing.
	ct := resp.Header.Get("Content-Type")
	if resp.StatusCode >= 400 && !client.IsJSONContentType(ct) && ct != "" {
		const maxBodyEcho = 256
		body := string(resp.RawBody)
		if len(body) > maxBodyEcho {
			body = body[:maxBodyEcho] + "…(truncated)"
		}
		if resp.StatusCode >= 500 {
			return nil, errs.NewNetworkError(errs.SubtypeNetworkServer,
				"api %s %s returned %d: %s", method, path, resp.StatusCode, body).WithRetryable()
		}
		return nil, errs.NewInternalError(errs.SubtypeInvalidResponse,
			"api %s %s returned %d: %s", method, path, resp.StatusCode, body)
	}
	result, err := client.ParseJSONResponse(resp)
	if err != nil {
		if _, ok := errs.ProblemOf(err); ok {
			return nil, err
		}
		return nil, errs.NewInternalError(errs.SubtypeInvalidResponse,
			"api %s %s: %s", method, path, err).WithCause(err)
	}
	if apiErr := r.client.CheckResponse(result, r.accessIdentity); apiErr != nil {
		return json.RawMessage(resp.RawBody), apiErr
	}
	return json.RawMessage(resp.RawBody), nil
}