Function sendHttpRequest

backend/test/helper/client.go:364–418

(t *testing.T, timeout time.Duration, ctx *testContext, httpMethod string, endpoint string, headers map[string]string, body any)

}

func sendHttpRequest[Res any](t *testing.T, timeout time.Duration, ctx *testContext, httpMethod string, endpoint string, headers map[string]string, body any) Res {
	t.Helper()
	defer func() {
		ctx.client.expectedStatusCode = 0
	}()
	b := ToJson(body)
	if ctx.printPayload {
		coloredPrintf("calling:\n\t%s %s\nwith:\n%s\n", httpMethod, endpoint, string(ToCleanJson(ctx.inlineJson, body)))
	}
	var result Res
	err := runWithTimeout(timeout, func() (bool, errors.Error) {
		request, err := http.NewRequest(httpMethod, endpoint, bytes.NewReader(b))
		if err != nil {
			return false, errors.Convert(err)
		}
		request.Close = true
		request.Header.Add("Content-Type", "application/json")
		for header, headerVal := range headers {
			request.Header.Add(header, headerVal)
		}
		response, err := http.DefaultClient.Do(request)
		if err != nil {
			return false, errors.Convert(err)
		}
		defer func() {
			ctx.client.lastReturnedStatusCode = response.StatusCode
		}()
		if ctx.client.expectedStatusCode > 0 || response.StatusCode >= 300 {
			if ctx.client.expectedStatusCode == 0 || ctx.client.expectedStatusCode != response.StatusCode {
				if err = response.Body.Close(); err != nil {
					return false, errors.Convert(err)
				}
				response.Close = true
				return false, errors.HttpStatus(response.StatusCode).New(fmt.Sprintf("unexpected http status code calling [%s] %s: %d", httpMethod, endpoint, response.StatusCode))
			}
		}
		b, _ = io.ReadAll(response.Body)
		if err = json.Unmarshal(b, &result); err != nil {
			if response.StatusCode < 300 {
				return false, errors.Convert(err)
			}
			// it's probably ok since the request failed anyway
		}
		if ctx.printPayload {
			coloredPrintf("result: %s\n", ToCleanJson(ctx.inlineJson, b))
		}
		if err = response.Body.Close(); err != nil {
			return false, errors.Convert(err)
		}
		response.Close = true
		return true, nil
	})
	require.NoError(t, err)
	return result
}

func coloredPrintf(msg string, args ...any) {
	msg = fmt.Sprintf(msg, args...)