重构了基于websocket的SSH终端连接方案

Merge branch 'test'

Html/apps/extension_ase/ase_client/manager.py

@@ -35,7 +35,6 @@ class ChatManager:
     _lock = threading.RLock()
     def __init__(self, restart=False):
         self.restart = restart
-        self.chapter_chain_now = -1
         self.ase_client = None
         self.app = None
         self.socketio = None
@@ -70,6 +69,9 @@ class ChatManager:
         self.chapter_chain = load_chapters(raw_markdown, raw_markdown_prompts, raw_score_prompts)
         self.bb = None 
         self.chat_historys = []
+        self.chapter_chain_now = 0
+        self.scores = []
+
 
 
     def send_to_vscode(self, event: str, data: dict, room: str = None, namespace: str = '/vscode'):

Html/apps/services/asectrl_service.py

@@ -33,10 +33,15 @@ def on_connect_to_ase(client, entry, init_data, **kwargs):
     namespace_entry.emit('message', "Agents服务已连接, 加载教案中", room=init_data['room'], namespace='/agent')
         
     restart = init_data.get("restart", False)
-    if restart: # 重启时，从-1章进入 0章
+    # 不再需要手动next_chapter，因为已经在on_login中根据mongo进度恢复了正确的章节
-        ase_client.chatmanager.next_chapter()
+    # if restart: # 重启时，从-1章进入 0章
+    #     ase_client.chatmanager.next_chapter()
+    
+    # 根据restart决定是否重新加载代码
     ase_client.chatmanager.load_now_chapter(load_code=restart)
     print("load_now_chapter with restart:", restart)
+    
+    # 只有当需要restart时才发送chapter-start
     if restart: 
         ase_client.send_text("chapter-start", "")
     namespace_entry.emit('message', "教案加载完毕", room=init_data['room'], namespace='/agent')

Html/apps/sockets/namespaces.py

@@ -72,38 +72,39 @@ class AgentNamespace(Namespace):
             course_id: 课程ID
             chapter_name: 章节名称
             lesson_name: 课时名称
