"chore: added new chain rpc endpoints"

Author: enigmarikki

pyinjective/async_client.py

@@ -613,6 +613,9 @@ async def fetch_spot_orderbook(
             pagination=pagination,
         )
 
+    async def fetch_full_spot_orderbook(self, market_id: str) -> Dict[str, any]:
+        return await self.chain_exchange_api.fetch_l3_spot_orderbook(market_id=market_id)
+
     async def fetch_trader_spot_orders(
         self,
         market_id: str,
@@ -693,6 +696,12 @@ async def fetch_derivative_orderbook(
             pagination=pagination,
         )
 
+    async def fetch_full_derivative_orderbook(
+        self,
+        market_id: str,
+    ) -> Dict[str, Any]:
+        return await self.chain_exchange_api.fetch_l3_derivative_orderbook(market_id=market_id)
+
     async def fetch_trader_derivative_orders(
         self,
         market_id: str,
@@ -1038,49 +1047,8 @@ async def abci_query(
     # OracleRPC
     # InsuranceRPC
     # SpotRPC
-    async def fetch_spot_market(self, market_id: str) -> Dict[str, Any]:
-        return await self.chain_exchange_api.fetch_market(market_id=market_id)
 
-    async def fetch_spot_markets(
-        self,
-        market_statuses: Optional[List[str]] = None,
-        base_denom: Optional[str] = None,
-        quote_denom: Optional[str] = None,
-    ) -> Dict[str, Any]:
-        return await self.chain_exchange_api.fetch_markets(
-            market_statuses=market_statuses, base_denom=base_denom, quote_denom=quote_denom
-        )
-
-    async def fetch_spot_orderbook(self, market_id: str) -> Dict[str, Any]:
-        return await self.chain_exchange_api.fetch_orderbook_v2(market_id=market_id)
-
-    # DerivativeRPC
-    ####MASSIVE TODO : NEED TO WRITE A LIQUIDABLE POSITIONS WATCHER#######
-    # async def get_derivative_liquidable_positions(self, **kwargs):
-    #    """
-    #    This method is deprecated and will be removed soon. Please use `fetch_derivative_liquidable_positions` instead
-    #    """
-    #    warn(
-    #        "This method is deprecated. Use fetch_derivative_liquidable_positions instead",
-    #        DeprecationWarning,
-    #        stacklevel=2,
-    #    )
-    #    req = derivative_exchange_rpc_pb.LiquidablePositionsRequest(
-    #        market_id=kwargs.get("market_id"),
-    #        skip=kwargs.get("skip"),
-    #        limit=kwargs.get("limit"),
-    #    )
-    #    return await self.stubDerivativeExchange.LiquidablePositions(req)
-
-    # async def fetch_derivative_liquidable_positions(
-    #    self,
-    #    market_id: Optional[str] = None,
-    #    pagination: Optional[PaginationOption] = None,
-    # ) -> Dict[str, Any]:
-    #    return await self.exchange_derivative_api.fetch_liquidable_positions(
-    #        market_id=market_id,
-    #        pagination=pagination,
-    #    )
+    # TODO (Hrishikesh) : add liquidable positions
     # PortfolioRPC
     async def chain_stream(
         self,

pyinjective/client/chain/grpc/chain_grpc_exchange_api.py

@@ -118,6 +118,11 @@ async def fetch_spot_market(self, market_id: str) -> Dict[str, Any]:
 
         return response
 
+    async def fetch_l3_spot_orderbook(self, market_id: str) -> Dict[str, Any]:
+        request = exchange_query_pb.QueryFullSpotOrderbookRequest(market_id=market_id)
+        response = await self._execute_call(call=self._stub.L3SpotOrderBook, request=request)
+        return response
+
     async def fetch_full_spot_markets(
         self,
         status: Optional[str] = None,
@@ -275,6 +280,11 @@ async def fetch_derivative_orderbook(
 
         return response
 
+    async def fetch_l3_derivative_orderbook(self, market_id: str) -> Dict[str, Any]:
+        request = exchange_query_pb.QueryFullDerivativeOrderbookRequest(market_id=market_id)
+        response = await self._execute_call(call=self._stub.L3DerivativeOrderBook, request=request)
+        return response
+
     async def fetch_trader_derivative_orders(
         self,
         market_id: str,

pyinjective/composer.py

@@ -300,6 +300,7 @@ def spot_order(
             trigger_price=chain_trigger_price,
         )
 
+    # TODO (Hrishikesh): I noticed that this is very inconsistent
     def calculate_margin(
         self, quantity: Decimal, price: Decimal, leverage: Decimal, is_reduce_only: bool = False
     ) -> Decimal:

pyinjective/proto/amino/amino_pb2.py

@@ -1,4 +1,3 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
-

pyinjective/proto/amino/amino_pb2_grpc.py

@@ -1,4 +1,3 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
-

pyinjective/proto/capability/v1/capability_pb2.py

@@ -1,4 +1,3 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
-