| /* |
| * 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; |
| } |
| |
| } |