p5 0.10.0

A tui client for Pulumi
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
71
72
73
74
75
76
77
78
79
80
81
82

pub mod controller;

pub type Result<T> = color_eyre::Result<T>;

use ratatui::{crossterm::ExecutableCommand, widgets::StatefulWidget};
use tracing_subscriber::prelude::*;

pub async fn run<H, W>(
    handler: H,
    state: H::State,
    init_actions: Vec<H::Action>,
    widget: W,
) -> color_eyre::Result<()>
where
    H: controller::Handler + Send + Sync + Clone + 'static,
    W: StatefulWidget<State = H::State> + Send + Sync + Clone + 'static,
{
    install_tracing();
    install_panic_hook()?;

    let cancel_token = tokio_util::sync::CancellationToken::new();

    let terminal = init_terminal()?;

    let controller =
        controller::Controller::new(handler, state, init_actions, cancel_token.clone());

    tokio::select! {
        _ = controller.run(terminal, widget) => {
            tracing::info!("Run task completed");
        },
        _ = tokio::signal::ctrl_c() => {
            tracing::info!("Ctrl-C received");
            cancel_token.cancel();
        },
        _ = cancel_token.cancelled() => {
            tracing::info!("Cancellation token triggered, shutting down...");
        },
    }

    tracing::debug!("Shutting down...");
    restore_terminal()?;

    Ok(())
}

fn init_terminal() -> color_eyre::Result<ratatui::DefaultTerminal> {
    ratatui::crossterm::terminal::enable_raw_mode()?;
    std::io::stdout().execute(ratatui::crossterm::terminal::EnterAlternateScreen)?;
    let terminal =
        ratatui::Terminal::new(ratatui::backend::CrosstermBackend::new(std::io::stdout()))?;
    Ok(terminal)
}

fn restore_terminal() -> color_eyre::Result<()> {
    std::io::stdout().execute(ratatui::crossterm::terminal::LeaveAlternateScreen)?;
    ratatui::crossterm::terminal::disable_raw_mode()?;
    Ok(())
}

fn install_panic_hook() -> color_eyre::Result<()> {
    color_eyre::config::HookBuilder::default()
        .panic_section("consider reporting the bug on github")
        .install()
}

fn install_tracing() {
    let registry = tracing_subscriber::registry()
        .with(tracing_error::ErrorLayer::default())
        .with(tracing_subscriber::EnvFilter::from_default_env())
        .with(
            tracing_subscriber::fmt::layer()
                .with_thread_ids(false)
                .with_thread_names(false)
                .with_file(true)
                .with_line_number(true)
                .with_target(false)
                .compact(),
        );

    registry.init();
}