Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
async.spec.ts	6.62 KB	-rw-r--r--
async.ts	3.13 KB	-rw-r--r--
common.spec.ts	3.3 KB	-rw-r--r--
common.ts	852 B	-rw-r--r--
reader.spec.ts	762 B	-rw-r--r--
reader.ts	287 B	-rw-r--r--
sync.spec.ts	3.97 KB	-rw-r--r--
sync.ts	1.74 KB	-rw-r--r--

Code Editor : sync.ts

import * as fsScandir from '@nodelib/fs.scandir';

import { Entry, Errno, QueueItem } from '../types';
import * as common from './common';
import Reader from './reader';

export default class SyncReader extends Reader {
	protected readonly _scandir: typeof fsScandir.scandirSync = fsScandir.scandirSync;

private readonly _storage: Set<Entry> = new Set();
	private readonly _queue: Set<QueueItem> = new Set();

public read(): Entry[] {
		this._pushToQueue(this._root, this._settings.basePath);
		this._handleQueue();

return [...this._storage];
	}

private _pushToQueue(directory: string, base?: string): void {
		this._queue.add({ directory, base });
	}

private _handleQueue(): void {
		for (const item of this._queue.values()) {
			this._handleDirectory(item.directory, item.base);
		}
	}

private _handleDirectory(directory: string, base?: string): void {
		try {
			const entries = this._scandir(directory, this._settings.fsScandirSettings);

for (const entry of entries) {
				this._handleEntry(entry, base);
			}
		} catch (error) {
			this._handleError(error as Errno);
		}
	}

private _handleError(error: Errno): void {
		if (!common.isFatalError(this._settings, error)) {
			return;
		}

throw error;
	}

private _handleEntry(entry: Entry, base?: string): void {
		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);
		}
	}

private _pushToStorage(entry: Entry): void {
		this._storage.add(entry);
	}
}

${this.title}

Code Editor : sync.ts