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 }, Update { key: String, value: serde_json::Value }, Delete { key: String }, BeginTransaction, CommitTransaction, RollbackTransaction, CreateIndex { field: String }, DropIndex { field: String }, SysExec { script_name: String }, ReplicationEnable, ReplicationDisable, ReplicationAddPeer { addr: String }, ReplicationRemovePeer { addr: String }, ReplicationStatus, } #[derive(Debug, Serialize, Deserialize)] pub enum Response { Success(Option), Error(String), ReplicationStatus { enabled: bool, peers: Vec, last_sync: u128, }, } } 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> { println!(); println!("{}", "Futriix CLI Client".bold().bright_cyan()); println!("Type 'help' for available commands"); println!(); let mut rl = Editor::<()>::new()?; if rl.load_history("futriix-history.txt").is_err() { println!("No previous history."); println!(); } loop { let readline = rl.readline(&"futriix:~> ".bright_cyan()); 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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), }, Err(e) => println!("{}: {}", "Invalid JSON".red(), e), } }, "get" | "g" => { if parts.len() < 2 { println!("{}", "Usage: get ".red()); continue; } let key = parts[1].to_string(); match send_command(Command::Get { key }).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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), }, 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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "begin" | "transaction" | "tx" => { match send_command(Command::BeginTransaction).await { Ok(Response::Success(_)) => { println!("{}", "Transaction started".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "commit" => { match send_command(Command::CommitTransaction).await { Ok(Response::Success(_)) => { println!("{}", "Transaction committed".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "rollback" => { match send_command(Command::RollbackTransaction).await { Ok(Response::Success(_)) => { println!("{}", "Transaction rolled back".bright_green()); println!(); }, Ok(Response::Error(e)) => println!("{}", e.bold().red()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } }, "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } } "off" => { match send_command(Command::ReplicationDisable).await { Ok(Response::Success(_)) => println!("{}", "Replication disabled".bright_green()), Ok(Response::Error(e)) => println!("{}", e.red()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } } "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()), Err(e) => println!("{}: {}", "Connection error".red(), e), } } "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } } "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()), Ok(Response::ReplicationStatus { .. }) => println!("{}", "Unexpected response type".red()), Err(e) => println!("{}: {}", "Connection error".red(), e), } } _ => println!("{}", "Unknown replication command".red()), } }, "help" => { println!(); println!("{}", "Available commands:".bold()); println!(" insert (or i) - Insert data"); println!(" get (or g) - Get data"); println!(" update (or u) - Update data"); println!(" delete (or d) - Delete data"); println!(" begin (or transaction, tx) - Start transaction"); println!(" commit - Commit transaction"); println!(" rollback - Rollback 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!(" 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(()) }