chore(exchange): re-gen API

Author: hmoragrega

pyinjective/async_client.py

@@ -991,3 +991,14 @@ async def get_binary_options_market(self, market_id: str):
     async def get_account_portfolio(self, account_address: str):
         req = portfolio_rpc_pb.AccountPortfolioRequest(account_address=account_address)
         return await self.stubPortfolio.AccountPortfolio(req)
+
+    async def stream_account_portfolio(
+            self, account_address: str = None, subaccount_id: str = None, portfolio_type: str = None
+    ):
+        req = portfolio_rpc_pb.StreamAccountPortfolioRequest(
+            account_address=account_address,
+            subaccount_id=subaccount_id,
+            type=portfolio_type
+        )
+        metadata = await self.load_cookie(type="exchange")
+        return self.stubPortfolio.StreamAccountPortfolio.__call__(req, metadata=metadata)

pyinjective/proto/exchange/injective_accounts_rpc_pb2.py

@@ -6,7 +6,7 @@
 
 
 class InjectiveAccountsRPCStub(object):
-    """InjectiveAccountsRPC defines gRPC API of Exchange Accounts provider.
+    """InjectiveAccountsRPC defines API of Exchange Accounts provider.
     """
 
     def __init__(self, channel):
@@ -37,8 +37,8 @@ def __init__(self, channel):
                 )
         self.SubaccountBalanceEndpoint = channel.unary_unary(
                 '/injective_accounts_rpc.InjectiveAccountsRPC/SubaccountBalanceEndpoint',
-                request_serializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceRequest.SerializeToString,
-                response_deserializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceResponse.FromString,
+                request_serializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointRequest.SerializeToString,
+                response_deserializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointResponse.FromString,
                 )
         self.StreamSubaccountBalance = channel.unary_stream(
                 '/injective_accounts_rpc.InjectiveAccountsRPC/StreamSubaccountBalance',
@@ -63,7 +63,7 @@ def __init__(self, channel):
 
 
 class InjectiveAccountsRPCServicer(object):
-    """InjectiveAccountsRPC defines gRPC API of Exchange Accounts provider.
+    """InjectiveAccountsRPC defines API of Exchange Accounts provider.
     """
 
     def Portfolio(self, request, context):
@@ -156,8 +156,8 @@ def add_InjectiveAccountsRPCServicer_to_server(servicer, server):
             ),
             'SubaccountBalanceEndpoint': grpc.unary_unary_rpc_method_handler(
                     servicer.SubaccountBalanceEndpoint,
-                    request_deserializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceRequest.FromString,
-                    response_serializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceResponse.SerializeToString,
+                    request_deserializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointRequest.FromString,
+                    response_serializer=exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointResponse.SerializeToString,
             ),
             'StreamSubaccountBalance': grpc.unary_stream_rpc_method_handler(
                     servicer.StreamSubaccountBalance,
@@ -187,7 +187,7 @@ def add_InjectiveAccountsRPCServicer_to_server(servicer, server):
 
  # This class is part of an EXPERIMENTAL API.
 class InjectiveAccountsRPC(object):
-    """InjectiveAccountsRPC defines gRPC API of Exchange Accounts provider.
+    """InjectiveAccountsRPC defines API of Exchange Accounts provider.
     """
 
     @staticmethod
@@ -270,8 +270,8 @@ def SubaccountBalanceEndpoint(request,
             timeout=None,
             metadata=None):
         return grpc.experimental.unary_unary(request, target, '/injective_accounts_rpc.InjectiveAccountsRPC/SubaccountBalanceEndpoint',
-            exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceRequest.SerializeToString,
-            exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceResponse.FromString,
+            exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointRequest.SerializeToString,
+            exchange_dot_injective__accounts__rpc__pb2.SubaccountBalanceEndpointResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 

pyinjective/proto/exchange/injective_accounts_rpc_pb2_grpc.py

@@ -17,8 +17,8 @@ def __init__(self, channel):
         """
         self.AuctionEndpoint = channel.unary_unary(
                 '/injective_auction_rpc.InjectiveAuctionRPC/AuctionEndpoint',
-                request_serializer=exchange_dot_injective__auction__rpc__pb2.AuctionRequest.SerializeToString,
-                response_deserializer=exchange_dot_injective__auction__rpc__pb2.AuctionResponse.FromString,
+                request_serializer=exchange_dot_injective__auction__rpc__pb2.AuctionEndpointRequest.SerializeToString,
+                response_deserializer=exchange_dot_injective__auction__rpc__pb2.AuctionEndpointResponse.FromString,
                 )
         self.Auctions = channel.unary_unary(
                 '/injective_auction_rpc.InjectiveAuctionRPC/Auctions',
@@ -62,8 +62,8 @@ def add_InjectiveAuctionRPCServicer_to_server(servicer, server):
     rpc_method_handlers = {
             'AuctionEndpoint': grpc.unary_unary_rpc_method_handler(
                     servicer.AuctionEndpoint,
-                    request_deserializer=exchange_dot_injective__auction__rpc__pb2.AuctionRequest.FromString,
-                    response_serializer=exchange_dot_injective__auction__rpc__pb2.AuctionResponse.SerializeToString,
+                    request_deserializer=exchange_dot_injective__auction__rpc__pb2.AuctionEndpointRequest.FromString,
+                    response_serializer=exchange_dot_injective__auction__rpc__pb2.AuctionEndpointResponse.SerializeToString,
             ),
             'Auctions': grpc.unary_unary_rpc_method_handler(
                     servicer.Auctions,
@@ -98,8 +98,8 @@ def AuctionEndpoint(request,
             timeout=None,
             metadata=None):
         return grpc.experimental.unary_unary(request, target, '/injective_auction_rpc.InjectiveAuctionRPC/AuctionEndpoint',
-            exchange_dot_injective__auction__rpc__pb2.AuctionRequest.SerializeToString,
-            exchange_dot_injective__auction__rpc__pb2.AuctionResponse.FromString,
+            exchange_dot_injective__auction__rpc__pb2.AuctionEndpointRequest.SerializeToString,
+            exchange_dot_injective__auction__rpc__pb2.AuctionEndpointResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 

pyinjective/proto/exchange/injective_auction_rpc_pb2.py

@@ -233,7 +233,7 @@ def StreamOrderbookUpdate(self, request, context):
         raise NotImplementedError('Method not implemented!')
 
     def Orders(self, request, context):
-        """DerivativeLimitOrders gets the limit orders of a Derivative Market.
+        """DerivativeLimitOrders gets the limit orders of a derivative Market.
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')