// =-=-= lib.rs =-=-=
// Core routines and API for banzai

mod bwt;
mod crc32;
mod huffman;
mod mtf;
mod rle;

mod out;
use out::OutputStream;

use std::convert;
use std::fs;
use std::io;
use std::path;

fn write_stream_header<W: io::Write>(output: &mut OutputStream<W>, level: usize) -> io::Result<()> {
    assert!(1 <= level && level <= 9);
    let level_byte = char::from_digit(level as u32, 10).expect("1 <= level <= 9") as u8;
    output.write_bytes(&[0x42, 0x5A, 0x68, level_byte])
}

fn write_block_header<W: io::Write>(
    output: &mut OutputStream<W>,
    crc: u32,
    ptr: usize,
) -> io::Result<()> {
    output.write_bytes(&[0x31, 0x41, 0x59, 0x26, 0x53, 0x59])?;
    output.write_bytes(&crc.to_be_bytes())?;
    output.write_bits(0, 1)?;

    let ptr_bytes = ptr.to_be_bytes();
    let slice_left = ptr_bytes.len() - 3;
    output.write_bytes(&ptr.to_be_bytes()[slice_left..])
}

// All bzip2 blocks have a symbol map indicating which byte values are present in the BWT
fn write_sym_map<W: io::Write>(output: &mut OutputStream<W>, has_byte: &[bool]) -> io::Result<()> {
    let mut sector_map: u16 = 0;
    let mut sectors: Vec<u16> = vec![];

    for a in 0..16 {
        sector_map <<= 1;
        let mut sector = 0;
        for b in 0..16 {
            sector <<= 1;
            let byte = (a << 4) | b;
            if has_byte[byte] {
                sector |= 1;
            }
        }
        if sector != 0 {
            sector_map |= 1;
            sectors.push(sector);
        }
    }
    assert!(!sectors.is_empty());
    output.write_bytes(&sector_map.to_be_bytes())?;
    for s in sectors {
        output.write_bytes(&s.to_be_bytes())?;
    }
    Ok(())
}

fn write_stream_footer<W: io::Write>(output: &mut OutputStream<W>, crc: u32) -> io::Result<()> {
    /* 1.77245385090 is the square-root of pi, apparently */
    output.write_bytes(&[0x17, 0x72, 0x45, 0x38, 0x50, 0x90])?;
    output.write_bytes(&crc.to_be_bytes())
}

/// bzip2 encode an input stream and write the output to a `BufWriter`
///
/// `level` must be in `1..=9` and describes the block size.
/// That is: the block size is `level * 100_000`.
///
/// In principle, a smaller block size trades away some
/// compression performance for a shorter runtime. In practice,
/// the speedup is not very large, and you almost certainly
/// want level = 9.
///
/// Returns the number of input bytes encoded.

pub fn encode<R, W>(mut reader: R, writer: io::BufWriter<W>, level: usize) -> io::Result<usize>
where
    R: io::BufRead,
    W: io::Write,
{
    assert!(1 <= level && level <= 9);
    let mut output = OutputStream::new(writer);

    write_stream_header(&mut output, level)?;

    let mut stream_crc: u32 = 0;

    // Data that has been read from the reader but not yet encoded
    let mut raw = vec![];

    // Iteratively build blocks until we run out of input
    let mut consumed = 0;
    loop {
        let rle_out = rle::rle_one(&mut reader, raw, level)?;
        if rle_out.consumed == 0 {
            break;
        }

        /* bzip2's idiosyncratic cumulative checksum */
        stream_crc = rle_out.chk ^ ((stream_crc << 1) | (stream_crc >> 31));

        let bwt_out = bwt::bwt(rle_out.output);

        write_block_header(&mut output, rle_out.chk, bwt_out.ptr)?;
        write_sym_map(&mut output, &bwt_out.has_byte)?;

        let mtf_out = mtf::mtf_and_rle(bwt_out.bwt, bwt_out.has_byte);

        huffman::encode(&mut output, mtf_out)?;

        consumed += rle_out.consumed;

        /* if raw is None, then we reached EOF */
        raw = match rle_out.raw {
            None => break,
            Some(raw) => raw,
        };
    }

    write_stream_footer(&mut output, stream_crc)?;
    output.close()?;

    Ok(consumed)
}

/// bzip2 encode a file and write the output to another file
///
/// Returns the number of bytes encoded.
///
/// Use encode() instead of this if you want fine-grained
/// control over block-size or I/O streams.

pub fn encode_file<I, O>(in_path: I, out_path: O) -> io::Result<usize>
where
    I: convert::AsRef<path::Path>,
    O: convert::AsRef<path::Path>,
{
    let inf = fs::File::open(in_path.as_ref())?;
    let outf = fs::File::create(out_path.as_ref())?;

    let in_reader = io::BufReader::new(inf);
    let out_writer = io::BufWriter::new(outf);

    encode(in_reader, out_writer, 9)
}