ignore missing scale types, nicer node log

src/dipdup/cli.py

@@ -1,10 +1,10 @@
 # NOTE: All imports except the basic ones are very lazy in this module. Let's keep it that way.
 import asyncio
 import atexit
-from collections import defaultdict
 import logging
 import sys
 import traceback
+from collections import defaultdict
 from collections.abc import Callable
 from collections.abc import Coroutine
 from contextlib import AsyncExitStack
@@ -979,12 +979,14 @@ async def self_env(ctx: click.Context) -> None:
     env.refresh()
     env.print()
 
+
 @cli.group(hidden=True)
 @click.pass_context
 @_cli_wrapper
 async def abi(ctx: click.Context) -> None:
     pass
 
+
 @abi.command(name='lookup', hidden=True)
 @click.pass_context
 @click.argument('query', type=str)
@@ -1006,7 +1008,7 @@ async def abi_lookup(ctx: click.Context, query: str) -> None:
     res = subprocess.run(
         ('grep', '-n', '-r', query, *abi_paths),
         capture_output=True,
-        check=True,
+        check=False,
     )
     out = res.stdout.decode()
     lines = out.splitlines()
@@ -1022,6 +1024,7 @@ async def abi_lookup(ctx: click.Context, query: str) -> None:
             echo('- ' + line)
         echo('')
 
+
 @cli.group()
 @click.pass_context
 @_cli_wrapper

src/dipdup/datasources/substrate_node.py

@@ -121,16 +121,19 @@ async def run(self) -> None:
                 await asyncio.sleep(self._http_config.polling_interval)
 
     async def initialize(self) -> None:
-        version_info = await self._interface.rpc_request('system_version', [])
-        self._logger.info('running version %s', version_info['result'])
-
         level = await self.get_head_level()
         self.set_sync_level(None, level)
 
         # NOTE: Prepare substrate_interface
         await self._interface.init_props()  # type: ignore[no-untyped-call]
         self._interface.reload_type_registry()
 
+        self._logger.info(
+            'connected to %s (%s)',
+            self._interface.chain,
+            self._interface.version,
+        )
+
     @cached_property
     def _interface(self) -> 'SubstrateInterface':
         from dipdup.datasources._aiosubstrate import SubstrateInterfaceProxy

src/dipdup/runtimes.py

@@ -187,10 +187,15 @@ def decode_event_args(
                 value_len = len(value[2:]) * 2
                 value = f'0x{value_len:02x}{value[2:]}'
 
-            scale_obj = self.runtime_config.create_scale_object(
-                type_string=type_,
-                data=ScaleBytes(value) if isinstance(value, str) else value,
-            )
+            try:
+                scale_obj = self.runtime_config.create_scale_object(
+                    type_string=type_,
+                    data=ScaleBytes(value) if isinstance(value, str) else value,
+                )
+            except NotImplementedError:
+                _logger.error('unsupported type `%s`', type_)
+                payload[key] = value
+                continue
 
             payload[key] = scale_obj.process()