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.
For more options, visit https://groups.google.com/d/optout.
