lzo.go

package lzo

import (
	"bytes"
	"encoding/binary"
	"errors"
	"fmt"
	"hash"
	"hash/adler32"
	"hash/crc32"
	"io"
	"time"
	"unsafe"
)

const (
	// BestSpeed provides speed over better compression.
	BestSpeed = 3
	// BestCompression provides better compression over speed.
	BestCompression    = 9
	defaultCompression = -1
	version            = 0x1030
	flagAdler32D       = 1 << 0
	flagAdler32C       = 1 << 1
	flagStdin          = 1 << 2
	flagStdout         = 1 << 3
	flagNameDefault    = 1 << 4
	flagDosish         = 1 << 5
	flagExtra          = 1 << 6
	flagGmtDiff        = 1 << 7
	flagCRC32D         = 1 << 8
	flagCRC32C         = 1 << 9
	flagMultipart      = 1 << 10
	flagFilter         = 1 << 11
	flagCRC32          = 1 << 12
	flagPath           = 1 << 13
	flagMask           = 1 << 14
)

var (
	lzoMagic  = []byte{0x89, 0x4c, 0x5a, 0x4f, 0x00, 0x0d, 0x0a, 0x1a, 0x0a}
	lzoErrors = []string{
		1: "data corrupted",
		2: "out of memory",
		4: "input overrun",
		5: "output overrun",
		6: "data corrupted",
		7: "eof not found",
		8: "input not consumed",
	}
)

func init() {
	if err := C.lzo_initialize(); err != 0 {
		panic("lzo: can't initialize")
	}
}

type errno int

func (e errno) Error() string {
	if 0 <= int(e) && int(e) < len(lzoErrors) {
		s := lzoErrors[e]
		if s != "" {
			return fmt.Sprintf("lzo: %s", s)
		}
	}
	return fmt.Sprintf("lzo: errno %d", int(e))
}

// Header metadata about the compressed file.
// This header is exposed as the fields of the Writer and Reader structs.
type Header struct {
	ModTime time.Time
	Name    string
	flags   uint32
}

// A Reader is an io.Reader that can be read to retrieve
// uncompressed data from a lzop-format compressed file.
type Reader struct {
	Header
	r       io.Reader
	buf     [512]byte
	hist    []byte
	adler32 hash.Hash32
	crc32   hash.Hash32
	err     error
}

// NewReader creates a new Reader reading the given reader.
func NewReader(r io.Reader) (*Reader, error) {
	z := new(Reader)
	z.adler32 = adler32.New()
	z.crc32 = crc32.NewIEEE()
	z.r = io.TeeReader(r, io.MultiWriter(z.adler32, z.crc32))
	if err := z.readHeader(); err != nil {
		return nil, err
	}
	return z, nil
}

func (z *Reader) readHeader() error {
	// Read and check magic
	if _, err := io.ReadFull(z.r, z.buf[0:len(lzoMagic)]); err != nil {
		return err
	}
	if !bytes.Equal(z.buf[0:len(lzoMagic)], lzoMagic) {
		return errors.New("lzo: invalid header")
	}
	z.crc32.Reset()
	z.adler32.Reset()
	// Read version
	var version uint16
	if err := z.read(&version); err != nil {
		return err
	}
	if version < 0x0900 {
		return errors.New("lzo: invalid header")
	}
	// Read library version needed to extract
	var libraryVersion uint16
	if err := z.read(&libraryVersion); err != nil {
		return err
	}
	if version >= 0x0940 {
		if err := z.read(&libraryVersion); err != nil {
			return err
		}
		if libraryVersion > version {
			return errors.New("lzo: incompatible version")
		}
		if libraryVersion < 0x0900 {
			return errors.New("lzo: invalid header")
		}
	}
	// Read method
	var method uint8
	if err := z.read(&method); err != nil {
		return err
	}
	// Read level
	if version >= 0x0940 {
		var level uint8
		if err := z.read(&level); err != nil {
			return err
		}
	}
	// Read flags
	if err := z.read(&z.flags); err != nil {
		return err
	}
	// Read filters
	if z.flags&flagFilter != 0 {
		var filters uint32
		if err := z.read(&filters); err != nil {
			return err
		}
	}
	// Read mode
	var mode uint32
	if err := z.read(&mode); err != nil {
		return err
	}
	// Read modification times
	var modTime, modTimeHigh uint32
	if err := z.read(&modTime); err != nil {
		return err
	}
	z.ModTime = time.Unix(int64(modTime), 0)
	// Read mod time high
	if version >= 0x0940 {
		if err := z.read(&modTimeHigh); err != nil {
			return err
		}
	}
	if version < 0x0120 {
		z.ModTime = time.Unix(0, 0)
	}
	// Read name
	var l uint8
	if err := z.read(&l); err != nil {
		return err
	}
	if l > 0 {
		if _, err := io.ReadFull(z.r, z.buf[0:l]); err != nil {
			return err
		}
		z.Name = string(z.buf[0:l])
	}
	// Read and check header checksum
	var checksum uint32
	if z.flags&flagCRC32 != 0 {
		checksum = z.crc32.Sum32()
		z.crc32.Reset()
	} else {
		checksum = z.adler32.Sum32()
		z.adler32.Reset()
	}
	var checksumHeader uint32
	if err := z.read(&checksumHeader); err != nil {
		return err
	}
	if checksumHeader != checksum {
		return errors.New("lzo: invalid header")
	}
	if method <= 0 {
		return errors.New("lzo: incompatible method")
	}
	return nil
}

