auto commit

wsps/consumers.py

@@ -10,11 +10,8 @@ Mixins = wsps.tasks_loop.Mixins
 
 # class ChatConsumer(WebsocketConsumer,wsps.tasks_loop.AclTaskMixin,wsps.tasks_loop.AconMixin):
 class DispConsumer():
-	async def ws_conn0(self):
-		print("WS~~ DispConsumer")
 	async def ws_rec_once(self, text_data):
 		# print("WS~~ 12")
-		# print("WS~~ DispConsumer")
 		msg_data = json.loads(text_data) 
 		# if 'message' in text_data_json:
 
@@ -32,13 +29,47 @@ class DispConsumer():
 
 
 
-class ChatConsumer():
+class ChatConsumer(
+	DispConsumer,
+	Mixins.DevMixin,
+	Mixins.LoneMixinA,
+	Mixins.AclTaskMixin,
+	Mixins.AconMixin,
+	Mixins.LoneMixinB,
+	Mixins.DevMroMixin,
+	AsyncWebsocketConsumer,
+	):
+	# def connect(self):
 	async def ws_conn0(self):
-		print("WS~~ ChatConsumer")
+
+		# print("ChatConsumer:ws_conn0")
+		# p("!!!!!!!!!!!!!!!!!!!!?")
 		print("",end="",flush=True)
+		# time.sleep(1.5)
+
+		# p("!!!!!!!!!!!!!!!!!!!!")
+		r'''
+		await self.send(text_data=json.dumps({
+			'wsconn': {"abc.":12}
+		}))
+		'''
+
+		# print("",end="",flush=True)
 		self.accept()
+
+		r'''
+		await self.send(text_data=json.dumps({
+			'wsconn': {"abc.":123}
+		}))
+		'''
+
+
 	async def ws_disconn(self, close_code):
 		pass
+
+	async def ws_disconn_z(self, close_code):
+		pass
+
 	async def ws_rec(self, text_data):
 		return
 		p("text_data:",text_data)
@@ -55,4 +86,12 @@ class ChatConsumer():
 			'zzz': {"abc":123}
 		}))
 
-Mixins.ChatConsumer = ChatConsumer
+
+# print(">>>>>>>>>>>>>")
+Mixins.ChatConsumer = ChatConsumer
+
+print("++?",end="\n",flush=True)
+# print("++2?",end="\n",flush=True)
+
+# print("++",end="\n",flush=True)
+