ftnet 0.1.0

FTNet: FifthTry Network
Documentation 
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

/// start ftn service
///
/// on startup, we first check if another instance is running if so we exit.
///
/// the main job of this function is to run an instance of `fastn` for every identity in the
/// identities folder, and set-up http device driver for each of them.
///
/// it also has to start the device "drivers" for every device in the <identities>/devices folder.
pub async fn start(_fg: bool, dir: Option<String>) -> eyre::Result<()> {
    use eyre::WrapErr;

    let config = ftnet::Config::read(dir)
        .await
        .wrap_err_with(|| "failed to run config")?;

    let _lock = config
        .lock()
        .await
        .wrap_err_with(|| "looks like there is another instance of ftn running")?;

    println!("ftn service started: {config:?}");
    let identities = config.identities().await?;

    let (graceful_shutdown_tx, graceful_shutdown_rx) = tokio::sync::watch::channel(false);

    for identity in identities {
        let graceful_shutdown_rx = graceful_shutdown_rx.clone();
        tokio::spawn(async move {
            let public_key = identity.public_key;
            println!("running: {public_key}");
            if let Err(e) = identity.run(graceful_shutdown_rx).await {
                eprintln!("failed to run identity: {public_key}: {e}");
            }
        });
    }

    tokio::signal::ctrl_c()
        .await
        .wrap_err_with(|| "failed to get ctrl-c signal handler")?;
    graceful_shutdown_tx
        .send(true)
        .wrap_err_with(|| "failed to send graceful shutdown signal")?;

    let mut count = 0;

    loop {
        count += 1;
        tokio::time::sleep(std::time::Duration::from_millis(100)).await;
        let v = ftnet::OPEN_CONNECTION_COUNT.get();
        if v == 0 {
            println!("No inflight requests open.");
            break;
        }

        // every second print status
        if count % 10 == 0 {
            println!("Waiting for {v} inflight requests to finish.");
        }

        // give up in 1 min
        if count > 60 {
            println!("Giving up.");
            break;
        }
    }

    println!("Shutting down.");

    Ok(())
}