/*jshint esversion: 6 */ var chokidar = require('chokidar'); var fs = require('../core/fs.js'); // TODO: this should be receiving the config object not re-reading the // embark.json file var Watch = function(options) { this.logger = options.logger; this.events = {}; }; Watch.prototype.start = function() { var self = this; // TODO: should come from the config object instead of reading the file // directly var embarkConfig = fs.readJSONSync("embark.json"); this.watchAssets(embarkConfig, function() { self.logger.trace('ready to watch asset changes'); }); this.watchContracts(embarkConfig, function() { self.logger.trace('ready to watch contract changes'); }); this.watchConfigs(function() { self.logger.trace('ready to watch config changes'); }); this.logger.info("ready to watch file changes"); }; Watch.prototype.watchAssets = function(embarkConfig, callback) { var self = this; var appConfig = embarkConfig.app; var filesToWatch = []; for(var targetFile in appConfig) { filesToWatch.push(appConfig[targetFile]); } this.watchFiles( filesToWatch, function(eventName, path) { self.logger.info(`${eventName}: ${path}`); self.trigger('rebuildAssets', path); }, function() { callback(); } ); }; Watch.prototype.watchContracts = function(embarkConfig, callback) { var self = this; this.watchFiles( [embarkConfig.contracts], function(eventName, path) { self.logger.info(`${eventName}: ${path}`); self.trigger('redeploy', path); }, function() { callback(); } ); }; Watch.prototype.watchConfigs = function(callback) { var self = this; this.watchFiles( "config/**/contracts.json", function(eventName, path) { self.logger.info(`${eventName}: ${path}`); self.trigger('redeploy', path); }, function() { callback(); } ); }; Watch.prototype.watchFiles = function(files, changeCallback, doneCallback) { this.logger.trace('watchFiles'); this.logger.trace(files); var configWatcher = chokidar.watch(files, { ignored: /[\/\\]\./, persistent: true, ignoreInitial: true, followSymlinks: true }); configWatcher .on('add', path => changeCallback('add', path)) .on('change', path => changeCallback('add', path)) .on('unlink', path => changeCallback('add', path)) .on('ready', doneCallback); }; Watch.prototype.on = function(eventName, callback) { this.events[eventName] = callback; }; Watch.prototype.trigger = function(eventName, values) { this.events[eventName](values); }; module.exports = Watch;