|
@@ -58,7 +58,7 @@ CacheModule.runJob("SUB", {
|
|
channel: "song.newVerifiedSong",
|
|
channel: "song.newVerifiedSong",
|
|
cb: async songId => {
|
|
cb: async songId => {
|
|
const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" });
|
|
const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" });
|
|
- songModel.findOne({ songId }, (err, song) => {
|
|
|
|
|
|
+ songModel.findOne({ _id: songId }, (err, song) => {
|
|
WSModule.runJob("EMIT_TO_ROOM", {
|
|
WSModule.runJob("EMIT_TO_ROOM", {
|
|
room: "admin.songs",
|
|
room: "admin.songs",
|
|
args: ["event:admin.verifiedSong.added", song]
|
|
args: ["event:admin.verifiedSong.added", song]
|
|
@@ -81,7 +81,7 @@ CacheModule.runJob("SUB", {
|
|
channel: "song.updatedVerifiedSong",
|
|
channel: "song.updatedVerifiedSong",
|
|
cb: async songId => {
|
|
cb: async songId => {
|
|
const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" });
|
|
const songModel = await DBModule.runJob("GET_MODEL", { modelName: "song" });
|
|
- songModel.findOne({ songId }, (err, song) => {
|
|
|
|
|
|
+ songModel.findOne({ _id: songId }, (err, song) => {
|
|
WSModule.runJob("EMIT_TO_ROOM", {
|
|
WSModule.runJob("EMIT_TO_ROOM", {
|
|
room: "admin.songs",
|
|
room: "admin.songs",
|
|
args: ["event:admin.verifiedSong.updated", song]
|
|
args: ["event:admin.verifiedSong.updated", song]
|
|
@@ -475,17 +475,17 @@ export default {
|
|
if (song.status === "verified") {
|
|
if (song.status === "verified") {
|
|
CacheModule.runJob("PUB", {
|
|
CacheModule.runJob("PUB", {
|
|
channel: "song.updatedVerifiedSong",
|
|
channel: "song.updatedVerifiedSong",
|
|
- value: song.songId
|
|
|
|
|
|
+ value: song._id
|
|
});
|
|
});
|
|
} else if (song.status === "unverified") {
|
|
} else if (song.status === "unverified") {
|
|
CacheModule.runJob("PUB", {
|
|
CacheModule.runJob("PUB", {
|
|
channel: "song.updatedUnverifiedSong",
|
|
channel: "song.updatedUnverifiedSong",
|
|
- value: song.songId
|
|
|
|
|
|
+ value: song._id
|
|
});
|
|
});
|
|
} else if (song.status === "hidden") {
|
|
} else if (song.status === "hidden") {
|
|
CacheModule.runJob("PUB", {
|
|
CacheModule.runJob("PUB", {
|
|
channel: "song.updatedHiddenSong",
|
|
channel: "song.updatedHiddenSong",
|
|
- value: song.songId
|
|
|
|
|
|
+ value: song._id
|
|
});
|
|
});
|
|
}
|
|
}
|
|
|
|
|