Function init

core/cb.watch/init.js:10–125

(logger, events, rootPath)

function init(logger, events, rootPath) {
    var d = Q.defer();

    // Normalize paths
    function normalize(fullPath) {
        return path.normalize(
            '/' + path.relative(rootPath, fullPath)
        );
    }

    logger.log('Starting Watch');
    // Construct
    watchr.watch({
        paths: [rootPath],

        // Following links causes issues with broken symlinks
        // crashing the whole watchr instance and thus codebox
        // so disabling link following for now
        followLinks: false,

        listeners: {
            log: function(logLevel) {
                /*
                events.emit('watch.log', {
                    level: logLevel,
                    args: _.toArray(arguments)
                });
                */
            },
            error: function(err) {
                events.emit('watch.error', err);
            },
            watching: function(err, watcherInstance, isWatching) {
                var emitStr = 'watch.watching.' + (err ? 'error' : 'success');
                var info = {
                    watching: isWatching,
                    state: watcherInstance.state,
                    path: normalize(watcherInstance.path),
                    error: err || null
                };

                events.emit(emitStr, info);
            },
            change: batch(function(changeType, filePath, fileCurrentStat, filePreviousStat) {
                // Simply queue the data for our batch processor
                return {
                    change: changeType,
                    path: normalize(filePath),
                    stats: {
                        current: fileCurrentStat,
                        old: filePreviousStat
                    }
                };
            }, function process(eventList) {
                // Aggregate events by folder
                var folderEvents = _(eventList).reduce(function(context, e) {
                    // Aggregate by parent folder of changed path
                    var key = path.dirname(e.path);