"""Module that responds for input message processing."""

from oto import response

from app_name.constants import error
from app_name.utils import message_extractor


def sample_processing(message):
    """Process your data here.

    Args:
        message (sqs.Message): message pulled from SQS-queue.

    Returns:
        Response: successful response in case there was no exceptions.
    """
    message_body = message_extractor.get_message_body(message)
    if not message_body:
        return response.create_error_response(
            code=error.ERROR_MESSAGE_INVALID_SQS,
            message=error.ERROR_MESSAGE_INVALID_SQS)
    # add some processing code and additional validation here
    return response.Response()