func (z *Reader) read(data interface{}) error {
	return binary.Read(z.r, binary.BigEndian, data)
}

func (z *Reader) nextBlock() {
	// Read uncompressed block size
	var dstLen uint32
	z.err = z.read(&dstLen)
	if z.err != nil {
		return
	}
	if dstLen == 0 {
		z.err = io.EOF
		return
	}
	// Read compressed block size
	var srcLen uint32
	z.err = z.read(&srcLen)
	if z.err != nil {
		return
	}
	if srcLen <= 0 || srcLen > dstLen {
		z.err = errors.New("lzo: data corruption")
		return
	}
	// Read checksum of uncompressed block
	var dstChecksum uint32
	if z.flags&flagAdler32D != 0 {
		z.err = z.read(&dstChecksum)
		if z.err != nil {
			return
		}
	}
	if z.flags&flagCRC32D != 0 {
		z.err = z.read(&dstChecksum)
		if z.err != nil {
			return
		}
	}
	// Read checksum of compressed block
	var srcChecksum uint32
	if z.flags&flagAdler32C != 0 {
		if srcLen < dstLen {
			z.err = z.read(&srcChecksum)
			if z.err != nil {
				return
			}
		} else {
			srcChecksum = dstChecksum
		}
	}
	if z.flags&flagCRC32C != 0 {
		if srcLen < dstLen {
			z.err = z.read(&srcChecksum)
			if z.err != nil {
				return
			}
		} else {
			srcChecksum = dstChecksum
		}
	}
	// Read block
	block := make([]byte, srcLen)
	_, z.err = io.ReadFull(z.r, block)
	if z.err != nil {
		return
	}
	// Verify compressed block checksum
	if z.flags&flagAdler32C != 0 {
		z.adler32.Reset()
		z.adler32.Write(block)
		if srcChecksum != z.adler32.Sum32() {
			z.err = errors.New("lzo: data corruption")
			return
		}
	}
	if z.flags&flagCRC32C != 0 {
		z.crc32.Reset()
		z.crc32.Write(block)
		if srcChecksum != z.crc32.Sum32() {
			z.err = errors.New("lzo: data corruption")
			return
		}
	}
	// Decompress
	data := make([]byte, dstLen)
	if srcLen < dstLen {
		br := NewReader(block)
		_, z.err = Decompress1X(br, srcLen, data)
		if z.err != nil {
			return
		}
	} else {
		copy(data, block)
	}
	// Verify uncompressed block checksum
	if z.flags&flagAdler32D != 0 {
		z.adler32.Reset()
		z.adler32.Write(data)
		if dstChecksum != z.adler32.Sum32() {
			z.err = errors.New("lzo: data corruption")
			return
		}
	}
	if z.flags&flagCRC32D != 0 {
		z.crc32.Reset()
		z.crc32.Write(data)
		if dstChecksum != z.crc32.Sum32() {
			z.err = errors.New("lzo: data corruption")
			return
		}
	}
	// Add block to our history
	z.hist = append(z.hist, data...)
}

func (z *Reader) Read(p []byte) (int, error) {
	for {
		if len(z.hist) > 0 {
			n := copy(p, z.hist)
			z.hist = z.hist[n:]
			return n, nil
		}
		if z.err != nil {
			return 0, z.err
		}
		z.nextBlock()
	}
}

// Close closes the Reader. It does not close the underlying io.Reader.
func (z *Reader) Close() error {
	if z.err == io.EOF {
		return nil
	}
	return z.err
}

func lzoDecompress(src []byte, dst []byte) (int, error) {
	dstLen := len(dst)
	err := C.lzo1x_decompress_safe((*C.uchar)(unsafe.Pointer(&src[0])), C.lzo_uint(len(src)),
		(*C.uchar)(unsafe.Pointer(&dst[0])), (*C.lzo_uint)(unsafe.Pointer(&dstLen)), nil)
	if err != 0 {
		return 0, errno(err)
	}
	return dstLen, nil
}

// A Writer is an io.Write that satisfies writes by compressing data written
// to its wrapped io.Writer.
type Writer struct {
	Header
	w          io.Writer
	level      int
	err        error
	compressor func([]byte) ([]byte, error)
	adler32    hash.Hash32
	crc32      hash.Hash32
}

// NewWriter creates a new Writer that satisfies writes by compressing data
// written to w.
func NewWriter(w io.Writer) *Writer {
	z, _ := NewWriterLevel(w, defaultCompression)
	return z
}

