broccoli/dist/watcher_adapter.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
const sane_1 = __importDefault(require("sane"));
const events_1 = require("events");
const source_node_1 = __importDefault(require("./wrappers/source-node"));
const bind_file_event_1 = __importDefault(require("./utils/bind-file-event"));
const logger = require('heimdalljs-logger')('broccoli:watcherAdapter');
function defaultFilterFunction(name) {
    return /^[^.]/.test(name);
}
class WatcherAdapter extends events_1.EventEmitter {
    constructor(watchedNodes, options = {}) {
        super();
        if (!Array.isArray(watchedNodes)) {
            throw new TypeError(`WatcherAdapter's first argument must be an array of SourceNodeWrapper nodes`);
        }
        for (const node of watchedNodes) {
            if (!(node instanceof source_node_1.default)) {
                throw new Error(`${node} is not a SourceNode`);
            }
            if (node.nodeInfo.watched !== true) {
                throw new Error(`'${node.nodeInfo.sourceDirectory}' is not watched`);
            }
        }
        this.watchedNodes = watchedNodes;
        this.options = options;
        this.options.filter = this.options.filter || defaultFilterFunction;
        this.watchers = [];
    }
    watch() {
        let watchers = this.watchedNodes.map((node) => {
            const watchedPath = node.nodeInfo.sourceDirectory;
            const watcher = sane_1.default(watchedPath, this.options);
            this.watchers.push(watcher);
            bind_file_event_1.default(this, watcher, node, 'change');
            bind_file_event_1.default(this, watcher, node, 'add');
            bind_file_event_1.default(this, watcher, node, 'delete');
            return new Promise((resolve, reject) => {
                watcher.on('ready', resolve);
                watcher.on('error', reject);
            }).then(() => {
                watcher.removeAllListeners('ready');
                watcher.removeAllListeners('error');
                watcher.on('error', (err) => {
                    logger.debug('error', err);
                    this.emit('error', err);
                });
                logger.debug('ready', watchedPath);
            });
        });
        return Promise.all(watchers).then(() => { });
    }
    quit() {
        let closing = this.watchers.map((watcher) => new Promise((resolve, reject) => 
        // @ts-ignore
        watcher.close((err) => {
            if (err)
                reject(err);
            else
                resolve();
        })));
        this.watchers.length = 0;
        return Promise.all(closing).then(() => { });
    }
}
;
module.exports = WatcherAdapter;
//# sourceMappingURL=watcher_adapter.js.map