Function WebhookReceiver

internal/testutil/server.go:341–373

(t *testing.T)

}

func WebhookReceiver(t *testing.T) *WebhookReceiverResult {
	t.Helper()

	result := &WebhookReceiverResult{}

	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		rawBody, err := io.ReadAll(r.Body)
		if err != nil {
			http.Error(w, "read error", 500)
			return
		}
		var payload webhook.Payload
		if err := json.Unmarshal(rawBody, &payload); err != nil {
			http.Error(w, fmt.Sprintf("unmarshal error: %v", err), 400)
			return
		}

		result.mu.Lock()
		result.payloads = append(result.payloads, ReceivedPayload{
			Body:    payload,
			Headers: r.Header.Clone(),
			RawBody: rawBody,
		})
		result.mu.Unlock()

		w.WriteHeader(200)
	}))

	result.Server = server
	t.Cleanup(server.Close)

	return result
}