falcott/futriix-cli/src/main.rs

use colored::Colorize;
use rustyline::Editor;
use rustyline::error::ReadlineError;
use serde::{Deserialize, Serialize};
use serde_json;
use std::error::Error;
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 },
    }

    #[derive(Debug, Serialize, Deserialize)]
    pub enum Response {
        Success(Option<serde_json::Value>),
        Error(String),
    }
}

use server::{Command, Response};

async fn send_command(cmd: Command) -> Result<Response, Box<dyn std::error::Error>> {
    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<dyn std::error::Error>> {
    println!();
    println!("{}", "Futriix CLI Client".bright_cyan());
    println!("Type 'help' for available commands");
    
    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> ");
        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 <key> <json_value>".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()),
                                Err(e) => println!("{}: {}", "Connection error".red(), e),
                            },
                            Err(e) => println!("{}: {}", "Invalid JSON".red(), e),
                        }
                    },
                    "get" | "g" => {
                        if parts.len() < 2 {
                            println!("{}", "Usage: get <key>".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()),
                            Err(e) => println!("{}: {}", "Connection error".red(), e),
                        }
                    },
                    "update" | "u" => {
                        if parts.len() < 3 {
                            println!("{}", "Usage: update <key> <json_value>".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()),
                                Err(e) => println!("{}: {}", "Connection error".red(), e),
                            },
                            Err(e) => println!("{}: {}", "Invalid JSON".red(), e),
                        }
                    },
                    "delete" | "d" => {
                        if parts.len() < 2 {
                            println!("{}", "Usage: delete <key>".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()),
                            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()),
                            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()),
                            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()),
                            Err(e) => println!("{}: {}", "Connection error".red(), e),
                        }
                    },
                    "createindex" => {
                        if parts.len() < 2 {
                            println!("{}", "Usage: createindex <field>".red());
                            continue;
                        }
                        let field = parts[1].to_string();
                        match send_command(Command::CreateIndex { field }).await {
                            Ok(Response::Success(_)) => {
                                println!("{}", "Index created".bright_green());
                                println!();
                            },
                            Ok(Response::Error(e)) => println!("{}", e.bold().red()),
                            Err(e) => println!("{}: {}", "Connection error".red(), e),
                        }
                    },
                    "dropindex" => {
                        if parts.len() < 2 {
                            println!("{}", "Usage: dropindex <field>".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()),
                            Err(e) => println!("{}: {}", "Connection error".red(), e),
                        }
                    },
                    "sysexec" => {
                        if parts.len() < 2 {
                            println!("{}", "Usage: sysexec <script_name>".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()),
                            Err(e) => println!("{}: {}", "Connection error".red(), e),
                        }
                    },
                    "help" => {
                        println!("Available commands:");
                        println!("  insert <key> <json_value> (or i) - Insert data");
                        println!("  get <key> (or g) - Get data");
                        println!("  update <key> <json_value> (or u) - Update data");
                        println!("  delete <key> (or d) - Delete data");
                        println!("  begin (or transaction, tx) - Start transaction");
                        println!("  commit - Commit transaction");
                        println!("  rollback - Rollback transaction");
                        println!("  createindex <field> - Create index");
                        println!("  dropindex <field> - Drop index");
                        println!("  sysexec <script_name> - Execute system script");
                        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(())
}