go

Author: guibescos

Cargo.lock

@@ -35,7 +35,7 @@ num-traits = { version = "0.2" }
 num_cpus = "1.13.1"
 once_cell = "1.12.0"
 ouroboros = "0.15.0"
-pyth-oracle = { path = "/code/pyth-network/pyth-client/program/rust", features = ["library"] }
+pyth-oracle = { git = "https://github.com/pyth-network/pyth-client.git" ,branch="feat/publisher-caps" , features = ["library"] }
 pythnet-sdk = { git = "https://github.com/pyth-network/pyth-crosschain", version = "1.13.6", rev = "e670f57f89b05398ca352e4accb1e32724a8e1b4" }
 rand = "0.7.0"
 rayon = "1.5.3"

runtime/Cargo.toml

@@ -12,8 +12,7 @@ use {
         pubkey::Pubkey,
     },
     std::{
-        env::{self, VarError},
-        str::FromStr,
+        borrow::Borrow, env::{self, VarError}, str::FromStr
     },
 };
 
@@ -405,5 +404,16 @@ pub fn update_v2(bank: &Bank) -> std::result::Result<(), AccumulatorUpdateErrorV
         }
     }
 
+    let accounts = bank
+    .get_program_accounts(&ORACLE_PUBKEY, &ScanConfig::new(true))
+    .map_err(AccumulatorUpdateErrorV1::GetProgramAccounts)?;
+
+    let account_datas = accounts
+        .iter()
+        .map(|(_, account)| account.data().borrow())
+        .collect::<Vec<_>>();
+
+    let message = pyth_oracle::validator::compute_publisher_caps(account_datas, bank.clock().unix_timestamp);
+
     update_v1(bank, &v2_messages, any_v1_aggregations)
 }