5e03303370b7943a799a56c317c7bb05419e9354,dino/endpoint/queue.py,QueueHandler,kick,#QueueHandler#Any#Any#Any#Any#Any#Any#,161

Before Change

        self.env.out_of_scope_emit("gn_user_kicked", data, json=True, namespace=namespace, room=room_id, broadcast=True)
        self.send_kick_event_to_external_queue(activity)

        logger.info("about to kick user %s, all users in room: %s" % (user_sid, str(_users)))

        if user_sid in _users:
            try:
                self.socketio.server.leave_room(user_sid, room_id, "/ws")

After Change

            environ.env.publish(data, external=True)

    def kick(self, orig_data: dict, activity: Activity, room_id: str, user_id: str, user_sid: str, namespace: str) -> None:
        if room_id is None:
            raise RuntimeError("trying to kick when room is none")

        try:
            _users = list()
            if room_id in self.socketio.server.manager.rooms[namespace]:
                _users = self.socketio.server.manager.rooms[namespace][room_id]

Instances