aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/@isaacs/fs-minipass/dist/esm
diff options
context:
space:
mode:
authorpack <pack@packgekko.xyz>2026-08-09 10:54:08 +0000
committerpack <pack@packgekko.xyz>2026-08-09 10:54:08 +0000
commitd3adc16a08d95d6e331de55d7d3bf05a66a874a8 (patch)
treea2dabd199501e67c547c2ce79e1374ca3aa55443 /node_modules/@isaacs/fs-minipass/dist/esm
parent55a4f1fc869e41aca748c63d3018f0448b1606e0 (diff)
downloadcrud-d3adc16a08d95d6e331de55d7d3bf05a66a874a8.tar.gz
stop tracking node_modules/
Diffstat (limited to '')
-rw-r--r--node_modules/@isaacs/fs-minipass/dist/esm/index.d.ts118
-rw-r--r--node_modules/@isaacs/fs-minipass/dist/esm/index.js420
-rw-r--r--node_modules/@isaacs/fs-minipass/dist/esm/package.json3
3 files changed, 0 insertions, 541 deletions
diff --git a/node_modules/@isaacs/fs-minipass/dist/esm/index.d.ts b/node_modules/@isaacs/fs-minipass/dist/esm/index.d.ts
deleted file mode 100644
index 54aebe1..0000000
--- a/node_modules/@isaacs/fs-minipass/dist/esm/index.d.ts
+++ /dev/null
@@ -1,118 +0,0 @@
-/// <reference types="node" resolution-mode="require"/>
-/// <reference types="node" resolution-mode="require"/>
-/// <reference types="node" resolution-mode="require"/>
-import EE from 'events';
-import { Minipass } from 'minipass';
-declare const _autoClose: unique symbol;
-declare const _close: unique symbol;
-declare const _ended: unique symbol;
-declare const _fd: unique symbol;
-declare const _finished: unique symbol;
-declare const _flags: unique symbol;
-declare const _flush: unique symbol;
-declare const _handleChunk: unique symbol;
-declare const _makeBuf: unique symbol;
-declare const _mode: unique symbol;
-declare const _needDrain: unique symbol;
-declare const _onerror: unique symbol;
-declare const _onopen: unique symbol;
-declare const _onread: unique symbol;
-declare const _onwrite: unique symbol;
-declare const _open: unique symbol;
-declare const _path: unique symbol;
-declare const _pos: unique symbol;
-declare const _queue: unique symbol;
-declare const _read: unique symbol;
-declare const _readSize: unique symbol;
-declare const _reading: unique symbol;
-declare const _remain: unique symbol;
-declare const _size: unique symbol;
-declare const _write: unique symbol;
-declare const _writing: unique symbol;
-declare const _defaultFlag: unique symbol;
-declare const _errored: unique symbol;
-export type ReadStreamOptions = Minipass.Options<Minipass.ContiguousData> & {
- fd?: number;
- readSize?: number;
- size?: number;
- autoClose?: boolean;
-};
-export type ReadStreamEvents = Minipass.Events<Minipass.ContiguousData> & {
- open: [fd: number];
-};
-export declare class ReadStream extends Minipass<Minipass.ContiguousData, Buffer, ReadStreamEvents> {
- [_errored]: boolean;
- [_fd]?: number;
- [_path]: string;
- [_readSize]: number;
- [_reading]: boolean;
- [_size]: number;
- [_remain]: number;
- [_autoClose]: boolean;
- constructor(path: string, opt: ReadStreamOptions);
- get fd(): number | undefined;
- get path(): string;
- write(): void;
- end(): void;
- [_open](): void;
- [_onopen](er?: NodeJS.ErrnoException | null, fd?: number): void;
- [_makeBuf](): Buffer;
- [_read](): void;
- [_onread](er?: NodeJS.ErrnoException | null, br?: number, buf?: Buffer): void;
- [_close](): void;
- [_onerror](er: NodeJS.ErrnoException): void;
- [_handleChunk](br: number, buf: Buffer): boolean;
- emit<Event extends keyof ReadStreamEvents>(ev: Event, ...args: ReadStreamEvents[Event]): boolean;
-}
-export declare class ReadStreamSync extends ReadStream {
- [_open](): void;
- [_read](): void;
- [_close](): void;
-}
-export type WriteStreamOptions = {
- fd?: number;
- autoClose?: boolean;
- mode?: number;
- captureRejections?: boolean;
- start?: number;
- flags?: string;
-};
-export declare class WriteStream extends EE {
- readable: false;
- writable: boolean;
- [_errored]: boolean;
- [_writing]: boolean;
- [_ended]: boolean;
- [_queue]: Buffer[];
- [_needDrain]: boolean;
- [_path]: string;
- [_mode]: number;
- [_autoClose]: boolean;
- [_fd]?: number;
- [_defaultFlag]: boolean;
- [_flags]: string;
- [_finished]: boolean;
- [_pos]?: number;
- constructor(path: string, opt: WriteStreamOptions);
- emit(ev: string, ...args: any[]): boolean;
- get fd(): number | undefined;
- get path(): string;
- [_onerror](er: NodeJS.ErrnoException): void;
- [_open](): void;
- [_onopen](er?: null | NodeJS.ErrnoException, fd?: number): void;
- end(buf: string, enc?: BufferEncoding): this;
- end(buf?: Buffer, enc?: undefined): this;
- write(buf: string, enc?: BufferEncoding): boolean;
- write(buf: Buffer, enc?: undefined): boolean;
- [_write](buf: Buffer): void;
- [_onwrite](er?: null | NodeJS.ErrnoException, bw?: number): void;
- [_flush](): void;
- [_close](): void;
-}
-export declare class WriteStreamSync extends WriteStream {
- [_open](): void;
- [_close](): void;
- [_write](buf: Buffer): void;
-}
-export {};
-//# sourceMappingURL=index.d.ts.map \ No newline at end of file
diff --git a/node_modules/@isaacs/fs-minipass/dist/esm/index.js b/node_modules/@isaacs/fs-minipass/dist/esm/index.js
deleted file mode 100644
index 287a0f6..0000000
--- a/node_modules/@isaacs/fs-minipass/dist/esm/index.js
+++ /dev/null
@@ -1,420 +0,0 @@
-import EE from 'events';
-import fs from 'fs';
-import { Minipass } from 'minipass';
-const writev = fs.writev;
-const _autoClose = Symbol('_autoClose');
-const _close = Symbol('_close');
-const _ended = Symbol('_ended');
-const _fd = Symbol('_fd');
-const _finished = Symbol('_finished');
-const _flags = Symbol('_flags');
-const _flush = Symbol('_flush');
-const _handleChunk = Symbol('_handleChunk');
-const _makeBuf = Symbol('_makeBuf');
-const _mode = Symbol('_mode');
-const _needDrain = Symbol('_needDrain');
-const _onerror = Symbol('_onerror');
-const _onopen = Symbol('_onopen');
-const _onread = Symbol('_onread');
-const _onwrite = Symbol('_onwrite');
-const _open = Symbol('_open');
-const _path = Symbol('_path');
-const _pos = Symbol('_pos');
-const _queue = Symbol('_queue');
-const _read = Symbol('_read');
-const _readSize = Symbol('_readSize');
-const _reading = Symbol('_reading');
-const _remain = Symbol('_remain');
-const _size = Symbol('_size');
-const _write = Symbol('_write');
-const _writing = Symbol('_writing');
-const _defaultFlag = Symbol('_defaultFlag');
-const _errored = Symbol('_errored');
-export class ReadStream extends Minipass {
- [_errored] = false;
- [_fd];
- [_path];
- [_readSize];
- [_reading] = false;
- [_size];
- [_remain];
- [_autoClose];
- constructor(path, opt) {
- opt = opt || {};
- super(opt);
- this.readable = true;
- this.writable = false;
- if (typeof path !== 'string') {
- throw new TypeError('path must be a string');
- }
- this[_errored] = false;
- this[_fd] = typeof opt.fd === 'number' ? opt.fd : undefined;
- this[_path] = path;
- this[_readSize] = opt.readSize || 16 * 1024 * 1024;
- this[_reading] = false;
- this[_size] = typeof opt.size === 'number' ? opt.size : Infinity;
- this[_remain] = this[_size];
- this[_autoClose] =
- typeof opt.autoClose === 'boolean' ? opt.autoClose : true;
- if (typeof this[_fd] === 'number') {
- this[_read]();
- }
- else {
- this[_open]();
- }
- }
- get fd() {
- return this[_fd];
- }
- get path() {
- return this[_path];
- }
- //@ts-ignore
- write() {
- throw new TypeError('this is a readable stream');
- }
- //@ts-ignore
- end() {
- throw new TypeError('this is a readable stream');
- }
- [_open]() {
- fs.open(this[_path], 'r', (er, fd) => this[_onopen](er, fd));
- }
- [_onopen](er, fd) {
- if (er) {
- this[_onerror](er);
- }
- else {
- this[_fd] = fd;
- this.emit('open', fd);
- this[_read]();
- }
- }
- [_makeBuf]() {
- return Buffer.allocUnsafe(Math.min(this[_readSize], this[_remain]));
- }
- [_read]() {
- if (!this[_reading]) {
- this[_reading] = true;
- const buf = this[_makeBuf]();
- /* c8 ignore start */
- if (buf.length === 0) {
- return process.nextTick(() => this[_onread](null, 0, buf));
- }
- /* c8 ignore stop */
- fs.read(this[_fd], buf, 0, buf.length, null, (er, br, b) => this[_onread](er, br, b));
- }
- }
- [_onread](er, br, buf) {
- this[_reading] = false;
- if (er) {
- this[_onerror](er);
- }
- else if (this[_handleChunk](br, buf)) {
- this[_read]();
- }
- }
- [_close]() {
- if (this[_autoClose] && typeof this[_fd] === 'number') {
- const fd = this[_fd];
- this[_fd] = undefined;
- fs.close(fd, er => er ? this.emit('error', er) : this.emit('close'));
- }
- }
- [_onerror](er) {
- this[_reading] = true;
- this[_close]();
- this.emit('error', er);
- }
- [_handleChunk](br, buf) {
- let ret = false;
- // no effect if infinite
- this[_remain] -= br;
- if (br > 0) {
- ret = super.write(br < buf.length ? buf.subarray(0, br) : buf);
- }
- if (br === 0 || this[_remain] <= 0) {
- ret = false;
- this[_close]();
- super.end();
- }
- return ret;
- }
- emit(ev, ...args) {
- switch (ev) {
- case 'prefinish':
- case 'finish':
- return false;
- case 'drain':
- if (typeof this[_fd] === 'number') {
- this[_read]();
- }
- return false;
- case 'error':
- if (this[_errored]) {
- return false;
- }
- this[_errored] = true;
- return super.emit(ev, ...args);
- default:
- return super.emit(ev, ...args);
- }
- }
-}
-export class ReadStreamSync extends ReadStream {
- [_open]() {
- let threw = true;
- try {
- this[_onopen](null, fs.openSync(this[_path], 'r'));
- threw = false;
- }
- finally {
- if (threw) {
- this[_close]();
- }
- }
- }
- [_read]() {
- let threw = true;
- try {
- if (!this[_reading]) {
- this[_reading] = true;
- do {
- const buf = this[_makeBuf]();
- /* c8 ignore start */
- const br = buf.length === 0
- ? 0
- : fs.readSync(this[_fd], buf, 0, buf.length, null);
- /* c8 ignore stop */
- if (!this[_handleChunk](br, buf)) {
- break;
- }
- } while (true);
- this[_reading] = false;
- }
- threw = false;
- }
- finally {
- if (threw) {
- this[_close]();
- }
- }
- }
- [_close]() {
- if (this[_autoClose] && typeof this[_fd] === 'number') {
- const fd = this[_fd];
- this[_fd] = undefined;
- fs.closeSync(fd);
- this.emit('close');
- }
- }
-}
-export class WriteStream extends EE {
- readable = false;
- writable = true;
- [_errored] = false;
- [_writing] = false;
- [_ended] = false;
- [_queue] = [];
- [_needDrain] = false;
- [_path];
- [_mode];
- [_autoClose];
- [_fd];
- [_defaultFlag];
- [_flags];
- [_finished] = false;
- [_pos];
- constructor(path, opt) {
- opt = opt || {};
- super(opt);
- this[_path] = path;
- this[_fd] = typeof opt.fd === 'number' ? opt.fd : undefined;
- this[_mode] = opt.mode === undefined ? 0o666 : opt.mode;
- this[_pos] = typeof opt.start === 'number' ? opt.start : undefined;
- this[_autoClose] =
- typeof opt.autoClose === 'boolean' ? opt.autoClose : true;
- // truncating makes no sense when writing into the middle
- const defaultFlag = this[_pos] !== undefined ? 'r+' : 'w';
- this[_defaultFlag] = opt.flags === undefined;
- this[_flags] = opt.flags === undefined ? defaultFlag : opt.flags;
- if (this[_fd] === undefined) {
- this[_open]();
- }
- }
- emit(ev, ...args) {
- if (ev === 'error') {
- if (this[_errored]) {
- return false;
- }
- this[_errored] = true;
- }
- return super.emit(ev, ...args);
- }
- get fd() {
- return this[_fd];
- }
- get path() {
- return this[_path];
- }
- [_onerror](er) {
- this[_close]();
- this[_writing] = true;
- this.emit('error', er);
- }
- [_open]() {
- fs.open(this[_path], this[_flags], this[_mode], (er, fd) => this[_onopen](er, fd));
- }
- [_onopen](er, fd) {
- if (this[_defaultFlag] &&
- this[_flags] === 'r+' &&
- er &&
- er.code === 'ENOENT') {
- this[_flags] = 'w';
- this[_open]();
- }
- else if (er) {
- this[_onerror](er);
- }
- else {
- this[_fd] = fd;
- this.emit('open', fd);
- if (!this[_writing]) {
- this[_flush]();
- }
- }
- }
- end(buf, enc) {
- if (buf) {
- //@ts-ignore
- this.write(buf, enc);
- }
- this[_ended] = true;
- // synthetic after-write logic, where drain/finish live
- if (!this[_writing] &&
- !this[_queue].length &&
- typeof this[_fd] === 'number') {
- this[_onwrite](null, 0);
- }
- return this;
- }
- write(buf, enc) {
- if (typeof buf === 'string') {
- buf = Buffer.from(buf, enc);
- }
- if (this[_ended]) {
- this.emit('error', new Error('write() after end()'));
- return false;
- }
- if (this[_fd] === undefined || this[_writing] || this[_queue].length) {
- this[_queue].push(buf);
- this[_needDrain] = true;
- return false;
- }
- this[_writing] = true;
- this[_write](buf);
- return true;
- }
- [_write](buf) {
- fs.write(this[_fd], buf, 0, buf.length, this[_pos], (er, bw) => this[_onwrite](er, bw));
- }
- [_onwrite](er, bw) {
- if (er) {
- this[_onerror](er);
- }
- else {
- if (this[_pos] !== undefined && typeof bw === 'number') {
- this[_pos] += bw;
- }
- if (this[_queue].length) {
- this[_flush]();
- }
- else {
- this[_writing] = false;
- if (this[_ended] && !this[_finished]) {
- this[_finished] = true;
- this[_close]();
- this.emit('finish');
- }
- else if (this[_needDrain]) {
- this[_needDrain] = false;
- this.emit('drain');
- }
- }
- }
- }
- [_flush]() {
- if (this[_queue].length === 0) {
- if (this[_ended]) {
- this[_onwrite](null, 0);
- }
- }
- else if (this[_queue].length === 1) {
- this[_write](this[_queue].pop());
- }
- else {
- const iovec = this[_queue];
- this[_queue] = [];
- writev(this[_fd], iovec, this[_pos], (er, bw) => this[_onwrite](er, bw));
- }
- }
- [_close]() {
- if (this[_autoClose] && typeof this[_fd] === 'number') {
- const fd = this[_fd];
- this[_fd] = undefined;
- fs.close(fd, er => er ? this.emit('error', er) : this.emit('close'));
- }
- }
-}
-export class WriteStreamSync extends WriteStream {
- [_open]() {
- let fd;
- // only wrap in a try{} block if we know we'll retry, to avoid
- // the rethrow obscuring the error's source frame in most cases.
- if (this[_defaultFlag] && this[_flags] === 'r+') {
- try {
- fd = fs.openSync(this[_path], this[_flags], this[_mode]);
- }
- catch (er) {
- if (er?.code === 'ENOENT') {
- this[_flags] = 'w';
- return this[_open]();
- }
- else {
- throw er;
- }
- }
- }
- else {
- fd = fs.openSync(this[_path], this[_flags], this[_mode]);
- }
- this[_onopen](null, fd);
- }
- [_close]() {
- if (this[_autoClose] && typeof this[_fd] === 'number') {
- const fd = this[_fd];
- this[_fd] = undefined;
- fs.closeSync(fd);
- this.emit('close');
- }
- }
- [_write](buf) {
- // throw the original, but try to close if it fails
- let threw = true;
- try {
- this[_onwrite](null, fs.writeSync(this[_fd], buf, 0, buf.length, this[_pos]));
- threw = false;
- }
- finally {
- if (threw) {
- try {
- this[_close]();
- }
- catch {
- // ok error
- }
- }
- }
- }
-}
-//# sourceMappingURL=index.js.map \ No newline at end of file
diff --git a/node_modules/@isaacs/fs-minipass/dist/esm/package.json b/node_modules/@isaacs/fs-minipass/dist/esm/package.json
deleted file mode 100644
index 3dbc1ca..0000000
--- a/node_modules/@isaacs/fs-minipass/dist/esm/package.json
+++ /dev/null
@@ -1,3 +0,0 @@
-{
- "type": "module"
-}