cdk/test/test_s3_batch_lambda_handler.py

"""S3 batch Lambda handler behaviour (assignPublicIp, env merge)."""

import importlib.util
import sys
from pathlib import Path

CDK_DIR = Path(__file__).resolve().parents[1]
LAMBDA_PATH = CDK_DIR / "config" / "lambda" / "lambda_function.py"


def _load_lambda_module(module_name: str = "batch_lambda"):
    spec = importlib.util.spec_from_file_location(module_name, LAMBDA_PATH)
    module = importlib.util.module_from_spec(spec)
    assert spec.loader is not None
    sys.modules[module_name] = module
    spec.loader.exec_module(module)
    return module


def test_assign_public_ip_reads_env(monkeypatch):
    monkeypatch.setenv("ECS_ASSIGN_PUBLIC_IP", "ENABLED")
    module = _load_lambda_module("batch_lambda_ip")
    assert module.ECS_ASSIGN_PUBLIC_IP == "ENABLED"


def test_build_environment_merges_job_and_default_env(monkeypatch):
    mod = _load_lambda_module("batch_lambda_merge")
    monkeypatch.setattr(
        mod,
        "s3",
        type(
            "S3",
            (),
            {
                "get_object": staticmethod(
                    lambda Bucket, Key: {
                        "Body": type(
                            "Body",
                            (),
                            {
                                "read": staticmethod(
                                    lambda: (
                                        b"RUN_DIRECT_MODE=1\n"
                                        b"DIRECT_MODE_INPUT_FILE=job.xlsx\n"
                                        if Key.endswith("job.env")
                                        else b"RUN_AWS_FUNCTIONS=1\n"
                                    )
                                )
                            },
                        )()
                    }
                ),
            },
        )(),
    )
    monkeypatch.setattr(
        mod,
        "ecs",
        type(
            "ECS",
            (),
            {"run_task": staticmethod(lambda **kwargs: {"tasks": [], "failures": []})},
        )(),
    )

    mod.BUCKET = "output-bucket"
    mod.INPUT_PREFIX = "input/"
    mod.ENV_PREFIX = "input/config/"
    mod.ENV_SUFFIX = ".env"
    mod.DEFAULT_PARAMS_KEY = "general-config/app_defaults.env"
    mod.CLUSTER = "cluster"
    mod.TASK_DEF = "arn:aws:ecs:eu-west-2:123:task-definition/app:1"
    mod.SUBNETS = ["subnet-1"]
    mod.SECURITY_GROUPS = ["sg-1"]
    mod.CONTAINER_NAME = "app"

    event = {
        "Records": [
            {
                "s3": {
                    "bucket": {"name": "output-bucket"},
                    "object": {"key": "input/config/job.env"},
                }
            }
        ]
    }
    result = mod.lambda_handler(event, None)
    assert result["runs"]
    assert result["runs"][0]["envCount"] >= 2