feat: add stake amount too

Author: aoikurokawa

api/src/resolvers/query_resolver.rs

@@ -542,6 +542,7 @@ impl QueryResolver {
                         running_jito: v.running_jito,
                         running_bam: v.running_bam,
                         jito_directed_stake_target: v.jito_directed_stake_target,
+                        jito_directed_stake_lamports: v.jito_directed_stake_lamports,
                         jito_sol_active_lamports: None,
                     }
                 })
@@ -623,6 +624,7 @@ impl QueryResolver {
                         running_jito: v.running_jito,
                         running_bam: v.running_bam,
                         jito_directed_stake_target: v.jito_directed_stake_target,
+                        jito_directed_stake_lamports: v.jito_directed_stake_lamports,
                         jito_sol_active_lamports: Some(v.target_pool_active_lamports),
                     }
                 })

api/src/schemas/validator.rs

@@ -35,6 +35,9 @@ pub struct ValidatorEntry {
     /// Whether or not this is a jito directed stake target validator
     pub jito_directed_stake_target: Option<bool>,
 
+    /// Total stake amount in lamports for Jito directed stake
+    pub jito_directed_stake_lamports: Option<u64>,
+
     /// Active stake lamports delegated to this validator from the JitoSOL stake-pool
     #[serde(skip_serializing_if = "Option::is_none")]
     pub jito_sol_active_lamports: Option<u64>,

core/src/db_models/validators.rs

@@ -31,6 +31,9 @@ pub struct Validator {
     /// Whether or not this is a jito directed stake target validator
     pub jito_directed_stake_target: Option<bool>,
 
+    /// Total stake amount in lamports for Jito directed stake
+    pub jito_directed_stake_lamports: Option<u64>,
+
     pub mev_commission_bps: Option<u16>,
     pub mev_revenue_lamports: u64,
     pub priority_fee_commission_bps: Option<u16>,
@@ -87,6 +90,7 @@ impl Validator {
             epoch_credits: validators_app_entry.epoch_credits,
             identity_account: validators_app_entry.account.clone(),
             jito_directed_stake_target: Some(on_chain_data.jito_directed_stake_target),
+            jito_directed_stake_lamports: Some(on_chain_data.jito_directed_stake_lamports),
             mev_commission_bps: on_chain_data.mev_commission_bps,
             mev_revenue_lamports: on_chain_data.mev_revenue_lamports,
             priority_fee_commission_bps: Some(on_chain_data.priority_fee_commission_bps),

core/src/fetcher.rs

@@ -69,6 +69,9 @@ pub struct ChainData {
 
     /// Jito Directed Stake Target
     pub jito_directed_stake_target: bool,
+
+    /// Total stake amount in lamports for Jito directed stake
+    pub jito_directed_stake_lamports: u64,
 }
 
 pub fn get_tip_distribution_program_id(cluster: &Cluster) -> Pubkey {
@@ -229,10 +232,12 @@ pub async fn fetch_chain_data(
         let inflation_rewards_lamports =
             inflation_rate / epochs_per_year * staked_amount * vote_credit_proportion;
 
-        let jito_directed_stake_target = directed_stake_meta
+        let (jito_directed_stake_target, jito_directed_stake_lamports) = directed_stake_meta
             .targets
             .iter()
-            .any(|target| target.vote_pubkey.eq(&v.vote_account));
+            .find(|target| target.vote_pubkey.eq(&v.vote_account))
+            .map(|target| (true, target.staked_last_updated_epoch))
+            .unwrap_or_default();
 
         let data = ChainData {
             mev_commission_bps,
@@ -246,6 +251,7 @@ pub async fn fetch_chain_data(
             priority_fee_commission_bps,
             priority_fee_revenue_lamports,
             jito_directed_stake_target,
+            jito_directed_stake_lamports,
         };
 
         (vote_account, data)