refactor OBPClient to use HTTP verbs

Author: nemozak1

src/auth/admin_client.py

@@ -160,7 +160,7 @@ def get_admin_client() -> OBPClient:
         >>> 
         >>> # Later, anywhere in the app
         >>> admin_client = get_admin_client()
-        >>> response = await admin_client.async_obp_requests("GET", "/obp/v6.0.0/banks", "")
+        >>> response = await admin_client.get("/obp/v6.0.0/banks")
     """
     return _admin_manager.get_client()
 

src/auth/auth.py

@@ -459,10 +459,8 @@ async def create_admin_direct_login_auth(
         version = os.getenv('OBP_API_VERSION', 'v6.0.0')
 
         try:
-            response_json = await obp_client.async_obp_requests(
-                "GET", 
-                f"/obp/{version}/my/entitlements",
-                ""
+            response_json = await obp_client.get(
+                f"/obp/{version}/my/entitlements"
             )
 
             if not response_json:

src/checkpointer/entities.py

@@ -2,6 +2,7 @@
 from typing import Optional
 from pydantic import BaseModel, Field
 from src.client.obp_client import OBPClient
+import json
 
 class OpeyCheckpointEntity(BaseModel):
     """OBP Dynamic Entity representation of a LangGraph checkpoint."""
@@ -73,26 +74,21 @@ def __init__(self, obp_client: OBPClient, endpoint_url: str):
 
 
     async def create(self, entity: OpeyCheckpointEntity | OpeyCheckpointWriteEntity):
-        await self.client.async_obp_requests(
-            method="POST",
-            body=str(entity.model_dump()),
-            path=self.endpoint_url
+        await self.client.post(
+            path=self.endpoint_url,
+            body=entity.model_dump()
         )
 
     async def delete(self, entity_id: str):
-        await self.client.async_obp_requests(
-            method="DELETE",
-            body="",
+        await self.client.delete(
             path=f"{self.endpoint_url}/{entity_id}"
         )
 
     async def read(self, entity_id: str) -> dict:
-        response = await self.client.async_obp_requests(
-            method="GET",
-            body="",
+        response = await self.client.get(
             path=f"{self.endpoint_url}/{entity_id}"
         )
-        return response
+        return json.loads(response) if isinstance(response, str) else response
 
 opey_checkpoint_entity = {
   "hasPersonalEntity": True,