Forráskód Böngészése

增加过期提示

gemercheung 2 éve
szülő
commit
02df26f692
1 módosított fájl, 3 hozzáadás és 1 törlés
  1. 3 1
      src/room/users/users.service.ts

+ 3 - 1
src/room/users/users.service.ts

@@ -10,7 +10,7 @@ export class UsersService {
     @InjectRedis() private readonly redis: Redis,
     @Inject(forwardRef(() => RoomService))
     private roomService: RoomService,
-  ) {}
+  ) { }
 
   async isUserInRooms(RoomId: string, UserId: string): Promise<boolean> {
     const res = await this.redis.hexists(
@@ -139,6 +139,8 @@ export class UsersService {
             type: 'invalid-room-params',
             code: 403,
           });
+        this.roomService.handleRoomDismiss(RoomId);
+        socket.disconnect();
       }
     }