app.js

/*globals Homey, module, require, setInterval*/
"use strict";

const Homey = require('homey');
const DateTimeHelper = require('./lib/datetime.js');

var http = require('http');
var apiArray = require('./trashapis.js');
var supportedTypes = ["GFT","PLASTIC","PAPIER","PMD","REST","TEXTIEL"];

class TrashcanReminder extends Homey.App
{
	onInit()
	{
		this.manualInput = false;
		this.gdates = '';
		
		// Update manual input dates when settings change.
		Homey.on('settings.set', this.onSettingsChanged.bind(this));
		
		// Register flow card
		let daysToCollect = new Homey.FlowCardCondition('days_to_collect');
		daysToCollect
			.register()
			.registerRunListener(this.flowDaysToCollect.bind(this));
		
		// Register speech events
		Homey.ManagerSpeechInput.on('speechEval', this.speechEvalExecute.bind(this));
		Homey.ManagerSpeechInput.on('speechMatch', this.parseSpeechExecute.bind(this));
		
		// Check if we have to handle manual input, or automatically.
		if(Homey.ManagerSettings.get('manualInput'))
		{
			var manually = Homey.ManagerSettings.get('manualInput');
			this.manualInput = Boolean(manually);
		}
	
		// Manually kick off data retrieval
		this.onUpdateData();
		
		// Every 24 hours update API or manual dates
		setInterval(this.onUpdateData.bind(this), 86400000); // Every 24-hours
		
		this.log("App initialized");
	}
	
	/* ******************
		SPEECH FUNCTIONS
	********************/
	speechEvalExecute(speech, callback)
	{
		callback ( null, true)
		return;
		
		var result = this.parseSpeech(speech, this.gdates);
		if(result != null && result != "")
		{
			//speech.say( result );
			
			callback(null, true);
			return true;
		}

        // Only execute 1 trigger
		callback(null, false);
        return false;
	}
	
	parseSpeechExecute(speech, onSpeechEvalData)
	{
		console.log("parsing speech");
		
		var result = this.parseSpeech(speech, this.gdates);
		if(result != null && result != "")
		{
			speech.say( result );
			
			callback(null, true);
			return true;
		}

        // Only execute 1 trigger
		callback(null, false);
        return false;
	}
	
