mod events;
mod handler;
mod keybindings;
mod ui_commands;

use std::sync::{Arc, Mutex};
use std::process::Stdio;

use rmpv::Value;
use nvim_rs::{create::tokio as create, UiAttachOptions};
use tokio::runtime::Runtime;
use tokio::process::Command;
use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};

pub use events::*;
pub use keybindings::*;
pub use ui_commands::UiCommand;
use crate::editor::Editor;
use crate::error_handling::ResultPanicExplanation;
use handler::NeovimHandler;

#[cfg(target_os = "windows")]
fn set_windows_creation_flags(cmd: &mut Command) {
    cmd.creation_flags(0x08000000); // CREATE_NO_WINDOW
}

fn create_nvim_command() -> Command {
    let mut cmd = Command::new("nvim");

    cmd.arg("--embed")
        .args(std::env::args().skip(1))
        .stderr(Stdio::inherit());

    #[cfg(target_os = "windows")]
    set_windows_creation_flags(&mut cmd);

    cmd
}

pub async fn start_process(editor: Arc<Mutex<Editor>>, mut receiver: UnboundedReceiver<UiCommand>, grid_dimensions: (u64, u64)) {
    let (width, height) = grid_dimensions;
    let (mut nvim, io_handler, _) = create::new_child_cmd(&mut create_nvim_command(), NeovimHandler(editor)).await
        .unwrap_or_explained_panic("Could not create nvim process", "Could not locate or start the neovim process");

    tokio::spawn(async move {
        match io_handler.await {
            Err(join_error) => eprintln!("Error joining IO loop: '{}'", join_error),
            Ok(Err(error)) => eprintln!("Error: '{}'", error),
            Ok(Ok(())) => {}
        };
        std::process::exit(0);
    });

    nvim.set_var("neovide", Value::Boolean(true)).await
        .unwrap_or_explained_panic("Could not communicate.", "Could not communicate with neovim process");
    let mut options = UiAttachOptions::new();
    options.set_linegrid_external(true);
    options.set_rgb(true);
    nvim.ui_attach(width as i64, height as i64, &options).await
        .unwrap_or_explained_panic("Could not attach.", "Could not attach ui to neovim process");

    let nvim = Arc::new(nvim);
    loop {
        let mut commands = Vec::new();
        let mut resize_command = None;
        while let Ok(ui_command) = receiver.try_recv() {
            if let UiCommand::Resize { .. } = ui_command {
                resize_command = Some(ui_command);
            } else {
                commands.push(ui_command);
            }
        }
        if let Some(resize_command) = resize_command {
            commands.push(resize_command);
        }

        for ui_command in commands.into_iter() {
            ui_command.execute(&nvim).await;
        }
    }
}

pub struct Bridge {
    runtime: Runtime,
    sender: UnboundedSender<UiCommand>
}

impl Bridge {
    pub fn new(editor: Arc<Mutex<Editor>>, grid_dimensions: (u64, u64)) -> Bridge {
        let runtime = Runtime::new().unwrap();
        let (sender, receiver) = unbounded_channel::<UiCommand>();

        runtime.spawn(async move {
            start_process(editor, receiver, grid_dimensions).await;
        });

        Bridge { runtime, sender }
    }

    pub fn queue_command(&mut self, command: UiCommand) {
        self.sender.send(command);
    }
}