adding initial testing consumers/routes for channels

awx/main/consumers.py

@@ -0,0 +1,13 @@
+from channels import Group
+from channels.sessions import channel_session
+
+
+@channel_session
+def job_event_connect(message):
+    job_id = message.content['path'].strip('/')
+    message.channel_session['job_id'] = job_id
+    Group("job_events-%s" % job_id).add(message.reply_channel)
+
+def emit_channel_notification(event, payload):
+    Group(event).send(payload)
+

awx/main/routing.py

@@ -0,0 +1,6 @@
+from channels.routing import route
+
+
+channel_routing = [
+    route("websocket.connect", "awx.main.consumers.job_event_connect", path=r'^/job_event/(?P<id>[a-zA-Z0-9_]+)/$'),
+]