"""Process to monitor SQS and update product statuses."""
import sentry_sdk
from sentry_sdk.integrations.logging import ignore_logger

from availability import config
from availability.connectors import loggly
from availability.logic.queue import consumer
from availability.logic.queue import utils

if __name__ == '__main__':
    sentry_sdk.init(
        dsn=config.SENTRY,
        enable_tracing=True
    )
    ignore_logger('ddtrace.internal.*')
    ignore_logger('spotipy.client')

    logger = loggly.get_current_logger()
    try:
        queue = utils.get_availability_queue()
        logger.info('Connected to SQS')
        consumer.process_messages(queue)
    except Exception as e:
        logger.error('Exception occurred: {}'.format(e))
        sentry_sdk.capture_exception(e)