"""Lambda function module."""
from typing import Dict

import boto3
from bulk_metadata_ingester_common.utils.jitter import jitter
from bulk_metadata_ingester_common.utils.logging import get_current_logger
import config


def handler(event: Dict, context: object) -> Dict:
    """Lambda Entrypoint."""
    bucket = event.get('bucket')
    item_index = event.get('item_index')
    correlation_id = event.get('correlation_id')

    logger = get_current_logger(
        config.ENVIRONMENT,
        config.LAMBDA_NAME,
        logging_level=config.LOGGING_LEVEL,
        correlation_id=correlation_id)

    # Jitter calls - Sleep for randomness
    jitter(logger)

    # Log lambda begins message
    logger.info(f'remove_ingestion_lock received: {event}')

    s3 = boto3.client('s3')

    lockfile_key = f'locks/{item_index}.lock'

    # Delete lockfile
    logger.info(f'Deleting lockfile: {lockfile_key}')
    s3.delete_object(Bucket=bucket, Key=lockfile_key)

    return event