MusareReact/backend/logic/coreHandler.js

'use strict';

// nodejs modules
const path   = require('path'),
      fs     = require('fs'),
      os     = require('os'),
      events = require('events');

// npm modules
const config    = require('config'),
      request   = require('request'),
      waterfall = require('async/waterfall'),
      bcrypt = require('bcrypt'),
	  passport  = require('passport');

// custom modules
const global   = require('./global'),
	  stations = require('./stations');

var eventEmitter = new events.EventEmitter();

const edmStation = new stations.Station("edm", {
	"genres": ["edm"],
	playlist: [
		{
			id: "dQw4w9WgXcQ",
			title: "Never gonna give you up",
			artists: ["Rick Astley"],
			duration: 20,
			thumbnail: "https://yt3.ggpht.com/-CGlBu6kDEi8/AAAAAAAAAAI/AAAAAAAAAAA/Pi679mvyyyU/s88-c-k-no-mo-rj-c0xffffff/photo.jpg",
			likes: 0,
			dislikes: 1
		},
		{
			id: "GxBSyx85Kp8",
			title: "Yeah!",
			artists: ["Usher"],
			duration: 20,
			thumbnail: "https://yt3.ggpht.com/-CGlBu6kDEi8/AAAAAAAAAAI/AAAAAAAAAAA/Pi679mvyyyU/s88-c-k-no-mo-rj-c0xffffff/photo.jpg",
			likes: 0,
			dislikes: 1
		}
	],
	currentSongIndex: 0,
	paused: false,
	displayName: "EDM",
	description: "EDM Music"
});

const popStation = new stations.Station("pop", {
	"genres": ["pop"],
	playlist: [
		{
			id: "HXeYRs_zR6w",
			title: "Nobody But Me",
			artists: ["Michael Bublé"],
			duration: 12,
			thumbnail: "https://yt3.ggpht.com/-CGlBu6kDEi8/AAAAAAAAAAI/AAAAAAAAAAA/Pi679mvyyyU/s88-c-k-no-mo-rj-c0xffffff/photo.jpg",
			likes: 0,
			dislikes: 1
		},
		{
			id: "CR4YE7htLgI",
			title: "Someday ",
			artists: ["Michael Bublé", "Meghan Trainor"],
			duration: 30,
			thumbnail: "https://yt3.ggpht.com/-CGlBu6kDEi8/AAAAAAAAAAI/AAAAAAAAAAA/Pi679mvyyyU/s88-c-k-no-mo-rj-c0xffffff/photo.jpg",
			likes: 0,
			dislikes: 1
		}
	],
	currentSongIndex: 0,
	paused: false,
	displayName: "Pop",
	description: "Pop Music"
});

stations.addStation(edmStation);
stations.addStation(popStation);

