"""Lambda module."""

from content_utils.exceptions import InvalidMessageException
import sentry_sdk
from sentry_sdk.integrations.aws_lambda import AwsLambdaIntegration

from src import config
from src.connectors.opensearch import os_connector

if config.SENTRY_DSN:
    sentry_sdk.init(
        dsn=config.SENTRY_DSN,
        environment=config.ENVIRONMENT,
        integrations=[AwsLambdaIntegration(timeout_warning=True)]
    )


def handler(event, context):
    """Lambda Entry point."""
    config.app_logger.debug(event)
    if 'product_id' not in event:
        raise InvalidMessageException('Invalid Message Structure')
    product_id = event['product_id']
    os_connector.remove_product(product_id)
    config.app_logger.info(f'Removed product {product_id} from index')
    return {'status': 'success'}