diff options
| author | pack <pack@packgekko.xyz> | 2026-08-09 10:54:08 +0000 |
|---|---|---|
| committer | pack <pack@packgekko.xyz> | 2026-08-09 10:54:08 +0000 |
| commit | d3adc16a08d95d6e331de55d7d3bf05a66a874a8 (patch) | |
| tree | a2dabd199501e67c547c2ce79e1374ca3aa55443 /node_modules/minizlib/dist/esm/index.js | |
| parent | 55a4f1fc869e41aca748c63d3018f0448b1606e0 (diff) | |
| download | crud-d3adc16a08d95d6e331de55d7d3bf05a66a874a8.tar.gz | |
stop tracking node_modules/
Diffstat (limited to '')
| -rw-r--r-- | node_modules/minizlib/dist/esm/index.js | 363 |
1 files changed, 0 insertions, 363 deletions
diff --git a/node_modules/minizlib/dist/esm/index.js b/node_modules/minizlib/dist/esm/index.js deleted file mode 100644 index b70ba1f..0000000 --- a/node_modules/minizlib/dist/esm/index.js +++ /dev/null @@ -1,363 +0,0 @@ -import assert from 'assert'; -import { Buffer } from 'buffer'; -import { Minipass } from 'minipass'; -import * as realZlib from 'zlib'; -import { constants } from './constants.js'; -export { constants } from './constants.js'; -const OriginalBufferConcat = Buffer.concat; -const desc = Object.getOwnPropertyDescriptor(Buffer, 'concat'); -const noop = (args) => args; -const passthroughBufferConcat = desc?.writable === true || desc?.set !== undefined - ? (makeNoOp) => { - Buffer.concat = makeNoOp ? noop : OriginalBufferConcat; - } - : (_) => { }; -const _superWrite = Symbol('_superWrite'); -export class ZlibError extends Error { - code; - errno; - constructor(err, origin) { - super('zlib: ' + err.message, { cause: err }); - this.code = err.code; - this.errno = err.errno; - /* c8 ignore next */ - if (!this.code) - this.code = 'ZLIB_ERROR'; - this.message = 'zlib: ' + err.message; - Error.captureStackTrace(this, origin ?? this.constructor); - } - get name() { - return 'ZlibError'; - } -} -// the Zlib class they all inherit from -// This thing manages the queue of requests, and returns -// true or false if there is anything in the queue when -// you call the .write() method. -const _flushFlag = Symbol('flushFlag'); -class ZlibBase extends Minipass { - #sawError = false; - #ended = false; - #flushFlag; - #finishFlushFlag; - #fullFlushFlag; - #handle; - #onError; - get sawError() { - return this.#sawError; - } - get handle() { - return this.#handle; - } - /* c8 ignore start */ - get flushFlag() { - return this.#flushFlag; - } - /* c8 ignore stop */ - constructor(opts, mode) { - if (!opts || typeof opts !== 'object') - throw new TypeError('invalid options for ZlibBase constructor'); - //@ts-ignore - super(opts); - /* c8 ignore start */ - this.#flushFlag = opts.flush ?? 0; - this.#finishFlushFlag = opts.finishFlush ?? 0; - this.#fullFlushFlag = opts.fullFlushFlag ?? 0; - /* c8 ignore stop */ - //@ts-ignore - if (typeof realZlib[mode] !== 'function') { - throw new TypeError('Compression method not supported: ' + mode); - } - // this will throw if any options are invalid for the class selected - try { - // @types/node doesn't know that it exports the classes, but they're there - //@ts-ignore - this.#handle = new realZlib[mode](opts); - } - catch (er) { - // make sure that all errors get decorated properly - throw new ZlibError(er, this.constructor); - } - this.#onError = err => { - // no sense raising multiple errors, since we abort on the first one. - if (this.#sawError) - return; - this.#sawError = true; - // there is no way to cleanly recover. - // continuing only obscures problems. - this.close(); - this.emit('error', err); - }; - this.#handle?.on('error', er => this.#onError(new ZlibError(er))); - this.once('end', () => this.close); - } - close() { - if (this.#handle) { - this.#handle.close(); - this.#handle = undefined; - this.emit('close'); - } - } - reset() { - if (!this.#sawError) { - assert(this.#handle, 'zlib binding closed'); - //@ts-ignore - return this.#handle.reset?.(); - } - } - flush(flushFlag) { - if (this.ended) - return; - if (typeof flushFlag !== 'number') - flushFlag = this.#fullFlushFlag; - this.write(Object.assign(Buffer.alloc(0), { [_flushFlag]: flushFlag })); - } - end(chunk, encoding, cb) { - /* c8 ignore start */ - if (typeof chunk === 'function') { - cb = chunk; - encoding = undefined; - chunk = undefined; - } - if (typeof encoding === 'function') { - cb = encoding; - encoding = undefined; - } - /* c8 ignore stop */ - if (chunk) { - if (encoding) - this.write(chunk, encoding); - else - this.write(chunk); - } - this.flush(this.#finishFlushFlag); - this.#ended = true; - return super.end(cb); - } - get ended() { - return this.#ended; - } - // overridden in the gzip classes to do portable writes - [_superWrite](data) { - return super.write(data); - } - write(chunk, encoding, cb) { - // process the chunk using the sync process - // then super.write() all the outputted chunks - if (typeof encoding === 'function') - (cb = encoding), (encoding = 'utf8'); - if (typeof chunk === 'string') - chunk = Buffer.from(chunk, encoding); - if (this.#sawError) - return; - assert(this.#handle, 'zlib binding closed'); - // _processChunk tries to .close() the native handle after it's done, so we - // intercept that by temporarily making it a no-op. - // diving into the node:zlib internals a bit here - const nativeHandle = this.#handle - ._handle; - const originalNativeClose = nativeHandle.close; - nativeHandle.close = () => { }; - const originalClose = this.#handle.close; - this.#handle.close = () => { }; - // It also calls `Buffer.concat()` at the end, which may be convenient - // for some, but which we are not interested in as it slows us down. - passthroughBufferConcat(true); - let result = undefined; - try { - const flushFlag = typeof chunk[_flushFlag] === 'number' - ? chunk[_flushFlag] - : this.#flushFlag; - result = this.#handle._processChunk(chunk, flushFlag); - // if we don't throw, reset it back how it was - passthroughBufferConcat(false); - } - catch (err) { - // or if we do, put Buffer.concat() back before we emit error - // Error events call into user code, which may call Buffer.concat() - passthroughBufferConcat(false); - this.#onError(new ZlibError(err, this.write)); - } - finally { - if (this.#handle) { - // Core zlib resets `_handle` to null after attempting to close the - // native handle. Our no-op handler prevented actual closure, but we - // need to restore the `._handle` property. - ; - this.#handle._handle = - nativeHandle; - nativeHandle.close = originalNativeClose; - this.#handle.close = originalClose; - // `_processChunk()` adds an 'error' listener. If we don't remove it - // after each call, these handlers start piling up. - this.#handle.removeAllListeners('error'); - // make sure OUR error listener is still attached tho - } - } - if (this.#handle) - this.#handle.on('error', er => this.#onError(new ZlibError(er, this.write))); - let writeReturn; - if (result) { - if (Array.isArray(result) && result.length > 0) { - const r = result[0]; - // The first buffer is always `handle._outBuffer`, which would be - // re-used for later invocations; so, we always have to copy that one. - writeReturn = this[_superWrite](Buffer.from(r)); - for (let i = 1; i < result.length; i++) { - writeReturn = this[_superWrite](result[i]); - } - } - else { - // either a single Buffer or an empty array - writeReturn = this[_superWrite](Buffer.from(result)); - } - } - if (cb) - cb(); - return writeReturn; - } -} -export class Zlib extends ZlibBase { - #level; - #strategy; - constructor(opts, mode) { - opts = opts || {}; - opts.flush = opts.flush || constants.Z_NO_FLUSH; - opts.finishFlush = opts.finishFlush || constants.Z_FINISH; - opts.fullFlushFlag = constants.Z_FULL_FLUSH; - super(opts, mode); - this.#level = opts.level; - this.#strategy = opts.strategy; - } - params(level, strategy) { - if (this.sawError) - return; - if (!this.handle) - throw new Error('cannot switch params when binding is closed'); - // no way to test this without also not supporting params at all - /* c8 ignore start */ - if (!this.handle.params) - throw new Error('not supported in this implementation'); - /* c8 ignore stop */ - if (this.#level !== level || this.#strategy !== strategy) { - this.flush(constants.Z_SYNC_FLUSH); - assert(this.handle, 'zlib binding closed'); - // .params() calls .flush(), but the latter is always async in the - // core zlib. We override .flush() temporarily to intercept that and - // flush synchronously. - const origFlush = this.handle.flush; - this.handle.flush = (flushFlag, cb) => { - /* c8 ignore start */ - if (typeof flushFlag === 'function') { - cb = flushFlag; - flushFlag = this.flushFlag; - } - /* c8 ignore stop */ - this.flush(flushFlag); - cb?.(); - }; - try { - ; - this.handle.params(level, strategy); - } - finally { - this.handle.flush = origFlush; - } - /* c8 ignore start */ - if (this.handle) { - this.#level = level; - this.#strategy = strategy; - } - /* c8 ignore stop */ - } - } -} -// minimal 2-byte header -export class Deflate extends Zlib { - constructor(opts) { - super(opts, 'Deflate'); - } -} -export class Inflate extends Zlib { - constructor(opts) { - super(opts, 'Inflate'); - } -} -export class Gzip extends Zlib { - #portable; - constructor(opts) { - super(opts, 'Gzip'); - this.#portable = opts && !!opts.portable; - } - [_superWrite](data) { - if (!this.#portable) - return super[_superWrite](data); - // we'll always get the header emitted in one first chunk - // overwrite the OS indicator byte with 0xFF - this.#portable = false; - data[9] = 255; - return super[_superWrite](data); - } -} -export class Gunzip extends Zlib { - constructor(opts) { - super(opts, 'Gunzip'); - } -} -// raw - no header -export class DeflateRaw extends Zlib { - constructor(opts) { - super(opts, 'DeflateRaw'); - } -} -export class InflateRaw extends Zlib { - constructor(opts) { - super(opts, 'InflateRaw'); - } -} -// auto-detect header. -export class Unzip extends Zlib { - constructor(opts) { - super(opts, 'Unzip'); - } -} -class Brotli extends ZlibBase { - constructor(opts, mode) { - opts = opts || {}; - opts.flush = opts.flush || constants.BROTLI_OPERATION_PROCESS; - opts.finishFlush = - opts.finishFlush || constants.BROTLI_OPERATION_FINISH; - opts.fullFlushFlag = constants.BROTLI_OPERATION_FLUSH; - super(opts, mode); - } -} -export class BrotliCompress extends Brotli { - constructor(opts) { - super(opts, 'BrotliCompress'); - } -} -export class BrotliDecompress extends Brotli { - constructor(opts) { - super(opts, 'BrotliDecompress'); - } -} -class Zstd extends ZlibBase { - constructor(opts, mode) { - opts = opts || {}; - opts.flush = opts.flush || constants.ZSTD_e_continue; - opts.finishFlush = opts.finishFlush || constants.ZSTD_e_end; - opts.fullFlushFlag = constants.ZSTD_e_flush; - super(opts, mode); - } -} -export class ZstdCompress extends Zstd { - constructor(opts) { - super(opts, 'ZstdCompress'); - } -} -export class ZstdDecompress extends Zstd { - constructor(opts) { - super(opts, 'ZstdDecompress'); - } -} -//# sourceMappingURL=index.js.map
\ No newline at end of file |