"""Test integration of an app with SQS."""
from moto import mock_aws

from salessheets.connectors import sqs


@mock_aws
def test_get_connection():
    """Test if get_connection() returns a valid connection object."""
    connection = sqs.get_connection(
        access_key_id='test', secret_access_key='test-key')
    assert connection is not None


@mock_aws
def test_get_queue():
    """Test if get_queue() returns a Queue."""
    connection = sqs.get_connection(
        access_key_id='test', secret_access_key='test-key')
    connection.create_queue(QueueName='dev-test-queue')
    queue = sqs.get_queue('dev-test-queue', sqs_connection=connection)
    assert queue is not None