vote feedback

backend/voting/consumers.py

@@ -57,6 +57,7 @@ class SessionConsumer(WebsocketConsumer):
 		if action == "vote":
 			points = text_data_json.get("points", None)
 			track = session.current_track;
+			vote = None
 			try:
 				vote = Vote.objects.get(user=user, track=track, session=session)
 				vote.points = points
@@ -68,6 +69,10 @@ class SessionConsumer(WebsocketConsumer):
 				vote.save()
 			except Exception as e:
 				self.logger.error(f"Error voting on {track} by {user} for {points} points: {e}")
+			if vote:
+				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 == "next":
@@ -96,6 +101,11 @@ class SessionConsumer(WebsocketConsumer):
 	def announce_track(self, event):
 		self.send(text_data=json.dumps({"track": {}}))
 
+	def voted(self, event):
+		user = event["user"]
+		#self.session_name, {"type": "voted", "user": { "id": user.id, "username": user.username}, "track": track.id, "points": points}
+		self.send(text_data=json.dumps({"voted": { "id": user["id"], "username": user["username"], "points": event["points"], "track": event["track"]}}))
+
 
 	# Receive message from room group
 	def chat_message(self, event):