//! # Minimal gif encoder



use std::cmp::min;
use std::io;
use std::io::prelude::*;

use lzw;

use traits::{Parameter, WriteBytesExt};
use common::{Block, Frame, Extension, DisposalMethod};
use util;

/// Number of repetitions
pub enum Repeat {
    /// Finite number of repetitions
    Finite(u16),
    /// Infinite number of repetitions
    Infinite
}

impl<W: Write> Parameter<Encoder<W>> for Repeat {
    type Result = Result<(), io::Error>;
    fn set_param(self, this: &mut Encoder<W>) -> Self::Result {
        this.write_extension(ExtensionData::Repetitions(self))
    }
}

/// Extension data.
pub enum ExtensionData {
    /// Control extension. Use `ExtensionData::new_control_ext` to construct.
    Control { 
        /// Flags.
        flags: u8,
        /// Frame delay.
        delay: u16,
        /// Transparent index.
        trns: u8
    },
    /// Sets the number of repetitions
    Repetitions(Repeat)
}

impl ExtensionData {
    /// Constructor for control extension data.
    ///
    /// `delay` is given in units of 10 ms.
    pub fn new_control_ext(delay: u16, dispose: DisposalMethod, 
                           needs_user_input: bool, trns: Option<u8>) -> ExtensionData {
        let mut flags = 0;
        let trns = match trns {
            Some(trns) => {
                flags |= 1;
                trns as u8
            },
            None => 0
        };
        flags |= (needs_user_input as u8) << 1;
        flags |= (dispose as u8) << 2;
        ExtensionData::Control {
            flags: flags,
            delay: delay,
            trns: trns
        }
    }
}

struct BlockWriter<'a, W: Write + 'a> {
    w: &'a mut W,
    bytes: usize,
    buf: [u8; 0xFF]
}


impl<'a, W: Write + 'a> BlockWriter<'a, W> {
    fn new(w: &'a mut W) -> BlockWriter<'a, W> {
        BlockWriter {
            w: w,
            bytes: 0,
            buf: [0; 0xFF]
        }
    }
}

impl<'a, W: Write + 'a> Write for BlockWriter<'a, W> {

    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
        let to_copy = min(buf.len(), 0xFF - self.bytes);
        util::copy_memory(&buf[..to_copy], &mut self.buf[self.bytes..]);
        self.bytes += to_copy;
        if self.bytes == 0xFF {
            self.bytes = 0;
            try!(self.w.write_le(0xFFu8));
            try!(self.w.write_all(&self.buf));
        }
        Ok(to_copy)
    }
    fn flush(&mut self) -> io::Result<()> {
        return Err(io::Error::new(
            io::ErrorKind::Other,
            "Cannot flush a BlockWriter, use `drop` instead."
        ))
    }
}

impl<'a, W: Write + 'a> Drop for BlockWriter<'a, W> {

    #[cfg(feature = "raii_no_panic")]
    fn drop(&mut self) {
        if self.bytes > 0 {
            let _ = self.w.write_le(self.bytes as u8);
            let _ = self.w.write_all(&self.buf[..self.bytes]);    
        }
    }

    #[cfg(not(feature = "raii_no_panic"))]
    fn drop(&mut self) {
        if self.bytes > 0 {
            self.w.write_le(self.bytes as u8).unwrap();
            self.w.write_all(&self.buf[..self.bytes]).unwrap();    
        }
    }
}

/// GIF encoder.
pub struct Encoder<W: Write> {
    w: W,
    global_palette: bool,
    width: u16,
    height: u16
}

impl<W: Write> Encoder<W> {
    /// Creates a new encoder.
    ///
    /// `global_palette` gives the global color palette in the format `[r, g, b, ...]`,
    /// if no global palette shall be used an empty slice may be supplied.
    pub fn new(w: W, width: u16, height: u16, global_palette: &[u8]) -> io::Result<Self> {
        Encoder {
            w: w,
            global_palette: false,
            width: width,
            height: height
        }.write_global_palette(global_palette)
    }

    /// Writes the global color palette.
    pub fn write_global_palette(mut self, palette: &[u8]) -> io::Result<Self> {
        self.global_palette = true;
        let mut flags = 0;
        flags |= 0b1000_0000;
        let num_colors = palette.len() / 3;
        flags |= flag_size(num_colors);
        flags |= flag_size(num_colors) << 4; // wtf flag
        try!(self.write_screen_desc(flags));
        try!(self.write_color_table(palette));
        Ok(self)
    }

