86 lines
2.5 KiB
JavaScript
86 lines
2.5 KiB
JavaScript
|
/*
|
||
|
|
* noVNC: HTML5 VNC client
|
||
|
|
* Copyright (C) 2020 The noVNC Authors
|
||
|
|
* Licensed under MPL 2.0 (see LICENSE.txt)
|
||
|
|
*
|
||
|
|
* See README.md for usage and integration instructions.
|
||
|
|
*/
|
||
|
|
|
||
|
|
import { deflateInit, deflate } from "../vendor/pako/lib/zlib/deflate.js";
|
||
|
|
import { Z_FULL_FLUSH } from "../vendor/pako/lib/zlib/deflate.js";
|
||
|
|
import ZStream from "../vendor/pako/lib/zlib/zstream.js";
|
||
|
|
|
||
|
|
export default class Deflator {
|
||
|
|
constructor() {
|
||
|
|
this.strm = new ZStream();
|
||
|
|
this.chunkSize = 1024 * 10 * 10;
|
||
|
|
this.outputBuffer = new Uint8Array(this.chunkSize);
|
||
|
|
this.windowBits = 5;
|
||
|
|
|
||
|
|
deflateInit(this.strm, this.windowBits);
|
||
|
|
}
|
||
|
|
|
||
|
|
deflate(inData) {
|
||
|
|
/* eslint-disable camelcase */
|
||
|
|
this.strm.input = inData;
|
||
|
|
this.strm.avail_in = this.strm.input.length;
|
||
|
|
this.strm.next_in = 0;
|
||
|
|
this.strm.output = this.outputBuffer;
|
||
|
|
this.strm.avail_out = this.chunkSize;
|
||
|
|
this.strm.next_out = 0;
|
||
|
|
/* eslint-enable camelcase */
|
||
|
|
|
||
|
|
let lastRet = deflate(this.strm, Z_FULL_FLUSH);
|
||
|
|
let outData = new Uint8Array(this.strm.output.buffer, 0, this.strm.next_out);
|
||
|
|
|
||
|
|
if (lastRet < 0) {
|
||
|
|
throw new Error("zlib deflate failed");
|
||
|
|
}
|
||
|
|
|
||
|
|
if (this.strm.avail_in > 0) {
|
||
|
|
// Read chunks until done
|
||
|
|
|
||
|
|
let chunks = [outData];
|
||
|
|
let totalLen = outData.length;
|
||
|
|
do {
|
||
|
|
/* eslint-disable camelcase */
|
||
|
|
this.strm.output = new Uint8Array(this.chunkSize);
|
||
|
|
this.strm.next_out = 0;
|
||
|
|
this.strm.avail_out = this.chunkSize;
|
||
|
|
/* eslint-enable camelcase */
|
||
|
|
|
||
|
|
lastRet = deflate(this.strm, Z_FULL_FLUSH);
|
||
|
|
|
||
|
|
if (lastRet < 0) {
|
||
|
|
throw new Error("zlib deflate failed");
|
||
|
|
}
|
||
|
|
|
||
|
|
let chunk = new Uint8Array(this.strm.output.buffer, 0, this.strm.next_out);
|
||
|
|
totalLen += chunk.length;
|
||
|
|
chunks.push(chunk);
|
||
|
|
} while (this.strm.avail_in > 0);
|
||
|
|
|
||
|
|
// Combine chunks into a single data
|
||
|
|
|
||
|
|
let newData = new Uint8Array(totalLen);
|
||
|
|
let offset = 0;
|
||
|
|
|
||
|
|
for (let i = 0; i < chunks.length; i++) {
|
||
|
|
newData.set(chunks[i], offset);
|
||
|
|
offset += chunks[i].length;
|
||
|
|
}
|
||
|
|
|
||
|
|
outData = newData;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* eslint-disable camelcase */
|
||
|
|
this.strm.input = null;
|
||
|
|
this.strm.avail_in = 0;
|
||
|
|
this.strm.next_in = 0;
|
||
|
|
/* eslint-enable camelcase */
|
||
|
|
|
||
|
|
return outData;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|