# pylint: disable=unused-argument
from sqlalchemy import null

from delphi_slz_admin.services.notification import NotificationService


def test_push_content_statuses_metadata_ok(db, clean_db, sqs, sqs_queue_arn, content_status):
    service = NotificationService(db)

    failed_ids = service.push_content_statuses_metadata([content_status.content_status_id])

    assert not failed_ids
    assert 'Messages' in sqs.receive_message(QueueUrl=sqs_queue_arn['arn-1'])


def test_push_content_statuses_metadata_empty_metadata(
    db, clean_db, sqs, sqs_queue_arn, content_status
):
    content_status.meta_data = null()
    service = NotificationService(db)

    failed_ids = service.push_content_statuses_metadata([content_status.content_status_id])

    assert not failed_ids
    assert 'Messages' not in sqs.receive_message(QueueUrl=sqs_queue_arn['arn-1'])


def test_push_content_statuses_metadata_failed(db, clean_db, sqs, sqs_queue_arn, content_status):
    sqs.delete_queue(QueueUrl=sqs_queue_arn['arn-1'])
    service = NotificationService(db)

    failed_ids = service.push_content_statuses_metadata([content_status.content_status_id])

    assert failed_ids == [content_status.content_status_id]