gex 0.6.3

//! This module relates to the message buffer that appears on the bottom of the screen after
//! certain actions are performed and handles the arbitrary git command functionality.

use std::{
    env,
    io::{stdout, Write},
    process::{Command, Output},
    str,
};

use anyhow::{Context, Result};
use crossterm::{
    cursor::{self, SetCursorStyle},
    event::{self, Event, KeyCode, KeyEventKind, KeyModifiers},
    style::SetForegroundColor,
    terminal::{self, ClearType},
};
use itertools::Itertools;

use crate::{config::CONFIG, git_process, render::Clear};

#[derive(Default)]
pub struct MiniBuffer {
    /// The messages to be sent are maintained in this struct as a stack.
    messages: Vec<(String, MessageType)>,
    /// The current height of the buffer, including the border.
    current_height: usize,
    /// History of commands sent via `:`.
    git_command_history: Vec<String>,
    /// History of commands sent via `!`.
    command_history: Vec<String>,
}

pub enum MessageType {
    Note,
    Error,
}

impl MiniBuffer {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn is_empty(&self) -> bool {
        self.messages.is_empty()
    }

    /// Push a new message onto the message stack.
    pub fn push(&mut self, msg: &str, msg_type: MessageType) {
        if !msg.is_empty() {
            self.messages.push((msg.trim().to_string(), msg_type));
        }
    }

    pub fn push_command_output(&mut self, output: &Output) {
        match str::from_utf8(&output.stdout) {
            Ok(s) => self.push(s, MessageType::Note),
            Err(e) => self.push(
                &format!("Received invalid UTF8 stdout from git: {e}"),
                MessageType::Error,
            ),
        }
        match str::from_utf8(&output.stderr) {
            Ok(s) => self.push(s, MessageType::Error),
            Err(e) => self.push(
                &format!("Received invalid UTF8 stderr from git: {e}"),
                MessageType::Error,
            ),
        }
    }

