Add client SDK, fix openenv.yaml format, add model aliases

- Add client.py: typed Python SDK wrapping the HTTP API
- Fix openenv.yaml to spec_version 1 format (matches reference envs)
- Add CloudSenseAction/CloudSenseObservation aliases in models
- Add root __init__.py exporting client and models

__init__.py

@@ -0,0 +1,23 @@
+"""CloudSense — RL benchmark for FinOps AI agents on cloud cost optimization."""
+
+from client import CloudSenseClient
+from env.models import (
+    ActionType,
+    CloudAction,
+    CloudObservation,
+    CloudResource,
+    CloudSenseAction,
+    CloudSenseObservation,
+    StepResult,
+)
+
+__all__ = [
+    "CloudSenseClient",
+    "ActionType",
+    "CloudAction",
+    "CloudObservation",
+    "CloudResource",
+    "CloudSenseAction",
+    "CloudSenseObservation",
+    "StepResult",
+]

client.py

@@ -0,0 +1,110 @@
+"""CloudSense Python SDK — typed client for the CloudSense RL environment."""
+
+from __future__ import annotations
+
+import requests
+from env.models import (
+    ActionType,
+    CloudAction,
+    CloudObservation,
+    CloudSenseAction,
+    CloudSenseObservation,
+    StepResult,
+)
+
+
+class CloudSenseClient:
+    """Typed HTTP client for the CloudSense environment API."""
+
+    def __init__(self, base_url: str = "http://localhost:7860"):
+        self.base_url = base_url.rstrip("/")
+        self._session = requests.Session()
+
+    # ── Core environment API ────────────────────────────────────────
+
+    def reset(self, task_id: str = "startup-cleanup") -> CloudObservation:
+        """Reset the environment to a new episode."""
+        resp = self._session.post(
+            f"{self.base_url}/reset",
+            params={"task_id": task_id},
+            timeout=30,
+        )
+        resp.raise_for_status()
+        return CloudObservation(**resp.json())
+
+    def step(self, action: CloudAction) -> StepResult:
+        """Execute an action and return the result."""
+        resp = self._session.post(
+            f"{self.base_url}/step",
+            json=action.model_dump(),
+            timeout=30,
+        )
+        resp.raise_for_status()
+        data = resp.json()
+        return StepResult(
+            observation=CloudObservation(**data["observation"]),
+            reward=data["reward"],
+            done=data["done"],
+            info=data.get("info", {}),
+        )
+
+    def state(self) -> dict:
+        """Get the current environment state."""
+        resp = self._session.get(f"{self.base_url}/state", timeout=10)
+        resp.raise_for_status()
+        return resp.json()
+
+    def close(self) -> None:
+        """Close the current episode."""
+        resp = self._session.post(f"{self.base_url}/close", timeout=10)
+        resp.raise_for_status()
+
+    # ── Discovery ───────────────────────────────────────────────────
+
+    def health(self) -> dict:
+        """Check environment health."""
+        resp = self._session.get(f"{self.base_url}/health", timeout=10)
+        resp.raise_for_status()
+        return resp.json()
+
+    def tasks(self) -> list[dict]:
+        """List available tasks."""
+        resp = self._session.get(f"{self.base_url}/tasks", timeout=10)
+        resp.raise_for_status()
+        return resp.json()
+
+    # ── Convenience ─────────────────────────────────────────────────
+
+    def rightsize(
+        self, resource_id: str, instance_type: str, reasoning: str = "", **config
+    ) -> StepResult:
+        """Shortcut: rightsize a resource."""
+        new_config = {"instance_type": instance_type, **config}
+        return self.step(
+            CloudAction(
+                action_type=ActionType.rightsize_resource,
+                resource_id=resource_id,
+                new_config=new_config,
+                reasoning=reasoning,
+            )
+        )
+
+    def terminate(self, resource_id: str, reasoning: str = "") -> StepResult:
+        """Shortcut: terminate a resource."""
+        return self.step(
+            CloudAction(
+                action_type=ActionType.terminate_resource,
+                resource_id=resource_id,
+                reasoning=reasoning,
+            )
+        )
+
+    def skip(self, resource_id: str, reasoning: str = "") -> StepResult:
+        """Shortcut: skip a resource."""
+        return self.step(
+            CloudAction(
+                action_type=ActionType.skip_resource,
+                resource_id=resource_id,
+                reasoning=reasoning,
+            )
+        )

env/models.py

@@ -91,3 +91,8 @@ class StepResult(BaseModel):
     reward: float
     done: bool
     info: dict = Field(default_factory=dict)
+
+
+# Aliases following OpenEnv naming convention
+CloudSenseAction = CloudAction
+CloudSenseObservation = CloudObservation

openenv.yaml

@@ -1,61 +1,6 @@
+spec_version: 1
 name: cloudsense
-description: "CloudSense: RL benchmark for training FinOps AI agents on cloud cost optimization with real AWS pricing and blast radius mechanics"
-version: "1.0.0"
-author: "CloudSense Team"
-
-environment:
-  type: docker
-  image: cloudsense
-  port: 7860
-
-tasks:
-  - id: startup-cleanup
-    difficulty: easy
-    description: "Optimize a small startup's dev/staging AWS account with 6 obviously oversized or unused resources. Total spend ~$627/mo, optimal ~$240/mo."
-    max_steps: 10
-    tags: ["finops", "cost-optimization", "beginner"]
-
-  - id: mid-size-audit
-    difficulty: medium
-    description: "Audit a mid-size company's mixed prod/dev AWS account with 15 resources. Must identify which resources to optimize and which to leave alone. Total spend ~$3,487/mo, optimal ~$1,700/mo."
-    max_steps: 20
-    tags: ["finops", "cost-optimization", "intermediate", "production-safety"]
-
-  - id: enterprise-finops
-    difficulty: hard
-    description: "Full FinOps review of an enterprise AWS account with 40 resources across prod/staging/dev. Complex dependencies, blast radius considerations, reserved instance management, and multi-service optimization. Total spend ~$14,230/mo, optimal ~$7,100/mo."
-    max_steps: 45
-    tags: ["finops", "cost-optimization", "advanced", "blast-radius", "dependencies"]
-
-endpoints:
-  reset: POST /reset?task_id={task_id}
-  step: POST /step
-  state: GET /state
-  health: GET /health
-  close: POST /close
-
-action_space:
-  type: json
-  schema:
-    action_type: "ActionType enum"
-    resource_id: "string"
-    new_config: "optional dict"
-    reasoning: "string"
-
-observation_space:
-  type: json
-  schema:
-    task_id: "string"
-    goal: "string"
-    account_id: "string"
-    resources: "list of CloudResource dicts"
-    monthly_cost_current: "float"
-    monthly_cost_optimized: "float"
-    total_possible_savings: "float"
-    actions_taken: "list of action dicts"
-    warnings: "list of strings"
-    step_number: "int"
-    max_steps: "int"
-    last_reward: "float"
-    last_action_error: "optional string"
-    info: "dict with blast_radius etc."
+type: environment
+runtime: docker
+app: server.app:app
+port: 7860