localStorage token and websocket reconnect
This commit is contained in:
@@ -73,8 +73,10 @@ class SessionConsumer(WebsocketConsumer):
|
||||
async_to_sync(self.channel_layer.group_send)(
|
||||
self.session_name, {"type": "voted", "user": { "id": user.id, "username": user.username}, "track": track.id, "points": points}
|
||||
)
|
||||
if action == "pause":
|
||||
pass
|
||||
if action == "start":
|
||||
async_to_sync(self.channel_layer.group_send)(
|
||||
self.session_name, {"type": "announce.start"}
|
||||
)
|
||||
if action == "next":
|
||||
random.seed(session.seed)
|
||||
tracks = Track.objects.order_by("?")
|
||||
@@ -107,10 +109,13 @@ class SessionConsumer(WebsocketConsumer):
|
||||
user = event["user"]
|
||||
self.send(text_data=json.dumps({"joined": user}))
|
||||
|
||||
# TODO: maybe this could be one function.
|
||||
def announce_track(self, event):
|
||||
self.send(text_data=json.dumps({"track": {}}))
|
||||
def announce_done(self, event):
|
||||
self.send(text_data=json.dumps({"done": {}}))
|
||||
def announce_start(self, event):
|
||||
self.send(text_data=json.dumps({"start": {}}))
|
||||
|
||||
def voted(self, event):
|
||||
user = event["user"]
|
||||
|
||||
Reference in New Issue
Block a user