fix: ping issue. reponse has changed

Author: atstaeff

eventsourcingdb_client_python/handlers/ping.py

@@ -7,12 +7,13 @@
 OK_RESPONSE = "OK"
 STATUS_OK = "ok"
 
+
 async def ping(client: AbstractBaseClient) -> None:
-    response = await client.http_client.get('/api/v1/ping')
-    response_body = bytes.decode(await response.body.read(), encoding='utf-8')
+    response = await client.http_client.get("/api/v1/ping")
+    response_body = bytes.decode(await response.body.read(), encoding="utf-8")
 
     if response.status_code != HTTPStatus.OK:
-        raise ServerError(f'Received unexpected response: {response_body}')
+        raise ServerError(f"Received unexpected response: {response_body}")
 
     # Check old format (plain "OK")
     if response_body == OK_RESPONSE:
@@ -21,9 +22,19 @@ async def ping(client: AbstractBaseClient) -> None:
     try:
         response_json = json.loads(response_body)
     except json.JSONDecodeError:
-        pass
-    else:
-        if isinstance(response_json, dict) and response_json.get('status') == STATUS_OK:
+        raise ServerError(f"Received unexpected response: {response_body}")
+
+    # Check if it's a JSON with status field
+    if isinstance(response_json, dict) and response_json.get("status") == STATUS_OK:
+        return
+
+    # Check if it's a CloudEvent format (has specversion, type fields)
+    if (
+        isinstance(response_json, dict)
+        and "specversion" in response_json
+        and "type" in response_json
+    ):
+        if response_json.get("type") == "io.eventsourcingdb.ping-received":
             return
 
-    raise ServerError(f'Received unexpected response: {response_body}')
+    raise ServerError(f"Received unexpected response: {response_body}")