polyguard-rl/app/env/catalog.py

"""Adapter catalog for old task labels over the canonical PolyGuard env."""

from __future__ import annotations

from typing import Any

from app.common.constants import REWARD_MAX, REWARD_MIN, REWARD_PRECISION
from app.common.enums import Difficulty, SubEnvironment

TASK_PRESETS: tuple[dict[str, str], ...] = (
    {
        "id": "easy_screening",
        "label": "Easy Screening",
        "difficulty": Difficulty.EASY.value,
        "sub_environment": SubEnvironment.DDI.value,
    },
    {
        "id": "budgeted_screening",
        "label": "Budgeted Screening",
        "difficulty": Difficulty.MEDIUM.value,
        "sub_environment": SubEnvironment.REGIMEN_RISK.value,
    },
    {
        "id": "complex_tradeoff",
        "label": "Complex Tradeoff",
        "difficulty": Difficulty.HARD.value,
        "sub_environment": SubEnvironment.REGIMEN_RISK.value,
    },
    {
        "id": "bandit_mining",
        "label": "Bandit Mining",
        "difficulty": Difficulty.HARD.value,
        "sub_environment": SubEnvironment.BANDIT_MINING.value,
    },
)

TASK_PRESET_BY_ID = {item["id"]: item for item in TASK_PRESETS}


def env_catalog() -> dict[str, Any]:
    return {
        "reward_range": [REWARD_MIN, REWARD_MAX],
        "reward_precision": REWARD_PRECISION,
        "task_presets": [dict(item) for item in TASK_PRESETS],
        "sub_environments": [item.value for item in SubEnvironment],
    }


def apply_task_preset(payload: dict[str, Any]) -> dict[str, Any]:
    """Expand an old task label into canonical difficulty/sub-environment fields."""
    task_id = payload.pop("task_id", None)
    if not task_id:
        return payload
    preset = TASK_PRESET_BY_ID.get(str(task_id))
    if preset is None:
        raise ValueError(f"Unknown task_id {task_id!r}")
    if payload.get("difficulty") is None:
        payload["difficulty"] = preset["difficulty"]
    if payload.get("sub_environment") is None:
        payload["sub_environment"] = preset["sub_environment"]
    return payload