Moved to channels websocket bridge

Mark Gibbs · Mark Gibbs · commit 81cf9174f101 · 2018-06-13T19:25:55.000-07:00
diff --git a/demo/demo/consumers.py b/demo/demo/consumers.py
@@ -1,11 +1,15 @@
 from channels.generic.websocket import WebsocketConsumer
 
+import json
+
 class MessageConsumer(WebsocketConsumer):
     def connect(self):
         self.accept()
     def disconnect(self, close_code):
         pass
     def receive(self, text_data):
         print("Got incoming")
+        message = json.loads(text_data)
         print(text_data)
-        self.send("Thanks for [%s]"%text_data)
+        self.send(json.dumps({'message':"Thanks for [%s]"%text_data}))
+        self.send(json.dumps({'original_message':message}))
diff --git a/demo/demo/templates/index.html b/demo/demo/templates/index.html
@@ -1,5 +1,6 @@
 <!DOCTYPE HTML>
 <html>
+{%load staticfiles%}
 {%load plotly_dash%}
 <title>Simple stuff</title>
 <body>
@@ -16,11 +17,14 @@
     {%plotly_app name="Ex2"%}
   </div>
 </body>
+<script src="{%static "channels/js/websocketbridge.js"%}"></script>
 <script>
-  var socket = new WebSocket("ws://"+window.location.host+"/ws/channel");
-  socket.onmessage = function(e) {
-    console.log("Got ws inbound message");
-    console.log(e);
-  };
+  const wsb = new channels.WebSocketBridge();
+  wsb.connect("/ws/channel");
+  wsb.listen(function(action, stream) {
+    console.log("WSB inbound");
+    console.log(action);
+    console.log(stream);
+  });
 </script>
 </html>
