(misc) fmt

Author: nykma

src/geyser_plugin_postgres.rs

@@ -5,14 +5,14 @@ use {
         postgres_client::{ParallelPostgresClient, PostgresClientBuilder},
         transaction_selector::TransactionSelector,
     },
-    bs58,
-    log::*,
-    serde_derive::{Deserialize, Serialize},
-    serde_json,
     agave_geyser_plugin_interface::geyser_plugin_interface::{
         GeyserPlugin, GeyserPluginError, ReplicaAccountInfoVersions, ReplicaBlockInfoVersions,
         ReplicaTransactionInfoVersions, Result, SlotStatus,
     },
+    bs58,
+    log::*,
+    serde_derive::{Deserialize, Serialize},
+    serde_json,
     solana_measure::measure::Measure,
     solana_metrics::*,
     std::{fs::File, io::Read},
@@ -311,7 +311,12 @@ impl GeyserPlugin for GeyserPluginPostgres {
         Ok(())
     }
 
-    fn update_slot_status(&self, slot: u64, parent: Option<u64>, status: &SlotStatus) -> Result<()> {
+    fn update_slot_status(
+        &self,
+        slot: u64,
+        parent: Option<u64>,
+        status: &SlotStatus,
+    ) -> Result<()> {
         info!("Updating slot {:?} at with status {:?}", slot, status);
 
         match &self.client {

src/postgres_client.rs

@@ -10,6 +10,9 @@ use {
         geyser_plugin_postgres::{GeyserPluginPostgresConfig, GeyserPluginPostgresError},
         postgres_client::postgres_client_account_index::TokenSecondaryIndexEntry,
     },
+    agave_geyser_plugin_interface::geyser_plugin_interface::{
+        GeyserPluginError, ReplicaAccountInfoV3, ReplicaBlockInfoV4, SlotStatus,
+    },
     chrono::Utc,
     crossbeam_channel::{bounded, Receiver, RecvTimeoutError, Sender},
     log::*,
@@ -18,9 +21,6 @@ use {
     postgres_client_block_metadata::DbBlockInfo,
     postgres_client_transaction::LogTransactionRequest,
     postgres_openssl::MakeTlsConnector,
-    agave_geyser_plugin_interface::geyser_plugin_interface::{
-        GeyserPluginError, ReplicaAccountInfoV3, ReplicaBlockInfoV4, SlotStatus,
-    },
     solana_measure::measure::Measure,
     solana_metrics::*,
     solana_sdk::timing::AtomicInterval,

src/postgres_client/postgres_client_account_index.rs

@@ -8,9 +8,9 @@ use {
         inline_spl_token::{self, GenericTokenAccount},
         inline_spl_token_2022,
     },
+    agave_geyser_plugin_interface::geyser_plugin_interface::GeyserPluginError,
     log::*,
     postgres::{Client, Statement},
-    agave_geyser_plugin_interface::geyser_plugin_interface::GeyserPluginError,
     solana_measure::measure::Measure,
     solana_metrics::*,
     solana_sdk::pubkey::Pubkey,

src/postgres_client/postgres_client_block_metadata.rs

@@ -5,12 +5,12 @@ use {
             postgres_client_transaction::DbReward, SimplePostgresClient, UpdateBlockMetadataRequest,
         },
     },
-    chrono::Utc,
-    log::*,
-    postgres::{Client, Statement},
     agave_geyser_plugin_interface::geyser_plugin_interface::{
         GeyserPluginError, ReplicaBlockInfoV4,
     },
+    chrono::Utc,
+    log::*,
+    postgres::{Client, Statement},
 };
 
 #[derive(Clone, Debug)]
@@ -27,7 +27,12 @@ impl<'a> From<&ReplicaBlockInfoV4<'a>> for DbBlockInfo {
         Self {
             slot: block_info.slot as i64,
             blockhash: block_info.blockhash.to_string(),
-            rewards: block_info.rewards.rewards.iter().map(DbReward::from).collect(),
+            rewards: block_info
+                .rewards
+                .rewards
+                .iter()
+                .map(DbReward::from)
+                .collect(),
             block_time: block_info.block_time,
             block_height: block_info
                 .block_height

src/postgres_client/postgres_client_transaction.rs

@@ -5,13 +5,13 @@ use {
         geyser_plugin_postgres::{GeyserPluginPostgresConfig, GeyserPluginPostgresError},
         postgres_client::{DbWorkItem, ParallelPostgresClient, SimplePostgresClient},
     },
+    agave_geyser_plugin_interface::geyser_plugin_interface::{
+        GeyserPluginError, ReplicaTransactionInfoV2,
+    },
     chrono::Utc,
     log::*,
     postgres::{Client, Statement},
     postgres_types::{FromSql, ToSql},
-    agave_geyser_plugin_interface::geyser_plugin_interface::{
-        GeyserPluginError, ReplicaTransactionInfoV2,
-    },
     solana_runtime::bank::RewardType,
     solana_sdk::{
         instruction::CompiledInstruction,
@@ -353,7 +353,7 @@ pub enum DbTransactionErrorCode {
     ResanitizationNeeded,
     UnbalancedTransaction,
     ProgramExecutionTemporarilyRestricted,
-    ProgramCacheHitMaxLimit
+    ProgramCacheHitMaxLimit,
 }
 
 impl From<&TransactionError> for DbTransactionErrorCode {
@@ -414,7 +414,7 @@ impl From<&TransactionError> for DbTransactionErrorCode {
             TransactionError::ProgramExecutionTemporarilyRestricted { account_index: _ } => {
                 Self::ProgramExecutionTemporarilyRestricted
             }
-            TransactionError::ProgramCacheHitMaxLimit => Self::ProgramCacheHitMaxLimit
+            TransactionError::ProgramCacheHitMaxLimit => Self::ProgramCacheHitMaxLimit,
         }
     }
 }