style: ruff format

Author: jjcav84

deploy/proxy/mempalace_mcp_proxy.py

@@ -69,9 +69,7 @@
 # ALLOWED_HOSTS: comma-separated list of permitted Host headers (no Origin).
 # INBOUND_TOKEN: optional bearer token required for all /mcp endpoints.
 ALLOWED_ORIGINS = frozenset(
-    o.strip()
-    for o in os.environ.get("ALLOWED_ORIGINS", "").split(",")
-    if o.strip()
+    o.strip() for o in os.environ.get("ALLOWED_ORIGINS", "").split(",") if o.strip()
 )
 ALLOWED_HOSTS = frozenset(
     h.strip().lower()
@@ -264,9 +262,7 @@ def _is_valid_jsonrpc_request(body: bytes) -> tuple[bool, str | None, int]:
         return False, "method must be a non-empty string", -32600
 
     # id may be absent (notification), but if present must be a valid type.
-    if "id" in req and not (
-        isinstance(req["id"], (str, int, float)) or req["id"] is None
-    ):
+    if "id" in req and not (isinstance(req["id"], (str, int, float)) or req["id"] is None):
         return False, "id must be a string, number, or null", -32600
 
     params = req.get("params")

tests/test_proxy.py

@@ -557,7 +557,7 @@ def test_invalid_json_shape_is_not_retried(self):
         """Malformed JSON-RPC is not safe to retry."""
         import mempalace_mcp_proxy as proxy
 
-        body = b'not json'
+        body = b"not json"
         assert not proxy._is_retry_safe(body)
 
     def test_missing_jsonrpc_field_is_not_retried(self):
@@ -612,9 +612,7 @@ def test_final_5xx_with_json_body_is_failure_and_preserves_status(self):
                 FakeResponse(503, b"{}"),
                 FakeResponse(
                     503,
-                    json.dumps(
-                        {"jsonrpc": "2.0", "id": 1, "error": {"code": -32000}}
-                    ).encode(),
+                    json.dumps({"jsonrpc": "2.0", "id": 1, "error": {"code": -32000}}).encode(),
                 ),
             ],
             restore_circuit=False,
@@ -737,9 +735,7 @@ def test_repeated_json_5xx_opens_circuit_and_persists_status(self):
         body = json.dumps(
             {"jsonrpc": "2.0", "id": 1, "method": "tools/list", "params": {}}
         ).encode()
-        upstream_body = json.dumps(
-            {"jsonrpc": "2.0", "id": 1, "error": {"code": -32000}}
-        ).encode()
+        upstream_body = json.dumps({"jsonrpc": "2.0", "id": 1, "error": {"code": -32000}}).encode()
 
         async def test():
             # Reset proxy state for a clean circuit.
@@ -940,7 +936,10 @@ async def post(self, *args, **kwargs):
                     (b"null", "null"),
                     (b'"string"', "string"),
                     (b"123", "number"),
-                    (b'[{"jsonrpc":"2.0","id":1,"method":"tools/list","params":{}}, {"jsonrpc":"2.0","id":2,"method":"tools/list","params":{}}]', "batch array"),
+                    (
+                        b'[{"jsonrpc":"2.0","id":1,"method":"tools/list","params":{}}, {"jsonrpc":"2.0","id":2,"method":"tools/list","params":{}}]',
+                        "batch array",
+                    ),
                 ]
                 for body, label in cases:
                     resp = await client.post("/mcp", data=body)
@@ -993,7 +992,9 @@ async def aclose(self):
 
                 async def post(self, *args, **kwargs):
                     CountingClient.calls += 1
-                    return FakeResponse(200, json.dumps({"jsonrpc": "2.0", "id": 1, "result": []}).encode())
+                    return FakeResponse(
+                        200, json.dumps({"jsonrpc": "2.0", "id": 1, "result": []}).encode()
+                    )
 
             proxy._http_client = CountingClient()