	parseSpeech(speech, gdates)
	{
		let trigger = speech.triggers[0];
		
	    switch (trigger.id)
	    {
	      case 'trash_collected' :
	        
			// TYPE OF QUESTIONS
			// WHAT type of trash is collected << TODAY | TOMORROW | DAY AFTER TOMORROW >>
			// WHEN is <<TYPE>> collected?
			// IS <<TYn38PE>> colllected << TODAY | TOMORROW | DAY AFTER TOMORROW >>
			// WHICH type will be collected << TODAY | TOMORROW | DAY AFTER TOMORROW >>
			
			var regexReplace = new RegExp("(" + Homey.__('speech.replacequestion') + ")", 'gi');
			var newTranscript = speech.transcript.replace(regexReplace, "");
			
			/* ******************
				FIND TRASH TYPE INDICATOR
			********************/
			var foundType = null;
			var differenceInDaysForType = null;
			for (var i = 0, len = supportedTypes.length; i < len; i++) {
				if (newTranscript.indexOf(Homey.__('speech.type.' + supportedTypes[i])) > -1)
				{
					foundType = supportedTypes[i];
					break; // stop loop after first match.
				}
				
				// Other words for types (search via regex)
				var regex = new RegExp("(" +Homey.__('speech.type_multipleother.' + supportedTypes[i])+ ")", 'gi');
				if (newTranscript.match(regex) !== null)
				{
					foundType = supportedTypes[i];
					break; // stop loop after first match.
				}
			}
				
			// Find first collection date for this type of trash
			if(foundType != null && typeof gdates[ foundType ] !== 'undefined')
			{
				var today = new Date();
				for (var i = 0, len = gdates[foundType].length; i < len; i++)
				{				
					var date = new Date(gdates[foundType][i].substring(6,10), (parseInt(gdates[foundType][i].substring(3,5))-1), gdates[foundType][i].substring(0,2));
									
					if(DateTimeHelper.daysBetween(today, date) >= 0)
					{
						differenceInDaysForType = DateTimeHelper.daysBetween(today, date);
						break;
					}				
				}
			}
			
			//console.log("type and difference in days");
			//console.log(foundType);
			//console.log(differenceInDaysForType);
			
			/* ******************
				FIND TIME INDICATOR
			********************/
			var checkDate = null;
			var typeCollectedOnThisDay = [];
			var matchesWithGivenType = false;
			// If bigger then one, someone probably asked something like 'is the container picked up tomorrow or the day after tomorrow'
			if(speech.time != null && speech.time !== false && speech.time.length == 1) 
			{
				var dateInput = null;
				try {
					dateInput = new Date(speech.time[0].time.year, speech.time[0].time.month, speech.time[0].time.day);
				} catch(e) { console.log(e); }
				
				//console.log("given date via speech");
				//console.log(dateInput);
				checkDate = dateInput;
			}
			
			if(checkDate != null)
			{
				// Go through types
				for (var i = 0, len = supportedTypes.length; i < len; i++) {
					if( typeof gdates[ supportedTypes[i] ] !== 'undefined' )
					{
						if(gdates[ supportedTypes[i] ].indexOf(this.dateToString(checkDate)) > -1 && typeCollectedOnThisDay.indexOf(Homey.__('speech.type.' + supportedTypes[i])) <= -1)
						{
							typeCollectedOnThisDay.push(Homey.__('speech.output.type.' + supportedTypes[i]));
							if(!matchesWithGivenType)
							{
								matchesWithGivenType = supportedTypes[i] == foundType;
							}
						}
					}
				}
				
				//console.log("types collected on this day");
				//console.log(typeCollectedOnThisDay);
			}
			
			/* ******************
				FIND TYPE OF QUESTION (sentence starting with WHAT, IS, WHEN)
			********************/
			var questionType = 0;
			if(newTranscript.toLowerCase().startsWith(Homey.__('speech.questiontype.what')) || 
				newTranscript.toLowerCase().startsWith(Homey.__('speech.questiontype.which')))
			{
				questionType = 1;
			}
			else if(newTranscript.toLowerCase().startsWith(Homey.__('speech.questiontype.when')))
			{
				questionType = 2;
			}
			else if(newTranscript.toLowerCase().startsWith(Homey.__('speech.questiontype.is')))
			{
				questionType = 3;
			}
			
			//console.log("defined question type");
			//console.log(questionType);
	
			var responseText = "";
			try {
				// which, what type of trash is collected <<time>>
				if(questionType == 1 && checkDate != null)
				{
					if(typeCollectedOnThisDay.length == 0)
					{
						responseText = Homey.__('speech.output.notrashcollectedonx', { time: speech.time[0].transcript });
					}
					else if(typeCollectedOnThisDay.length > 1)
					{
						var multiTypeString = "";				
						for (var i = 0, len = multiTypeString.length; i < len; i++) {
							multiTypeString += typeCollectedOnThisDay[i] + (i < (len-2) ? ", " : (i == (len-2) ? " " + Homey.__('speech.output.and') + " " : ""));
						}
						
						responseText = Homey.__('speech.output.trashtypesycollectedonx', { time: speech.time[0].transcript, types: multiTypeString.toLowerCase() });
					}
					else
					{
						responseText = Homey.__('speech.output.trashtypeycollectedonx', { time: speech.time[0].transcript, type: typeCollectedOnThisDay[0] });
					}
				}
				// when is <<type>> collected?
				else if(questionType == 2 && foundType != null)
				{
					if(differenceInDaysForType === null)
					{
						responseText = Homey.__('speech.output.notrashcollectionforx', { type: Homey.__('speech.output.type.' + foundType) });
					}
					else
					{
						responseText = Homey.__('speech.output.trashtypexcollectedony', { type: Homey.__('speech.output.type.' + foundType), time: TrashcanReminder.toDateOutputString(differenceInDaysForType).toLowerCase() });
					}
				}
				// is <<type>> collected on <<date>>
				else if(questionType == 3 && foundType != null && checkDate != null)
				{
					if(differenceInDaysForType === null)
					{
						responseText = Homey.__('speech.output.notrashcollectionforx', { type: Homey.__('speech.output.type.' + foundType) });
					}
					else if(matchesWithGivenType)
					{
						responseText = Homey.__('speech.output.yesyiscollectedonx', { time: speech.time[0].transcript.toLowerCase(), type: Homey.__('speech.output.type.' + foundType).toLowerCase() });
					}
					else 
					{
						responseText = Homey.__('speech.output.noyiscollectedonxbutonz', { time: speech.time[0].transcript.toLowerCase(), type: Homey.__('speech.output.type.' + foundType).toLowerCase(), time2: TrashcanReminder.toDateOutputString(differenceInDaysForType).toLowerCase() });
					}
				}
				else if(questionType == 1) // what|which type is collected next?
				{
					// Find the container that is picked up next
					var nextContainerNotBefore = new Date();
					var containerDateNext = new Date();
					containerDateNext.setDate(containerDateNext.getDate() + 366);
					var containerTypesNext = [];
					
					for (var i = 0, len = supportedTypes.length; i < len; i++) {
						if( typeof gdates[ supportedTypes[i] ] !== 'undefined' )
						{						
							for (var y = 0, len = gdates[supportedTypes[i]].length; y < len; y++)
							{				
								var date = new Date(gdates[supportedTypes[i]][y].substring(6,10), (parseInt(gdates[supportedTypes[i]][y].substring(3,5))-1), gdates[supportedTypes[i]][y].substring(0,2));
								
								if(DateTimeHelper.daysBetween(nextContainerNotBefore, date) >= 0 && DateTimeHelper.daysBetween(containerDateNext, date) <= 0)
								{
									var diff = DateTimeHelper.daysBetween(containerDateNext, date);
									if(diff === 0)
									{
										containerTypesNext.push(Homey.__('speech.output.type.' + supportedTypes[i]));
									}
									else
									{
										containerDateNext = date;
										containerTypesNext = [];
										containerTypesNext.push(Homey.__('speech.output.type.' + supportedTypes[i]));
									}
								}			
							}
						}
					}
					
					//console.log(containerTypesNext);
					var differenceInDaysForNextCollection = DateTimeHelper.daysBetween(nextContainerNotBefore, containerDateNext);
					
					if(containerTypesNext.length == 0)
					{
						responseText = Homey.__('speech.output.noknowntrashcollected');
					}
					else if(containerTypesNext.length > 1)
					{
						var multiTypeString = "";				
						for (var i = 0, len = multiTypeString.length; i < len; i++) {
							multiTypeString += containerTypesNext[i] + (i < (len-2) ? ", " : (i == (len-2) ? " " + Homey.__('speech.output.and') + " " : ""));
						}
						
						responseText = Homey.__('speech.output.trashtypesycollectedonx', { time: TrashcanReminder.toDateOutputString(differenceInDaysForNextCollection), types: multiTypeString.toLowerCase() });
					}
					else
					{
						responseText = Homey.__('speech.output.trashtypeycollectedonx', { time: TrashcanReminder.toDateOutputString(differenceInDaysForNextCollection), type: containerTypesNext[0].toLowerCase() });
					}				
				}
			}
			catch(e)
			{
				console.log(e);
			}
			
			console.log(responseText);
			return responseText;
	    }
	
	  return null;
	}
	
