Support multi subaccount ids for streamPositions and spot/deriv streamTrades API (#91)

* update proto, grpc files

* added: subaccount ids param to sync, async clients

* chore: regen

Author: vinhphuctadang

pyinjective/async_client.py

@@ -407,6 +407,7 @@ async def stream_spot_trades(self, **kwargs):
             execution_side=kwargs.get("execution_side"),
             direction=kwargs.get("direction"),
             subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids"),
             skip=kwargs.get("skip"),
             limit=kwargs.get("limit"),
         )
@@ -492,6 +493,7 @@ async def stream_derivative_trades(self, **kwargs):
             market_id=kwargs.get("market_id"),
             market_ids=kwargs.get("market_ids"),
             subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids"),
             execution_side=kwargs.get("execution_side"),
             direction=kwargs.get("direction"),
             skip=kwargs.get("skip"),
@@ -509,7 +511,8 @@ async def stream_derivative_positions(self, **kwargs):
         req = derivative_exchange_rpc_pb.StreamPositionsRequest(
             market_id=kwargs.get("market_id"), 
             market_ids=kwargs.get("market_ids"),
-            subaccount_id=kwargs.get("subaccount_id")
+            subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids")
         )
         return self.stubDerivativeExchange.StreamPositions(req)
 

pyinjective/client.py

@@ -447,6 +447,7 @@ def stream_spot_trades(self, **kwargs):
             execution_side=kwargs.get("execution_side"),
             direction=kwargs.get("direction"),
             subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids"),
             skip=kwargs.get("skip"),
             limit=kwargs.get("limit"),
         )
@@ -547,6 +548,7 @@ def stream_derivative_trades(self, **kwargs):
             market_id=kwargs.get("market_id"),
             market_ids=kwargs.get("market_ids"),
             subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids"),
             execution_side=kwargs.get("execution_side"),
             direction=kwargs.get("direction"),
             skip=kwargs.get("skip"),
@@ -567,7 +569,8 @@ def stream_derivative_positions(self, **kwargs):
         req = derivative_exchange_rpc_pb.StreamPositionsRequest(
             market_id=kwargs.get("market_id"),
             market_ids=kwargs.get("market_ids"),
-            subaccount_id=kwargs.get("subaccount_id")
+            subaccount_id=kwargs.get("subaccount_id"),
+            subaccount_ids=kwargs.get("subaccount_ids")
         )
         metadata = self.get_cookie(type="exchange")
         res = self.stubDerivativeExchange.StreamPositions(req, metadata=metadata)