fmt

Author: merolish

src/agent/state/exporter.rs

@@ -1,65 +1,36 @@
 use {
-    super::{
-        local::PriceInfo,
-        oracle::PricePublishingMetadata,
-        transactions::Transactions,
-        State,
-    },
+    super::{State, local::PriceInfo, oracle::PricePublishingMetadata, transactions::Transactions},
     crate::agent::{
         services::exporter::NetworkState,
         solana::network::Network,
-        state::{
-            global::GlobalStore,
-            keypairs::Keypairs,
-            local::LocalStore,
-        },
-    },
-    anyhow::{
-        anyhow,
-        bail,
-        Context,
-        Result,
+        state::{global::GlobalStore, keypairs::Keypairs, local::LocalStore},
     },
+    anyhow::{Context, Result, anyhow, bail},
     bincode::Options,
-    bytemuck::{
-        bytes_of,
-        cast_slice,
-    },
+    bytemuck::{bytes_of, cast_slice},
     chrono::Utc,
     futures_util::future::join_all,
     pyth_price_store::accounts::buffer::BufferedPrice,
     pyth_sdk::Identifier,
     pyth_sdk_solana::state::PriceStatus,
     serde::Serialize,
-    solana_client::{
-        nonblocking::rpc_client::RpcClient,
-        rpc_config::RpcSendTransactionConfig,
-    },
+    solana_client::{nonblocking::rpc_client::RpcClient, rpc_config::RpcSendTransactionConfig},
     solana_pubkey,
     solana_sdk::{
         compute_budget::ComputeBudgetInstruction,
-        instruction::{
-            AccountMeta,
-            Instruction,
-        },
+        instruction::{AccountMeta, Instruction},
         pubkey::Pubkey,
         signature::Keypair,
         signer::Signer,
         sysvar::clock,
         transaction::Transaction,
     },
     std::{
-        collections::{
-            BTreeMap,
-            HashMap,
-        },
+        collections::{BTreeMap, HashMap},
         sync::Arc,
         time::Duration,
     },
-    tokio::sync::{
-        watch,
-        RwLock,
-    },
+    tokio::sync::{RwLock, watch},
     tracing::instrument,
 };
 
@@ -69,12 +40,12 @@ const UPDATE_PRICE_NO_FAIL_ON_ERROR: i32 = 13;
 #[repr(C)]
 #[derive(Serialize, PartialEq, Debug, Clone)]
 struct UpdPriceCmd {
-    version:  u32,
-    cmd:      i32,
-    status:   PriceStatus,
-    unused_:  u32,
-    price:    i64,
-    conf:     u64,
+    version: u32,
+    cmd: i32,
+    status: PriceStatus,
+    unused_: u32,
+    price: i64,
+    conf: u64,
     pub_slot: u64,
 }
 
@@ -142,9 +113,9 @@ impl<'a> From<&'a State> for &'a ExporterState {
 
 #[derive(Debug, Clone)]
 pub struct PermissionedUpdate {
-    pub feed_id:    pyth_sdk::Identifier,
+    pub feed_id: pyth_sdk::Identifier,
     pub feed_index: u32,
-    pub info:       PriceInfo,
+    pub info: PriceInfo,
 }
 
 #[async_trait::async_trait]
@@ -693,7 +664,10 @@ where
                 account
                     .comp
                     .iter()
-                    .find(|c| c.publisher == solana_pubkey::Pubkey::from(publish_keypair.pubkey().to_bytes()))
+                    .find(|c| {
+                        c.publisher
+                            == solana_pubkey::Pubkey::from(publish_keypair.pubkey().to_bytes())
+                    })
                     .map(|c| c.latest.pub_slot.max(account.agg.pub_slot))
             })
             .min();
