|
@@ -133,9 +133,29 @@ class ClientRequest {
|
|
|
// 静音
|
|
|
this.socket.on("muted", (muted, userId) => this.onMuted(muted, userId))
|
|
|
//禁言
|
|
|
- this.socket.on("forbidden", (data) =>
|
|
|
- // this.socket.broadcast.to(this.option.roomId).emit("forbidden", data)
|
|
|
- io.to(this.option.roomId).emit("forbidden", data)
|
|
|
+ this.socket.on("forbidden", (data) => {
|
|
|
+ let user = null
|
|
|
+ let users = __rooms[this.option.roomId]
|
|
|
+ if (data.userId) {
|
|
|
+ for (let i = 0; i < users.length; i++) {
|
|
|
+ if (users[i].userId == data.userId) {
|
|
|
+ user = users[i]
|
|
|
+ user.can_speak = !data.can_speak
|
|
|
+ break
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 没找到指定参与人时不做操作
|
|
|
+ if (!user) {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ io.to(this.option.roomId).emit("forbidden", data)
|
|
|
+ // this.socket.broadcast.to(this.option.roomId).emit("forbidden", data)
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
)
|
|
|
// 成员关闭推流后通知静音
|
|
|
this.socket.on("mutedChanged", (muted, userId) => io.to(this.option.roomId).emit("mutedChanged", muted, userId))
|