From a0dd3d7ac642111faeaefd02c5a452898b9c6d49 Mon Sep 17 00:00:00 2001
From: haoyuren <13851610112@163.com>
Date: Thu, 12 Mar 2026 18:11:10 -0500
Subject: Add collaborator cursors and project chat

Collaborator cursors:
- Real-time cursor positions via clientTracking Socket.IO events
- CM6 extension renders colored cursor widgets with name labels
- Throttled cursor position broadcasting (300ms)
- Connected users count in toolbar and status bar

Project chat:
- Chat panel in right sidebar (toggleable)
- Load message history via REST API
- Send messages with real-time delivery via Socket.IO new-chat-message
- Auto-scroll, avatars, timestamps

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 src/main/overleafSocket.ts | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

(limited to 'src/main/overleafSocket.ts')

diff --git a/src/main/overleafSocket.ts b/src/main/overleafSocket.ts
index f825c4c..52ac20f 100644
--- a/src/main/overleafSocket.ts
+++ b/src/main/overleafSocket.ts
@@ -92,6 +92,10 @@ export class OverleafSocket extends EventEmitter {
     return this._projectData
   }
 
+  get publicId(): string | null {
+    return this._projectData?.publicId || null
+  }
+
   private setState(s: ConnectionState) {
     this._state = s
     this.emit('connectionState', s)
@@ -270,6 +274,20 @@ export class OverleafSocket extends EventEmitter {
     this.ws?.send(encodeEvent('applyOtUpdate', [docId, { doc: docId, op: ops, v: version, hash, lastV: version }]))
   }
 
+  /** Get list of connected users with their cursor positions */
+  async getConnectedUsers(): Promise<unknown[]> {
+    const result = await this.emitWithAck('clientTracking.getConnectedUsers', []) as unknown[]
+    // result format: [error, usersArray]
+    const err = result[0]
+    if (err) throw new Error(`getConnectedUsers failed: ${JSON.stringify(err)}`)
+    return (result[1] as unknown[]) || []
+  }
+
+  /** Send our cursor position */
+  updateCursorPosition(docId: string, row: number, column: number): void {
+    this.ws?.send(encodeEvent('clientTracking.updatePosition', [{ row, column, doc_id: docId }]))
+  }
+
   disconnect() {
     this.shouldReconnect = false
     this.stopHeartbeat()
-- 
cgit v1.2.3