kannon/classes/Watcher.js

const path = require('path');
const chokidar = require('chokidar');

const Environment = require('../models/Environment.js');

class Watcher {

    constructor() {
        this.#initialize();
    }

    async #initialize() {
        if (config?.library === undefined) {
            throw new Error('library not defined');
        }
        if (config?.library?.sources === undefined || config?.library?.sources.length === 0) {
            throw new Error('no library sources defined');
        }
        let initialScan = config?.library?.initialscan?.enabled;
        if (initialScan === undefined) {
            initialScan = true;
        }
        let polling = config?.library?.polling;
        if (polling === undefined) {
            polling = false;
        }
        for (let index = 0; index < config.library.sources.length; index++) {
            const directory = path.resolve(config.library.sources[index]);
            let ignoreInitial = !initialScan;
            if (ignoreInitial === false) {
                let env = new Environment(constants.ENVIRONMENT_LASTSCAN);
                await env.find('key');
                if (env === undefined) {
                    env = new Environment(constants.ENVIRONMENT_LASTSCAN, new Date().getTime().toString());
                    env.save();
                }
            }
            logger.debug('watching directory \'' + directory + '\'...');
            this.#handleEvents(chokidar.watch(directory, {
                ignoreInitial: ignoreInitial,
                usePolling: polling
            }));
        }
    }

    #handleEvents(watcher) {
        if (watcher === undefined) {
            return;
        }
        watcher.on(constants.FS_EVENT_ADD, (file, stats) => {
            queue.add(constants.FS_EVENT_ADD, file, stats);
        });
        watcher.on(constants.FS_EVENT_UNLINK, (file, stats) => {
            queue.add(constants.FS_EVENT_UNLINK, file, stats);
        });
        watcher.on(constants.FS_EVENT_CHANGE, (file, stats) => {
            queue.add(constants.FS_EVENT_CHANGE, file, stats);
        });
    }
}

module.exports = Watcher;