Fixed issue where homepage didn't update when station paused/resumed, privacy changed, name/displatname/description changed

backend/logic/actions/stations.js

@@ -108,6 +108,17 @@ CacheModule.runJob("SUB", {
 				room: `station.${stationId}`,
 				args: ["event:stations.pause", { pausedAt: station.pausedAt }]
 			});
+
+			StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+				room: `home`,
+				station
+			})
+				.then(response => {
+					const { socketsThatCan } = response;
+					socketsThatCan.forEach(socket => {
+						socket.emit("event:station.pause", { stationId });
+					});
+				});
 		});
 	}
 });
@@ -120,6 +131,118 @@ CacheModule.runJob("SUB", {
 				room: `station.${stationId}`,
 				args: ["event:stations.resume", { timePaused: station.timePaused }]
 			});
+
+			StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+				room: `home`,
+				station
+			})
+				.then(response => {
+					const { socketsThatCan } = response;
+					socketsThatCan.forEach(socket => {
+						socket.emit("event:station.resume", { stationId });
+					});
+				})
+				.catch(console.log);
+		});
+	}
+});
+
+CacheModule.runJob("SUB", {
+	channel: "station.privacyUpdate",
+	cb: response => {
+		const { stationId, previousPrivacy } = response;
+		StationsModule.runJob("GET_STATION", { stationId }).then(station => {
+			if (previousPrivacy !== station.privacy) {
+				if (station.privacy === "public") {
+					// Station became public
+
+					IOModule.runJob("EMIT_TO_ROOM", {
+						room: "home",
+						args: ["event:stations.created", station]
+					});
+				} else if (previousPrivacy === "public") {
+					// Station became hidden
+
+					StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+						room: `home`,
+						station
+					}).then(response => {
+						const { socketsThatCan, socketsThatCannot } = response;
+						socketsThatCan.forEach(socket => {
+							socket.emit("event:station.updatePrivacy", { stationId, privacy: station.privacy });
+						});
+						socketsThatCannot.forEach(socket => {
+							socket.emit("event:station.removed", { stationId });
+						});
+					});
+				} else {
+					// Station was hidden and is still hidden
+
+					StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+						room: `home`,
+						station
+					}).then(response => {
+						const { socketsThatCan } = response;
+						socketsThatCan.forEach(socket => {
+							socket.emit("event:station.updatePrivacy", { stationId, privacy: station.privacy });
+						});
+					});
+				}
+			}
+		});
+	}
+});
+
+CacheModule.runJob("SUB", {
+	channel: "station.nameUpdate",
+	cb: response => {
+		const { stationId } = response;
+		StationsModule.runJob("GET_STATION", { stationId }).then(station => {
+			StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+				room: `home`,
+				station
+			}).then(response => {
+				const { socketsThatCan } = response;
+				socketsThatCan.forEach(socket => {
+					socket.emit("event:station.updateName", { stationId, name: station.name });
+				});
+			});
+		});
+	}
+});
+
+CacheModule.runJob("SUB", {
+	channel: "station.displayNameUpdate",
+	cb: response => {
+		const { stationId } = response;
+		StationsModule.runJob("GET_STATION", { stationId }).then(station => {
+			StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+				room: `home`,
+				station
+			}).then(response => {
+				const { socketsThatCan } = response;
+				socketsThatCan.forEach(socket => {
+					socket.emit("event:station.updateDisplayName", { stationId, displayName: station.displayName });
+				});
+			});
+		});
+	}
+});
+
+CacheModule.runJob("SUB", {
+	channel: "station.descriptionUpdate",
+	cb: response => {
+		const { stationId } = response;
+		StationsModule.runJob("GET_STATION", { stationId }).then(station => {
+			StationsModule.runJob("GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION", {
+				room: `home`,
+				station
+			}).then(response => {
+				const { socketsThatCan } = response;
+				socketsThatCan.forEach(socket => {
+					socket.emit("event:station.updateDescription", { stationId, description: station.description });
+				});
+			});
 		});
 	}
 });
