djc_srv/wsps/consumers.py

# chat/consumers.py
import json
from channels.generic.websocket import WebsocketConsumer,AsyncWebsocketConsumer
import wsps.tasks_loop
import time
p=print

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:

		if "key" in msg_data:
			key = "jm_" + msg_data["key"] 
			# key = "j_" + 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():
	async def ws_conn0(self):
		print("WS~~ ChatConsumer")
		print("",end="",flush=True)
		self.accept()
	async def ws_disconn(self, close_code):
		pass
	async def ws_rec(self, text_data):
		return
		p("text_data:",text_data)
		print("",end="",flush=True)
		text_data_json = json.loads(text_data)
		message = text_data_json['message']

		await self.send(text_data=json.dumps({
			'message': message
		}))


		await self.send(text_data=json.dumps({
			'zzz': {"abc":123}
		}))zzz

Mixins.ChatConsumer = ChatConsumer