use colored::Colorize; use rustyline::Editor; use rustyline::error::ReadlineError; use serde_json; use std::fs; use tokio::io::{AsyncReadExt, AsyncWriteExt}; use tokio::net::TcpStream; use toml::Value; mod server { use serde::{Deserialize, Serialize}; use serde_json; #[derive(Debug, Serialize, Deserialize)] pub enum Command { Insert { key: String, value: serde_json::Value }, Get { key: String, version: Option }, Update { key: String, value: serde_json::Value }, Delete { key: String }, BeginTransaction, CommitTransaction(u64), RollbackTransaction(u64), CreateIndex { field: String }, DropIndex { field: String }, SysExec { script_name: String }, ReplicationEnable, ReplicationDisable, ReplicationAddPeer { addr: String }, ReplicationRemovePeer { addr: String }, ReplicationStatus, BackupCreate { path: String }, BackupRestore { path: String }, } #[derive(Debug, Serialize, Deserialize)] pub enum Response { Success(Option), Error(String), ReplicationStatus { enabled: bool, peers: Vec, last_sync: u128, }, BackupStatus { success: bool, message: String }, } } use server::{Command, Response}; async fn send_command(cmd: Command) -> Result> { let config_content = fs::read_to_string("futriix.config.toml")?; let config: Value = toml::from_str(&config_content)?; let ip = config["client"]["ip"].as_str().unwrap_or("127.0.0.1"); let port = config["client"]["port"].as_integer().unwrap_or(8080) as u16; let addr = format!("{}:{}", ip, port); let mut stream = TcpStream::connect(&addr).await?; let cmd_bytes = rmp_serde::to_vec(&cmd)?; let len = cmd_bytes.len() as u32; stream.write_all(&len.to_be_bytes()).await?; stream.write_all(&cmd_bytes).await?; let mut len_buf = [0u8; 4]; stream.read_exact(&mut len_buf).await?; let len = u32::from_be_bytes(len_buf) as usize; let mut buf = vec![0u8; len]; stream.read_exact(&mut buf).await?; Ok(rmp_serde::from_slice(&buf)?) } #[tokio::main] async fn main() -> Result<(), Box> { let config_content = fs::read_to_string("futriix.config.toml")?; let config: Value = toml::from_str(&config_content)?; let ip = config["server"]["ip"].as_str().unwrap_or("127.0.0.1"); let port = config["server"]["port"].as_integer().unwrap_or(8080) as u16; let addr = format!("{}:{}", ip, port); match TcpStream::connect(&addr).await { Ok(_) => { println!("\n{}", "Futriix CLI Client".truecolor(12, 149, 193)); println!("Connected to server at {}", addr.green()); println!("Type 'help' for available commands\n"); }, Err(e) => { eprintln!("{}: Failed to connect to server at {}: {}", "Error".red(), addr, e); eprintln!("Please make sure futriix-server is running"); std::process::exit(1); } } let mut rl = Editor::<()>::new()?; if rl.load_history("futriix-history.txt").is_err() { println!("No previous history."); println!(); } let mut current_tx_id: Option = None; loop { let prompt = if let Some(tx_id) = current_tx_id { format!("futriix:tx{}:~> ", tx_id).bright_cyan() } else { "futriix:~> ".bright_cyan() }; let readline = rl.readline(&prompt); match readline { Ok(line) => { rl.add_history_entry(&line); if line.trim().is_empty() { continue; } let parts: Vec<&str> = line.split_whitespace().collect(); match parts[0].to_lowercase().as_str() { "insert" | "i" => { if parts.len() < 3 { println!("{}", "Usage: insert ".red()); continue; } let key = parts[1].to_string(); let value_str = parts[2..].join(" "); match serde_json::from_str(&value_str) { Ok(value) => match send_command(Command::Insert { key, value }).await { Ok(Response::Success(_)) => { println!("{}", "Insert successful".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), }, Err(e) => println!("{}: {}", "Invalid JSON".red(), e), } }, "get" | "g" => { if parts.len() < 2 { println!("{}", "Usage: get [version]".red()); continue; } let key = parts[1].to_string(); let version = if parts.len() > 2 { parts[2].parse().ok() } else { None }; match send_command(Command::Get { key, version }).await { Ok(Response::Success(Some(value))) => { println!("{}", serde_json::to_string_pretty(&value)?); println!(); }, Ok(Response::Success(None)) => { println!("{}", "Key found but no value returned".yellow()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "update" | "u" => { if parts.len() < 3 { println!("{}", "Usage: update ".red()); continue; } let key = parts[1].to_string(); let value_str = parts[2..].join(" "); match serde_json::from_str(&value_str) { Ok(value) => match send_command(Command::Update { key, value }).await { Ok(Response::Success(_)) => { println!("{}", "Update successful".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), }, Err(e) => println!("{}: {}", "Invalid JSON".red(), e), } }, "delete" | "d" => { if parts.len() < 2 { println!("{}", "Usage: delete ".red()); continue; } let key = parts[1].to_string(); match send_command(Command::Delete { key }).await { Ok(Response::Success(_)) => { println!("{}", "Delete successful".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "begin" | "transaction" | "tx" => { match send_command(Command::BeginTransaction).await { Ok(Response::Success(Some(tx_id))) => { if let Some(id) = tx_id.as_u64() { current_tx_id = Some(id); println!("{}", format!("Transaction {} started", id).bright_green()); println!(); } else { println!("{}", "Invalid transaction ID received".red()); } }, Ok(Response::Success(None)) => println!("{}", "No transaction ID received".red()), Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "commit" => { if let Some(tx_id) = current_tx_id { match send_command(Command::CommitTransaction(tx_id)).await { Ok(Response::Success(_)) => { println!("{}", format!("Transaction {} committed", tx_id).bright_green()); println!(); current_tx_id = None; }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } } else { println!("{}", "No active transaction to commit".red()); } }, "rollback" => { if let Some(tx_id) = current_tx_id { match send_command(Command::RollbackTransaction(tx_id)).await { Ok(Response::Success(_)) => { println!("{}", format!("Transaction {} rolled back", tx_id).bright_green()); println!(); current_tx_id = None; }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } } else { println!("{}", "No active transaction to rollback".red()); } }, "createindex" => { if parts.len() < 2 { println!("{}", "Usage: createindex ".red()); continue; } let field = parts[1].to_string(); match send_command(Command::CreateIndex { field: field.clone() }).await { Ok(Response::Success(_)) => { println!("{}", format!("Index created on field '{}'", field).bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "dropindex" => { if parts.len() < 2 { println!("{}", "Usage: dropindex ".red()); continue; } let field = parts[1].to_string(); match send_command(Command::DropIndex { field }).await { Ok(Response::Success(_)) => { println!("{}", "Index dropped".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "sysexec" => { if parts.len() < 2 { println!("{}", "Usage: sysexec ".red()); continue; } let script_name = parts[1].to_string(); match send_command(Command::SysExec { script_name }).await { Ok(Response::Success(Some(output))) => { println!("{}", "Script output:".bright_green()); println!("{}", output); println!(); }, Ok(Response::Success(None)) => { println!("{}", "Script executed but no output".yellow()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), _ => println!("{}", "Unexpected response type".red()), } }, "replication" => { if parts.len() < 2 { println!("{}", "Usage: replication ".red()); continue; } match parts[1].to_lowercase().as_str() { "on" => { match send_command(Command::ReplicationEnable).await { Ok(Response::Success(_)) => println!("{}", "Replication enabled".bright_green()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } } "off" => { match send_command(Command::ReplicationDisable).await { Ok(Response::Success(_)) => println!("{}", "Replication disabled".bright_green()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } } "status" => { match send_command(Command::ReplicationStatus).await { Ok(Response::ReplicationStatus { enabled, peers, last_sync }) => { println!("Status:"); println!(" Enabled: {}", enabled); println!(" Peers: {:?}", peers); println!(" Last sync: {}", last_sync); } Ok(Response::Success(_)) => println!("{}", "Unexpected success response".red()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } } "add-peer" => { if parts.len() < 3 { println!("{}", "Usage: replication add-peer ".red()); continue; } match send_command(Command::ReplicationAddPeer { addr: parts[2].to_string() }).await { Ok(Response::Success(_)) => println!("{}", "Peer added".bright_green()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } } "remove-peer" => { if parts.len() < 3 { println!("{}", "Usage: replication remove-peer ".red()); continue; } match send_command(Command::ReplicationRemovePeer { addr: parts[2].to_string() }).await { Ok(Response::Success(_)) => println!("{}", "Peer removed".bright_green()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } } _ => println!("{}", "Unknown replication command".red()), } }, "futload" => { if parts.len() < 2 { println!("{}", "Usage: futload ".red()); continue; } match send_command(Command::BackupRestore { path: parts[1].to_string() }).await { Ok(Response::BackupStatus { success, message }) => { if success { println!("{}", message.green()); } else { println!("{}", message.red()); } } Ok(Response::Success(_)) => println!("{}", "Unexpected success response".red()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } }, "futunload" => { if parts.len() < 2 { println!("{}", "Usage: futunload ".red()); continue; } match send_command(Command::BackupCreate { path: parts[1].to_string() }).await { Ok(Response::BackupStatus { success, message }) => { if success { println!("{}", message.green()); } else { println!("{}", message.red()); } } Ok(Response::Success(_)) => println!("{}", "Unexpected success response".red()), Ok(Response::Error(e)) => println!("{}", e.red()), _ => println!("{}", "Unexpected response type".red()), } }, "help" => { println!(); println!("{}", "Available commands:".bold()); println!(" insert (or i) - Insert data"); println!(" get [version] (or g) - Get data (optionally specify version)"); println!(" update (or u) - Update data"); println!(" delete (or d) - Delete data"); println!(" begin (or transaction, tx) - Start transaction"); println!(" commit - Commit current transaction"); println!(" rollback - Rollback current transaction"); println!(" createindex - Create index"); println!(" dropindex - Drop index"); println!(" sysexec - Execute system script"); println!(" replication on/off - Enable/disable replication"); println!(" replication status - Show replication status"); println!(" replication add-peer - Add replication peer"); println!(" replication remove-peer - Remove replication peer"); println!(" futload - Load data from backup file"); println!(" futunload - Save data to backup file"); println!(" exit (or quit) - Exit client"); println!(" help - Show this help"); println!(); }, "exit" | "quit" => break, _ => println!("{}: Unknown command. Type 'help' for available commands.", "Error".red()), } }, Err(ReadlineError::Interrupted) => break, Err(ReadlineError::Eof) => break, Err(err) => { println!("{}: {:?}", "Error".red(), err); break; } } } rl.save_history("futriix-history.txt")?; Ok(()) }