[C-655] Updated proto definitions to chain v1.18.0 and indexer v1.17.81. Includes support for the new Chainlink oracle messages.

Author: aarmoa

.gitignore

@@ -140,9 +140,8 @@ dmypy.json
 cython_debug/
 
 .idea
-
 .chain_cookie
 .exchange_cookie
-
 .flakeheaven_cache
 .vscode/settings.json
+.python-version

Makefile

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

buf.gen.yaml

@@ -25,10 +25,10 @@ inputs:
   - git_repo: https://github.com/InjectiveLabs/hyperlane-cosmos
     tag: v1.0.1-inj
     subdir: proto
-  # - git_repo: https://github.com/InjectiveLabs/injective-core
-  #   tag: v1.17.0
-  #   subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
-    branch: c-655/add_chainlink_data_streams_oracle
+    tag: v1.18.0-alpha.3
     subdir: proto
+  # - git_repo: https://github.com/InjectiveLabs/injective-core
+  #   branch: c-655/add_chainlink_data_streams_oracle
+  #   subdir: proto
   - directory: proto

pyinjective/async_client.py

@@ -1295,9 +1295,13 @@ async def fetch_oracle_price(
         )
 
     async def fetch_oracle_list(
-        self, symbol: Optional[str] = None, oracle_type: Optional[str] = None
+        self, 
+        symbol: Optional[str] = None, 
+        oracle_type: Optional[str] = None,
+        per_page: Optional[int] = None,
+        token: Optional[str] = None,
     ) -> Dict[str, Any]:
-        return await self.indexer_client.fetch_oracle_list(symbol=symbol, oracle_type=oracle_type)
+        return await self.indexer_client.fetch_oracle_list(symbol=symbol, oracle_type=oracle_type, per_page=per_page, token=token)
 
     # InsuranceRPC
 

pyinjective/client/indexer/grpc/indexer_grpc_oracle_api.py

@@ -16,11 +16,17 @@ def __init__(self, channel: Channel, cookie_assistant: CookieAssistant):
         self._assistant = GrpcApiRequestAssistant(cookie_assistant=cookie_assistant)
 
     async def fetch_oracle_list(
-        self, symbol: Optional[str] = None, oracle_type: Optional[str] = None
+        self, 
+        symbol: Optional[str] = None, 
+        oracle_type: Optional[str] = None,
+        per_page: Optional[int] = None,
+        token: Optional[str] = None,
     ) -> Dict[str, Any]:
         request = exchange_oracle_pb.OracleListRequest(
             symbol=symbol,
             oracle_type=oracle_type,
+            per_page=per_page,
+            token=token,
         )
         response = await self._execute_call(call=self._stub.OracleList, request=request)
 

pyinjective/indexer_client.py

@@ -660,9 +660,13 @@ async def fetch_oracle_price_v2(self, filters: List[exchange_oracle_pb.PricePayl
         return await self.oracle_api.fetch_oracle_price_v2(filters=filters)
 
     async def fetch_oracle_list(
-        self, symbol: Optional[str] = None, oracle_type: Optional[str] = None
+        self, 
+        symbol: Optional[str] = None, 
+        oracle_type: Optional[str] = None,
+        per_page: Optional[int] = None,
+        token: Optional[str] = None,
     ) -> Dict[str, Any]:
-        return await self.oracle_api.fetch_oracle_list(symbol=symbol, oracle_type=oracle_type)
+        return await self.oracle_api.fetch_oracle_list(symbol=symbol, oracle_type=oracle_type, per_page=per_page, token=token)
 
     async def listen_oracle_prices_updates(
         self,