railwayapp 4.17.1

mod app;
mod docker_logs;
mod log_store;
mod ui;

pub use app::{RestartRequest, ServiceInfo, TuiAction};
pub use docker_logs::{ServiceMapping, spawn_docker_logs};

use std::io::stdout;
use std::panic;
use std::time::Duration;

use anyhow::Result;
use app::TuiApp;
use crossterm::cursor::{Hide, Show};
use crossterm::event::{
    DisableMouseCapture, EnableMouseCapture, Event, EventStream, MouseEventKind,
};
use crossterm::execute;
use crossterm::terminal::{
    EnterAlternateScreen, LeaveAlternateScreen, disable_raw_mode, enable_raw_mode,
};
use futures_util::StreamExt;
use ratatui::Terminal;
use ratatui::backend::CrosstermBackend;
use tokio::sync::mpsc;

use super::LogLine;

fn setup_terminal() -> Result<Terminal<CrosstermBackend<std::io::Stdout>>> {
    enable_raw_mode()?;
    execute!(stdout(), EnterAlternateScreen, Hide)?;
    execute!(stdout(), EnableMouseCapture)?;

    let backend = CrosstermBackend::new(stdout());
    let terminal = Terminal::new(backend)?;
    Ok(terminal)
}

fn restore_terminal() {
    let _ = execute!(stdout(), DisableMouseCapture);
    let _ = execute!(stdout(), LeaveAlternateScreen, Show);
    let _ = disable_raw_mode();
    // Ensure cursor starts at column 0 on a fresh line
    print!("\r\n");
    let _ = std::io::Write::flush(&mut stdout());
}

pub async fn run(
    mut log_rx: mpsc::Receiver<LogLine>,
    mut docker_rx: mpsc::Receiver<LogLine>,
    services: Vec<ServiceInfo>,
    restart_tx: Option<mpsc::Sender<RestartRequest>>,
) -> Result<()> {
    let original_hook = panic::take_hook();
    panic::set_hook(Box::new(move |info| {
        restore_terminal();
        original_hook(info);
    }));

    let mut terminal = setup_terminal()?;

    let _cleanup = scopeguard::guard((), |_| {
        restore_terminal();
    });

    let mut app = TuiApp::new(services);
    let mut events = EventStream::new();

    'main: loop {
        terminal.draw(|f| ui::render(&mut app, f))?;

        tokio::select! {
            Some(log) = log_rx.recv() => {
                app.push_log(log, false);
            }
            Some(log) = docker_rx.recv() => {
                app.push_log(log, true);
            }
            Some(Ok(event)) = events.next() => {
                match process_event(&mut app, event) {
                    TuiAction::Quit => break 'main,
                    TuiAction::Restart(req) => {
                        if let Some(tx) = &restart_tx {
                            let _ = tx.send(req).await;
                        }
                    }
                    TuiAction::None => {}
                }
                // Drain any queued events to batch scroll and prevent momentum lag
                while let Ok(Some(Ok(event))) =
                    tokio::time::timeout(Duration::from_millis(1), events.next()).await
                {
                    match process_event(&mut app, event) {
                        TuiAction::Quit => break 'main,
                        TuiAction::Restart(req) => {
                            if let Some(tx) = &restart_tx {
                                let _ = tx.send(req).await;
                            }
                        }
                        TuiAction::None => {}
                    }
                }
            }
            _ = tokio::signal::ctrl_c() => {
                break;
            }
        }
    }

    Ok(())
}

fn process_event(app: &mut TuiApp, event: Event) -> TuiAction {
    match event {
        Event::Key(key) => {
            return app.handle_key(key);
        }
        Event::Mouse(mouse) => match mouse.kind {
            MouseEventKind::ScrollDown | MouseEventKind::ScrollUp => {
                app.handle_mouse(mouse);
            }
            _ => {}
        },
        _ => {}
    }
    TuiAction::None
}