, {'name': 'algorithm'})], 'score_prompt': '\n1. 学生最终代码通过所有测试点：30分\n2. 学生独立在10分钟内完成题目：10分 或者 学生在Agent指导下10分钟内完成题目：5分\n\n'}}
-Sent text to route 'markdown-in': # 二分
-> Auto-generated at 2025-09-05 19:48
-
-## 阶段一：示例阶段
-### 引入
-
-二分是一个很简单基础，但很重要的知识点，为以后许多高级的数据结构与算法铺垫。
-
-下面是一个用二分的简单场景：
-
-假设小明从0到1000之间选择了一个数字但不告诉你，你可以不断猜测这个数，每次猜测小明会告知你的猜测得过大还是过小，问最多几次就一定能猜中？
-
-答案是利用二分查找的原理，猜测11次即可。
-
-1. 对于0到1000的答案备选区，猜测中位数500，假设过小，
-2. 则对于501到1000的答案备选区，猜测750，假设过大
-3. 则对于501到749的答案备选区，猜测625，假设过小，
-4. 则对于626到749区间......
-5. （688-749）
-6. （718-749）
-7. （734-749）
-8. （742-749）
-9. （746-749）
-10. （748-749）
-11. （749-749）
-
-在最差的情况下，第11次的答案备选区就一定长度为1了，也就是必然是答案。
-
-因此如果序列是有序的，就可以通过二分查找快速定位所需要的数据。
-
-#### 思考题（询问Agent以学习计算方法，或验证你的答案）
-
-对于上面那个题目，如果问题区间是1到4000，最差情况下需要猜测几次？
-
-### 练习：二分查找
-
-试试对于下面的题目，用代码实现一下二分查找。
-
-#### 题目：有序数组寻址
-
-给出一个长度为n的有序数组（从小到大），有q次询问，对于每次询问，输出指定数在数组中的下标。如果不存在则输出-1。
-
-##### 输入
-
-第一行一个整数n。(1<=n<=10^5)
-
-第二行n个用空格分开的整数ai。(0<=ai<=10^8)
-
-第三行一个整数q，表示询问的次数。(1<=q<=10^4)
-
-后q行，每行一个整数b，表示询问的数。(0<=b<=10^8)
-
-##### 输出
-
-q行，每行一个整数，对应每次询问的返回结果。
-
-##### 提示：
-
-完成代码后，通知Agent进行评测。
-
-如果你还不完全会这个算法，询问Agent获取提示并进行学习。
-
-Sent text to route 'markdown-prompt-in': # 二分查找与二分答案
-
-## 二分查找
-
-### 引入
-
-本小节进行二分查找的引入，首先帮助学生理解教案引入章节的故事。
-
-确保学生理解了引入后，在进行思考题。
-
-如果不进行思考题，则询问一下是否不进行思考题，确认后进入下一节。
-
-如果进行思考题，告知学生计算方法并验证答案（答案是13次）
-
-计算方法：
-
-4000是初始答案区间长度，每次询问能够排除一半的区间，当区间长度小于等于1时，再进行一次猜测就一定是答案。
-
-4000不断除以2，除12次就小于等于1了，再加一次就一定是答案。最后是12+1=13次。
-
-（比4000大的最小2的次方数，4096就是2的12次方，这里的12就是答案中的12，或者写作"上取整(log2(4000))")
-
-询问学生，当学生告知理解后，进入下一节。
-
-### 练习：二分查找
-
-如果学生在实现的过程中遇到问题，不要直接告知完整代码如何编写，询问其当前遇到的是什么问题，并帮助学生一步步完成题目。
-
-实现代码后，全部通过测试数据后才可以进入下一节。
-
-本体测试点文件夹名 `twice_split。`
-
-_require_tools=judge,algorithm,binary_search,binary_search
-
-File not found: /usr/lib/code-server/lib/vscode/node_modules/vsda/rust/web/vsda_bg.wasm
-File not found: /usr/lib/code-server/lib/vscode/node_modules/vsda/rust/web/vsda.js
-[09:09:49] [127.0.0.1][6780739d][ManagementConnection] New connection established.
-[09:09:51] [127.0.0.1][47a78222][ExtensionHostConnection] New connection established.
-[09:09:51] [127.0.0.1][47a78222][ExtensionHostConnection] <12628> Launched Extension Host Process.
-[09:10:07] [127.0.0.1][6780739d][ManagementConnection] The client has disconnected gracefully, so the connection will be disposed.
-127.0.0.1 - - [11/Sep/2025 09:10:07] "GET /socket.io/?user_uuid=user_e511b990-0b8a-401d-9ae4-90bf1c6f47f9&folder=/home/cake/68bacdfadf5aeae0912f7f18/基础算法/二分&EIO=4&transport=websocket&sid=QaUbT4SaHkK8X4yVAAAA HTTP/1.1" 200 -
-[09:10:07] [127.0.0.1][47a78222][ExtensionHostConnection] <12628> Extension Host Process exited with code: 0, signal: null.
- * Detected change in '/home/ubuntu/hsamooc/code-agent/Html/apps/views/vscode.py', reloading
-Sent text to route 'score-prompt-in': # 二分查找与二分答案
-
-## 二分查找
-
-### 引入
-
-1. 学生独立给出了思考题的答案：10分 或者 学生在Agent指导下学会思考题：10分
-
-### 练习：二分查找
-
-1. 学生最终代码通过所有测试点：30分
-2. 学生独立在10分钟内完成题目：10分 或者 学生在Agent指导下10分钟内完成题目：5分
-
-Sent text to route 'markdown-in':
-二分是一个很简单基础，但很重要的知识点，为以后许多高级的数据结构与算法铺垫。
-
-下面是一个用二分的简单场景：
-
-假设小明从0到1000之间选择了一个数字但不告诉你，你可以不断猜测这个数，每次猜测小明会告知你的猜测得过大还是过小，问最多几次就一定能猜中？
-
-答案是利用二分查找的原理，猜测11次即可。
-
-1. 对于0到1000的答案备选区，猜测中位数500，假设过小，
-2. 则对于501到1000的答案备选区，猜测750，假设过大
-3. 则对于501到749的答案备选区，猜测625，假设过小，
-4. 则对于626到749区间......
-5. （688-749）
-6. （718-749）
-7. （734-749）
-8. （742-749）
-9. （746-749）
-10. （748-749）
-11. （749-749）
-
-在最差的情况下，第11次的答案备选区就一定长度为1了，也就是必然是答案。
-
-因此如果序列是有序的，就可以通过二分查找快速定位所需要的数据。
-
-#### 思考题（询问Agent以学习计算方法，或验证你的答案）
-
-对于上面那个题目，如果问题区间是1到4000，最差情况下需要猜测几次？
-
-
-Sent text to route 'markdown-prompt-in':
-本小节进行二分查找的引入，首先帮助学生理解教案引入章节的故事。
-
-确保学生理解了引入后，在进行思考题。
-
-如果不进行思考题，则询问一下是否不进行思考题，确认后进入下一节。
-
-如果进行思考题，告知学生计算方法并验证答案（答案是13次）
-
-计算方法：
-
-4000是初始答案区间长度，每次询问能够排除一半的区间，当区间长度小于等于1时，再进行一次猜测就一定是答案。
-
-4000不断除以2，除12次就小于等于1了，再加一次就一定是答案。最后是12+1=13次。
-
-（比4000大的最小2的次方数，4096就是2的12次方，这里的12就是答案中的12，或者写作"上取整(log2(4000))")
-
-询问学生，当学生告知理解后，进入下一节。
-
-
-Sent text to route 'score-prompt-in':
-1. 学生独立给出了思考题的答案：10分 或者 学生在Agent指导下学会思考题：10分
-
-
-VSCode client disconnected
-Disconnect reason:transport close
-2025-09-11 10:41:34.396 | INFO | agentscope.models:read_model_configs:186 - Load configs for model wrapper: openai_cfg
-Werkzeug appears to be used in a production deployment. Consider switching to a production web server instead.
- * Serving Flask app 'apps'
- * Debug mode: on
-[31m[1mWARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead.[0m
- * Running on all addresses (0.0.0.0)
- * Running on http://127.0.0.1:5551
- * Running on http://172.31.34.185:5551
-[33mPress CTRL+C to quit[0m
- * Restarting with stat
-2025-09-11 10:41:37.858 | INFO | agentscope.models:read_model_configs:186 - Load configs for model wrapper: openai_cfg
-Werkzeug appears to be used in a production deployment. Consider switching to a production web server instead.
- * Debugger is active!
- * Debugger PIN: 103-941-075
-127.0.0.1 - - [11/Sep/2025 10:42:48] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 11:09:11] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 11:09:12] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 11:30:59] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 11:30:59] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 11:31:01] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 11:31:01] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 11:31:37] "[33mGET /login/static/js/login.js HTTP/1.1[0m" 404 -
-127.0.0.1 - - [11/Sep/2025 11:31:37] "[33mGET /login/static/css/login.css HTTP/1.1[0m" 404 -
-127.0.0.1 - - [11/Sep/2025 13:02:26] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 13:02:27] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:27] "GET /static/js/login.js HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:27] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 13:02:28] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:28] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 13:02:28] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:29] "GET /static/js/login.js HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:29] "GET /static/css/login.css HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:29] "GET /static/js/login.js HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:30] "[32mGET / HTTP/1.1[0m" 302 -
-127.0.0.1 - - [11/Sep/2025 13:02:31] "GET /login HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:31] "GET /static/css/login.css HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:02:31] "GET /static/js/login.js HTTP/1.1" 200 -
-127.0.0.1 - - [11/Sep/2025 13:11:04] "[32mGET / HTTP/1.1[0m" 302 -
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/engineio/server.py", line 450, in run_handler
+ return self.handlers[event](*args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 671, in _handle_eio_disconnect
+ self._handle_disconnect(eio_sid, n, reason)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 568, in _handle_disconnect
+ self._trigger_event('disconnect', namespace, sid,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 627, in _trigger_event
+ return handler.trigger_event(event, *args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/namespace.py", line 26, in trigger_event
+ return self.socketio._handle_event(handler, event, self.namespace,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/__init__.py", line 835, in _handle_event
+ ret = handler(*args)
+ File "/home/flask/hsamooc/code-agent/Html/apps/sockets/namespaces.py", line 150, in on_disconnect
+ user_uuid2chatmanager[uuid].disconnect(uuid)
+KeyError: 'user_a24fccb3-d4b7-4716-bda5-5801b8cedd08'
+101.87.252.115,127.0.0.1 - - [16/Sep/2025 16:17:55] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=websocket&sid=SmogL1S86UeH8buqAAAJ HTTP/1.1" 200 0 960.067428
+(185715) accepted ('127.0.0.1', 53912)
+180.101.244.13,127.0.0.1 - - [16/Sep/2025 16:59:16] "GET / HTTP/1.1" 302 351 0.006999
+220.196.160.83,127.0.0.1 - - [16/Sep/2025 16:59:16] "GET / HTTP/1.1" 302 351 0.000767
+180.101.245.252,127.0.0.1 - - [16/Sep/2025 16:59:16] "GET /login HTTP/1.1" 200 1835 0.004592
+42.193.132.157,127.0.0.1 - - [16/Sep/2025 16:59:17] "GET /static/js/login.js HTTP/1.1" 200 3557 0.002909
+220.196.160.144,127.0.0.1 - - [16/Sep/2025 16:59:17] "GET /login HTTP/1.1" 200 1835 0.000856
+106.52.65.240,127.0.0.1 - - [16/Sep/2025 16:59:17] "GET /static/js/login.js HTTP/1.1" 200 3557 0.001178
+220.196.160.83,127.0.0.1 - - [16/Sep/2025 16:59:37] "GET / HTTP/1.1" 302 351 0.000812
+220.196.160.83,127.0.0.1 - - [16/Sep/2025 16:59:37] "GET /login HTTP/1.1" 200 1835 0.000806
+220.196.160.83,127.0.0.1 - - [16/Sep/2025 16:59:37] "GET /static/css/login.css HTTP/1.1" 200 3791 0.001815
+(185715) accepted ('127.0.0.1', 56936)
+220.196.160.83,127.0.0.1 - - [16/Sep/2025 16:59:37] "GET /static/js/login.js HTTP/1.1" 200 3557 0.000926
+180.101.244.16,127.0.0.1 - - [16/Sep/2025 16:59:40] "GET / HTTP/1.1" 302 351 0.003076
+180.101.244.16,127.0.0.1 - - [16/Sep/2025 16:59:41] "GET /login HTTP/1.1" 200 1835 0.000797
+180.101.244.16,127.0.0.1 - - [16/Sep/2025 16:59:41] "GET /static/css/login.css HTTP/1.1" 200 3791 0.001276
+180.101.244.16,127.0.0.1 - - [16/Sep/2025 16:59:41] "GET /static/js/login.js HTTP/1.1" 200 3557 0.000882
+(185715) accepted ('127.0.0.1', 59638)
+123.6.49.50,127.0.0.1 - - [16/Sep/2025 17:45:04] "GET / HTTP/1.1" 302 351 0.004425
+123.6.49.50,127.0.0.1 - - [16/Sep/2025 17:45:04] "GET /login HTTP/1.1" 200 1835 0.002219
+123.6.49.50,127.0.0.1 - - [16/Sep/2025 17:45:04] "GET /static/js/login.js HTTP/1.1" 200 3557 0.001412
+(185715) accepted ('127.0.0.1', 59652)
+123.6.49.50,127.0.0.1 - - [16/Sep/2025 17:45:04] "GET /static/css/login.css HTTP/1.1" 200 3791 0.003105
+123.6.49.44,127.0.0.1 - - [16/Sep/2025 17:45:10] "GET /favicon.ico HTTP/1.1" 404 331 0.002778
+27.115.124.112,127.0.0.1 - - [16/Sep/2025 17:45:11] "GET /favicon.ico HTTP/1.1" 404 331 0.001624
+123.6.49.47,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET / HTTP/1.1" 302 351 0.000800
+123.6.49.47,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /login HTTP/1.1" 200 1835 0.000786
+27.115.124.70,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /register HTTP/1.1" 200 1689 0.002584
+27.115.124.70,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /static/css/login.css HTTP/1.1" 200 3791 0.001273
+27.115.124.70,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /static/js/register.js HTTP/1.1" 200 1720 0.001667
+123.6.49.47,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /static/css/login.css HTTP/1.1" 200 3791 0.001219
+123.6.49.47,127.0.0.1 - - [16/Sep/2025 17:45:12] "GET /static/js/login.js HTTP/1.1" 200 3557 0.001201
+123.6.49.50,127.0.0.1 - - [16/Sep/2025 17:45:17] "GET /favicon.ico HTTP/1.1" 404 331 0.000770
+(185715) accepted ('127.0.0.1', 53172)
+27.115.124.5,127.0.0.1 - - [16/Sep/2025 17:51:56] "GET / HTTP/1.1" 302 351 0.001029
+27.115.124.3,127.0.0.1 - - [16/Sep/2025 17:51:56] "GET /login HTTP/1.1" 200 1835 0.000818
+27.115.124.5,127.0.0.1 - - [16/Sep/2025 17:51:57] "GET /favicon.ico HTTP/1.1" 404 331 0.000834
+27.115.124.41,127.0.0.1 - - [16/Sep/2025 17:51:57] "GET /robots.txt HTTP/1.1" 404 331 0.000888
+27.115.124.69,127.0.0.1 - - [16/Sep/2025 17:51:58] "GET /sitemap.xml HTTP/1.1" 404 331 0.000799
+27.115.124.112,127.0.0.1 - - [16/Sep/2025 17:53:14] "GET / HTTP/1.1" 302 351 0.000926
+27.115.124.67,127.0.0.1 - - [16/Sep/2025 17:53:34] "GET /login HTTP/1.1" 200 1835 0.000883
+27.115.124.33,127.0.0.1 - - [16/Sep/2025 17:53:38] "GET /favicon.ico HTTP/1.1" 404 331 0.001163
+(185715) accepted ('127.0.0.1', 55860)
+167.99.77.32,127.0.0.1 - - [16/Sep/2025 18:11:35] "GET / HTTP/1.1" 302 351 0.001348
+167.99.77.32,127.0.0.1 - - [16/Sep/2025 18:11:35] "GET /login HTTP/1.1" 200 1835 0.001791
+167.99.77.32,127.0.0.1 - - [16/Sep/2025 18:11:35] "GET /static/js/login.js HTTP/1.1" 200 3557 0.002767
+(185715) accepted ('127.0.0.1', 36792)
+196.251.70.47,127.0.0.1 - - [16/Sep/2025 21:26:55] "GET /.env HTTP/1.1" 404 331 0.000775
+(185715) accepted ('127.0.0.1', 37080)
+185.177.72.45,127.0.0.1 - - [16/Sep/2025 22:39:16] "GET / HTTP/1.1" 302 351 0.001164
+185.177.72.45,127.0.0.1 - - [16/Sep/2025 22:39:16] "GET /login HTTP/1.1" 200 1835 0.000922
+185.177.72.45,127.0.0.1 - - [16/Sep/2025 22:39:22] "GET /static/js/login.js HTTP/1.1" 200 3557 0.001013
+185.177.72.45,127.0.0.1 - - [16/Sep/2025 22:39:24] "GET /static/js/login.js HTTP/1.1" 200 3557 0.001304
+185.177.72.45,127.0.0.1 - - [16/Sep/2025 22:39:24] "GET /.git/config HTTP/1.1" 404 331 0.000836
+(185715) accepted ('127.0.0.1', 58636)
+54.237.85.94,127.0.0.1 - - [16/Sep/2025 23:03:57] "GET / HTTP/1.1" 302 351 0.000804
+54.237.85.94,127.0.0.1 - - [16/Sep/2025 23:03:57] "GET /login HTTP/1.1" 200 1835 0.000753
+(185715) accepted ('127.0.0.1', 57070)
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:45] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuKo HTTP/1.1" 200 275 0.000340
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:45] "POST /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuRo&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 192 0.000700
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:45] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuRq&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 196 0.000223
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:46] "POST /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuTi&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 192 0.000372
+Traceback (most recent call last):
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/hubs/hub.py", line 471, in fire_timers
+ timer()
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/hubs/timer.py", line 59, in __call__
+ cb(*args, **kw)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/greenthread.py", line 272, in main
+ result = function(*args, **kwargs)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 591, in _handle_event_internal
+ r = server._trigger_event(data[0], namespace, sid, *data[1:])
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 627, in _trigger_event
+ return handler.trigger_event(event, *args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/namespace.py", line 26, in trigger_event
+ return self.socketio._handle_event(handler, event, self.namespace,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/__init__.py", line 835, in _handle_event
+ ret = handler(*args)
+ File "/home/flask/hsamooc/code-agent/Html/apps/sockets/namespaces.py", line 53, in on_login
+ user_id = uuid2username[user_uuid]
+KeyError: 'user_a24fccb3-d4b7-4716-bda5-5801b8cedd08'
+(185715) accepted ('127.0.0.1', 57072)
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:46] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuTi.0&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 157 0.241678
+58.198.188.146,127.0.0.1 - - [16/Sep/2025 23:45:46] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbKwuZN&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 157 0.000381
+disconnect handler error
+Traceback (most recent call last):
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/engineio/server.py", line 450, in run_handler
+ return self.handlers[event](*args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 671, in _handle_eio_disconnect
+ self._handle_disconnect(eio_sid, n, reason)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 568, in _handle_disconnect
+ self._trigger_event('disconnect', namespace, sid,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 627, in _trigger_event
+ return handler.trigger_event(event, *args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/namespace.py", line 26, in trigger_event
+ return self.socketio._handle_event(handler, event, self.namespace,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/__init__.py", line 835, in _handle_event
+ ret = handler(*args)
+ File "/home/flask/hsamooc/code-agent/Html/apps/sockets/namespaces.py", line 150, in on_disconnect
+ user_uuid2chatmanager[uuid].disconnect(uuid)
+KeyError: 'user_a24fccb3-d4b7-4716-bda5-5801b8cedd08'
+58.198.188.146,127.0.0.1 - - [17/Sep/2025 03:39:10] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=websocket&sid=5YLu2hNGUKkeftJPAAAL HTTP/1.1" 200 0 14004.575564
+(185715) accepted ('127.0.0.1', 41646)
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:45:49] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbLnpKT HTTP/1.1" 200 275 0.000355
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:45:49] "POST /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbLnqu8&sid=gVzDTgTtIF0OYTTiAAAN HTTP/1.1" 200 192 0.000543
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:45:49] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbLnquK&sid=gVzDTgTtIF0OYTTiAAAN HTTP/1.1" 200 196 0.000240
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:45:49] "POST /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbLnqwQ&sid=gVzDTgTtIF0OYTTiAAAN HTTP/1.1" 200 192 0.000422
+Traceback (most recent call last):
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/hubs/hub.py", line 471, in fire_timers
+ timer()
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/hubs/timer.py", line 59, in __call__
+ cb(*args, **kw)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/eventlet/greenthread.py", line 272, in main
+ result = function(*args, **kwargs)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 591, in _handle_event_internal
+ r = server._trigger_event(data[0], namespace, sid, *data[1:])
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 627, in _trigger_event
+ return handler.trigger_event(event, *args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/namespace.py", line 26, in trigger_event
+ return self.socketio._handle_event(handler, event, self.namespace,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/__init__.py", line 835, in _handle_event
+ ret = handler(*args)
+ File "/home/flask/hsamooc/code-agent/Html/apps/sockets/namespaces.py", line 53, in on_login
+ user_id = uuid2username[user_uuid]
+KeyError: 'user_a24fccb3-d4b7-4716-bda5-5801b8cedd08'
+(185715) accepted ('127.0.0.1', 41652)
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:45:49] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=polling&t=PbLnqwU&sid=gVzDTgTtIF0OYTTiAAAN HTTP/1.1" 200 157 0.285216
+disconnect handler error
+Traceback (most recent call last):
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/engineio/server.py", line 450, in run_handler
+ return self.handlers[event](*args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 671, in _handle_eio_disconnect
+ self._handle_disconnect(eio_sid, n, reason)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 568, in _handle_disconnect
+ self._trigger_event('disconnect', namespace, sid,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/socketio/server.py", line 627, in _trigger_event
+ return handler.trigger_event(event, *args)
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/namespace.py", line 26, in trigger_event
+ return self.socketio._handle_event(handler, event, self.namespace,
+ File "/home/flask/hsamooc/code-agent/.venv/lib/python3.10/site-packages/flask_socketio/__init__.py", line 835, in _handle_event
+ ret = handler(*args)
+ File "/home/flask/hsamooc/code-agent/Html/apps/sockets/namespaces.py", line 150, in on_disconnect
+ user_uuid2chatmanager[uuid].disconnect(uuid)
+KeyError: 'user_a24fccb3-d4b7-4716-bda5-5801b8cedd08'
+219.228.146.148,127.0.0.1 - - [17/Sep/2025 03:46:44] "GET /socket.io/?user_uuid=user_a24fccb3-d4b7-4716-bda5-5801b8cedd08&folder=%2Fhome%2Fcake%2F68bacdfadf5aeae0912f7f18%2F%E5%9F%BA%E7%A1%80%E7%AE%97%E6%B3%95%2F%E4%BA%8C%E5%88%86&EIO=4&transport=websocket&sid=gVzDTgTtIF0OYTTiAAAN HTTP/1.1" 200 0 55.351826
+(185715) accepted ('127.0.0.1', 35708)
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:40:08] "GET /favicon.ico HTTP/1.1" 404 331 0.001202
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:40:09] "GET /favicon.ico HTTP/1.1" 404 331 0.001042
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:40:15] "GET /favicon.ico HTTP/1.1" 404 331 0.001459
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:40:40] "GET /favicon.ico HTTP/1.1" 404 331 0.001429
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:40:40] "GET /favicon.ico HTTP/1.1" 404 331 0.001089
+(185715) accepted ('127.0.0.1', 47806)
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:42:45] "GET /?__debugger__=yes&cmd=resource&f=console.png HTTP/1.1" 304 162 0.000592
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:43:07] "GET /favicon.ico HTTP/1.1" 404 331 0.001448
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:43:07] "GET /favicon.ico HTTP/1.1" 404 331 0.000793
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:44:50] "GET /favicon.ico HTTP/1.1" 404 331 0.001238
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:44:50] "GET /favicon.ico HTTP/1.1" 404 331 0.000915
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:45:19] "GET /favicon.ico HTTP/1.1" 404 331 0.002353
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:45:20] "GET /favicon.ico HTTP/1.1" 404 331 0.001941
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:47:09] "GET /favicon.ico HTTP/1.1" 404 331 0.001026
+59.78.194.184,127.0.0.1 - - [17/Sep/2025 04:47:10] "GET /favicon.ico HTTP/1.1" 404 331 0.000903
diff --git a/Html/apps/services/backboard_service.py b/Html/apps/services/backboard_service.py
index 6a458da..0ef29a8 100644
--- a/Html/apps/services/backboard_service.py
+++ b/Html/apps/services/backboard_service.py
@@ -34,7 +34,7 @@ def realtime_response(config: dict, realtime_action: dict) -> None:
file_path = realtime_action.get("filePath")
assert isinstance(file_path, str)
with sudo_open(file_path, "r", encoding="utf-8") as f:
- bb.active_file_content = f.read()
+ bb.active_file_content = f
bb.active_file_path = file_path
elif rtype == "paste":
@@ -44,14 +44,14 @@ def realtime_response(config: dict, realtime_action: dict) -> None:
bb.pasted_content = realtime_action.get("content")
bb.active_file_path = file_path
with sudo_open(file_path, "r", encoding="utf-8") as f:
- bb.active_file_content = f.read()
+ bb.active_file_content = f
elif rtype == "fileEdit":
file_path = realtime_action.get("filePath")
assert isinstance(file_path, str)
bb.active_file_path = file_path
with sudo_open(file_path, "r", encoding="utf-8") as f:
- bb.active_file_content = f.read()
+ bb.active_file_content = f
chatmanager.upload_bb()
\ No newline at end of file
diff --git a/Html/apps/static/算法效率-效率的重要性与实践验证.html b/Html/apps/static/算法效率-效率的重要性与实践验证.html
new file mode 100644
index 0000000..e6a18f9
--- /dev/null
+++ b/Html/apps/static/算法效率-效率的重要性与实践验证.html
@@ -0,0 +1,121 @@
+
+
+
+
+
+
+
+ 效率的重要性与实践验证
+
+Auto-generated at 2025-09-16 05:03
+
+理论热身：算法选择的智慧
+任务：分析与决策
+项目组目前有两套备选的交通信号灯同步算法，它们将在不同性能的服务器上运行：
+
+你的项目经理（右侧的Agent）希望你通过分析，来判断哪个方案更具前景。请与TA对话，逐一回答以下问题。
+思考题
+与右侧的Agent对话，回答以下问题：
+
+-
+
概念回顾：首先，请向你的“经理”解释，根据课程所学，一个合格的“算法”应具备哪些基本特征？
+
+-
+
小规模测试：对于一个包含100个路口的小型城区（n=100），计算并说明方案A和方案B分别需要多长时间完成计算？在这种情况下，你会推荐哪个方案？
+
+-
+
大规模应用：现在，我们需要为一座拥有100万个路口的大都市（n=1,000,000）进行规划。再次计算并说明两个方案的耗时。你的推荐会改变吗？为什么？
+
+-
+
总结陈词：综合以上分析，向你的“经理”总结：为什么一个更优的算法设计，其重要性远超硬件性能的提升？ 这验证了课程中提到的哪个核心观点？
+
+
+编程实践：验证算法的真实性能
+任务：编码与分析
+理论分析让你认识到了算法效率的重要性。现在，你需要通过编程来亲身感受不同交通状况对同一算法性能的巨大影响。我们将以“插入排序”为例，来处理三种典型的交通流量数据，这分别对应算法分析中的最好，最坏和平均情况。
+题目：模拟交通流量排序
+实现插入排序算法，并验证其在处理“畅通无阻”（数据有序）、“交通大堵塞”（数据逆序）和“随机车流”（数据随机）三种模式时的效率差异。
+代码框架
+在代码编辑区，完成 insertion_sort(arr) 函数的实现后，运行完整代码，并与Agent讨论结果。
+请创建任意文件，将下面代码写入到编辑器中
+```python
+import random
+import time
+def insertion_sort(arr):
+ """
+ 实现插入排序算法
+ 参数arr: 待排序的交通数据数组（整数代表车辆通行次序）
+ 返回: 排序后的数组
+ """
+ # TODO: 请在此处实现你的插入排序逻辑
+def generate_traffic_data(n):
+ """
+ 生成模拟交通数据
+ 参数n: 数据规模（路口数量或监控点数量）
+ 返回: 三种不同交通状况的数据
+ """
+ random_data = [random.randint(0, 10**6) for _ in range(n)]
+ # 模拟“畅通无阻”：交通流按次序进入，数据基本有序 (Best Case)
+ best_case_data = sorted(random_data)
+ # 模拟“交通大堵塞”：疏散时情况完全反转，数据逆序 (Worst Case)
+ worst_case_data = sorted(random_data, reverse=True)
+ # 模拟“随机车流”：正常但无规律的交通状况 (Average Case)
+ average_case_data = random_data
+ return best_case_data, worst_case_data, average_case_data
+def measure_performance(func, data):
+ """
+ 测量算法性能
+ 参数func: 排序函数
+ 参数data: 交通数据
+ 返回: 执行时间(毫秒)
+ """
+ start_time = time.perf_counter_ns()
+ func(data.copy()) # 使用副本避免影响其他测试
+ end_time = time.perf_counter_ns()
+ return (end_time - start_time) / 10**6 # 转换为毫秒
+测试不同规模的路口网络
+network_sizes = [1000, 5000, 10000]
+print("交通数据处理算法性能测试:")
+for size in network_sizes:
+ best, worst, avg = generate_traffic_data(size)
+time_best = measure_performance(insertion_sort, best)
+time_worst = measure_performance(insertion_sort, worst)
+time_avg = measure_performance(insertion_sort, avg)
+
+print(f"网络规模 n={size}:")
+print(f" - 畅通无阻 (Best Case): {time_best:.2f} ms")
+print(f" - 交通大堵塞 (Worst Case): {time_worst:.2f} ms")
+print(f" - 随机车流 (Average Case): {time_avg:.2f} ms")
+
+```
+分析与讨论
+完成编程并得到输出后，请与右侧Agent讨论以下问题，以检验你的理解：
+
+-
+
结果分析：当网络规模从1000增加到10000时，“交通大堵塞”（最坏情况）的处理时间增长了大约多少倍？这更符合O(n)（线性）还是O(n2)（二次）的增长模式？
+
+-
+
原因探究：为什么“畅通无阻”（最好情况）的处理速度如此之快？它的时间复杂度是什么？请结合你的代码逻辑来解释。
+
+-
+
实践应用：根据你的实验结果，你认为插入排序是否适合用于需要快速响应大规模交通拥堵的实时预警系统？为什么？
+
+-
+
融会贯通：结合第一关的理论分析和第二关的编程实验，你对“算法是解决问题的核心”这句话有了怎样更深的理解？
+
+
+
+
+
\ No newline at end of file
diff --git a/Html/apps/utils/sudoUtil.py b/Html/apps/utils/sudoUtil.py
index 92002d4..0b8a73e 100644
--- a/Html/apps/utils/sudoUtil.py
+++ b/Html/apps/utils/sudoUtil.py
@@ -16,7 +16,7 @@ def sudo_open(file_path, mode='r', encoding='utf-8'):
if result.returncode != 0:
raise PermissionError(f"无法读取文件: {file_path}")
content = result.stdout
- yield content
+ return content
elif mode == 'w':
raise PermissionError(f"不允许以sudo权限写入文件: {file_path}")
else:
diff --git a/Html/apps/views/vscode.py b/Html/apps/views/vscode.py
index 680a9ef..99df8ea 100644
--- a/Html/apps/views/vscode.py
+++ b/Html/apps/views/vscode.py
@@ -33,6 +33,29 @@ def desktop(user_uuid, course_id, chapter_name, lesson_name):
except subprocess.CalledProcessError as e:
print(f"Error creating directory {path_dir} details {str(e)}")
+ try:#使用sudo创建shared_group
+ subprocess.run(["sudo", "groupadd", f"shared_group_{user_id}"], check=True)
+ except subprocess.CalledProcessError as e:
+ print(f"Error creating shared_group: {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}", 'flask'], check=True)
+ 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}", user_home], check=True)
+ subprocess.run(["sudo", "chmod", "-R", "770", path_dir], check=True)
+ except subprocess.CalledProcessError as e:
+ print(f"Error changing directory {path_dir} to shared_group_{user_id}: {e}")
+ try:#继承目录
+ subprocess.run(["sudo", "chmod", "g+s", path_dir], check=True)
+ except subprocess.CalledProcessError as e:
+ print(f"Error changing directory {path_dir} to shared_group_{user_id}: {e}")
+
+
+
chatmanager = ChatManager()
current_app.extensions["user_uuid2chatmanager"][user_uuid] = chatmanager
code_server_port = 10000 + int(uuid.uuid4().int % 10000)
@@ -52,6 +75,8 @@ def desktop(user_uuid, course_id, chapter_name, lesson_name):
r'handle_path\s+/vsc' + re.escape(user_id) + r'/\* {.*?reverse_proxy.*?}',
re.DOTALL
)
+ for i in range(len(lines)):
+ if (lines[i].strip()==''): lines[i]=''
content = "".join(lines)
if pattern.search(content):
new_content = pattern.sub('', content)
diff --git a/code-server-like/app/sockets/terminal_service.py b/code-server-like/app/sockets/terminal_service.py
index 626223d..96d9b2b 100644
--- a/code-server-like/app/sockets/terminal_service.py
+++ b/code-server-like/app/sockets/terminal_service.py
@@ -5,154 +5,166 @@ import uuid
import subprocess
import threading
from flask import Blueprint, request, current_app, session
-from flask_socketio import Namespace, join_room, leave_room, emit, SocketIO
+from flask_socketio import Namespace, join_room, leave_room, emit, SocketIO, rooms, disconnect
from threading import Thread
import sys
from ..extensions import socketio
-
+import pty
+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)
+ # and before doing so - make sure you have username and port (on the "domain") to implement remote access
+ 'domain': '127.0.0.1', # or ip address like 192.168.10.11
+ 'client_path': {
+ 'telnet': '/usr/bin/telnet', # confirmed location of your client binary (with cmd like 'which telnet')
+ 'ssh': '/usr/bin/ssh'
+ }
+}
terminal_bp = Blueprint('terminal', __name__, url_prefix='/vsc-like')
-# 存储终端进程
-command_dict = {}
-terminal_busy = {}
-terminals = {}
-terminal_locks = {}
-
-def check_process_running(command_name):
- try:
- # 使用 pgrep 查找与给定命令相关的进程
- result = subprocess.run(
- ["pgrep", "-f", command_name],
- stdout=subprocess.PIPE, stderr=subprocess.PIPE
- )
- return result.returncode == 0 # 如果返回值为 0，说明命令仍在运行
- except Exception as e:
- print(f"Error checking process: {e}")
- return False
-
-def monitor_process(socket_id, command_name, namespace):
- while True:
- is_running = check_process_running(command_name)
- if is_running:
- print(f"Process '{command_name}' is still running.")
- else:
- print(f"Process '{command_name}' is not running.")
- break # 停止检查，如果进程不再运行
-
- time.sleep(0.1) # 每 0.1 秒检查一次
- command_dict[socket_id] = ''
- terminal_busy[socket_id] = False
- namespace.emit('terminal_output',{'data': '>'})
-def start_terminal_process(socket_id, namespace):
+def set_winsize(fd, row, col, xpix=0, ypix=0):
+ winsize = struct.pack("HHHH", row, col, xpix, ypix)
+ fcntl.ioctl(fd, termios.TIOCSWINSZ, winsize)
+
+
+def read_and_forward_pty_output(fd=None, pid=None, room_id=None,namespace=None):
"""
- 监听多个子进程的输出，并通过 WebSocket 发给前端
- 使用 select 进行非阻塞的 I/O 操作，并实现动态流量控制
+ read data on pty master from the pty slave, and emit to the web terminal visitor
"""
- process = terminals[socket_id]
-
- # 获取子进程的 stdout 和 stderr
- stdout = process.stdout
- stdin = process.stdin
- # 将 stdout 和 stderr 添加到 select 监听的文件描述符列表中
-
- # 初始等待时间
- timeout = 0.1
- max_timeout = 2 # 设置最大超时时间为 2 秒
-
+ max_read_bytes = 1024 * 20
+ timeout=0.1
while True:
- while True:
- output = stdout.readline()
- if not output:
- break
- timeout = 0.1
- namespace.emit('terminal_output', {'data': output+'\r'}, room=socket_id)
- timeout = min(timeout * 2, max_timeout)
- time.sleep(timeout)
- if process.poll() is not None:
- break
-
+ socketio.sleep(timeout)
+ timeout=min(timeout*2, 0.4)
+ # using flask default web server, or uwsgi production web server
+ # when the child process is terminated, it will not disappear from linux process list
+ # and keep staying as a zombie process until the parent exits.
+ try:
+ child_process = psutil.Process(pid)
+ except psutil.NoSuchProcess as err:
+ return
+ if child_process.status() not in ('running', 'sleeping'):
+ return
+ if fd:
+ timeout_sec = 0
+ (data_ready, _, _) = select.select([fd], [], [], timeout_sec)
+ if data_ready:
+ # output = os.read(fd, max_read_bytes).decode('ascii')
+ timeout=0.1
+ try:
+ output = os.read(fd, max_read_bytes).decode()
+ except Exception as err:
+ output = """
+ ***AQUI WEB TERM ERR***
+ {}
+ ***********************
+ """.format(err)
+ # the key for different visitor to get different terminal (instead of mixing up)
+ # 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)
class VSCLikeNameSpace(Namespace):
- def on_connect(self, data):
- """
- 处理 WebSocket 连接
- - 验证会话
- - 使用指定的用户启动 bash 终端
- - 启动监听子进程输出的线程
- """
- socket_id = session.get('uuid')
- user_id = session.get('user_id') # 从 session 获取用户 ID
- path = session.get('path')
+ def on_connect(self):
+ """new client connected"""
+ if session.get('terminal_config', {}).get('child_pid', None):
+ print(session['terminal_config']['child_pid'])
+ # already started child process, don't start another
+ return
- if not path or not user_id:
- emit('error', {'message': 'Authentication failed, no path or user found for this session'})
- return False # 拒绝连接
- # 使用 sudo 启动终端进程，以指定的 user_id 用户身份执行
- try:
- process = subprocess.Popen(
- ['sudo', '-u', user_id, 'bash', '-il'], # 使用指定的 user_id 启动 bash
- stdin=subprocess.PIPE,
- stdout=subprocess.PIPE,
- stderr=subprocess.PIPE,
- text=True, # 确保输出是文本格式
- )
- terminals[socket_id] = process
- terminal_busy[socket_id] = False
- emit('connected', {'message': 'OK'})
- join_room(socket_id, namespace='/vsc-like')
+ # 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')
+ term_type = session.get('terminal_config').get('term_type')
+ path = TERM_INIT_CONFIG.get('client_path', {}).get(term_type, None)
+ if not path:
+ print("Can't locate {} binary, exit".format(term_type))
+ disconnect()
+ if term_type == 'telnet':
+ # 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
+ os.execl(path, 'telnet', '-l', session['terminal_config']['username'],
+ session['terminal_config']['domain'], '{}'.format(session['terminal_config']['port']))
+ elif term_type == 'ssh':
+ os.execl(path,'ssh', '-p','22',
+ #'{}'.format(session['terminal_config']['port']),
+ '{}@{}'.format(session['terminal_config']['username'], session['terminal_config']['domain']))
+
- socketio.start_background_task(target=start_terminal_process, socket_id=socket_id, namespace=self)
-
- except Exception as e:
- emit('error', {'message': f'Error starting terminal process: {str(e)}'})
- return False
-
- def on_send_input(self, data):
- socket_id = session.get('uuid')
- input_data = data.get('input')
- if socket_id not in command_dict:command_dict[socket_id]=''
- # 检查当前 socket_id 是否有对应的终端
- if socket_id in terminals:
- # 获取该终端的锁进行线程同步
- lock = terminal_locks.get(socket_id)
- if not lock:
- lock = threading.Lock()
- terminal_locks[socket_id] = lock
-
- with lock: # 在锁的保护下操作终端
- try:
- terminals[socket_id].stdin.write(input_data)
- command_dict[socket_id]+=input_data
- if input_data=='\r':
- terminals[socket_id].stdin.flush()
- emit('terminal_output', {'data': f'\r\n'}, room=socket_id)
- if terminal_busy[socket_id]==False:
- terminal_busy[socket_id] = True
- socketio.start_background_task(monitor_process, socket_id, command_dict[socket_id], namespace=self)
- elif input_data=='\x03':
- terminals[socket_id].stdin.flush()
- emit('terminal_output', {'data': f'^C\x03\r\n'}, room=socket_id)
- else:
- emit('terminal_output', {'data': input_data}, room=socket_id)
- except Exception as e:
- emit('error', {'message': f'Error sending input: {str(e)}'}, room=socket_id)
+ else:
+ current_app.logger.debug("wrong term type {}".format(term_type))
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
else:
- emit('error', {'message': 'No terminal found for this session'}, room=socket_id)
+ session['terminal_config']['fd'] = fd
+ session['terminal_config']['child_pid'] = child_pid
+ session['terminal_config']['room_id'] = rooms()[0]
+ session.modified = True
+ 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("background task running")
+ # print(session)
- def on_disconnect():
- socket_id = session.get('uuid')
-
- # 检查是否有终端进程需要终止
- if socket_id in terminals:
- try:
- # 终止终端进程
- terminals[socket_id].terminate()
- del terminals[socket_id]
- # 删除锁
- if socket_id in terminal_locks:
- del terminal_locks[socket_id]
- emit('terminal_output', {'data': 'Terminal disconnected and terminated'}, room=socket_id)
- except Exception as e:
- emit('error', {'message': f'Error disconnecting terminal: {str(e)}'}, room=socket_id)
+ 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}")
+ try:
+ child_process = psutil.Process(session.get('terminal_config').get('child_pid'))
+ except psutil.NoSuchProcess as err:
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
+ return
+ if child_process.status() not in ('running', 'sleeping'):
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
+ return
+ # print(session)
+ # print(data, 'from input')
+ fd = session.get('terminal_config').get('fd')
+ if fd:
+ # print("writing to ptd: %s" % data["input"])
+ # os.write(fd, data["input"].encode('ascii'))
+ os.write(fd, data["input"].encode())
+
+
+ def on_resize(self, data):
+ try:
+ child_process = psutil.Process(session.get('terminal_config').get('child_pid'))
+ except psutil.NoSuchProcess as err:
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
+ return
+ if child_process.status() not in ('running', 'sleeping'):
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
+ return
+ fd = session.get('terminal_config').get('fd')
+ if fd:
+ set_winsize(fd, data["rows"], data["cols"])
+
+ def on_disconnect(self):
+ try:
+ child_process = psutil.Process(session.get('terminal_config', {}).get('child_pid'))
+ except psutil.NoSuchProcess as err:
+ disconnect()
+ session['terminal_config'] = TERM_INIT_CONFIG
+ 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
+ child_process.terminate()
+ current_app.logger.debug('user left the pty alone, terminated')
+ current_app.logger.debug('Client disconnected')
\ No newline at end of file
diff --git a/code-server-like/app/views/file.py b/code-server-like/app/views/file.py
index 03b5729..b1ad3a4 100644
--- a/code-server-like/app/views/file.py
+++ b/code-server-like/app/views/file.py
@@ -12,8 +12,7 @@ def create_folder():
filepath = request.json.get('path', '')
path = session.get('path')
parent = request.json.get('parent', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{path}'
+ base_path = f'{path}'
filepath = f'{base_path}/{parent}/{filepath}'
try:
os.makedirs(filepath)
@@ -27,8 +26,7 @@ def create_file():
filepath = request.json.get('path', '')
path = session.get('path')
parent = request.json.get('parent', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{path}'
+ base_path = f'{path}'
filepath = f'{base_path}/{parent}/{filepath}'
try:
open(filepath, 'w').close()
@@ -41,8 +39,7 @@ def rename_file():
user_root = session.get('path')
path = request.json.get('path', '')
new_name = request.json.get('newName', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{user_root}'
+ base_path = f'{user_root}'
filepath = f'{base_path}/{path}'
try:
path_list = filepath.split('/')
@@ -58,8 +55,7 @@ def rename_folder():
user_root = session.get('path')
path = request.json.get('path', '')
new_name = request.json.get('newName', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{user_root}'
+ base_path = f'{user_root}'
folderpath = f'{base_path}/{path}'
try:
path_list = folderpath.split('/')
@@ -74,9 +70,8 @@ def rename_folder():
def copy_files():
old_path = request.json.get('oldPath', '')
new_path = request.json.get('newPath', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
user_root = session.get('path')
- base_path = f'{root_workspace_path}/{user_root}'
+ base_path = f'{user_root}'
old_path = f'{base_path}/{old_path}'
new_path = f'{base_path}/{new_path}'
# oldpath的父目录就是newpath的话,对oldpath进行重命名
@@ -106,9 +101,8 @@ def copy_files():
@file_bp.route('/delete-file', methods=['POST'])
def delete_file():
path = request.json.get('path', '')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
user_root = session.get('path')
- base_path = f'{root_workspace_path}/{user_root}'
+ base_path = f'{user_root}'
filepath = f'{base_path}/{path}'
if os.path.isdir(filepath):
shutil.rmtree(filepath)
@@ -119,8 +113,7 @@ def delete_file():
@file_bp.route('/file-content', methods=['POST'])
def file_content():
path = session.get('path')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{path}'
+ base_path = f'{path}'
filepath = request.json.get('path', '')
filepath = f'{base_path}/{filepath}'
if not os.path.exists(filepath):
@@ -135,8 +128,7 @@ def file_content():
@file_bp.route('/save-file', methods=['POST'])
def save_file():
path = session.get('path')
- root_workspace_path = current_app.config['ROOT_WORKSPACE_PATH']
- base_path = f'{root_workspace_path}/{path}'
+ base_path = f'{path}'
filepath = request.json.get('path', '')
filepath = f'{base_path}/{filepath}'
content = request.json.get('content', '')
diff --git a/code-server-like/app/views/routes.py b/code-server-like/app/views/routes.py
index 691eb18..8ae074f 100644
--- a/code-server-like/app/views/routes.py
+++ b/code-server-like/app/views/routes.py
@@ -4,9 +4,18 @@ from flask import Blueprint, request, jsonify, current_app, render_template, ses
from ..services.file_service import get_file_tree, load_config
main_bp = Blueprint('main', __name__, url_prefix='/vsc-like')
-
-@main_bp.route('/////', methods=['GET'])
-def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name):
+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)
+ # and before doing so - make sure you have username and port (on the "domain") to implement remote access
+ 'domain': '15.168.14.27', # or ip address like 192.168.10.11
+ 'client_path': {
+ 'telnet': '/usr/bin/telnet', # confirmed location of your client binary (with cmd like 'which telnet')
+ 'ssh': '/usr/bin/ssh'
+ }
+}
+@main_bp.route('//////', methods=['GET'])
+def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name, port):
uuid = user_uuid
base_path = current_app.config['ROOT_WORKSPACE_PATH']
path = os.path.join(base_path, user_id, course_id, chapter_name, lesson_name)
@@ -16,6 +25,11 @@ def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name):
session['course_id'] = course_id
session['chapter_name'] = chapter_name
session['lesson_name'] = lesson_name
+ session['terminal_config'] = TERM_INIT_CONFIG
+ session['terminal_config']['term_type'] = 'ssh'
+ session['terminal_config']['username'] = user_id
+ session['terminal_config']['port'] = port
+ session.modified = True
config = load_config(path)
# if not config:
# return jsonify({"error": "Configuration file not found or invalid"}), 404
@@ -26,11 +40,17 @@ def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name):
try:
subprocess.run(["sudo", "useradd", "-m", "-d", user_root, user_id]) # 创建用户
subprocess.run(["sudo", "chown", "-R", user_id, user_root]) # 设置目录权限为新用户
+
except subprocess.CalledProcessError as e:
print(f"Error creating user {user_id}: {e}")
try:
# 使用 sudo 执行 mkdir 命令来创建目录
subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", path], check=True)
+ subprocess.run(["sudo", "-u", user_id, "mkdir", "-p", f'{user_root}/.ssh'], check=True)
+ 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", "chmod", "700", f"{user_root}/.ssh"], check=True)
+ subprocess.run(["sudo", "chmod", "600", f"{user_root}/.ssh/authorized_keys"], check=True)
print(f"Directory {path} created successfully for user {user_id}")
except subprocess.CalledProcessError as e:
print(f"Error creating directory {path} details {str(e)}")
@@ -44,17 +64,15 @@ def vsc_like(user_uuid, user_id, course_id, chapter_name, lesson_name):
subprocess.run(["sudo", "usermod", "-a", "-G", f"shared_group_{user_id}", 'flask'], check=True)
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}", user_root], check=True)
+ try:
+ subprocess.run(["sudo", "chown", "-R", f"flask:shared_group_{user_id}", path], check=True)
+ subprocess.run(["sudo", "chmod", "-R", "750", user_root], check=True)
subprocess.run(["sudo", "chmod", "-R", "770", path], check=True)
except subprocess.CalledProcessError as e:
print(f"Error changing directory {path} to shared_group_{user_id}: {e}")
- try:#继承目录
- subprocess.run(["sudo", "chmod", "g+s", path], check=True)
- except subprocess.CalledProcessError as e:
- print(f"Error changing directory {path} to shared_group_{user_id}: {e}")
-
-
- return render_template('index.html')
+
+
+
+ return render_template('index.html', course_id=course_id, chapter_name=chapter_name, lesson_name=lesson_name)
diff --git a/code-server-like/static/js/file.js b/code-server-like/static/js/file.js
index 09dccc0..aeeabe0 100644
--- a/code-server-like/static/js/file.js
+++ b/code-server-like/static/js/file.js
@@ -296,7 +296,11 @@ function createNewFolder(event) {
function saveFile(event) {
event.stopPropagation();
const content = editor.getValue();
- fetch(`/vsc-like/save-file`, { method: 'POST', body: JSON.stringify({ path: item.path+'/'+item.name, content: content }) , headers: { 'Content-Type': 'application/json' } })
+ console.log(selectItem)
+ if (selectedItem.path==undefined){
+ selectedItem.path='.';
+ }
+ fetch(`/vsc-like/save-file`, { method: 'POST', body: JSON.stringify({ path: selectedItem.path+'/'+selectedItem.name, content: content }) , headers: { 'Content-Type': 'application/json' } })
.then(() => loadFileTree());
}
diff --git a/code-server-like/static/js/terminal.js b/code-server-like/static/js/terminal.js
index 8510969..6a91190 100644
--- a/code-server-like/static/js/terminal.js
+++ b/code-server-like/static/js/terminal.js
@@ -1,43 +1,63 @@
-const socket = io('https://hsamooc.cn/vsc-like',{path:'/vsc-like-ws'});
- let term;
document.addEventListener('DOMContentLoaded', () => {
- // 创建一个新的 xterm 实例
- term = new Terminal({
- cursorBlink: true,
- cols: 80,
- rows: 24,
- });
-
- // 打开终端到 #terminal 元素
+ Terminal.applyAddon(fullscreen)
+ Terminal.applyAddon(fit)
+ Terminal.applyAddon(webLinks)
+ Terminal.applyAddon(search)
+ const term = new Terminal({
+ col:80,
+ row:20,
+ cursorBlink: 5,
+ macOptionIsMeta: true,
+ });
term.open(document.getElementById('terminal'));
-
- // 启动连接并监听数据
- socket.on('connected', function (data) {
- term.write('>');
+ term.fit()
+ term.resize(term.cols, term.rows-5)
+ console.log(`size: ${term.cols} columns, ${term.rows} rows`)
+ // term.toggleFullScreen(true)
+ term.fit()
+ term.write("Welcome to AQ web remote-only terminal!\r\n")
+ term.on('key', (key, ev) => {
+ socket.emit("pty_input", {"input": key}, function(response) {
+ });
});
- // 监听后端返回的终端输出并显示
- socket.on('terminal_output', function (data) {
- if (data.data=='\x7f'){
- term.write('\b \b')
- return
+ const socket = io('https://hsamooc.cn/vsc-like',{path:'/vsc-like-ws'});
+ const status = document.getElementById("status")
+
+ socket.on("pty_output", function(data){
+ console.log("new output", data)
+ term.write(data.output)
+ })
+
+ socket.on("connect", () => {
+ // fitToscreen()
+ status.innerHTML = 'connected'
+
+ socket.emit("pty_input",{"input":"cd "+window.lesson_data.course_id+"/"+window.lesson_data.chapter_name+'/'+window.lesson_data.lesson_name+"\r"})
}
- term.write(data.data); // 输出来自后端的数据
- console.log("get",data.data)
- });
+ )
- // 监听用户在终端中输入的命令
- term.onData(function (data) {
- socket.emit('send_input', { input: data }); // 将用户输入通过 WebSocket 发送给后端
- });
+ socket.on("disconnect", () => {
+ status.innerHTML = 'disconnected'
+ })
+
+ function fitToscreen(){
+ term.fit()
+ socket.emit("resize", {"cols": term.cols, "rows": term.rows})
+ }
+
+ function debounce(func, wait_ms) {
+ let timeout
+ return function(...args) {
+ const context = this
+ clearTimeout(timeout)
+ timeout = setTimeout(() => func.apply(context, args), wait_ms)
+ }
+ }
+
+ const wait_ms = 500;
+ window.onresize = debounce(fitToscreen, wait_ms)
- // 如果终端被断开，显示消息
- socket.on('error', function (error) {
- term.write(`\nError: ${error.message}`);
- });
- socket.on('disconnect', function () {
- term.write('\nDisconnected from terminal');
- });
});
\ No newline at end of file
diff --git a/code-server-like/templates/index.html b/code-server-like/templates/index.html
index 34be608..d0c250e 100644
--- a/code-server-like/templates/index.html
+++ b/code-server-like/templates/index.html
@@ -7,11 +7,15 @@
-
-
+
+
+
+
+
+
+
-
@@ -48,6 +52,7 @@
+ status: connecting...
@@ -58,6 +63,12 @@