chore: fmt

Author: thlorenz

test-integration/test-chainlink/tests/ix_03_deleg_after_sub.rs

@@ -21,10 +21,11 @@ async fn ixtest_deleg_after_subscribe_case2() {
     // 1. Initially the account does not exist
     {
         info!("1. Initially the account does not exist");
-        let res = ctx.chainlink
-        .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+        let res = ctx
+            .chainlink
+            .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
 
         assert_not_found!(res, &pubkeys);
         assert_not_cloned!(ctx.cloner, &pubkeys);
@@ -37,9 +38,9 @@ async fn ixtest_deleg_after_subscribe_case2() {
         ctx.init_counter(&counter_auth).await;
 
         ctx.chainlink
-        .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+            .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
 
         // Assert cloned account state matches the remote account and slot
         let account = ctx.cloner.get_account(&counter_pda).unwrap();
@@ -61,9 +62,9 @@ async fn ixtest_deleg_after_subscribe_case2() {
         let deleg_record_pubkey = ctx.delegation_record_pubkey(&counter_pda);
 
         ctx.chainlink
-        .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+            .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
 
         let account = ctx.cloner.get_account(&counter_pda).unwrap();
         assert_cloned_as_delegated!(

test-integration/test-chainlink/tests/ix_06_redeleg_us_separate_slots.rs

@@ -7,8 +7,7 @@ use log::*;
 use magicblock_chainlink::{
     assert_cloned_as_delegated_with_retries, assert_cloned_as_undelegated,
     assert_not_subscribed, assert_subscribed_without_delegation_record,
-    testing::init_logger,
-    AccountFetchOrigin,
+    testing::init_logger, AccountFetchOrigin,
 };
 use solana_sdk::{signature::Keypair, signer::Signer};
 use test_chainlink::{ixtest_context::IxtestContext, sleep_ms};
@@ -35,9 +34,9 @@ async fn ixtest_undelegate_redelegate_to_us_in_separate_slots() {
         info!("1. Account delegated to us");
 
         ctx.chainlink
-        .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+            .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
         sleep_ms(1_500).await;
 
         // Account should be cloned as delegated

test-integration/test-chainlink/tests/ix_07_redeleg_us_same_slot.rs

@@ -34,9 +34,9 @@ async fn ixtest_undelegate_redelegate_to_us_in_same_slot() {
         info!("1. Account delegated to us");
 
         ctx.chainlink
-        .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+            .ensure_accounts(&pubkeys, None, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
         sleep_ms(1_500).await;
 
         // Account should be cloned as delegated

test-integration/test-chainlink/tests/ix_full_scenarios.rs

@@ -162,8 +162,8 @@ async fn ixtest_accounts_for_tx_2_delegated_3_readonly_3_programs_one_native() {
     // Initially the new_pubkey does not exist on chain so it will be returned as None
     {
         let (fetched_pubkeys, fetched_strs) = {
-            let fetched_accounts =
-                ctx.chainlink
+            let fetched_accounts = ctx
+                .chainlink
                 .fetch_accounts(&all_pubkeys, AccountFetchOrigin::GetAccount)
                 .await
                 .unwrap();
@@ -210,8 +210,8 @@ async fn ixtest_accounts_for_tx_2_delegated_3_readonly_3_programs_one_native() {
         sleep_ms(500).await;
 
         let (fetched_pubkeys, fetched_strs) = {
-            let fetched_accounts =
-                ctx.chainlink
+            let fetched_accounts = ctx
+                .chainlink
                 .fetch_accounts(&all_pubkeys, AccountFetchOrigin::GetAccount)
                 .await
                 .unwrap();

test-integration/test-chainlink/tests/ix_remote_account_provider.rs

@@ -119,11 +119,10 @@ async fn ixtest_get_existing_account_for_valid_slot() {
 
     {
         // Fetching immediately does not return the account yet
-        let remote_account =
-            remote_account_provider
-        .try_get(pubkey, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+        let remote_account = remote_account_provider
+            .try_get(pubkey, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
         assert!(!remote_account.is_found());
     }
 
@@ -139,11 +138,10 @@ async fn ixtest_get_existing_account_for_valid_slot() {
     {
         // After waiting for a bit the subscription update came in
         let cs = current_slot(rpc_client).await;
-        let remote_account =
-            remote_account_provider
-        .try_get(pubkey, AccountFetchOrigin::GetAccount)
-        .await
-        .unwrap();
+        let remote_account = remote_account_provider
+            .try_get(pubkey, AccountFetchOrigin::GetAccount)
+            .await
+            .unwrap();
         assert!(remote_account.is_found());
         assert!(remote_account.slot() >= cs);
         assert_eq!(remote_account.fresh_lamports().unwrap(), 2_000_000);