use std::path::PathBuf;
use std::io;
pub mod app;
pub async fn run(config_path: &PathBuf) -> anyhow::Result<()> {
use self::app::App;
use crossterm::event::{self, Event};
use crossterm::terminal::{disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen};
use crossterm::execute;
use ratatui::{backend::CrosstermBackend, Terminal};
use std::time::Duration;
use crate::foreground_process::ForegroundProcess;
let mut app = App::new(config_path.clone());
enable_raw_mode()?;
let mut stdout = io::stdout();
execute!(stdout, EnterAlternateScreen)?;
let backend = CrosstermBackend::new(stdout);
let mut terminal = Terminal::new(backend)?;
loop {
app.process_update_messages();
if matches!(app.state, app::AppState::RunningForeground) {
if app.foreground_process.is_none() {
if let Ok(config) = crate::config::Config::load(config_path) {
let jar = config.server.jar.clone();
let min_mem = config.server.min_mem.clone();
let max_mem = config.server.max_mem.clone();
match ForegroundProcess::spawn(
&jar,
&min_mem,
&max_mem,
None, None, ).await {
Ok(proc) => {
log::info!("[TUI] Foreground server process spawned successfully");
app.foreground_process = Some(proc);
app.fg_server_alive = true;
app.fg_console_lines.push("=== MC-Minder: Server starting... ===".to_string());
}
Err(e) => {
log::error!("[TUI] Failed to spawn foreground server: {}", e);
app.fg_console_lines.push(format!("Failed to start server: {}", e));
app.state = app::AppState::MainMenu;
}
}
} else {
app.fg_console_lines.push("Failed to load configuration".to_string());
app.state = app::AppState::MainMenu;
}
} else {
app.poll_foreground_output();
let alive = app.is_foreground_process_alive();
app.fg_server_alive = alive;
if !alive {
app.fg_console_lines.push("=== MC-Minder: Server has stopped ===".to_string());
app.foreground_process = None;
}
}
}
terminal.draw(|f| {
app.draw(f);
})?;
if app.should_quit {
break;
}
if let Some(timeout) = &app.message_timeout {
if timeout.elapsed() > Duration::from_secs(3) {
app.message = None;
app.message_timeout = None;
}
}
if event::poll(Duration::from_millis(200))? {
if let Event::Key(key) = event::read()? {
let had_message = app.message.is_some();
app.on_key(key);
if app.message.is_some() && !had_message {
app.message_timeout = Some(std::time::Instant::now());
}
}
}
}
disable_raw_mode()?;
execute!(terminal.backend_mut(), LeaveAlternateScreen)?;
if app.foreground_requested {
let config = crate::config::Config::load(config_path).ok();
let jar = config.as_ref().map(|c| c.server.jar.clone()).unwrap_or_default();
let min_mem = config.as_ref().map(|c| c.server.min_mem.clone()).unwrap_or_else(|| "512M".to_string());
let max_mem = config.as_ref().map(|c| c.server.max_mem.clone()).unwrap_or_else(|| "1G".to_string());
println!();
println!("Starting Minecraft server in foreground...");
println!("Command: java -Xms{} -Xmx{} -jar {} nogui", min_mem, max_mem, jar);
println!("Press Ctrl+C to stop the server");
println!();
let status = std::process::Command::new("java")
.args(["-Xms".to_owned() + &min_mem, "-Xmx".to_owned() + &max_mem, "-jar".to_owned(), jar, "nogui".to_owned()])
.status();
match status {
Ok(exit_code) => {
if exit_code.success() {
println!("\nServer stopped normally.");
} else {
println!("\nServer exited with code: {:?}", exit_code.code());
}
}
Err(e) => {
println!("\nFailed to start server: {}", e);
}
}
}
Ok(())
}