camelCase normalization

Author: psyb0t

README.md

@@ -290,19 +290,31 @@ You can also pin specific versions with full model names (`claude-opus-4-6`, `cl
 
 **`text`** (default) — plain text response.
 
-**`json`** — single JSON object:
+**`json`** — single JSON object (all keys normalized to camelCase):
 
 ```json
 {
   "type": "result",
   "subtype": "success",
-  "is_error": false,
+  "isError": false,
   "result": "the response text",
-  "num_turns": 1,
-  "duration_ms": 3100,
-  "total_cost_usd": 0.156,
-  "session_id": "...",
-  "usage": { "input_tokens": 3, "output_tokens": 4 }
+  "numTurns": 1,
+  "durationMs": 3100,
+  "totalCostUsd": 0.156,
+  "sessionId": "...",
+  "usage": { "inputTokens": 3, "outputTokens": 4, "cacheReadInputTokens": 512 },
+  "modelUsage": {
+    "glm-5.1": {
+      "inputTokens": 15702,
+      "outputTokens": 28,
+      "cacheReadInputTokens": 6836,
+      "costUsd": 0.0826,
+      "contextWindow": 200000,
+      "maxOutputTokens": 32000
+    }
+  },
+  "permissionDenials": [],
+  "iterations": []
 }
 ```
 

api_server.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python3
 
 import asyncio
+import json
 import os
 import signal
 from typing import Optional
@@ -13,6 +14,31 @@
 app = FastAPI()
 
 
+def _to_camel(name: str) -> str:
+    """Convert a snake_case string to camelCase."""
+    parts = name.split("_")
+    return parts[0] + "".join(p.capitalize() for p in parts[1:])
+
+
+def _normalize_keys(obj):
+    """Recursively convert all dict keys from snake_case to camelCase."""
+    if isinstance(obj, dict):
+        return {_to_camel(k): _normalize_keys(v) for k, v in obj.items()}
+    if isinstance(obj, list):
+        return [_normalize_keys(item) for item in obj]
+    return obj
+
+
+def _normalize_response(raw: bytes) -> bytes:
+    """Parse raw JSON bytes, normalize keys to camelCase, return bytes."""
+    try:
+        parsed = json.loads(raw)
+        normalized = _normalize_keys(parsed)
+        return json.dumps(normalized).encode()
+    except (json.JSONDecodeError, ValueError):
+        return raw
+
+
 def _shutdown(sig, _frame):
     for ws, proc in list(busy_workspaces.items()):
         try:
@@ -216,7 +242,7 @@ async def _disconnect_watcher():
     if not req.fire_and_forget and await request.is_disconnected():
         return Response(status_code=499)
 
-    return Response(content=output, media_type="application/json")
+    return Response(content=_normalize_response(output), media_type="application/json")
 
 
 @app.get("/files/{path:path}")