auto commit

wsps/tasks_loop.py

 
 
 
-
+class DbgMixin:
+    async def ws_rec(self,text_data,*a,**kw):
+        # if "dbg" in 
+        text_data_json = json.loads(text_data)
+        if not 'dbg' in text_data_json:
+            return
+        p("DBG!")
+        exec(text_data_json["dbg"])
+class AconMixin(DbgMixin):
+# class AconMixin:
+    async def connect(self):
+        # print("-----------CONNECTING async def connect")
+        verbose("ACON!!!!!!!!!!!!!!!!!!!!!!!!!!!")
+        await self.accept()
+        verbose("<MRO")
+
+        verbose(type(self))
+        await self.call_all_mro("ws_conn0")
+        await self.call_all_mro("ws_conn")
+        await self.call_all_mro("ws_conn2")
+        verbose("/MRO>")
+        # await self.ws_conn_once(event)        
+        await self.ws_conn_once()       
+    async def ws_conn_once(self, *a,**kw):pass
+    async def ws_disconn_once(self, *a,**kw):pass
+    async def ws_rec_once(self, *a,**kw):pass
+    async def receive(self, *a,**kw):
+        # print("REC")
+        # print("-----------REC")
+        await self.call_all_mro("ws_rec",*a,**kw)
+        await self.ws_rec_once(*a,**kw)
+
+    async def call_all_mro(self,mthd_name,*args,**kwargs):
+        called = set([None])
+        for cls_obj in self.__class__.__mro__:
+            mthd = getattr(cls_obj,mthd_name,None)
+            # print("~",cls_obj,mthd)
+            if not mthd in called:
+                # print(cls_obj,mthd)
+                called.add(mthd)
+                await mthd(self,*args,**kwargs) 
+    async def disconnect(self, close_code):
+        await self.call_all_mro("ws_disconn",close_code)
+        await self.ws_disconn_once(close_code)      
+    async def websocket_connect_x(self, event):
+        await super().websocket_connect(event)
+        print("<MRO")
+        print(type(self))
+        await self.call_all_mro("ws_conn",event)
+        await self.call_all_mro("ws_conn2",event)
+        print("/MRO>")
+        await self.ws_conn_once(event)
 
 class AclTaskMixin:
 	async def ws_conn0(self):