chore: remove directed stake target

Author: aoikurokawa

Cargo.lock

@@ -600,7 +600,6 @@ impl QueryResolver {
                         running_jito: v.running_jito,
                         running_bam: v.running_bam,
                         jito_sol_active_lamports: None,
-                        jito_pool_directed_stake_target: v.jito_directed_stake_target,
                     }
                 })
                 .collect(),
@@ -682,7 +681,6 @@ impl QueryResolver {
                         running_jito: v.running_jito,
                         running_bam: v.running_bam,
                         jito_sol_active_lamports: Some(v.target_pool_active_lamports),
-                        jito_pool_directed_stake_target: v.jito_directed_stake_target,
                     }
                 })
                 .collect(),

api/src/resolvers/query_resolver.rs

@@ -40,9 +40,6 @@ pub struct ValidatorEntry {
     /// 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>,
-
-    /// Indicates whether this validator is a target for directed stake from the JitoSOL stake-pool.
-    pub jito_pool_directed_stake_target: Option<bool>,
 }
 
 #[derive(Serialize, Deserialize, Clone, Default)]

api/src/schemas/validator.rs

@@ -28,9 +28,6 @@ pub struct Validator {
     pub epoch_credits: Option<u64>,
     pub identity_account: Option<String>,
 
-    /// Whether or not jito directed stake target validator
-    pub jito_directed_stake_target: Option<bool>,
-
     pub mev_commission_bps: Option<u16>,
     pub mev_revenue_lamports: u64,
     pub priority_fee_commission_bps: Option<u16>,
@@ -111,7 +108,6 @@ impl Validator {
             vote_credit_proportion: on_chain_data.vote_credit_proportion,
             www_url: validators_app_entry.www_url.clone(),
             inflation_rewards_lamports: on_chain_data.inflation_rewards_lamports,
-            jito_directed_stake_target: Some(on_chain_data.jito_directed_stake_target),
         }
     }
 

core/src/db_models/validators.rs

