auto commit

wsps/tasks_loop.py

@@ -120,6 +120,9 @@ class AconMixin(DbgMixin):
 
 class AclTaskMixin:
 	async def ws_conn0(self):
+		if glob_cl.has_cl:
+			return
+		glob_cl = True
 		print("AclTaskMixin:ws_conn0")
 		glob_cl.run_persistent_loop(self)
 		glob_cl.acl = self.channel_layer
@@ -156,9 +159,11 @@ Mixins.AclTaskMixin = AclTaskMixin
 
 # GCLMixin
 class globCL(GCLMixin):
+
 	def __init__(self,*a,**kw):
 		# for now we are not going to do any weird class stuff
 		self.acl = None
+		self.has_cl = False
 		self.rconn = connect_redis()
 		self.rman = RldMan()
 		self.cbs_once = []
@@ -236,6 +241,16 @@ class globCL(GCLMixin):
 		loop.create_task(self.persistent_loop())
 		self.loop = loop
 	run_persistent_loop = _run_persistent_loop
+
+
+	def sync_dev_group_add(self,*a,**kw):
+		glob_cl.cbs_once.append(group_add(*a,**kw))
+	async def dev_group_add(self,group_name,consumer):
+		channel_layer = glob_cl.acl
+		if not consumer.channel_name in consumer.groups_set:
+			consumer.groups_set.add(groups)
+		consumer.groups
+		await channel_layer.group_add(group_name,consumer.channel_name)