atmos/apps/terminal/

shell.rs

//! # ターミナル用対話型シェル・コマンドプロセッサ
//!
//! このモジュールは、ターミナルに入力されたコマンドライン文字列の解釈と、
//! `ls` や `cd` などのエイリアス展開、または `clear` や `history` などの
//! ローカルコマンドのインターセプト処理を提供します。

use crate::apps::terminal::Terminal;
use crate::kernel::keyboard::Keyboard;
use alloc::string::String;
use alloc::vec::Vec;

/// 入力されたコマンドライン文字列のエイリアスを展開し、Aura プログラミング言語の
/// スクリプト実行コードへ変換します。
///
/// 例えば、`ls /user` は `fs.ls("/user")` に、`pwd` は `fs.pwd()` に展開されます。
/// 括弧やイコールなどのプログラミング記号が含まれる場合は、すでに有効な Aura スクリプトと
/// みなしてエイリアス展開をスキップし、入力をそのまま返します。
///
/// # 引数
/// * `cmd_line` - 展開前のコマンドライン文字列
///
/// # 戻り値
/// エイリアス展開後の Aura スクリプト文字列
fn expand_aliases(cmd_line: &str) -> String {
    let trimmed = cmd_line.trim();
    if trimmed.is_empty() {
        return String::new();
    }

    // プログラミング記号が含まれている場合は、エイリアス展開をスキップしてそのまま返す
    let has_symbols = trimmed
        .chars()
        .any(|c| c == '(' || c == ')' || c == '{' || c == '}' || c == '=' || c == ',');
    if has_symbols {
        return String::from(trimmed);
    }

    // スペース区切りの単純なトークンに分割
    let tokens: Vec<&str> = trimmed.split_whitespace().collect();
    if tokens.is_empty() {
        return String::from(trimmed);
    }

    let cmd = tokens[0];
    let args = &tokens[1..];

    match cmd {
        "ls" => {
            if args.is_empty() {
                String::from("fs.ls()")
            } else {
                alloc::format!("fs.ls(\"{}\")", args[0])
            }
        }
        "cd" => {
            if args.is_empty() {
                String::from("fs.cd(\"/user/\")")
            } else {
                alloc::format!("fs.cd(\"{}\")", args[0])
            }
        }
        "pwd" => String::from("fs.pwd()"),
        "cat" => {
            if args.is_empty() {
                String::from("print(\"USAGE: cat <file>\")")
            } else {
                alloc::format!("fs.cat(\"{}\")", args[0])
            }
        }
        "mkdir" => {
            if args.is_empty() {
                String::from("print(\"USAGE: mkdir <dir>\")")
            } else {
                alloc::format!("fs.mkdir(\"{}\")", args[0])
            }
        }
        "rm" => {
            if args.is_empty() {
                String::from("print(\"USAGE: rm <file>\")")
            } else {
                alloc::format!("fs.rm(\"{}\")", args[0])
            }
        }
        "help" => String::from("help()"),
        "apps" => String::from("os.apps()"),
        "run" => {
            if args.is_empty() {
                String::from("print(\"USAGE: run <app>\")")
            } else {
                alloc::format!("os.run(\"{}\")", args[0])
            }
        }
        // `drive <sub> [arg]` → drive.<sub>([arg]) （Google Drive CUI。認証は drive アプリと共有）
        "drive" => match args.first().copied() {
            Some("ls") => match args.get(1) {
                Some(folder) => alloc::format!("drive.ls(\"{}\")", folder),
                None => String::from("drive.ls()"),
            },
            Some("cat") if args.len() > 1 => alloc::format!("drive.cat(\"{}\")", args[1]),
            Some("download") if args.len() > 2 => {
                alloc::format!("drive.download(\"{}\", \"{}\")", args[1], args[2])
            }
            Some("rm") if args.len() > 1 => alloc::format!("drive.rm(\"{}\")", args[1]),
            _ => String::from(
                "print(\"USAGE: drive ls [folder_id] | drive cat <file_id> | drive download <file_id> <local_name> | drive rm <file_id>\")",
            ),
        },
        // `gh <sub> [arg]` → gh.<sub>([arg]) （GitHub CUI。認証は gh_auth.json）
        "gh" => match args.first().copied() {
            Some("user") => String::from("gh.user()"),
            Some("repos") => String::from("gh.repos()"),
            Some("poll") => String::from("gh.poll()"),
            Some("logout") => String::from("gh.logout()"),
            Some("login") if args.len() > 1 => alloc::format!("gh.login(\"{}\")", args[1]),
            _ => String::from(
                "print(\"USAGE: gh login <client_id> | gh poll | gh user | gh repos | gh logout\")",
            ),
        },
        _ => {
            // アプリ名単体（例：settings）でインストールされている場合は、自動実行に展開する
            let app_name = cmd;
            let manifest_path = alloc::format!("/apps/{}/manifest.json", app_name);
            if crate::kernel::fs::get_fs()
                .read_file(&manifest_path)
                .is_some()
            {
                if args.is_empty() {
                    alloc::format!("os.run(\"{}\")", app_name)
                } else {
                    let mut run_cmd = alloc::format!("os.run(\"{}\"", app_name);
                    for arg in args {
                        run_cmd.push_str(&alloc::format!(", \"{}\"", arg));
                    }
                    run_cmd.push(')');
                    run_cmd
                }
            } else {
                String::from(trimmed)
            }
        }
    }
}

