server.js

//required modules
var http = require('http');
var request = require('request');
var schedule = require('node-schedule');
var fs = require('fs');
var express = require('express');
var app = express();
var mongoose = require('mongoose');
var bodyParser = require('body-parser');
var Routine = require('./models/routine');


//bodyparser stuff
app.use(bodyParser.json()); 
app.use(bodyParser.json({ type: 'application/vnd.api+json' })); 
app.use(bodyParser.urlencoded({ extended: true })); 
app.use('/', express.static(__dirname + '/public'));
require('./routes')(app);
exports = app;

//constants
const PORT=8080;
const settings = 'settings.json'; 
const darkSkyBaseURL = 'https://api.darksky.net/forecast/';
const darkSkyQueryString = '?units=us&language=en&exclude=[minutely,alerts,flags,hourly]';
const dailyQuoteBaseURL = 'http://quotes.rest/qod.json?category=inspire';
const sayCommand = 'http://localhost:5005/master%20room/say/';

//read config. values from settings.json configuration file
var configuration = JSON.parse(
	fs.readFileSync(settings)
);

mongoose.Promise = global.Promise;
mongoose.connect(configuration.mongoUrl);

//misc variables
var weatherOutput;
var currentWeather;
var dailyForecast;
var morningPrompt;
var logging = true;
var quoteOutput;
var qotd;
var fullweatherSpeech;
var currentDate = new Date();
var year = currentDate.getFullYear();
var month = currentDate.getMonth();
var day = currentDate.getDate();

var hueBridgeIp;

getHueBridgeIp();
eveningRoutine();
morningRoutine();
frontPorchLightOnRoutine();
frontPorchLightOffRoutine();
addRoutinesFromDB();

app.post('/createRoutine', function (req, res) {
	newRoutine(req, res);
	res.sendStatus(200);
});

app.post('/deleteRoutine', function (req, res) {
	cancelRoutine(req.body.name);
	res.sendStatus(200);
});

function newRoutine(req) {
	console.log("adding routine to scheduler");
	var newRule = new schedule.RecurrenceRule();
	var newRuleName = req.body.name;

	newRule.dayOfWeek = req.body.dayOfWeek;
	newRule.minute = req.body.minute;
	newRule.hour = req.body.hour;
	
	schedule.scheduleJob(newRuleName, newRule, function() {
		console.log(newRuleName + ' routine just popped, boi!');
		if (req.body.message) {
			textToSpeech(req.body.message);
		}
		if (req.body.getWeather) {
			getWeather();
		}
		if (req.body.getQotd) {
			getQotd();
		}
	});
}


function eveningRoutine() {
	var eveningRule = new schedule.RecurrenceRule();
	eveningRule.dayOfWeek = new schedule.Range(0, 6, 1);
	eveningRule.minute = 30;
	eveningRule.hour = 8;
	var eveningRuleName = 'eveningRoutine';
	 
	// var eveningRoutine = schedule.scheduleJob(eveningRuleName, eveningRule, function() {
	// 	console.log("evening routine starting");
	// 	setLights({url: 'http://' + hueBridgeIp + '/api/JFrRiCjcmLRcI8v7RLq1QEpQXZp4UyjXtdjylYyC/lights/1/state/', method: 'PUT', json: {"on":true, "bri":100}});
	// 	playFavorite('sleep');
	// 	setShuffle('on');
	// 	setVolume(15);
	// })
}

function frontPorchLightOnRoutine() {
	var eveningRule = new schedule.RecurrenceRule();
	eveningRule.dayOfWeek = new schedule.Range(0, 6, 1);
	eveningRule.minute = 30;
	eveningRule.hour = 19;
	var eveningRuleName = 'frontPorchLightOnRoutine';
	// var eveningRoutine = schedule.scheduleJob(eveningRuleName, eveningRule, function() {
	// 	console.log("turning on front porch light");
	// 	setLights({url: 'http://' + hueBridgeIp + '/api/JFrRiCjcmLRcI8v7RLq1QEpQXZp4UyjXtdjylYyC/lights/2/state/', method: 'PUT', json: {"on":true, "bri":200}});
	// })
}

function frontPorchLightOffRoutine() {
	var eveningRule = new schedule.RecurrenceRule();
	eveningRule.dayOfWeek = new schedule.Range(0, 6, 1);
	eveningRule.minute = 30;
	eveningRule.hour = 5;
	var eveningRuleName = 'frontPorchLightOffRoutine';
	// var eveningRoutine = schedule.scheduleJob(eveningRuleName, eveningRule, function() {
	// 	console.log("turning off front porch light");
	// 	setLights({url: 'http://' + hueBridgeIp + '/api/JFrRiCjcmLRcI8v7RLq1QEpQXZp4UyjXtdjylYyC/lights/2/state/', method: 'PUT', json: {"on":false}});
	// })	
}

