MusareFork/backend/logic/actions/playlists.js

'use strict';

const db = require('../db');
const io = require('../io');
const cache = require('../cache');
const utils = require('../utils');
const hooks = require('./hooks');
const async = require('async');
const playlists = require('../playlists');
const songs = require('../songs');

let lib = {

	indexForUser: hooks.loginRequired((session, cb, userId) => {
		db.models.playlist.find({ createdBy: userId }, (err, playlists) => {
			if (err) return cb({ status: 'failure', message: 'Something went wrong when getting the playlists.'});;
			cb({
				status: 'success',
				data: playlists
			});
		});
	}),

	create: hooks.loginRequired((session, data, cb, userId) => {
		async.waterfall([

			(next) => {
				return (data) ? next() : cb({ 'status': 'failure', 'message': 'Invalid data' });
			},

			(next) => {
				const { name, displayName, songs } = data;
				db.models.playlist.create({
					displayName,
					songs,
					createdBy: userId,
					createdAt: Date.now()
				}, next);
			}

		], (err, playlist) => {
			if (err) return cb({ 'status': 'failure', 'message': 'Something went wrong'});
			cache.pub('playlist.create', data._id);
			return cb({ 'status': 'success', 'message': 'Successfully created playlist' });
		});
	}),

	getPlaylist: hooks.loginRequired((session, id, cb, userId) => {
		playlists.getPlaylist(id, (err, playlist) => {
			if (err || playlist.createdBy !== userId) return cb({status: 'success', message: 'Playlist not found.'});
			if (err == null) return cb({
				status: 'success',
				data: playlist
			});
		});
	}),

	//TODO Remove this
	update: hooks.loginRequired((session, _id, playlist, cb, userId) => {
		db.models.playlist.update({ _id, createdBy: userId }, playlist, (err, data) => {
			if (err) return cb({ status: 'failure', message: 'Something went wrong.' });
			playlists.updatePlaylist(_id, (err) => {
				if (err) return cb({ status: 'failure', message: 'Something went wrong.' });
				return cb({ status: 'success', message: 'Playlist has been successfully updated', data });
			});
		});
	}),

	addSongToPlaylist: hooks.loginRequired((session, songId, playlistId, cb, userId) => {
		async.waterfall([
			(next) => {
				songs.getSong(songId, (err, song) => {
					if (err) {
						utils.getSongFromYouTube(songId, (song) => {
							next(null, song);
						});
					} else {
						next(null, {
							_id: songId,
							title: song.title,
							duration: song.duration
						});
					}
				});
			},
			(newSong, next) => {
				playlists.getPlaylist(_id, (err, playlist) => {
					if (err || !playlist || playlist.createdBy !== userId) return next('Something went wrong when trying to get the playlist.');

					if (Array.isArray(playlist.songs)) {
						playlist.songs.push(newSong);
						playlist.save(err => {
							if (err) {
								console.error(err);
								return next('Failed to add song to playlist');
							}

							playlists.updatePlaylist(_id, () => {
								next(null, playlist);
							});
						});
					}
				});
			}
		],
		(err, playlist) => {
			if (err) return cb({ status: 'error', message: err });
			else if (playlist.songs) return cb({ status: 'success', message: 'Song has been successfully added to the playlist', data: playlist.songs });
		});
	}),
	
	addSetToPlaylist: hooks.loginRequired((session, url, playlistId, cb, userId) => {
		async.waterfall([
			(next) => {
				utils.getPlaylistFromYouTube(url, songs => {
					next(null, songs);
				});
			},
			(songs, next) => {
				for (let s = 0; s < songs.length; s++) {
					lib.addSongToPlaylist(session, songs[s].contentDetails.videoId, playlistId, (res) => {})();
				}
				next(null);
			},
			(next) => {
				playlists.getPlaylist(_id, (err, playlist) => {
					if (err || !playlist || playlist.createdBy !== userId) return next('Something went wrong while trying to get the playlist.');

					next(null, playlist);
				});
			}
		],
		(err, playlist) => {
			if (err) return cb({ status: 'failure', message: err });
			else if (playlist.songs) return cb({ status: 'success', message: 'Playlist has been successfully added', data: playlist.songs });
		});
	}),


	removeSongFromPlaylist: hooks.loginRequired((session, songId, playlistId, cb, userId) => {
		playlists.getPlaylist(playlistId, (err, playlist) => {
			if (err || !playlist || playlist.createdBy !== userId) return cb({ status: 'failure', message: 'Something went wrong when getting the playlist.'});

			for (let z = 0; z < playlist.songs.length; z++) {
				if (playlist.songs[z]._id == songId) playlist.songs.shift(playlist.songs[z]);
			}

			db.models.playlist.update({_id: playlistId}, {$pull: {_id: songId}}, (err) => {
				if (err) {
					console.error(err);
					return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
				}

				return cb({ status: 'success', message: 'Song has been successfully removed from playlist', data: playlist.songs });
			});
		});
	}),

	updateDisplayName: hooks.loginRequired((session, _id, displayName, cb, userId) => {
		db.models.playlist.update({ _id, createdBy: userId }, { displayName }, (err, res) => {
			if (err) return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
			playlists.updatePlaylist(_id, (err) => {
				if (err) return cb({ status: 'failure', message: err});
				return cb({ status: 'success', message: 'Playlist has been successfully updated' });
			})
		});
	}),

	promoteSong: hooks.loginRequired((session, playlistId, fromIndex, cb, userId) => {
		db.models.playlist.findOne({ _id: playlistId }, (err, playlist) => {
			if (err || !playlist || playlist.createdBy !== userId) return cb({ status: 'failure', message: 'Something went wrong when getting the playlist.'});

			let song = playlist.songs[fromIndex];
			playlist.songs.splice(fromIndex, 1);
			playlist.songs.splice((fromIndex + 1), 0, song);

			playlist.save(err => {
				if (err) {
					console.error(err);
					return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
				}

				playlists.updatePlaylist(playlistId, (err) => {
					if (err) return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
					return cb({ status: 'success', data: playlist.songs });
				});

			});
		});
	}),

	demoteSong: hooks.loginRequired((session, playlistId, fromIndex, cb, userId) => {
		db.models.playlist.findOne({ _id: playlistId }, (err, playlist) => {
			if (err || !playlist || playlist.createdBy !== userId) return cb({ status: 'failure', message: 'Something went wrong when getting the playlist.'});

			let song = playlist.songs[fromIndex];
			playlist.songs.splice(fromIndex, 1);
			playlist.songs.splice((fromIndex - 1), 0, song);

			playlist.save(err => {
				if (err) {
					console.error(err);
					return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
				}

				playlists.updatePlaylist(playlistId, (err) => {
					if (err) return cb({ status: 'failure', message: 'Something went wrong when saving the playlist.'});
					return cb({ status: 'success', data: playlist.songs });
				});

			});
		});
	}),

	remove: hooks.loginRequired((session, _id, cb, userId) => {
		db.models.playlist.remove({ _id, createdBy: userId }).exec(err => {
			if (err) return cb({ status: 'failure', message: 'Something went wrong when removing the playlist.'});
			cache.hdel('playlists', _id, () => {
				return cb({ status: 'success', message: 'Playlist successfully removed' });
			});
		});
	})

};

module.exports = lib;