mirror of
https://github.com/GSA/notifications-api.git
synced 2026-02-01 15:46:07 -05:00
@@ -144,6 +144,7 @@ def test_create_broadcast_message(admin_request, sample_broadcast_service, train
|
||||
broadcast_message = dao_get_broadcast_message_by_id_and_service_id(response["id"], sample_broadcast_service.id)
|
||||
assert broadcast_message.stubbed == training_mode_service
|
||||
|
||||
|
||||
@pytest.mark.parametrize('data, expected_errors', [
|
||||
(
|
||||
{},
|
||||
@@ -625,6 +626,7 @@ def test_update_broadcast_message_status_creates_event_with_correct_content_if_b
|
||||
|
||||
assert alert_event.transmitted_content == {"body": "tailor made emergency broadcast content"}
|
||||
|
||||
|
||||
@pytest.mark.parametrize('is_platform_admin', [True, False])
|
||||
def test_update_broadcast_message_status_rejects_approval_from_creator(
|
||||
admin_request,
|
||||
|
||||
@@ -253,20 +253,20 @@ def test_send_broadcast_provider_message_works_if_we_retried_previously(mocker,
|
||||
template = create_template(sample_service, BROADCAST_TYPE)
|
||||
broadcast_message = create_broadcast_message(
|
||||
template,
|
||||
areas={'areas': [], 'simple_polygons': [],},
|
||||
areas={'areas': [], 'simple_polygons': [], },
|
||||
status=BroadcastStatusType.BROADCASTING
|
||||
)
|
||||
event = create_broadcast_event(broadcast_message)
|
||||
|
||||
# an existing provider message already exists, and previously failed
|
||||
existing_provider_message = create_broadcast_provider_message(
|
||||
create_broadcast_provider_message(
|
||||
broadcast_event=event,
|
||||
provider='ee',
|
||||
status=BroadcastProviderMessageStatus.SENDING
|
||||
)
|
||||
|
||||
mock_create_broadcast = mocker.patch(
|
||||
f'app.clients.cbc_proxy.CBCProxyEE.create_and_send_broadcast',
|
||||
'app.clients.cbc_proxy.CBCProxyEE.create_and_send_broadcast',
|
||||
)
|
||||
|
||||
send_broadcast_provider_message(provider='ee', broadcast_event_id=str(event.id))
|
||||
@@ -496,7 +496,6 @@ def test_send_broadcast_provider_message_errors(mocker, sample_service, provider
|
||||
assert broadcast_provider_message.status == BroadcastProviderMessageStatus.SENDING
|
||||
|
||||
|
||||
|
||||
@pytest.mark.parametrize('num_retries, expected_countdown', [
|
||||
(0, 1),
|
||||
(5, 32),
|
||||
@@ -688,7 +687,8 @@ def test_check_provider_message_should_send_doesnt_raise_if_newer_event_not_acke
|
||||
message_type='alert',
|
||||
sent_at=datetime(2021, 1, 1, 0, 0),
|
||||
)
|
||||
future_event = create_broadcast_event(
|
||||
# create a future event
|
||||
create_broadcast_event(
|
||||
broadcast_message,
|
||||
message_type='cancel',
|
||||
sent_at=datetime(2021, 1, 1, 10, 0),
|
||||
|
||||
@@ -57,7 +57,10 @@ def test_send_sms_should_not_switch_providers_on_non_provider_failure(
|
||||
|
||||
|
||||
def test_should_retry_and_log_warning_if_SmsClientResponseException_for_deliver_sms_task(sample_notification, mocker):
|
||||
mocker.patch('app.delivery.send_to_providers.send_sms_to_provider', side_effect=SmsClientResponseException("something went wrong"))
|
||||
mocker.patch(
|
||||
'app.delivery.send_to_providers.send_sms_to_provider',
|
||||
side_effect=SmsClientResponseException("something went wrong"),
|
||||
)
|
||||
mocker.patch('app.celery.provider_tasks.deliver_sms.retry')
|
||||
mock_logger_warning = mocker.patch('app.celery.tasks.current_app.logger.warning')
|
||||
|
||||
|
||||
@@ -40,6 +40,7 @@ def cbc_proxy_client(client, mocker):
|
||||
def cbc_proxy_ee(cbc_proxy_client):
|
||||
return cbc_proxy_client.get_proxy('ee')
|
||||
|
||||
|
||||
@pytest.fixture
|
||||
def cbc_proxy_vodafone(cbc_proxy_client):
|
||||
return cbc_proxy_client.get_proxy('vodafone')
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
import pytest
|
||||
|
||||
from flask import json
|
||||
from freezegun import freeze_time
|
||||
from tests import create_authorization_header
|
||||
from unittest.mock import ANY
|
||||
from . import sample_cap_xml_documents
|
||||
@@ -80,12 +79,12 @@ def test_valid_post_cap_xml_broadcast_returns_201(
|
||||
response_json = json.loads(response.get_data(as_text=True))
|
||||
|
||||
assert response_json['approved_at'] is None
|
||||
assert response_json['approved_by_id'] == None
|
||||
assert response_json['approved_by_id'] is None
|
||||
assert response_json['areas'] == [
|
||||
'River Steeping in Wainfleet All Saints'
|
||||
]
|
||||
assert response_json['cancelled_at'] == None
|
||||
assert response_json['cancelled_by_id'] == None
|
||||
assert response_json['cancelled_at'] is None
|
||||
assert response_json['cancelled_by_id'] is None
|
||||
assert response_json['content'].startswith(
|
||||
'A severe flood warning has been issued. Storm Dennis'
|
||||
)
|
||||
@@ -94,7 +93,7 @@ def test_valid_post_cap_xml_broadcast_returns_201(
|
||||
)
|
||||
assert response_json['reference'] == '50385fcb0ab7aa447bbd46d848ce8466E'
|
||||
assert response_json['created_at'] # datetime generated by the DB so can’t freeze it
|
||||
assert response_json['created_by_id'] == None
|
||||
assert response_json['created_by_id'] is None
|
||||
assert response_json['finishes_at'] is None
|
||||
assert response_json['id'] == ANY
|
||||
assert response_json['personalisation'] is None
|
||||
|
||||
Reference in New Issue
Block a user