1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774 |
- import async from "async";
- import { isAdminRequired, isLoginRequired } from "./hooks";
- import moduleManager from "../../index";
- const DBModule = moduleManager.modules.db;
- const UtilsModule = moduleManager.modules.utils;
- const WSModule = moduleManager.modules.ws;
- const CacheModule = moduleManager.modules.cache;
- const SongsModule = moduleManager.modules.songs;
- const ActivitiesModule = moduleManager.modules.activities;
- const YouTubeModule = moduleManager.modules.youtube;
- const PlaylistsModule = moduleManager.modules.playlists;
- const StationsModule = moduleManager.modules.stations;
- CacheModule.runJob("SUB", {
- channel: "song.updated",
- cb: async data => {
- const songModel = await DBModule.runJob("GET_MODEL", {
- modelName: "song"
- });
- songModel.findOne({ _id: data.songId }, (err, song) => {
- WSModule.runJob("EMIT_TO_ROOMS", {
- rooms: ["import-album", "admin.songs", `edit-song.${data.songId}`],
- args: ["event:admin.song.updated", { data: { song, oldStatus: data.oldStatus } }]
- });
- });
- }
- });
- CacheModule.runJob("SUB", {
- channel: "song.removed",
- cb: async data => {
- WSModule.runJob("EMIT_TO_ROOMS", {
- rooms: ["import-album", "admin.songs", `edit-song.${data.songId}`],
- args: ["event:admin.song.removed", { data }]
- });
- }
- });
- CacheModule.runJob("SUB", {
- channel: "song.like",
- cb: data => {
- WSModule.runJob("EMIT_TO_ROOM", {
- room: `song.${data.youtubeId}`,
- args: [
- "event:song.liked",
- {
- data: { youtubeId: data.youtubeId, likes: data.likes, dislikes: data.dislikes }
- }
- ]
- });
- WSModule.runJob("SOCKETS_FROM_USER", { userId: data.userId }).then(sockets => {
- sockets.forEach(socket => {
- socket.dispatch("event:song.ratings.updated", {
- data: {
- youtubeId: data.youtubeId,
- liked: true,
- disliked: false
- }
- });
- });
- });
- }
- });
- CacheModule.runJob("SUB", {
- channel: "song.dislike",
- cb: data => {
- WSModule.runJob("EMIT_TO_ROOM", {
- room: `song.${data.youtubeId}`,
- args: [
- "event:song.disliked",
- {
- data: { youtubeId: data.youtubeId, likes: data.likes, dislikes: data.dislikes }
- }
- ]
- });
- WSModule.runJob("SOCKETS_FROM_USER", { userId: data.userId }).then(sockets => {
- sockets.forEach(socket => {
- socket.dispatch("event:song.ratings.updated", {
- data: {
- youtubeId: data.youtubeId,
- liked: false,
- disliked: true
- }
- });
- });
- });
- }
- });
- CacheModule.runJob("SUB", {
- channel: "song.unlike",
- cb: data => {
- WSModule.runJob("EMIT_TO_ROOM", {
- room: `song.${data.youtubeId}`,
- args: [
- "event:song.unliked",
- {
- data: { youtubeId: data.youtubeId, likes: data.likes, dislikes: data.dislikes }
- }
- ]
- });
- WSModule.runJob("SOCKETS_FROM_USER", { userId: data.userId }).then(sockets => {
- sockets.forEach(socket => {
- socket.dispatch("event:song.ratings.updated", {
- data: {
- youtubeId: data.youtubeId,
- liked: false,
- disliked: false
- }
- });
- });
- });
- }
- });
- CacheModule.runJob("SUB", {
- channel: "song.undislike",
- cb: data => {
- WSModule.runJob("EMIT_TO_ROOM", {
- room: `song.${data.youtubeId}`,
- args: [
- "event:song.undisliked",
- {
- data: { youtubeId: data.youtubeId, likes: data.likes, dislikes: data.dislikes }
- }
- ]
- });
- WSModule.runJob("SOCKETS_FROM_USER", { userId: data.userId }).then(sockets => {
- sockets.forEach(socket => {
- socket.dispatch("event:song.ratings.updated", {
- data: {
- youtubeId: data.youtubeId,
- liked: false,
- disliked: false
- }
- });
- });
- });
- }
- });
- export default {
- /**
- * Returns the length of the songs list
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param cb
- */
- length: isAdminRequired(async function length(session, cb) {
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- songModel.countDocuments({}, next);
- }
- ],
- async (err, count) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_LENGTH", `Failed to get length from songs. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_LENGTH", `Got length from songs successfully.`);
- return cb({ status: "success", message: "Successfully got length of songs.", data: { length: count } });
- }
- );
- }),
- /**
- * Gets songs, used in the admin songs page by the AdvancedTable component
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param page - the page
- * @param pageSize - the size per page
- * @param properties - the properties to return for each song
- * @param sort - the sort object
- * @param queries - the queries array
- * @param operator - the operator for queries
- * @param cb
- */
- getData: isAdminRequired(async function getSet(session, page, pageSize, properties, sort, queries, operator, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob(
- "GET_DATA",
- {
- page,
- pageSize,
- properties,
- sort,
- queries,
- operator
- },
- this
- )
- .then(response => {
- next(null, response);
- })
- .catch(err => {
- next(err);
- });
- }
- ],
- async (err, response) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_GET_DATA", `Failed to get data from songs. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_GET_DATA", `Got data from songs successfully.`);
- return cb({ status: "success", message: "Successfully got data from songs.", data: response });
- }
- );
- }),
- /**
- * Updates all songs
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param cb
- */
- updateAll: isAdminRequired(async function updateAll(session, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("UPDATE_ALL_SONGS", {}, this)
- .then(() => {
- next();
- })
- .catch(err => {
- next(err);
- });
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_UPDATE_ALL", `Failed to update all songs. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_UPDATE_ALL", `Updated all songs successfully.`);
- return cb({ status: "success", message: "Successfully updated all songs." });
- }
- );
- }),
- /**
- * Recalculates all song ratings
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param cb
- */
- recalculateAllRatings: isAdminRequired(async function recalculateAllRatings(session, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("RECALCULATE_ALL_SONG_RATINGS", {}, this)
- .then(() => {
- next();
- })
- .catch(err => {
- next(err);
- });
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_RECALCULATE_ALL_RATINGS",
- `Failed to recalculate all song ratings. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_RECALCULATE_ALL_RATINGS", `Recalculated all song ratings successfully.`);
- return cb({ status: "success", message: "Successfully recalculated all song ratings." });
- }
- );
- }),
- /**
- * Gets a song from the Musare song id
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} songId - the song id
- * @param {Function} cb
- */
- getSongFromSongId: isAdminRequired(function getSongFromSongId(session, songId, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("GET_SONG", { songId }, this)
- .then(response => next(null, response.song))
- .catch(err => next(err));
- }
- ],
- async (err, song) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_GET_SONG_FROM_MUSARE_ID", `Failed to get song ${songId}. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_GET_SONG_FROM_MUSARE_ID", `Got song ${songId} successfully.`);
- return cb({ status: "success", data: { song } });
- }
- );
- }),
- /**
- * Updates a song
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} songId - the song id
- * @param {object} song - the updated song object
- * @param {Function} cb
- */
- update: isAdminRequired(async function update(session, songId, song, cb) {
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- let existingSong = null;
- async.waterfall(
- [
- next => {
- songModel.findOne({ _id: songId }, next);
- },
- (_existingSong, next) => {
- existingSong = _existingSong;
- songModel.updateOne({ _id: songId }, song, { runValidators: true }, next);
- },
- (res, next) => {
- SongsModule.runJob("UPDATE_SONG", { songId }, this)
- .then(song => {
- existingSong.genres
- .concat(song.genres)
- .filter((value, index, self) => self.indexOf(value) === index)
- .forEach(genre => {
- PlaylistsModule.runJob("AUTOFILL_GENRE_PLAYLIST", { genre })
- .then(() => {})
- .catch(() => {});
- });
- next(null, song);
- })
- .catch(next);
- }
- ],
- async (err, song) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_UPDATE", `Failed to update song "${songId}". "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_UPDATE", `Successfully updated song "${songId}".`);
- return cb({
- status: "success",
- message: "Song has been successfully updated",
- data: { song }
- });
- }
- );
- }),
- /**
- * Removes a song
- *
- * @param session
- * @param songId - the song id
- * @param cb
- */
- remove: isAdminRequired(async function remove(session, songId, cb) {
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- const stationModel = await DBModule.runJob("GET_MODEL", { modelName: "station" }, this);
- async.waterfall(
- [
- next => {
- songModel.findOne({ _id: songId }, next);
- },
- (song, next) => {
- PlaylistsModule.runJob("GET_PLAYLISTS_WITH_SONG", { songId }, this)
- .then(res => {
- async.eachLimit(
- res.playlists,
- 1,
- (playlist, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [song.youtubeId, playlist._id]
- },
- this
- )
- .then(res => {
- if (res.status === "error") next(res.message);
- else next();
- })
- .catch(err => {
- next(err);
- });
- },
- err => {
- if (err) next(err);
- else next(null, song);
- }
- );
- })
- .catch(err => next(err));
- },
- (song, next) => {
- stationModel.find({ "queue._id": songId }, (err, stations) => {
- if (err) next(err);
- else {
- async.eachLimit(
- stations,
- 1,
- (station, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "stations",
- action: "removeFromQueue",
- args: [station._id, song.youtubeId]
- },
- this
- )
- .then(res => {
- if (
- res.status === "error" &&
- res.message !== "Station not found" &&
- res.message !== "Song is not currently in the queue."
- )
- next(res.message);
- else next();
- })
- .catch(err => {
- next(err);
- });
- },
- err => {
- if (err) next(err);
- else next();
- }
- );
- }
- });
- },
- next => {
- stationModel.find({ "currentSong._id": songId }, (err, stations) => {
- if (err) next(err);
- else {
- async.eachLimit(
- stations,
- 1,
- (station, next) => {
- StationsModule.runJob(
- "SKIP_STATION",
- { stationId: station._id, natural: false },
- this
- )
- .then(() => {
- next();
- })
- .catch(err => {
- if (err.message === "Station not found.") next();
- else next(err);
- });
- },
- err => {
- if (err) next(err);
- else next();
- }
- );
- }
- });
- },
- next => {
- songModel.deleteOne({ _id: songId }, err => {
- if (err) next(err);
- else next();
- });
- },
- next => {
- CacheModule.runJob("HDEL", { table: "songs", key: songId }, this)
- .then(() => {
- next();
- })
- .catch(next);
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_REMOVE", `Failed to remove song "${songId}". "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_REMOVE", `Successfully removed song "${songId}".`);
- CacheModule.runJob("PUB", {
- channel: "song.removed",
- value: { songId }
- });
- return cb({
- status: "success",
- message: "Song has been successfully removed"
- });
- }
- );
- }),
- /**
- * Removes many songs
- *
- * @param session
- * @param songIds - array of song ids
- * @param cb
- */
- removeMany: isAdminRequired(async function remove(session, songIds, cb) {
- const successful = [];
- const failed = [];
- async.waterfall(
- [
- next => {
- async.eachLimit(
- songIds,
- 1,
- (songId, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "songs",
- action: "remove",
- args: [songId]
- },
- this
- )
- .then(res => {
- if (res.status === "error") failed.push(songId);
- else successful.push(songId);
- next();
- })
- .catch(err => {
- next(err);
- });
- },
- err => {
- if (err) next(err);
- else next();
- }
- );
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_REMOVE_MANY", `Failed to remove songs "${failed.join(", ")}". "${err}"`);
- return cb({ status: "error", message: err });
- }
- let message = "";
- if (successful.length === 1) message += `1 song has been successfully removed`;
- else message += `${successful.length} songs have been successfully removed`;
- if (failed.length > 0) {
- this.log("ERROR", "SONGS_REMOVE_MANY", `Failed to remove songs "${failed.join(", ")}". "${err}"`);
- if (failed.length === 1) message += `, failed to remove 1 song`;
- else message += `, failed to remove ${failed.length} songs`;
- }
- this.log("SUCCESS", "SONGS_REMOVE_MANY", `${message} "${successful.join(", ")}"`);
- return cb({
- status: "success",
- message
- });
- }
- );
- }),
- /**
- * Searches through official songs
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} query - the query
- * @param {string} page - the page
- * @param {Function} cb - gets called with the result
- */
- searchOfficial: isLoginRequired(async function searchOfficial(session, query, page, cb) {
- async.waterfall(
- [
- next => {
- if ((!query && query !== "") || typeof query !== "string") next("Invalid query.");
- else next();
- },
- next => {
- SongsModule.runJob("SEARCH", {
- query,
- includeVerified: true,
- trimmed: true,
- page
- })
- .then(response => {
- next(null, response);
- })
- .catch(err => {
- next(err);
- });
- }
- ],
- async (err, data) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_SEARCH_OFFICIAL", `Searching songs failed. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_SEARCH_OFFICIAL", "Searching songs successful.");
- return cb({ status: "success", data });
- }
- );
- }),
- /**
- * Requests a song
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} youtubeId - the youtube id of the song that gets requested
- * @param {string} returnSong - returns the simple song
- * @param {Function} cb - gets called with the result
- */
- request: isLoginRequired(async function add(session, youtubeId, returnSong, cb) {
- SongsModule.runJob("REQUEST_SONG", { youtubeId, userId: session.userId }, this)
- .then(response => {
- this.log(
- "SUCCESS",
- "SONGS_REQUEST",
- `User "${session.userId}" successfully requested song "${youtubeId}".`
- );
- return cb({
- status: "success",
- message: "Successfully requested that song",
- song: returnSong ? response.song : null
- });
- })
- .catch(async _err => {
- const err = await UtilsModule.runJob("GET_ERROR", { error: _err }, this);
- this.log(
- "ERROR",
- "SONGS_REQUEST",
- `Requesting song "${youtubeId}" failed for user ${session.userId}. "${err}"`
- );
- return cb({ status: "error", message: err, song: returnSong && _err.data ? _err.data.song : null });
- });
- }),
- /**
- * Hides a song
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} songId - the song id of the song that gets hidden
- * @param {Function} cb - gets called with the result
- */
- hide: isLoginRequired(async function add(session, songId, cb) {
- SongsModule.runJob("HIDE_SONG", { songId }, this)
- .then(() => {
- this.log("SUCCESS", "SONGS_HIDE", `User "${session.userId}" successfully hid song "${songId}".`);
- return cb({
- status: "success",
- message: "Successfully hid that song"
- });
- })
- .catch(async err => {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_HIDE", `Hiding song "${songId}" failed for user ${session.userId}. "${err}"`);
- return cb({ status: "error", message: err });
- });
- }),
- /**
- * Unhides a song
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} songId - the song id of the song that gets hidden
- * @param {Function} cb - gets called with the result
- */
- unhide: isLoginRequired(async function add(session, songId, cb) {
- SongsModule.runJob("UNHIDE_SONG", { songId }, this)
- .then(() => {
- this.log("SUCCESS", "SONGS_UNHIDE", `User "${session.userId}" successfully unhid song "${songId}".`);
- return cb({
- status: "success",
- message: "Successfully unhid that song"
- });
- })
- .catch(async err => {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_UNHIDE",
- `Unhiding song "${songId}" failed for user ${session.userId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- });
- }),
- /**
- * Verifies a song
- *
- * @param session
- * @param songId - the song id
- * @param cb
- */
- verify: isAdminRequired(async function add(session, songId, cb) {
- const SongModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- SongModel.findOne({ _id: songId }, next);
- },
- (song, next) => {
- if (!song) return next("This song is not in the database.");
- return next(null, song);
- },
- (song, next) => {
- const oldStatus = song.status;
- song.verifiedBy = session.userId;
- song.verifiedAt = Date.now();
- song.status = "verified";
- song.save(err => next(err, song, oldStatus));
- },
- (song, oldStatus, next) => {
- song.genres.forEach(genre => {
- PlaylistsModule.runJob("AUTOFILL_GENRE_PLAYLIST", { genre })
- .then(() => {})
- .catch(() => {});
- });
- SongsModule.runJob("UPDATE_SONG", { songId: song._id, oldStatus });
- next(null, song, oldStatus);
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_VERIFY", `User "${session.userId}" failed to verify song. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log("SUCCESS", "SONGS_VERIFY", `User "${session.userId}" successfully verified song "${songId}".`);
- return cb({
- status: "success",
- message: "Song has been verified successfully."
- });
- }
- );
- // TODO Check if video is in queue and Add the song to the appropriate stations
- }),
- /**
- * Verify many songs
- *
- * @param session
- * @param songIds - array of song ids
- * @param cb
- */
- verifyMany: isAdminRequired(async function verifyMany(session, songIds, cb) {
- const successful = [];
- const failed = [];
- async.waterfall(
- [
- next => {
- async.eachLimit(
- songIds,
- 1,
- (songId, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "songs",
- action: "verify",
- args: [songId]
- },
- this
- )
- .then(res => {
- if (res.status === "error") failed.push(songId);
- else successful.push(songId);
- next();
- })
- .catch(err => {
- next(err);
- });
- },
- err => {
- if (err) next(err);
- else next();
- }
- );
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_VERIFY_MANY", `Failed to verify songs "${failed.join(", ")}". "${err}"`);
- return cb({ status: "error", message: err });
- }
- let message = "";
- if (successful.length === 1) message += `1 song has been successfully verified`;
- else message += `${successful.length} songs have been successfully verified`;
- if (failed.length > 0) {
- this.log("ERROR", "SONGS_VERIFY_MANY", `Failed to verify songs "${failed.join(", ")}". "${err}"`);
- if (failed.length === 1) message += `, failed to verify 1 song`;
- else message += `, failed to verify ${failed.length} songs`;
- }
- this.log("SUCCESS", "SONGS_VERIFY_MANY", `${message} "${successful.join(", ")}"`);
- return cb({
- status: "success",
- message
- });
- }
- );
- }),
- /**
- * Un-verifies a song
- *
- * @param session
- * @param songId - the song id
- * @param cb
- */
- unverify: isAdminRequired(async function add(session, songId, cb) {
- const SongModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- SongModel.findOne({ _id: songId }, next);
- },
- (song, next) => {
- if (!song) return next("This song is not in the database.");
- return next(null, song);
- },
- (song, next) => {
- song.status = "unverified";
- song.save(err => {
- next(err, song);
- });
- },
- (song, next) => {
- song.genres.forEach(genre => {
- PlaylistsModule.runJob("AUTOFILL_GENRE_PLAYLIST", { genre })
- .then(() => {})
- .catch(() => {});
- });
- SongsModule.runJob("UPDATE_SONG", { songId, oldStatus: "verified" });
- next(null);
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "SONGS_UNVERIFY", `User "${session.userId}" failed to verify song. "${err}"`);
- return cb({ status: "error", message: err });
- }
- this.log(
- "SUCCESS",
- "SONGS_UNVERIFY",
- `User "${session.userId}" successfully unverified song "${songId}".`
- );
- return cb({
- status: "success",
- message: "Song has been unverified successfully."
- });
- }
- );
- // TODO Check if video is in queue and Add the song to the appropriate stations
- }),
- /**
- * Unverify many songs
- *
- * @param session
- * @param songIds - array of song ids
- * @param cb
- */
- unverifyMany: isAdminRequired(async function unverifyMany(session, songIds, cb) {
- const successful = [];
- const failed = [];
- async.waterfall(
- [
- next => {
- async.eachLimit(
- songIds,
- 1,
- (songId, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "songs",
- action: "unverify",
- args: [songId]
- },
- this
- )
- .then(res => {
- if (res.status === "error") failed.push(songId);
- else successful.push(songId);
- next();
- })
- .catch(err => {
- next(err);
- });
- },
- err => {
- if (err) next(err);
- else next();
- }
- );
- }
- ],
- async err => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_UNVERIFY_MANY",
- `Failed to unverify songs "${failed.join(", ")}". "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- let message = "";
- if (successful.length === 1) message += `1 song has been successfully unverified`;
- else message += `${successful.length} songs have been successfully unverified`;
- if (failed.length > 0) {
- this.log(
- "ERROR",
- "SONGS_UNVERIFY_MANY",
- `Failed to unverify songs "${failed.join(", ")}". "${err}"`
- );
- if (failed.length === 1) message += `, failed to unverify 1 song`;
- else message += `, failed to unverify ${failed.length} songs`;
- }
- this.log("SUCCESS", "SONGS_UNVERIFY_MANY", `${message} "${successful.join(", ")}"`);
- return cb({
- status: "success",
- message
- });
- }
- );
- }),
- /**
- * Requests a set of songs
- *
- * @param {object} session - the session object automatically added by the websocket
- * @param {string} url - the url of the the YouTube playlist
- * @param {boolean} musicOnly - whether to only get music from the playlist
- * @param {Function} cb - gets called with the result
- */
- requestSet: isLoginRequired(function requestSet(session, url, musicOnly, returnSongs, cb) {
- async.waterfall(
- [
- next => {
- YouTubeModule.runJob(
- "GET_PLAYLIST",
- {
- url,
- musicOnly
- },
- this
- )
- .then(res => {
- next(null, res.songs);
- })
- .catch(next);
- },
- (youtubeIds, next) => {
- let successful = 0;
- let songs = {};
- let failed = 0;
- let alreadyInDatabase = 0;
- if (youtubeIds.length === 0) next();
- async.eachOfLimit(
- youtubeIds,
- 1,
- (youtubeId, index, next) => {
- WSModule.runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "songs",
- action: "request",
- args: [youtubeId, returnSongs]
- },
- this
- )
- .then(res => {
- if (res.status === "success") successful += 1;
- else failed += 1;
- if (res.message === "This song is already in the database.") alreadyInDatabase += 1;
- if (res.song) songs[index] = res.song;
- else songs[index] = null;
- })
- .catch(() => {
- failed += 1;
- })
- .finally(() => {
- next();
- });
- },
- () => {
- if (returnSongs)
- songs = Object.keys(songs)
- .sort()
- .map(key => songs[key]);
- next(null, { successful, failed, alreadyInDatabase, songs });
- }
- );
- }
- ],
- async (err, response) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "REQUEST_SET",
- `Importing a YouTube playlist to be requested failed for user "${session.userId}". "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- this.log(
- "SUCCESS",
- "REQUEST_SET",
- `Successfully imported a YouTube playlist to be requested for user "${session.userId}".`
- );
- return cb({
- status: "success",
- message: `Playlist is done importing. ${response.successful} were added succesfully, ${response.failed} failed (${response.alreadyInDatabase} were already in database)`,
- songs: returnSongs ? response.songs : null
- });
- }
- );
- }),
- /**
- * Likes a song
- *
- * @param session
- * @param youtubeId - the youtube id
- * @param cb
- */
- like: isLoginRequired(async function like(session, youtubeId, cb) {
- const userModel = await DBModule.runJob("GET_MODEL", { modelName: "user" }, this);
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => songModel.findOne({ youtubeId }, next),
- (song, next) => {
- if (!song) return next("No song found with that id.");
- return next(null, song);
- },
- (song, next) => userModel.findOne({ _id: session.userId }, (err, user) => next(err, song, user)),
- (song, user, next) => {
- if (!user) return next("User does not exist.");
- return this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, user.dislikedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Disliked Songs' playlist.");
- return next(null, song, user.likedSongsPlaylist);
- })
- .catch(err => next(err));
- },
- (song, likedSongsPlaylist, next) =>
- this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "addSongToPlaylist",
- args: [false, youtubeId, likedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error") {
- if (res.message === "That song is already in the playlist")
- return next("You have already liked this song.");
- return next("Unable to add song to the 'Liked Songs' playlist.");
- }
- return next(null, song);
- })
- .catch(err => next(err)),
- (song, next) => {
- SongsModule.runJob("RECALCULATE_SONG_RATINGS", { songId: song._id, youtubeId })
- .then(ratings => next(null, song, ratings))
- .catch(err => next(err));
- }
- ],
- async (err, song, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_LIKE",
- `User "${session.userId}" failed to like song ${youtubeId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { likes, dislikes } = ratings;
- SongsModule.runJob("UPDATE_SONG", { songId: song._id });
- CacheModule.runJob("PUB", {
- channel: "song.like",
- value: JSON.stringify({
- youtubeId,
- userId: session.userId,
- likes,
- dislikes
- })
- });
- ActivitiesModule.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- type: "song__like",
- payload: {
- message: `Liked song <youtubeId>${song.title} by ${song.artists.join(", ")}</youtubeId>`,
- youtubeId,
- thumbnail: song.thumbnail
- }
- });
- return cb({
- status: "success",
- message: "You have successfully liked this song."
- });
- }
- );
- }),
- /**
- * Dislikes a song
- *
- * @param session
- * @param youtubeId - the youtube id
- * @param cb
- */
- dislike: isLoginRequired(async function dislike(session, youtubeId, cb) {
- const userModel = await DBModule.runJob("GET_MODEL", { modelName: "user" }, this);
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- songModel.findOne({ youtubeId }, next);
- },
- (song, next) => {
- if (!song) return next("No song found with that id.");
- return next(null, song);
- },
- (song, next) => userModel.findOne({ _id: session.userId }, (err, user) => next(err, song, user)),
- (song, user, next) => {
- if (!user) return next("User does not exist.");
- return this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, user.likedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Liked Songs' playlist.");
- return next(null, song, user.dislikedSongsPlaylist);
- })
- .catch(err => next(err));
- },
- (song, dislikedSongsPlaylist, next) =>
- this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "addSongToPlaylist",
- args: [false, youtubeId, dislikedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error") {
- if (res.message === "That song is already in the playlist")
- return next("You have already disliked this song.");
- return next("Unable to add song to the 'Disliked Songs' playlist.");
- }
- return next(null, song);
- })
- .catch(err => next(err)),
- (song, next) => {
- SongsModule.runJob("RECALCULATE_SONG_RATINGS", { songId: song._id, youtubeId })
- .then(ratings => next(null, song, ratings))
- .catch(err => next(err));
- }
- ],
- async (err, song, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_DISLIKE",
- `User "${session.userId}" failed to dislike song ${youtubeId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { likes, dislikes } = ratings;
- SongsModule.runJob("UPDATE_SONG", { songId: song._id });
- CacheModule.runJob("PUB", {
- channel: "song.dislike",
- value: JSON.stringify({
- youtubeId,
- userId: session.userId,
- likes,
- dislikes
- })
- });
- ActivitiesModule.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- type: "song__dislike",
- payload: {
- message: `Disliked song <youtubeId>${song.title} by ${song.artists.join(", ")}</youtubeId>`,
- youtubeId,
- thumbnail: song.thumbnail
- }
- });
- return cb({
- status: "success",
- message: "You have successfully disliked this song."
- });
- }
- );
- }),
- /**
- * Undislikes a song
- *
- * @param session
- * @param youtubeId - the youtube id
- * @param cb
- */
- undislike: isLoginRequired(async function undislike(session, youtubeId, cb) {
- const userModel = await DBModule.runJob("GET_MODEL", { modelName: "user" }, this);
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- songModel.findOne({ youtubeId }, next);
- },
- (song, next) => {
- if (!song) return next("No song found with that id.");
- return next(null, song);
- },
- (song, next) => userModel.findOne({ _id: session.userId }, (err, user) => next(err, song, user)),
- (song, user, next) => {
- if (!user) return next("User does not exist.");
- return this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, user.dislikedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Disliked Songs' playlist.");
- return next(null, song, user.likedSongsPlaylist);
- })
- .catch(err => next(err));
- },
- (song, likedSongsPlaylist, next) => {
- this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, likedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Liked Songs' playlist.");
- return next(null, song);
- })
- .catch(err => next(err));
- },
- (song, next) => {
- SongsModule.runJob("RECALCULATE_SONG_RATINGS", { songId: song._id, youtubeId })
- .then(ratings => next(null, song, ratings))
- .catch(err => next(err));
- }
- ],
- async (err, song, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_UNDISLIKE",
- `User "${session.userId}" failed to undislike song ${youtubeId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { likes, dislikes } = ratings;
- SongsModule.runJob("UPDATE_SONG", { songId: song._id });
- CacheModule.runJob("PUB", {
- channel: "song.undislike",
- value: JSON.stringify({
- youtubeId,
- userId: session.userId,
- likes,
- dislikes
- })
- });
- ActivitiesModule.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- type: "song__undislike",
- payload: {
- message: `Removed <youtubeId>${song.title} by ${song.artists.join(
- ", "
- )}</youtubeId> from your Disliked Songs`,
- youtubeId,
- thumbnail: song.thumbnail
- }
- });
- return cb({
- status: "success",
- message: "You have successfully undisliked this song."
- });
- }
- );
- }),
- /**
- * Unlikes a song
- *
- * @param session
- * @param youtubeId - the youtube id
- * @param cb
- */
- unlike: isLoginRequired(async function unlike(session, youtubeId, cb) {
- const userModel = await DBModule.runJob("GET_MODEL", { modelName: "user" }, this);
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => {
- songModel.findOne({ youtubeId }, next);
- },
- (song, next) => {
- if (!song) return next("No song found with that id.");
- return next(null, song);
- },
- (song, next) => userModel.findOne({ _id: session.userId }, (err, user) => next(err, song, user)),
- (song, user, next) => {
- if (!user) return next("User does not exist.");
- return this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, user.dislikedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Disliked Songs' playlist.");
- return next(null, song, user.likedSongsPlaylist);
- })
- .catch(err => next(err));
- },
- (song, likedSongsPlaylist, next) => {
- this.module
- .runJob(
- "RUN_ACTION2",
- {
- session,
- namespace: "playlists",
- action: "removeSongFromPlaylist",
- args: [youtubeId, likedSongsPlaylist]
- },
- this
- )
- .then(res => {
- if (res.status === "error")
- return next("Unable to remove song from the 'Liked Songs' playlist.");
- return next(null, song);
- })
- .catch(err => next(err));
- },
- (song, next) => {
- SongsModule.runJob("RECALCULATE_SONG_RATINGS", { songId: song._id, youtubeId })
- .then(ratings => next(null, song, ratings))
- .catch(err => next(err));
- }
- ],
- async (err, song, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_UNLIKE",
- `User "${session.userId}" failed to unlike song ${youtubeId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { likes, dislikes } = ratings;
- SongsModule.runJob("UPDATE_SONG", { songId: song._id });
- CacheModule.runJob("PUB", {
- channel: "song.unlike",
- value: JSON.stringify({
- youtubeId,
- userId: session.userId,
- likes,
- dislikes
- })
- });
- ActivitiesModule.runJob("ADD_ACTIVITY", {
- userId: session.userId,
- type: "song__unlike",
- payload: {
- message: `Removed <youtubeId>${song.title} by ${song.artists.join(
- ", "
- )}</youtubeId> from your Liked Songs`,
- youtubeId,
- thumbnail: song.thumbnail
- }
- });
- return cb({
- status: "success",
- message: "You have successfully unliked this song."
- });
- }
- );
- }),
- /**
- * Gets song ratings
- *
- * @param session
- * @param songId - the Musare song id
- * @param cb
- */
- getSongRatings: isLoginRequired(async function getSongRatings(session, songId, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("GET_SONG", { songId }, this)
- .then(res => next(null, res.song))
- .catch(next);
- },
- (song, next) => {
- next(null, {
- likes: song.likes,
- dislikes: song.dislikes
- });
- }
- ],
- async (err, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_GET_RATINGS",
- `User "${session.userId}" failed to get ratings for ${songId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { likes, dislikes } = ratings;
- return cb({
- status: "success",
- data: {
- likes,
- dislikes
- }
- });
- }
- );
- }),
- /**
- * Gets user's own song ratings
- *
- * @param session
- * @param youtubeId - the youtube id
- * @param cb
- */
- getOwnSongRatings: isLoginRequired(async function getOwnSongRatings(session, youtubeId, cb) {
- const playlistModel = await DBModule.runJob("GET_MODEL", { modelName: "playlist" }, this);
- const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" }, this);
- async.waterfall(
- [
- next => songModel.findOne({ youtubeId }, next),
- (song, next) => {
- if (!song) return next("No song found with that id.");
- return next(null);
- },
- next =>
- playlistModel.findOne(
- { createdBy: session.userId, displayName: "Liked Songs" },
- (err, playlist) => {
- if (err) return next(err);
- if (!playlist) return next("'Liked Songs' playlist does not exist.");
- let isLiked = false;
- Object.values(playlist.songs).forEach(song => {
- // song is found in 'liked songs' playlist
- if (song.youtubeId === youtubeId) isLiked = true;
- });
- return next(null, isLiked);
- }
- ),
- (isLiked, next) =>
- playlistModel.findOne(
- { createdBy: session.userId, displayName: "Disliked Songs" },
- (err, playlist) => {
- if (err) return next(err);
- if (!playlist) return next("'Disliked Songs' playlist does not exist.");
- const ratings = { isLiked, isDisliked: false };
- Object.values(playlist.songs).forEach(song => {
- // song is found in 'disliked songs' playlist
- if (song.youtubeId === youtubeId) ratings.isDisliked = true;
- });
- return next(null, ratings);
- }
- )
- ],
- async (err, ratings) => {
- if (err) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log(
- "ERROR",
- "SONGS_GET_OWN_RATINGS",
- `User "${session.userId}" failed to get ratings for ${youtubeId}. "${err}"`
- );
- return cb({ status: "error", message: err });
- }
- const { isLiked, isDisliked } = ratings;
- return cb({
- status: "success",
- data: {
- youtubeId,
- liked: isLiked,
- disliked: isDisliked
- }
- });
- }
- );
- }),
- /**
- * Gets a list of all genres
- *
- * @param session
- * @param cb
- */
- getGenres: isAdminRequired(function getModule(session, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("GET_GENRES", this)
- .then(res => {
- next(null, res.genres);
- })
- .catch(next);
- }
- ],
- async (err, genres) => {
- if (err && err !== true) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "GET_GENRES", `User ${session.userId} failed to get genres. '${err}'`);
- cb({ status: "error", message: err });
- } else {
- this.log("SUCCESS", "GET_GENRES", `User ${session.userId} has successfully got the genres.`);
- cb({
- status: "success",
- message: "Successfully got genres.",
- data: {
- items: genres
- }
- });
- }
- }
- );
- }),
- /**
- * Gets a list of all artists
- *
- * @param session
- * @param cb
- */
- getArtists: isAdminRequired(function getModule(session, cb) {
- async.waterfall(
- [
- next => {
- SongsModule.runJob("GET_ARTISTS", this)
- .then(res => {
- next(null, res.artists);
- })
- .catch(next);
- }
- ],
- async (err, artists) => {
- if (err && err !== true) {
- err = await UtilsModule.runJob("GET_ERROR", { error: err }, this);
- this.log("ERROR", "GET_ARTISTS", `User ${session.userId} failed to get artists. '${err}'`);
- cb({ status: "error", message: err });
- } else {
- this.log("SUCCESS", "GET_ARTISTS", `User ${session.userId} has successfully got the artists.`);
- cb({
- status: "success",
- message: "Successfully got artists.",
- data: {
- items: artists
- }
- });
- }
- }
- );
- })
- };
|