// NewWriterLevel is like NewWriter but specifies the compression level instead
// of assuming DefaultCompression.
func NewWriterLevel(w io.Writer, level int) (*Writer, error) {
	if level < defaultCompression || level > BestCompression {
		return nil, fmt.Errorf("lzo: invalid compression level: %d", level)
	}
	z := new(Writer)
	z.init(w, level)
	return z, nil
}

func (z *Writer) init(w io.Writer, level int) {
	z.compressor = nil
	z.ModTime = time.Now()
	z.level = level
	z.adler32 = adler32.New()
	z.crc32 = crc32.NewIEEE()
	z.w = io.MultiWriter(w, z.adler32, z.crc32)
}

func (z *Writer) writeHeader() error {
	// Write magic numbers
	if _, err := z.w.Write(lzoMagic); err != nil {
		return err
	}
	z.adler32.Reset()
	z.crc32.Reset()
	// Write version
	if err := z.write(uint16(version & 0xffff)); err != nil {
		return err
	}
	// Write library version
	if err := z.write(uint16(lzoVersion() & 0xffff)); err != nil {
		return err
	}
	// Write library version needed to extract
	if err := z.write(uint16(0x0940)); err != nil {
		return err
	}
	// Write method
	var method, level uint8
	if z.level == BestCompression {
		method = 3
		level = 9
	} else {
		method = 1
		level = 3
	}
	if err := z.write(method); err != nil {
		return err
	}
	// Write level
	if err := z.write(level); err != nil {
		return err
	}
	// Write flags
	z.flags = 0
	z.flags |= flagAdler32D
	z.flags |= flagAdler32C
	if z.Name == "" {
		z.flags |= flagStdin
		z.flags |= flagStdout
	}
	if err := z.write(z.flags); err != nil {
		return err
	}
	// Write mode
	if err := z.write(uint32(0)); err != nil {
		return err
	}
	// Write modification time
	if err := z.write(uint32(z.ModTime.Unix())); err != nil {
		return err
	}
	if err := z.write(uint32(z.ModTime.Unix()) >> 16 >> 16); err != nil {
		return err
	}
	// Write file name
	name := []byte(z.Name)
	if err := z.write(uint8(len(name))); err != nil {
		return err
	}
	if z.Name != "" {
		if _, err := z.w.Write(name); err != nil {
			return err
		}
	}
	// Write header checksum
	if err := z.write(z.adler32.Sum32()); err != nil {
		return err
	}
	z.adler32.Reset()
	z.crc32.Reset()
	return nil
}

func (z *Writer) write(v interface{}) error {
	return binary.Write(z.w, binary.BigEndian, v)
}

// Write writes a compressed form of p to the underlying io.Writer.
func (z *Writer) Write(p []byte) (int, error) {
	if z.err != nil {
		return 0, z.err
	}
	// Write headers
	if z.compressor == nil {
		z.compressor = Compress1X
		z.err = z.writeHeader()
		if z.err != nil {
			return 0, z.err
		}
	}
	srcLen := len(p)
	// Write uncompressed block size
	z.err = z.write(uint32(srcLen))
	if z.err != nil {
		return 0, z.err
	}
	// Last block?
	if srcLen == 0 {
		return 0, z.err
	}
	// Compute uncompressed block checksum
	z.adler32.Reset()
	z.adler32.Write(p)
	srcChecksum := z.adler32.Sum32()
	// Compress
	var compressed []byte
	compressed, z.err = z.compressor(p)
	if z.err != nil {
		return 0, z.err
	}
	// Write compressed block size
	if len(compressed) >= srcLen {
		compressed = p
	}
	dstLen := len(compressed)
	z.err = z.write(uint32(dstLen))
	if z.err != nil {
		return 0, z.err
	}
	// Write uncompressed block checksum
	z.err = z.write(srcChecksum)
	if z.err != nil {
		return 0, z.err
	}
	// Write compressed block checksum
	z.adler32.Reset()
	z.adler32.Write(compressed)
	dstChecksum := z.adler32.Sum32()
	if dstLen < srcLen {
		z.err = z.write(dstChecksum)
		if z.err != nil {
			return 0, z.err
		}
	}
	// Write compressed block data
	_, z.err = z.w.Write(compressed)
	if z.err != nil {
		return 0, z.err
	}
	return srcLen, z.err
}

// Reset discards the Writer's state and makes it equivalent to the
// result of its original state from NewWriter or NewWriterLevel, but
// writing to w instead. This permits reusing a Writer rather than
// allocating a new one.
func (z *Writer) Reset(w io.Writer) {
	z.init(w, z.level)
}

// Close closes the Writer. It does not close the underlying io.Writer.
func (z *Writer) Close() error {
	z.err = z.write(uint32(0))
	return z.err
}

func lzoVersion() uint16 {
	return uint16(C.lzo_version())
}

func lzoDestinationSize(n int) int {
	return (n + n/16 + 64 + 3)
}