    fn take_input<'a>(
        prompt: &str,
        term_width: u16,
        term_height: u16,
        history: &'a mut Vec<String>,
    ) -> Option<&'a str> {
        let mut input_buffer = String::new();
        let mut cursor = 0;
        let mut history_cursor = 0;
        loop {
            print!(
                "{}{}\r\n{}{prompt}{command}{}{}",
                cursor::MoveTo(0, term_height - 2),
                "\u{2574}".repeat(term_width.into()),
                Clear(ClearType::CurrentLine),
                cursor::MoveToColumn(cursor + prompt.len() as u16),
                if input_buffer.len() == cursor.into() {
                    SetCursorStyle::DefaultUserShape
                } else {
                    SetCursorStyle::SteadyBar
                },
                command = input_buffer
            );
            drop(stdout().flush());

            // TODO: ideally I'd like to refactor it such that all the inputs are received in the
            // same place as everywhere else (currently in `main.rs`). This would solve other minor
            // issues like the minibuffer not adjusting when the terminal font is increased. This
            // could probably be achieved by having the minibuffer be a `View`.
            if let Event::Key(key_event) = event::read().expect("failed to read a terminal event") {
                if key_event.kind == KeyEventKind::Release {
                    continue;
                }
                match (key_event.code, key_event.modifiers) {
                    (KeyCode::Enter, _) => break,
                    (KeyCode::Left, _) | (KeyCode::Char('b'), KeyModifiers::CONTROL) => {
                        cursor = cursor.saturating_sub(1);
                    }
                    (KeyCode::Right, _) | (KeyCode::Char('f'), KeyModifiers::CONTROL) => {
                        if (cursor as usize) < input_buffer.len() {
                            cursor += 1;
                        }
                    }
                    (KeyCode::Up, _) | (KeyCode::Char('p'), KeyModifiers::CONTROL) => {
                        if history_cursor < history.len() {
                            history_cursor += 1;
                            history[history.len() - history_cursor].clone_into(&mut input_buffer);
                            cursor = input_buffer.len() as u16;
                        }
                    }
                    (KeyCode::Down, _) | (KeyCode::Char('n'), KeyModifiers::CONTROL) => {
                        history_cursor = history_cursor.saturating_sub(1);
                        if history_cursor == 0 {
                            input_buffer.clear();
                        } else {
                            history[history.len() - history_cursor].clone_into(&mut input_buffer);
                        }
                        cursor = input_buffer.len() as u16;
                    }
                    (KeyCode::Home, _) => cursor = 0,
                    (KeyCode::End, _) => cursor = input_buffer.len() as u16,
                    (KeyCode::Char('b'), KeyModifiers::ALT) => {
                        while cursor > 0 {
                            cursor = cursor.saturating_sub(1);
                            if word_boundary(&input_buffer, cursor as usize) {
                                break;
                            }
                        }
                    }
                    (KeyCode::Char('f'), KeyModifiers::ALT) => {
                        while cursor < input_buffer.len() as u16 {
                            cursor += 1;
                            if word_boundary(&input_buffer, cursor as usize) {
                                break;
                            }
                        }
                    }
                    (KeyCode::Char(c), _) => {
                        input_buffer.insert(cursor.into(), c);
                        cursor += 1;
                    }
                    (KeyCode::Backspace, _) => {
                        if cursor > 0 {
                            cursor -= 1;
                            input_buffer.remove(cursor.into());
                        }
                    }
                    (KeyCode::Delete, _) => {
                        if (cursor as usize) < input_buffer.len()
                            || cursor == 0 && input_buffer.len() == 1
                        {
                            input_buffer.remove(cursor.into());
                        } else if !input_buffer.is_empty() {
                            input_buffer.pop();
                            cursor -= 1;
                        }
                    }
                    (KeyCode::Esc, _) => {
                        input_buffer.clear();
                        break;
                    }
                    _ => {}
                }
            }
        }
        (!input_buffer.is_empty()).then(|| {
            history.push(input_buffer);
            history.last().expect("we just pushed an elem").as_str()
        })
    }

    /// Call to enter command mode. It will be exited automatically in the render call after the
    /// command is sent.
    pub fn command(&mut self, term_width: u16, term_height: u16, git_cmd: bool) -> Result<()> {
        // Clear the git output, if there is any.
        print!(
            "{}{}{}",
            cursor::MoveTo(0, term_height.saturating_sub(self.current_height as u16)),
            Clear(ClearType::FromCursorDown),
            cursor::Show,
        );

        let (prompt, history) = if git_cmd {
            (":git ", &mut self.git_command_history)
        } else {
            ("!", &mut self.command_history)
        };
        let cmd = Self::take_input(prompt, term_width, term_height, history);

        crossterm::execute!(stdout(), cursor::MoveToColumn(0))?;
        terminal::disable_raw_mode().context("failed to disable raw mode")?;
        if let Some(cmd) = cmd {
            let cmd_output = if git_cmd {
                let output = git_process(&cmd.split_whitespace().collect::<Vec<_>>());
                Some(output)
            } else {
                // TODO: lazy_static the shell or something.
                let output = env::var("SHELL").map_or_else(
                    |_| {
                        let mut words = cmd.split_whitespace();
                        words
                            .next()
                            .map(|cmd| Command::new(cmd).args(words).output())
                    },
                    |sh| Some(Command::new(sh).args(["-c", cmd]).output()),
                );

                output.map(|o| o.context("failed to run command"))
            };
            match cmd_output {
                Some(Ok(cmd_output)) => self.push_command_output(&cmd_output),
                Some(Err(e)) => self.push(&format!("{e:?}"), MessageType::Error),
                None => {}
            }
        }
        terminal::enable_raw_mode().context("failed to enable raw mode")?;

        print!("{}", cursor::Hide);
        Ok(())
    }

    /// Render the most recent unsent message.
    pub fn render(&mut self, term_width: u16, term_height: u16) -> Result<()> {
        let Some((msg, msg_type)) = self.messages.pop() else {
            self.current_height = 0;
            return Ok(());
        };
        let config = CONFIG.get().expect("config wasn't initialised");
        // Make sure raw mode is disabled so we can just print the message.
        terminal::disable_raw_mode().context("failed to exit raw mode")?;
        self.current_height = msg.lines().count() + 1;
        match msg_type {
            MessageType::Note => print!(
                "{}{}\n{msg}",
                cursor::MoveTo(0, term_height.saturating_sub(self.current_height as u16)),
                "─".repeat(term_width.into()),
            ),
            MessageType::Error => print!(
                "{}{}\n{}{msg}{}",
                cursor::MoveTo(0, term_height.saturating_sub(self.current_height as u16)),
                "─".repeat(term_width.into()),
                SetForegroundColor(config.colors.error),
                SetForegroundColor(config.colors.foreground),
            ),
        }
        terminal::enable_raw_mode().context("failed to enable raw mode")?;
        drop(stdout().flush());
        Ok(())
    }
}

/// Checks if idx is on an Emacs-style word boundary in the buffer.
/// <https://www.gnu.org/software/emacs/manual/html_node/elisp/Syntax-Class-Table.html>
fn word_boundary(buffer: &str, idx: usize) -> bool {
    buffer
        .chars()
        .tuple_windows()
        .nth(idx.saturating_sub(1))
        .map_or(true, |(c1, c2)| {
            !c1.is_alphanumeric() && c2.is_alphanumeric()
        })
}