inactive cursors access control.

internal/api/members/controler.go

@@ -63,6 +63,8 @@ func (h *MembersHandler) membersCreate(w http.ResponseWriter, r *http.Request) e
 			CanWatch:              true,
 			CanHost:               true,
 			CanAccessClipboard:    true,
+			SendsInactiveCursor:   true,
+			CanSeeInactiveCursors: true,
 		},
 	}
 

internal/member/dummy/provider.go

@@ -15,6 +15,8 @@ func New() types.MemberProvider {
 			CanWatch:              true,
 			CanHost:               true,
 			CanAccessClipboard:    true,
+			SendsInactiveCursor:   true,
+			CanSeeInactiveCursors: true,
 		},
 	}
 }

internal/member/object/provider.go

@@ -29,6 +29,8 @@ func (provider *MemberProviderCtx) Connect() error {
 			CanWatch:              true,
 			CanHost:               true,
 			CanAccessClipboard:    true,
+			SendsInactiveCursor:   true,
+			CanSeeInactiveCursors: true,
 		})
 	}
 
@@ -42,6 +44,8 @@ func (provider *MemberProviderCtx) Connect() error {
 			CanWatch:              true,
 			CanHost:               true,
 			CanAccessClipboard:    true,
+			SendsInactiveCursor:   true,
+			CanSeeInactiveCursors: false,
 		})
 	}
 

internal/session/manager.go

@@ -254,6 +254,22 @@ func (manager *SessionManagerCtx) AdminBroadcast(event string, payload interface
 	}
 }
 
+func (manager *SessionManagerCtx) InactiveCursorsBroadcast(event string, payload interface{}, exclude interface{}) {
+	for _, session := range manager.List() {
+		if !session.State().IsConnected || !session.Profile().CanSeeInactiveCursors {
+			continue
+		}
+
+		if exclude != nil {
+			if in, _ := utils.ArrayIn(session.ID(), exclude); in {
+				continue
+			}
+		}
+
+		session.Send(event, payload)
+	}
+}
+
 // ---
 // events
 // ---

internal/session/session.go

@@ -54,7 +54,7 @@ func (session *SessionCtx) IsHost() bool {
 }
 
 func (session *SessionCtx) SetCursor(cursor types.Cursor) {
-	if session.manager.InactiveCursors() {
+	if session.manager.InactiveCursors() && session.profile.SendsInactiveCursor {
 		session.manager.SetCursor(cursor, session)
 	}
 }

internal/types/member.go

@@ -16,6 +16,8 @@ type MemberProfile struct {
 	CanWatch              bool   `json:"can_watch"`
 	CanHost               bool   `json:"can_host"`
 	CanAccessClipboard    bool   `json:"can_access_clipboard"`
+	SendsInactiveCursor   bool   `json:"sends_inactive_cursor"`
+	CanSeeInactiveCursors bool   `json:"can_see_inactive_cursors"`
 }
 
 type MemberProvider interface {

internal/types/session.go

@@ -60,6 +60,7 @@ type SessionManager interface {
 
 	Broadcast(event string, payload interface{}, exclude interface{})
 	AdminBroadcast(event string, payload interface{}, exclude interface{})
+	InactiveCursorsBroadcast(event string, payload interface{}, exclude interface{})
 
 	OnCreated(listener func(session Session))
 	OnDeleted(listener func(session Session))

internal/websocket/manager.go

@@ -173,8 +173,7 @@ func (manager *WebSocketManagerCtx) Start() {
 						)
 					}
 
-					// TODO: Send to subscribers only.
+					manager.sessions.InactiveCursorsBroadcast(event.SESSION_CURSORS, cursors, nil)
-					manager.sessions.AdminBroadcast(event.SESSION_CURSORS, cursors, nil)
 				}
 			}
 		}()