aster_cli/commands/

term.rs

use anyhow::{anyhow, Result};
use aster::conversation::message::{Message, MessageContent, MessageMetadata};
use aster::session::SessionManager;
use aster::session::SessionType;
use chrono;
use rmcp::model::Role;

use crate::session::{build_session, SessionBuilderConfig};

use clap::ValueEnum;

#[derive(ValueEnum, Clone, Debug)]
pub enum Shell {
    Bash,
    Zsh,
    Fish,
    #[value(alias = "pwsh")]
    Powershell,
}

struct ShellConfig {
    script_template: &'static str,
    command_not_found: Option<&'static str>,
}

impl Shell {
    fn config(&self) -> &'static ShellConfig {
        match self {
            Shell::Bash => &BASH_CONFIG,
            Shell::Zsh => &ZSH_CONFIG,
            Shell::Fish => &FISH_CONFIG,
            Shell::Powershell => &POWERSHELL_CONFIG,
        }
    }
}

static BASH_CONFIG: ShellConfig = ShellConfig {
    script_template: r#"export ASTER_SESSION_ID="{session_id}"
alias @aster='{aster_bin} term run'
alias @g='{aster_bin} term run'

aster_preexec() {
    [[ "$1" =~ ^aster\ term ]] && return
    [[ "$1" =~ ^(@aster|@g)($|[[:space:]]) ]] && return
    ('{aster_bin}' term log "$1" &) 2>/dev/null
}

if [[ -z "$aster_preexec_installed" ]]; then
    aster_preexec_installed=1
    trap 'aster_preexec "$BASH_COMMAND"' DEBUG
fi{command_not_found_handler}"#,
    command_not_found: Some(
        r#"

command_not_found_handle() {
    echo "🪿 Command '$1' not found. Asking aster..."
    '{aster_bin}' term run "$@"
    return 0
}"#,
    ),
};

static ZSH_CONFIG: ShellConfig = ShellConfig {
    script_template: r#"export ASTER_SESSION_ID="{session_id}"
alias @aster='{aster_bin} term run'
alias @g='{aster_bin} term run'

aster_preexec() {
    [[ "$1" =~ ^aster\ term ]] && return
    [[ "$1" =~ ^(@aster|@g)($|[[:space:]]) ]] && return
    ('{aster_bin}' term log "$1" &) 2>/dev/null
}

autoload -Uz add-zsh-hook
add-zsh-hook preexec aster_preexec{command_not_found_handler}"#,
    command_not_found: Some(
        r#"

command_not_found_handler() {
    echo "🪿 Command '$1' not found. Asking aster..."
    '{aster_bin}' term run "$@"
    return 0
}"#,
    ),
};

static FISH_CONFIG: ShellConfig = ShellConfig {
    script_template: r#"set -gx ASTER_SESSION_ID "{session_id}"
function @aster; {aster_bin} term run $argv; end
function @g; {aster_bin} term run $argv; end

function aster_preexec --on-event fish_preexec
    string match -q -r '^aster term' -- $argv[1]; and return
    string match -q -r '^(@aster|@g)($|\s)' -- $argv[1]; and return
    {aster_bin} term log "$argv[1]" 2>/dev/null &
end"#,
    command_not_found: None,
};

static POWERSHELL_CONFIG: ShellConfig = ShellConfig {
    script_template: r#"$env:ASTER_SESSION_ID = "{session_id}"
function @aster {{ & '{aster_bin}' term run @args }}
function @g {{ & '{aster_bin}' term run @args }}

Set-PSReadLineKeyHandler -Chord Enter -ScriptBlock {{
    $line = $null
    [Microsoft.PowerShell.PSConsoleReadLine]::GetBufferState([ref]$line, [ref]$null)
    if ($line -notmatch '^aster term' -and $line -notmatch '^(@aster|@g)($|\s)') {{
        Start-Job -ScriptBlock {{ & '{aster_bin}' term log $using:line }} | Out-Null
    }}
    [Microsoft.PowerShell.PSConsoleReadLine]::AcceptLine()
}}"#,
    command_not_found: None,
};

