File Explorer

1"use strict";2Object.defineProperty(exports, "__esModule", { value: true });3exports.MinipassSized = exports.SizeError = void 0;4const minipass_1 = require("minipass");5const isBufferEncoding = (enc) => typeof enc === 'string';6class SizeError extends Error {7    expect;8    found;9    code = 'EBADSIZE';10    constructor(found, expect, from) {11        super(`Bad data size: expected ${expect} bytes, but got ${found}`);12        this.expect = expect;13        this.found = found;14        Error.captureStackTrace(this, from ?? this.constructor);15    }16    get name() {17        return 'SizeError';18    }19}20exports.SizeError = SizeError;21class MinipassSized extends minipass_1.Minipass {22    found = 0;23    expect;24    constructor(options) {25        const size = options?.size;26        if (typeof size !== 'number' ||27            size > Number.MAX_SAFE_INTEGER ||28            isNaN(size) ||29            size < 0 ||30            !isFinite(size) ||31            size !== Math.floor(size)) {32            throw new Error('invalid expected size: ' + size);33        }34        //@ts-ignore35        super(options);36        if (options.objectMode) {37            throw new TypeError(`${this.constructor.name} streams only work with string and buffer data`);38        }39        this.expect = size;40    }41    write(chunk, encoding, cb) {42        const buffer = Buffer.isBuffer(chunk) ? chunk43            : typeof chunk === 'string' ?44                Buffer.from(chunk, isBufferEncoding(encoding) ? encoding : 'utf8')45                : chunk;46        if (typeof encoding === 'function') {47            cb = encoding;48            encoding = null;49        }50        if (!Buffer.isBuffer(buffer)) {51            this.emit('error', new TypeError(`${this.constructor.name} streams only work with string and buffer data`));52            return false;53        }54        this.found += buffer.length;55        if (this.found > this.expect)56            this.emit('error', new SizeError(this.found, this.expect));57        return super.write(chunk, encoding, cb);58    }59    emit(ev, ...args) {60        if (ev === 'end') {61            if (this.found !== this.expect) {62                this.emit('error', new SizeError(this.found, this.expect, this.emit));63            }64        }65        return super.emit(ev, ...args);66    }67}68exports.MinipassSized = MinipassSized;69//# sourceMappingURL=index.js.map