1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

mod secondary;
mod shared;

use anyhow::Context;
use arti_client::{TorClient, TorClientConfig};
use dotenv::dotenv;
use env_logger::{Builder, Target};
use erpc_scanner::relay::NetDirProvider;
use log::info;
use secondary::{config::SecondaryWorkerConfig, worker::SecondaryWorker};

#[tokio::main]
#[deny(clippy::await_holding_lock)]
#[deny(clippy::print_stderr)]
#[deny(clippy::print_stdout)]
async fn main() -> anyhow::Result<()> {
    dotenv().context(".env file not found")?;
    let mut builder = Builder::from_default_env();
    builder.target(Target::Stdout).init();

    info!("Loading the configs from .env file");
    let secondary_worker_config = SecondaryWorkerConfig::from_env()?;
    info!("Current configs set to {secondary_worker_config:#?}");

    // We spin a TorClient and distribute it's parts i.e DirMgr and CircMgr,
    // similar to how we do it in PrimaryWorker
    info!("Spawning a bootstrapped arti_client::TorClient");
    //let mut tor_client_config_builder = TorClientConfigBuilder::default();
    // TODO: Add build timeout
    //    tor_client_config_builder
    //        .override_net_params()
    //        .insert(String::from("cbtmintimeout"), primary_worker_config.primary.min_circuit_build_timeout);
    //let tor_client_config = tor_client_config_builder.build()?;
    let tor_client_config = TorClientConfig::default();
    let tor_client = TorClient::create_bootstrapped(tor_client_config).await?;
    info!("Spawned a bootstrapped arti_client::TorClient");

    let circmgr = tor_client.circmgr().clone();
    let dirmgr = tor_client.dirmgr().clone();
    let netdir_provider = NetDirProvider::from_dirmgr(dirmgr).await?;

    let mut secondary_worker = SecondaryWorker::new(secondary_worker_config, netdir_provider, circmgr);

    secondary_worker.start().await?;

    Ok(())
}