    /// Writes a frame to the image.
    ///
    /// Note: This function also writes a control extension if necessary.
    pub fn write_frame(&mut self, frame: &Frame) -> io::Result<()> {
        // TODO commented off to pass test in lib.rs
        //if frame.delay > 0 || frame.transparent.is_some() {
            try!(self.write_extension(ExtensionData::new_control_ext(
                frame.delay,
                frame.dispose,
                frame.needs_user_input,
                frame.transparent

            )));
        //}
        try!(self.w.write_le(Block::Image as u8));
        try!(self.w.write_le(frame.left));
        try!(self.w.write_le(frame.top));
        try!(self.w.write_le(frame.width));
        try!(self.w.write_le(frame.height));
        let mut flags = 0;
        if frame.interlaced {
            flags |= 0b0100_0000;
        }
        try!(match frame.palette {
            Some(ref palette) => {
                flags |= 0b1000_0000;
                let num_colors = palette.len() / 3;
                flags |= flag_size(num_colors);
                try!(self.w.write_le(flags));
                self.write_color_table(palette)
            },
            None => if !self.global_palette {
                return Err(io::Error::new(
                    io::ErrorKind::InvalidInput,
                    "The GIF format requires a color palette but none was given."
                ))
            } else {
                self.w.write_le(flags)
            }
        });
        self.write_image_block(&frame.buffer)
    }

    fn write_image_block(&mut self, data: &[u8]) -> io::Result<()> {
        {
            let min_code_size: u8 = match flag_size((*data.iter().max().unwrap_or(&0) as usize + 1)) + 1 {
                1 => 2, // As per gif spec: The minimal code size has to be >= 2
                n => n
            };
            try!(self.w.write_le(min_code_size));
            let mut bw = BlockWriter::new(&mut self.w);
            let mut enc = try!(lzw::Encoder::new(lzw::LsbWriter::new(&mut bw), min_code_size));
            try!(enc.encode_bytes(data));
        }
        self.w.write_le(0u8)
    }

    fn write_color_table(&mut self, table: &[u8]) -> io::Result<()> {
        let num_colors = table.len() / 3;
        let size = flag_size(num_colors);
        try!(self.w.write_all(&table[..num_colors * 3]));
        // Waste some space as of gif spec
        for _ in 0..((2 << size) - num_colors) {
            try!(self.w.write_all(&[0, 0, 0]))
        }
        Ok(())
    }

    /// Writes an extension to the image.
    ///
    /// It is normally not necessary to call this method manually.
    pub fn write_extension(&mut self, extension: ExtensionData) -> io::Result<()> {
        use self::ExtensionData::*;
        // 0 finite repetitions can only be achieved
        // if the corresponting extension is not written
        if let Repetitions(Repeat::Finite(0)) = extension {
            return Ok(())
        }
        try!(self.w.write_le(Block::Extension as u8));
        match extension {
            Control { flags, delay, trns } => {
                try!(self.w.write_le(Extension::Control as u8));
                try!(self.w.write_le(4u8));
                try!(self.w.write_le(flags));
                try!(self.w.write_le(delay));
                try!(self.w.write_le(trns));
            }
            Repetitions(repeat) => {
                try!(self.w.write_le(Extension::Application as u8));
                try!(self.w.write_le(11u8));
                try!(self.w.write(b"NETSCAPE2.0"));
                try!(self.w.write_le(3u8));
                try!(self.w.write_le(1u8));
                match repeat {
                    Repeat::Finite(no) => try!(self.w.write_le(no)),
                    Repeat::Infinite => try!(self.w.write_le(0u16)),
                }
            }
        }
        self.w.write_le(0u8)
    }

    /// Writes a raw extension to the image.
    ///
    /// This method can be used to write an unsupported extesion to the file. `func` is the extension 
    /// identifier (e.g. `Extension::Application as u8`). `data` are the extension payload blocks. If any
    /// contained slice has a lenght > 255 it is automatically divided into sub-blocks.
    pub fn write_raw_extension(&mut self, func: u8, data: &[&[u8]]) -> io::Result<()> {
        try!(self.w.write_le(Block::Extension as u8));
        try!(self.w.write_le(func as u8));
        for block in data {
            for chunk in block.chunks(0xFF) {
                try!(self.w.write_le(chunk.len() as u8));
                try!(self.w.write_all(chunk));
            }
        }
        self.w.write_le(0u8)
    }

    /// Writes the logical screen desriptor
    fn write_screen_desc(&mut self, flags: u8) -> io::Result<()> {
        try!(self.w.write_all(b"GIF89a"));
        try!(self.w.write_le(self.width));
        try!(self.w.write_le(self.height));
        try!(self.w.write_le(flags)); // packed field
        try!(self.w.write_le(0u8)); // bg index
        self.w.write_le(0u8) // aspect ratio
    }
}

impl<W: Write> Drop for Encoder<W> {

    #[cfg(feature = "raii_no_panic")]
    fn drop(&mut self) {
        let _ = self.w.write_le(Block::Trailer as u8);
    }

    #[cfg(not(feature = "raii_no_panic"))]
    fn drop(&mut self) {
        self.w.write_le(Block::Trailer as u8).unwrap()
    }
}

// Color table size converted to flag bits
fn flag_size(size: usize) -> u8 {
    match size {
        0  ...2   => 0,
        3  ...4   => 1,
        5  ...8   => 2,
        7  ...16  => 3,
        17 ...32  => 4,
        33 ...64  => 5,
        65 ...128 => 6,
        129...256 => 7,
        _ => 7
    }
}