|
|
|
@ -5,6 +5,7 @@
|
|
|
|
import json
|
|
|
|
import json
|
|
|
|
import os.path as osp
|
|
|
|
import os.path as osp
|
|
|
|
from http import HTTPStatus
|
|
|
|
from http import HTTPStatus
|
|
|
|
|
|
|
|
from time import sleep
|
|
|
|
|
|
|
|
|
|
|
|
import pytest
|
|
|
|
import pytest
|
|
|
|
from deepdiff import DeepDiff
|
|
|
|
from deepdiff import DeepDiff
|
|
|
|
@ -63,13 +64,21 @@ def create_webhook(events, webhook_type, project_id=None, org_id=""):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_deliveries(webhook_id):
|
|
|
|
def get_deliveries(webhook_id):
|
|
|
|
response = get_method("admin1", f"webhooks/{webhook_id}/deliveries")
|
|
|
|
delivery_response = {}
|
|
|
|
assert response.status_code == HTTPStatus.OK
|
|
|
|
for _ in range(10):
|
|
|
|
|
|
|
|
response = get_method("admin1", f"webhooks/{webhook_id}/deliveries")
|
|
|
|
|
|
|
|
assert response.status_code == HTTPStatus.OK
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
deliveries = response.json()
|
|
|
|
|
|
|
|
delivery = deliveries["results"][0]["response"]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if delivery:
|
|
|
|
|
|
|
|
delivery_response = json.loads(delivery)
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
deliveries = response.json()
|
|
|
|
sleep(1)
|
|
|
|
last_payload = json.loads(deliveries["results"][0]["response"])
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return deliveries, last_payload
|
|
|
|
return deliveries, delivery_response
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@pytest.mark.usefixtures("restore_db_per_function")
|
|
|
|
@pytest.mark.usefixtures("restore_db_per_function")
|
|
|
|
|