MusareNode/backend/logic/actions/songs.js

'use strict';

const db = require('../db');
const io = require('../io');
const songs = require('../songs');
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
		const newSong = new db.models.song(song);
		db.models.song.findOne({ _id: song._id }, (err, existingSong) => {
			if (err) throw err;
			if (!existingSong) newSong.save(err => {
				if (err) throw err;
				else cb({ status: 'success', message: 'Song has been moved from Queue' })
			});
		});
		//TODO Check if video is in queue and 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 }));
									songs.updateSong(songId, (err, song) => {});
									cache.pub('song.like', JSON.stringify({ songId, userId: userSession.userId, undisliked: (dislikes === -1) }));
								} 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) {
									songs.updateSong(songId, (err, song) => {});
									cache.pub('song.dislike', JSON.stringify({songId, userId: userSession.userId, unliked: (likes === -1)}));
								} 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) {
									songs.updateSong(songId, (err, song) => {});
									cache.pub('song.undislike', JSON.stringify({songId, userId: userSession.userId}));
								} 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) {
									songs.updateSong(songId, (err, song) => {});
									cache.pub('song.unlike', JSON.stringify({songId, userId: userSession.userId}));
								} 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) });
				});
			});
		});
	},

};