FM / readers

/var/www/cobraambalaj/node_modules/@nodelib/fs.walk/out/readers/

/var/www/cobraambalaj/node_modules/@nodelib/fs.walk/out/readers

Name	Size	Mode	Actions
async.d.ts	1146	0644	edit dl rm
async.d.ts.map	1097	0644	edit dl rm
async.js	3203	0644	edit dl rm
async.spec.d.ts	52	0644	edit dl rm
async.spec.d.ts.map	125	0644	edit dl rm
async.spec.js	8052	0644	edit dl rm
common.d.ts	499	0644	edit dl rm
common.d.ts.map	559	0644	edit dl rm
common.js	1083	0644	edit dl rm
common.spec.d.ts	53	0644	edit dl rm
common.spec.d.ts.map	127	0644	edit dl rm
common.spec.js	4165	0644	edit dl rm
reader.d.ts	245	0644	edit dl rm
reader.d.ts.map	306	0644	edit dl rm
reader.js	369	0644	edit dl rm
reader.spec.d.ts	53	0644	edit dl rm
reader.spec.d.ts.map	127	0644	edit dl rm
reader.spec.js	912	0644	edit dl rm
sync.d.ts	521	0644	edit dl rm
sync.d.ts.map	560	0644	edit dl rm
sync.js	1948	0644	edit dl rm
sync.spec.d.ts	51	0644	edit dl rm
sync.spec.d.ts.map	123	0644	edit dl rm
sync.spec.js	4801	0644	edit dl rm

Edit: /var/www/cobraambalaj/node_modules/@nodelib/fs.walk/out/readers/sync.js (1948B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const fsScandir = require("@nodelib/fs.scandir");
const common = require("./common");
const reader_1 = require("./reader");
class SyncReader extends reader_1.default {
    constructor() {
        super(...arguments);
        this._scandir = fsScandir.scandirSync;
        this._storage = new Set();
        this._queue = new Set();
    }
    read() {
        this._pushToQueue(this._root, this._settings.basePath);
        this._handleQueue();
        return [...this._storage];
    }
    _pushToQueue(directory, base) {
        this._queue.add({ directory, base });
    }
    _handleQueue() {
        for (const item of this._queue.values()) {
            this._handleDirectory(item.directory, item.base);
        }
    }
    _handleDirectory(directory, base) {
        try {
            const entries = this._scandir(directory, this._settings.fsScandirSettings);
            for (const entry of entries) {
                this._handleEntry(entry, base);
            }
        }
        catch (error) {
            this._handleError(error);
        }
    }
    _handleError(error) {
        if (!common.isFatalError(this._settings, error)) {
            return;
        }
        throw error;
    }
    _handleEntry(entry, base) {
        const fullpath = entry.path;
        if (base !== undefined) {
            entry.path = common.joinPathSegments(base, entry.name, this._settings.pathSegmentSeparator);
        }
        if (common.isAppliedFilter(this._settings.entryFilter, entry)) {
            this._pushToStorage(entry);
        }
        if (entry.dirent.isDirectory() && common.isAppliedFilter(this._settings.deepFilter, entry)) {
            this._pushToQueue(fullpath, entry.path);
        }
    }
    _pushToStorage(entry) {
        this._storage.add(entry);
    }
}
exports.default = SyncReader;

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); const fsScandir = require("@nodelib/fs.scandir"); const common = require("./common"); const reader_1 = require("./reader"); class SyncReader extends reader_1.default { constructor() { super(...arguments); this._scandir = fsScandir.scandirSync; this._storage = new Set(); this._queue = new Set(); } read() { this._pushToQueue(this._root, this._settings.basePath); this._handleQueue(); return [...this._storage]; } _pushToQueue(directory, base) { this._queue.add({ directory, base }); } _handleQueue() { for (const item of this._queue.values()) { this._handleDirectory(item.directory, item.base); } } _handleDirectory(directory, base) { try { const entries = this._scandir(directory, this._settings.fsScandirSettings); for (const entry of entries) { this._handleEntry(entry, base); } } catch (error) { this._handleError(error); } } _handleError(error) { if (!common.isFatalError(this._settings, error)) { return; } throw error; } _handleEntry(entry, base) { const fullpath = entry.path; if (base !== undefined) { entry.path = common.joinPathSegments(base, entry.name, this._settings.pathSegmentSeparator); } if (common.isAppliedFilter(this._settings.entryFilter, entry)) { this._pushToStorage(entry); } if (entry.dirent.isDirectory() && common.isAppliedFilter(this._settings.deepFilter, entry)) { this._pushToQueue(fullpath, entry.path); } } _pushToStorage(entry) { this._storage.add(entry); } } exports.default = SyncReader;