[0701] Loro Collab: 适配 ImGUI (#4200)

Author: JimZhouZZY

devel/0701.md

@@ -0,0 +1,15 @@
+# [0701] Loro Collab: 适配 ImGUI
+## 如何测试
+
+```
+xmake f --loro=yes --qt_frontend=no
+xmake b stem
+xmake r stem
+```
+
+起服务器
+```
+cd tools/loro-server/ && npm install && node server.js
+```
+
+使用多 ImGui 客户端测试协作

src/Plugins/ImGui/im_gui.cpp

@@ -27,6 +27,10 @@
 
 #include <GLFW/glfw3.h> // system clipboard (glfwSet/GetClipboardString)
 
+#ifdef LORO_ENABLED
+#include "loro_collab.hpp" // loro_collab_disconnect
+#endif
+
 #ifndef GL_SILENCE_DEPRECATION
 #define GL_SILENCE_DEPRECATION
 #endif
@@ -512,6 +516,11 @@ im_interpose () {
 
 void
 gui_close () {
+#ifdef LORO_ENABLED
+  // 关闭协作会话的 WS，避免进程退出时 curl 在半操作中 teardown（镜像
+  // qt_gui.cpp 的 gui_close）。
+  loro_collab_disconnect ();
+#endif
   if (s_glfw_initialized) {
     glfwTerminate ();
     s_glfw_initialized= false;

src/Plugins/ImGui/im_tm_widget.cpp

@@ -29,6 +29,10 @@
 #include "im_menu.hpp" // im_render_main_menu / im_render_active_popup / im_has_active_popup
 #include "im_simple_widget.hpp" // editor canvas (main_widget)
 
+#ifdef LORO_ENABLED
+#include "loro_collab.hpp" // loro_collab_poll / apply / disconnect
+#endif
+
 #include "backends/imgui_impl_glfw.h"
 #include "backends/imgui_impl_opengl3.h"
 #ifndef __EMSCRIPTEN__
@@ -736,6 +740,22 @@ im_tm_widget_rep::im_main_loop () {
 
   // Drive one TeXmacs tick. 驱动编辑器。
   im_interpose ();
+#ifdef LORO_ENABLED
+  // 驱动协同会话：drain WS 回调 + apply_remote。节流到 ~6Hz，镜像
+  // qt_gui.cpp 的 loro_collab_poll/apply 接入点。Native 与 WASM 都走
+  // im_main_loop，此处一处覆盖两平台。放在 iconified 检查之前，使最小化时
+  // 仍保持 CRDT 同步（不依赖渲染管线）。远程光标由 kernel 的
+  // draw_remote_cursors 画进同一纹理，无需此处处理。
+  {
+    static time_t last_loro_poll_time= 0;
+    time_t        now                = texmacs_time ();
+    if (now - last_loro_poll_time >= 1000 / 6) {
+      loro_collab_poll ();
+      loro_collab_apply ();
+      last_loro_poll_time= now;
+    }
+  }
+#endif
   if (glfwGetWindowAttrib (window, GLFW_ICONIFIED) != 0) {
     ImGui_ImplGlfw_Sleep (10);
     return;