mirror of
https://github.com/django/daphne.git
synced 2025-07-10 16:02:18 +03:00
updated example and made decorators py3-ready
This commit is contained in:
parent
93472226fb
commit
ff9cdb7113
|
@ -50,8 +50,8 @@ def channel_session(func):
|
||||||
# Turn the reply_channel into a valid session key length thing.
|
# Turn the reply_channel into a valid session key length thing.
|
||||||
# We take the last 24 bytes verbatim, as these are the random section,
|
# We take the last 24 bytes verbatim, as these are the random section,
|
||||||
# and then hash the remaining ones onto the start, and add a prefix
|
# and then hash the remaining ones onto the start, and add a prefix
|
||||||
reply_name = message.reply_channel.name
|
reply_name = str(message.reply_channel.name).encode()
|
||||||
session_key = "skt" + hashlib.md5(reply_name[:-24]).hexdigest()[:8] + reply_name[-24:]
|
session_key = b"skt" + str(hashlib.md5(reply_name[:-24]).hexdigest()[:8]).encode() + reply_name[-24:]
|
||||||
# Make a session storage
|
# Make a session storage
|
||||||
session_engine = import_module(settings.SESSION_ENGINE)
|
session_engine = import_module(settings.SESSION_ENGINE)
|
||||||
session = session_engine.SessionStore(session_key=session_key)
|
session = session_engine.SessionStore(session_key=session_key)
|
||||||
|
|
|
@ -267,7 +267,7 @@ name in the path of your WebSocket request (we'll ignore auth for now - that's n
|
||||||
|
|
||||||
# Connected to websocket.keepalive
|
# Connected to websocket.keepalive
|
||||||
@channel_session
|
@channel_session
|
||||||
def ws_add(message):
|
def ws_keepalive(message):
|
||||||
Group("chat-%s" % message.channel_session['room']).add(message.reply_channel)
|
Group("chat-%s" % message.channel_session['room']).add(message.reply_channel)
|
||||||
|
|
||||||
# Connected to websocket.receive
|
# Connected to websocket.receive
|
||||||
|
|
Loading…
Reference in New Issue
Block a user