-            continue_learn: 是否继续学习
+            continue_learn: 是否继续学习（现在总是为True，保持兼容性）
             
         Returns:
             int: 需要跳过的章节数
         """
-        need_skip_chapters = 0
+        # 总是从mongo加载学习进度
+        progress_result = load_learning_progress(user_id, course_id, chapter_name, lesson_name)
         
-        if continue_learn:  # 尝试加载用户学习进度
+        if progress_result['exists']:
-            progress_result = load_learning_progress(user_id, course_id, chapter_name, lesson_name)
+            progress = progress_result['data']
+            # 恢复学习进度数据
+            if 'scores' in progress:
+                chatmanager.scores = progress['scores']
             
-            if progress_result['exists']:
+            # 恢复聊天历史
-                progress = progress_result['data']
+            if 'chat_historys' in progress:
-                # 恢复学习进度数据
+                chatmanager.chat_historys = progress['chat_historys']
-                if 'scores' in progress:
-                    # 根据scores的数量确定需要跳过的章节数
-                    need_skip_chapters = len(progress['scores'])
-                    chatmanager.scores = progress['scores']
-                
-                # 恢复聊天历史
-                if 'chat_historys' in progress:
-                    chatmanager.chat_historys = progress['chat_historys']
-                else:
-                    chatmanager.chat_historys = []
-                
-                # 恢复当前章节链
-                if 'chapter_chain_now' in progress:
-                    chatmanager.chapter_chain_now = progress['chapter_chain_now']
-                upload_learning_progress_to_cloud(progress)
             else:
-                # 使用默认值，确保有完整的结构
+                chatmanager.chat_historys = []
-                chatmanager.chat_historys = progress_result['data']['chat_historys']
+            
-                chatmanager.scores = progress_result['data']['scores']
+            # 恢复当前章节链
+            if 'chapter_chain_now' in progress:
+                chatmanager.chapter_chain_now = progress['chapter_chain_now']
+            upload_learning_progress_to_cloud(progress)
+            
+            # 计算需要跳过的章节数：从初始的-1到当前的chapter_chain_now
+            need_skip_chapters = chatmanager.chapter_chain_now 
+        else:
+            # 使用默认值，确保有完整的结构
+            chatmanager.chat_historys = progress_result['data']['chat_historys']
+            chatmanager.scores = progress_result['data']['scores']
+            chatmanager.chapter_chain_now = 0
+            need_skip_chapters = 0
         
         return need_skip_chapters
     
@@ -131,8 +132,9 @@ class AgentNamespace(Namespace):
         chatmanager.function_manager.add_function(next_chapter, {'user_uuid': user_uuid})
 
         clear_user_session(current_app.config["ASE_ENGINE_URL"], current_app.config["ASE_ENGINE_URL_TOKEN"], user_id)
-        continue_learn = not chatmanager.restart
+        
-        need_skip_chapters = self._load_learning_progress(chatmanager, user_id, course_id, chapter_name, lesson_name, continue_learn)
+        # 总是从mongo加载进度，不管restart状态
+        need_skip_chapters = self._load_learning_progress(chatmanager, user_id, course_id, chapter_name, lesson_name, True)
 
         fmd,fmdp,fsp = load_full_markdown_file(course_id, chapter_name, lesson_name)
         user_uuid2ase_client[user_uuid] = HSAEngineClient(current_app.config["ASE_ENGINE_URL"], current_app.config["ASE_ENGINE_NAMESPACE"],id=user_id, chatmanager = chatmanager)
@@ -141,21 +143,26 @@ class AgentNamespace(Namespace):
         backboard_manager.add_backboard(user_uuid, user_id, course_id,
                                          lesson_name, root_path=f'/home/{user_id}/{course_id}/{chapter_name}/{lesson_name}')
         chatmanager.bb = backboard_manager.get_backboard(user_uuid)
-        # 如果有保存的进度，需要跳过已经完成的章节、无需清空代码、对话历史恢复
+        
-        if continue_learn:
+        # 总是根据进度跳过章节，恢复对话历史
-            for _ in range(need_skip_chapters):
+        for _ in range(need_skip_chapters):
-                chatmanager.next_chapter()
+            chatmanager.next_chapter()
-                emit('next_chapter', room=user_uuid, namespace='/agent')
+            emit('next_chapter', room=user_uuid, namespace='/agent')
-            # 恢复对话历史到前端 - 使用批量发送消息列表
+        # 恢复对话历史到前端 - 使用批量发送消息列表
-            if chatmanager.chat_historys:
+        if chatmanager.chat_historys:
-                emit('messages', chatmanager.chat_historys, room=user_uuid, namespace='/agent')
+            emit('messages', chatmanager.chat_historys, room=user_uuid, namespace='/agent')
         
         self.chatmanager = chatmanager
         self.ase_client = user_uuid2ase_client[user_uuid]
+        
+        # 将restart设置为False，避免后续重复处理
+        restart = chatmanager.restart
+        chatmanager.restart = False
+        
         user_uuid2ase_client[user_uuid].register_on_connect_entry(
             callback=on_connect_to_ase,
             entry=(self, user_uuid2ase_client[user_uuid]),
-            init_data={'room':user_uuid, 'restart':chatmanager.restart}
+            init_data={'room':user_uuid, 'restart':restart}
         )
         user_uuid2ase_client[user_uuid].register_route_with_entry(
                                             route='dialog',

Html/apps/static/js/chatbox.js

@@ -90,7 +90,7 @@ document.addEventListener('DOMContentLoaded', function () {
     socket.on('voiceMessage', function (data) {
         console.log(data);
         const input =  document.getElementById('messageInput');
-        input.value += data;
+        input.value = data;
     });
     socket.on('message', function (data) {
         // 显示服务器的回复消息 - 单个消息

Html/apps/static/js/index.js

@@ -1,41 +1,53 @@
-function show_books(courses_data, user_selected_courses){
+function show_books(courses_data, user_selected_courses) {
     console.log(courses_data)
     console.log(user_selected_courses)
 }
-function show_course_details(course_id){
+function show_course_details(course_id) {
-    window.location.href = '/course/' + course_id 
+    window.location.href = '/course/' + course_id
 }
 
-function on_click_select_course(event){
+function on_click_select_course(event) {
     event.stopPropagation(); // 阻止事件冒泡
-    const courseId = event.currentTarget.getAttribute('data-course-id');
+    const button = event.currentTarget;
-    if (event.currentTarget.classList.contains("selected-button")) {alert('课程已选择'); return;}
+    const courseId = button.getAttribute('data-course-id');
+    if (!courseId) { alert('缺少课程ID'); return; }
+    if (button.classList.contains("selected-button")) { alert('课程已选择'); return; }
+    if (button.disabled) { return; }
+    button.disabled = true;
     fetch(`/select_course`, {
         method: 'POST',
         headers: {
             'Content-Type': 'application/json',
-            'X-CSRFToken': '{{ csrf_token() }}' // 如果使用 CSRF 保护
         },
         body: JSON.stringify({ course_id: courseId })
     })
-    .then(response => response.json())
+        .then(async (response) => {
-    .then(data => {
+            let data = null;
-        if (data.success) {
+            try {
-            // 更新按钮样式或显示消息
+                data = await response.json();
-            this.classList.remove('select-button');
+            } catch (_) {
-            this.classList.add('selected-button');
+            }
-            this.textContent = '已选择';
+            if (!response.ok) {
+                throw new Error(data?.message || `请求失败(${response.status})`);
+            }
+            return data;
+        })
+        .then((data) => {
+            if (!data?.success) {
+                throw new Error(data?.message || '选择课程失败');
+            }
+            button.classList.remove('select-button');
+            button.classList.add('selected-button');
+            button.textContent = '已选课';
             alert('选择课程成功');
-        } else {
+        })
-            alert('选择课程失败');
+        .catch(error => {
-        }
+            console.error('Error:', error);
-    })
+            alert(error?.message || '选择课程失败');
-    .catch(error => {
+            button.disabled = false;
-        console.error('Error:', error);
+        });
-        alert('选择课程失败');
-    });
 }
 
-document.addEventListener('DOMContentLoaded', function() {
+document.addEventListener('DOMContentLoaded', function () {
 
-});
+});

Html/apps/templates/dashboard.html

@@ -4,6 +4,7 @@
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
     <title>华实学伴 - 专业的在线学习平台</title>
+    <script src="/static/cdnback/jquery.min.js"></script>
     <link href="/static/cdnback/bootstrap.min.css" rel="stylesheet">
     <link rel="stylesheet" href="/static/cdnback/all.min.css">
     <link rel="stylesheet" href="/static/css/dashboard.css">

Html/apps/templates/index.html

@@ -1,8 +1,9 @@
 <!DOCTYPE html>
 <html lang="zh">
+
 <head>
-  <meta charset="UTF-8">
+    <meta charset="UTF-8">
-  <title>课程选择主页</title>
+    <title>课程选择主页</title>
     <script src="/static/cdnback/jquery.min.js"></script>
 
     <link href="/static/cdnback/bootstrap.min.css" rel="stylesheet">
@@ -12,6 +13,7 @@
     <script src="/static/cdnback/js/bootstrap.bundle.min.js"></script>
     <link rel="stylesheet" href="/static/css/index.css">
 </head>
+
 <body>
     {% include 'navbar.html' %}
 
@@ -38,7 +40,7 @@
             <h2>课程列表</h2>
             <div class="course-cards" id="course-cards">
                 {% for course in courses_data %}
-                            <!-- <div class="course-card" onclick="show_course_details('{{ course._id }}')">
+                <!-- <div class="course-card" onclick="show_course_details('{{ course._id }}')">
                                 <img src="{{ course.image_url }}" alt="{{ course.course_name }}">
                                 <h3>{{ course.name }}</h3>
                                 <p>{{ course.description }}</p>
@@ -49,10 +51,9 @@
                                 {% endif %}
                             </div> -->
 
-                            <div class="col-md-6 col-lg-4">
+                <div class="col-md-6 col-lg-4">
                     <div class="course-card card h-100" onclick="openCourseProgress('{{course._id}}')">
-                        <img src="{{course.image_url}}"
+                        <img src="{{course.image_url}}" class="course-img" alt="课程封面">
-                            class="course-img" alt="课程封面">
                         <div class="card-body d-flex flex-column">
                             <span class="course-category">算法设计</span>
                             <h5 class="course-title">{{course.name}}</h5>
@@ -62,11 +63,15 @@
                                 <span class="course-rating"><i class="fas fa-star"></i> 4.7</span>
                             </div>
                             <div class="mt-auto d-grid gap-2 d-md-flex">
-                                <button class="btn btn-view flex-fill" onclick="btn_view(event,'{{course._id}}')"><i class="far fa-eye me-1"></i> 课程</button>
+                                <button class="btn btn-view flex-fill" onclick="btn_view(event,'{{course._id}}')"><i
+                                        class="far fa-eye me-1"></i> 课程</button>
                                 {% if course._id in selected_courses %}
-                                    <button class="btn btn-process flex-fill selected-button"  data-course-id="{{course._id}}">已选课</button>
+                                <button class="btn btn-process flex-fill selected-button"
+                                    data-course-id="{{course._id}}">已选课</button>
                                 {% else %}
-                                    <button class="btn btn-process flex-fill select-button" onclick="on_click_select_course(event)" data-course-id="{{course._id}}">选择课程</button>
+                                <button class="btn btn-process flex-fill select-button"
+                                    onclick="on_click_select_course(event)"
+                                    data-course-id="{{course._id}}">选择课程</button>
                                 {% endif %}
 
                             </div>
@@ -74,13 +79,13 @@
                     </div>
                 </div>
                 {% endfor %}
-                
+
             </div>
         </div>
     </main>
 
 
-  {% include 'footer-brief.html' %}
+    {% include 'footer-brief.html' %}
 </body>
 <script>
     window.appData = {
@@ -88,5 +93,6 @@
     }
 </script>
 <script src="/static/js/index.js"></script>
-</html>
+<script src="/static/js/dashboard.js"></script>
 
+</html>

Html/apps/views/vscode.py

@@ -69,8 +69,23 @@ def desktop(user_uuid, course_id, chapter_name, lesson_name):
 
 
 
-    chatmanager = ChatManager(restart=not load_history)
+    restart = not load_history
+    chatmanager = ChatManager(restart=restart)
     current_app.extensions["user_uuid2chatmanager"][user_uuid] = chatmanager
+    
+    # 如果restart为True，删除mongo中的学习进度
+    if restart:
+        try:
+            mongo = current_app.extensions["mongo"]
+            mongo.db.learning_progress.delete_one({
+                "user_id": user_id,
+                "material_id": course_id,
+                "chapter_name": chapter_name,
+                "lesson_name": lesson_name
+            })
+            current_app.logger.info(f"删除学习进度成功: user_id={user_id}, course_id={course_id}, chapter={chapter_name}, lesson={lesson_name}")
+        except Exception as e:
+            current_app.logger.error(f"删除学习进度失败: {str(e)}")
     code_server_port = 10000 + int(uuid.uuid4().int % 10000)
     # chatmanager.start_code_server(user_uuid, user_id, path_dir, code_server_port)
     

Html/config.ini

@@ -5,7 +5,7 @@ api_key = sk-aMpnWklN2IbsK44d1kNpy6YOP9bk1pdPJjFeEmbb0a5ytEFf
 model=gpt-4.1-nano
 
 [VSCODE_WEB]
-url = https://hsamooc.cn
+url = https://hsamooc.com
 [CODE_LIKE]
 url = /vsc-like
 #http://asengine.net:8282
@@ -27,6 +27,6 @@ bucket = hsamooc-cdn-1374354408
 region = ap-guangzhou
 
 [ASE_ENGINE]
-url = https://test.asengine.net
+url = https://asengine.net
-namespace = /socket.io/7100eebf7a909e1ee3f4e06766f512f0358ecb6ac51d5434c17d31dd70890dc1
+namespace = /socket.io/afe58a9e4c03e10fae6fae5985e8adde23a49635
-url_token = 7100eebf7a909e1ee3f4e06766f512f0358ecb6ac51d5434c17d31dd70890dc1
+url_token = afe58a9e4c03e10fae6fae5985e8adde23a49635

Html/db/data/user/_10235101560.json

@@ -0,0 +1 @@
+{"username": "_10235101560"}

Html/db/data/user/shanks.json

@@ -0,0 +1 @@
+{"username": "shanks"}

Html/db/data/user/ts88.json

@@ -0,0 +1 @@
+{"username": "ts88"}

Html/db/data/user/xuans.json

@@ -0,0 +1 @@
+{"username": "xuans"}

Html/db/data/user/xuans_.json

@@ -0,0 +1 @@
+{"username": "xuans_"}

code-server-like/app/__init__.py

@@ -1,5 +1,210 @@
 import eventlet
-eventlet.monkey_patch()  # 进行猴子补丁操作
+import logging
+
+# 配置 eventlet 日志，抑制 IOClosed 等错误日志
+logging.getLogger('eventlet.hubs').setLevel(logging.CRITICAL)
+logging.getLogger('eventlet.greenio').setLevel(logging.CRITICAL)
+
+# 进行猴子补丁操作
+eventlet.monkey_patch()
+
+# 配置 eventlet 以更优雅地处理错误，避免疯狂报错
+try:
+    import eventlet
+    import traceback
+    
+    # 1. 首先，禁用 eventlet 的调试日志，减少输出
+    import logging
+    logging.getLogger('eventlet').setLevel(logging.CRITICAL)
+    logging.getLogger('socketio').setLevel(logging.CRITICAL)
+    logging.getLogger('werkzeug').setLevel(logging.CRITICAL)
+    
+    # 2. 配置 eventlet 相关设置（移除了不存在的debug属性）
+    
+    # 3. 避免重复打印相同错误的机制
+    seen_errors = set()
+    max_error_logs = 5  # 每个错误最多打印5次
+    error_counts = {}
+    
+    def is_duplicate_error(e):
+        """检查是否为重复错误"""
+        error_key = f"{type(e).__name__}: {e}"
+        if error_key in seen_errors:
+            error_counts[error_key] = error_counts.get(error_key, 0) + 1
+            if error_counts[error_key] > max_error_logs:
+                return True
+        else:
+            seen_errors.add(error_key)
+            error_counts[error_key] = 1
+        return False
+    
+    # 4. 只修改关键的 greenio 方法，确保在致命错误时彻底关闭连接
+    # 增强 socketio 错误处理，确保不会因为单个连接错误而宕机
+    try:
+        from flask_socketio import SocketIO
+        # 获取当前 socketio 实例并配置错误处理
+        import sys
+        original_excepthook = sys.excepthook
+        
+        def custom_excepthook(exc_type, exc_value, exc_traceback):
+            """全局异常钩子，捕获所有未处理的异常"""
+            error_str = str(exc_value)
+            if exc_type.__name__ in ['OSError', 'IOError'] and any(msg in error_str for msg in ['Bad file descriptor', 'Socket operation on non-socket', 'Operation on closed file']):
+                # 处理各种socket错误，不导致服务器宕机
+                if not is_duplicate_error(exc_value):
+                    print(f"[Global Error Handler] {exc_type.__name__}: {exc_value}")
+                    print("[Traceback]")
+                    traceback.print_exception(exc_type, exc_value, exc_traceback)
+                # 不调用原始的 excepthook，防止服务器宕机
+                return
+            # 其他异常调用原始的 excepthook
+            original_excepthook(exc_type, exc_value, exc_traceback)
+        
+        # 设置全局异常钩子
+        sys.excepthook = custom_excepthook
+    except Exception as e:
+        # 如果修改失败，忽略错误
+        print(f"[Global Excepthook Patch Error] {e}")
+    from eventlet import greenio
+    
+    # 保存并替换原始的 greenio 方法
+    if hasattr(greenio.base.GreenSocket, '_recv_loop'):
+        original_recv_loop = greenio.base.GreenSocket._recv_loop
+        
+        def custom_recv_loop(self, recv_func, recv_args, *args, **kwargs):
+            try:
+                return original_recv_loop(self, recv_func, recv_args, *args, **kwargs)
+            except Exception as e:
+                if not is_duplicate_error(e):
+                    print(f"[Eventlet IO Error] _recv_loop: {type(e).__name__}: {e}")
+                    print("[Traceback]")
+                    traceback.print_exc()
+                # 彻底关闭连接，不再继续处理
+                try:
+                    self.close()
+                except Exception:
+                    pass
+                return b''
+        
+        greenio.base.GreenSocket._recv_loop = custom_recv_loop
+    
+    if hasattr(greenio.base.GreenSocket, 'recv_into'):
+        original_recv_into = greenio.base.GreenSocket.recv_into
+        
+        def custom_recv_into(self, buffer, nbytes=0, flags=0):
+            try:
+                return original_recv_into(self, buffer, nbytes, flags)
+            except Exception as e:
+                if not is_duplicate_error(e):
+                    print(f"[Eventlet IO Error] recv_into: {type(e).__name__}: {e}")
+                    print("[Traceback]")
+                    traceback.print_exc()
+                # 彻底关闭连接，不再继续处理
+                try:
+                    self.close()
+                except Exception:
+                    pass
+                return 0
+        
+        greenio.base.GreenSocket.recv_into = custom_recv_into
+    
+    if hasattr(greenio.base.GreenSocket, '_send_loop'):
+        original_send_loop = greenio.base.GreenSocket._send_loop
+        
+        def custom_send_loop(self, send_func, data, *args, **kwargs):
+            try:
+                return original_send_loop(self, send_func, data, *args, **kwargs)
+            except Exception as e:
+                if not is_duplicate_error(e):
+                    print(f"[Eventlet IO Error] _send_loop: {type(e).__name__}: {e}")
+                    print("[Traceback]")
+                    traceback.print_exc()
+                # 彻底关闭连接，不再继续处理
+                try:
+                    self.close()
+                except Exception:
+                    pass
+                return 0
+        
+        greenio.base.GreenSocket._send_loop = custom_send_loop
+    
+    if hasattr(greenio.base.GreenSocket, 'send'):
+        original_send = greenio.base.GreenSocket.send
+        
+        def custom_send(self, data, flags=0):
+            try:
+                return original_send(self, data, flags)
+            except Exception as e:
+                if not is_duplicate_error(e):
+                    print(f"[Eventlet IO Error] send: {type(e).__name__}: {e}")
+                    print("[Traceback]")
+                    traceback.print_exc()
+                # 彻底关闭连接，不再继续处理
+                try:
+                    self.close()
+                except Exception:
+                    pass
+                return 0
+        
+        greenio.base.GreenSocket.send = custom_send
+    
+    # 5. 处理 WSGI 中的错误，确保彻底清理
+    try:
+        import eventlet.wsgi
+        
+        if hasattr(eventlet.wsgi.HttpProtocol, 'handle_one_request'):
+            original_wsgi_handle_one_request = eventlet.wsgi.HttpProtocol.handle_one_request
+            
+            def custom_wsgi_handle_one_request(self):
+                try:
+                    return original_wsgi_handle_one_request(self)
+                except Exception as e:
+                    if not is_duplicate_error(e):
+                        print(f"[Eventlet WSGI Request Error] {type(e).__name__}: {e}")
+                        print("[Traceback]")
+                        traceback.print_exc()
+                    # 彻底清理连接，不再继续
+                    try:
+                        self.rfile.close()
+                        self.wfile.close()
+                        self.finish()
+                    except Exception:
+                        pass
+                    return
+            
+            eventlet.wsgi.HttpProtocol.handle_one_request = custom_wsgi_handle_one_request
+        
+        if hasattr(eventlet.wsgi.HttpProtocol, 'handle_one_response'):
+            original_wsgi_handle_one_response = eventlet.wsgi.HttpProtocol.handle_one_response
+            
+            def custom_wsgi_handle_one_response(self):
+                try:
+                    return original_wsgi_handle_one_response(self)
+                except Exception as e:
+                    if not is_duplicate_error(e):
+                        print(f"[Eventlet WSGI Response Error] {type(e).__name__}: {e}")
+                        print("[Traceback]")
+                        traceback.print_exc()
+                    # 彻底清理连接，不再继续
+                    try:
+                        self.rfile.close()
+                        self.wfile.close()
+                        self.finish()
+                    except Exception:
+                        pass
+                    return
+            
+            eventlet.wsgi.HttpProtocol.handle_one_response = custom_wsgi_handle_one_response
+    except Exception as e:
+        # 如果修改失败，忽略错误
+        print(f"[WSGI Patch Error] {e}")
+    
+    print("[Eventlet Error Handling] Configured to handle errors gracefully, avoiding duplicate logs")
+except Exception as e:
+    # 如果修改失败，打印错误但继续运行
+    print(f"[Eventlet Patch Initialization Error] {e}")
+    traceback.print_exc()
+
 from flask import Flask
 from .views.routes import main_bp
 from .views.file import file_bp

code-server-like/app/config.py

@@ -13,4 +13,5 @@ class Config:
 
     # 自定义其他全局配置
     ROOT_WORKSPACE_PATH = GLOBAL_CONFIG['Global']['ROOT_WORKSPACE_PATH']
+    DEBUG = GLOBAL_CONFIG['Global'].getboolean('DEBUG', False)
 

code-server-like/app/sockets/terminal_service.py

@@ -14,6 +14,7 @@ import termios
 import struct
 import fcntl
 import psutil
+
 TERM_INIT_CONFIG = {
     # instead of local server runnning this web terminal service
     # "domain" is the target that you want to access through local server (with this web terminal)
@@ -24,147 +25,556 @@ TERM_INIT_CONFIG = {
         'ssh': '/usr/bin/ssh'
     }
 }
+
 terminal_bp = Blueprint('terminal', __name__, url_prefix='/vsc-like')
 
 
+class TerminalSessionManager:
+    """终端会话管理器，用于统一管理所有终端会话"""
+    def __init__(self):
+        # 存储所有终端会话，key为session_id，value为会话配置
+        self.sessions = {}
+        # 线程锁，保证多线程安全
+        self.lock = threading.Lock()
+        # 最大终端数量限制
+        self.max_terminals = 100
+        # 终端空闲超时时间（秒）
+        self.idle_timeout = 3600  # 1小时
+    
+    def create_session(self):
+        """创建新的终端会话"""
+        with self.lock:
+            # 检查是否达到最大终端数量
+            if len(self.sessions) >= self.max_terminals:
+                return None, "Maximum number of terminals reached"
+            
+            # 生成唯一的会话ID和房间ID
+            session_id = str(uuid.uuid4())
+            room_id = f"terminal_{session_id}"
+            
+            # 创建会话配置
+            session_config = {
+                **TERM_INIT_CONFIG.copy(),
+                'session_id': session_id,
+                'room_id': room_id,
+                'created_at': time.time(),
+                'last_activity': time.time()
+            }
+            
+            # 保存会话
+            self.sessions[session_id] = session_config
+            
+            return session_config, None
+    
+    def get_session(self, session_id):
+        """获取会话配置"""
+        with self.lock:
+            return self.sessions.get(session_id)
+    
+    def update_session(self, session_id, updates):
+        """更新会话配置"""
+        with self.lock:
+            if session_id not in self.sessions:
+                return False
+            
+            # 更新会话配置
+            self.sessions[session_id].update(updates)
+            # 更新最后活动时间
+            self.sessions[session_id]['last_activity'] = time.time()
+            
+            return True
+    
+    def delete_session(self, session_id):
+        """删除会话"""
+        with self.lock:
+            if session_id in self.sessions:
+                del self.sessions[session_id]
+                return True
+            return False
+    
+    def get_session_by_room_id(self, room_id):
+        """通过房间ID获取会话"""
+        with self.lock:
+            for session_config in self.sessions.values():
+                if session_config.get('room_id') == room_id:
+                    return session_config
+            return None
+    
+    def cleanup_inactive_sessions(self):
+        """清理不活动的会话"""
+        with self.lock:
+            current_time = time.time()
+            expired_sessions = []
+            
+            # 找出超时的会话
+            for session_id, session_config in self.sessions.items():
+                if current_time - session_config['last_activity'] > self.idle_timeout:
+                    expired_sessions.append(session_id)
+            
+            # 删除超时的会话
+            for session_id in expired_sessions:
+                del self.sessions[session_id]
+            
+            return expired_sessions
+    
+    def get_active_session_count(self):
+        """获取当前活动会话数量"""
+        with self.lock:
+            return len(self.sessions)
+
+
+# 创建全局终端会话管理器实例
+terminal_manager = TerminalSessionManager()
+
+
 
 def set_winsize(fd, row, col, xpix=0, ypix=0):
-    winsize = struct.pack("HHHH", row, col, xpix, ypix)
+    try:
-    fcntl.ioctl(fd, termios.TIOCSWINSZ, winsize)
+        winsize = struct.pack("HHHH", row, col, xpix, ypix)
+        fcntl.ioctl(fd, termios.TIOCSWINSZ, winsize)
+    except (OSError, IOError):
+        # File descriptor closed or invalid, do nothing
+        pass
 
 
-def read_and_forward_pty_output(fd=None, pid=None, room_id=None,namespace=None):
+def read_and_forward_pty_output(fd=None, pid=None, room_id=None, namespace=None):
     """
     read data on pty master from the pty slave, and emit to the web terminal visitor
     """
     max_read_bytes = 1024 * 20
-    timeout=0.1
+    # 初始超时时间设置为较短值，确保响应迅速
-    while True:
+    timeout = 0.05
-        socketio.sleep(timeout)
+    # 最大超时时间，避免太频繁的检查
-        timeout=min(timeout*2, 0.4)
+    max_timeout = 0.5
-        # using flask default web server, or uwsgi production web server
+    # 成功读取数据后的重置超时时间
-        # when the child process is terminated, it will not disappear from linux process list
+    reset_timeout = 0.05
-        # and keep staying as a zombie process until the parent exits.
+    
-        try:
+    try:
-            child_process = psutil.Process(pid)
+        while True:
-        except psutil.NoSuchProcess as err:
+            # 等待一段时间，减少CPU占用
-            return
+            socketio.sleep(timeout)
-        if child_process.status() not in ('running', 'sleeping'):
+            
-            return
+            # 使用指数退避算法调整超时时间，但不超过最大值
-        if fd:
+            timeout = min(timeout * 1.5, max_timeout)
-            timeout_sec = 0
+            
-            (data_ready, _, _) = select.select([fd], [], [], timeout_sec)
+            # 检查子进程状态
-            if data_ready:
+            try:
-                # output = os.read(fd, max_read_bytes).decode('ascii')
+                child_process = psutil.Process(pid)
-                timeout=0.1
+            except psutil.NoSuchProcess:
+                # 进程已终止，清理僵尸进程
                 try:
-                    output = os.read(fd, max_read_bytes).decode()
+                    os.waitpid(pid, os.WNOHANG)
-                except Exception as err:
+                except Exception:
-                    output = """
+                    pass
-                    ***AQUI WEB TERM ERR***
+                return
-                    {}
+            
-                    ***********************
+            # 检查进程状态，如果不是运行或睡眠状态，则退出
-                    """.format(err)
+            if child_process.status() not in ('running', 'sleeping'):
-                # the key for different visitor to get different terminal (instead of mixing up)
+                try:
-                # is to let the background task push pty response to each one's own (default) ROOM!
+                    # 等待进程终止
-                namespace.emit("pty_output", {"output": output}, room=room_id)
+                    child_process.wait(timeout=1)
+                except Exception:
+                    try:
+                        os.waitpid(pid, os.WNOHANG)
+                    except Exception:
+                        pass
+                return
+            
+            # 如果文件描述符有效，尝试读取数据
+            if fd:
+                try:
+                    # 使用非阻塞select检查是否有数据可读
+                    (data_ready, _, _) = select.select([fd], [], [], 0)
+                    if data_ready:
+                        # 有数据可读，重置超时时间
+                        timeout = reset_timeout
+                        try:
+                            # 读取数据
+                            output = os.read(fd, max_read_bytes).decode()
+                        except (OSError, IOError, EOFError):
+                            # 文件描述符已关闭或其他IO错误，优雅退出
+                            return
+                        except UnicodeDecodeError as err:
+                            # 处理编码错误
+                            output = f"""
+                            ***AQUI WEB TERM ERR***
+                            Unicode decode error: {err}
+                            ***********************
+                            """
+                        
+                        # 发送数据到客户端
+                        try:
+                            namespace.emit("pty_output", {"output": output}, room=room_id)
+                        except Exception:
+                            # 如果发送失败，客户端可能已断开连接，退出
+                            return
+                except (OSError, IOError):
+                    # 文件描述符无效，优雅退出
+                    return
+    except Exception as e:
+        # 捕获任何其他未预期的异常，防止服务器崩溃
+        current_app.logger.error(f"Unexpected error in read_and_forward_pty_output: {e}")
+    finally:
+        # 清理文件描述符
+        if fd:
+            try:
+                os.close(fd)
+            except Exception:
+                pass
 
 class VSCLikeNameSpace(Namespace):
-    def on_connect(self):
+    def __init__(self, namespace=None):
-        """new client connected"""
+        super().__init__(namespace)
-        if session.get('terminal_config', {}).get('child_pid', None):
+        # 存储客户端socket_id到session_id的映射
-            print(session['terminal_config']['child_pid'])
+        self.socket_session_map = {}
-            # already started child process, don't start another
+        # 线程锁，保证多线程安全
-            return
+        self.lock = threading.Lock()
-
+    
+    def create_terminal(self, session_id):
+        """创建新的终端并更新会话配置"""
+        # 获取会话配置
+        terminal_config = terminal_manager.get_session(session_id)
+        if not terminal_config:
+            current_app.logger.error(f"Session not found: {session_id}")
+            return None
+        
+        room_id = terminal_config['room_id']
+        current_app.logger.debug(f"Creating new terminal for room: {room_id}")
+        
         # create child process attached to a pty we can read from and write to
         (child_pid, fd) = pty.fork()
-        lesson_path = session.get('path')
         if child_pid == 0:
             # this is the child process fork.
             # anything printed here will show up in the pty, including the output
             # of this subprocess
-            # subprocess.run('bash')
+            try:
-            term_type = session.get('terminal_config').get('term_type')
+                # 获取终端配置
-            path = TERM_INIT_CONFIG.get('client_path', {}).get(term_type, None)
+                term_type = terminal_config.get('term_type')
-            if not path:
+                
-                print("Can't locate {} binary, exit".format(term_type))
+                if not term_type:
-                disconnect()
+                    print("Terminal type not specified, exit")
-            if term_type == 'telnet':
+                    os._exit(1)
-                # switch to the right location of your telnet binary (example comes from OSX which got telnet from brew)
+                
-                # or you can also make work like auto-detection, or manually but configurable
+                path = terminal_config.get('client_path', {}).get(term_type, None)
-                os.execl(path, 'telnet', '-l', session['terminal_config']['username'],
+                if not path or not os.path.exists(path):
-                        session['terminal_config']['domain'], '{}'.format(session['terminal_config']['port']))
+                    print(f"Can't locate {term_type} binary at {path}, exit")
-            elif term_type == 'ssh':
+                    os._exit(1)
-                os.execl(path,'ssh', '-p','22',
+                
-                        #'{}'.format(session['terminal_config']['port']),
+                # 获取连接参数
-                        '{}@{}'.format(session['terminal_config']['username'], session['terminal_config']['domain']))
+                username = terminal_config.get('username')
-                        
+                domain = terminal_config.get('domain')
-
+                port = terminal_config.get('port')
-            else:
+                
-                current_app.logger.debug("wrong term type {}".format(term_type))
+                if not username or not domain:
-                disconnect()
+                    print("Missing required connection parameters, exit")
-                session['terminal_config'] = TERM_INIT_CONFIG
+                    os._exit(1)
+                
+                if term_type == 'telnet':
+                    # 使用telnet连接
+                    if not port:
+                        print("Port not specified for telnet, exit")
+                        os._exit(1)
+                    os.execl(path, 'telnet', '-l', username, domain, str(port))
+                elif term_type == 'ssh':
+                    # 使用ssh连接
+                    ssh_port = port if port else 22  # 默认端口22
+                    os.execl(path, 'ssh', '-p', str(ssh_port), f'{username}@{domain}')
+                else:
+                    print(f"Wrong term type {term_type}, exit")
+                    os._exit(1)
+            except Exception as e:
+                print(f"Error in child process: {e}")
+                os._exit(1)
         else:
-            session['terminal_config']['fd'] = fd
+            # 更新会话配置，保存到终端管理器
-            session['terminal_config']['child_pid'] = child_pid
+            updates = {
-            session['terminal_config']['room_id'] = rooms()[0]
+                'fd': fd,
-            session.modified = True
+                'child_pid': child_pid
+            }
+            terminal_manager.update_session(session_id, updates)
+            
+            # 设置初始窗口大小
             set_winsize(fd, 50, 50)
-            current_app.logger.debug("child pid = {}".format(child_pid))
+            
-            current_app.logger.debug("rooms of this session = {}".format(rooms()))
+            # 记录日志
-            socketio.start_background_task(read_and_forward_pty_output, fd, child_pid, rooms()[0],self)
+            current_app.logger.debug(f"Child process created: {child_pid} for room: {room_id}")
-            current_app.logger.debug("background task running")
+            
-            # print(session)
+            # 启动后台任务读取pty输出，传入正确的room_id
+            socketio.start_background_task(read_and_forward_pty_output, fd, child_pid, room_id, self)
+            current_app.logger.debug("Background task running")
+        
+        return terminal_config
+    
+    def on_connect(self):
+        """new client connected"""
+        # 创建新的终端会话
+        terminal_config, error = terminal_manager.create_session()
+        if not terminal_config:
+            current_app.logger.error(f"Failed to create terminal session: {error}")
+            return
+        
+        session_id = terminal_config['session_id']
+        room_id = terminal_config['room_id']
+        
+        # 加入房间
+        join_room(room_id)
+        
+        # 保存socket_id到session_id的映射
+        socket_id = request.sid
+        with self.lock:
+            self.socket_session_map[socket_id] = session_id
+        
+        current_app.logger.debug(f"Client connected, session_id: {session_id}, room_id: {room_id}, socket_id: {socket_id}")
+        
+        # 创建终端
+        self.create_terminal(session_id)
+        current_app.logger.debug("background task running")
 
     def on_pty_input(self, data):
         """write to the child pty, which now is the ssh process from this machine to the 'domain' configured
     """
-        print(f"get data {data}")
+        # 获取socket_id对应的session_id
+        socket_id = request.sid
+        with self.lock:
+            session_id = self.socket_session_map.get(socket_id)
+        
+        if not session_id:
+            current_app.logger.error(f"No session found for socket: {socket_id}")
+            return
+        
+        # 输入验证
+        if not isinstance(data, dict):
+            current_app.logger.error("Invalid input format: expected dictionary")
+            return
+        
+        input_data = data.get("input")
+        if not isinstance(input_data, str):
+            current_app.logger.error("Invalid input data: expected string")
+            return
+        
+        # 限制输入长度，防止缓冲区溢出
+        if len(input_data) > 1024:
+            input_data = input_data[:1024]
+            current_app.logger.warning("Input truncated due to length")
+        
         try:
-            child_process = psutil.Process(session.get('terminal_config').get('child_pid'))
+            terminal_config = terminal_manager.get_session(session_id)
-        except psutil.NoSuchProcess as err:
+            if not terminal_config:
-            disconnect()
+                current_app.logger.error(f"Session not found: {session_id}")
-            session['terminal_config'] = TERM_INIT_CONFIG
+                return
-            return
+            
-        if child_process.status() not in ('running', 'sleeping'):
+            child_pid = terminal_config.get('child_pid')
-            disconnect()
+            
-            session['terminal_config'] = TERM_INIT_CONFIG
+            # 如果没有子进程，重新创建终端
-            return
+            if not child_pid:
-        # print(session)
+                current_app.logger.debug(f"No child process found for session: {session_id}, creating new terminal")
-        # print(data, 'from input')
+                terminal_config = self.create_terminal(session_id)
-        fd = session.get('terminal_config').get('fd')
+                if not terminal_config:
-        if fd:
+                    current_app.logger.error(f"Failed to create new terminal for session: {session_id}")
-            # print("writing to ptd: %s" % data["input"])
+                    return
-            # os.write(fd, data["input"].encode('ascii'))
+                child_pid = terminal_config.get('child_pid')
-            os.write(fd, data["input"].encode())
+                if not child_pid:
+                    current_app.logger.error(f"Failed to get child_pid for session: {session_id}")
+                    return
+            
+            # 检查子进程是否存在且运行中
+            try:
+                child_process = psutil.Process(child_pid)
+                if child_process.status() not in ('running', 'sleeping'):
+                    current_app.logger.debug(f"Child process not running for session: {session_id}, creating new terminal")
+                    terminal_config = self.create_terminal(session_id)
+                    if not terminal_config:
+                        current_app.logger.error(f"Failed to create new terminal for session: {session_id}")
+                        return
+                    child_pid = terminal_config.get('child_pid')
+                    if not child_pid:
+                        current_app.logger.error(f"Failed to get child_pid for session: {session_id}")
+                        return
+            except psutil.NoSuchProcess:
+                current_app.logger.debug(f"Child process not found for session: {session_id}, creating new terminal")
+                terminal_config = self.create_terminal(session_id)
+                if not terminal_config:
+                    current_app.logger.error(f"Failed to create new terminal for session: {session_id}")
+                    return
+                child_pid = terminal_config.get('child_pid')
+                if not child_pid:
+                    current_app.logger.error(f"Failed to get child_pid for session: {session_id}")
+                    return
+            
+            # 获取文件描述符并写入数据
+            fd = terminal_config.get('fd')
+            if fd:
+                try:
+                    os.write(fd, input_data.encode())
+                except (OSError, IOError) as e:
+                    # File descriptor closed or invalid, create new terminal
+                    current_app.logger.debug(f"Error writing to file descriptor: {e}, creating new terminal for session: {session_id}")
+                    self.create_terminal(session_id)
+        except Exception as e:
+            current_app.logger.error(f"Error in pty_input handling: {e}")
+            # 发生异常时尝试重新创建终端
+            try:
+                self.create_terminal(session_id)
+            except Exception as create_err:
+                current_app.logger.error(f"Failed to recreate terminal: {create_err}")
 
     
     def on_resize(self, data):
+        # 获取socket_id对应的session_id
+        socket_id = request.sid
+        with self.lock:
+            session_id = self.socket_session_map.get(socket_id)
+        
+        if not session_id:
+            current_app.logger.error(f"No session found for socket: {socket_id}")
+            return
+        
+        # 输入验证
+        if not isinstance(data, dict):
+            current_app.logger.error("Invalid resize data format: expected dictionary")
+            return
+        
+        rows = data.get("rows")
+        cols = data.get("cols")
+        
+        # 验证行和列的值是否为正整数
+        if not (isinstance(rows, int) and isinstance(cols, int)):
+            current_app.logger.error("Invalid resize dimensions: expected integers")
+            return
+        
+        # 限制窗口大小范围，防止异常值
+        if rows <= 0 or rows > 1000 or cols <= 0 or cols > 1000:
+            current_app.logger.error(f"Invalid resize dimensions: {rows}x{cols} (out of range)")
+            return
+        
         try:
-            child_process = psutil.Process(session.get('terminal_config').get('child_pid'))
+            terminal_config = terminal_manager.get_session(session_id)
-        except psutil.NoSuchProcess as err:
+            if not terminal_config:
-            disconnect()
+                current_app.logger.error(f"Session not found: {session_id}")
-            session['terminal_config'] = TERM_INIT_CONFIG
+                return
-            return
+            
-        if child_process.status() not in ('running', 'sleeping'):
+            child_pid = terminal_config.get('child_pid')
-            disconnect()
+            
-            session['terminal_config'] = TERM_INIT_CONFIG
+            # 如果没有子进程，重新创建终端
-            return
+            if not child_pid:
-        fd = session.get('terminal_config').get('fd')
+                current_app.logger.debug(f"No child process found for resize, creating new terminal for session: {session_id}")
-        if fd:
+                terminal_config = self.create_terminal(session_id)
-            set_winsize(fd, data["rows"], data["cols"])
+                if not terminal_config:
+                    current_app.logger.error(f"Failed to create new terminal for resize, session: {session_id}")
+                    return
+                child_pid = terminal_config.get('child_pid')
+                if not child_pid:
+                    current_app.logger.error(f"Failed to get child_pid for resize, session: {session_id}")
+                    return
+            
+            # 检查子进程是否存在且运行中
+            try:
+                child_process = psutil.Process(child_pid)
+                if child_process.status() not in ('running', 'sleeping'):
+                    current_app.logger.debug(f"Child process not running for resize, creating new terminal for session: {session_id}")
+                    terminal_config = self.create_terminal(session_id)
+                    if not terminal_config:
+                        current_app.logger.error(f"Failed to create new terminal for resize, session: {session_id}")
+                        return
+                    child_pid = terminal_config.get('child_pid')
+                    if not child_pid:
+                        current_app.logger.error(f"Failed to get child_pid for resize, session: {session_id}")
+                        return
+            except psutil.NoSuchProcess:
+                current_app.logger.debug(f"Child process not found for resize, creating new terminal for session: {session_id}")
+                terminal_config = self.create_terminal(session_id)
+                if not terminal_config:
+                    current_app.logger.error(f"Failed to create new terminal for resize, session: {session_id}")
+                    return
+                child_pid = terminal_config.get('child_pid')
+                if not child_pid:
+                    current_app.logger.error(f"Failed to get child_pid for resize, session: {session_id}")
+                    return
+            
+            # 获取文件描述符并调整窗口大小
+            fd = terminal_config.get('fd')
+            if fd:
+                try:
+                    os.fstat(fd)
+                    set_winsize(fd, rows, cols)
+                except (OSError, IOError) as e:
+                    # 文件描述符无效，创建新终端
+                    current_app.logger.debug(f"Error resizing terminal: {e}, creating new terminal for session: {session_id}")
+                    self.create_terminal(session_id)
+        except Exception as e:
+            current_app.logger.error(f"Error in resize handling: {e}")
+            # 发生异常时尝试重新创建终端
+            try:
+                self.create_terminal(session_id)
+            except Exception as create_err:
+                current_app.logger.error(f"Failed to recreate terminal for resize: {create_err}")
 
     def on_disconnect(self):
-        try:
+        # 获取socket_id对应的session_id
-            child_process = psutil.Process(session.get('terminal_config', {}).get('child_pid'))
+        socket_id = request.sid
-        except psutil.NoSuchProcess as err:
+        with self.lock:
-            disconnect()
+            session_id = self.socket_session_map.pop(socket_id, None)
-            session['terminal_config'] = TERM_INIT_CONFIG
+        
+        if not session_id:
+            current_app.logger.error(f"No session found for socket: {socket_id}")
             return
-        if child_process.status() in ('running', 'sleeping'):
+        
-            # if visitor just close the browser tab then left alone the pty here
+        # 获取会话配置
-            # it should be terminated by the parent process after
+        terminal_config = terminal_manager.get_session(session_id)
-            child_process.terminate()
+        if not terminal_config:
-            current_app.logger.debug('user left the pty alone, terminated')
+            current_app.logger.error(f"Session not found: {session_id}")
+            return
+        
+        child_pid = terminal_config.get('child_pid')
+        fd = terminal_config.get('fd')
+        room_id = terminal_config.get('room_id')
+        
+        current_app.logger.debug(f"Client disconnecting, session_id: {session_id}, room_id: {room_id}, socket_id: {socket_id}")
+        
+        # 退出房间
+        if room_id:
+            leave_room(room_id)
+            current_app.logger.debug(f"Client left room: {room_id}")
+        
+        # 先关闭文件描述符，避免其他操作尝试使用无效的文件描述符
+        if fd:
+            try:
+                os.close(fd)
+                current_app.logger.debug(f"Closed file descriptor: {fd}")
+            except Exception as e:
+                current_app.logger.debug(f"Error closing file descriptor: {e}")
+        
+        if child_pid:
+            try:
+                child_process = psutil.Process(child_pid)
+                if child_process.status() in ('running', 'sleeping'):
+                    # if visitor just close the browser tab then left alone the pty here
+                    # it should be terminated by the parent process after
+                    child_process.terminate()
+                    # Wait for the process to terminate and collect its exit status
+                    child_process.wait(timeout=2)
+                    current_app.logger.debug(f'User left pty alone, terminated and waited: {child_pid}')
+            except psutil.NoSuchProcess:
+                # Process already terminated, try to wait anyway to clean up any zombie
+                try:
+                    os.waitpid(child_pid, os.WNOHANG)
+                    current_app.logger.debug(f'Cleaned up zombie process: {child_pid}')
+                except Exception as e:
+                    current_app.logger.debug(f"Error cleaning up zombie process: {e}")
+            except psutil.TimeoutExpired:
+                # If process didn't terminate in time, kill it forcefully
+                try:
+                    child_process.kill()
+                    child_process.wait(timeout=1)
+                    current_app.logger.debug(f'Forcefully killed process: {child_pid}')
+                except Exception as e:
+                    current_app.logger.debug(f"Error forcefully killing process: {e}")
+            except Exception as err:
+                current_app.logger.error(f'Error terminating process: {err}')
+        
+        # 从终端管理器中删除会话
+        terminal_manager.delete_session(session_id)
+        current_app.logger.debug(f"Session deleted: {session_id}")
+        
+        current_app.logger.debug(f"Client disconnected, session_id: {session_id}, room_id: {room_id}")
         current_app.logger.debug('Client disconnected')

code-server-like/app/views/routes.py

@@ -1,5 +1,5 @@
 import os
-import subprocess
+from eventlet.green import subprocess
 from flask import Blueprint, request, jsonify, current_app, render_template, session
 from ..services.file_service import get_file_tree, load_config
 
@@ -42,32 +42,34 @@ def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name, port):
         subprocess.run(["sudo", "chown", "-R", user_id, user_root])  # 设置目录权限为新用户
         
     except subprocess.CalledProcessError as e:
-        print(f"Error creating user {user_id}: {e}")
+        # 用户可能已经存在，这是正常情况，继续执行
+        print(f"Useradd command returned non-zero exit status, this is expected if user already exists: {e}")
     try:
         # 使用 sudo 执行 mkdir 命令来创建目录
-        subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", path], check=True)
+        subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", path], check=current_app.config['DEBUG'])
-        subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", f'{user_root}/.ssh'], check=True)
+        subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", f'{user_root}/.ssh'], check=current_app.config['DEBUG'])
         flask_pub_key = "/home/flask/.ssh/id_ed25519.pub"
-        subprocess.run(["sudo", "cp", flask_pub_key, f"{user_root}/.ssh/authorized_keys"], check=True)
+        subprocess.run(["sudo", "cp", flask_pub_key, f"{user_root}/.ssh/authorized_keys"], check=current_app.config['DEBUG'])
-        subprocess.run(["sudo", "chmod", "700", f"{user_root}/.ssh"], check=True)
+        subprocess.run(["sudo", "chmod", "700", f"{user_root}/.ssh"], check=current_app.config['DEBUG'])
-        subprocess.run(["sudo", "chmod", "600", f"{user_root}/.ssh/authorized_keys"], check=True)
+        subprocess.run(["sudo", "chmod", "600", f"{user_root}/.ssh/authorized_keys"], check=current_app.config['DEBUG'])
         print(f"Directory {path} created successfully for user {user_id}")
     except subprocess.CalledProcessError as e:
         print(f"Error creating directory {path} details {str(e)}")
     try:#使用sudo创建shared_group
-        subprocess.run(["sudo", "groupadd", f"shared_group_{user_id}"], check=True)
+        subprocess.run(["sudo", "groupadd", f"shared_group_{user_id}"], check=current_app.config['DEBUG'])
     except subprocess.CalledProcessError as e:
-        print(f"Error creating shared_group: {e}")
+        # 组可能已经存在，这是正常情况，继续执行
+        print(f"Groupadd command returned non-zero exit status, this is expected if group already exists: {e}")
     try:#使用sudo将user_id加入shared_group
-        subprocess.run(["sudo", "usermod", "-a", "-G", f"shared_group_{user_id}", user_id], check=True)
+        subprocess.run(["sudo", "usermod", "-a", "-G", f"shared_group_{user_id}", user_id], check=current_app.config['DEBUG'])
         # 自己也加入
-        subprocess.run(["sudo", "usermod", "-a", "-G", f"shared_group_{user_id}", 'flask'], check=True)
+        subprocess.run(["sudo", "usermod", "-a", "-G", f"shared_group_{user_id}", 'flask'], check=current_app.config['DEBUG'])
     except subprocess.CalledProcessError as e:
         print(f"Error adding user {user_id} to shared_group: {e}")
     try:
-        subprocess.run(["sudo", "chown", "-R", f"flask:shared_group_{user_id}", path], check=True)
+        subprocess.run(["sudo", "chown", "-R", f"flask:shared_group_{user_id}", path], check=current_app.config['DEBUG'])
-        subprocess.run(["sudo", "chmod", "-R", "755", user_root], check=True)
+        subprocess.run(["sudo", "chmod", "-R", "755", user_root], check=current_app.config['DEBUG'])
-        subprocess.run(["sudo", "chmod", "-R", "775", path], check=True)
+        subprocess.run(["sudo", "chmod", "-R", "775", path], check=current_app.config['DEBUG'])
     except subprocess.CalledProcessError as e:
         print(f"Error changing directory {path} to shared_group_{user_id}: {e}")
 

code-server-like/config.ini

@@ -1,3 +1,4 @@
 [Global]
 SECRET_KEY = cakebaker
 ROOT_WORKSPACE_PATH = /home
+DEBUG = False

code-server-like/run.py

@@ -1,5 +1,12 @@
 from app import create_app
 from app.extensions import socketio
+import logging
+
+# 配置日志，减少eventlet的调试日志
+logging.getLogger('eventlet').setLevel(logging.ERROR)
+logging.getLogger('socketio').setLevel(logging.ERROR)
+logging.getLogger('werkzeug').setLevel(logging.ERROR)
+
 app = create_app()
 
 if __name__ == '__main__':
@@ -9,4 +16,5 @@ if __name__ == '__main__':
         port=5200,
         debug=False,                # 开发期打开
         allow_unsafe_werkzeug=True, # 避免 dev server 的安全限制提示
-        )
+        log_output=False            # 禁用详细输出
+    )

code-server-like/templates/index.html

@@ -4,17 +4,17 @@
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
     <title>Cloud IDE</title>
-    <link rel="stylesheet" href="static/cdnback/css/editor/editor.main.css">
+    <link rel="stylesheet" href="/static/cdnback/css/editor/editor.main.css">
-    <script src="static/cdnback/socket.io.min.js"></script>
+    <script src="/static/cdnback/socket.io.min.js"></script>
-    <link rel="stylesheet" href="static/cdnback/all.min.css">
+    <link rel="stylesheet" href="/static/cdnback/all.min.css">
-    <link rel="stylesheet" href="static/cdnback/css/xterm.css" />
+    <link rel="stylesheet" href="/static/cdnback/css/xterm.css" />
     <!-- <script src="https://cdnjs.cloudflare.com/ajax/libs/xterm/5.5.0/xterm.js"></script> -->
-    <script src="static/cdnback/js/xterm.js"></script>
+    <script src="/static/cdnback/js/xterm.js"></script>
-    <script src="static/cdnback/js/addons/fit/fit.js"></script>
+    <script src="/static/cdnback/js/addons/fit/fit.js"></script>
-    <script src="static/cdnback/js/addons/webLinks/webLinks.js"></script>
+    <script src="/static/cdnback/js/addons/webLinks/webLinks.js"></script>
-    <script src="static/cdnback/js/addons/fullscreen/fullscreen.js"></script>
+    <script src="/static/cdnback/js/addons/fullscreen/fullscreen.js"></script>
-    <script src="static/cdnback/js/addons/search/search.js"></script>
+    <script src="/static/cdnback/js/addons/search/search.js"></script>
-    <link rel="stylesheet" href="static/cdnback/all.min.css">
+    <link rel="stylesheet" href="/static/cdnback/all.min.css">
 
     <link rel="stylesheet" href="/vsc-like/static/css/index.css">
     <link rel="stylesheet" href="/vsc-like/static/css/notification.css">
@@ -61,7 +61,7 @@
     </div>
     <div id="notificationsContainer"></div>
 
-    <script src="https://cdnjs.cloudflare.com/ajax/libs/monaco-editor/0.34.0/min/vs/loader.js"></script>
+    <script src="/static/cdnback/js/monaco-editor/0.34.0/min/vs/loader.js"></script>
     <script src="/vsc-like/static/js/code-like-extension.js"></script>
     <script src="/vsc-like/static/js/file.js"></script>
     <script src="/vsc-like/static/js/terminal.js"></script>
@@ -161,7 +161,7 @@
                 // saveFile
                 if (saveTimeout) clearTimeout(saveTimeout);
                 saveTimeout = setTimeout(() => {
-                    postSaveFile(selectedItem.path+'/'+selectedItem.name, editor.getValue());
+                    postSaveFile(filePath, editor.getValue());
                 }, 5000); // 5000ms = 5秒
             });
 

et --hard HEAD@{1}

@@ -0,0 +1,69 @@
+68493d6a (HEAD -> main, origin/main) HEAD@{0}: pull origin main: Fast-forward
+0852e121 HEAD@{1}: reset: moving to HEAD
+0852e121 HEAD@{2}: commit: cdn fix more
+7dc4714a HEAD@{3}: commit: index style
+9dc81b14 (origin/feature/paste_detecte_new, feature/paste_detecte_new) HEAD@{4}: merge feature/paste_detecte_new: Fast-forward
+7862647b HEAD@{5}: checkout: moving from feature/paste_detecte_new to main
+9dc81b14 (origin/feature/paste_detecte_new, feature/paste_detecte_new) HEAD@{6}: commit (merge): Merge branch 'main' into feature/paste_detecte_new
+0cf1896b HEAD@{7}: checkout: moving from main to feature/paste_detecte_new
+7862647b HEAD@{8}: commit: style fix
+6b9c8e9e HEAD@{9}: commit: cdn change to local and use markdown and style change
+33844786 HEAD@{10}: commit: use markdown to edit
+ce88ae64 HEAD@{11}: commit: use queue to allow send vscode_ws when it is none
+6c38e906 HEAD@{12}: pull: Fast-forward
+9759c93a HEAD@{13}: commit: fix funciton response
+ecf19f49 HEAD@{14}: commit: fix function double promlem
+f5d50772 HEAD@{15}: commit: function call can be expire
+4a390adb HEAD@{16}: commit: fix style bug
+960d1f1d HEAD@{17}: commit: style fix
+c73ea447 HEAD@{18}: commit: fix index
+33bf569f HEAD@{19}: commit: fix nextchapter bug
+b921bda4 HEAD@{20}: commit: auto get domain
+9921848d HEAD@{21}: commit: remove prefix of http url
+4d81aef8 HEAD@{22}: commit (merge): Merge branch 'feature/paste_deteced'
+8fe5ee16 HEAD@{23}: checkout: moving from feature/paste_deteced to main
+9ce212e9 (origin/feature/paste_deteced, feature/paste_deteced) HEAD@{24}: checkout: moving from main to feature/paste_deteced
+8fe5ee16 HEAD@{25}: commit (merge): 准备合并main
+908d5915 HEAD@{26}: checkout: moving from syt to main
+57d8ac32 (origin/syt, syt) HEAD@{27}: checkout: moving from main to syt
+908d5915 HEAD@{28}: commit: ready
+02b12791 HEAD@{29}: checkout: moving from syt to main
+57d8ac32 (origin/syt, syt) HEAD@{30}: checkout: moving from main to syt
+02b12791 HEAD@{31}: pull: Fast-forward
+7d861e34 (origin/zrz) HEAD@{32}: checkout: moving from syt to main
+57d8ac32 (origin/syt, syt) HEAD@{33}: commit: first
+0196f37e HEAD@{34}: pull: Merge made by the 'ort' strategy.
+57eb1197 HEAD@{35}: commit: ok
+382f2006 HEAD@{36}: checkout: moving from main to syt
+7d861e34 (origin/zrz) HEAD@{37}: commit (merge): Merge branch 'main' of https://gitee.com/CakeCN/code-agent
+5f8f6c94 HEAD@{38}: commit: many ok
+e24aa12e HEAD@{39}: commit: ready to process
+6766ca85 HEAD@{40}: commit (merge): Merge branch 'feature/voice_send'
+3c9c7553 HEAD@{41}: checkout: moving from feature/voice_send to main
+58a95e9f (origin/feature/voice_send, feature/voice_send) HEAD@{42}: commit: ready merge to main
+79125ffc HEAD@{43}: commit: change .cn to .com
+2f9bc7df HEAD@{44}: checkout: moving from main to feature/voice_send
+3c9c7553 HEAD@{45}: reset: moving to HEAD
+3c9c7553 HEAD@{46}: checkout: moving from feature/voice_send to main
+2f9bc7df HEAD@{47}: pull: Fast-forward
+504c5cae (0v) HEAD@{48}: checkout: moving from main to feature/voice_send
+3c9c7553 HEAD@{49}: commit: cn/com allow all
+7122c3be HEAD@{50}: commit (merge): fix url
+e07c41fb HEAD@{51}: commit: fix code-server reboot problem(close debug)
+821e20c9 HEAD@{52}: commit: clear double iframe more safe
+053584a7 HEAD@{53}: checkout: moving from feature/voice_send to main
+504c5cae (0v) HEAD@{54}: checkout: moving from main to feature/voice_send
+053584a7 HEAD@{55}: commit: clear iframe double
+10481b0b HEAD@{56}: commit: fix permisson bug
+dc0eeaa9 HEAD@{57}: commit: add hint
+a24df620 HEAD@{58}: commit: fix some bug
+3ad36c29 HEAD@{59}: commit: 25/09/24 10:00~11:30 停机维护
+07cf2363 HEAD@{60}: commit: fix many bug
+6aac4200 HEAD@{61}: commit: try hello message
+271672c9 HEAD@{62}: commit: check to code-server-like
+252c426c HEAD@{63}: pull: Merge made by the 'ort' strategy.
+588fc3b6 HEAD@{64}: commit: ready to code-like
+b1f832a2 (origin/code-like-autosave, code-like-autosave) HEAD@{65}: merge code-like-autosave: Fast-forward
+24f191d5 HEAD@{66}: checkout: moving from code-like-autosave to main
+b1f832a2 (origin/code-like-autosave, code-like-autosave) HEAD@{67}: checkout: moving from main to code-like-autosave
+24f191d5 HEAD@{68}: clone: from https://gitee.com/CakeCN/code-agent.git