"""execute-content-transfer Lambda handler."""

from typing import Any

from src import config  # noqa: F401 -- initializes Sentry and client
from src.client import execute_content_transfer


def _job_id_from_event(event: dict[str, Any]) -> int:
    raw_job_id = event["job_id"]
    if isinstance(raw_job_id, bool):
        raise ValueError("event['job_id'] must be an integer.")

    try:
        return int(raw_job_id)
    except (TypeError, ValueError) as exc:
        raise ValueError("event['job_id'] must be an integer.") from exc


def handler(event: dict[str, Any], context: object) -> dict[str, Any]:
    del context

    job_id = _job_id_from_event(event)
    config.logger.info(f"Executing content transfer for job {job_id}")
    transfer_result = execute_content_transfer(job_id)
    config.logger.info(f"Completed content transfer for job {job_id}: {transfer_result}")
    return {
        **event,
        "execute_content_transfer_result": transfer_result,
    }