auto commit

djc_srv/asgi.py

@@ -11,6 +11,30 @@ import os
 
 from django.core.asgi import get_asgi_application
 
+from channels.auth import AuthMiddlewareStack
+from channels.routing import ProtocolTypeRouter, URLRouter
+from channels.security.websocket import AllowedHostsOriginValidator
+
+import wsps.routing
+
+
 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'djc_srv.settings')
 
-application = get_asgi_application()
+# application = get_asgi_application()
+
+
+application = ProtocolTypeRouter({
+    "http": get_asgi_application(),
+    # Just HTTP for now. (We can add other protocols later.)
+
+  "websocket": AllowedHostsOriginValidator(
+        AuthMiddlewareStack(
+            URLRouter(
+                wsps.routing.websocket_urlpatterns
+            )
+        )
+    ),
+
+})
+
+

wsps/consumers.py

@@ -0,0 +1,18 @@
+# chat/consumers.py
+import json
+from channels.generic.websocket import WebsocketConsumer
+
+class ChatConsumer(WebsocketConsumer):
+    def connect(self):
+        self.accept()
+
+    def disconnect(self, close_code):
+        pass
+
+    def receive(self, text_data):
+        text_data_json = json.loads(text_data)
+        message = text_data_json['message']
+
+        self.send(text_data=json.dumps({
+            'message': message
+        }))