Feat/remove cron dependency

README.md

@@ -78,6 +78,12 @@ poetry run pytest -v
 ```
 
 ### Changelogs
+**0.10**
+* Remove `aiocron` dependency. Use plain asyncio tasks to solve the timeout height synchronization
+
+**0.9.3**
+* Updated TIA/USDT-30NOV2023 market id in denoms_mainnet.ini file
+
 **0.9.2**
 * Added fix to the grpc import error in Mac with M1 and M2 chips
 

pyinjective/async_client.py

@@ -4,7 +4,6 @@
 from decimal import Decimal
 from typing import Coroutine, Dict, List, Optional, Tuple, Union
 
-import aiocron
 import grpc
 
 from pyinjective.composer import Composer
@@ -108,13 +107,8 @@
         )
         self.stubExplorer = explorer_rpc_grpc.InjectiveExplorerRPCStub(self.explorer_channel)
 
-        # timeout height update routine
-        self.cron = aiocron.crontab(
-            "* * * * * */{}".format(DEFAULT_TIMEOUTHEIGHT_SYNC_INTERVAL),
-            func=self.sync_timeout_height,
-            args=(),
-            start=True,
-        )
+        self._timeout_height_sync_task = None
+        self._initialize_timeout_height_sync_task()
 
         self._tokens_and_markets_initialization_lock = asyncio.Lock()
         self._tokens: Optional[Dict[str, Token]] = None
@@ -163,11 +157,11 @@
 
     async def close_exchange_channel(self):
         await self.exchange_channel.close()
-        self.cron.stop()
+        self._cancel_timeout_height_sync_task()
 
     async def close_chain_channel(self):
         await self.chain_channel.close()
-        self.cron.stop()
+        self._cancel_timeout_height_sync_task()
 
     async def sync_timeout_height(self):
         try:
@@ -1009,3 +1003,17 @@
     def _exchange_cookie_metadata_requestor(self) -> Coroutine:
         request = exchange_meta_rpc_pb.VersionRequest()
         return self.stubMeta.Version(request).initial_metadata()
+
+    def _initialize_timeout_height_sync_task(self):
+        self._cancel_timeout_height_sync_task()
+        self._timeout_height_sync_task = asyncio.create_task(self._timeout_height_sync_process())
+
+    async def _timeout_height_sync_process(self):
+        while True:
+            await self.sync_timeout_height()
+            await asyncio.sleep(DEFAULT_TIMEOUTHEIGHT_SYNC_INTERVAL)
+
+    def _cancel_timeout_height_sync_task(self):
+        if self._timeout_height_sync_task is not None:
+            self._timeout_height_sync_task.cancel()
+        self._timeout_height_sync_task = None

pyinjective/core/network.py

@@ -244,9 +244,6 @@ def mainnet(cls, node="lb"):
         nodes = [
             "lb",  # us, asia, prod
             "lb_k8s",
-            "sentry0",  # ca, prod
-            "sentry1",  # ca, prod
-            "sentry3",  # us, prod
         ]
         if node not in nodes:
             raise ValueError("Must be one of {}".format(nodes))
@@ -259,22 +256,14 @@ def mainnet(cls, node="lb"):
             grpc_explorer_endpoint = "sentry.explorer.grpc.injective.network:443"
             cookie_assistant = BareMetalLoadBalancedCookieAssistant()
             use_secure_connection = True
-        elif node == "lb_k8s":
+        else:
             lcd_endpoint = "https://k8s.global.mainnet.lcd.injective.network:443"
             tm_websocket_endpoint = "wss://k8s.global.mainnet.tm.injective.network:443/websocket"
             grpc_endpoint = "k8s.global.mainnet.chain.grpc.injective.network:443"
             grpc_exchange_endpoint = "k8s.global.mainnet.exchange.grpc.injective.network:443"
             grpc_explorer_endpoint = "k8s.global.mainnet.explorer.grpc.injective.network:443"
             cookie_assistant = KubernetesLoadBalancedCookieAssistant()
             use_secure_connection = True
-        else:
-            lcd_endpoint = f"http://{node}.injective.network:10337"
-            tm_websocket_endpoint = f"ws://{node}.injective.network:26657/websocket"
-            grpc_endpoint = f"{node}.injective.network:9900"
-            grpc_exchange_endpoint = f"{node}.injective.network:9910"
-            grpc_explorer_endpoint = f"{node}.injective.network:9911"
-            cookie_assistant = DisabledCookieAssistant()
-            use_secure_connection = False
 
         return cls(
             lcd_endpoint=lcd_endpoint,

pyinjective/denoms_mainnet.ini

@@ -565,7 +565,7 @@ min_display_price_tick_size = 0.0001
 min_quantity_tick_size = 0.1
 min_display_quantity_tick_size = 0.1
 
-[0x4b7a550e1760cbd2c6ccb97562c56878083b92e32d07e9e3326945c6e60e6b60]
+[0x64c3a57b693ede854b0a2794ed5c99546925d1fbe74d91a2e3286e4155a00dee]
 description = 'Mainnet Derivative TIA/USDT-30NOV2023 PERP'
 base = 0
 quote = 6

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "injective-py"
-version = "0.9.2"
+version = "0.10dev"
 description = "Injective Python SDK, with Exchange API Client"
 authors = ["Injective Labs <[email protected]>"]
 license = "Apache-2.0"
@@ -22,7 +22,6 @@ include = [
 
 [tool.poetry.dependencies]
 python = "^3.9"
-aiocron = "*"
 aiohttp = "*"
 asyncio = "*"
 bech32 = "*"