Merge pull request #74 from InjectiveLabs/bug_fixes

bug fixes

Author: achilleas-kal

examples/async/chain_client/20_MsgExec.py

@@ -24,12 +24,15 @@ async def main() -> None:
 
     # prepare tx msg
     market_id = "0xa508cb32923323679f29a032c70342c147c17d0145625922b0ef22e955c844c0"
-    granter = "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku"
     grantee = "inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r"
+
+    granter_inj_address = "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku"
+    granter_address = Address.from_acc_bech32(granter_inj_address)
+    granter_subaccount_id = granter_address.get_subaccount_id(index=0)
     msg0 = composer.MsgCreateSpotLimitOrder(
-        sender=granter,
+        sender=granter_inj_address,
         market_id=market_id,
-        subaccount_id=subaccount_id,
+        subaccount_id=granter_subaccount_id,
         fee_recipient=grantee,
         price=7.523,
         quantity=0.01,

examples/sync/chain_client/20_MsgExec.py

@@ -23,12 +23,15 @@ async def main() -> None:
 
     # prepare tx msg
     market_id = "0xa508cb32923323679f29a032c70342c147c17d0145625922b0ef22e955c844c0"
-    granter = "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku"
+
     grantee = "inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r"
+    granter_inj_address = "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku"
+    granter_address = Address.from_acc_bech32(granter_inj_address)
+    granter_subaccount_id = granter_address.get_subaccount_id(index=0)
     msg0 = composer.MsgCreateSpotLimitOrder(
-        sender=granter,
+        sender=granter_inj_address,
         market_id=market_id,
-        subaccount_id=subaccount_id,
+        subaccount_id=granter_subaccount_id,
         fee_recipient=grantee,
         price=7.523,
         quantity=0.01,

pyinjective/async_client.py

@@ -72,6 +72,7 @@ def __init__(
         )
         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)
 
         # exchange stubs
@@ -381,4 +382,4 @@ async def get_derivative_subaccount_trades(self, subaccount_id: str, **kwargs):
 
     async def get_funding_payments(self, subaccount_id: str, **kwargs):
         req = derivative_exchange_rpc_pb.FundingPaymentsRequest(subaccount_id=subaccount_id, market_id=kwargs.get("market_id"), skip=kwargs.get("skip"), limit=kwargs.get("limit"))
-        return await self.stubDerivativeExchange.FundingPayments(req)
+        return await self.stubDerivativeExchange.FundingPayments(req)

pyinjective/composer.py

@@ -16,6 +16,7 @@
 
 from .constant import Denom
 from .utils import *
+from typing import List
 
 class Composer:
     def __init__(self, network: str):
@@ -188,7 +189,7 @@ def MsgCancelSpotOrder(
     def MsgBatchCreateSpotLimitOrders(
         self,
         sender: str,
-        orders: list
+        orders: List
     ):
         return injective_exchange_tx_pb.MsgBatchCreateSpotLimitOrders(
             sender=sender,
@@ -198,7 +199,7 @@ def MsgBatchCreateSpotLimitOrders(
     def MsgBatchCancelSpotOrders(
         self,
         sender: str,
-        data: list
+        data: List
     ):
         return injective_exchange_tx_pb.MsgBatchCancelSpotOrders(
             sender=sender,
@@ -271,7 +272,7 @@ def MsgCancelDerivativeOrder(
     def MsgBatchCreateDerivativeLimitOrders(
         self,
         sender: str,
-        orders: list
+        orders: List
     ):
         return injective_exchange_tx_pb.MsgBatchCreateDerivativeLimitOrders(
             sender=sender,
@@ -281,7 +282,7 @@ def MsgBatchCreateDerivativeLimitOrders(
     def MsgBatchCancelDerivativeOrders(
         self,
         sender: str,
-        data: list
+        data: List
     ):
         return injective_exchange_tx_pb.MsgBatchCancelDerivativeOrders(
             sender=sender,
@@ -407,9 +408,9 @@ def MsgGrant(
     def MsgExec(
         self,
         grantee: str,
-        msgs: list
+        msgs: List
     ):
-        any_msgs: [any_pb2.Any] = []
+        any_msgs: List[any_pb2.Any] = []
         for msg in msgs:
             any_msg = any_pb2.Any()
             any_msg.Pack(msg, type_url_prefix="")
@@ -424,7 +425,7 @@ def MsgRevoke(
         self,
         granter: str,
         grantee: str,
-        msg_type: list
+        msg_type: str
     ):
         return cosmos_authz_tx_pb.MsgRevoke(
             granter=granter,
@@ -470,6 +471,7 @@ def MsgResponses(data, simulation=False):
 
         return msgs
 
+    @staticmethod
     def UnpackMsgExecResponse(msg_type, data):
         header_map = {
             "MsgCreateSpotLimitOrder": injective_exchange_tx_pb.MsgCreateSpotLimitOrderResponse,