From d6f8b079352b069de1852b1eef3db2c73411eb5d Mon Sep 17 00:00:00 2001 From: Jorrit Schaap <schaap@astron.nl> Date: Mon, 2 Nov 2020 20:08:54 +0100 Subject: [PATCH] TMSS-413: commented out proof-of-concept which depends on new channels package --- SAS/TMSS/src/tmss/settings.py | 12 +++---- SAS/TMSS/src/tmss/tmssapp/consumers.py | 44 +++++++++++++------------- 2 files changed, 28 insertions(+), 28 deletions(-) diff --git a/SAS/TMSS/src/tmss/settings.py b/SAS/TMSS/src/tmss/settings.py index 9a1c3fda21c..233091a8616 100644 --- a/SAS/TMSS/src/tmss/settings.py +++ b/SAS/TMSS/src/tmss/settings.py @@ -125,7 +125,7 @@ INSTALLED_APPS = [ 'viewflow', 'viewflow.frontend', 'lofar.sas.tmss.tmss.workflowapp', - 'channels', + # 'channels', ] @@ -176,11 +176,11 @@ STATICFILES_DIRS = [ ASGI_APPLICATION = 'lofar.sas.tmss.tmss.routing.application' WSGI_APPLICATION = 'lofar.sas.tmss.tmss.wsgi.application' -CHANNEL_LAYERS = { - "default": { - "BACKEND": "channels.layers.InMemoryChannelLayer", - }, -} +# CHANNEL_LAYERS = { +# "default": { +# "BACKEND": "channels.layers.InMemoryChannelLayer", +# }, +# } # Database # https://docs.djangoproject.com/en/2.0/ref/settings/#databases diff --git a/SAS/TMSS/src/tmss/tmssapp/consumers.py b/SAS/TMSS/src/tmss/tmssapp/consumers.py index c6d1a47ec5b..a6f16a437bc 100644 --- a/SAS/TMSS/src/tmss/tmssapp/consumers.py +++ b/SAS/TMSS/src/tmss/tmssapp/consumers.py @@ -1,22 +1,22 @@ -from channels.generic.websocket import WebsocketConsumer -import json - - -# Simple Channels consumer for Websockets -class AppConsumer(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'] - - print('WS> Received', message) - - self.send(text_data=json.dumps({ - 'message': message[::-1] - })) +# from channels.generic.websocket import WebsocketConsumer +# import json +# +# +# # Simple Channels consumer for Websockets +# class AppConsumer(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'] +# +# print('WS> Received', message) +# +# self.send(text_data=json.dumps({ +# 'message': message[::-1] +# })) -- GitLab