[CHORE] Updated proto definitions to Injective Core v1.19.0 and Indexer v1.19.0

Author: aarmoa

Makefile

@@ -26,7 +26,7 @@ clean-all:
 	$(call clean_repos)
 
 clone-injective-indexer:
-	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.18.59 --depth 1 --single-branch
+	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.19.0 --depth 1 --single-branch
 
 clone-all: clone-injective-indexer
 

buf.gen.yaml

@@ -26,7 +26,7 @@ inputs:
   #   tag: v1.0.1-inj
   #   subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
-    tag: v1.19.0-beta
+    tag: v1.19.0
     subdir: proto
   # - git_repo: https://github.com/InjectiveLabs/injective-core
   #   branch: c-655/add_chainlink_data_streams_oracle

examples/exchange_client/oracle_rpc/5_StreamOracleList.py

@@ -0,0 +1,41 @@
+import asyncio
+from typing import Any, Dict
+
+from grpc import RpcError
+
+from pyinjective.core.network import Network
+from pyinjective.indexer_client import IndexerClient
+
+
+async def oracle_list_event_processor(event: Dict[str, Any]):
+    print(event)
+
+
+def stream_error_processor(exception: RpcError):
+    print(f"There was an error listening to oracle list updates ({exception})")
+
+
+def stream_closed_processor():
+    print("The oracle list updates stream has been closed")
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = IndexerClient(network)
+
+    task = asyncio.get_event_loop().create_task(
+        client.listen_oracle_list_updates(
+            callback=oracle_list_event_processor,
+            on_end_callback=stream_closed_processor,
+            on_status_callback=stream_error_processor,
+            oracle_type="provider",
+            symbols=["TIA"],
+        )
+    )
+
+    await asyncio.sleep(delay=60)
+    task.cancel()
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/oracle_rpc/6_StreamPricesByMarkets.py

@@ -0,0 +1,43 @@
+import asyncio
+from typing import Any, Dict
+
+from grpc import RpcError
+
+from pyinjective.core.network import Network
+from pyinjective.indexer_client import IndexerClient
+
+
+async def price_event_processor(event: Dict[str, Any]):
+    print(event)
+
+
+def stream_error_processor(exception: RpcError):
+    print(f"There was an error listening to oracle prices by markets updates ({exception})")
+
+
+def stream_closed_processor():
+    print("The oracle prices by markets updates stream has been closed")
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = IndexerClient(network)
+    market = (await client.all_derivative_markets())[
+        "0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6"
+    ]
+
+    task = asyncio.get_event_loop().create_task(
+        client.listen_oracle_prices_by_markets_updates(
+            market_ids=[market.id],
+            callback=price_event_processor,
+            on_end_callback=stream_closed_processor,
+            on_status_callback=stream_error_processor,
+        )
+    )
+
+    await asyncio.sleep(delay=60)
+    task.cancel()
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

pyinjective/client/indexer/grpc_stream/indexer_grpc_oracle_stream.py

@@ -12,7 +12,7 @@
 
 class IndexerGrpcOracleStream:
     def __init__(self, channel: Channel, cookie_assistant: CookieAssistant):