	/* ******************
		FLOW FUNCTIONS
	********************/
	flowDaysToCollect(args, state)
	{
		// For testing use these variables, will become pulled from settings
		//Homey.log(Object.keys(gdates));
		if( typeof this.gdates[ args.trash_type.toUpperCase() ] === 'undefined' && args.trash_type.toUpperCase() !== "ANY")
		{
			if(this.manualInput)
			{
				var message = Homey.__('error.typenotsupported.addviasettings');
				console.log(message);
				return Promise.resolve(new Error(message));
			}
			else
			{
				var message = Homey.__('error.typenotsupported.onyouraddress');
				console.log(message);
				return Promise.resolve(new Error(message));
			}
		}
	
		var now = new Date();
		//uncomment below to test on working date(or some other number)
		//now.setDate(now.getDate() -1);
		if(args.when == 'tomorrow') {
			now.setDate(now.getDate() + 1);
		} else if(args.when == 'datomorrow') {
			now.setDate(now.getDate() + 2);
		}
		
		var dateString = this.dateToString(now);
		if(args.trash_type.toUpperCase() == "ANY") {
			var result = false;
			
			for(var i=0; i<supportedTypes.length; i++)
			{				
				if(result === false && typeof(this.gdates[supportedTypes[i].toUpperCase()]) !== 'undefined') {
					result = this.gdates[ supportedTypes[i].toUpperCase() ].indexOf(dateString) > -1;
				}
			}		
			
			return Promise.resolve( result );
		}	
	
		var dateString = this.dateToString(now);
		//Homey.log(dateString);
		return Promise.resolve( this.gdates[ args.trash_type.toUpperCase() ].indexOf(dateString) > -1 );
	}
	
