Django 1000 код ошибки на веб-сокете при отправке данных в сокет(AsyncJsonWebSocketConsumer)

Может ли кто-нибудь объяснить мне причину этой ошибки. Сокет подключается, как только я посылаю в него данные, он выдает ответ

WebSocket HANDSHAKING /physiochat/ [192.168.43.159:57270]
WebSocket CONNECT /physiochat/ [192.168.43.159:57270]
WebSocket DISCONNECT /physiochat/ [192.168.43.159:57270]
disconnected :-  1000

Вот мой код, Также команды печати не работают, ничего не печатается на терминале. Я использовал другой потребитель с тем же кодом, но он работает нормально. Я новичок в веб-сокетах, поэтому прошу прощения за мой вопрос. Любая помощь будет оценена по достоинству. Спасибо 🙏🏻.

class PhysioChatConsumer(AsyncJsonWebsocketConsumer):

user = None
participant_info_obj = None

async def connect(self):
    print("CONNECTED")
    await self.accept()

async def disconnect(self, code):
    print('disconnected :- ', code)

async def receive_json(self, data):
    print("Receiving Json")
    try:
        print(self.user)
        if self.user and self.user.id:
            if 'text' in data.keys() and 'token' in data.keys():
                data = await self.add_mssg_to_db(data)
                await self.channel_layer.group_send(
                    self.room_name,
                    {
                        'type':'broadcast_message',
                        'data': data,
                    }
                )
            else:
                print("NOT GETTING USER")
                await self.close()
        else:
            if 'token' in data.keys() and 'room_id' in data.keys() :
                self.token = data['token']
                self.room_id = data['room_id']
                self.is_kiosk = data.get('kiosk', None)
                if self.is_kiosk:
                    self.profile_id = data['profile_id']
                authenticated = await self.authenticate_user()
                if authenticated:
                    check = await self.check_user_info()
                    if check:
                        self.room_name = f'chat-under-{self.room_id}'
                        await self.channel_layer.group_add(
                                self.room_name,
                                self.channel_name
                            )
                    else:
                        print("Unable to get the user info")
                        await self.close()
                else:
                    print("The user isn't an authenticated user")
                    await self.close()
            else:
                print("Not getting both token and room id")
                await self.close()
    except:
        traceback.print_exc
        await self.close()

async def broadcast_message(self, event):
    await self.send_json(event['data'])


    

Вернуться на верх