Merge pull request #98 from InjectiveLabs/f/add_close_functions

feat: add functions to close chain/exchange channels

Author: achilleas-kal

README.md

@@ -86,6 +86,7 @@ python pyinjective/fetch_metadata.py
 * Add support for multiple subaccounts in StreamTrades and StreamPosition
 * Add K8S endpoint to mainnet network options
 * Add MsgRegisterAsDMM to the composer
+* Add functions to close chain/exchange channels
 * Re-gen ini files
 
 

pyinjective/async_client.py

@@ -108,6 +108,12 @@ def __init__(
             self.exchange_channel
         )
 
+    async def close_exchange_channel(self):
+        await self.exchange_channel.close()
+
+    async def close_chain_channel(self):
+        await self.chain_channel.close()
+
     # default client methods
     async def get_latest_block(self) -> tendermint_query.GetLatestBlockResponse:
         return await self.stubCosmosTendermint.GetLatestBlock(

pyinjective/client.py

@@ -65,41 +65,47 @@ def __init__(
                         credentials = grpc.ssl_channel_credentials(f.read())
 
         # chain stubs
-        chain_channel = (
+        self.chain_channel = (
             grpc.insecure_channel(network.grpc_endpoint)
             if insecure else grpc.secure_channel(network.grpc_endpoint, credentials)
         )
-        self.stubCosmosTendermint = tendermint_query_grpc.ServiceStub(chain_channel)
-        self.stubAuth = auth_query_grpc.QueryStub(chain_channel)
-        self.stubAuthz = authz_query_grpc.QueryStub(chain_channel)
-        self.stubTx = tx_service_grpc.ServiceStub(chain_channel)
+        self.stubCosmosTendermint = tendermint_query_grpc.ServiceStub(self.chain_channel)
+        self.stubAuth = auth_query_grpc.QueryStub(self.chain_channel)
+        self.stubAuthz = authz_query_grpc.QueryStub(self.chain_channel)
+        self.stubTx = tx_service_grpc.ServiceStub(self.chain_channel)
         self.chain_cookie = ""
         self.exchange_cookie = ""
 
         # exchange stubs
-        exchange_channel = (
+        self.exchange_channel = (
             grpc.insecure_channel(network.grpc_exchange_endpoint)
             if insecure else grpc.secure_channel(network.grpc_exchange_endpoint, credentials)
         )
 
-        self.stubMeta = exchange_meta_rpc_grpc.InjectiveMetaRPCStub(exchange_channel)
+        self.stubMeta = exchange_meta_rpc_grpc.InjectiveMetaRPCStub(self.exchange_channel)
         self.stubExchangeAccount = exchange_accounts_rpc_grpc.InjectiveAccountsRPCStub(
-            exchange_channel
+            self.exchange_channel
         )
-        self.stubOracle = oracle_rpc_grpc.InjectiveOracleRPCStub(exchange_channel)
+        self.stubOracle = oracle_rpc_grpc.InjectiveOracleRPCStub(self.exchange_channel)
         self.stubInsurance = insurance_rpc_grpc.InjectiveInsuranceRPCStub(
-            exchange_channel
+            self.exchange_channel
         )
         self.stubSpotExchange = spot_exchange_rpc_grpc.InjectiveSpotExchangeRPCStub(
-            exchange_channel
+            self.exchange_channel
         )
         self.stubDerivativeExchange = (
             derivative_exchange_rpc_grpc.InjectiveDerivativeExchangeRPCStub(
-                exchange_channel
+                self.exchange_channel
             )
         )
-        self.stubExplorer = explorer_rpc_grpc.InjectiveExplorerRPCStub(exchange_channel)
-        self.stubAuction = auction_rpc_grpc.InjectiveAuctionRPCStub(exchange_channel)
+        self.stubExplorer = explorer_rpc_grpc.InjectiveExplorerRPCStub(self.exchange_channel)
+        self.stubAuction = auction_rpc_grpc.InjectiveAuctionRPCStub(self.exchange_channel)
+
+    def close_exchange_channel(self):
+        self.exchange_channel.close()
+
+    def close_chain_channel(self):
+        self.chain_channel.close()
 
     # cookie helper methods
     def get_cookie(self, type):

pyinjective/denoms_mainnet.ini

@@ -304,6 +304,15 @@ min_display_price_tick_size = 0.001
 min_quantity_tick_size = 0.01
 min_display_quantity_tick_size = 0.01
 
+[0xc60c2ba4c11976e4c10ed7c1f5ca789b63282d0b3782ec3d7fc29dec9f43415e]
+description = 'Mainnet Derivative STX/USDT PERP'
+base = 0
+quote = 6
+min_price_tick_size = 1000
+min_display_price_tick_size = 0.001
+min_quantity_tick_size = 0.1
+min_display_quantity_tick_size = 0.1
+
 [WETH]
 peggy_denom = peggy0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2
 decimals = 18