@@ -13,7 +13,7 @@ use solana_client::{nonblocking::rpc_client::RpcClient, rpc_response::RpcVoteAcc
 use solana_pubkey::Pubkey;
 use spl_stake_pool::state::ValidatorStakeInfo;
 use spl_stake_pool_cli::client::get_validator_list;
-use stakenet_sdk::utils::accounts::{get_all_validator_history_accounts, get_directed_stake_meta};
+use stakenet_sdk::utils::accounts::get_all_validator_history_accounts;
 use validator_history::ValidatorHistory;
 
 use crate::{
@@ -66,9 +66,6 @@ pub struct ChainData {
     pub inflation_rewards_lamports: u64,
     pub priority_fee_commission_bps: u16,
     pub priority_fee_revenue_lamports: u64,
-
-    /// Jito Directed Stake Target
-    pub jito_directed_stake_target: bool,
 }
 
 pub fn get_tip_distribution_program_id(cluster: &Cluster) -> Pubkey {
@@ -126,15 +123,13 @@ pub fn get_priority_fee_distribution_program_id() -> solana_pubkey::Pubkey {
 ///
 /// - If BAM validator set exists and not empty: check if validator identity is in the set
 /// - Otherwise: fall back to client_type check from validator history
-#[allow(clippy::too_many_arguments)]
 pub async fn fetch_chain_data(
     validators: &[ValidatorsAppResponseEntry],
     bam_validator_set: HashSet<String>,
     rpc_client: Arc<RpcClient>,
     cluster: &Cluster,
     epoch: u64,
     validator_list_pubkey: &Pubkey,
-    steward_config_pubkey: &Pubkey,
 ) -> Result<HashMap<Pubkey, ChainData>, Error> {
     // Fetch on-chain data
     let tip_distributions =
@@ -161,9 +156,6 @@ pub async fn fetch_chain_data(
     let validator_histories =
         fetch_validator_history_accounts(&rpc_client, validator_history_program_id).await?;
 
-    let directed_stake_meta =
-        get_directed_stake_meta(rpc_client, steward_config_pubkey, &jito_steward::id()).await?;
-
     Ok(HashMap::from_iter(validators.iter().map(|v| {
         let vote_account = v.vote_account;
         let maybe_tip_distribution_account = tip_distributions.get(&vote_account);
@@ -228,11 +220,6 @@ 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
-            .targets
-            .iter()
-            .any(|target| target.vote_pubkey.eq(&v.vote_account));
-
         let data = ChainData {
             mev_commission_bps,
             mev_revenue_lamports,
@@ -244,7 +231,6 @@ pub async fn fetch_chain_data(
             inflation_rewards_lamports: inflation_rewards_lamports as u64,
             priority_fee_commission_bps,
             priority_fee_revenue_lamports,
-            jito_directed_stake_target,
         };
 
         (vote_account, data)

core/src/fetcher.rs

@@ -29,7 +29,6 @@ solana-clap-utils = { workspace = true }
 solana-client = { workspace = true }
 solana-metrics = { workspace = true }
 solana-program = { workspace = true }
-solana-pubkey = { workspace = true }
 solana-sdk = { workspace = true }
 spl-stake-pool = { workspace = true }
 spl-stake-pool-cli = { workspace = true }

writer-service/Cargo.toml

@@ -66,7 +66,6 @@ impl KobeWriterService {
         tip_distribution_program_id: String,
         priority_fee_distribution_program_id: String,
         mainnet_gcp_server_names: Vec<String>,
-        steward_config: Pubkey,
         bam_api_base_url: Option<String>,
     ) -> Result<Self> {
         let mongodb_client = db::setup_mongo_client(mongo_connection_uri).await?;
@@ -90,13 +89,8 @@ impl KobeWriterService {
         .await
         .expect("Failed to initialize Validators App client");
 
-        let stake_pool_manager = StakePoolManager::new(
-            rpc_client,
-            validators_app_client,
-            bam_api_base_url,
-            cluster,
-            steward_config,
-        );
+        let stake_pool_manager =
+            StakePoolManager::new(rpc_client, validators_app_client, bam_api_base_url, cluster);
 
         Ok(Self {
             db,

writer-service/src/lib.rs

@@ -5,7 +5,6 @@ use kobe_writer_service::{result::Result, KobeWriterService};
 use log::{error, info, set_boxed_logger, set_max_level, LevelFilter};
 use solana_clap_utils::input_validators::is_url_or_moniker;
 use solana_metrics::set_host_id;
-use solana_pubkey::Pubkey;
 use tokio::runtime::Runtime;
 
 #[derive(Parser)]
@@ -59,14 +58,6 @@ struct Args {
     )]
     priority_fee_distribution_program_id: String,
 
-    /// Steward config pubkey
-    #[arg(
-        long,
-        env,
-        default_value = "jitoVjT9jRUyeXHzvCwzPgHj7yWNRhLcUoXtes4wtjv"
-    )]
-    steward_config_pubkey: Pubkey,
-
     /// Mainnet gcp server names
     #[arg(long, env, value_delimiter = ',')]
     mainnet_gcp_server_names: Vec<String>,
@@ -120,7 +111,6 @@ fn main() -> Result<()> {
             args.tip_distribution_program_id,
             args.priority_fee_distribution_program_id,
             args.mainnet_gcp_server_names,
-            args.steward_config_pubkey,
             args.bam_api_base_url,
         )
         .await

writer-service/src/main.rs

@@ -32,9 +32,6 @@ pub struct StakePoolManager {
 
     /// Cluster [Mainnet, Testnet, Devnet]
     pub cluster: Cluster,
-
-    /// Steward config pubkey
-    steward_config: Pubkey,
 }
 
 impl StakePoolManager {
@@ -43,14 +40,12 @@ impl StakePoolManager {
         validators_app_client: Client,
         bam_api_base_url: Option<String>,
         cluster: Cluster,
-        steward_config: Pubkey,
     ) -> Self {
         let mut manager = Self {
             rpc_client: Arc::new(rpc_client),
             validators_app_client,
             bam_api_client: None,
             cluster,
-            steward_config,
         };
 
         if let Some(bam_api_base_url) = bam_api_base_url {
@@ -91,7 +86,6 @@ impl StakePoolManager {
             &self.cluster,
             epoch,
             validator_list_address,
-            &self.steward_config,
         )
         .await?;