@@ -153,6 +276,11 @@ CacheModule.runJob("SUB", {
 			room: `station.${stationId}`,
 			args: ["event:stations.remove"]
 		});
+		console.log(111, "REMOVED");
+		IOModule.runJob("EMIT_TO_ROOM", {
+			room: `home`,
+			args: ["event:station.removed", { stationId }]
+		});
 		IOModule.runJob("EMIT_TO_ROOM", {
 			room: "admin.stations",
 			args: ["event:admin.station.removed", stationId]
@@ -867,6 +995,10 @@ export default {
 					"STATIONS_UPDATE_NAME",
 					`Updated station "${stationId}" name to "${newName}" successfully.`
 				);
+				CacheModule.runJob("PUB", {
+					channel: "station.nameUpdate",
+					value: { stationId }
+				});
 				return cb({
 					status: "success",
 					message: "Successfully updated the name."
@@ -926,6 +1058,10 @@ export default {
 					"STATIONS_UPDATE_DISPLAY_NAME",
 					`Updated station "${stationId}" displayName to "${newDisplayName}" successfully.`
 				);
+				CacheModule.runJob("PUB", {
+					channel: "station.displayNameUpdate",
+					value: { stationId }
+				});
 				return cb({
 					status: "success",
 					message: "Successfully updated the display name."
@@ -985,6 +1121,10 @@ export default {
 					"STATIONS_UPDATE_DESCRIPTION",
 					`Updated station "${stationId}" description to "${newDescription}" successfully.`
 				);
+				CacheModule.runJob("PUB", {
+					channel: "station.descriptionUpdate",
+					value: { stationId }
+				});
 				return cb({
 					status: "success",
 					message: "Successfully updated the description."
@@ -1009,8 +1149,21 @@ export default {
 			},
 			this
 		);
+		let previousPrivacy = null;
 		async.waterfall(
 			[
+				next => {
+					stationModel.findOne({ _id: stationId }, next);
+				},
+
+				(station, next) => {
+					if (!station) next("No station found.");
+					else {
+						previousPrivacy = station.privacy;
+						next();
+					}
+				},
+
 				next => {
 					stationModel.updateOne(
 						{ _id: stationId },
@@ -1043,6 +1196,10 @@ export default {
 					"STATIONS_UPDATE_PRIVACY",
 					`Updated station "${stationId}" privacy to "${newPrivacy}" successfully.`
 				);
+				CacheModule.runJob("PUB", {
+					channel: "station.privacyUpdate",
+					value: { stationId, previousPrivacy }
+				});
 				return cb({
 					status: "success",
 					message: "Successfully updated the privacy."

backend/logic/stations.js

@@ -1085,6 +1085,107 @@ class _StationsModule extends CoreClass {
 			);
 		});
 	}
+
+	/**
+	 * Returns a list of sockets in a room that can and can't know about a station
+	 *
+	 * @param {object} payload - the payload object
+	 * @param {object} payload.station - the station object
+	 * @param {string} payload.room - the socket.io room to get the sockets from
+	 * @returns {Promise} - returns a promise (resolve, reject)
+	 */
+	GET_SOCKETS_THAT_CAN_KNOW_ABOUT_STATION(payload) {
+		return new Promise((resolve, reject) => {
+			IOModule.runJob("GET_ROOM_SOCKETS", { room: payload.room }, this)
+				.then(socketsObject => {
+					const sockets = Object.keys(socketsObject).map(socketKey => socketsObject[socketKey]);
+					let socketsThatCan = [];
+					const socketsThatCannot = [];
+
+					if (payload.station.privacy === "public") {
+						socketsThatCan = sockets;
+						resolve({ socketsThatCan, socketsThatCannot });
+					} else {
+						async.eachLimit(
+							sockets,
+							1,
+							(socket, next) => {
+								const { session } = socket;
+
+								async.waterfall(
+									[
+										next => {
+											if (!session.sessionId) next("No session id");
+											else next();
+										},
+
+										next => {
+											CacheModule.runJob(
+												"HGET",
+												{
+													table: "sessions",
+													key: session.sessionId
+												},
+												this
+											)
+												.then(response => {
+													next(null, response);
+												})
+												.catch(next);
+										},
+
+										(session, next) => {
+											if (!session) next("No session");
+											else {
+												DBModule.runJob("GET_MODEL", { modelName: "user" }, this)
+													.then(userModel => {
+														next(null, userModel);
+													})
+													.catch(next);
+											}
+										},
+
+										(userModel, next) => {
+											if (!userModel) next("No user model");
+											else
+												userModel.findOne(
+													{
+														_id: session.userId
+													},
+													next
+												);
+										},
+
+										(user, next) => {
+											if (!user) next("No user found");
+											else if (user.role === "admin") {
+												socketsThatCan.push(socket);
+												next();
+											} else if (
+												payload.station.type === "community" &&
+												payload.station.owner === session.userId
+											) {
+												socketsThatCan.push(socket);
+												next();
+											}
+										}
+									],
+									err => {
+										if (err) socketsThatCannot.push(socket);
+										next();
+									}
+								);
+							},
+							err => {
+								if (err) reject(err);
+								else resolve({ socketsThatCan, socketsThatCannot });
+							}
+						);
+					}
+				})
+				.catch(reject);
+		});
+	}
 }
 
 export default new _StationsModule();

frontend/src/pages/Home/index.vue

@@ -225,14 +225,35 @@ export default {
 			});
 			this.socket.on("event:stations.created", res => {
 				const station = res;
+				if (
+					this.stations.find(_station => _station._id === station._id)
+				) {
+					this.stations.forEach(s => {
+						const _station = s;
+						if (_station._id === station._id) {
+							_station.privacy = station.privacy;
+						}
+					});
+				} else {
+					if (!station.currentSong)
+						station.currentSong = {
+							thumbnail: "/assets/notes-transparent.png"
+						};
+					if (station.currentSong && !station.currentSong.thumbnail)
+						station.currentSong.ytThumbnail = `https://img.youtube.com/vi/${station.currentSong.songId}/mqdefault.jpg`;
+					this.stations.push(station);
+				}
+			});
 
-				if (!station.currentSong)
-					station.currentSong = {
-						thumbnail: "/assets/notes-transparent.png"
-					};
-				if (station.currentSong && !station.currentSong.thumbnail)
-					station.currentSong.ytThumbnail = `https://img.youtube.com/vi/${station.currentSong.songId}/mqdefault.jpg`;
-				this.stations.push(station);
+			this.socket.on("event:station.removed", response => {
+				const { stationId } = response;
+				const station = this.stations.find(
+					station => station._id === stationId
+				);
+				if (station) {
+					const stationIndex = this.stations.indexOf(station);
+					this.stations.splice(stationIndex, 1);
+				}
 			});
 
 			this.socket.on(
@@ -247,6 +268,46 @@ export default {
 				}
 			);
 
+			this.socket.on("event:station.updatePrivacy", response => {
+				const { stationId, privacy } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.privacy = privacy;
+					}
+				});
+			});
+
+			this.socket.on("event:station.updateName", response => {
+				const { stationId, name } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.name = name;
+					}
+				});
+			});
+
+			this.socket.on("event:station.updateDisplayName", response => {
+				const { stationId, displayName } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.displayName = displayName;
+					}
+				});
+			});
+
+			this.socket.on("event:station.updateDescription", response => {
+				const { stationId, description } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.description = description;
+					}
+				});
+			});
+
 			this.socket.on("event:station.nextSong", (stationId, song) => {
 				let newSong = song;
 				this.stations.forEach(s => {
@@ -263,6 +324,26 @@ export default {
 				});
 			});
 
+			this.socket.on("event:station.pause", response => {
+				const { stationId } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.paused = true;
+					}
+				});
+			});
+
+			this.socket.on("event:station.resume", response => {
+				const { stationId } = response;
+				this.stations.forEach(s => {
+					const station = s;
+					if (station._id === stationId) {
+						station.paused = false;
+					}
+				});
+			});
+
 			this.socket.on("event:user.favoritedStation", stationId => {
 				this.favoriteStations.push(stationId);
 			});