pic 0.1.4

use crate::{result::Result, support};
use ansi_colours::ansi256_from_rgb;
use crossbeam_channel::{unbounded, Receiver, Sender};
use image::{codecs::png::PngEncoder, DynamicImage, ImageEncoder};
use std::{
    fs::File,
    io::{Error, Write},
    path::PathBuf,
};

pub(crate) struct CtrlcHandler {
    pub sender: Sender<bool>,
    pub receiver: Receiver<bool>,
}

impl CtrlcHandler {
    pub fn new() -> Result<Self> {
        // We use two channels so that they can communicate
        let (ctrlc_tx, preview_rx) = unbounded();
        let (preview_tx, ctrlc_rx) = unbounded();

        ctrlc::set_handler(move || {
            ctrlc_tx
                .send(true)
                .expect("CTRL-C error: Unable to send message");

            ctrlc_rx
                .recv()
                .expect("CTRL-C error: No response from main thread");
            std::process::exit(0);
        })?;

        Ok(Self {
            sender: preview_tx,
            receiver: preview_rx,
        })
    }
}

/// Useful handle for terminal size
#[derive(Clone, Default, Debug)]
pub struct TermSize {
    /// the amount of visible rows in the pty
    pub(crate) rows: u32,
    /// the amount of visible columns in the pty
    pub(crate) cols: u32,
    /// the width of the view in pixels
    pub(crate) width: u32,
    /// the height of the view in pixels
    pub(crate) height: u32,
}

impl TermSize {
    pub fn new(rows: u16, cols: u16, width: u16, height: u16) -> Self {
        Self {
            rows: u32::from(rows),
            cols: u32::from(cols),
            width: u32::from(width),
            height: u32::from(height),
        }
    }

    /// Retrieve the size of a terminal cell
    pub fn get_cell_size(&self) -> Option<(u32, u32)> {
        if self.cols == 0 || self.rows == 0 {
            return None;
        }
        Some((self.width / self.cols, self.height / self.rows))
    }

    /// Create TermSize by getting the terminal size with an IOCTL
    pub fn from_ioctl() -> Result<Self> {
        // TODO: find a way to make that safe
        unsafe {
            let mut ws = libc::winsize {
                ws_row: 0,
                ws_col: 0,
                ws_xpixel: 0,
                ws_ypixel: 0,
            };
            let ret = libc::ioctl(0, libc::TIOCGWINSZ, &mut ws);
            if ret == 0 {
                Ok(TermSize::new(
                    ws.ws_row,
                    ws.ws_col,
                    ws.ws_xpixel,
                    ws.ws_ypixel,
                ))
            } else {
                Err(Error::last_os_error().into())
            }
        }
    }
}

/// Create a temporary file with the given prefix
pub fn create_temp_file(prefix: &str) -> Result<(File, PathBuf)> {
    let (tempfile, pathbuf) = tempfile::Builder::new()
        .prefix(prefix)
        .tempfile_in("/tmp/")?
        .keep()?;

    Ok((tempfile, pathbuf))
}

/// Save buffer in a temporary file
pub fn save_in_temp_file(buffer: &[u8], file: &mut File) -> Result {
    file.write_all(buffer)?;
    file.flush()?;
    Ok(())
}

/// Save terminal cursor position
#[allow(dead_code)]
pub fn save_cursor(stdout: &mut impl Write) -> Result {
    stdout.write_all(b"\x1b[s")?;
    stdout.flush()?;
    Ok(())
}

