From 115faabe1b40bc408b670de0bc7ec38d4987d15f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=93=D1=80=D0=B8=D0=B3=D0=BE=D1=80=D0=B8=D0=B9=20=D0=A1?= =?UTF-8?q?=D0=B0=D1=84=D1=80=D0=BE=D0=BD=D0=BE=D0=B2?= Date: Sun, 6 Jul 2025 13:41:52 +0000 Subject: [PATCH] Delete futriix-cli/src/old-main.rs --- futriix-cli/src/old-main.rs | 357 ------------------------------------ 1 file changed, 357 deletions(-) delete mode 100644 futriix-cli/src/old-main.rs diff --git a/futriix-cli/src/old-main.rs b/futriix-cli/src/old-main.rs deleted file mode 100644 index c33f207..0000000 --- a/futriix-cli/src/old-main.rs +++ /dev/null @@ -1,357 +0,0 @@ -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(()) -} \ No newline at end of file