pub async fn handle_term_init(
    shell: Shell,
    name: Option<String>,
    with_command_not_found: bool,
) -> Result<()> {
    let config = shell.config();

    let working_dir = std::env::current_dir()?;
    let named_session = if let Some(ref name) = name {
        let sessions = SessionManager::list_sessions_by_types(&[SessionType::Terminal]).await?;
        sessions.into_iter().find(|s| s.name == *name)
    } else {
        None
    };

    let session = match named_session {
        Some(s) => s,
        None => {
            let session = SessionManager::create_session(
                working_dir,
                "Aster Term Session".to_string(),
                SessionType::Terminal,
            )
            .await?;

            if let Some(name) = name {
                SessionManager::update_session(&session.id)
                    .user_provided_name(name)
                    .apply()
                    .await?;
            }

            session
        }
    };

    let aster_bin = std::env::current_exe()
        .map(|p| p.to_string_lossy().into_owned())
        .unwrap_or_else(|_| "aster".to_string());

    let command_not_found_handler = if with_command_not_found {
        config
            .command_not_found
            .map(|s| s.replace("{aster_bin}", &aster_bin))
            .unwrap_or_default()
    } else {
        String::new()
    };

    let script = config
        .script_template
        .replace("{session_id}", &session.id)
        .replace("{aster_bin}", &aster_bin)
        .replace("{command_not_found_handler}", &command_not_found_handler);

    println!("{}", script);
    Ok(())
}

pub async fn handle_term_log(command: String) -> Result<()> {
    let session_id = std::env::var("ASTER_SESSION_ID").map_err(|_| {
        anyhow!("ASTER_SESSION_ID not set. Run 'eval \"$(aster term init <shell>)\"' first.")
    })?;

    let message = Message::new(
        Role::User,
        chrono::Utc::now().timestamp_millis(),
        vec![MessageContent::text(command)],
    )
    .with_metadata(MessageMetadata::user_only());

    SessionManager::add_message(&session_id, &message).await?;

    Ok(())
}

pub async fn handle_term_run(prompt: Vec<String>) -> Result<()> {
    let prompt = prompt.join(" ");
    let session_id = std::env::var("ASTER_SESSION_ID").map_err(|_| {
        anyhow!(
            "ASTER_SESSION_ID not set.\n\n\
             Add to your shell config (~/.zshrc or ~/.bashrc):\n    \
             eval \"$(aster term init zsh)\"\n\n\
             Then restart your terminal or run: source ~/.zshrc"
        )
    })?;

    let working_dir = std::env::current_dir()?;

    SessionManager::update_session(&session_id)
        .working_dir(working_dir)
        .apply()
        .await?;

    let session = SessionManager::get_session(&session_id, true).await?;
    let user_messages_after_last_assistant: Vec<&Message> =
        if let Some(conv) = &session.conversation {
            conv.messages()
                .iter()
                .rev()
                .take_while(|m| m.role != Role::Assistant)
                .collect()
        } else {
            Vec::new()
        };

    if let Some(oldest_user) = user_messages_after_last_assistant.last() {
        SessionManager::truncate_conversation(&session_id, oldest_user.created).await?;
    }

    let prompt_with_context = if user_messages_after_last_assistant.is_empty() {
        prompt
    } else {
        let history = user_messages_after_last_assistant
            .iter()
            .rev() // back to chronological order
            .map(|m| m.as_concat_text())
            .collect::<Vec<_>>()
            .join("\n");

        format!(
            "<shell_history>\n{}\n</shell_history>\n\n{}",
            history, prompt
        )
    };

    let config = SessionBuilderConfig {
        session_id: Some(session_id),
        resume: true,
        interactive: false,
        quiet: true,
        ..Default::default()
    };

    let mut session = build_session(config).await;
    session.headless(prompt_with_context).await?;

    Ok(())
}

/// Handle `aster term info` - print compact session info for prompt integration
pub async fn handle_term_info() -> Result<()> {
    let session_id = match std::env::var("ASTER_SESSION_ID") {
        Ok(id) => id,
        Err(_) => return Ok(()),
    };

    let session = SessionManager::get_session(&session_id, false).await.ok();
    let total_tokens = session.as_ref().and_then(|s| s.total_tokens).unwrap_or(0) as usize;

    let config = aster::config::Config::global();
    let model_name = config
        .get_aster_model()
        .ok()
        .map(|name| {
            let short = name.rsplit('/').next().unwrap_or(&name);
            if let Some(stripped) = short.strip_prefix("aster-") {
                stripped.to_string()
            } else {
                short.to_string()
            }
        })
        .unwrap_or_else(|| "?".to_string());

    let context_limit = config
        .get_aster_model()
        .ok()
        .and_then(|model_name| aster::model::ModelConfig::new(&model_name).ok())
        .map(|mc| mc.context_limit())
        .unwrap_or(128_000);

    let percentage = if context_limit > 0 {
        ((total_tokens as f64 / context_limit as f64) * 100.0).round() as usize
    } else {
        0
    };

    let filled = (percentage / 20).min(5);
    let empty = 5 - filled;
    let dots = format!("{}{}", "●".repeat(filled), "○".repeat(empty));

    println!("{} {}", dots, model_name);

    Ok(())
}