test websocket

jumpserver.py

@@ -121,6 +121,7 @@ def connect(host, port, user, password):
     log_date_dir = '%s/%s' % (log_dir, time.strftime('%Y%m%d'))
     if not os.path.isdir(log_date_dir):
         os.mkdir(log_date_dir)
+        os.chmod(log_date_dir, 0777)
     structtime_start = time.localtime()
     datetime_start = time.strftime('%Y%m%d%H%M%S', structtime_start)
     logtime_start = time.strftime('%Y/%m/%d %H:%M:%S', structtime_start)

webroot/AutoSa/AutoSa/views.py

@@ -21,7 +21,10 @@ import paramiko
 from django.core.servers.basehttp import FileWrapper
 from AutoSa.settings import CONF_DIR
 from django.core.paginator import Paginator, InvalidPage, EmptyPage
-import time, datetime
+import time
+import datetime
+from django_websocket import require_websocket
+from django_websocket import accept_websocket
 
 
 cf = ConfigParser.ConfigParser()
@@ -1001,6 +1004,23 @@ def killSession(request):
             return HttpResponse('ok')
 
 
+@require_websocket
+def echo(request):
+    f = open('/tmp/websocket.log')
+    message = f.read()
+    request.websocket.send(message)
+
+
+
+@accept_websocket
+def lower_case(request):
+    f = open('/tmp/websocket.log')
+    while True:
+        message = f.read()
+        request.websocket.send(message)
+        time.sleep(5)
+
+