mirror of
https://github.com/kasmtech/KasmVNC.git
synced 2024-12-12 09:50:52 +01:00
1528 lines
46 KiB
JavaScript
1528 lines
46 KiB
JavaScript
|
import * as utils from "../utils/common.js";
|
||
|
|
import adler32 from "./adler32.js";
|
||
|
|
import crc32 from "./crc32.js";
|
||
|
|
import inflate_fast from "./inffast.js";
|
||
|
|
import inflate_table from "./inftrees.js";
|
||
|
|
|
||
|
|
var CODES = 0;
|
||
|
|
var LENS = 1;
|
||
|
|
var DISTS = 2;
|
||
|
|
|
||
|
|
/* Public constants ==========================================================*/
|
||
|
|
/* ===========================================================================*/
|
||
|
|
|
||
|
|
|
||
|
|
/* Allowed flush values; see deflate() and inflate() below for details */
|
||
|
|
//var Z_NO_FLUSH = 0;
|
||
|
|
//var Z_PARTIAL_FLUSH = 1;
|
||
|
|
//var Z_SYNC_FLUSH = 2;
|
||
|
|
//var Z_FULL_FLUSH = 3;
|
||
|
|
var Z_FINISH = 4;
|
||
|
|
var Z_BLOCK = 5;
|
||
|
|
var Z_TREES = 6;
|
||
|
|
|
||
|
|
|
||
|
|
/* Return codes for the compression/decompression functions. Negative values
|
||
|
|
* are errors, positive values are used for special but normal events.
|
||
|
|
*/
|
||
|
|
var Z_OK = 0;
|
||
|
|
var Z_STREAM_END = 1;
|
||
|
|
var Z_NEED_DICT = 2;
|
||
|
|
//var Z_ERRNO = -1;
|
||
|
|
var Z_STREAM_ERROR = -2;
|
||
|
|
var Z_DATA_ERROR = -3;
|
||
|
|
var Z_MEM_ERROR = -4;
|
||
|
|
var Z_BUF_ERROR = -5;
|
||
|
|
//var Z_VERSION_ERROR = -6;
|
||
|
|
|
||
|
|
/* The deflate compression method */
|
||
|
|
var Z_DEFLATED = 8;
|
||
|
|
|
||
|
|
|
||
|
|
/* STATES ====================================================================*/
|
||
|
|
/* ===========================================================================*/
|
||
|
|
|
||
|
|
|
||
|
|
var HEAD = 1; /* i: waiting for magic header */
|
||
|
|
var FLAGS = 2; /* i: waiting for method and flags (gzip) */
|
||
|
|
var TIME = 3; /* i: waiting for modification time (gzip) */
|
||
|
|
var OS = 4; /* i: waiting for extra flags and operating system (gzip) */
|
||
|
|
var EXLEN = 5; /* i: waiting for extra length (gzip) */
|
||
|
|
var EXTRA = 6; /* i: waiting for extra bytes (gzip) */
|
||
|
|
var NAME = 7; /* i: waiting for end of file name (gzip) */
|
||
|
|
var COMMENT = 8; /* i: waiting for end of comment (gzip) */
|
||
|
|
var HCRC = 9; /* i: waiting for header crc (gzip) */
|
||
|
|
var DICTID = 10; /* i: waiting for dictionary check value */
|
||
|
|
var DICT = 11; /* waiting for inflateSetDictionary() call */
|
||
|
|
var TYPE = 12; /* i: waiting for type bits, including last-flag bit */
|
||
|
|
var TYPEDO = 13; /* i: same, but skip check to exit inflate on new block */
|
||
|
|
var STORED = 14; /* i: waiting for stored size (length and complement) */
|
||
|
|
var COPY_ = 15; /* i/o: same as COPY below, but only first time in */
|
||
|
|
var COPY = 16; /* i/o: waiting for input or output to copy stored block */
|
||
|
|
var TABLE = 17; /* i: waiting for dynamic block table lengths */
|
||
|
|
var LENLENS = 18; /* i: waiting for code length code lengths */
|
||
|
|
var CODELENS = 19; /* i: waiting for length/lit and distance code lengths */
|
||
|
|
var LEN_ = 20; /* i: same as LEN below, but only first time in */
|
||
|
|
var LEN = 21; /* i: waiting for length/lit/eob code */
|
||
|
|
var LENEXT = 22; /* i: waiting for length extra bits */
|
||
|
|
var DIST = 23; /* i: waiting for distance code */
|
||
|
|
var DISTEXT = 24; /* i: waiting for distance extra bits */
|
||
|
|
var MATCH = 25; /* o: waiting for output space to copy string */
|
||
|
|
var LIT = 26; /* o: waiting for output space to write literal */
|
||
|
|
var CHECK = 27; /* i: waiting for 32-bit check value */
|
||
|
|
var LENGTH = 28; /* i: waiting for 32-bit length (gzip) */
|
||
|
|
var DONE = 29; /* finished check, done -- remain here until reset */
|
||
|
|
var BAD = 30; /* got a data error -- remain here until reset */
|
||
|
|
var MEM = 31; /* got an inflate() memory error -- remain here until reset */
|
||
|
|
var SYNC = 32; /* looking for synchronization bytes to restart inflate() */
|
||
|
|
|
||
|
|
/* ===========================================================================*/
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
var ENOUGH_LENS = 852;
|
||
|
|
var ENOUGH_DISTS = 592;
|
||
|
|
//var ENOUGH = (ENOUGH_LENS+ENOUGH_DISTS);
|
||
|
|
|
||
|
|
var MAX_WBITS = 15;
|
||
|
|
/* 32K LZ77 window */
|
||
|
|
var DEF_WBITS = MAX_WBITS;
|
||
|
|
|
||
|
|
|
||
|
|
function zswap32(q) {
|
||
|
|
return (((q >>> 24) & 0xff) +
|
||
|
|
((q >>> 8) & 0xff00) +
|
||
|
|
((q & 0xff00) << 8) +
|
||
|
|
((q & 0xff) << 24));
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
function InflateState() {
|
||
|
|
this.mode = 0; /* current inflate mode */
|
||
|
|
this.last = false; /* true if processing last block */
|
||
|
|
this.wrap = 0; /* bit 0 true for zlib, bit 1 true for gzip */
|
||
|
|
this.havedict = false; /* true if dictionary provided */
|
||
|
|
this.flags = 0; /* gzip header method and flags (0 if zlib) */
|
||
|
|
this.dmax = 0; /* zlib header max distance (INFLATE_STRICT) */
|
||
|
|
this.check = 0; /* protected copy of check value */
|
||
|
|
this.total = 0; /* protected copy of output count */
|
||
|
|
// TODO: may be {}
|
||
|
|
this.head = null; /* where to save gzip header information */
|
||
|
|
|
||
|
|
/* sliding window */
|
||
|
|
this.wbits = 0; /* log base 2 of requested window size */
|
||
|
|
this.wsize = 0; /* window size or zero if not using window */
|
||
|
|
this.whave = 0; /* valid bytes in the window */
|
||
|
|
this.wnext = 0; /* window write index */
|
||
|
|
this.window = null; /* allocated sliding window, if needed */
|
||
|
|
|
||
|
|
/* bit accumulator */
|
||
|
|
this.hold = 0; /* input bit accumulator */
|
||
|
|
this.bits = 0; /* number of bits in "in" */
|
||
|
|
|
||
|
|
/* for string and stored block copying */
|
||
|
|
this.length = 0; /* literal or length of data to copy */
|
||
|
|
this.offset = 0; /* distance back to copy string from */
|
||
|
|
|
||
|
|
/* for table and code decoding */
|
||
|
|
this.extra = 0; /* extra bits needed */
|
||
|
|
|
||
|
|
/* fixed and dynamic code tables */
|
||
|
|
this.lencode = null; /* starting table for length/literal codes */
|
||
|
|
this.distcode = null; /* starting table for distance codes */
|
||
|
|
this.lenbits = 0; /* index bits for lencode */
|
||
|
|
this.distbits = 0; /* index bits for distcode */
|
||
|
|
|
||
|
|
/* dynamic table building */
|
||
|
|
this.ncode = 0; /* number of code length code lengths */
|
||
|
|
this.nlen = 0; /* number of length code lengths */
|
||
|
|
this.ndist = 0; /* number of distance code lengths */
|
||
|
|
this.have = 0; /* number of code lengths in lens[] */
|
||
|
|
this.next = null; /* next available space in codes[] */
|
||
|
|
|
||
|
|
this.lens = new utils.Buf16(320); /* temporary storage for code lengths */
|
||
|
|
this.work = new utils.Buf16(288); /* work area for code table building */
|
||
|
|
|
||
|
|
/*
|
||
|
|
because we don't have pointers in js, we use lencode and distcode directly
|
||
|
|
as buffers so we don't need codes
|
||
|
|
*/
|
||
|
|
//this.codes = new utils.Buf32(ENOUGH); /* space for code tables */
|
||
|
|
this.lendyn = null; /* dynamic table for length/literal codes (JS specific) */
|
||
|
|
this.distdyn = null; /* dynamic table for distance codes (JS specific) */
|
||
|
|
this.sane = 0; /* if false, allow invalid distance too far */
|
||
|
|
this.back = 0; /* bits back of last unprocessed length/lit */
|
||
|
|
this.was = 0; /* initial length of match */
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateResetKeep(strm) {
|
||
|
|
var state;
|
||
|
|
|
||
|
|
if (!strm || !strm.state) { return Z_STREAM_ERROR; }
|
||
|
|
state = strm.state;
|
||
|
|
strm.total_in = strm.total_out = state.total = 0;
|
||
|
|
strm.msg = ''; /*Z_NULL*/
|
||
|
|
if (state.wrap) { /* to support ill-conceived Java test suite */
|
||
|
|
strm.adler = state.wrap & 1;
|
||
|
|
}
|
||
|
|
state.mode = HEAD;
|
||
|
|
state.last = 0;
|
||
|
|
state.havedict = 0;
|
||
|
|
state.dmax = 32768;
|
||
|
|
state.head = null/*Z_NULL*/;
|
||
|
|
state.hold = 0;
|
||
|
|
state.bits = 0;
|
||
|
|
//state.lencode = state.distcode = state.next = state.codes;
|
||
|
|
state.lencode = state.lendyn = new utils.Buf32(ENOUGH_LENS);
|
||
|
|
state.distcode = state.distdyn = new utils.Buf32(ENOUGH_DISTS);
|
||
|
|
|
||
|
|
state.sane = 1;
|
||
|
|
state.back = -1;
|
||
|
|
//Tracev((stderr, "inflate: reset\n"));
|
||
|
|
return Z_OK;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateReset(strm) {
|
||
|
|
var state;
|
||
|
|
|
||
|
|
if (!strm || !strm.state) { return Z_STREAM_ERROR; }
|
||
|
|
state = strm.state;
|
||
|
|
state.wsize = 0;
|
||
|
|
state.whave = 0;
|
||
|
|
state.wnext = 0;
|
||
|
|
return inflateResetKeep(strm);
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateReset2(strm, windowBits) {
|
||
|
|
var wrap;
|
||
|
|
var state;
|
||
|
|
|
||
|
|
/* get the state */
|
||
|
|
if (!strm || !strm.state) { return Z_STREAM_ERROR; }
|
||
|
|
state = strm.state;
|
||
|
|
|
||
|
|
/* extract wrap request from windowBits parameter */
|
||
|
|
if (windowBits < 0) {
|
||
|
|
wrap = 0;
|
||
|
|
windowBits = -windowBits;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
wrap = (windowBits >> 4) + 1;
|
||
|
|
if (windowBits < 48) {
|
||
|
|
windowBits &= 15;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* set number of window bits, free window if different */
|
||
|
|
if (windowBits && (windowBits < 8 || windowBits > 15)) {
|
||
|
|
return Z_STREAM_ERROR;
|
||
|
|
}
|
||
|
|
if (state.window !== null && state.wbits !== windowBits) {
|
||
|
|
state.window = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* update state and reset the rest of it */
|
||
|
|
state.wrap = wrap;
|
||
|
|
state.wbits = windowBits;
|
||
|
|
return inflateReset(strm);
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateInit2(strm, windowBits) {
|
||
|
|
var ret;
|
||
|
|
var state;
|
||
|
|
|
||
|
|
if (!strm) { return Z_STREAM_ERROR; }
|
||
|
|
//strm.msg = Z_NULL; /* in case we return an error */
|
||
|
|
|
||
|
|
state = new InflateState();
|
||
|
|
|
||
|
|
//if (state === Z_NULL) return Z_MEM_ERROR;
|
||
|
|
//Tracev((stderr, "inflate: allocated\n"));
|
||
|
|
strm.state = state;
|
||
|
|
state.window = null/*Z_NULL*/;
|
||
|
|
ret = inflateReset2(strm, windowBits);
|
||
|
|
if (ret !== Z_OK) {
|
||
|
|
strm.state = null/*Z_NULL*/;
|
||
|
|
}
|
||
|
|
return ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateInit(strm) {
|
||
|
|
return inflateInit2(strm, DEF_WBITS);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/*
|
||
|
|
Return state with length and distance decoding tables and index sizes set to
|
||
|
|
fixed code decoding. Normally this returns fixed tables from inffixed.h.
|
||
|
|
If BUILDFIXED is defined, then instead this routine builds the tables the
|
||
|
|
first time it's called, and returns those tables the first time and
|
||
|
|
thereafter. This reduces the size of the code by about 2K bytes, in
|
||
|
|
exchange for a little execution time. However, BUILDFIXED should not be
|
||
|
|
used for threaded applications, since the rewriting of the tables and virgin
|
||
|
|
may not be thread-safe.
|
||
|
|
*/
|
||
|
|
var virgin = true;
|
||
|
|
|
||
|
|
var lenfix, distfix; // We have no pointers in JS, so keep tables separate
|
||
|
|
|
||
|
|
function fixedtables(state) {
|
||
|
|
/* build fixed huffman tables if first call (may not be thread safe) */
|
||
|
|
if (virgin) {
|
||
|
|
var sym;
|
||
|
|
|
||
|
|
lenfix = new utils.Buf32(512);
|
||
|
|
distfix = new utils.Buf32(32);
|
||
|
|
|
||
|
|
/* literal/length table */
|
||
|
|
sym = 0;
|
||
|
|
while (sym < 144) { state.lens[sym++] = 8; }
|
||
|
|
while (sym < 256) { state.lens[sym++] = 9; }
|
||
|
|
while (sym < 280) { state.lens[sym++] = 7; }
|
||
|
|
while (sym < 288) { state.lens[sym++] = 8; }
|
||
|
|
|
||
|
|
inflate_table(LENS, state.lens, 0, 288, lenfix, 0, state.work, { bits: 9 });
|
||
|
|
|
||
|
|
/* distance table */
|
||
|
|
sym = 0;
|
||
|
|
while (sym < 32) { state.lens[sym++] = 5; }
|
||
|
|
|
||
|
|
inflate_table(DISTS, state.lens, 0, 32, distfix, 0, state.work, { bits: 5 });
|
||
|
|
|
||
|
|
/* do this just once */
|
||
|
|
virgin = false;
|
||
|
|
}
|
||
|
|
|
||
|
|
state.lencode = lenfix;
|
||
|
|
state.lenbits = 9;
|
||
|
|
state.distcode = distfix;
|
||
|
|
state.distbits = 5;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/*
|
||
|
|
Update the window with the last wsize (normally 32K) bytes written before
|
||
|
|
returning. If window does not exist yet, create it. This is only called
|
||
|
|
when a window is already in use, or when output has been written during this
|
||
|
|
inflate call, but the end of the deflate stream has not been reached yet.
|
||
|
|
It is also called to create a window for dictionary data when a dictionary
|
||
|
|
is loaded.
|
||
|
|
|
||
|
|
Providing output buffers larger than 32K to inflate() should provide a speed
|
||
|
|
advantage, since only the last 32K of output is copied to the sliding window
|
||
|
|
upon return from inflate(), and since all distances after the first 32K of
|
||
|
|
output will fall in the output data, making match copies simpler and faster.
|
||
|
|
The advantage may be dependent on the size of the processor's data caches.
|
||
|
|
*/
|
||
|
|
function updatewindow(strm, src, end, copy) {
|
||
|
|
var dist;
|
||
|
|
var state = strm.state;
|
||
|
|
|
||
|
|
/* if it hasn't been done already, allocate space for the window */
|
||
|
|
if (state.window === null) {
|
||
|
|
state.wsize = 1 << state.wbits;
|
||
|
|
state.wnext = 0;
|
||
|
|
state.whave = 0;
|
||
|
|
|
||
|
|
state.window = new utils.Buf8(state.wsize);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* copy state->wsize or less output bytes into the circular window */
|
||
|
|
if (copy >= state.wsize) {
|
||
|
|
utils.arraySet(state.window, src, end - state.wsize, state.wsize, 0);
|
||
|
|
state.wnext = 0;
|
||
|
|
state.whave = state.wsize;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
dist = state.wsize - state.wnext;
|
||
|
|
if (dist > copy) {
|
||
|
|
dist = copy;
|
||
|
|
}
|
||
|
|
//zmemcpy(state->window + state->wnext, end - copy, dist);
|
||
|
|
utils.arraySet(state.window, src, end - copy, dist, state.wnext);
|
||
|
|
copy -= dist;
|
||
|
|
if (copy) {
|
||
|
|
//zmemcpy(state->window, end - copy, copy);
|
||
|
|
utils.arraySet(state.window, src, end - copy, copy, 0);
|
||
|
|
state.wnext = copy;
|
||
|
|
state.whave = state.wsize;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
state.wnext += dist;
|
||
|
|
if (state.wnext === state.wsize) { state.wnext = 0; }
|
||
|
|
if (state.whave < state.wsize) { state.whave += dist; }
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflate(strm, flush) {
|
||
|
|
var state;
|
||
|
|
var input, output; // input/output buffers
|
||
|
|
var next; /* next input INDEX */
|
||
|
|
var put; /* next output INDEX */
|
||
|
|
var have, left; /* available input and output */
|
||
|
|
var hold; /* bit buffer */
|
||
|
|
var bits; /* bits in bit buffer */
|
||
|
|
var _in, _out; /* save starting available input and output */
|
||
|
|
var copy; /* number of stored or match bytes to copy */
|
||
|
|
var from; /* where to copy match bytes from */
|
||
|
|
var from_source;
|
||
|
|
var here = 0; /* current decoding table entry */
|
||
|
|
var here_bits, here_op, here_val; // paked "here" denormalized (JS specific)
|
||
|
|
//var last; /* parent table entry */
|
||
|
|
var last_bits, last_op, last_val; // paked "last" denormalized (JS specific)
|
||
|
|
var len; /* length to copy for repeats, bits to drop */
|
||
|
|
var ret; /* return code */
|
||
|
|
var hbuf = new utils.Buf8(4); /* buffer for gzip header crc calculation */
|
||
|
|
var opts;
|
||
|
|
|
||
|
|
var n; // temporary var for NEED_BITS
|
||
|
|
|
||
|
|
var order = /* permutation of code lengths */
|
||
|
|
[ 16, 17, 18, 0, 8, 7, 9, 6, 10, 5, 11, 4, 12, 3, 13, 2, 14, 1, 15 ];
|
||
|
|
|
||
|
|
|
||
|
|
if (!strm || !strm.state || !strm.output ||
|
||
|
|
(!strm.input && strm.avail_in !== 0)) {
|
||
|
|
return Z_STREAM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
state = strm.state;
|
||
|
|
if (state.mode === TYPE) { state.mode = TYPEDO; } /* skip check */
|
||
|
|
|
||
|
|
|
||
|
|
//--- LOAD() ---
|
||
|
|
put = strm.next_out;
|
||
|
|
output = strm.output;
|
||
|
|
left = strm.avail_out;
|
||
|
|
next = strm.next_in;
|
||
|
|
input = strm.input;
|
||
|
|
have = strm.avail_in;
|
||
|
|
hold = state.hold;
|
||
|
|
bits = state.bits;
|
||
|
|
//---
|
||
|
|
|
||
|
|
_in = have;
|
||
|
|
_out = left;
|
||
|
|
ret = Z_OK;
|
||
|
|
|
||
|
|
inf_leave: // goto emulation
|
||
|
|
for (;;) {
|
||
|
|
switch (state.mode) {
|
||
|
|
case HEAD:
|
||
|
|
if (state.wrap === 0) {
|
||
|
|
state.mode = TYPEDO;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//=== NEEDBITS(16);
|
||
|
|
while (bits < 16) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if ((state.wrap & 2) && hold === 0x8b1f) { /* gzip header */
|
||
|
|
state.check = 0/*crc32(0L, Z_NULL, 0)*/;
|
||
|
|
//=== CRC2(state.check, hold);
|
||
|
|
hbuf[0] = hold & 0xff;
|
||
|
|
hbuf[1] = (hold >>> 8) & 0xff;
|
||
|
|
state.check = crc32(state.check, hbuf, 2, 0);
|
||
|
|
//===//
|
||
|
|
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = FLAGS;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.flags = 0; /* expect zlib header */
|
||
|
|
if (state.head) {
|
||
|
|
state.head.done = false;
|
||
|
|
}
|
||
|
|
if (!(state.wrap & 1) || /* check if zlib header allowed */
|
||
|
|
(((hold & 0xff)/*BITS(8)*/ << 8) + (hold >> 8)) % 31) {
|
||
|
|
strm.msg = 'incorrect header check';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if ((hold & 0x0f)/*BITS(4)*/ !== Z_DEFLATED) {
|
||
|
|
strm.msg = 'unknown compression method';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//--- DROPBITS(4) ---//
|
||
|
|
hold >>>= 4;
|
||
|
|
bits -= 4;
|
||
|
|
//---//
|
||
|
|
len = (hold & 0x0f)/*BITS(4)*/ + 8;
|
||
|
|
if (state.wbits === 0) {
|
||
|
|
state.wbits = len;
|
||
|
|
}
|
||
|
|
else if (len > state.wbits) {
|
||
|
|
strm.msg = 'invalid window size';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.dmax = 1 << len;
|
||
|
|
//Tracev((stderr, "inflate: zlib header ok\n"));
|
||
|
|
strm.adler = state.check = 1/*adler32(0L, Z_NULL, 0)*/;
|
||
|
|
state.mode = hold & 0x200 ? DICTID : TYPE;
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
break;
|
||
|
|
case FLAGS:
|
||
|
|
//=== NEEDBITS(16); */
|
||
|
|
while (bits < 16) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.flags = hold;
|
||
|
|
if ((state.flags & 0xff) !== Z_DEFLATED) {
|
||
|
|
strm.msg = 'unknown compression method';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if (state.flags & 0xe000) {
|
||
|
|
strm.msg = 'unknown header flags set';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if (state.head) {
|
||
|
|
state.head.text = ((hold >> 8) & 1);
|
||
|
|
}
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
//=== CRC2(state.check, hold);
|
||
|
|
hbuf[0] = hold & 0xff;
|
||
|
|
hbuf[1] = (hold >>> 8) & 0xff;
|
||
|
|
state.check = crc32(state.check, hbuf, 2, 0);
|
||
|
|
//===//
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = TIME;
|
||
|
|
/* falls through */
|
||
|
|
case TIME:
|
||
|
|
//=== NEEDBITS(32); */
|
||
|
|
while (bits < 32) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if (state.head) {
|
||
|
|
state.head.time = hold;
|
||
|
|
}
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
//=== CRC4(state.check, hold)
|
||
|
|
hbuf[0] = hold & 0xff;
|
||
|
|
hbuf[1] = (hold >>> 8) & 0xff;
|
||
|
|
hbuf[2] = (hold >>> 16) & 0xff;
|
||
|
|
hbuf[3] = (hold >>> 24) & 0xff;
|
||
|
|
state.check = crc32(state.check, hbuf, 4, 0);
|
||
|
|
//===
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = OS;
|
||
|
|
/* falls through */
|
||
|
|
case OS:
|
||
|
|
//=== NEEDBITS(16); */
|
||
|
|
while (bits < 16) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if (state.head) {
|
||
|
|
state.head.xflags = (hold & 0xff);
|
||
|
|
state.head.os = (hold >> 8);
|
||
|
|
}
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
//=== CRC2(state.check, hold);
|
||
|
|
hbuf[0] = hold & 0xff;
|
||
|
|
hbuf[1] = (hold >>> 8) & 0xff;
|
||
|
|
state.check = crc32(state.check, hbuf, 2, 0);
|
||
|
|
//===//
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = EXLEN;
|
||
|
|
/* falls through */
|
||
|
|
case EXLEN:
|
||
|
|
if (state.flags & 0x0400) {
|
||
|
|
//=== NEEDBITS(16); */
|
||
|
|
while (bits < 16) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.length = hold;
|
||
|
|
if (state.head) {
|
||
|
|
state.head.extra_len = hold;
|
||
|
|
}
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
//=== CRC2(state.check, hold);
|
||
|
|
hbuf[0] = hold & 0xff;
|
||
|
|
hbuf[1] = (hold >>> 8) & 0xff;
|
||
|
|
state.check = crc32(state.check, hbuf, 2, 0);
|
||
|
|
//===//
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
}
|
||
|
|
else if (state.head) {
|
||
|
|
state.head.extra = null/*Z_NULL*/;
|
||
|
|
}
|
||
|
|
state.mode = EXTRA;
|
||
|
|
/* falls through */
|
||
|
|
case EXTRA:
|
||
|
|
if (state.flags & 0x0400) {
|
||
|
|
copy = state.length;
|
||
|
|
if (copy > have) { copy = have; }
|
||
|
|
if (copy) {
|
||
|
|
if (state.head) {
|
||
|
|
len = state.head.extra_len - state.length;
|
||
|
|
if (!state.head.extra) {
|
||
|
|
// Use untyped array for more conveniend processing later
|
||
|
|
state.head.extra = new Array(state.head.extra_len);
|
||
|
|
}
|
||
|
|
utils.arraySet(
|
||
|
|
state.head.extra,
|
||
|
|
input,
|
||
|
|
next,
|
||
|
|
// extra field is limited to 65536 bytes
|
||
|
|
// - no need for additional size check
|
||
|
|
copy,
|
||
|
|
/*len + copy > state.head.extra_max - len ? state.head.extra_max : copy,*/
|
||
|
|
len
|
||
|
|
);
|
||
|
|
//zmemcpy(state.head.extra + len, next,
|
||
|
|
// len + copy > state.head.extra_max ?
|
||
|
|
// state.head.extra_max - len : copy);
|
||
|
|
}
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
state.check = crc32(state.check, input, copy, next);
|
||
|
|
}
|
||
|
|
have -= copy;
|
||
|
|
next += copy;
|
||
|
|
state.length -= copy;
|
||
|
|
}
|
||
|
|
if (state.length) { break inf_leave; }
|
||
|
|
}
|
||
|
|
state.length = 0;
|
||
|
|
state.mode = NAME;
|
||
|
|
/* falls through */
|
||
|
|
case NAME:
|
||
|
|
if (state.flags & 0x0800) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
copy = 0;
|
||
|
|
do {
|
||
|
|
// TODO: 2 or 1 bytes?
|
||
|
|
len = input[next + copy++];
|
||
|
|
/* use constant limit because in js we should not preallocate memory */
|
||
|
|
if (state.head && len &&
|
||
|
|
(state.length < 65536 /*state.head.name_max*/)) {
|
||
|
|
state.head.name += String.fromCharCode(len);
|
||
|
|
}
|
||
|
|
} while (len && copy < have);
|
||
|
|
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
state.check = crc32(state.check, input, copy, next);
|
||
|
|
}
|
||
|
|
have -= copy;
|
||
|
|
next += copy;
|
||
|
|
if (len) { break inf_leave; }
|
||
|
|
}
|
||
|
|
else if (state.head) {
|
||
|
|
state.head.name = null;
|
||
|
|
}
|
||
|
|
state.length = 0;
|
||
|
|
state.mode = COMMENT;
|
||
|
|
/* falls through */
|
||
|
|
case COMMENT:
|
||
|
|
if (state.flags & 0x1000) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
copy = 0;
|
||
|
|
do {
|
||
|
|
len = input[next + copy++];
|
||
|
|
/* use constant limit because in js we should not preallocate memory */
|
||
|
|
if (state.head && len &&
|
||
|
|
(state.length < 65536 /*state.head.comm_max*/)) {
|
||
|
|
state.head.comment += String.fromCharCode(len);
|
||
|
|
}
|
||
|
|
} while (len && copy < have);
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
state.check = crc32(state.check, input, copy, next);
|
||
|
|
}
|
||
|
|
have -= copy;
|
||
|
|
next += copy;
|
||
|
|
if (len) { break inf_leave; }
|
||
|
|
}
|
||
|
|
else if (state.head) {
|
||
|
|
state.head.comment = null;
|
||
|
|
}
|
||
|
|
state.mode = HCRC;
|
||
|
|
/* falls through */
|
||
|
|
case HCRC:
|
||
|
|
if (state.flags & 0x0200) {
|
||
|
|
//=== NEEDBITS(16); */
|
||
|
|
while (bits < 16) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if (hold !== (state.check & 0xffff)) {
|
||
|
|
strm.msg = 'header crc mismatch';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
}
|
||
|
|
if (state.head) {
|
||
|
|
state.head.hcrc = ((state.flags >> 9) & 1);
|
||
|
|
state.head.done = true;
|
||
|
|
}
|
||
|
|
strm.adler = state.check = 0;
|
||
|
|
state.mode = TYPE;
|
||
|
|
break;
|
||
|
|
case DICTID:
|
||
|
|
//=== NEEDBITS(32); */
|
||
|
|
while (bits < 32) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
strm.adler = state.check = zswap32(hold);
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = DICT;
|
||
|
|
/* falls through */
|
||
|
|
case DICT:
|
||
|
|
if (state.havedict === 0) {
|
||
|
|
//--- RESTORE() ---
|
||
|
|
strm.next_out = put;
|
||
|
|
strm.avail_out = left;
|
||
|
|
strm.next_in = next;
|
||
|
|
strm.avail_in = have;
|
||
|
|
state.hold = hold;
|
||
|
|
state.bits = bits;
|
||
|
|
//---
|
||
|
|
return Z_NEED_DICT;
|
||
|
|
}
|
||
|
|
strm.adler = state.check = 1/*adler32(0L, Z_NULL, 0)*/;
|
||
|
|
state.mode = TYPE;
|
||
|
|
/* falls through */
|
||
|
|
case TYPE:
|
||
|
|
if (flush === Z_BLOCK || flush === Z_TREES) { break inf_leave; }
|
||
|
|
/* falls through */
|
||
|
|
case TYPEDO:
|
||
|
|
if (state.last) {
|
||
|
|
//--- BYTEBITS() ---//
|
||
|
|
hold >>>= bits & 7;
|
||
|
|
bits -= bits & 7;
|
||
|
|
//---//
|
||
|
|
state.mode = CHECK;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//=== NEEDBITS(3); */
|
||
|
|
while (bits < 3) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.last = (hold & 0x01)/*BITS(1)*/;
|
||
|
|
//--- DROPBITS(1) ---//
|
||
|
|
hold >>>= 1;
|
||
|
|
bits -= 1;
|
||
|
|
//---//
|
||
|
|
|
||
|
|
switch ((hold & 0x03)/*BITS(2)*/) {
|
||
|
|
case 0: /* stored block */
|
||
|
|
//Tracev((stderr, "inflate: stored block%s\n",
|
||
|
|
// state.last ? " (last)" : ""));
|
||
|
|
state.mode = STORED;
|
||
|
|
break;
|
||
|
|
case 1: /* fixed block */
|
||
|
|
fixedtables(state);
|
||
|
|
//Tracev((stderr, "inflate: fixed codes block%s\n",
|
||
|
|
// state.last ? " (last)" : ""));
|
||
|
|
state.mode = LEN_; /* decode codes */
|
||
|
|
if (flush === Z_TREES) {
|
||
|
|
//--- DROPBITS(2) ---//
|
||
|
|
hold >>>= 2;
|
||
|
|
bits -= 2;
|
||
|
|
//---//
|
||
|
|
break inf_leave;
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case 2: /* dynamic block */
|
||
|
|
//Tracev((stderr, "inflate: dynamic codes block%s\n",
|
||
|
|
// state.last ? " (last)" : ""));
|
||
|
|
state.mode = TABLE;
|
||
|
|
break;
|
||
|
|
case 3:
|
||
|
|
strm.msg = 'invalid block type';
|
||
|
|
state.mode = BAD;
|
||
|
|
}
|
||
|
|
//--- DROPBITS(2) ---//
|
||
|
|
hold >>>= 2;
|
||
|
|
bits -= 2;
|
||
|
|
//---//
|
||
|
|
break;
|
||
|
|
case STORED:
|
||
|
|
//--- BYTEBITS() ---// /* go to byte boundary */
|
||
|
|
hold >>>= bits & 7;
|
||
|
|
bits -= bits & 7;
|
||
|
|
//---//
|
||
|
|
//=== NEEDBITS(32); */
|
||
|
|
while (bits < 32) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if ((hold & 0xffff) !== ((hold >>> 16) ^ 0xffff)) {
|
||
|
|
strm.msg = 'invalid stored block lengths';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.length = hold & 0xffff;
|
||
|
|
//Tracev((stderr, "inflate: stored length %u\n",
|
||
|
|
// state.length));
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
state.mode = COPY_;
|
||
|
|
if (flush === Z_TREES) { break inf_leave; }
|
||
|
|
/* falls through */
|
||
|
|
case COPY_:
|
||
|
|
state.mode = COPY;
|
||
|
|
/* falls through */
|
||
|
|
case COPY:
|
||
|
|
copy = state.length;
|
||
|
|
if (copy) {
|
||
|
|
if (copy > have) { copy = have; }
|
||
|
|
if (copy > left) { copy = left; }
|
||
|
|
if (copy === 0) { break inf_leave; }
|
||
|
|
//--- zmemcpy(put, next, copy); ---
|
||
|
|
utils.arraySet(output, input, next, copy, put);
|
||
|
|
//---//
|
||
|
|
have -= copy;
|
||
|
|
next += copy;
|
||
|
|
left -= copy;
|
||
|
|
put += copy;
|
||
|
|
state.length -= copy;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//Tracev((stderr, "inflate: stored end\n"));
|
||
|
|
state.mode = TYPE;
|
||
|
|
break;
|
||
|
|
case TABLE:
|
||
|
|
//=== NEEDBITS(14); */
|
||
|
|
while (bits < 14) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.nlen = (hold & 0x1f)/*BITS(5)*/ + 257;
|
||
|
|
//--- DROPBITS(5) ---//
|
||
|
|
hold >>>= 5;
|
||
|
|
bits -= 5;
|
||
|
|
//---//
|
||
|
|
state.ndist = (hold & 0x1f)/*BITS(5)*/ + 1;
|
||
|
|
//--- DROPBITS(5) ---//
|
||
|
|
hold >>>= 5;
|
||
|
|
bits -= 5;
|
||
|
|
//---//
|
||
|
|
state.ncode = (hold & 0x0f)/*BITS(4)*/ + 4;
|
||
|
|
//--- DROPBITS(4) ---//
|
||
|
|
hold >>>= 4;
|
||
|
|
bits -= 4;
|
||
|
|
//---//
|
||
|
|
//#ifndef PKZIP_BUG_WORKAROUND
|
||
|
|
if (state.nlen > 286 || state.ndist > 30) {
|
||
|
|
strm.msg = 'too many length or distance symbols';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//#endif
|
||
|
|
//Tracev((stderr, "inflate: table sizes ok\n"));
|
||
|
|
state.have = 0;
|
||
|
|
state.mode = LENLENS;
|
||
|
|
/* falls through */
|
||
|
|
case LENLENS:
|
||
|
|
while (state.have < state.ncode) {
|
||
|
|
//=== NEEDBITS(3);
|
||
|
|
while (bits < 3) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.lens[order[state.have++]] = (hold & 0x07);//BITS(3);
|
||
|
|
//--- DROPBITS(3) ---//
|
||
|
|
hold >>>= 3;
|
||
|
|
bits -= 3;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
while (state.have < 19) {
|
||
|
|
state.lens[order[state.have++]] = 0;
|
||
|
|
}
|
||
|
|
// We have separate tables & no pointers. 2 commented lines below not needed.
|
||
|
|
//state.next = state.codes;
|
||
|
|
//state.lencode = state.next;
|
||
|
|
// Switch to use dynamic table
|
||
|
|
state.lencode = state.lendyn;
|
||
|
|
state.lenbits = 7;
|
||
|
|
|
||
|
|
opts = { bits: state.lenbits };
|
||
|
|
ret = inflate_table(CODES, state.lens, 0, 19, state.lencode, 0, state.work, opts);
|
||
|
|
state.lenbits = opts.bits;
|
||
|
|
|
||
|
|
if (ret) {
|
||
|
|
strm.msg = 'invalid code lengths set';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//Tracev((stderr, "inflate: code lengths ok\n"));
|
||
|
|
state.have = 0;
|
||
|
|
state.mode = CODELENS;
|
||
|
|
/* falls through */
|
||
|
|
case CODELENS:
|
||
|
|
while (state.have < state.nlen + state.ndist) {
|
||
|
|
for (;;) {
|
||
|
|
here = state.lencode[hold & ((1 << state.lenbits) - 1)];/*BITS(state.lenbits)*/
|
||
|
|
here_bits = here >>> 24;
|
||
|
|
here_op = (here >>> 16) & 0xff;
|
||
|
|
here_val = here & 0xffff;
|
||
|
|
|
||
|
|
if ((here_bits) <= bits) { break; }
|
||
|
|
//--- PULLBYTE() ---//
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
if (here_val < 16) {
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
state.lens[state.have++] = here_val;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
if (here_val === 16) {
|
||
|
|
//=== NEEDBITS(here.bits + 2);
|
||
|
|
n = here_bits + 2;
|
||
|
|
while (bits < n) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
if (state.have === 0) {
|
||
|
|
strm.msg = 'invalid bit length repeat';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
len = state.lens[state.have - 1];
|
||
|
|
copy = 3 + (hold & 0x03);//BITS(2);
|
||
|
|
//--- DROPBITS(2) ---//
|
||
|
|
hold >>>= 2;
|
||
|
|
bits -= 2;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
else if (here_val === 17) {
|
||
|
|
//=== NEEDBITS(here.bits + 3);
|
||
|
|
n = here_bits + 3;
|
||
|
|
while (bits < n) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
len = 0;
|
||
|
|
copy = 3 + (hold & 0x07);//BITS(3);
|
||
|
|
//--- DROPBITS(3) ---//
|
||
|
|
hold >>>= 3;
|
||
|
|
bits -= 3;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
//=== NEEDBITS(here.bits + 7);
|
||
|
|
n = here_bits + 7;
|
||
|
|
while (bits < n) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
len = 0;
|
||
|
|
copy = 11 + (hold & 0x7f);//BITS(7);
|
||
|
|
//--- DROPBITS(7) ---//
|
||
|
|
hold >>>= 7;
|
||
|
|
bits -= 7;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
if (state.have + copy > state.nlen + state.ndist) {
|
||
|
|
strm.msg = 'invalid bit length repeat';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
while (copy--) {
|
||
|
|
state.lens[state.have++] = len;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* handle error breaks in while */
|
||
|
|
if (state.mode === BAD) { break; }
|
||
|
|
|
||
|
|
/* check for end-of-block code (better have one) */
|
||
|
|
if (state.lens[256] === 0) {
|
||
|
|
strm.msg = 'invalid code -- missing end-of-block';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* build code tables -- note: do not change the lenbits or distbits
|
||
|
|
values here (9 and 6) without reading the comments in inftrees.h
|
||
|
|
concerning the ENOUGH constants, which depend on those values */
|
||
|
|
state.lenbits = 9;
|
||
|
|
|
||
|
|
opts = { bits: state.lenbits };
|
||
|
|
ret = inflate_table(LENS, state.lens, 0, state.nlen, state.lencode, 0, state.work, opts);
|
||
|
|
// We have separate tables & no pointers. 2 commented lines below not needed.
|
||
|
|
// state.next_index = opts.table_index;
|
||
|
|
state.lenbits = opts.bits;
|
||
|
|
// state.lencode = state.next;
|
||
|
|
|
||
|
|
if (ret) {
|
||
|
|
strm.msg = 'invalid literal/lengths set';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
state.distbits = 6;
|
||
|
|
//state.distcode.copy(state.codes);
|
||
|
|
// Switch to use dynamic table
|
||
|
|
state.distcode = state.distdyn;
|
||
|
|
opts = { bits: state.distbits };
|
||
|
|
ret = inflate_table(DISTS, state.lens, state.nlen, state.ndist, state.distcode, 0, state.work, opts);
|
||
|
|
// We have separate tables & no pointers. 2 commented lines below not needed.
|
||
|
|
// state.next_index = opts.table_index;
|
||
|
|
state.distbits = opts.bits;
|
||
|
|
// state.distcode = state.next;
|
||
|
|
|
||
|
|
if (ret) {
|
||
|
|
strm.msg = 'invalid distances set';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//Tracev((stderr, 'inflate: codes ok\n'));
|
||
|
|
state.mode = LEN_;
|
||
|
|
if (flush === Z_TREES) { break inf_leave; }
|
||
|
|
/* falls through */
|
||
|
|
case LEN_:
|
||
|
|
state.mode = LEN;
|
||
|
|
/* falls through */
|
||
|
|
case LEN:
|
||
|
|
if (have >= 6 && left >= 258) {
|
||
|
|
//--- RESTORE() ---
|
||
|
|
strm.next_out = put;
|
||
|
|
strm.avail_out = left;
|
||
|
|
strm.next_in = next;
|
||
|
|
strm.avail_in = have;
|
||
|
|
state.hold = hold;
|
||
|
|
state.bits = bits;
|
||
|
|
//---
|
||
|
|
inflate_fast(strm, _out);
|
||
|
|
//--- LOAD() ---
|
||
|
|
put = strm.next_out;
|
||
|
|
output = strm.output;
|
||
|
|
left = strm.avail_out;
|
||
|
|
next = strm.next_in;
|
||
|
|
input = strm.input;
|
||
|
|
have = strm.avail_in;
|
||
|
|
hold = state.hold;
|
||
|
|
bits = state.bits;
|
||
|
|
//---
|
||
|
|
|
||
|
|
if (state.mode === TYPE) {
|
||
|
|
state.back = -1;
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.back = 0;
|
||
|
|
for (;;) {
|
||
|
|
here = state.lencode[hold & ((1 << state.lenbits) - 1)]; /*BITS(state.lenbits)*/
|
||
|
|
here_bits = here >>> 24;
|
||
|
|
here_op = (here >>> 16) & 0xff;
|
||
|
|
here_val = here & 0xffff;
|
||
|
|
|
||
|
|
if (here_bits <= bits) { break; }
|
||
|
|
//--- PULLBYTE() ---//
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
if (here_op && (here_op & 0xf0) === 0) {
|
||
|
|
last_bits = here_bits;
|
||
|
|
last_op = here_op;
|
||
|
|
last_val = here_val;
|
||
|
|
for (;;) {
|
||
|
|
here = state.lencode[last_val +
|
||
|
|
((hold & ((1 << (last_bits + last_op)) - 1))/*BITS(last.bits + last.op)*/ >> last_bits)];
|
||
|
|
here_bits = here >>> 24;
|
||
|
|
here_op = (here >>> 16) & 0xff;
|
||
|
|
here_val = here & 0xffff;
|
||
|
|
|
||
|
|
if ((last_bits + here_bits) <= bits) { break; }
|
||
|
|
//--- PULLBYTE() ---//
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
//--- DROPBITS(last.bits) ---//
|
||
|
|
hold >>>= last_bits;
|
||
|
|
bits -= last_bits;
|
||
|
|
//---//
|
||
|
|
state.back += last_bits;
|
||
|
|
}
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
state.back += here_bits;
|
||
|
|
state.length = here_val;
|
||
|
|
if (here_op === 0) {
|
||
|
|
//Tracevv((stderr, here.val >= 0x20 && here.val < 0x7f ?
|
||
|
|
// "inflate: literal '%c'\n" :
|
||
|
|
// "inflate: literal 0x%02x\n", here.val));
|
||
|
|
state.mode = LIT;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if (here_op & 32) {
|
||
|
|
//Tracevv((stderr, "inflate: end of block\n"));
|
||
|
|
state.back = -1;
|
||
|
|
state.mode = TYPE;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
if (here_op & 64) {
|
||
|
|
strm.msg = 'invalid literal/length code';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.extra = here_op & 15;
|
||
|
|
state.mode = LENEXT;
|
||
|
|
/* falls through */
|
||
|
|
case LENEXT:
|
||
|
|
if (state.extra) {
|
||
|
|
//=== NEEDBITS(state.extra);
|
||
|
|
n = state.extra;
|
||
|
|
while (bits < n) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.length += hold & ((1 << state.extra) - 1)/*BITS(state.extra)*/;
|
||
|
|
//--- DROPBITS(state.extra) ---//
|
||
|
|
hold >>>= state.extra;
|
||
|
|
bits -= state.extra;
|
||
|
|
//---//
|
||
|
|
state.back += state.extra;
|
||
|
|
}
|
||
|
|
//Tracevv((stderr, "inflate: length %u\n", state.length));
|
||
|
|
state.was = state.length;
|
||
|
|
state.mode = DIST;
|
||
|
|
/* falls through */
|
||
|
|
case DIST:
|
||
|
|
for (;;) {
|
||
|
|
here = state.distcode[hold & ((1 << state.distbits) - 1)];/*BITS(state.distbits)*/
|
||
|
|
here_bits = here >>> 24;
|
||
|
|
here_op = (here >>> 16) & 0xff;
|
||
|
|
here_val = here & 0xffff;
|
||
|
|
|
||
|
|
if ((here_bits) <= bits) { break; }
|
||
|
|
//--- PULLBYTE() ---//
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
if ((here_op & 0xf0) === 0) {
|
||
|
|
last_bits = here_bits;
|
||
|
|
last_op = here_op;
|
||
|
|
last_val = here_val;
|
||
|
|
for (;;) {
|
||
|
|
here = state.distcode[last_val +
|
||
|
|
((hold & ((1 << (last_bits + last_op)) - 1))/*BITS(last.bits + last.op)*/ >> last_bits)];
|
||
|
|
here_bits = here >>> 24;
|
||
|
|
here_op = (here >>> 16) & 0xff;
|
||
|
|
here_val = here & 0xffff;
|
||
|
|
|
||
|
|
if ((last_bits + here_bits) <= bits) { break; }
|
||
|
|
//--- PULLBYTE() ---//
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
//---//
|
||
|
|
}
|
||
|
|
//--- DROPBITS(last.bits) ---//
|
||
|
|
hold >>>= last_bits;
|
||
|
|
bits -= last_bits;
|
||
|
|
//---//
|
||
|
|
state.back += last_bits;
|
||
|
|
}
|
||
|
|
//--- DROPBITS(here.bits) ---//
|
||
|
|
hold >>>= here_bits;
|
||
|
|
bits -= here_bits;
|
||
|
|
//---//
|
||
|
|
state.back += here_bits;
|
||
|
|
if (here_op & 64) {
|
||
|
|
strm.msg = 'invalid distance code';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
state.offset = here_val;
|
||
|
|
state.extra = (here_op) & 15;
|
||
|
|
state.mode = DISTEXT;
|
||
|
|
/* falls through */
|
||
|
|
case DISTEXT:
|
||
|
|
if (state.extra) {
|
||
|
|
//=== NEEDBITS(state.extra);
|
||
|
|
n = state.extra;
|
||
|
|
while (bits < n) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
state.offset += hold & ((1 << state.extra) - 1)/*BITS(state.extra)*/;
|
||
|
|
//--- DROPBITS(state.extra) ---//
|
||
|
|
hold >>>= state.extra;
|
||
|
|
bits -= state.extra;
|
||
|
|
//---//
|
||
|
|
state.back += state.extra;
|
||
|
|
}
|
||
|
|
//#ifdef INFLATE_STRICT
|
||
|
|
if (state.offset > state.dmax) {
|
||
|
|
strm.msg = 'invalid distance too far back';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//#endif
|
||
|
|
//Tracevv((stderr, "inflate: distance %u\n", state.offset));
|
||
|
|
state.mode = MATCH;
|
||
|
|
/* falls through */
|
||
|
|
case MATCH:
|
||
|
|
if (left === 0) { break inf_leave; }
|
||
|
|
copy = _out - left;
|
||
|
|
if (state.offset > copy) { /* copy from window */
|
||
|
|
copy = state.offset - copy;
|
||
|
|
if (copy > state.whave) {
|
||
|
|
if (state.sane) {
|
||
|
|
strm.msg = 'invalid distance too far back';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
// (!) This block is disabled in zlib defailts,
|
||
|
|
// don't enable it for binary compatibility
|
||
|
|
//#ifdef INFLATE_ALLOW_INVALID_DISTANCE_TOOFAR_ARRR
|
||
|
|
// Trace((stderr, "inflate.c too far\n"));
|
||
|
|
// copy -= state.whave;
|
||
|
|
// if (copy > state.length) { copy = state.length; }
|
||
|
|
// if (copy > left) { copy = left; }
|
||
|
|
// left -= copy;
|
||
|
|
// state.length -= copy;
|
||
|
|
// do {
|
||
|
|
// output[put++] = 0;
|
||
|
|
// } while (--copy);
|
||
|
|
// if (state.length === 0) { state.mode = LEN; }
|
||
|
|
// break;
|
||
|
|
//#endif
|
||
|
|
}
|
||
|
|
if (copy > state.wnext) {
|
||
|
|
copy -= state.wnext;
|
||
|
|
from = state.wsize - copy;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
from = state.wnext - copy;
|
||
|
|
}
|
||
|
|
if (copy > state.length) { copy = state.length; }
|
||
|
|
from_source = state.window;
|
||
|
|
}
|
||
|
|
else { /* copy from output */
|
||
|
|
from_source = output;
|
||
|
|
from = put - state.offset;
|
||
|
|
copy = state.length;
|
||
|
|
}
|
||
|
|
if (copy > left) { copy = left; }
|
||
|
|
left -= copy;
|
||
|
|
state.length -= copy;
|
||
|
|
do {
|
||
|
|
output[put++] = from_source[from++];
|
||
|
|
} while (--copy);
|
||
|
|
if (state.length === 0) { state.mode = LEN; }
|
||
|
|
break;
|
||
|
|
case LIT:
|
||
|
|
if (left === 0) { break inf_leave; }
|
||
|
|
output[put++] = state.length;
|
||
|
|
left--;
|
||
|
|
state.mode = LEN;
|
||
|
|
break;
|
||
|
|
case CHECK:
|
||
|
|
if (state.wrap) {
|
||
|
|
//=== NEEDBITS(32);
|
||
|
|
while (bits < 32) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
// Use '|' insdead of '+' to make sure that result is signed
|
||
|
|
hold |= input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
_out -= left;
|
||
|
|
strm.total_out += _out;
|
||
|
|
state.total += _out;
|
||
|
|
if (_out) {
|
||
|
|
strm.adler = state.check =
|
||
|
|
/*UPDATE(state.check, put - _out, _out);*/
|
||
|
|
(state.flags ? crc32(state.check, output, _out, put - _out) : adler32(state.check, output, _out, put - _out));
|
||
|
|
|
||
|
|
}
|
||
|
|
_out = left;
|
||
|
|
// NB: crc32 stored as signed 32-bit int, zswap32 returns signed too
|
||
|
|
if ((state.flags ? hold : zswap32(hold)) !== state.check) {
|
||
|
|
strm.msg = 'incorrect data check';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
//Tracev((stderr, "inflate: check matches trailer\n"));
|
||
|
|
}
|
||
|
|
state.mode = LENGTH;
|
||
|
|
/* falls through */
|
||
|
|
case LENGTH:
|
||
|
|
if (state.wrap && state.flags) {
|
||
|
|
//=== NEEDBITS(32);
|
||
|
|
while (bits < 32) {
|
||
|
|
if (have === 0) { break inf_leave; }
|
||
|
|
have--;
|
||
|
|
hold += input[next++] << bits;
|
||
|
|
bits += 8;
|
||
|
|
}
|
||
|
|
//===//
|
||
|
|
if (hold !== (state.total & 0xffffffff)) {
|
||
|
|
strm.msg = 'incorrect length check';
|
||
|
|
state.mode = BAD;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
//=== INITBITS();
|
||
|
|
hold = 0;
|
||
|
|
bits = 0;
|
||
|
|
//===//
|
||
|
|
//Tracev((stderr, "inflate: length matches trailer\n"));
|
||
|
|
}
|
||
|
|
state.mode = DONE;
|
||
|
|
/* falls through */
|
||
|
|
case DONE:
|
||
|
|
ret = Z_STREAM_END;
|
||
|
|
break inf_leave;
|
||
|
|
case BAD:
|
||
|
|
ret = Z_DATA_ERROR;
|
||
|
|
break inf_leave;
|
||
|
|
case MEM:
|
||
|
|
return Z_MEM_ERROR;
|
||
|
|
case SYNC:
|
||
|
|
/* falls through */
|
||
|
|
default:
|
||
|
|
return Z_STREAM_ERROR;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// inf_leave <- here is real place for "goto inf_leave", emulated via "break inf_leave"
|
||
|
|
|
||
|
|
/*
|
||
|
|
Return from inflate(), updating the total counts and the check value.
|
||
|
|
If there was no progress during the inflate() call, return a buffer
|
||
|
|
error. Call updatewindow() to create and/or update the window state.
|
||
|
|
Note: a memory error from inflate() is non-recoverable.
|
||
|
|
*/
|
||
|
|
|
||
|
|
//--- RESTORE() ---
|
||
|
|
strm.next_out = put;
|
||
|
|
strm.avail_out = left;
|
||
|
|
strm.next_in = next;
|
||
|
|
strm.avail_in = have;
|
||
|
|
state.hold = hold;
|
||
|
|
state.bits = bits;
|
||
|
|
//---
|
||
|
|
|
||
|
|
if (state.wsize || (_out !== strm.avail_out && state.mode < BAD &&
|
||
|
|
(state.mode < CHECK || flush !== Z_FINISH))) {
|
||
|
|
if (updatewindow(strm, strm.output, strm.next_out, _out - strm.avail_out)) {
|
||
|
|
state.mode = MEM;
|
||
|
|
return Z_MEM_ERROR;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
_in -= strm.avail_in;
|
||
|
|
_out -= strm.avail_out;
|
||
|
|
strm.total_in += _in;
|
||
|
|
strm.total_out += _out;
|
||
|
|
state.total += _out;
|
||
|
|
if (state.wrap && _out) {
|
||
|
|
strm.adler = state.check = /*UPDATE(state.check, strm.next_out - _out, _out);*/
|
||
|
|
(state.flags ? crc32(state.check, output, _out, strm.next_out - _out) : adler32(state.check, output, _out, strm.next_out - _out));
|
||
|
|
}
|
||
|
|
strm.data_type = state.bits + (state.last ? 64 : 0) +
|
||
|
|
(state.mode === TYPE ? 128 : 0) +
|
||
|
|
(state.mode === LEN_ || state.mode === COPY_ ? 256 : 0);
|
||
|
|
if (((_in === 0 && _out === 0) || flush === Z_FINISH) && ret === Z_OK) {
|
||
|
|
ret = Z_BUF_ERROR;
|
||
|
|
}
|
||
|
|
return ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateEnd(strm) {
|
||
|
|
|
||
|
|
if (!strm || !strm.state /*|| strm->zfree == (free_func)0*/) {
|
||
|
|
return Z_STREAM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
var state = strm.state;
|
||
|
|
if (state.window) {
|
||
|
|
state.window = null;
|
||
|
|
}
|
||
|
|
strm.state = null;
|
||
|
|
return Z_OK;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateGetHeader(strm, head) {
|
||
|
|
var state;
|
||
|
|
|
||
|
|
/* check state */
|
||
|
|
if (!strm || !strm.state) { return Z_STREAM_ERROR; }
|
||
|
|
state = strm.state;
|
||
|
|
if ((state.wrap & 2) === 0) { return Z_STREAM_ERROR; }
|
||
|
|
|
||
|
|
/* save header structure */
|
||
|
|
state.head = head;
|
||
|
|
head.done = false;
|
||
|
|
return Z_OK;
|
||
|
|
}
|
||
|
|
|
||
|
|
function inflateSetDictionary(strm, dictionary) {
|
||
|
|
var dictLength = dictionary.length;
|
||
|
|
|
||
|
|
var state;
|
||
|
|
var dictid;
|
||
|
|
var ret;
|
||
|
|
|
||
|
|
/* check state */
|
||
|
|
if (!strm /* == Z_NULL */ || !strm.state /* == Z_NULL */) { return Z_STREAM_ERROR; }
|
||
|
|
state = strm.state;
|
||
|
|
|
||
|
|
if (state.wrap !== 0 && state.mode !== DICT) {
|
||
|
|
return Z_STREAM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* check for correct dictionary identifier */
|
||
|
|
if (state.mode === DICT) {
|
||
|
|
dictid = 1; /* adler32(0, null, 0)*/
|
||
|
|
/* dictid = adler32(dictid, dictionary, dictLength); */
|
||
|
|
dictid = adler32(dictid, dictionary, dictLength, 0);
|
||
|
|
if (dictid !== state.check) {
|
||
|
|
return Z_DATA_ERROR;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/* copy dictionary to window using updatewindow(), which will amend the
|
||
|
|
existing dictionary if appropriate */
|
||
|
|
ret = updatewindow(strm, dictionary, dictLength, dictLength);
|
||
|
|
if (ret) {
|
||
|
|
state.mode = MEM;
|
||
|
|
return Z_MEM_ERROR;
|
||
|
|
}
|
||
|
|
state.havedict = 1;
|
||
|
|
// Tracev((stderr, "inflate: dictionary set\n"));
|
||
|
|
return Z_OK;
|
||
|
|
}
|
||
|
|
|
||
|
|
export { inflateReset, inflateReset2, inflateResetKeep, inflateInit, inflateInit2, inflate, inflateEnd, inflateGetHeader, inflateSetDictionary };
|
||
|
|
export var inflateInfo = 'pako inflate (from Nodeca project)';
|
||
|
|
|
||
|
|
/* Not implemented
|
||
|
|
exports.inflateCopy = inflateCopy;
|
||
|
|
exports.inflateGetDictionary = inflateGetDictionary;
|
||
|
|
exports.inflateMark = inflateMark;
|
||
|
|
exports.inflatePrime = inflatePrime;
|
||
|
|
exports.inflateSync = inflateSync;
|
||
|
|
exports.inflateSyncPoint = inflateSyncPoint;
|
||
|
|
exports.inflateUndermine = inflateUndermine;
|
||
|
|
*/
|