module.exports = {

	// module functions

	on: (name, cb) => {
		eventEmitter.on(name, cb);
	},

	emit: (name, data) => {
		eventEmitter.emit(name, data);
	},

	// core route handlers

	'/users/register': (username, email, password, recaptcha, cb) => {
		console.log(username, password);
		request({
			url: 'https://www.google.com/recaptcha/api/siteverify',
			method: 'POST',
			form: {
				'secret': config.get("apis.recapthca.secret"),
				'response': recaptcha
			}
		}, function (error, response, body) {
			if (error === null && JSON.parse(body).success === true) {
				body = JSON.parse(body);
				global.db.user.findOne({'username': username}, function (err, user) {
					console.log(err, user);
					if (err) return cb(err);
					if (user) return cb("username");
					else {
						global.db.user.findOne({'email.address': email}, function (err, user) {
							console.log(err, user);
							if (err) return cb(err);
							if (user) return cb("email");
							else {
								// TODO: Email verification code, send email
								bcrypt.genSalt(10, function (err, salt) {
									if (err) {
										return cb(err);
									} else {
										bcrypt.hash(password, salt, function (err, hash) {
											if (err) {
												return cb(err);
											} else {
												let newUser = new global.db.user({
													username: username,
													email: {
														address: email,
														verificationToken: global.generateRandomString("64")
													},
													services: {
														password: {
															password: hash
														}
													}
												});
												newUser.save(function (err) {
													if (err) throw err;
													return cb(null, newUser);
												});
											}
										});
									}
								});
							}
						});
					}
				});
			} else {
				cb("Recaptcha failed");
			}
		});
	},

	'/stations': cb => {
		cb(stations.getStations().map(station => {
			return {
				id: station.id,
				playlist: station.playlist,
				displayName: station.displayName,
				description: station.description,
				currentSongIndex: station.currentSongIndex
			}
		}));
	},

	'/youtube/getVideo/:query': (query, cb) => {
		const params = [
			'part=snippet',
			`q=${encodeURIComponent(query)}`,
			`key=${config.get('apis.youtube.key')}`,
			'type=video',
			'maxResults=15'
		].join('&');
		// function params(type, id) {
		// 	if (type == "search") {
		// 		return [
		// 			'part=snippet',
		// 			`q=${encodeURIComponent(query)}`,
		// 			`key=${config.get('apis.youtube.key')}`,
		// 			'type=video',
		// 			'maxResults=15'
		// 		].join('&');
		// 	} else if (type == "video") {
		// 		return [
		// 			'part=snippet,contentDetails,statistics,status',
		// 			`id=${encodeURIComponent(id)}`,
		// 			`key=${config.get('apis.youtube.key')}`
		// 		].join('&');
		// 	}
		// }

		// let finalResults = [];

		request(`https://www.googleapis.com/youtube/v3/search?${params}`, (err, res, body) => {
			cb(body);
			// for (let i = 0; i < results.items.length; i++) {
			// 	request(`https://www.googleapis.com/youtube/v3/videos?${
			// 		params("video", results.items[i].id.videoId)
			// 	}`, (err, res, body) => {
			// 		finalResults.push(JSON.parse(body));
			// 	});
			// }
			// setTimeout(() => {
			// 	return cb(finalResults);
			// }, 500);
		});
	},

	'/songs/queue/add/:song': (song, user, cb) => {
		if (user.logged_in) {
				// if (songs.length > 0) {
				// 	let failed = 0;
				// 	let success = 0;
				// 	songs.forEach(function (song) {
				// 		if (typeof song === "object" && song !== null) {
				// 			let obj = {};
				// 			obj.title = song.title;
				// 			obj._id = song.id;
				// 			obj.artists = [];
				// 			obj.image = "test";
				// 			obj.duration = 0;
				// 			obj.genres = ["edm"];
				// 			//TODO Get data from Wikipedia and Spotify
				// 			obj.requestedBy = user._id;
				// 			console.log(user._id);
				// 			console.log(user);
				// 			obj.requestedAt = Date.now();
				// 			let queueSong = new global.db.queueSong(obj);
				// 			queueSong.save(function(err) {
				// 				console.log(err);
				// 				if (err) failed++;
				// 				else success++;
				// 			});
				// 		} else {
				// 			failed++;
				// 		}
				// 	});
				// 	cb({success, failed});
				// } else {
				// 	cb({err: "No songs supplied."});
				// }
				console.log(song);
			} else {
			cb({err: "Not logged in."});
		}
	},

	'/songs/queue/getSongs': (user, cb) => {
		if (user !== null && user !== undefined && user.logged_in) {
			global.db.queueSong.find({}, function(err, songs) {
				if (err) throw err;
				else cb({songs: songs});
			});
		} else {
			cb({err: "Not logged in."});
		}
	},

	'/songs/queue/updateSong/:id': (user, id, object, cb) => {
		if (user !== null && user !== undefined && user.logged_in) {
			global.db.queueSong.findOne({_id: id}, function(err, song) {
				if (err) throw err;
				else {
					if (song !== undefined && song !== null) {
						if (typeof object === "object" && object !== null) {
							delete object.requestedBy;
							delete object.requestedAt;
							global.db.queueSong.update({_id: id}, {$set: object}, function(err, song) {
								if (err) throw err;
								cb({success: true});
							});
						} else {
							cb({err: "Invalid data."});
						}
					} else {
						cb({err: "Song not found."});
					}
				}
			});
		} else {
			cb({err: "Not logged in."});
		}
	},

	'/stations/search/:query': (query, cb) => {

		const params = [
			'part=snippet',
			`q=${encodeURIComponent(query)}`,
			`key=${config.get('apis.youtube.key')}`,
			'type=video',
			'maxResults=25'
		].join('&');

		request(`https://www.googleapis.com/youtube/v3/search?${params}`, (err, res, body) => {
			if (err) {
				return cb({ status: 'error', message: 'Failed to make request' });
			} else {
				try {
					return cb({ status: 'success', body: JSON.parse(body) });
				}
				catch (e) {
					return cb({ status: 'error', message: 'Non JSON response' });
				}
			}
		});
	},

	'/song/:id/toggleLike': (songId, userId, cb) => {

		var user = global.db.user.findOne(userId);
		var song = global.db.song.findOne(songId);
		if (user !== undefined) {
			if (song !== undefined) {
				var liked = false;
				if (song.likes.indexOf(userId) === -1) {
					liked = true;
					// Add like
				} else {
					// Remove like
				}
				if (song.dislikes.indexOf(userId) !== -1) {
					// Remove dislike
				}
				// Emit to all sockets with this user that their likes/dislikes updated.
				// Emit to all sockets in the room that the likes/dislikes has updated
				cb({liked: liked, disliked: false});
			} else {
				cb({err: "Song not found."});
			}
		} else {
			cb({err: "User not found."});
		}

	},

	'/user/:id/ratings': (userId, cb) => {

		var user = global.db.user.findOne(userId);
		if (user !== undefined) {
			cb({likes: user.likes, dislikes: user.dislikes});
		} else {
			cb({err: "User not found."});
		}

	}
};