"

 COPYRIGHT (c) 2002 by eXept Software AG

 This software is furnished under a license and may be used

 only in accordance with the terms of that license and with the

 inclusion of the above copyright notice.   This software may not

 be provided or otherwise made available to, or used by, any

 other person.  No title to or ownership of the software is

 hereby transferred.

"

"{ Package: 'stx:libbasic2' }"

CompressionStream subclass:#ZipStream

	instanceVariableNames:''

	classVariableNames:'Z_DEFLATED HEAD_OS_CODE HEAD_RESERVED HEAD_EXTRA_FIELD

		HEAD_ORIG_NAME HEAD_COMMENT HEAD_CRC GZ_MAGIC_ID'

	poolDictionaries:''

	category:'System-Compress'

!

!ZipStream primitiveDefinitions!

%{

/*

 * includes, defines, structure definitions

 * and typedefs come here.

 */

#include "zlib/zlib.h"

#include "zlib/zutil.h"

typedef enum {

	  e_opmode_unspecified          /* processing done */

	, e_opmode_deflate              /* running deflate */

	, e_opmode_inflate              /* running inflate */

} e_opmode;

typedef struct {

	z_stream        stream;         /* pointer to the external in -stream */

	Bytef *         in_ref;         /* size    of the external in -stream */

	Bytef *         out_ref;        /* pointer to the external out-stream */

	uLong           out_total;      /* size    of the external out-stream */

	e_opmode        op_mode;        /* current operational mode */

	uLong           crc_32;         /* keeps the current crc */

	Bytef           tail_buff[ 8 ]; /* store the tail in the read modus */

	uLong           tail_size;      /* to check the crc and data length */

} zstream_s;

%}

! !

!ZipStream class methodsFor:'documentation'!

copyright

"

 COPYRIGHT (c) 2002 by eXept Software AG

 This software is furnished under a license and may be used

 only in accordance with the terms of that license and with the

 inclusion of the above copyright notice.   This software may not

 be provided or otherwise made available to, or used by, any

 other person.  No title to or ownership of the software is

 hereby transferred.

"

!

documentation

"

    Zip compression and decompression (used in gzip and zip)

    [author:]

    [instance variables:]

    [class variables:]

    [see also:]

"

!

examples

"

    |compressed zipStream|

    compressed := #[] writeStream.

    zipStream := self writeOpenOn:compressed.

    zipStream nextPutAll:'This is some text 1234567890'.

    zipStream flush.

    self information:compressed contents size printString.

self halt.

    zipStream := self readOpenOn:compressed contents readStream.

    self information:zipStream contents.

"

! !

!ZipStream class methodsFor:'initialization'!

initialize

    "setup class attributes derived from the library

    "

    |z_deflated os_code|

%{

    z_deflated = __MKSMALLINT( Z_DEFLATED );

    os_code    = __MKSMALLINT( OS_CODE );

%}.

    Z_DEFLATED            := z_deflated.

    HEAD_OS_CODE          := os_code.

    HEAD_RESERVED         := 16rE0.     " bits 5..7:  reserved "

    HEAD_EXTRA_FIELD      := 16r04.     " bit 2 set:  extra field present "

    HEAD_ORIG_NAME        := 16r08.     " bit 3 set:  original file name present "

    HEAD_COMMENT          := 16r10.     " bit 4 set:  file comment present "

    HEAD_CRC              := 16r02.     " bit 1 set:  header CRC present "

    GZ_MAGIC_ID           := #[ 16r1f 16r8b ]

! !

!ZipStream methodsFor:'low level'!

zclose

    "low level close of the zip stream

    "

%{

    OBJ _zstreamObj = __INST( zstream );

    if( _zstreamObj != nil )

    {

    }

%}.

!

zdeflate

    "low level - deflate

    "

    |errorNo|

    errorNo := nil.

