Function SubscriberReceiver

internal/testutil/server.go:310–339

SubscriberReceiver returns a multi-path HTTP receiver wired for the new webhook-resource envelope. Routes work as plain paths under the receiver's base URL — e.g. receiver.Server.URL + "/sent" + ".../fail".

(t *testing.T)

// new webhook-resource envelope. Routes work as plain paths under the
// receiver's base URL — e.g. receiver.Server.URL + "/sent" + ".../fail".
func SubscriberReceiver(t *testing.T) *SubscriberReceiverResult {
	t.Helper()
	result := &SubscriberReceiverResult{}
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		raw, err := io.ReadAll(r.Body)
		if err != nil {
			http.Error(w, "read err", 500)
			return
		}
		var env map[string]any
		_ = json.Unmarshal(raw, &env) // tolerate non-JSON for negative cases

		result.mu.Lock()
		result.captured = append(result.captured, SubscriberCaptured{
			URL:      r.URL.Path,
			Envelope: env,
			RawBody:  raw,
			Headers:  r.Header.Clone(),
		})
		status := 200
		if s, ok := result.statusByPath[r.URL.Path]; ok {
			status = s
		}
		result.mu.Unlock()
		w.WriteHeader(status)
	}))
	result.Server = server
	t.Cleanup(server.Close)
	return result
}

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