Function handle_gql

gql-cli/src/cli/gqlcli.rs:116–258

Handle the gql (REPL) command

(
    path: PathBuf,
    user: Option<String>,
    password: Option<String>,
    _sample: bool,
)

/// Handle the gql (REPL) command
pub fn handle_gql(
    path: PathBuf,
    user: Option<String>,
    password: Option<String>,
    _sample: bool,
) -> Result<(), Box<dyn std::error::Error>> {
    // Check if database exists
    if !path.exists() {
        return Err(format!(
            "Database not found at {:?}. Run 'cargo run -- install' first.",
            path
        )
        .into());
    }

    // Prompt for credentials if not provided
    let username = user.unwrap_or_else(|| {
        print!("Username: ");
        std::io::Write::flush(&mut std::io::stdout()).unwrap();
        let mut input = String::new();
        std::io::stdin().read_line(&mut input).unwrap();
        input.trim().to_string()
    });

    let password = password.unwrap_or_else(|| {
        print!("Password: ");
        std::io::Write::flush(&mut std::io::stdout()).unwrap();
        rpassword::read_password().unwrap()
    });

    // Load database
    let coordinator = load_database(&path)?;

    // Authenticate
    let session_id = authenticate(&coordinator, &username, &password)?;

    println!("{}", "GraphLite".bold().green());
    println!("Type 'help' for commands, 'exit' or 'quit' to exit");
    println!("Multi-line queries supported - use ';' to terminate\n");
    println!("{}", format!("Authenticated as: {}", username).cyan());
    println!("Session ID: {}", session_id);

    // Create REPL editor
    let config = Config::builder()
        .edit_mode(EditMode::Emacs)
        .history_ignore_space(true)
        .completion_type(CompletionType::List)
        .auto_add_history(false)
        .build();

    let mut rl = Editor::<(), _>::with_config(config)?;

    let history_path = ".graphlite/.gql_history.txt";
    if let Some(parent) = Path::new(&history_path).parent() {
        std::fs::create_dir_all(parent)?;
    }

    let _ = rl.load_history(&history_path);