|
@@ -15,7 +15,20 @@ export class ConnectController extends BasicController {
|
|
|
await this.syncDeviceController.run();
|
|
|
|
|
|
this.redisSubClient.subscribe("dismissRoom", (message) => {
|
|
|
+ // chat:room:dismiss:c-fCTZyvc:E71464
|
|
|
this.logger("subscribe-订阅", JSON.stringify(message));
|
|
|
+ const disMissId = message.split("chat:room:dismiss:")[1];
|
|
|
+ if (disMissId) {
|
|
|
+ const disMissRoomId = `room:${disMissId}`;
|
|
|
+ const userId = this.roomController.userId;
|
|
|
+ const roomId = this.roomController.roomId;
|
|
|
+ const user = this.roomController.user;
|
|
|
+ this.logger("subscribe-订阅", disMissRoomId, userId, roomId, user);
|
|
|
+ if (disMissRoomId === disMissRoomId) {
|
|
|
+ this.roomController.roomAssistant.stopCall(roomId, userId, user);
|
|
|
+ //
|
|
|
+ }
|
|
|
+ }
|
|
|
});
|
|
|
|
|
|
this.socket.on("disconnect", async (reason) => {
|