xevent cursor change.

internal/desktop/manager.go

@@ -11,6 +11,7 @@ import (
 
 	"demodesk/neko/internal/config"
 	"demodesk/neko/internal/desktop/xorg"
+	"demodesk/neko/internal/desktop/xevent"
 )
 
 var mu = sync.Mutex{}
@@ -50,6 +51,8 @@ func (manager *DesktopManagerCtx) Start() {
 		manager.logger.Warn().Err(err).Msg("unable to set initial screen size")
 	}
 
+	go xevent.EventLoop(manager.display)
+
 	go func() {
 		defer func() {
 			xorg.DisplayClose()

internal/desktop/xevent.go

@@ -0,0 +1,13 @@
+package desktop
+
+import (
+	"demodesk/neko/internal/desktop/xevent"
+)
+
+func (manager *DesktopManagerCtx) OnCursorChanged(listener func(serial uint64)) {
+	xevent.OnCursorChanged(listener)
+}
+
+func (manager *DesktopManagerCtx) OnEventError(listener func(error_code uint8, message string, request_code uint8, minor_code uint8)) {
+	xevent.OnEventError(listener)
+}

internal/types/desktop.go

@@ -42,6 +42,10 @@ type DesktopManager interface {
 	SetKeyboardModifiers(NumLock int, CapsLock int, ScrollLock int)
 	GetCursorImage() *CursorImage
 
+	// xevent
+	OnCursorChanged(listener func(serial uint64))
+	OnEventError(listener func(error_code uint8, message string, request_code uint8, minor_code uint8))
+
 	// clipboard
 	ReadClipboard() string
 	WriteClipboard(data string)

internal/websocket/manager.go

@@ -99,26 +99,15 @@ func (ws *WebSocketManagerCtx) Start() {
 		}
 	})
 
-	go func() {
+	// TOOD: Throttle events.
-		ws.logger.Info().Msg("clipboard loop started")
+	ws.desktop.OnCursorChanged(func(serial uint64) {
-
-		defer func() {
-			ws.logger.Info().Msg("clipboard loop stopped")
-		}()
-
-		current := ws.desktop.ReadClipboard()
-		cursor := uint64(0)
-
-		for {
-			select {
-			case <-ws.shutdown:
-				return
-			default:
 		cur := ws.desktop.GetCursorImage()
-				if cursor != cur.Serial || cur.Serial == 0 {
+		uri, err := utils.GetCursorImageURI(cur)
-					cursor = cur.Serial
+		if err != nil {
+			ws.logger.Warn().Err(err).Msg("could create cursor image")
+			return
+		}
 
-					uri, _ := utils.GetCursorImageURI(cur)
 		ws.sessions.Broadcast(message.CursorImage{
 			Event:  event.CURSOR_IMAGE,
 			Uri:    uri,
@@ -127,8 +116,22 @@ func (ws *WebSocketManagerCtx) Start() {
 			X:      cur.Xhot,
 			Y:      cur.Yhot,
 		}, nil)
-				}
+	})
 
+	go func() {
+		ws.logger.Info().Msg("clipboard loop started")
+
+		defer func() {
+			ws.logger.Info().Msg("clipboard loop stopped")
+		}()
+
+		current := ws.desktop.ReadClipboard()
+
+		for {
+			select {
+			case <-ws.shutdown:
+				return
+			default:
 				session := ws.sessions.GetHost()
 				if session == nil {
 					break