auto commit

wsps/tasks_loop.py

@@ -63,59 +63,59 @@ def callable_helper(fn):
 
 verbose = print
 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"])
+	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")
-        p("ACON!!!!!!!!!!!!!!!!!!!!!!!!!!!")
-        p(flush=True)
-        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("",end="",flush=True)
-        # 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)
+	async def connect(self):
+		# print("-----------CONNECTING async def connect")
+		p("ACON!!!!!!!!!!!!!!!!!!!!!!!!!!!")
+		p(flush=True)
+		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("",end="",flush=True)
+		# 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):
@@ -387,20 +387,20 @@ redis_info()
 r"""
 
 def atexit_fn():
-    pass
-    # rconn.flushall()
-    print("ATEXIT FN")
-    rinfo_len()
-    keys = rconn.keys()
-    print(keys)
-    print(len(keys))
-    print("t 000")
-    # time.sleep(10)
-    print("t 010")
-    # time.sleep(20)
-    print("t 020")
-    print("ATEXIT FN...")
-    rconn.flushall()
+	pass
+	# rconn.flushall()
+	print("ATEXIT FN")
+	rinfo_len()
+	keys = rconn.keys()
+	print(keys)
+	print(len(keys))
+	print("t 000")
+	# time.sleep(10)
+	print("t 010")
+	# time.sleep(20)
+	print("t 020")
+	print("ATEXIT FN...")
+	rconn.flushall()
 atexit.register(atexit_fn)