vars naming

src/dipdup/datasources/evm_node.py

@@ -102,7 +102,7 @@ async def initialize(self) -> None:
         self.set_sync_level(None, level)
 
     async def run(self) -> None:
-        if self.realtime:
+        if self.ws_available:
             await asyncio.gather(
                 self._ws_loop(),
                 self._emitter_loop(),
@@ -181,11 +181,11 @@ async def _ws_loop(self) -> None:
         raise DatasourceError('Websocket connection failed', self.name)
 
     @property
-    def realtime(self) -> bool:
+    def ws_available(self) -> bool:
         return self._config.ws_url is not None
 
     async def subscribe(self) -> None:
-        if not self.realtime:
+        if not self.ws_available:
             return
 
         missing_subscriptions = self._subscriptions.missing_subscriptions

src/dipdup/datasources/starknet_node.py

@@ -33,7 +33,7 @@ async def initialize(self) -> None:
         self.set_sync_level(None, level)
 
     async def run(self) -> None:
-        if self.realtime:
+        if self.ws_available:
             raise NotImplementedError('Realtime mode is not supported yet; remove `ws_url` from datasource config')
 
         while True:
@@ -42,11 +42,11 @@ async def run(self) -> None:
             await asyncio.sleep(self._http_config.polling_interval)
 
     @property
-    def realtime(self) -> bool:
+    def ws_available(self) -> bool:
         return self._config.ws_url is not None
 
     async def subscribe(self) -> None:
-        if self.realtime:
+        if self.ws_available:
             raise NotImplementedError('Realtime mode is not supported yet; remove `ws_url` from datasource config')
 
     async def get_head_level(self) -> int:

src/dipdup/datasources/substrate_node.py

@@ -114,7 +114,7 @@ def __init__(self, config: SubstrateNodeDatasourceConfig) -> None:
         self._on_event_callbacks: set[EventCallback] = set()
 
     async def run(self) -> None:
-        if self.realtime:
+        if self.ws_available:
             await asyncio.gather(
                 self._ws_loop(),
                 self._emitter_loop(),
@@ -152,11 +152,11 @@ async def _ws_loop(self) -> None:
         raise DatasourceError('Websocket connection failed', self.name)
 
     @property
-    def realtime(self) -> bool:
+    def ws_available(self) -> bool:
         return self._config.ws_url is not None
 
     async def subscribe(self) -> None:
-        if not self.realtime:
+        if not self.ws_available:
             return
 
         missing_subscriptions = self._subscriptions.missing_subscriptions

src/dipdup/dipdup.py

@@ -230,11 +230,11 @@ async def _update_metrics(self) -> None:
         active, synced, realtime = 0, 0, 0
         levels_indexed, levels_total, levels_interval = 0, 0, 0
         for index in self._indexes.values():
-            # FIXME: We don't remove disabled indexes from dispatcher anymore
-            active += 1
-            if index.synchronized:
+            if index.is_active:
+                active += 1
+            if index.is_synchronized:
                 synced += 1
-            if index.realtime:
+            if index.is_realtime:
                 realtime += 1
 
             try:

src/dipdup/index.py

@@ -190,11 +190,15 @@ def state(self) -> models.Index:
         return self._state
 
     @property
-    def synchronized(self) -> bool:
+    def is_active(self) -> bool:
+        return self.state.status not in (IndexStatus.disabled, IndexStatus.failed)
+
+    @property
+    def is_synchronized(self) -> bool:
         return self.state.status == IndexStatus.realtime
 
     @property
-    def realtime(self) -> bool:
+    def is_realtime(self) -> bool:
         return self.state.status == IndexStatus.realtime and not self.queue
 
     def get_sync_level(self) -> int: