Musare/backend/logic/actions/songs.js

'use strict';

const db = require('../db');
const io = require('../io');
const cache = require('../cache');
const utils = require('../utils');

cache.sub('song.like', (data) => {
	io.io.to(`song.${data.songId}`).emit('event:song.like', {songId: data.songId, undisliked: data.undisliked});
	utils.socketsFromUser(data.userId, (sockets) => {
		sockets.forEach((socket) => {
			socket.emit('event:song.newRatings', {songId: data.songId, liked: true, disliked: false});
		});
	});
});

cache.sub('song.dislike', (data) => {
	io.io.to(`song.${data.songId}`).emit('event:song.dislike', {songId: data.songId, unliked: data.unliked});
	utils.socketsFromUser(data.userId, (sockets) => {
		sockets.forEach((socket) => {
			socket.emit('event:song.newRatings', {songId: data.songId, liked: false, disliked: true});
		});
	});
});

cache.sub('song.unlike', (data) => {
	io.io.to(`song.${data.songId}`).emit('event:song.unlike', {songId: data.songId});
	utils.socketsFromUser(data.userId, (sockets) => {
		sockets.forEach((socket) => {
			socket.emit('event:song.newRatings', {songId: data.songId, liked: false, disliked: false});
		});
	});
});

cache.sub('song.undislike', (data) => {
	io.io.to(`song.${data.songId}`).emit('event:song.undislike', {songId: data.songId});
	utils.socketsFromUser(data.userId, (sockets) => {
		sockets.forEach((socket) => {
			socket.emit('event:song.newRatings', {songId: data.songId, liked: false, disliked: false});
		});
	});
});