function morningRoutine() {
	var morningRule = new schedule.RecurrenceRule();
	morningRule.dayOfWeek = new schedule.Range(1, 5, 1);
	morningRule.minute = 30;
	morningRule.hour = 5;
	var morningRuleName = 'morningRoutine';
	// var morningRoutine = schedule.scheduleJob(morningRuleName, morningRule, function() {
	// 	console.log("morning routine starting");
	// 	setLights({url: 'http://' + hueBridgeIp + '/api/JFrRiCjcmLRcI8v7RLq1QEpQXZp4UyjXtdjylYyC/lights/1/state/', method: 'PUT', json: {"on":true, "bri":254}});
	// 	playFavorite('starred');
	// 	setShuffle('on');
	// 	setVolume(20);
	// })
}

function setShuffle(setting) {
	request('http://localhost:5005/master%20room/shuffle/' + setting, function (error, response, body) {
			if (handleResponse(error, response, body)) {
				console.log("successfully set shuffle");		
			}
		})
}
function setVolume(setting) {
	request('http://localhost:5005/master%20room/volume/' + setting, function (error, response, body) {
	  		if (handleResponse(error, response, body)) {
				console.log("successfully set volume to " + setting + ' on sonos');		
			}
		})
}
function playFavorite(playlist) {
	request('http://localhost:5005/master%20room/favorite/' + playlist, function (error, response, body) {
			if (handleResponse(error, response, body)) {
				console.log("successfully started " + playlist + " playlist.");
			}
		})
}
function textToSpeech(text) {
	request(sayCommand + encodeURIComponent(text), function (error, response, body) {
		if (handleResponse(error, response, body)) {
			console.log("successfully sent text to sonos");
		}
	})
}
function setLights(settings) {
	request(settings, function(error, response, body) {
		if (handleResponse(error, response, body)) {
			console.log('successfully set lights');
		}
	})
}	

function getWeather() {
	var requestURL = darkSkyBaseURL + configuration.darksky + '/' +  configuration.latitude + ',' + configuration.longitude + darkSkyQueryString;

	//sending request to darksky api to get weather information
	console.log("getting weather");
	console.log("Hitting API for weather: " + requestURL);
	
	request(requestURL, function (error, response, body) {
		if (handleResponse(error, response, body)) {
			var currentDateUNIX = new Date(year, month, day).getTime() / 1000;
			console.log("current UNIX time " + currentDateUNIX);
			weatherOutput = JSON.parse(body);
			var daily = weatherOutput.daily.data;
			
			for (var i = 0; i < daily.length; i++) {
				if (daily[i].time === currentDateUNIX) {
					console.log("found the proper daily routine");
					console.log(' daily weather ' + weatherOutput.daily);
		    		currentWeather = 'Current weather is ' + weatherOutput.currently.summary + '. Weekly weather is ' + weatherOutput.daily.summary + '. Temperature is ' + weatherOutput.currently.temperature + '. Precipitation chance is ' + weatherOutput.currently.precipProbability + '.';
					dailyForecast = "The daily Forecast is " + daily[i].summary;
					textToSpeech(currentWeather + ' ' + dailyForecast);
					break;
				}
			}

	  	}	
	})
}

function getQotd() {
	//sending request to get a daily quote
	console.log("getting qotd");
	console.log("Hitting PI for qotd: " + dailyQuoteBaseURL);
	request(dailyQuoteBaseURL, function (error, response, body) {

		if (handleResponse(error, response, body)) {
			quoteOutput = JSON.parse(body);

			//get first quote in array passed back
			qotd = 'quote of the day is by: ' + quoteOutput.contents.quotes[0].author + '. It is: ' + quoteOutput.contents.quotes[0].quote;
			textToSpeech(qotd);
		}
	})
}

function addRoutinesFromDB() {
	Routine.find(function(err, routines) {

        if (err) {
            res.send(err);
        } else {
    	    for (var i = 0; i < routines.length;i++) {
        		//todo convert this to a more generic method that can be used by newRoutine(req);
        		var newRule = new schedule.RecurrenceRule();
				newRule.dayOfWeek = routines[i].dayOfWeek;
				newRule.minute = routines[i].minute;
				newRule.hour = routines[i].hour;
				var message = routines[i].message;
				var weather = routines[i].getWeather;
				var qotd = routines[i].getQotd;
				var name = routines[i].name;

				schedule.scheduleJob(name, newRule, function(message, weather, qotd, name) {
					console.log(name + ' routine just popped, boi!');
					if (message) { 
						textToSpeech(message);
					}
					if (weather) {
						getWeather();
					}
					if (qotd) {
						getQotd();
					}
				}.bind(null, message, weather, qotd, name));
			}
        }
    })
}

function getHueBridgeIp() {
	request('https://www.meethue.com/api/nupnp', function (error, response, body) {
		console.log("looking for hueBridgeIp...");
		if (handleResponse(error, response, body)) {		
			var json = JSON.parse(body);
			hueBridgeIp = json[0].internalipaddress;
			console.log('hue ip is ' + hueBridgeIp);
		}
	})
}


function cancelRoutine(routineName) {
	var jobs = schedule.scheduledJobs;
	console.log("entering cancelling job ");

	for(var i in jobs)
	{
		console.log(jobs[i].name);
		if (jobs[i].name == routineName) {
			console.log("cancelling job " + jobs[i].name);
			jobs[i].cancel();
			break;
		}
	}
}

app.listen(PORT);

function handleResponse(error, response, body) {
  if (!error && response.statusCode == 200 && logging) {
    console.log(body);
    return true;
  }
}