use EmpiricBaseClient as base class

open_oracle_client/client.py

@@ -0,0 +1,71 @@
+import json
+from starknet_py.contract import Contract
+
+from client_tools import fetch_coinbase, fetch_okx, prepare_contract_call_args
+from empiric.core.base_client import EmpiricBaseClient
+from empiric.core.types import HEX_STR
+
+
+class OpenOracleClient(EmpiricBaseClient):
+ def __init__(
+ self,
+ open_oracle_address: HEX_STR,
+ account_contract_address: HEX_STR,
+ account_private_key: int,
+ ):
+ super().__init__(
+ account_private_key=account_private_key,
+ account_contract_address=account_contract_address,
+ )
+ # OpenOracle contract
+ open_oracle_abi = open("build/OpenOraclePublisher_abi.json", "r")
+ self.open_oracle_contract = Contract(
+ address=open_oracle_address,
+ abi=json.load(open_oracle_abi),
+ client=self.client,
+ )
+ open_oracle_abi.close()
+
+ async def _fetch_contracts(self):
+ pass
+
+ async def publish_open_oracle_entries_okx(
+ self, assets=["btc", "eth", "dai"]
+ ) -> hex:
+ okx_oracle_data = fetch_okx(assets=assets)
+ calls = [
+ self.open_oracle_contract.functions["publish_entry"].prepare(
+ prepare_contract_call_args(*oracle_data)
+ )
+ for oracle_data in okx_oracle_data
+ ]
+
+ return await self.send_transactions(calls=calls)
+
+ async def publish_open_oracle_entries_coinbase(
+ self, assets=["btc", "eth", "dai"]
+ ) -> hex:
+ coinbase_oracle_data = fetch_coinbase(assets=assets)
+ calls = [
+ self.open_oracle_contract.functions["publish_entry"].prepare(
+ prepare_contract_call_args(*oracle_data)
+ )
+ for oracle_data in coinbase_oracle_data
+ ]
+
+ return await self.send_transactions(calls=calls)
+
+ async def publish_open_oracle_entries_all_publishers(
+ self, assets=["btc", "eth", "dai"]
+ ) -> hex:
+ okx_oracle_data = fetch_okx(assets=assets)
+ coinbase_oracle_data = fetch_coinbase(assets=assets)
+ all_data = okx_oracle_data + coinbase_oracle_data
+
+ calls = [
+ self.open_oracle_contract.functions["publish_entry"].prepare(
+ prepare_contract_call_args(*oracle_data)
+ )
+ for oracle_data in all_data
+ ]
+ return await self.send_transactions(calls=calls)

client/client_tools.py → open_oracle_client/client_tools.py

@@ -126,5 +126,5 @@ def prepare_contract_call_args(oracle_message_hex: str, oracle_signature_hex: st
  'ticker_len_little': ticker_len_little_endian, 'ticker_name_little': ticker_little_endian,
  'r_low': signature_r_uint256[0], 'r_high': signature_r_uint256[1],
  's_low': signature_s_uint256[0], 's_high': signature_s_uint256[1],
- 'v': signature_v_big, 'eth_address': eth_address_big}
+ 'v': signature_v_big, 'public_key': eth_address_big}
  return contract_call_args

open_oracle_client/main.py

@@ -0,0 +1,29 @@
+import asyncio
+from client import OpenOracleClient
+import os
+from dotenv import load_dotenv
+
+
+load_dotenv("open_oracle_client/.env")
+account_private_key = int(os.getenv("ACCOUNT_PRIVATE_KEY"))
+account_contract_address = os.getenv("ACCOUNT_CONTRACT_ADDRESS")
+
+
+OPEN_ORACLE_ADDRESS = (
+ "0x03f0c6d6c792e8a1febc289e023de63824391a0056dd43a154bec792fec1ddff"
+)
+
+
+async def main():
+ c = OpenOracleClient(
+ open_oracle_address=OPEN_ORACLE_ADDRESS,
+ account_contract_address=account_contract_address,
+ account_private_key=account_private_key,
+ )
+
+ await c.publish_open_oracle_entries_all_publishers(assets=["btc", "eth"])
+
+
+if __name__ == "__main__":
+
+ asyncio.run(main())

requirements.txt

@@ -1,4 +1,4 @@
 cairo-lang
 cairo-nile
 starknet.py
-openzeppelin-cairo-contracts
+empiric-network