auto commit

wsps/consumers.py

@@ -9,6 +9,24 @@ Mixins = wsps.tasks_loop.Mixins
 
 
 # class ChatConsumer(WebsocketConsumer,wsps.tasks_loop.AclTaskMixin,wsps.tasks_loop.AconMixin):
+class DispConsumer():
+    async def ws_rec_once(self, text_data):
+        # print("WS~~ 1")
+        msg_data = json.loads(text_data) 
+        # if 'message' in text_data_json:
+
+        if "key" in msg_data:
+            key = msg_data["key"]
+            mthd = getattr(self,key,None)
+            if mthd:
+                await mthd(msg_data) 
+            else:
+                p("METHOD " + key + " NOT FOUND!")
+        print("",end="",flush=True)
+
+
+
+
 class ChatConsumer(
     Mixins.DevMixin,
     Mixins.LoneMixinA,