django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-18 03:42:18 +03:00
Code Issues Packages Projects Releases Wiki Activity

Json encoding/decoding for send/receive content at the HttpClient

Browse Source
This commit is contained in:
Krukov Dima 2016-07-24 13:10:57 +00:00
parent 3c03b44af7
commit a3e779fe9c
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
channels/tests/http.py
View File

@ -1,4 +1,4 @@
import json
import copy import copy
from django.apps import apps from django.apps import apps
@ -56,7 +56,12 @@ class HttpClient(Client):
self._session = session_for_reply_channel(self.reply_channel) self._session = session_for_reply_channel(self.reply_channel)
return self._session return self._session
def send(self, to, content={}, path='/'): def receive(self):
content = super(HttpClient, self).receive()
if content:
return json.loads(content['text'])
def send(self, to, text=None, content={}, path='/'):
""" """
Send a message to a channel. Send a message to a channel.
Adds reply_channel name and channel_session to the message. Adds reply_channel name and channel_session to the message.
@ -65,6 +70,9 @@ class HttpClient(Client):
content.setdefault('reply_channel', self.reply_channel) content.setdefault('reply_channel', self.reply_channel)
content.setdefault('path', path) content.setdefault('path', path)
content.setdefault('headers', self.headers) content.setdefault('headers', self.headers)
text = text or content.get('text', None)
if text:
content['text'] = json.dumps(text)
self.channel_layer.send(to, content) self.channel_layer.send(to, content)
def login(self, **credentials): def login(self, **credentials):