M webhooks/legacy.go => webhooks/legacy.go +1 -0
@@ 230,6 230,7 @@ func deliverPayload(ctx context.Context, name, url string,
Set("response", string(body)).
Set("response_status", resp.StatusCode).
Set("response_headers", sb.String()).
+ Where("id = ?", deliveryID).
RunWith(tx).
ExecContext(ctx)
return err
M webhooks/legacy_test.go => webhooks/legacy_test.go +1 -1
@@ 103,7 103,7 @@ func TestDelivery(t *testing.T) {
mock.ExpectBegin()
mock.ExpectExec(`UPDATE user_webhook_delivery`).
- WithArgs("Thanks!", 200, sqlmock.AnyArg()) // Any => response headers
+ WithArgs("Thanks!", 200, sqlmock.AnyArg(), 4096) // Any => response headers
mock.ExpectCommit()
ctx = database.Context(context.Background(), db)