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) {
			/* collects descriptions and adds them to the slideset */
			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'];
							}
						}
					}
					setSlides(slideset, newSlides[slideset], function(err) { if(err) { throw err; }});
				});
			}
			/* collect events and adds them to the slideset */
			var collectEvents = function(slideset) {
				fs.readFile(path.join(__dirname, configuration.dir, slideset, configuration.events), function(err, data) {
					if(err) { throw err; }
					try {
						var events = JSON.parse(data.toString());
					} catch(e) {
						throw err;
					}
					if(events['type'] == 'text') {
						setEvents(slideset, events['events'], function(err) {
							if(err) { throw err; }
						});
					} else if(events['type'] == 'ical') {
						ical.fromURL(events['url'], {}, function(err, bloat) {
							if(err) { throw err; }
							var bDate = new Date();
							var fDate = new Date();
							bDate.setMinutes(bDate.getMinutes() - events['before']);
							fDate.setMinutes(bDate.getMinutes() + events['after']);
							var data = ical.events_between(bDate, fDate);
							var compEv = [];
							for (var k in data) {
								if (!data.hasOwnProperty(k)) { continue; }
								var ev = data[k];
								if(ev.start && ev.summary) {
									var dateStr = ev.start.toLocaleDateString();
									ev.start = ev.start.toLocaleTimeString();
									ev.end = ev.end.toLocaleTimeString();
									delete ev.rrule;
									delete ev.uid;
									delete ev.type;
									for(var i in ev) {
										if(!ev.hasOwnProperty(i)) { continue; }
										if(typeof ev[i] != 'string') { continue; }
										ev[i] = ev[i].replace(/\\,/g, ',');
										ev[i] = ev[i].replace(/\\n/g, '<br />');
									}
									if(typeof compEv[dateStr] == "undefined") {
										compEv[dateStr] = [];
									}
									compEv[dateStr].push(ev);
								}
							}
							setEvents(slideset, compEv, function(err) {
								if(err) { throw err; }
							});
						});
					}
				});
			}
			collectDescs(slideset);
			collectEvents(slideset);
		}
	});
};

var setEvents = function(slideset, events, cb) {

	for (var searchset in files) {
		if(!files.hasOwnProperty(searchset)) { continue; }
		if(files[searchset].name == slideset) {
			files[searchset]['events'] = events;
			cb(null);
			return;
		}
	}
	cb('Couldn\'t find slideset');
};

var setSlides = 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]);
			return;
		}
	}
	cb('Couldn\'t find slideset');
};

exports.getAllSlides = function(cb) {

	var slidesets = [];
	for(var slideset in files) {
		if(!files.hasOwnProperty(slideset)) { continue; }
		slidesets.push(files[slideset].name);
	}
	cb(slidesets);
};