feat: make chainlink aware of validator mode

magicblock-aperture/Cargo.toml

@@ -41,6 +41,7 @@ magicblock-version = { workspace = true }
 agave-geyser-plugin-interface = { workspace = true }
 solana-account = { workspace = true }
 solana-account-decoder = { workspace = true }
+solana-commitment-config = { workspace = true }
 solana-feature-set = { workspace = true }
 solana-fee-structure = { workspace = true }
 solana-keypair = { workspace = true }

magicblock-aperture/src/error.rs

@@ -6,6 +6,8 @@ use solana_transaction_error::TransactionError;
 
 pub(crate) const TRANSACTION_SIMULATION: i16 = -32002;
 pub(crate) const TRANSACTION_VERIFICATION: i16 = -32003;
+#[allow(dead_code)]
+pub(crate) const TEMPORARILY_UNAVAILABLE: i16 = -32004;
 pub(crate) const BLOCK_NOT_FOUND: i16 = -32009;
 pub(crate) const INVALID_REQUEST: i16 = -32600;
 pub(crate) const INVALID_PARAMS: i16 = -32602;
@@ -145,6 +147,15 @@ impl RpcError {
         }
     }
 
+    #[allow(dead_code)]
+    pub(crate) fn temporarily_unavailable<E: Display>(error: E) -> Self {
+        Self {
+            code: TEMPORARILY_UNAVAILABLE,
+            message: format!("temporarily unavailable: {error}"),
+            http_status: 503,
+        }
+    }
+
     pub(crate) fn invalid_request<E: Display>(error: E) -> Self {
         Self {
             code: INVALID_REQUEST,

magicblock-aperture/src/requests/http/get_account_info.rs

@@ -31,8 +31,8 @@ impl HttpDispatcher {
 
         // `read_account_with_ensure` guarantees the account is clone from chain if not in database.
         let account = self
-            .read_account_with_ensure(&pubkey)
-            .await
+            .read_account_with_ensure("getAccountInfo", &pubkey)
+            .await?
             .filter(|acc| !Self::account_should_render_as_null(acc))
             // `LockedAccount` provides a race-free read of the account data before encoding.
             .map(|acc| {

magicblock-aperture/src/requests/http/get_balance.rs

@@ -14,8 +14,8 @@ impl HttpDispatcher {
         let pubkey = some_or_err!(pubkey_bytes);
 
         let balance = self
-            .read_account_with_ensure(&pubkey)
-            .await
+            .read_account_with_ensure("getBalance", &pubkey)
+            .await?
             .map(|a| a.lamports())
             .unwrap_or_default(); // Default to 0 if account not found
 

magicblock-aperture/src/requests/http/get_delegation_status.rs

@@ -20,7 +20,9 @@ impl HttpDispatcher {
 
         // Ensure the account is present in the local AccountsDb, cloning it
         // from the reference cluster if necessary.
-        let account = self.read_account_with_ensure(&pubkey).await;
+        let account = self
+            .read_account_with_ensure("getDelegationStatus", &pubkey)
+            .await?;
 
         let is_delegated =
             account.as_ref().map(|acc| acc.delegated()).unwrap_or(false);

magicblock-aperture/src/requests/http/get_multiple_accounts.rs

@@ -28,9 +28,12 @@ impl HttpDispatcher {
         let encoding = config.encoding.unwrap_or(UiAccountEncoding::Base58);
         let slice = config.data_slice;
 
+        let ensured_accounts = self
+            .read_accounts_with_ensure("getMultipleAccounts", &pubkeys)
+            .await?;
         let accounts = pubkeys
             .iter()
-            .zip(self.read_accounts_with_ensure(&pubkeys).await.into_iter())
+            .zip(ensured_accounts.into_iter())
             .map(|(pubkey, acc)| {
                 acc.filter(|account| {
                     !Self::account_should_render_as_null(account)

magicblock-aperture/src/requests/http/get_token_account_balance.rs

@@ -26,7 +26,8 @@ impl HttpDispatcher {
 
         // Fetch the target token account.
         let token_account: AccountSharedData = some_or_err!(
-            self.read_account_with_ensure(&pubkey).await,
+            self.read_account_with_ensure("getTokenAccountBalance", &pubkey)
+                .await?,
             "token account not found or is not a token account"
         );
 
@@ -42,7 +43,11 @@ impl HttpDispatcher {
 
         // Fetch the mint account to get the token's decimals.
         let mint_account: AccountSharedData = some_or_err!(
-            self.read_account_with_ensure(&mint_pubkey).await,
+            self.read_account_with_ensure(
+                "getTokenAccountBalance",
+                &mint_pubkey
+            )
+            .await?,
             "mint account not found"
         );
         let decimals =