oxidux 0.4.0

Reverse proxy and process manager for web app development.
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

use std::time::Duration;
use tokio::signal;
use tokio::sync::oneshot;
use tokio::time::timeout;

use crate::process_manager::ProcessManager;
use crate::tmux;

pub(crate) async fn ctrlc_listener() {
    let (tx, rx) = oneshot::channel::<()>();

    let mut shutdown_tx = Some(tx);

    let signal_handler = async move {
        loop {
            signal::ctrl_c().await.unwrap();

            if let Some(tx) = shutdown_tx.take() {
                eprintln!("Gracefully shutting down");

                timeout(
                    Duration::from_secs(10),
                    ProcessManager::global().write().await.shutdown(),
                )
                .await
                .ok();

                tmux::kill_server().await.ok();
                eprintln!("All processes have stopped");

                tx.send(()).unwrap();
            } else {
                eprintln!("Forcibly shutting down");
                std::process::exit(1);
            }
        }
    };

    tokio::spawn(signal_handler);

    rx.await.ok();
}