From 3bc74b1ce56f9f62023b1346592cd23e0e3f23a2 Mon Sep 17 00:00:00 2001
From: Siyuan Miao <i@xswan.net>
Date: Thu, 28 Aug 2025 23:11:37 +0200
Subject: [PATCH] add log for rpc queue

---
 webrtc.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/webrtc.go b/webrtc.go
index 1d4dd94..d4f1c17 100644
--- a/webrtc.go
+++ b/webrtc.go
@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"net"
 	"strings"
+	"time"
 
 	"github.com/coder/websocket"
 	"github.com/coder/websocket/wsjson"
@@ -110,7 +111,9 @@ func newSession(config SessionConfig) (*Session, error) {
 	session.rpcQueue = make(chan webrtc.DataChannelMessage, 256)
 	go func() {
 		for msg := range session.rpcQueue {
+			start := time.Now()
 			onRPCMessage(msg, session)
+			scopedLogger.Info().Dur("duration", time.Since(start)).Interface("msg", msg).Msg("RPC message processed")
 		}
 	}()
 
@@ -121,6 +124,7 @@ func newSession(config SessionConfig) (*Session, error) {
 			session.RPCChannel = d
 			d.OnMessage(func(msg webrtc.DataChannelMessage) {
 				// Enqueue to ensure ordered processing
+				scopedLogger.Info().Interface("msg", msg).Msg("Enqueuing RPC message")
 				session.rpcQueue <- msg
 			})
 			triggerOTAStateUpdate()