module.exports = {

	index: (session, cb) => {
		db.models.song.find({}, (err, songs) => {
			if (err) throw err;
			cb(songs);
		});
	},

	update: (session, id, song, cb) => {
		//TODO Require admin/login
		db.models.song.findOneAndUpdate({ id }, song, { upsert: true }, (err, updatedSong) => {
			if (err) throw err;
			cb(updatedSong);
		});
	},

	remove: (session, _id, cb) => {
		//TODO Require admin/login
		db.models.song.find({ _id }).remove().exec();
	},

	add: (session, song, cb) => {
		//TODO Require admin/login
		console.log(session.logged_in);
		// if (!session.logged_in) return cb({ status: 'failure', message: 'You must be logged in to add a song' });
		const newSong = new db.models.song(song);
		newSong.save(err => {
			if (err) throw err;
			else cb({ status: 'success', message: 'Song has been moved from Queue' })
		});
		//TODO Check if video already in songs list
		//TODO Check if video is in queue
		//TODO Add the song to the appropriate stations
	},

	like: (sessionId, songId, cb) => {
		cache.hget('sessions', sessionId, (err, session) => {
			cache.hget('userSessions', session.userSessionId, (err, userSession) => {
				db.models.user.findOne({_id: userSession.userId}, (err, user) => {
					if (user.liked.indexOf(songId) !== -1) return cb({ status: 'failure', message: 'You have already liked this song.' });
					let dislikes = 0;
					if (user.disliked.indexOf(songId) !== -1) dislikes = -1;
					db.models.song.update({_id: songId}, {$inc: {likes: 1, dislikes: dislikes}}, (err) => {
						if (!err) {
							db.models.user.update({_id: userSession.userId}, {$push: {liked: songId}, $pull: {disliked: songId}}, (err) => {
								if (!err) {
									console.log(JSON.stringify({songId, userId: userSession.userId}));
									cache.pub('song.like', JSON.stringify({songId, userId: userSession.userId, undisliked: (dislikes === -1)}));
									//TODO Update song object in Redis
								} else db.models.song.update({_id: songId}, {$inc: {likes: -1, dislikes: -dislikes}}, (err) => {
									return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
								});
							});
						} else {
							return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
						}
					});
				});
			});
		});
	},

	dislike: (sessionId, songId, cb) => {
		cache.hget('sessions', sessionId, (err, session) => {
			cache.hget('userSessions', session.userSessionId, (err, userSession) => {
				db.models.user.findOne({_id: userSession.userId}, (err, user) => {
					if (user.disliked.indexOf(songId) !== -1) return cb({ status: 'failure', message: 'You have already disliked this song.' });
					let likes = 0;
					if (user.liked.indexOf(songId) !== -1) likes = -1;
					db.models.song.update({_id: songId}, {$inc: {likes: likes, dislikes: 1}}, (err) => {
						if (!err) {
							db.models.user.update({_id: userSession.userId}, {$push: {disliked: songId}, $pull: {liked: songId}}, (err) => {
								if (!err) {
									cache.pub('song.dislike', JSON.stringify({songId, userId: userSession.userId, unliked: (likes === -1)}));
									//TODO Update song object in Redis
								} else db.models.song.update({_id: songId}, {$inc: {likes: -likes, dislikes: -1}}, (err) => {
									return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
								});
							});
						} else {
							return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
						}
					});
				});
			});
		});
	},

	undislike: (sessionId, songId, cb) => {
		cache.hget('sessions', sessionId, (err, session) => {
			cache.hget('userSessions', session.userSessionId, (err, userSession) => {
				db.models.user.findOne({_id: userSession.userId}, (err, user) => {
					if (user.disliked.indexOf(songId) === -1) return cb({ status: 'failure', message: 'You have not disliked this song.' });
					db.models.song.update({_id: songId}, {$inc: {dislikes: -1}}, (err) => {
						if (!err) {
							db.models.user.update({_id: userSession.userId}, {$pull: {disliked: songId}}, (err) => {
								if (!err) {
									cache.pub('song.undislike', JSON.stringify({songId, userId: userSession.userId}));
									//TODO Update song object in Redis
								} else db.models.song.update({_id: songId}, {$inc: {dislikes: 1}}, (err) => {
									return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
								});
							});
						} else {
							return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
						}
					});
				});
			});
		});
	},

	unlike: (sessionId, songId, cb) => {
		cache.hget('sessions', sessionId, (err, session) => {
			cache.hget('userSessions', session.userSessionId, (err, userSession) => {
				db.models.user.findOne({_id: userSession.userId}, (err, user) => {
					if (user.liked.indexOf(songId) === -1) return cb({ status: 'failure', message: 'You have not liked this song.' });
					db.models.song.update({_id: songId}, {$inc: {likes: -1}}, (err) => {
						if (!err) {
							db.models.user.update({_id: userSession.userId}, {$pull: {liked: songId}}, (err) => {
								if (!err) {
									cache.pub('song.unlike', JSON.stringify({songId, userId: userSession.userId}));
									//TODO Update song object in Redis
								} else db.models.song.update({_id: songId}, {$inc: {likes: 1}}, (err) => {
									return cb({ status: 'failure', message: 'Something went wrong while unliking this song.' });
								});
							});
						} else {
							return cb({ status: 'failure', message: 'Something went wrong while unliking this song.' });
						}
					});
				});
			});
		});
	},

	getOwnSongRatings: (sessionId, songId, cb) => {
		cache.hget('sessions', sessionId, (err, session) => {
			cache.hget('userSessions', session.userSessionId, (err, userSession) => {
				db.models.user.findOne({_id: userSession.userId}, (err, user) => {
					console.log({ status: 'success', songId: songId, liked: (user.liked.indexOf(songId) !== -1), disliked: (user.disliked.indexOf(songId) !== -1) })
					console.log(user.liked)
					console.log(user.disliked)
					return cb({ status: 'success', songId: songId, liked: (user.liked.indexOf(songId) !== -1), disliked: (user.disliked.indexOf(songId) !== -1) });
				});
			});
		});
	},

};