	/* ******************
		EVENT HANDLERS
	********************/
	onSettingsChanged(parameterName)
	{
		if(parameterName !== "manualEntryData")
		{
			return;
		}
		
		this.GenerateNewDaysBasedOnManualInput();
	}
	
	onUpdateData()
	{
		if (this.manualInput === false && 
			Homey.ManagerSettings.get('postcode') &&
			Homey.ManagerSettings.get('hnumber') &&
			Homey.ManagerSettings.get('country'))
		{
			updateAPI(
				Homey.ManagerSettings.get('postcode'),
				Homey.ManagerSettings.get('hnumber'),
				Homey.ManagerSettings.get('country'),
				function(success)
				{
					if(success)
					{
						Homey.log('retrieved house information');
					} 
					else 
					{
						Homey.log('house information has not been set');
					}
				}
			);
		}
		else if (this.manualInput === true)
		{
			// Generate new days based on manual input
			this.GenerateNewDaysBasedOnManualInput();
		}
	}
	
	/* ******************
		COMMON FUNCTIONS
	********************/
	pad(n, width, z)
	{
	  z = z || '0';
	  n = n + '';
	  return n.length >= width ? n : new Array(width - n.length + 1).join(z) + n;
	}
	
	updateAPI(postcode, homenumber, country, callback)
	{
		//postcode = '5301hBD';
		//homenumber = '13';
		//country = 'NL';
		function asyncLoop(iterations, func, callback) {
			var index = 0;
			var done = false;
			var loop = {
				next: function() {
					if (done) {
						return;
					}
	
					if (index < iterations) {
						index++;
						func(loop);
	
					} else {
						done = true;
						callback();
					}
				},
	
				iteration: function() {
					return index - 1;
				},
	
				break: function() {
					done = true;
					callback();
				}
			};
			loop.next();
			return loop;
		}
	
		asyncLoop(apiArray.length, function(loop) {
			apiArray[loop.iteration()](postcode,homenumber,country,(err,result)=> {
				if(err) {
					console.log('error while looping', err);
					loop.next();
				} else if(Object.keys(result).length > 0) {
					this.gdates = result;
					callback(true);
				} else if(Object.keys(result).length === 0) {
					loop.next();
				}
			});
		},()=> {
			console.log('Checked all APIs');
			return callback(false);
		});
	}
	
	dateToString(inputDate)
	{
		var dateString = this.pad( inputDate.getDate(), 2);
		dateString += '-';
		dateString += this.pad( inputDate.getMonth()+1, 2);
		dateString += '-';
		dateString += inputDate.getFullYear();
		return dateString;
	}
	
