"""Boto3 sqs message operations."""

import json

from oto import response

import config
from connectors import sqs


def send_sqs_message(
        queue_url, message, delay_seconds=config.SQS_DELAY_TIMEOUT):
    """Send sqs message to given queue_url.

    Args:
        queue_url (str): Destination queue url.
        message (dict): Message body.
        delay_seconds (int): SQS message delay time.

    Returns:
        response.Response: Saved status info or error.
    """
    sqs_client = sqs.get_sqs_client()
    try:
        result = sqs_client.send_message(
            QueueUrl=queue_url,
            MessageBody=json.dumps(message),
            DelaySeconds=delay_seconds)
        return result
    except Exception as error:
        return response.create_fatal_response(
            'Failed to send sqs message with error: {msg}'.format(
                msg=str(error)))