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

* Better error handling

* Fix metadata request

Author: droserasprout

CHANGELOG.md

@@ -7,6 +7,7 @@ Please use [this](https://docs.gitlab.com/ee/development/changelog.html) documen
 ### Fixed
 
 * config: Fixed default SQLite path (`:memory:`).
+* hasura: Fixed metadata generation for v2.3.0 and above.
 * tzkt: Fixed data loss when `skip_history` option is enabled.
 
 ## 4.2.6 - 2022-02-25

src/demo_hic_et_nunc/docker/docker-compose.yml

@@ -30,7 +30,7 @@ services:
       retries: 5
 
   hasura:
-    image: hasura/graphql-engine:v2.2.0
+    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.2.0
+    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.2.0
+    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.2.0
+    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.2.0
+    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.2.0
+    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.2.0
+    image: hasura/graphql-engine:v2.4.0
     ports:
       - 127.0.0.1:8080:8080
     depends_on:

src/dipdup/exceptions.py

@@ -336,5 +336,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 humps  # type: ignore
 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)