	GenerateNewDaysBasedOnManualInput()
	{
		// Retrieve settings
		var manualSettings = Homey.ManagerSettings.get('manualEntryData');
		var dates = {};
		
		// Parse dates per type
		if(manualSettings.gft)
		{
			dates.GFT = this.CalculatePickupDates(manualSettings.gft);
		}
		
		if(manualSettings.paper)
		{
			dates.PAPIER = this.CalculatePickupDates(manualSettings.paper);
		}
		
		if(manualSettings.rest)
		{
			dates.REST = this.CalculatePickupDates(manualSettings.rest);
		}
		
		if(manualSettings.pmd)
		{
			dates.PMD = this.CalculatePickupDates(manualSettings.pmd);
		}
		
		if(manualSettings.plastic)
		{
			dates.PLASTIC = this.CalculatePickupDates(manualSettings.plastic);
		}
		
		if(manualSettings.textile)
		{
			dates.TEXTIEL = this.CalculatePickupDates(manualSettings.textile);
		}
		
		// Push to gdates
		this.gdates = dates;
	}
	
	CalculatePickupDates(settings)
	{
		var result = [];
	
		var interval = -1;
		try { 
			interval = parseInt(settings.option);
		} catch(e) { console.log(e); }
		
		var intervalExtended = -1;
		try { 
			intervalExtended = parseInt(settings.option_extension);
		} catch(e) { console.log(e); }
		
		var startDate = new Date(Date.now());
		try { 
			startDate = settings.startdate;
		} catch(e) { console.log(e); }
		
		var dayOfWeek = null;
		try { 
			dayOfWeek = parseInt(settings.day);
		} catch(e) { console.log(e); }
		
		var currentDate = new Date(Date.now());
		var startDate = new Date(startDate);
		
		var firstDayInCurrentMonth = new Date(currentDate.getFullYear(), currentDate.getMonth(), 1);
		var previousMonth = new Date(new Date(firstDayInCurrentMonth).setMonth(firstDayInCurrentMonth.getMonth()-1));
		var nextMonth = new Date(new Date(firstDayInCurrentMonth).setMonth(firstDayInCurrentMonth.getMonth()+1));
		var afterNextMonth = new Date(new Date(firstDayInCurrentMonth).setMonth(firstDayInCurrentMonth.getMonth()+2));
		
		if(interval >= 5 && interval <= 7) // every x-th week of month/quarter/year
		{
			var nThWeek = interval-4;
			var date1 = new Date();
			var date2 = new Date();
			var date3 = new Date();
			
			if(intervalExtended == 12) // every x-th week of the year
			{
				date1 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, 0, currentDate.getFullYear()-1);
				date2 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, 0, currentDate.getFullYear());
				date3 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, 0, currentDate.getFullYear()+1);
			}
			else if(intervalExtended == 3) // every x-th week of the quarter
			{
				var currentQuarter = ((currentDate.getMonth()-((currentDate.getMonth()+3)%3))/3);
				var currentQuarterStart = new Date(currentDate.getFullYear(), currentQuarter*3, 1);
				var previousQuarterStart = new Date(new Date(currentQuarterStart).setMonth(currentQuarterStart.getMonth()-3));
				var nextQuarterStart = new Date(new Date(currentQuarterStart).setMonth(currentQuarterStart.getMonth()+3));
				
				date1 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, previousQuarterStart.getMonth(), previousQuarterStart.getFullYear());
				date2 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, currentQuarterStart.getMonth(), currentQuarterStart.getFullYear());
				date3 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, nextQuarterStart.getMonth(), nextQuarterStart.getFullYear());
			}
			else // every x-th week of the month
			{		
				date1 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, previousMonth.getMonth(), previousMonth.getFullYear());
				date2 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, firstDayInCurrentMonth.getMonth(), firstDayInCurrentMonth.getFullYear());
				date3 = DateTimeHelper.nthDayInMonth(nThWeek, dayOfWeek, nextMonth.getMonth(), nextMonth.getFullYear());
			}
			
			result.push(this.dateToString(date1));
			result.push(this.dateToString(date2));
			result.push(this.dateToString(date3));
		}
		else if(interval <= 4) // per week
		{
			var date0 = DateTimeHelper.everyNthWeek(interval, dayOfWeek, startDate, currentDate, -2);
			var date1 = DateTimeHelper.everyNthWeek(interval, dayOfWeek, startDate, currentDate, -1);
			var date2 = DateTimeHelper.everyNthWeek(interval, dayOfWeek, startDate, currentDate, 0);
			var date3 = DateTimeHelper.everyNthWeek(interval, dayOfWeek, startDate, currentDate, 1);
			var date4 = DateTimeHelper.everyNthWeek(interval, dayOfWeek, startDate, currentDate, 2);
			
			result.push(this.dateToString(date0));
			result.push(this.dateToString(date1));
			result.push(this.dateToString(date2));
			result.push(this.dateToString(date3));
			result.push(this.dateToString(date4));
		}
		else if(interval >= 8 && interval <= 9) // every last, every second last
		{
			var nthLastWeekOf = interval-7;
			
			var date1 = new Date();
			var date2 = new Date();
			var date3 = new Date();
			var date4 = new Date();
			
			if(intervalExtended == 12) // every x-th last week of the year
			{
				date1 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, 0, currentDate.getFullYear()-1);
				date2 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, 0, currentDate.getFullYear());
				date3 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, 0, currentDate.getFullYear()+1);
				date4 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, 0, currentDate.getFullYear()+2);
			}
			else if(intervalExtended == 3) // every x-th last week of the quarter
			{
				var currentQuarter = ((currentDate.getMonth()-((currentDate.getMonth()+3)%3))/3);
				var currentQuarterStart = new Date(currentDate.getFullYear(), currentQuarter*3, 1);
				var previousQuarterStart = new Date(new Date(currentQuarterStart).setMonth(currentQuarterStart.getMonth()-3));
				var nextQuarterStart = new Date(new Date(currentQuarterStart).setMonth(currentQuarterStart.getMonth()+3));
				var overNextQuarterStart = new Date(new Date(currentQuarterStart).setMonth(currentQuarterStart.getMonth()+6));
				
				date1 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, previousQuarterStart.getMonth(), previousQuarterStart.getFullYear());
				date2 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, currentQuarterStart.getMonth(), currentQuarterStart.getFullYear());
				date3 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, nextQuarterStart.getMonth(), nextQuarterStart.getFullYear());
				date4 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, overNextQuarterStart.getMonth(), overNextQuarterStart.getFullYear());
			}
			else // every x-th last week of the month
			{		
				date1 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, previousMonth.getMonth(), previousMonth.getFullYear());
				date2 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, firstDayInCurrentMonth.getMonth(), firstDayInCurrentMonth.getFullYear());
				date3 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, nextMonth.getMonth(), nextMonth.getFullYear());
				date4 = DateTimeHelper.nthLastDayInMonth(nthLastWeekOf, dayOfWeek, afterNextMonth.getMonth(), afterNextMonth.getFullYear());
			}
			
			result.push(this.dateToString(date1));
			result.push(this.dateToString(date2));
			result.push(this.dateToString(date3));
			result.push(this.dateToString(date4));
		}
		
		return result;
	}
	
	static toDateOutputString(differenceInDaysForType)
	{
		if(differenceInDaysForType >= 0 && differenceInDaysForType <= 2)
		{
			return Homey.__('speech.output.timeindicator.t'+differenceInDaysForType);
		}
		else if(differenceInDaysForType <= 7)
		{
			var today = new Date();
			var dayOfWeek = (today.getDay() + differenceInDaysForType) % 7;
			return Homey.__('speech.output.next') + " " +Homey.__('speech.output.weekdays.d'+dayOfWeek);
		}
		else
		{
			return Homey.__('speech.output.in') + " " + differenceInDaysForType + " " + Homey.__('speech.output.days');
		}
	}
}

module.exports = TrashcanReminder;
//module.exports.updateAPI = updateAPI;