diff --git a/internal/delivery/engine_integration_test.go b/internal/delivery/engine_integration_test.go index 90d028e..784cf2a 100644 --- a/internal/delivery/engine_integration_test.go +++ b/internal/delivery/engine_integration_test.go @@ -355,9 +355,14 @@ func TestProcessRetryTask_SuccessfulRetry(t *testing.T) { s := newISetup(t) + var receivedBody string + ts := httptest.NewServer( http.HandlerFunc( - func(w http.ResponseWriter, _ *http.Request) { + func(w http.ResponseWriter, r *http.Request) { + body, _ := io.ReadAll(r.Body) + receivedBody = string(body) + w.WriteHeader(http.StatusOK) }, ), @@ -397,6 +402,8 @@ func TestProcessRetryTask_SuccessfulRetry(t *testing.T) { context.TODO(), &task, ) + assert.Equal(t, event.Body, receivedBody) + iAssertStatus(t, s.WebhookDB, d.ID, database.DeliveryStatusDelivered, ) @@ -443,9 +450,14 @@ func TestProcessRetryTask_LargeBody_FetchFromDB( s := newISetup(t) + var receivedBody string + ts := httptest.NewServer( http.HandlerFunc( - func(w http.ResponseWriter, _ *http.Request) { + func(w http.ResponseWriter, r *http.Request) { + body, _ := io.ReadAll(r.Body) + receivedBody = string(body) + w.WriteHeader(http.StatusOK) }, ), @@ -482,6 +494,8 @@ func TestProcessRetryTask_LargeBody_FetchFromDB( context.TODO(), &task, ) + assert.Equal(t, largeBody, receivedBody) + iAssertStatus(t, s.WebhookDB, d.ID, database.DeliveryStatusDelivered, )