%{

    OBJ _zstreamObj = __INST( zstream );

    if( _zstreamObj != nil )

    {

	int         _errorNo, _action;

	uLong       _bfsize;

	zstream_s * _zstream = (zstream_s *) __externalBytesAddress( _zstreamObj );

	if( _zstream->op_mode != e_opmode_deflate )

	    RETURN( false );

	_bfsize = _zstream->out_total;

	if( _zstream->stream.state == NULL )

	{

	    /* processing finished; write crc_32 and the total size

	    */

	    uLong   v, i;

	    Bytef * p = _zstream->out_ref;

	    v = _zstream->crc_32;

	    for( i = 0; i < 4; ++i ) { p[i] = v & 0xff; v >>= 8; }

	    v = _zstream->stream.total_in;

	    for( i = 4; i < 8; ++i ) { p[i] = v & 0xff; v >>= 8; }

	    _zstream->op_mode          = e_opmode_unspecified;

	    _zstream->stream.avail_in  = 0;

	    _zstream->stream.next_in   = Z_NULL;

	    _zstream->stream.avail_out = _bfsize - 8;

	    RETURN( true );

	}

	_zstream->stream.avail_out = _bfsize;

	_zstream->stream.next_out  = _zstream->out_ref;

	_errorNo = deflate( & _zstream->stream, _action );

	if( _errorNo == Z_STREAM_END )

	{

	    _zstream->stream.avail_in = 0;

	    _zstream->stream.next_in  = Z_NULL;

	    _errorNo = deflateEnd( & _zstream->stream );

	}

	if( _errorNo == Z_OK )

	{

	    if(   (_zstream->stream.avail_out != _bfsize)

	       || (_zstream->stream.avail_in  != 0)

	      )

	      RETURN( true );

	    RETURN( false );

	}

	errorNo = __MKSMALLINT( _errorNo );

    }

%}.

    errorNo ifNil:[

	zstream ifNil:[self errorNotOpen].

	self invalidArguments.

    ].

    self zerror:errorNo.

!

zdeflateInit

    "low level - deflateInit

    "

    |errorNo level|

    errorNo := nil.

    level   := BlockSize.

%{

    OBJ _zstreamObj = __INST( zstream );

    if( (_zstreamObj != nil) && __isSmallInteger(level) )

    {

	int         _errorNo;

	zstream_s * _zstream = (zstream_s *) __externalBytesAddress( _zstreamObj );

	_zstream->op_mode = e_opmode_deflate;

	_errorNo = deflateInit2( & _zstream->stream

			       , __intVal( level )

			       , Z_DEFLATED

			       , -MAX_WBITS

			       , DEF_MEM_LEVEL

			       , Z_DEFAULT_STRATEGY

			       );

	if( _errorNo == Z_OK )

	    RETURN( self );

	errorNo = __MKSMALLINT( _errorNo );

    }

%}.

    errorNo ifNil:[

	zstream ifNil:[ self errorNotOpen ].

	self invalidArguments .

    ].

    self zerror:errorNo.

!

zget_avail_out

    "low level - get the number of available out bytes

    "

%{

    OBJ _zstreamObj = __INST( zstream );

    if( _zstreamObj != nil )

    {

	uInt        _count;

	zstream_s * _zstream = (zstream_s *) __externalBytesAddress( _zstreamObj );

	_count = _zstream->out_total - _zstream->stream.avail_out;

	RETURN( __MKSMALLINT (_count) );

    }

%}.

    self errorNotOpen.

!

zinflate

    "low level - inflate

    "

    |errorNo tailError|

    tailError := nil.

    errorNo   := nil.

%{

    OBJ _zstreamObj = __INST( zstream );

    if( _zstreamObj != nil )

    {

	int         _errorNo, _count;

	zstream_s * _zstream;

	int         _avail_in;

	_zstream = (zstream_s *) __externalBytesAddress( _zstreamObj );

	if( _zstream->op_mode != e_opmode_inflate )

	    RETURN( nil );

	_avail_in = _zstream->stream.avail_in;

	if( _zstream->stream.state == NULL )

	{

	    /* processing finished : check crc and data length */

	    Bytef * _next_in;

	    Bytef * _buff;

	    uLong   _tnum;

	    int     _i;