1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204 |
- "use strict";
- const async = require("async");
- const hooks = require("./hooks");
- const moduleManager = require("../../index");
- const db = require("../db");
- const cache = require("../cache");
- const utils = require("../utils");
- const playlists = require("../playlists");
- const songs = require("../songs");
- const activities = require("../activities");
- cache.runJob("SUB", {
- channel: "playlist.create",
- cb: (playlistId) => {
- playlists.runJob("GET_PLAYLIST", { playlistId }).then((playlist) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: playlist.createdBy })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.create", playlist);
- });
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.delete",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.delete", res.playlistId);
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.moveSongToTop",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.moveSongToTop", {
- playlistId: res.playlistId,
- songId: res.songId,
- });
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.moveSongToBottom",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.moveSongToBottom", {
- playlistId: res.playlistId,
- songId: res.songId,
- });
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.addSong",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.addSong", {
- playlistId: res.playlistId,
- song: res.song,
- });
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.removeSong",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.removeSong", {
- playlistId: res.playlistId,
- songId: res.songId,
- });
- });
- });
- },
- });
- cache.runJob("SUB", {
- channel: "playlist.updateDisplayName",
- cb: (res) => {
- utils
- .runJob("SOCKETS_FROM_USER", { userId: res.userId })
- .then((response) => {
- response.sockets.forEach((socket) => {
- socket.emit("event:playlist.updateDisplayName", {
- playlistId: res.playlistId,
- displayName: res.displayName,
- });
- });
- });
- },
- });
- let lib = {
- /**
- * Gets the first song from a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are getting the first song from
- * @param {Function} cb - gets called with the result
- */
- getFirstSong: hooks.loginRequired((session, playlistId, cb) => {
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found.");
- next(null, playlist.songs[0]);
- },
- ],
- async (err, song) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_GET_FIRST_SONG",
- `Getting the first song of playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_GET_FIRST_SONG",
- `Successfully got the first song of playlist "${playlistId}" for user "${session.userId}".`
- );
- cb({
- status: "success",
- song: song,
- });
- }
- );
- }),
- /**
- * Gets all playlists for the user requesting it
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {Function} cb - gets called with the result
- */
- indexForUser: hooks.loginRequired(async (session, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlistModel.find({ createdBy: session.userId }, next);
- },
- ],
- async (err, playlists) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_INDEX_FOR_USER",
- `Indexing playlists for user "${session.userId}" failed. "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_INDEX_FOR_USER",
- `Successfully indexed playlists for user "${session.userId}".`
- );
- cb({
- status: "success",
- data: playlists,
- });
- }
- );
- }),
- /**
- * Creates a new private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {Object} data - the data for the new private playlist
- * @param {Function} cb - gets called with the result
- */
- create: hooks.loginRequired(async (session, data, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- return data
- ? next()
- : cb({ status: "failure", message: "Invalid data" });
- },
- (next) => {
- const { displayName, songs } = data;
- playlistModel.create(
- {
- displayName,
- songs,
- createdBy: session.userId,
- createdAt: Date.now(),
- },
- next
- );
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_CREATE",
- `Creating private playlist failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- cache.runJob("PUB", {
- channel: "playlist.create",
- value: playlist._id,
- });
- activities.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- activityType: "created_playlist",
- payload: [playlist._id],
- });
- console.log(
- "SUCCESS",
- "PLAYLIST_CREATE",
- `Successfully created private playlist for user "${session.userId}".`
- );
- cb({
- status: "success",
- message: "Successfully created playlist",
- data: {
- _id: playlist._id,
- },
- });
- }
- );
- }),
- /**
- * Gets a playlist from id
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are getting
- * @param {Function} cb - gets called with the result
- */
- getPlaylist: hooks.loginRequired((session, playlistId, cb) => {
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found");
- next(null, playlist);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_GET",
- `Getting private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_GET",
- `Successfully got private playlist "${playlistId}" for user "${session.userId}".`
- );
- cb({
- status: "success",
- data: playlist,
- });
- }
- );
- }),
- /**
- * Obtains basic metadata of a playlist in order to format an activity
- *
- * @param session
- * @param playlistId - the playlist id
- * @param cb
- */
- getPlaylistForActivity: (session, playlistId, cb) => {
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLISTS_GET_PLAYLIST_FOR_ACTIVITY",
- `Failed to obtain metadata of playlist ${playlistId} for activity formatting. "${err}"`
- );
- return cb({ status: "failure", message: err });
- } else {
- console.log(
- "SUCCESS",
- "PLAYLISTS_GET_PLAYLIST_FOR_ACTIVITY",
- `Obtained metadata of playlist ${playlistId} for activity formatting successfully.`
- );
- cb({
- status: "success",
- data: {
- title: playlist.displayName,
- },
- });
- }
- }
- );
- },
- //TODO Remove this
- /**
- * Updates a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are updating
- * @param {Object} playlist - the new private playlist object
- * @param {Function} cb - gets called with the result
- */
- update: hooks.loginRequired(async (session, playlistId, playlist, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlistModel.updateOne(
- { _id: playlistId, createdBy: session.userId },
- playlist,
- { runValidators: true },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_UPDATE",
- `Updating private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_UPDATE",
- `Successfully updated private playlist "${playlistId}" for user "${session.userId}".`
- );
- cb({
- status: "success",
- data: playlist,
- });
- }
- );
- }),
- /**
- * Updates a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are updating
- * @param {Function} cb - gets called with the result
- */
- shuffle: hooks.loginRequired(async (session, playlistId, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- if (!playlistId) return next("No playlist id.");
- playlistModel.findById(playlistId, next);
- },
- (playlist, next) => {
- utils
- .runJob("SHUFFLE", { array: playlist.songs })
- .then((result) => {
- next(null, result.array);
- })
- .catch(next);
- },
- (songs, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- { $set: { songs } },
- { runValidators: true },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_SHUFFLE",
- `Updating private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_SHUFFLE",
- `Successfully updated private playlist "${playlistId}" for user "${session.userId}".`
- );
- cb({
- status: "success",
- message: "Successfully shuffled playlist.",
- data: playlist,
- });
- }
- );
- }),
- /**
- * Adds a song to a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {Boolean} isSet - is the song part of a set of songs to be added
- * @param {String} songId - the id of the song we are trying to add
- * @param {String} playlistId - the id of the playlist we are adding the song to
- * @param {Function} cb - gets called with the result
- */
- addSongToPlaylist: hooks.loginRequired(
- async (session, isSet, songId, playlistId, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- if (
- !playlist ||
- playlist.createdBy !== session.userId
- )
- return next(
- "Something went wrong when trying to get the playlist"
- );
- async.each(
- playlist.songs,
- (song, next) => {
- if (song.songId === songId)
- return next(
- "That song is already in the playlist"
- );
- next();
- },
- next
- );
- })
- .catch(next);
- },
- (next) => {
- songs
- .runJob("GET_SONG", { id: songId })
- .then((response) => {
- const song = response.song;
- next(null, {
- _id: song._id,
- songId: songId,
- title: song.title,
- duration: song.duration,
- });
- })
- .catch(() => {
- utils
- .runJob("GET_SONG_FROM_YOUTUBE", { songId })
- .then((response) =>
- next(null, response.song)
- )
- .catch(next);
- });
- },
- (newSong, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- { $push: { songs: newSong } },
- { runValidators: true },
- (err) => {
- if (err) return next(err);
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) =>
- next(null, playlist, newSong)
- )
- .catch(next);
- }
- );
- },
- ],
- async (err, playlist, newSong) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_ADD_SONG",
- `Adding song "${songId}" to private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- } else {
- console.log(
- "SUCCESS",
- "PLAYLIST_ADD_SONG",
- `Successfully added song "${songId}" to private playlist "${playlistId}" for user "${session.userId}".`
- );
- if (!isSet)
- activities.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- activityType: "added_song_to_playlist",
- payload: [{ songId, playlistId }],
- });
- cache.runJob("PUB", {
- channel: "playlist.addSong",
- value: {
- playlistId: playlist._id,
- song: newSong,
- userId: session.userId,
- },
- });
- return cb({
- status: "success",
- message:
- "Song has been successfully added to the playlist",
- data: playlist.songs,
- });
- }
- }
- );
- }
- ),
- /**
- * Adds a set of songs to a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} url - the url of the the YouTube playlist
- * @param {String} playlistId - the id of the playlist we are adding the set of songs to
- * @param {Boolean} musicOnly - whether to only add music to the playlist
- * @param {Function} cb - gets called with the result
- */
- addSetToPlaylist: hooks.loginRequired(
- (session, url, playlistId, musicOnly, cb) => {
- let videosInPlaylistTotal = 0;
- let songsInPlaylistTotal = 0;
- let songsSuccess = 0;
- let songsFail = 0;
- let addedSongs = [];
- async.waterfall(
- [
- (next) => {
- utils
- .runJob("GET_PLAYLIST_FROM_YOUTUBE", {
- url,
- musicOnly,
- })
- .then((response) => {
- if (response.filteredSongs) {
- videosInPlaylistTotal =
- response.songs.length;
- songsInPlaylistTotal =
- response.filteredSongs.length;
- } else {
- songsInPlaylistTotal = videosInPlaylistTotal =
- response.songs.length;
- }
- next(null, response.songs);
- });
- },
- (songIds, next) => {
- let processed = 0;
- function checkDone() {
- if (processed === songIds.length) next();
- }
- for (let s = 0; s < songIds.length; s++) {
- lib.addSongToPlaylist(
- session,
- true,
- songIds[s],
- playlistId,
- (res) => {
- processed++;
- if (res.status === "success") {
- addedSongs.push(songIds[s]);
- songsSuccess++;
- } else songsFail++;
- checkDone();
- }
- );
- }
- },
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found.");
- next(null, playlist);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_IMPORT",
- `Importing a YouTube playlist to private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- } else {
- activities.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- activityType: "added_songs_to_playlist",
- payload: addedSongs,
- });
- console.log(
- "SUCCESS",
- "PLAYLIST_IMPORT",
- `Successfully imported a YouTube playlist to private playlist "${playlistId}" for user "${session.userId}". Videos in playlist: ${videosInPlaylistTotal}, songs in playlist: ${songsInPlaylistTotal}, songs successfully added: ${songsSuccess}, songs failed: ${songsFail}.`
- );
- cb({
- status: "success",
- message: "Playlist has been successfully imported.",
- data: playlist.songs,
- stats: {
- videosInPlaylistTotal,
- songsInPlaylistTotal,
- songsAddedSuccessfully: songsSuccess,
- songsFailedToAdd: songsFail,
- },
- });
- }
- }
- );
- }
- ),
- /**
- * Removes a song from a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} songId - the id of the song we are removing from the private playlist
- * @param {String} playlistId - the id of the playlist we are removing the song from
- * @param {Function} cb - gets called with the result
- */
- removeSongFromPlaylist: hooks.loginRequired(
- async (session, songId, playlistId, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- if (!songId || typeof songId !== "string")
- return next("Invalid song id.");
- if (!playlistId || typeof playlistId !== "string")
- return next("Invalid playlist id.");
- next();
- },
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found");
- playlistModel.updateOne(
- { _id: playlistId },
- { $pull: { songs: { songId: songId } } },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_REMOVE_SONG",
- `Removing song "${songId}" from private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- } else {
- console.log(
- "SUCCESS",
- "PLAYLIST_REMOVE_SONG",
- `Successfully removed song "${songId}" from private playlist "${playlistId}" for user "${session.userId}".`
- );
- cache.runJob("PUB", {
- channel: "playlist.removeSong",
- value: {
- playlistId: playlist._id,
- songId: songId,
- userId: session.userId,
- },
- });
- return cb({
- status: "success",
- message:
- "Song has been successfully removed from playlist",
- data: playlist.songs,
- });
- }
- }
- );
- }
- ),
- /**
- * Updates the displayName of a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are updating the displayName for
- * @param {Function} cb - gets called with the result
- */
- updateDisplayName: hooks.loginRequired(
- async (session, playlistId, displayName, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlistModel.updateOne(
- { _id: playlistId, createdBy: session.userId },
- { $set: { displayName } },
- { runValidators: true },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_UPDATE_DISPLAY_NAME",
- `Updating display name to "${displayName}" for private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_UPDATE_DISPLAY_NAME",
- `Successfully updated display name to "${displayName}" for private playlist "${playlistId}" for user "${session.userId}".`
- );
- cache.runJob("PUB", {
- channel: "playlist.updateDisplayName",
- value: {
- playlistId: playlistId,
- displayName: displayName,
- userId: session.userId,
- },
- });
- return cb({
- status: "success",
- message: "Playlist has been successfully updated",
- });
- }
- );
- }
- ),
- /**
- * Moves a song to the top of the list in a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are moving the song to the top from
- * @param {String} songId - the id of the song we are moving to the top of the list
- * @param {Function} cb - gets called with the result
- */
- moveSongToTop: hooks.loginRequired(
- async (session, playlistId, songId, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found");
- async.each(
- playlist.songs,
- (song, next) => {
- if (song.songId === songId) return next(song);
- next();
- },
- (err) => {
- if (err && err.songId) return next(null, err);
- next("Song not found");
- }
- );
- },
- (song, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- { $pull: { songs: { songId } } },
- (err) => {
- if (err) return next(err);
- return next(null, song);
- }
- );
- },
- (song, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- {
- $push: {
- songs: {
- $each: [song],
- $position: 0,
- },
- },
- },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_MOVE_SONG_TO_TOP",
- `Moving song "${songId}" to the top for private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_MOVE_SONG_TO_TOP",
- `Successfully moved song "${songId}" to the top for private playlist "${playlistId}" for user "${session.userId}".`
- );
- cache.runJob("PUB", {
- channel: "playlist.moveSongToTop",
- value: {
- playlistId,
- songId,
- userId: session.userId,
- },
- });
- return cb({
- status: "success",
- message: "Playlist has been successfully updated",
- });
- }
- );
- }
- ),
- /**
- * Moves a song to the bottom of the list in a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are moving the song to the bottom from
- * @param {String} songId - the id of the song we are moving to the bottom of the list
- * @param {Function} cb - gets called with the result
- */
- moveSongToBottom: hooks.loginRequired(
- async (session, playlistId, songId, cb) => {
- const playlistModel = await db.runJob("GET_MODEL", {
- modelName: "playlist",
- });
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("GET_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- (playlist, next) => {
- if (!playlist || playlist.createdBy !== session.userId)
- return next("Playlist not found");
- async.each(
- playlist.songs,
- (song, next) => {
- if (song.songId === songId) return next(song);
- next();
- },
- (err) => {
- if (err && err.songId) return next(null, err);
- next("Song not found");
- }
- );
- },
- (song, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- { $pull: { songs: { songId } } },
- (err) => {
- if (err) return next(err);
- return next(null, song);
- }
- );
- },
- (song, next) => {
- playlistModel.updateOne(
- { _id: playlistId },
- {
- $push: {
- songs: song,
- },
- },
- next
- );
- },
- (res, next) => {
- playlists
- .runJob("UPDATE_PLAYLIST", { playlistId })
- .then((playlist) => {
- next(null, playlist);
- })
- .catch(next);
- },
- ],
- async (err, playlist) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_MOVE_SONG_TO_BOTTOM",
- `Moving song "${songId}" to the bottom for private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_MOVE_SONG_TO_BOTTOM",
- `Successfully moved song "${songId}" to the bottom for private playlist "${playlistId}" for user "${session.userId}".`
- );
- cache.runJob("PUB", {
- channel: "playlist.moveSongToBottom",
- value: {
- playlistId,
- songId,
- userId: session.userId,
- },
- });
- return cb({
- status: "success",
- message: "Playlist has been successfully updated",
- });
- }
- );
- }
- ),
- /**
- * Removes a private playlist
- *
- * @param {Object} session - the session object automatically added by socket.io
- * @param {String} playlistId - the id of the playlist we are moving the song to the top from
- * @param {Function} cb - gets called with the result
- */
- remove: hooks.loginRequired(async (session, playlistId, cb) => {
- const stationModel = await db.runJob("GET_MODEL", {
- modelName: "station",
- });
- async.waterfall(
- [
- (next) => {
- playlists
- .runJob("DELETE_PLAYLIST", { playlistId })
- .then(next)
- .catch(next);
- },
- (next) => {
- stationModel.find({ privatePlaylist: playlistId }, (err, res) => {
- next(err, res);
- });
- },
- (stations, next) => {
- async.each(
- stations,
- (station, next) => {
- async.waterfall(
- [
- (next) => {
- stationModel.updateOne(
- { _id: station._id },
- { $set: { privatePlaylist: null } },
- { runValidators: true },
- next
- );
- },
- (res, next) => {
- if (!station.partyMode) {
- moduleManager.modules["stations"]
- .runJob("UPDATE_STATION", {
- stationId: station._id,
- })
- .then((station) =>
- next(null, station)
- )
- .catch(next);
- cache.runJob("PUB", {
- channel:
- "privatePlaylist.selected",
- value: {
- playlistId: null,
- stationId: station._id,
- },
- });
- } else next();
- },
- ],
- (err) => {
- next();
- }
- );
- },
- (err) => {
- next();
- }
- );
- },
- ],
- async (err) => {
- if (err) {
- err = await utils.runJob("GET_ERROR", { error: err });
- console.log(
- "ERROR",
- "PLAYLIST_REMOVE",
- `Removing private playlist "${playlistId}" failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "failure", message: err });
- }
- console.log(
- "SUCCESS",
- "PLAYLIST_REMOVE",
- `Successfully removed private playlist "${playlistId}" for user "${session.userId}".`
- );
- cache.runJob("PUB", {
- channel: "playlist.delete",
- value: {
- userId: session.userId,
- playlistId,
- },
- });
- activities.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- activityType: "deleted_playlist",
- payload: [playlistId],
- });
- return cb({
- status: "success",
- message: "Playlist successfully removed",
- });
- }
- );
- }),
- };
- module.exports = lib;
|