feat: did not fix the bug...

coco/httpd.py

@@ -64,7 +64,6 @@ class ProxyNamespace(BaseNamespace):
             "room": room,
             "proxy": dict(),
             "client": dict(),
-            "thread": dict(),
             "forwarder": dict(),
             "request": self.make_coco_request()
         }
@@ -152,7 +151,7 @@ class ProxyNamespace(BaseNamespace):
         self.clients[request.sid]["forwarder"][connection] = ProxyServer(
             self.app, self.clients[request.sid]["client"][connection]
         )
-        self.clients[request.sid]["thread"][connection] = self.socketio.start_background_task(
+        self.socketio.start_background_task(
             self.clients[request.sid]["forwarder"][connection].proxy,
             asset, system_user
         )
@@ -232,9 +231,6 @@ class ProxyNamespace(BaseNamespace):
                 del self.clients[request.sid]["forwarder"][connection]
             if connection in self.clients[request.sid]["client"].keys():
                 del self.clients[request.sid]["client"][connection]
-            if connection in self.clients[request.sid]["thread"].keys():
-                logger.debug("thread close", connection)
-                self.clients[request.sid]["thread"][connection].stop()
 
 
 class HttpServer:
@@ -261,7 +257,6 @@ class HttpServer:
     def run(self):
         host = self.flask_app.config["BIND_HOST"]
         port = self.flask_app.config["HTTPD_PORT"]
-        print('Starting websocket server at {}:{}'.format(host, port))
         self.socket_io.init_app(self.flask_app, async_mode=self.async_mode)
         self.socket_io.run(self.flask_app, port=port, host=host, debug=False)
 

coco/interactive.py

@@ -129,7 +129,6 @@ class InteractiveServer:
                 input_data.append(data)
 
     def dispatch(self, opt):
-        print(repr(opt))
         if opt is None:
             return self._sentinel
         elif opt.startswith("/"):

coco/recorder.py

@@ -255,6 +255,7 @@ class S3ReplayRecorder(ServerReplayRecorder):
             self.s3 = boto3.client('s3')
 
     def push_to_server(self, session_id):
+        logger.debug("push to server")
         try:
             self.s3.upload_file(
                 os.path.join(self.app.config['LOG_DIR'], session_id + '.replay.gz'),