F/update indexer release

Pipfile

@@ -4,8 +4,8 @@ verify_ssl = true
 name = "pypi"
 
 [packages]
-protobuf = "==3.19.1"
-grpcio-tools = "==1.42.0"
+protobuf = "*"
+grpcio-tools = "*"
 grpcio = "*"
 asyncio = "*"
 aiohttp = "*"

examples/exchange_client/derivative_exchange_rpc/18_Orderbooks.py

@@ -13,7 +13,7 @@ async def main() -> None:
         "0x90e662193fa29a3a7e6c07be4407c94833e762d9ee82136a2cc712d6b87d7de3",
         "0xd5e4b12b19ecf176e4e14b42944731c27677819d2ed93be4104ad7025529c7ff"
     ]
-    markets = await client.get_derivative_orderbooks(market_ids=market_ids)
+    markets = await client.get_derivative_orderbooksV2(market_ids=market_ids)
     print(markets)
 
 if __name__ == '__main__':

examples/exchange_client/derivative_exchange_rpc/4_Orderbook.py

@@ -9,7 +9,7 @@ async def main() -> None:
     network = Network.testnet()
     client = AsyncClient(network, insecure=False)
     market_id = "0x90e662193fa29a3a7e6c07be4407c94833e762d9ee82136a2cc712d6b87d7de3"
-    market = await client.get_derivative_orderbook(market_id=market_id)
+    market = await client.get_derivative_orderbookV2(market_id=market_id)
     print(market)
 
 if __name__ == '__main__':

examples/exchange_client/spot_exchange_rpc/14_Orderbooks.py

@@ -11,7 +11,7 @@ async def main() -> None:
         "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
         "0x7a57e705bb4e09c88aecfc295569481dbf2fe1d5efe364651fbe72385938e9b0"
     ]
-    orderbooks = await client.get_spot_orderbooks(market_ids=market_ids)
+    orderbooks = await client.get_spot_orderbooksV2(market_ids=market_ids)
     print(orderbooks)
 
 if __name__ == '__main__':

examples/exchange_client/spot_exchange_rpc/4_Orderbook.py

@@ -8,7 +8,7 @@ async def main() -> None:
     network = Network.testnet()
     client = AsyncClient(network, insecure=False)
     market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
-    orderbook = await client.get_spot_orderbook(market_id=market_id)
+    orderbook = await client.get_spot_orderbookV2(market_id=market_id)
     print(orderbook)
 
 if __name__ == '__main__':

pyinjective/async_client.py

@@ -632,14 +632,6 @@ async def stream_spot_markets(self, **kwargs):
         metadata = await self.load_cookie(type="exchange")
         return self.stubSpotExchange.StreamMarkets.__call__(req, metadata=metadata)
 
-    async def get_spot_orderbook(self, market_id: str):
-        req = spot_exchange_rpc_pb.OrderbookRequest(market_id=market_id)
-        return await self.stubSpotExchange.Orderbook(req)
-
-    async def get_spot_orderbooks(self, market_ids: List):
-        req = spot_exchange_rpc_pb.OrderbooksRequest(market_ids=market_ids)
-        return await self.stubSpotExchange.Orderbooks(req)
-
     async def get_spot_orderbookV2(self, market_id: str):
         req = spot_exchange_rpc_pb.OrderbookV2Request(market_id=market_id)
         return await self.stubSpotExchange.OrderbookV2(req)
@@ -796,13 +788,9 @@ async def stream_derivative_markets(self, **kwargs):
         metadata = await self.load_cookie(type="exchange")
         return self.stubDerivativeExchange.StreamMarket.__call__(req, metadata=metadata)
 
-    async def get_derivative_orderbook(self, market_id: str):
-        req = derivative_exchange_rpc_pb.OrderbookRequest(market_id=market_id)
-        return await self.stubDerivativeExchange.Orderbook(req)
-
-    async def get_derivative_orderbooks(self, market_ids: List):
-        req = derivative_exchange_rpc_pb.OrderbooksRequest(market_ids=market_ids)
-        return await self.stubDerivativeExchange.Orderbooks(req)
+    async def get_derivative_orderbookV2(self, market_id: str):
+        req = derivative_exchange_rpc_pb.OrderbookV2Request(market_id=market_id)
+        return await self.stubDerivativeExchange.OrderbookV2(req)
 
     async def get_derivative_orderbooksV2(self, market_ids: List):
         req = derivative_exchange_rpc_pb.OrderbooksV2Request(market_ids=market_ids)

pyinjective/proto/exchange/injective_derivative_exchange_rpc_pb2_grpc.py

@@ -41,31 +41,16 @@ def __init__(self, channel):
                 request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.BinaryOptionsMarketRequest.SerializeToString,
                 response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.BinaryOptionsMarketResponse.FromString,
                 )
-        self.Orderbook = channel.unary_unary(
-                '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/Orderbook',
-                request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookRequest.SerializeToString,
-                response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookResponse.FromString,
-                )
         self.OrderbookV2 = channel.unary_unary(
                 '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/OrderbookV2',
                 request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookV2Request.SerializeToString,
                 response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookV2Response.FromString,
                 )
