martin/nci
1
0
Fork 0
mirror of https://gitlab.silvrtree.co.uk/martind2000/nci.git synced 2025-02-10 18:09:15 +00:00
Code Issues Projects Releases Wiki Activity

move projects watcher to separate module

Browse Source
This commit is contained in:
oleg 2015-07-12 10:54:03 +03:00
parent b41b76884b
commit 254239e182
2 changed files with 72 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
app.js
View File

@ -12,7 +12,7 @@ var db = require('./db'),
notifier = require('./lib/notifier'),
project = require('./lib/project'),
libLogger = require('./lib/logger'),
chokidar = require('chokidar');
EventEmitter = require('events').EventEmitter;
var logger = libLogger('app');
@ -34,10 +34,10 @@ var server = http.createServer(function(req, res, next) {
var socketio = require('socket.io')(server);
var dataio = require('./dataio')(socketio);
var app = {
server: server,
dataio: dataio
};
var app = new EventEmitter();
app.server = server;
app.dataio = dataio;
app.lib = {};
app.lib.reader = reader;
@ -100,6 +100,9 @@ Steppy(
function(err, projects) {
// note that `app.projects` is live variable
app.projects = projects;
_(app.projects).each(function(project) {
app.emit('projectLoaded', project);
});
logger.log('Loaded projects: ', _(app.projects).pluck('name'));
require('./distributor').init(app, this.slot());
@ -117,56 +120,7 @@ Steppy(
notifier.init(app.config.notify, this.slot());
// start file watcher for reloading projects on change
var syncProject = function(filename, fileInfo) {
var baseDir = app.config.paths.projects,
projectName = path.relative(
baseDir,
path.dirname(filename)
);
var projectIndex = _(app.projects).findIndex(function(project) {
return project.name === projectName;
});
if (projectIndex !== -1) {
logger.log('Unload project: "' + projectName + '"');
app.projects.splice(projectIndex, 1);
}
// on add or change (info is falsy on unlink)
if (fileInfo) {
logger.log('Load project "' + projectName + '" on change');
project.load(baseDir, projectName, function(err, project) {
if (err) {
return logger.error(
'Error during load project "' + projectName + '": ',
err.stack || err
);
}
app.projects.push(project);
logger.log(
'Project "' + projectName + '" loaded:',
JSON.stringify(project, null, 4)
);
});
}
};
// NOTE: currently after add remove and then add same file events will
// not be emitted
var watcher = chokidar.watch(
path.join(app.config.paths.projects, '*', 'config.*'),
{ignoreInitial: true}
);
watcher.on('add', syncProject);
watcher.on('change', syncProject);
watcher.on('unlink', syncProject);
watcher.on('error', function(err) {
logger.error('File watcher error occurred: ', err.stack || err);
});
require('./projectsWatcher').init(app, this.slot());
// init resources
require('./resources')(app);

63
projectsWatcher.js Normal file
View File

@ -0,0 +1,63 @@
'use strict';
var _ = require('underscore'),
path = require('path'),
chokidar = require('chokidar'),
project = require('./lib/project'),
logger = require('./lib/logger')('projects watcher');
exports.init = function(app, callback) {
// start file watcher for reloading projects on change
var syncProject = function(filename, fileInfo) {
var baseDir = app.config.paths.projects,
projectName = path.relative(
baseDir,
path.dirname(filename)
);
var projectIndex = _(app.projects).findIndex(function(project) {
return project.name === projectName;
});
if (projectIndex !== -1) {
logger.log('Unload project: "' + projectName + '"');
var unloadedProject = app.projects.splice(projectIndex, 1)[0];
app.emit('projectUnloaded', unloadedProject);
}
// on add or change (info is falsy on unlink)
if (fileInfo) {
logger.log('Load project "' + projectName + '" on change');
project.load(baseDir, projectName, function(err, project) {
if (err) {
return logger.error(
'Error during load project "' + projectName + '": ',
err.stack || err
);
}
app.projects.push(project);
logger.log(
'Project "' + projectName + '" loaded:',
JSON.stringify(project, null, 4)
);
app.emit('projectLoaded', project);
});
}
};
// NOTE: currently after add remove and then add same file events will
// not be emitted
var watcher = chokidar.watch(
path.join(app.config.paths.projects, '*', 'config.*'),
{ignoreInitial: true}
);
watcher.on('add', syncProject);
watcher.on('change', syncProject);
watcher.on('unlink', syncProject);
watcher.on('error', function(err) {
logger.error('File watcher error occurred: ', err.stack || err);
});
callback();
};