Model/backend/condition/handler/handler.py

# import json
from typing import Mapping, Any
import os

# from io import BytesIO

from backend.app.config import get_settings

# 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 DB HOST:",
        os.getenv("DB_HOST", "empty db host"),
    )
    print(
        "hello DB PORT:",
        os.getenv("DB_PORT", "empty db port"),
    )
    print(
        "hello DB NAME:",
        os.getenv("DB_NAME", "empty name"),
    )
    print(
        "hello region",
        os.getenv("AWS_REGION", "empty region"),
    )
    print(
        "hello Dan:",
        os.getenv("DAN", "empty dan"),
    )
    settings = get_settings()
    print("hello db user", settings.DB_USERNAME)

    # 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}")