(feat) Added gRPC keepalive options to all gRPC channels

Author: abel

examples/SendToInjective.py

@@ -27,8 +27,9 @@ async def main() -> None:
 
     data = '{"@type": "/injective.exchange.v1beta1.MsgDeposit","sender": "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku","subaccountId": "0xaf79152ac5df276d9a8e1e2e22822f9713474902000000000000000000000000","amount": {"denom": "inj","amount": "1000000000000000000"}}'
 
-    import_peggo = pkg_resources.read_text(pyinjective, 'Peggo_ABI.json')
-    peggo_abi = json.loads(import_peggo)
+    with open("../pyinjective/Peggo_ABI.json") as pego_file:
+        peggo_data = pego_file.read()
+    peggo_abi = json.loads(peggo_data)
 
     peggo_composer.sendToInjective(ethereum_endpoint=ethereum_endpoint, private_key=private_key, token_contract=token_contract,
                  receiver=receiver, amount=amount, maxFeePerGas=maxFeePerGas_Gwei, maxPriorityFeePerGas=maxPriorityFeePerGas_Gwei, data=data, peggo_abi=peggo_abi)

…t/48_WithdrawValidatorCommission_Rewards …WithdrawValidatorCommissionAndRewards.pyexamples/chain_client/48_WithdrawValidatorCommission_Rewards renamed to examples/chain_client/48_WithdrawValidatorCommissionAndRewards.py examples/chain_client/48_WithdrawValidatorCommission_Rewards renamed to examples/chain_client/48_WithdrawValidatorCommissionAndRewards.py

@@ -70,6 +70,13 @@
 DEFAULT_SESSION_RENEWAL_OFFSET = 120  # seconds
 DEFAULT_BLOCK_TIME = 2  # seconds
 
+GRPC_CHANNEL_OPTIONS = [
+    ("grpc.keepalive_time_ms", 45000),
+    ("grpc.keepalive_timeout_ms", 5000),
+    ("grpc.http2.max_pings_without_data", 5),
+    ("grpc.keepalive_permit_without_calls", 1),
+]
+
 
 class AsyncClient:
     def __init__(
@@ -88,9 +95,16 @@ def __init__(
 
         # chain stubs
         self.chain_channel = (
-            grpc.aio.secure_channel(network.grpc_endpoint, credentials)
+            grpc.aio.secure_channel(
+                target=network.grpc_endpoint,
+                credentials=credentials,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
             if (network.use_secure_connection and credentials is not None)
-            else grpc.aio.insecure_channel(network.grpc_endpoint)
+            else grpc.aio.insecure_channel(
+                target=network.grpc_endpoint,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
         )
 
         self.stubCosmosTendermint = tendermint_query_grpc.ServiceStub(
@@ -106,9 +120,16 @@ def __init__(
 
         # exchange stubs
         self.exchange_channel = (
-            grpc.aio.secure_channel(network.grpc_exchange_endpoint, credentials)
+            grpc.aio.secure_channel(
+                target=network.grpc_exchange_endpoint,
+                credentials=credentials,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
             if (network.use_secure_connection and credentials is not None)
-            else grpc.aio.insecure_channel(network.grpc_exchange_endpoint)
+            else grpc.aio.insecure_channel(
+                target=network.grpc_exchange_endpoint,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
         )
         self.stubMeta = exchange_meta_rpc_grpc.InjectiveMetaRPCStub(
             self.exchange_channel
@@ -137,9 +158,16 @@ def __init__(
 
         # explorer stubs
         self.explorer_channel = (
-            grpc.aio.secure_channel(network.grpc_explorer_endpoint, credentials)
+            grpc.aio.secure_channel(
+                target=network.grpc_explorer_endpoint,
+                credentials=credentials,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
             if (network.use_secure_connection and credentials is not None)
-            else grpc.aio.insecure_channel(network.grpc_explorer_endpoint)
+            else grpc.aio.insecure_channel(
+                target=network.grpc_explorer_endpoint,
+                options=GRPC_CHANNEL_OPTIONS,
+            )
         )
         self.stubExplorer = explorer_rpc_grpc.InjectiveExplorerRPCStub(
             self.explorer_channel