django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-10-30 23:37:25 +03:00
Code Issues Packages Projects Releases Wiki Activity

decode incoming data before loading

Browse Source
This commit is contained in:
Arne Schauf 2015-09-17 15:54:44 +02:00
parent 454839dafa
commit c1990a92ed
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
channels/backends/redis_py.py
View File

@ -27,6 +27,10 @@ class RedisChannelBackend(BaseChannelBackend):
return redis.Redis(host=self.host, port=self.port) return redis.Redis(host=self.host, port=self.port)
def send(self, channel, message): def send(self, channel, message):
# if channel is no str (=> bytes) convert it
if not isinstance(channel, str):
channel = channel.decode('utf-8')
# Write out message into expiring key (avoids big items in list) # Write out message into expiring key (avoids big items in list)
key = self.prefix + uuid.uuid4().get_hex() key = self.prefix + uuid.uuid4().get_hex()
self.connection.set( self.connection.set(
@ -59,7 +63,7 @@ class RedisChannelBackend(BaseChannelBackend):
content = self.connection.get(result[1]) content = self.connection.get(result[1])
if content is None: if content is None:
continue continue
return result[0][len(self.prefix):], json.loads(content) return result[0][len(self.prefix):].decode("utf-8"), json.loads(content.decode("utf-8"))
else: else:
return None, None return None, None