client.py

from __future__ import annotations

from dataclasses import fields
from typing import Any

from models import LedgerShieldAction, LedgerShieldObservation, LedgerShieldState
from openenv_compat import EnvClient, StepResult


class LedgerShieldEnv(EnvClient[LedgerShieldAction, LedgerShieldObservation, LedgerShieldState]):
    """
    Thin client wrapper for the LedgerShield OpenEnv-compatible HTTP server.
    """

    def _step_payload(self, action: LedgerShieldAction) -> dict[str, Any]:
        return {
            "action_type": action.action_type,
            "payload": action.payload,
        }

    def _parse_result(self, payload: dict[str, Any]) -> StepResult[LedgerShieldObservation]:
        observation_payload = payload.get("observation", {}) or {}
        observation = LedgerShieldObservation(**observation_payload)

        return StepResult(
            observation=observation,
            reward=float(payload.get("reward", 0.0) or 0.0),
            done=bool(payload.get("done", False)),
            info=payload.get("info", {}) or {},
        )

    def _parse_state(self, payload: dict[str, Any]) -> LedgerShieldState:
        allowed = {field.name for field in fields(LedgerShieldState)}
        filtered = {key: value for key, value in payload.items() if key in allowed}
        return LedgerShieldState(**filtered)