/// Restore terminal cursor position
#[allow(dead_code)]
pub fn restore_cursor(stdout: &mut impl Write) -> Result {
    stdout.write_all(b"\x1b[u")?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor up
#[allow(dead_code)]
pub fn move_cursor_up(stdout: &mut impl Write, x: u32) -> Result {
    let binding = format!("\x1b[{}A", x + 1);
    stdout.write_all(binding.as_bytes())?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor down
#[allow(dead_code)]
pub fn move_cursor_down(stdout: &mut impl Write, x: u32) -> Result {
    let binding = format!("\x1b[{}B", x + 1);
    stdout.write_all(binding.as_bytes())?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor to the given column
pub fn move_cursor_column(stdout: &mut impl Write, col: u32) -> Result {
    let binding = format!("\x1b[{}G", col + 1);
    stdout.write_all(binding.as_bytes())?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor to the given row
pub fn move_cursor_row(stdout: &mut impl Write, row: u32) -> Result {
    let binding = format!("\x1b[{}d", row + 1);
    stdout.write_all(binding.as_bytes())?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor to the given position
pub fn move_cursor_pos(stdout: &mut impl Write, col: u32, row: u32) -> Result {
    let binding = format!("\x1b[{};{}H", row + 1, col + 1);
    stdout.write_all(binding.as_bytes())?;
    stdout.flush()?;
    Ok(())
}

/// Move terminal cursor eventually given x and y
pub fn move_cursor(stdout: &mut impl Write, col: Option<u32>, row: Option<u32>) -> Result {
    match (col, row) {
        (None, None) => Ok(()),
        (Some(x), None) => move_cursor_column(stdout, x),
        (None, Some(y)) => move_cursor_row(stdout, y),
        (Some(x), Some(y)) => move_cursor_pos(stdout, x, y),
    }
}

/// Show terminal cursor
pub fn show_cursor(stdout: &mut impl Write) -> Result {
    stdout.write_all(b"\x1b[?25h")?;
    stdout.flush()?;
    Ok(())
}

/// Hide terminal cursor
pub fn hide_cursor(stdout: &mut impl Write) -> Result {
    stdout.write_all(b"\x1b[?25l")?;
    stdout.flush()?;
    Ok(())
}

/// Handle spacing between images
pub fn handle_spacing(stdout: &mut impl Write, spacing: Option<u32>) -> Result {
    if let Some(spacing) = spacing {
        stdout.write_all(&b"\n".repeat(spacing as usize))?;
        stdout.flush()?;
    }
    Ok(())
}

/// Fit an images into cols and rows bounds
pub fn fit_in_bounds(
    width: u32,
    height: u32,
    cols: Option<u32>,
    rows: Option<u32>,
    upscale: bool,
) -> Result<(u32, u32)> {
    let term_size = TermSize::from_ioctl()?;
    let (col_size, row_size) = match term_size.get_cell_size() {
        Some((0, 0)) | None => (15, 30),
        Some((c, r)) => (c, r),
    };
    let cols = cols.unwrap_or(term_size.cols);
    // Terminal prompt puts the image out of screen (rows - 1)
    let rows = rows.unwrap_or(term_size.rows - 1);

    let (bound_width, bound_height) = (cols * col_size, rows * row_size);

    if !upscale && width < bound_width && height < bound_height {
        return Ok((width / col_size, height / row_size));
    }

    let w_ratio = width * bound_height;
    let h_ratio = bound_width * height;

    if w_ratio >= h_ratio {
        Ok((
            cols,
            std::cmp::max((height * bound_width) / (width * row_size), 1),
        ))
    } else {
        Ok((
            std::cmp::max((width * bound_height) / (height * col_size), 1),
            rows,
        ))
    }
}

/// Resize an image
pub fn resize(image: &DynamicImage, width: u32, height: u32) -> DynamicImage {
    image.resize_exact(width, height, image::imageops::Triangle)
}

/// Convert an image to a png buffer
/// image is mainly supposed to be a GIF here
pub fn convert_to_image_buffer(image: &DynamicImage, width: u32, height: u32) -> Result<Vec<u8>> {
    let mut image_buffer = Vec::new();
    PngEncoder::new(&mut image_buffer).write_image(
        image.as_bytes(),
        width,
        height,
        image.color(),
    )?;
    Ok(image_buffer)
}

/// Assess the transparency of a pixel
pub fn pixel_is_transparent(rgb: [u8; 4]) -> bool {
    rgb[3] < 25
}

/// Convert rgb to ansi_rgb
pub fn ansi_rgb(rgb: [u8; 4], bg: bool) -> String {
    if bg {
        format!("\x1b[48;2;{};{};{}m", rgb[0], rgb[1], rgb[2])
    } else {
        format!("\x1b[38;2;{};{};{}m", rgb[0], rgb[1], rgb[2])
    }
}

/// Convert rgb to ansi_indexed
pub fn ansi_indexed(rgb: [u8; 4], bg: bool) -> String {
    let index = ansi256_from_rgb((rgb[0], rgb[1], rgb[2]));
    if bg {
        format!("\x1b[48;5;{index}m")
    } else {
        format!("\x1b[38;5;{index}m")
    }
}

/// Convert rgb to ansi
pub fn ansi_color(rgb: [u8; 4], bg: bool) -> String {
    if support::truecolor() {
        ansi_rgb(rgb, bg)
    } else {
        ansi_indexed(rgb, bg)
    }
}