Hi, I'm afraid you're using incredibly old versions of Channels and the bugs you're encountering are almost certainly fixed in more recent releases. I'm not sure there's much I can do.
Andrew On Tue, 15 May 2018, 13:01 LEEPS Lab, <leeps...@gmail.com> wrote: > We have an issue implementing django channels in an oTree project ( > http://otree.readthedocs.io/en/latest/) > > Currently we are forced to use django channels version 0.17.3 due to the > restriction inside of oTree, so it is possible that we are dealing with > version issues. > > However, we have an issue implementing a message.reply_channel response > where we are successfully adding messages to the reply channel queue, but > our client is not consuming these messages to the point of a > > asgiref.inmemory.ChannelLayer.ChannelFull: > > Our client code creates the usual websocket consuming scheme > > window.onload = function () { > var ws_scheme = window.location.protocol == "https:" ? "wss" : > "ws"; > var socket = new WebSocket(ws_scheme + '://' + > window.location.host + "/hft/{{group.id}}/{{player.id}}/"); > console.log(ws_scheme + '://' + window.location.host + "/hft/{{ > group.id}}/{{player.id}}/"); > > // Handle any errors that occur. > socket.onerror = function (error) { > console.log('WebSocket Error: ' + error); > }; > > // Show a connected message when the WebSocket is opened. > socket.onopen = function (event) { > console.log('connected to oTree'); > }; > // Handle messages sent by the server. > socket.onmessage = function (event) { > // var obj = jQuery.parseJSON(event.data); > // role = obj.state; > console.log("Received a message"); > }; > // Show a disconnected message when the WebSocket is closed. > socket.onclose = function (event) { > console.log('disconnected from oTree'); > }; > > > currently the socket.onmessage function is never called. > > Our consumer code looks like this: > > class SubjectConsumer(JsonWebsocketConsumer): > > def raw_connect(self, message, group_id, player_id): > Group(group_id).add(message.reply_channel) > log.info('Player %s is connected to Group %s.' % (player_id, > group_id)) > self.connect(message, player_id) > > def connect(self, message, player_id): > player = Player.objects.get(id=player_id) > player.channel = message.reply_channel > player.save() > > def raw_receive(self, message, group_id, player_id): > msg = json.loads(message.content['text']) > player = Player.objects.get(id=player_id) > player.receive_from_client(msg) > > def raw_disconnect(self, message, group_id, player_id): > log = 'Player %s disconnected from Group %s.' % (player_id, > group_id) > logging.info(log) > Group(group_id).discard(message.reply_channel) > > def send(self, msg, chnl): > Channel(chnl).send(msg) > > def broadcast(self, msg, chnl): > Group(chnl).send(msg) > > Usually we will save the reply_channel after connecting with the consumer > to a player object that will send a message when finished processing > received data from the client. We have already checked that the channels > names are correct, and that no errors are thrown in relation to the type of > our data and how we're sending it. > > We believe our routing is correct since we can receive data from the > client, but here is what we have > > channel_routing += [ > route_class(SubjectConsumer, > path=r"^/hft/(?P<group_id>\w+)/(?P<player_id>\w+)/"), > route_class(InvestorConsumer, > path=r"^/hft_investor/(?P<group_id>\w+)/"), > route_class(JumpConsumer, path=r"^/hft_jump/(?P<group_id>\w+)/") > ] > > We get the error after we successfully send several messages from the > consumer's send function but do not receive any on our client websockets. > We assume that they are sending correctly because we continue execution > after SubjectConsumer.send() and the queue eventually fills. > > 2018-05-15 10:43:06,813 - ERROR - worker - Error processing message with > consumer oTree_HFT_CDA.consumers.SubjectConsumer: > Traceback (most recent call last): > File "/usr/local/lib/python3.5/dist-packages/channels/worker.py", line > 120, in run > consumer(message, **kwargs) > File "/usr/local/lib/python3.5/dist-packages/channels/generic/base.py", > line 31, in __init__ > self.dispatch(message, **kwargs) > File "/usr/local/lib/python3.5/dist-packages/channels/generic/base.py", > line 69, in dispatch > return self.get_handler(message, **kwargs)(message, **kwargs) > File "/home/leeps/oTree_HFT_CDA/oTree_HFT_CDA/consumers.py", line 29, in > raw_receive > Channel(str(message.reply_channel)).send({'a':'b'}) > File "/usr/local/lib/python3.5/dist-packages/channels/channel.py", line > 38, in send > self.channel_layer.send(self.name, content) > File "/usr/local/lib/python3.5/dist-packages/asgiref/inmemory.py", line > 50, in send > raise self.ChannelFull(channel) > asgiref.inmemory.ChannelLayer.ChannelFull: websocket.send!haCXgRqE > websocket.send!haCXgRqE > 2018-05-15 10:43:07,019 - ERROR - worker - Error processing message with > consumer oTree_HFT_CDA.consumers.SubjectConsumer: > Traceback (most recent call last): > File "/usr/local/lib/python3.5/dist-packages/channels/worker.py", line > 120, in run > consumer(message, **kwargs) > File "/usr/local/lib/python3.5/dist-packages/channels/generic/base.py", > line 31, in __init__ > self.dispatch(message, **kwargs) > File "/usr/local/lib/python3.5/dist-packages/channels/generic/base.py", > line 69, in dispatch > return self.get_handler(message, **kwargs)(message, **kwargs) > File "/home/leeps/oTree_HFT_CDA/oTree_HFT_CDA/consumers.py", line 29, in > raw_receive > Channel(str(message.reply_channel)).send({'a':'b'}) > File "/usr/local/lib/python3.5/dist-packages/channels/channel.py", line > 38, in send > self.channel_layer.send(self.name, content) > File "/usr/local/lib/python3.5/dist-packages/asgiref/inmemory.py", line > 50, in send > raise self.ChannelFull(channel) > asgiref.inmemory.ChannelLayer.ChannelFull: websocket.send!haCXgRqE > > > > Package versions: > daphne 0.14.3 > asgiref 0.14.0 > > -- > You received this message because you are subscribed to the Google Groups > "Django users" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to django-users+unsubscr...@googlegroups.com. > To post to this group, send email to django-users@googlegroups.com. > Visit this group at https://groups.google.com/group/django-users. > To view this discussion on the web visit > https://groups.google.com/d/msgid/django-users/32412a05-9503-46ac-b59b-51cb6ee2b3c4%40googlegroups.com > <https://groups.google.com/d/msgid/django-users/32412a05-9503-46ac-b59b-51cb6ee2b3c4%40googlegroups.com?utm_medium=email&utm_source=footer> > . > For more options, visit https://groups.google.com/d/optout. > -- You received this message because you are subscribed to the Google Groups "Django users" group. To unsubscribe from this group and stop receiving emails from it, send an email to django-users+unsubscr...@googlegroups.com. To post to this group, send email to django-users@googlegroups.com. Visit this group at https://groups.google.com/group/django-users. To view this discussion on the web visit https://groups.google.com/d/msgid/django-users/CAFwN1uqf%2BPmAfyMzY6Z9k_tNvrDvqetE_HO0xPdM2Dd7gV5Q8A%40mail.gmail.com. For more options, visit https://groups.google.com/d/optout.
