Fix Hasura metadata generation for v2.3.0 and above (#279)

* Better error handling

* Fix metadata request

Author: droserasprout

CHANGELOG.md

@@ -5,6 +5,7 @@
 ### Fixed
 
 * config: Fixed `jobs` config section validation.
+* hasura: Fixed metadata generation for v2.3.0 and above.
 * tzkt: Fixed `get_originated_contracts` and `get_similar_contracts` methods response.
 
 ## 5.0.0-rc3 - 2022-03-28

src/demo_hic_et_nunc/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_quipuswap/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_registrydao/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_tezos_domains/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_tezos_domains_big_map/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_tzbtc/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/demo_tzcolors/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.3.1
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/dipdup/exceptions.py

@@ -316,5 +316,7 @@ def _help(self) -> str:
         return f"""
             Failed to configure Hasura: {self.msg}
 
+            Check out Hasura logs for more information.
+
             GraphQL integration docs: https://docs.dipdup.net/graphql/
         """

src/dipdup/hasura.py

@@ -20,6 +20,7 @@
 import orjson as json
 from aiohttp import ClientConnectorError
 from aiohttp import ClientOSError
+from aiohttp import ClientResponseError
 from aiohttp import ServerDisconnectedError
 from pydantic.dataclasses import dataclass
 from tortoise import fields
@@ -161,16 +162,21 @@ async def configure(self, force: bool = False) -> None:
 
     async def _hasura_request(self, endpoint: str, json: Dict[str, Any]) -> Dict[str, Any]:
         self._logger.debug('Sending `%s` request: %s', endpoint, dump_json(json))
-        result = await self.request(
-            method='post',
-            cache=False,
-            url=f'{self._hasura_config.url}/v1/{endpoint}',
-            json=json,
-            headers=self._hasura_config.headers,
-        )
+        try:
+            result = await self.request(
+                method='post',
+                cache=False,
+                url=f'{self._hasura_config.url}/v1/{endpoint}',
+                json=json,
+                headers=self._hasura_config.headers,
+            )
+        except ClientResponseError as e:
+            raise HasuraError(f'{e.status} {e.message}') from e
+
         self._logger.debug('Response: %s', result)
-        if 'error' in result or 'errors' in result:
-            raise HasuraError(result)
+        if errors := result.get('error') or result.get('errors'):
+            raise HasuraError(errors)
+
         return result
 
     async def _healthcheck(self) -> None:
@@ -212,8 +218,11 @@ def _hash_metadata(self, metadata: Dict[str, Any]) -> str:
     async def _replace_metadata(self, metadata: Dict[str, Any]) -> None:
         self._logger.info('Replacing metadata')
         endpoint, json = 'query', {
-            "type": "replace_metadata",
-            "args": metadata,
+            'type': 'replace_metadata',
+            'args': {
+                'metadata': metadata,
+                'allow_inconsistent_metadata': True,
+            },
         }
         await self._hasura_request(endpoint, json)