-        self.Orderbooks = channel.unary_unary(
-                '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/Orderbooks',
-                request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksRequest.SerializeToString,
-                response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksResponse.FromString,
-                )
         self.OrderbooksV2 = channel.unary_unary(
                 '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/OrderbooksV2',
                 request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksV2Request.SerializeToString,
                 response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksV2Response.FromString,
                 )
-        self.StreamOrderbook = channel.unary_stream(
-                '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/StreamOrderbook',
-                request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookRequest.SerializeToString,
-                response_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookResponse.FromString,
-                )
         self.StreamOrderbookV2 = channel.unary_stream(
                 '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/StreamOrderbookV2',
                 request_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookV2Request.SerializeToString,
@@ -183,41 +168,20 @@ def BinaryOptionsMarket(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def Orderbook(self, request, context):
-        """Orderbook gets the Orderbook of a Derivative Market
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
     def OrderbookV2(self, request, context):
         """Orderbook gets the Orderbook of a Derivative Market
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def Orderbooks(self, request, context):
-        """Orderbooks gets the Orderbooks of requested derivative markets
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
     def OrderbooksV2(self, request, context):
         """Orderbooks gets the Orderbooks of requested derivative markets
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
-    def StreamOrderbook(self, request, context):
-        """Stream live snapshot updates of selected derivative market orderbook
-        """
-        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
-        context.set_details('Method not implemented!')
-        raise NotImplementedError('Method not implemented!')
-
     def StreamOrderbookV2(self, request, context):
         """Stream live snapshot updates of selected derivative market orderbook
         """
@@ -352,31 +316,16 @@ def add_InjectiveDerivativeExchangeRPCServicer_to_server(servicer, server):
                     request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.BinaryOptionsMarketRequest.FromString,
                     response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.BinaryOptionsMarketResponse.SerializeToString,
             ),
-            'Orderbook': grpc.unary_unary_rpc_method_handler(
-                    servicer.Orderbook,
-                    request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookRequest.FromString,
-                    response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookResponse.SerializeToString,
-            ),
             'OrderbookV2': grpc.unary_unary_rpc_method_handler(
                     servicer.OrderbookV2,
                     request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookV2Request.FromString,
                     response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookV2Response.SerializeToString,
             ),
-            'Orderbooks': grpc.unary_unary_rpc_method_handler(
-                    servicer.Orderbooks,
-                    request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksRequest.FromString,
-                    response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksResponse.SerializeToString,
-            ),
             'OrderbooksV2': grpc.unary_unary_rpc_method_handler(
                     servicer.OrderbooksV2,
                     request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksV2Request.FromString,
                     response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksV2Response.SerializeToString,
             ),
-            'StreamOrderbook': grpc.unary_stream_rpc_method_handler(
-                    servicer.StreamOrderbook,
-                    request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookRequest.FromString,
-                    response_serializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookResponse.SerializeToString,
-            ),
             'StreamOrderbookV2': grpc.unary_stream_rpc_method_handler(
                     servicer.StreamOrderbookV2,
                     request_deserializer=exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookV2Request.FromString,
@@ -549,23 +498,6 @@ def BinaryOptionsMarket(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
-    @staticmethod
-    def Orderbook(request,
-            target,
-            options=(),
-            channel_credentials=None,
-            call_credentials=None,
-            insecure=False,
-            compression=None,
-            wait_for_ready=None,
-            timeout=None,
-            metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/Orderbook',
-            exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookRequest.SerializeToString,
-            exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbookResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
     @staticmethod
     def OrderbookV2(request,
             target,
@@ -583,23 +515,6 @@ def OrderbookV2(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
-    @staticmethod
-    def Orderbooks(request,
-            target,
-            options=(),
-            channel_credentials=None,
-            call_credentials=None,
-            insecure=False,
-            compression=None,
-            wait_for_ready=None,
-            timeout=None,
-            metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/Orderbooks',
-            exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksRequest.SerializeToString,
-            exchange_dot_injective__derivative__exchange__rpc__pb2.OrderbooksResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
     @staticmethod
     def OrderbooksV2(request,
             target,
@@ -617,23 +532,6 @@ def OrderbooksV2(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
-    @staticmethod
-    def StreamOrderbook(request,
-            target,
-            options=(),
-            channel_credentials=None,
-            call_credentials=None,
-            insecure=False,
-            compression=None,
-            wait_for_ready=None,
-            timeout=None,
-            metadata=None):
-        return grpc.experimental.unary_stream(request, target, '/injective_derivative_exchange_rpc.InjectiveDerivativeExchangeRPC/StreamOrderbook',
-            exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookRequest.SerializeToString,
-            exchange_dot_injective__derivative__exchange__rpc__pb2.StreamOrderbookResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
-
     @staticmethod
     def StreamOrderbookV2(request,
             target,