"""Lambda enqueue_sessions function module."""

from typing import Any

from common.connectors import ows_product_staging
from lambdacommon.common_config import logger

from src.connectors import sqs


def handle() -> None:
    """
    Lambda entry point.

    Retrieves ingestions ready to be finalized and publishes each
    to the SQS queue for downstream processing.
    """
    logger.info("enqueue_sessions invoked - no-op")
    ingestions = ows_product_staging.get_ingestions_to_finalize()
    logger.info(f"Found {len(ingestions)} ingestions to finalize")

    for ingestion in ingestions:
        sqs.send_finalize_session_message(ingestion)
        logger.info(f"Published ingestion {ingestion.bulk_session_ingestion_id} to SQS")


def handler(event_data: dict[str, Any], context: Any) -> dict[str, Any]:
    """
    Lambda handler function.

    Args:
        event_data: Lambda event payload (should look like event.shadow.json)
        context: Lambda context.

    Returns:
        The input event_data unchanged.
    """
    handle()
    return event_data