MusareFork/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');
const hooks = require('./hooks');
const queueSongs = require('./queueSongs');

cache.sub('song.removed', songId => {
	utils.emitToRoom('admin.songs', 'event:admin.song.removed', songId);
});

cache.sub('song.added', songId => {
	db.models.song.findOne({_id: songId}, (err, song) => {
		utils.emitToRoom('admin.songs', 'event:admin.song.added', song);
	});
});

cache.sub('song.updated', songId => {
	db.models.song.findOne({_id: songId}, (err, song) => {
		utils.emitToRoom('admin.songs', 'event:admin.song.updated', song);
	});
});

cache.sub('song.like', (data) => {
	utils.emitToRoom(`song.${data.songId}`, 'event:song.like', {songId: data.songId, likes: data.likes, dislikes: data.dislikes});
	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) => {
	utils.emitToRoom(`song.${data.songId}`, 'event:song.dislike', {songId: data.songId, likes: data.likes, dislikes: data.dislikes});
	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) => {
	utils.emitToRoom(`song.${data.songId}`, 'event:song.unlike', {songId: data.songId, likes: data.likes, dislikes: data.dislikes});
	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) => {
	utils.emitToRoom(`song.${data.songId}`, 'event:song.undislike', {songId: data.songId, likes: data.likes, dislikes: data.dislikes});
	utils.socketsFromUser(data.userId, (sockets) => {
		sockets.forEach((socket) => {
			socket.emit('event:song.newRatings', {songId: data.songId, liked: false, disliked: false});
		});
	});
});

