Method execRequest

tests/contract/contract_test.go:329–413

── Step executors ─────────────────────────────────────────────────

(t *testing.T, s *step)

// ── Step executors ─────────────────────────────────────────────────

func (r *runner) execRequest(t *testing.T, s *step) {
	t.Helper()
	path := r.resolve(s.Path)

	var bodyReader io.Reader
	if s.Body != nil {
		data, _ := json.Marshal(r.resolveValue(s.Body))
		bodyReader = bytes.NewReader(data)
	}
	req, err := http.NewRequest(s.Method, r.env.baseURL+path, bodyReader)
	if err != nil {
		t.Fatalf("step %s: create request: %v", s.ID, err)
	}
	if auth, ok := r.authHeader(s); ok {
		req.Header.Set("Authorization", auth)
	}
	if s.Body != nil {
		req.Header.Set("Content-Type", "application/json")
	}

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		t.Fatalf("step %s: %s %s: %v", s.ID, s.Method, path, err)
	}
	defer resp.Body.Close()

	rawBody, _ := io.ReadAll(resp.Body)

	if s.Expect == nil {
		return
	}

	// Status assertion
	if s.Expect.Status != 0 && resp.StatusCode != s.Expect.Status {
		t.Fatalf("step %s: status = %d, want %d; body: %s", s.ID, resp.StatusCode, s.Expect.Status, rawBody)
	}

	// JSON body assertions
	if len(s.Expect.BodyContains) == 0 && len(s.Expect.BodyMatch) == 0 && len(s.Expect.BodyExcludes) == 0 {
		return
	}

	var jsonBody map[string]interface{}
	if err := json.Unmarshal(rawBody, &jsonBody); err != nil {
		t.Fatalf("step %s: unmarshal response: %v; raw: %s", s.ID, err, rawBody)
	}

	for _, key := range s.Expect.BodyContains {
		resolvedKey := r.resolve(key)
		if _, ok := jsonBody[resolvedKey]; !ok {
			t.Fatalf("step %s: expected key %q in response", s.ID, resolvedKey)
		}
	}
	for _, key := range s.Expect.BodyExcludes {
		resolvedKey := r.resolve(key)
		if _, ok := jsonBody[resolvedKey]; ok {
			t.Fatalf("step %s: unexpected key %q in response", s.ID, resolvedKey)
		}