mirror of
https://github.com/PrivateBin/PrivateBin.git
synced 2026-04-15 21:16:59 -04:00
114 lines
3.9 KiB
JavaScript
114 lines
3.9 KiB
JavaScript
'use strict';
|
|
|
|
(function () {
|
|
let ret;
|
|
|
|
async function initialize() {
|
|
if (ret) return ret;
|
|
|
|
const COMPRESSION_LEVEL = 7;
|
|
const NO_ZLIB_HEADER = -1;
|
|
const CHUNK_SIZE = 32 * 1024;
|
|
const Module = await import('zlib-1.3.2.mjs');
|
|
Module.map = {};
|
|
const srcPtr = Module.__malloc(CHUNK_SIZE);
|
|
const dstPtr = Module.__malloc(CHUNK_SIZE);
|
|
|
|
class RawDef {
|
|
constructor() {
|
|
this.zstreamPtr = Module.__createDeflateContext(COMPRESSION_LEVEL, NO_ZLIB_HEADER);
|
|
Module.map[this.zstreamPtr] = this;
|
|
this.offset = 0;
|
|
this.buff = new Uint8Array(CHUNK_SIZE);
|
|
}
|
|
|
|
deflate(chunk, flush) {
|
|
Module.HEAPU8.set(chunk, srcPtr);
|
|
Module.__deflate(this.zstreamPtr, srcPtr, dstPtr, chunk.length, CHUNK_SIZE, flush);
|
|
}
|
|
|
|
onData(chunk) {
|
|
if (this.buff.length < this.offset + chunk.length) {
|
|
const buff = this.buff;
|
|
this.buff = new Uint8Array(this.buff.length * 2);
|
|
this.buff.set(buff);
|
|
}
|
|
this.buff.set(chunk, this.offset);
|
|
this.offset += chunk.length;
|
|
}
|
|
|
|
destroy() {
|
|
Module.__freeDeflateContext(this.zstreamPtr);
|
|
delete Module.map[this.zstreamPtr];
|
|
this.buff = null;
|
|
}
|
|
|
|
getBuffer() {
|
|
return Buffer.from(this.buff.buffer, 0, this.offset);
|
|
}
|
|
}
|
|
|
|
class RawInf {
|
|
constructor() {
|
|
this.zstreamPtr = Module.__createInflateContext(NO_ZLIB_HEADER);
|
|
Module.map[this.zstreamPtr] = this;
|
|
this.offset = 0;
|
|
this.buff = new Uint8Array(CHUNK_SIZE);
|
|
}
|
|
|
|
inflate(chunk) {
|
|
Module.HEAPU8.set(chunk, srcPtr);
|
|
Module.__inflate(this.zstreamPtr, srcPtr, dstPtr, chunk.length, CHUNK_SIZE);
|
|
}
|
|
|
|
onData(chunk) {
|
|
if (this.buff.length < this.offset + chunk.length) {
|
|
const buff = this.buff;
|
|
this.buff = new Uint8Array(this.buff.length * 2);
|
|
this.buff.set(buff);
|
|
}
|
|
this.buff.set(chunk, this.offset);
|
|
this.offset += chunk.length;
|
|
}
|
|
|
|
destroy() {
|
|
Module.__freeInflateContext(this.zstreamPtr);
|
|
delete Module.map[this.zstreamPtr];
|
|
this.buff = null;
|
|
}
|
|
|
|
getBuffer() {
|
|
return Buffer.from(this.buff.buffer, 0, this.offset);
|
|
}
|
|
}
|
|
|
|
ret = {
|
|
inflate(rawDeflateBuffer) {
|
|
const rawInf = new RawInf();
|
|
for (let offset = 0; offset < rawDeflateBuffer.length; offset += CHUNK_SIZE) {
|
|
const end = Math.min(offset + CHUNK_SIZE, rawDeflateBuffer.length);
|
|
const chunk = rawDeflateBuffer.subarray(offset, end);
|
|
rawInf.inflate(chunk);
|
|
}
|
|
const ret = rawInf.getBuffer();
|
|
rawInf.destroy();
|
|
return ret;
|
|
},
|
|
deflate(rawInflateBuffer) {
|
|
const rawDef = new RawDef();
|
|
for (let offset = 0; offset < rawInflateBuffer.length; offset += CHUNK_SIZE) {
|
|
const end = Math.min(offset + CHUNK_SIZE, rawInflateBuffer.length);
|
|
const chunk = rawInflateBuffer.subarray(offset, end);
|
|
rawDef.deflate(chunk, rawInflateBuffer.length <= offset + CHUNK_SIZE);
|
|
}
|
|
const ret = rawDef.getBuffer();
|
|
rawDef.destroy();
|
|
return ret;
|
|
},
|
|
};
|
|
|
|
return ret;
|
|
}
|
|
this.zlib = initialize();
|
|
}).call(this);
|