module.exports = {

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

	update: hooks.adminRequired((session, songId, song, cb) => {
		db.models.song.update({ _id: songId }, song, { upsert: true }, (err, updatedSong) => {
			if (err) console.error(err);
			songs.updateSong(songId, (err, song) => {
				if (err) console.error(err);
				cache.pub('song.updated', song._id);
				cb({ status: 'success', message: 'Song has been successfully updated', data: song });
			});
		});
	}),

	remove: hooks.adminRequired((session, songId, cb) => {
		db.models.song.remove({ _id: songId }, (err) => {
			if (err) return cb({status: 'failure', message: err.message});
			cache.hdel('songs', songId, (err) => {
				if (err) return cb({status: 'failure', message: err.message});
				cache.pub('song.removed', songId);
				cb({status: 'success', message: 'Successfully removed the song.'});
			});
		});
	}),

	add: hooks.adminRequired((session, song, cb, userId) => {
		queueSongs.remove(session, song._id, () => {
			const newSong = new db.models.song(song);
			db.models.song.findOne({ _id: song._id }, (err, existingSong) => {
				if (err) console.error(err);
				newSong.acceptedBy = userId;
				newSong.acceptedAt = Date.now();
				if (!existingSong) newSong.save(err => {
					if (err) {
						console.error(err);
						cb({ status: 'failure', message: 'Something went wrong while adding the song to the queue.' });
					} else {
						cache.pub('song.added', song._id);
						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: hooks.loginRequired((session, songId, cb, userId) => {
		db.models.user.findOne({ _id: userId }, (err, user) => {
			if (user.liked.indexOf(songId) !== -1) return cb({ status: 'failure', message: 'You have already liked this song.' });
			db.models.user.update({_id: userId}, {$push: {liked: songId}, $pull: {disliked: songId}}, err => {
				if (!err) {
					db.models.user.count({"liked": songId}, (err, likes) => {
						if (err) return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
						db.models.user.count({"disliked": songId}, (err, dislikes) => {
							if (err) return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
							db.models.song.update({_id: songId}, {$set: {likes: likes, dislikes: dislikes}}, (err) => {
								if (err) return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
								songs.updateSong(songId, (err, song) => {});
								cache.pub('song.like', JSON.stringify({ songId, userId: session.userId, likes: likes, dislikes: dislikes }));
								return cb({ status: 'success', message: 'You have successfully liked this song.' });
							});
						});
					});
				} else return cb({ status: 'failure', message: 'Something went wrong while liking this song.' });
			});
		});
	}),

	dislike: hooks.loginRequired((session, songId, cb, userId) => {
		db.models.user.findOne({ _id: userId }, (err, user) => {
			if (user.disliked.indexOf(songId) !== -1) return cb({ status: 'failure', message: 'You have already disliked this song.' });
			db.models.user.update({_id: userId}, {$push: {disliked: songId}, $pull: {liked: songId}}, err => {
				if (!err) {
					db.models.user.count({"liked": songId}, (err, likes) => {
						if (err) return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
						db.models.user.count({"disliked": songId}, (err, dislikes) => {
							if (err) return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
							db.models.song.update({_id: songId}, {$set: {likes: likes, dislikes: dislikes}}, (err) => {
								if (err) return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
								songs.updateSong(songId, (err, song) => {});
								cache.pub('song.dislike', JSON.stringify({ songId, userId: session.userId, likes: likes, dislikes: dislikes }));
								return cb({ status: 'success', message: 'You have successfully disliked this song.' });
							});
						});
					});
				} else return cb({ status: 'failure', message: 'Something went wrong while disliking this song.' });
			});
		});
	}),

	undislike: hooks.loginRequired((session, songId, cb, userId) => {
		db.models.user.findOne({ _id: userId }, (err, user) => {
			if (user.disliked.indexOf(songId) === -1) return cb({ status: 'failure', message: 'You have not disliked this song.' });
			db.models.user.update({_id: userId}, {$pull: {liked: songId, disliked: songId}}, err => {
				if (!err) {
					db.models.user.count({"liked": songId}, (err, likes) => {
						if (err) return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
						db.models.user.count({"disliked": songId}, (err, dislikes) => {
							if (err) return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
							db.models.song.update({_id: songId}, {$set: {likes: likes, dislikes: dislikes}}, (err) => {
								if (err) return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
								songs.updateSong(songId, (err, song) => {});
								cache.pub('song.undislike', JSON.stringify({ songId, userId: session.userId, likes: likes, dislikes: dislikes }));
								return cb({ status: 'success', message: 'You have successfully undisliked this song.' });
							});
						});
					});
				} else return cb({ status: 'failure', message: 'Something went wrong while undisliking this song.' });
			});
		});
	}),

	unlike: hooks.loginRequired((session, songId, cb, userId) => {
		db.models.user.findOne({ _id: userId }, (err, user) => {
			if (user.liked.indexOf(songId) === -1) return cb({ status: 'failure', message: 'You have not liked this song.' });
			db.models.user.update({_id: userId}, {$pull: {liked: songId, disliked: songId}}, err => {
				if (!err) {
					db.models.user.count({"liked": songId}, (err, likes) => {
						if (err) return cb({ status: 'failure', message: 'Something went wrong while unliking this song.' });
						db.models.user.count({"disliked": songId}, (err, dislikes) => {
							if (err) return cb({ status: 'failure', message: 'Something went wrong while undiking this song.' });
							db.models.song.update({_id: songId}, {$set: {likes: likes, dislikes: dislikes}}, (err) => {
								if (err) return cb({ status: 'failure', message: 'Something went wrong while unliking this song.' });
								songs.updateSong(songId, (err, song) => {});
								cache.pub('song.unlike', JSON.stringify({ songId, userId: session.userId, likes: likes, dislikes: dislikes }));
								return cb({ status: 'success', message: 'You have successfully unliked this song.' });
							});
						});
					});
				} else return cb({ status: 'failure', message: 'Something went wrong while unliking this song.' });
			});
		});
	}),

	getOwnSongRatings: hooks.loginRequired(function(session, songId, cb, userId) {
		db.models.user.findOne({_id: userId}, (err, user) => {
			if (!err && user) {
				return cb({
					status: 'success',
					songId: songId,
					liked: (user.liked.indexOf(songId) !== -1),
					disliked: (user.disliked.indexOf(songId) !== -1)
				});
			} else {
				return cb({
					status: 'failure',
					message: 'You are not logged in.'
				});
			}
		});
	})

};