"""Lambda function module."""

import logging

import consts
import s3
import streams_totals
import util


logger = logging.getLogger()
logger.setLevel(logging.INFO)


def handler(event, context):
    """Lambda entry point."""
    bucket, key = util.extract_triggered_key(event)
    if s3.key_exists(bucket, key) and util.object_is_file(key):
        s3_url = 's3://{bucket}/{key}'.format(bucket=bucket, key=key)
        logger.info('File is going to be processed {}'.format(s3_url))
        streams_totals.load(s3_url, consts.TRACK)
        logger.info('File was successfully processed {}'.format(s3_url))
        s3.delete_key(bucket, key)
        logger.info('File was successfully deleted {}'.format(s3_url))