import json
import os


def lambda_handler(event, context):
    app_name = os.environ.get("APP_NAME", "Quantum")
    bucket_name = os.environ.get("BUCKET_NAME", "unknown")
    secret_name = os.environ.get("SECRET_NAME", "unknown")

    records = event.get("Records", [])

    processed = []
    for record in records:
        body = record.get("body", "{}")

        try:
            payload = json.loads(body)
        except json.JSONDecodeError:
            payload = {"raw": body}

        processed.append(
            {
                "messageId": record.get("messageId"),
                "payload": payload,
            }
        )

    print(
        json.dumps(
            {
                "app": app_name,
                "bucket": bucket_name,
                "secret": secret_name,
                "processedCount": len(processed),
                "records": processed,
            }
        )
    )

    return {
        "statusCode": 200,
        "body": json.dumps(
            {
                "message": "Quantum event batch processed",
                "processedCount": len(processed),
            }
        ),
    }