var walk = require('walk'); var fs = require('fs'); var path = require('path'); var ical = require('ical'); var forEachAsync = require('forEachAsync'); var walker; var watcher; var configuration; var files = []; exports.start = function(config) { configuration = config; watcher = require('watch-tree').watchTree(configuration.dir, {'sample-rate': 5}); watcher.on('fileDeleted', exports.rebuildFiles); watcher.on('fileCreated', exports.rebuildFiles); watcher.on('fileModified', exports.rebuildFiles); exports.rebuildFiles(); }; exports.rebuildFiles = function() { walker = walk.walk(configuration.dir, { followLinks: false }); var newSlides = {}; walker.on("directories", function (root, dirAr, next) { var lastDir = path.join(__dirname, root).split('/'); if((lastDir.length - __dirname.split('/').length) < 2) { dirAr.forEach(function(dir) { newSlides[dir.name] = { name: dir.name, template: path.join(configuration.defaultSlides, configuration.template) , slides: []}; }); } next(); }).on("file", function(root, fileStats, next) { if(fileStats.name == configuration.description || fileStats.name == configuration.events) { next(); } else if(fileStats.name == configuration.template) { var lastDir = root.split('/'); newSlides[lastDir[lastDir.length - 1]]['template'] = path.join(lastDir[lastDir.length - 1], fileStats.name); next(); } else { var lastDir = path.join(root).split('/'); if(newSlides.hasOwnProperty(lastDir[lastDir.length - 1])) { var ext = path.extname(fileStats); var type = 'image'; switch (ext) { case '.mp4': case '.avi': case '.ogv': case '.mkv': type = 'video'; break; } newSlides[lastDir[lastDir.length - 1]]['slides'].push({ type: type, file: path.join(lastDir[lastDir.length - 1], fileStats.name), head: '', text: ''}); } next(); } }).on("errors", function(root, nodeStatsArray, next) { next(); }).on("end", function() { for(var slideset in newSlides) { var collectDescs = function(slideset) { fs.readFile(path.join(__dirname, configuration.dir, slideset, configuration.description), function(err, data) { if(err) { throw err; } var descs = JSON.parse(data.toString()); for(var file in newSlides[slideset]['slides']) { if(!newSlides[slideset]['slides'].hasOwnProperty(file)) { continue; } if(!newSlides[slideset]['slides'][file].hasOwnProperty('file')) { continue; } for(var desc in descs) { if(!descs.hasOwnProperty(desc)) { continue; } var comp = newSlides[slideset]['slides'][file]['file'].split('/'); if(descs[desc]['file'] == comp[comp.length - 1]) { newSlides[slideset]['slides'][file]['head'] = descs[desc]['head']; newSlides[slideset]['slides'][file]['text'] = descs[desc]['text']; } } } exports.addSlides(slideset, newSlides[slideset], function(err) { if(err) { throw err; }}); fs.readFile(path.join(__dirname, configuration.dir, 'default', configuration.events), function(err, data) { var events = JSON.parse(data.toString()); if(events['type'] == 'text') { files[slideset]['events'] = events['events']; } else if(events['type'] == 'ical') { var compEv = []; ical.fromURL(events['url'], {}, function(err, data) { for (var k in data) { if (data.hasOwnProperty(k)) { var ev = data[k]; if(ev.start && ev.summary) { compEv.push({ date: ev.start, text: ev.summary }); } } } }); } }); }); } collectDescs(slideset); } }); }; exports.setEvents = function(slideset, events, cb) { var found = 0; for (var searchset in files) { if(!files.hasOwnProperty(searchset)) { continue; } if(files[searchset].name == slideset) { files[searchset]['events'] = events; found = 1; } } if(found) { cb('Couldn\'t find slideset'); } else { cb(null); } }; exports.addSlides = function(slideName, newSlides, cb) { files[slideName] = newSlides; cb(null); }; exports.getSlides = function(slideset, cb) { for (var searchset in files) { if(!files.hasOwnProperty(searchset)) { continue; } if(files[searchset].name == slideset) { cb(null, files[searchset]); } } }; exports.getAllSlides = function(cb) { var slidesets = []; for(var slideset in files) { if(!files.hasOwnProperty(slideset)) { continue; } slidesets.push(files[slideset].name); } cb(slidesets); };