Django Каналы - self.channel_layer.group_send не вызывает функцию - PullRequest
Новая
       117

Django Каналы - self.channel_layer.group_send не вызывает функцию

0 голосов
/ 09 апреля 2020

Я создаю игру с функцией чата / голосования. Я сделал это в oTree, основанном на Django Web Framework. Чат работает и состоит из Django каналов, в каждой игре человек имеет сеть с другими игроками и должен проголосовать / ответить на вопрос.

Я определил функцию "send_choice" в моем потребителе, но когда я ссылаюсь на это как на тип, он никогда не становится экземпляром.

routing.py 

from . import consumers
from django.conf.urls import re_path

websocket_routes = [
    re_path(r'ws/chat/(?P<group_pk>[0-9]+)$', consumers.ChatConsumer),
    re_path(r'ws/network_voting/(?P<player_pk>[0-9]+)/(?P<group_pk>[0-9]+)$', consumers.NetworkVoting)
]

consumer.py 

class NetworkVoting(AsyncJsonWebsocketConsumer):

    def clean_kwargs(self):
        self.player_pk = self.scope['url_route']['kwargs']['player_pk']
        self.group_pk = self.scope['url_route']['kwargs']['group_pk']

    async def connect(self):
        self.clean_kwargs()
        # Join
        await self.channel_layer.group_add(
            self.connection_groups(),
            self.channel_name
        )

        await self.accept()
        print("Connected to Network Socket")

    async def disconnect(self, close_code):
        self.clean_kwargs()
        await self.channel_layer.group_discard(
            self.connection_groups(),
            self.channel_name
        )
        print("Disconnected from Network Socket")

    def connection_groups(self, **kwargs):
        group_name = self.get_group().get_channel_group_name()
        personal_channel = self.get_player().get_personal_channel_name()
        return "{}-{}".format(group_name, personal_channel)

    def get_player(self):
        return Player.objects.get(pk=self.player_pk)

    def get_group(self):
        return Group.objects.get(pk=self.group_pk)

    async def receive(self, text_data):
        self.clean_kwargs()
        text_data_json = json.loads(text_data)
        msg = text_data_json['message']

        await self.channel_layer.group_send(
                    "network_voting",
                    {
                        "type": "send_choice",
                        "message": "Hello"
                    }
                )

    async def send_choice(self, event):
        message = event['message']

        # Send message to WebSocket
        await self.send(text_data=json.dumps({
            'message': message
        }))

        print("Sent message")

1 Ответ

0 голосов
/ 10 апреля 2020

Чтобы вызываться по каналам, когда сообщение отправляется через группу, вам необходимо подписаться на эту группу.

С момента отправки на network_voting вам необходимо подписаться на это. 

await self.channel_layer.group_add("network_voting", self.channel_name)

вам также необходимо отменить подписку при отключении.

Каналы предоставляют простой способ сделать это, если ваши группы имен имеют статус c в экземпляре, который вы можете установить, есть свойство groups . 

class NetworkVoting(AsyncJsonWebsocketConsumer):

    groups = ['network_voting']

Каналы позаботятся о том, чтобы подписаться и отписаться от вас.

...