@@ -781,34 +755,34 @@ fn create_instruction_without_accumulator(
 ) -> Result<Instruction> {
     Ok(Instruction {
         program_id: pyth_oracle_program_key,
-        accounts:   vec![
+        accounts: vec![
             AccountMeta {
-                pubkey:      publish_pubkey,
-                is_signer:   true,
+                pubkey: publish_pubkey,
+                is_signer: true,
                 is_writable: true,
             },
             AccountMeta {
-                pubkey:      price_id,
-                is_signer:   false,
+                pubkey: price_id,
+                is_signer: false,
                 is_writable: true,
             },
             AccountMeta {
-                pubkey:      clock::id(),
-                is_signer:   false,
+                pubkey: clock::id(),
+                is_signer: false,
                 is_writable: false,
             },
         ],
-        data:       bincode::DefaultOptions::new()
+        data: bincode::DefaultOptions::new()
             .with_little_endian()
             .with_fixint_encoding()
             .serialize(
                 &(UpdPriceCmd {
-                    version:  PYTH_ORACLE_VERSION,
-                    cmd:      UPDATE_PRICE_NO_FAIL_ON_ERROR,
-                    status:   price_info.status,
-                    unused_:  0,
-                    price:    price_info.price,
-                    conf:     price_info.conf,
+                    version: PYTH_ORACLE_VERSION,
+                    cmd: UPDATE_PRICE_NO_FAIL_ON_ERROR,
+                    status: price_info.status,
+                    unused_: 0,
+                    price: price_info.price,
+                    conf: price_info.conf,
                     pub_slot: current_slot,
                 }),
             )?,
@@ -822,9 +796,7 @@ fn create_instruction_with_price_store_program(
     prices: Vec<PermissionedUpdate>,
 ) -> Result<Instruction> {
     use pyth_price_store::instruction::{
-        Instruction as PublishInstruction,
-        SubmitPricesArgsHeader,
-        PUBLISHER_CONFIG_SEED,
+        Instruction as PublishInstruction, PUBLISHER_CONFIG_SEED, SubmitPricesArgsHeader,
     };
     let (publisher_config_key, publisher_config_bump) = Pubkey::find_program_address(
         &[PUBLISHER_CONFIG_SEED.as_bytes(), &publish_pubkey.to_bytes()],
@@ -853,18 +825,18 @@ fn create_instruction_with_price_store_program(
         program_id: pyth_price_store_program_key,
         accounts: vec![
             AccountMeta {
-                pubkey:      publish_pubkey,
-                is_signer:   true,
+                pubkey: publish_pubkey,
+                is_signer: true,
                 is_writable: true,
             },
             AccountMeta {
-                pubkey:      publisher_config_key,
-                is_signer:   false,
+                pubkey: publisher_config_key,
+                is_signer: false,
                 is_writable: false,
             },
             AccountMeta {
-                pubkey:      publisher_buffer_key,
-                is_signer:   false,
+                pubkey: publisher_buffer_key,
+                is_signer: false,
                 is_writable: true,
             },
         ],
@@ -902,58 +874,58 @@ fn create_instruction_with_accumulator(
 
     Ok(Instruction {
         program_id: pyth_oracle_program_key,
-        accounts:   vec![
+        accounts: vec![
             AccountMeta {
-                pubkey:      publish_pubkey,
-                is_signer:   true,
+                pubkey: publish_pubkey,
+                is_signer: true,
                 is_writable: true,
             },
             AccountMeta {
-                pubkey:      price_id,
-                is_signer:   false,
+                pubkey: price_id,
+                is_signer: false,
                 is_writable: true,
             },
             AccountMeta {
-                pubkey:      clock::id(),
-                is_signer:   false,
+                pubkey: clock::id(),
+                is_signer: false,
                 is_writable: false,
             },
             // accumulator program key
             AccountMeta {
-                pubkey:      accumulator_program_key,
-                is_signer:   false,
+                pubkey: accumulator_program_key,
+                is_signer: false,
                 is_writable: false,
             },
             // whitelist
             AccountMeta {
-                pubkey:      whitelist_pubkey,
-                is_signer:   false,
+                pubkey: whitelist_pubkey,
+                is_signer: false,
                 is_writable: false,
             },
             // oracle_auth_pda
             AccountMeta {
-                pubkey:      oracle_auth_pda,
-                is_signer:   false,
+                pubkey: oracle_auth_pda,
+                is_signer: false,
                 is_writable: false,
             },
             // accumulator_data
             AccountMeta {
-                pubkey:      accumulator_data_pubkey,
-                is_signer:   false,
+                pubkey: accumulator_data_pubkey,
+                is_signer: false,
                 is_writable: true,
             },
         ],
-        data:       bincode::DefaultOptions::new()
+        data: bincode::DefaultOptions::new()
             .with_little_endian()
             .with_fixint_encoding()
             .serialize(
                 &(UpdPriceCmd {
-                    version:  PYTH_ORACLE_VERSION,
-                    cmd:      UPDATE_PRICE_NO_FAIL_ON_ERROR,
-                    status:   price_info.status,
-                    unused_:  0,
-                    price:    price_info.price,
-                    conf:     price_info.conf,
+                    version: PYTH_ORACLE_VERSION,
+                    cmd: UPDATE_PRICE_NO_FAIL_ON_ERROR,
+                    status: price_info.status,
+                    unused_: 0,
+                    price: price_info.price,
+                    conf: price_info.conf,
                     pub_slot: current_slot,
                 }),
             )?,