-        self._stub = self._stub = exchange_oracle_grpc.InjectiveOracleRPCStub(channel)
+        self._stub = exchange_oracle_grpc.InjectiveOracleRPCStub(channel)
         self._assistant = GrpcApiStreamAssistant(cookie_assistant=cookie_assistant)
 
     async def stream_oracle_prices(
@@ -38,6 +38,27 @@ async def stream_oracle_prices(
             on_status_callback=on_status_callback,
         )
 
+    async def stream_oracle_list(
+        self,
+        callback: Callable,
+        on_end_callback: Optional[Callable] = None,
+        on_status_callback: Optional[Callable] = None,
+        oracle_type: Optional[str] = None,
+        symbols: Optional[List[str]] = None,
+    ):
+        request = exchange_oracle_pb.StreamOracleListRequest(
+            oracle_type=oracle_type,
+            symbols=symbols or [],
+        )
+
+        await self._assistant.listen_stream(
+            call=self._stub.StreamOracleList,
+            request=request,
+            callback=callback,
+            on_end_callback=on_end_callback,
+            on_status_callback=on_status_callback,
+        )
+
     async def stream_oracle_prices_by_markets(
         self,
         market_ids: List[str],

pyinjective/indexer_client.py

@@ -663,6 +663,36 @@ async def listen_oracle_prices_updates(
             oracle_type=oracle_type,
         )
 
+    async def listen_oracle_list_updates(
+        self,
+        callback: Callable,
+        on_end_callback: Optional[Callable] = None,
+        on_status_callback: Optional[Callable] = None,
+        oracle_type: Optional[str] = None,
+        symbols: Optional[List[str]] = None,
+    ):
+        await self.oracle_stream_api.stream_oracle_list(
+            callback=callback,
+            on_end_callback=on_end_callback,
+            on_status_callback=on_status_callback,
+            oracle_type=oracle_type,
+            symbols=symbols,
+        )
+
+    async def listen_oracle_prices_by_markets_updates(
+        self,
+        market_ids: List[str],
+        callback: Callable,
+        on_end_callback: Optional[Callable] = None,
+        on_status_callback: Optional[Callable] = None,
+    ):
+        await self.oracle_stream_api.stream_oracle_prices_by_markets(
+            market_ids=market_ids,
+            callback=callback,
+            on_end_callback=on_end_callback,
+            on_status_callback=on_status_callback,
+        )
+
     # endregion
 
     # region portfolio

pyinjective/proto/exchange/injective_oracle_rpc_pb2.py

@@ -35,6 +35,11 @@ def __init__(self, channel):
                 request_serializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesRequest.SerializeToString,
                 response_deserializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesResponse.FromString,
                 _registered_method=True)
+        self.StreamOracleList = channel.unary_stream(
+                '/injective_oracle_rpc.InjectiveOracleRPC/StreamOracleList',
+                request_serializer=exchange_dot_injective__oracle__rpc__pb2.StreamOracleListRequest.SerializeToString,
+                response_deserializer=exchange_dot_injective__oracle__rpc__pb2.StreamOracleListResponse.FromString,
+                _registered_method=True)
         self.StreamPricesByMarkets = channel.unary_stream(
                 '/injective_oracle_rpc.InjectiveOracleRPC/StreamPricesByMarkets',
                 request_serializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesByMarketsRequest.SerializeToString,
@@ -75,6 +80,14 @@ def StreamPrices(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def StreamOracleList(self, request, context):
+        """StreamOracleList streams oracle data updates filtered by oracle type and
+        optionally by symbols.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def StreamPricesByMarkets(self, request, context):
         """StreamPrices streams new price changes markets
         """
@@ -105,6 +118,11 @@ def add_InjectiveOracleRPCServicer_to_server(servicer, server):
                     request_deserializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesRequest.FromString,
                     response_serializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesResponse.SerializeToString,
             ),
+            'StreamOracleList': grpc.unary_stream_rpc_method_handler(
+                    servicer.StreamOracleList,
+                    request_deserializer=exchange_dot_injective__oracle__rpc__pb2.StreamOracleListRequest.FromString,
+                    response_serializer=exchange_dot_injective__oracle__rpc__pb2.StreamOracleListResponse.SerializeToString,
+            ),
             'StreamPricesByMarkets': grpc.unary_stream_rpc_method_handler(
                     servicer.StreamPricesByMarkets,
                     request_deserializer=exchange_dot_injective__oracle__rpc__pb2.StreamPricesByMarketsRequest.FromString,
@@ -230,6 +248,33 @@ def StreamPrices(request,
             metadata,
             _registered_method=True)
 
+    @staticmethod
+    def StreamOracleList(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_oracle_rpc.InjectiveOracleRPC/StreamOracleList',
+            exchange_dot_injective__oracle__rpc__pb2.StreamOracleListRequest.SerializeToString,
+            exchange_dot_injective__oracle__rpc__pb2.StreamOracleListResponse.FromString,
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
+
     @staticmethod
     def StreamPricesByMarkets(request,
             target,