Fix: ClientResponse of aiohttps does not have model_dump_json() method

Author: 1yam

src/aleph/chains/indexer_reader.py

@@ -146,7 +146,7 @@ async def _query(self, query: str, model: Type[T]) -> T:
 
         response = await self.http_session.post("/", json={"query": query})
         response.raise_for_status()
-        response_json = await response.model_dump_json()
+        response_json = await response.json()
         return model.model_validate(response_json)
 
     async def fetch_account_state(

src/aleph/chains/nuls2.py

@@ -248,7 +248,7 @@ async def get_transactions(
             "pagination": 500,
         },
     ) as resp:
-        jres = await resp.model_dump_json()
+        jres = await resp.json()
         for tx in sorted(jres["transactions"], key=itemgetter("height")):
             if remark is not None and tx["remark"] != remark:
                 continue

src/aleph/chains/tezos.py

@@ -139,7 +139,7 @@ def make_graphql_query(
 async def get_indexer_status(http_session: aiohttp.ClientSession) -> SyncStatus:
     response = await http_session.post("/", json={"query": make_graphql_status_query()})
     response.raise_for_status()
-    response_json = await response.model_dump_json()
+    response_json = await response.json()
 
     return SyncStatus(response_json["data"]["indexStatus"]["status"])
 
@@ -160,7 +160,7 @@ async def fetch_messages(
 
     response = await http_session.post("/", json={"query": query})
     response.raise_for_status()
-    response_json = await response.model_dump_json()
+    response_json = await response.json()
 
     return IndexerResponse[IndexerMessageEvent].model_validate(response_json)
 

src/aleph/services/ipfs/service.py

@@ -165,7 +165,7 @@ async def add_file(self, file_content: bytes):
 
             resp = await session.post(url, data=data)
             resp.raise_for_status()
-            return await resp.model_dump_json()
+            return await resp.json()
 
     async def sub(self, topic: str):
         ipfs_client = self.ipfs_client