main.rs

use std::sync::Arc;

use mev_bot_solana::bot::solana_mev_bot::SolanaMevBot;
use mev_bot_solana::config::Config;
use mev_bot_solana::dex::dex_manager::DexManager;
use mev_bot_solana::monitoring::dashboard::Dashboard;
use mev_bot_solana::monitoring::metrics::Metrics;
use mev_bot_solana::strategies::copy_trade_strategy::CopyTradeStrategy;
use mev_bot_solana::strategies::sniping_strategy::SnipingStrategy;
use mev_bot_solana::utils::config_parser::parse_config;
use solana_client::rpc_client::RpcClient;
use solana_sdk::signature::read_keypair_file;

#[tokio::main]
async fn main() {
    let config = parse_config("config.toml").expect("Failed to parse config");

    let rpc_client = Arc::new(RpcClient::new_with_commitment(
        config.solana.rpc_url.clone(),
        config.solana.commitment.clone(),
    ));

    let metrics = Arc::new(Metrics::new());
    let dashboard = Dashboard::new(metrics.clone(), config.monitoring.update_interval);

    let dex_manager = Arc::new(tokio::sync::Mutex::new(DexManager::new(
        rpc_client.clone(),
        config.dexes.clone(),
    )));

    let sniping_strategy = Arc::new(tokio::sync::Mutex::new(SnipingStrategy::new(
        rpc_client.clone(),
        dex_manager.clone(),
        config.bot.max_position_size,
    )));

    let copy_trade_strategy = Arc::new(tokio::sync::Mutex::new(CopyTradeStrategy::new(
        rpc_client.clone(),
        dex_manager.clone(),
        config.bot.max_position_size,
    )));

    let authority_keypair = read_keypair_file(config.bot.keypair_path.clone())
        .expect("Failed to read keypair file");

    let mut mev_bot = SolanaMevBot::new(
        rpc_client,
        authority_keypair,
        vec![
            sniping_strategy.clone(),
            copy_trade_strategy.clone(),
        ],
        config.bot.profit_threshold,
        metrics,
    );

    tokio::spawn(async move {
        dashboard.run().await;
    });

    mev_bot.run().await;
}