use std::io::{self, Write};
use ::parse_code;
use ll;
struct EncoderContext {
s: *mut ll::ZSTD_CStream,
}
impl Default for EncoderContext {
fn default() -> Self {
EncoderContext { s: unsafe { ll::ZSTD_createCStream() } }
}
}
impl Drop for EncoderContext {
fn drop(&mut self) {
let code = unsafe { ll::ZSTD_freeCStream(self.s) };
parse_code(code).unwrap();
}
}
pub struct Encoder<W: Write> {
writer: W,
buffer: Vec<u8>,
context: EncoderContext,
}
pub struct AutoFinishEncoder<W: Write> {
encoder: Option<Encoder<W>>,
on_finish: Option<Box<FnMut(io::Result<W>)>>,
}
impl<W: Write> AutoFinishEncoder<W> {
fn new<F: 'static + FnMut(io::Result<W>)>(encoder: Encoder<W>,
on_finish: F)
-> Self {
AutoFinishEncoder {
encoder: Some(encoder),
on_finish: Some(Box::new(on_finish)),
}
}
}
impl<W: Write> Drop for AutoFinishEncoder<W> {
fn drop(&mut self) {
let result = self.encoder.take().unwrap().finish();
if let Some(mut on_finish) = self.on_finish.take() {
on_finish(result);
}
}
}
impl<W: Write> Write for AutoFinishEncoder<W> {
fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
self.encoder.as_mut().unwrap().write(buf)
}
fn flush(&mut self) -> io::Result<()> {
self.encoder.as_mut().unwrap().flush()
}
}
impl<W: Write> Encoder<W> {
pub fn new(writer: W, level: i32) -> io::Result<Self> {
Self::with_dictionary(writer, level, &[])
}
pub fn with_dictionary(writer: W, level: i32, dictionary: &[u8])
-> io::Result<Self> {
let context = EncoderContext::default();
try!(parse_code(unsafe {
ll::ZSTD_initCStream_usingDict(context.s,
dictionary.as_ptr(),
dictionary.len(),
level)
}));
Encoder::with_context(writer, context)
}
pub fn auto_finish(self) -> AutoFinishEncoder<W> {
self.on_finish(|result| {
result.unwrap();
})
}
pub fn on_finish<F: 'static + FnMut(io::Result<W>)>
(self, f: F)
-> AutoFinishEncoder<W> {
AutoFinishEncoder::new(self, f)
}
fn with_context(writer: W, context: EncoderContext) -> io::Result<Self> {
let buffer_size = unsafe { ll::ZSTD_CStreamOutSize() };
Ok(Encoder {
writer: writer,
buffer: Vec::with_capacity(buffer_size),
context: context,
})
}
pub fn finish(mut self) -> io::Result<W> {
let mut buffer = ll::ZSTD_outBuffer {
dst: self.buffer.as_mut_ptr(),
size: self.buffer.capacity(),
pos: 0,
};
let remaining = try!(parse_code(unsafe {
ll::ZSTD_endStream(self.context.s,
&mut buffer as *mut ll::ZSTD_outBuffer)
}));
unsafe {
self.buffer.set_len(buffer.pos);
}
if remaining != 0 {
panic!("Need to flush, but I'm lazy.");
}
try!(self.writer.write_all(&self.buffer));
Ok(self.writer)
}
pub fn recommended_input_size() -> usize {
unsafe { ll::ZSTD_CStreamInSize() }
}
}
impl<W: Write> Write for Encoder<W> {
fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
let mut in_buffer = ll::ZSTD_inBuffer {
src: buf.as_ptr(),
size: buf.len(),
pos: 0,
};
let mut out_buffer = ll::ZSTD_outBuffer {
dst: self.buffer.as_mut_ptr(),
size: self.buffer.capacity(),
pos: 0,
};
while in_buffer.pos != buf.len() {
out_buffer.pos = 0;
unsafe {
let code = ll::ZSTD_compressStream(self.context.s,
&mut out_buffer as *mut ll::ZSTD_outBuffer,
&mut in_buffer as *mut ll::ZSTD_inBuffer);
self.buffer.set_len(out_buffer.pos);
let _ = try!(parse_code(code));
}
try!(self.writer.write_all(&self.buffer));
}
Ok(in_buffer.pos)
}
fn flush(&mut self) -> io::Result<()> {
let mut buffer = ll::ZSTD_outBuffer {
dst: self.buffer.as_mut_ptr(),
size: self.buffer.capacity(),
pos: 0,
};
unsafe {
let code =
ll::ZSTD_flushStream(self.context.s,
&mut buffer as *mut ll::ZSTD_outBuffer);
self.buffer.set_len(buffer.pos);
let _ = try!(parse_code(code));
}
try!(self.writer.write_all(&self.buffer));
Ok(())
}
}