import json
from typing import Mapping, Any
from io import BytesIO

from backend.condition.condition_trigger_request import ConditionTriggerRequest
from backend.condition.lookups.uprn_lookup_s3 import UprnLookupS3
from backend.condition.processor import process_file
from utils.logger import setup_logger
from utils.s3 import read_io_from_s3


logger = setup_logger()


def handler(event: Mapping[str, Any], context: Any) -> None:
    print("hello world")
    # uprn_lookup = UprnLookupS3(
    #     bucket="", key=""
    # )  # TODO: replace with postgres implementation

    # for record in event.get("Records", []):
    #     try:
    #         body_dict = json.loads(record["body"])
    #         payload = ConditionTriggerRequest.model_validate(body_dict)

    #         file_bytes: BytesIO = read_io_from_s3(
    #             bucket_name=payload.trigger_file_bucket,
    #             file_key=payload.trigger_file_key,
    #         )

    #         process_file(
    #             file_stream=file_bytes,
    #             file_type=payload.file_type,
    #             uprn_lookup=uprn_lookup,
    #         )

    #     except Exception as e:
    #         logger.error(f"Failed to process record: {e}")