/// ターミナルから入力されたコマンドラインを実行します。
///
/// この関数は、以下の処理を行います。
/// 1. `clear` コマンドが入力された場合、ターミナルログをクリアして即時リターンします。
/// 2. `history` または `h` コマンドが入力された場合、ターミナルの履歴を表示して即時リターンします。
/// 3. それ以外のコマンドは、[`expand_aliases`] を通して Aura スクリプトへ変換し、非同期実行キューへ投入します。
///
/// # 引数
/// * `cmd_line` - 実行するコマンドライン文字列
/// * `terminal` - 操作対象のターミナル構造体へのミュータブル参照
/// * `_kbd` - キーボード状態へのミュータブル参照 (未使用)
pub fn execute_shell_command(cmd_line: &str, terminal: &mut Terminal, _kbd: &mut Keyboard) {
    let trimmed = cmd_line.trim();
    if trimmed.is_empty() {
        return;
    }

    // clearコマンドはUI側でその場で完結させる
    if trimmed == "clear" {
        terminal.clear_logs();
        return;
    }

    // history/hコマンドはUI側でその場で完結させる
    if trimmed == "history" || trimmed == "h" {
        crate::info!("[Terminal] Executing local history command: {}", trimmed);
        terminal.show_history();
        return;
    }

    // h(番号) でヒストリの指定番号を再実行
    if let Some(rest) = trimmed.strip_prefix("h(").and_then(|s| s.strip_suffix(')')) {
        match rest.trim().parse::<usize>() {
            Ok(0) | Err(_) => {
                terminal.print_line(String::from("  h(番号): 1 以上の数値を指定してください"));
            }
            Ok(n) => match terminal.history.get(n - 1).cloned() {
                None => {
                    terminal.print_line(alloc::format!("  h({}): ヒストリにありません（範囲: 1–{}）", n, terminal.history.len()));
                }
                Some(cmd) => {
                    terminal.print_line(alloc::format!("  → {}", cmd));
                    if terminal.history.last() != Some(&cmd) {
                        terminal.history.push(cmd.clone());
                    }
                    terminal.history_index = terminal.history.len();
                    if let Some(ctx) = &terminal.context {
                        ctx.cmd_queue.push(expand_aliases(&cmd));
                    }
                }
            },
        }
        return;
    }

    let resolved_cmd = expand_aliases(trimmed);
    if resolved_cmd.is_empty() {
        return;
    }

    // 非同期Aura実行スレッドのキューへ送信
    if let Some(ctx) = &terminal.context {
        ctx.cmd_queue.push(resolved_cmd);
    }
}