Function run

crates/openshell-tui/src/lib.rs:45–436

Launch the `OpenShell` TUI. `channel` must be a connected gRPC channel to the `OpenShell` gateway. `theme_mode` selects the color theme: `Auto` detects the terminal background, `Dark`/`Light` forces a specific palette.

(
    channel: Channel,
    interceptor: EdgeAuthInterceptor,
    gateway_name: &str,
    endpoint: &str,
    theme_mode: ThemeMode,
)

/// `theme_mode` selects the color theme: `Auto` detects the terminal
/// background, `Dark`/`Light` forces a specific palette.
pub async fn run(
    channel: Channel,
    interceptor: EdgeAuthInterceptor,
    gateway_name: &str,
    endpoint: &str,
    theme_mode: ThemeMode,
) -> Result<()> {
    // Detect theme *before* entering raw/alternate-screen mode.
    // The OSC 11 query temporarily enters raw mode itself; calling it
    // after our own enable_raw_mode() would conflict.
    let detected_theme = theme::detect(theme_mode);

    let client = OpenShellClient::with_interceptor(channel, interceptor);
    let mut app = App::new(
        client,
        gateway_name.to_string(),
        endpoint.to_string(),
        detected_theme,
    );

    enable_raw_mode().into_diagnostic()?;
    let mut stdout = io::stdout();
    execute!(stdout, EnterAlternateScreen, EnableMouseCapture).into_diagnostic()?;

    let backend = CrosstermBackend::new(stdout);
    let mut terminal = Terminal::new(backend).into_diagnostic()?;
    terminal.clear().into_diagnostic()?;

    let mut events = EventHandler::new(Duration::from_secs(2));

    refresh_gateway_list(&mut app);
    refresh_data(&mut app).await;

    while app.running {
        terminal
            .draw(|frame| ui::draw(frame, &mut app))
            .into_diagnostic()?;

        match events.next().await {
            Some(Event::Key(key)) => {
                app.handle_key(key);
                // Handle async actions triggered by key presses.
                if app.pending_gateway_switch.is_some() {
                    handle_gateway_switch(&mut app).await;
                }
                if app.pending_log_fetch {
                    app.pending_log_fetch = false;
                    spawn_log_stream(&mut app, events.sender());
                }
                if app.pending_sandbox_delete {
                    app.pending_sandbox_delete = false;
                    handle_sandbox_delete(&mut app).await;
                }
                if app.pending_create_sandbox {
                    app.pending_create_sandbox = false;
                    spawn_create_sandbox(&mut app, events.sender());
                    start_anim_ticker(&mut app, events.sender());
                }