X-Git-Url: http://spangdorfia.com/code/?a=blobdiff_plain;f=logviewer%2Feventbus%2Fconsumers.py;fp=logviewer%2Feventbus%2Fconsumers.py;h=0727dae0ba15f9a57a26393d31a404a057bb5d6d;hb=d4fe9834a60132f118a1e8ee68e5221b28e10ccc;hp=0000000000000000000000000000000000000000;hpb=662453a92f419012cde6a79dc38df89c5be4d91b;p=kismet-logviewer.git

diff --git a/logviewer/eventbus/consumers.py b/logviewer/eventbus/consumers.py
new file mode 100644
index 0000000..0727dae
--- /dev/null
+++ b/logviewer/eventbus/consumers.py
@@ -0,0 +1,20 @@
+import json
+
+from channels.generic.websocket import WebsocketConsumer
+
+
+class EventbusConsumer(WebsocketConsumer):
+    def connect(self):
+        self.accept()
+
+    def disconnect(self, close_code):
+        pass
+
+    def receive(self, text_data):
+        print(text_data)
+        #text_data_json = json.loads(text_data)
+        #message = text_data_json["message"]
+
+        self.send("[]")
+
+        #self.send(text_data=json.dumps({"message": message}))