new: add debouncer for sending proxy info

Author: hiddify-com

v2/hcore/debouncer.go

@@ -0,0 +1,37 @@
+package hcore
+
+import (
+	"time"
+)
+
+type Debouncer struct {
+	delay time.Duration
+	timer *time.Timer
+}
+
+func NewDebouncer(d time.Duration) *Debouncer {
+	t := time.NewTimer(d)
+	t.Stop()
+	return &Debouncer{
+		delay: d,
+		timer: t,
+	}
+}
+
+func (d *Debouncer) Hit() {
+	if !d.timer.Stop() {
+		select {
+		case <-d.timer.C:
+		default:
+		}
+	}
+	d.timer.Reset(d.delay)
+}
+
+func (d *Debouncer) C() <-chan time.Time {
+	return d.timer.C
+}
+
+func (d *Debouncer) Stop() {
+	d.timer.Stop()
+}

v2/hcore/proxy_info.go

@@ -2,6 +2,7 @@ package hcore
 
 import (
 	"strings"
+	"time"
 
 	hcommon "github.com/hiddify/hiddify-core/v2/hcommon"
 	"github.com/sagernet/sing-box/adapter"
@@ -130,29 +131,31 @@ func (h *HiddifyInstance) AllProxiesInfoStream(stream grpc.ServerStreamingServer
 			return err
 		}
 		stream.Send(h.GetAllProxiesInfo(onlyMain))
+		debouncer := NewDebouncer(500 * time.Millisecond)
+		defer debouncer.Stop()
+
 		for {
-		debounce:
-			for {
-				select {
-				case <-urltestch:
-				default:
-					break debounce
+			select {
+			case u := <-urltestch:
+				if u == 2 {
+					stream.Send(h.GetAllProxiesInfo(onlyMain))
+				} else {
+					debouncer.Hit()
+				}
+
+			case <-debouncer.C():
+				if err := stream.Send(h.GetAllProxiesInfo(onlyMain)); err != nil {
+					return err
 				}
-			}
 
-			select {
 			case <-stream.Context().Done():
 				return nil
 			case <-ctx.Done():
 				return nil
 			case <-done:
 				return nil
-			// case <-time.After(5000 * time.Millisecond):
-			case <-urltestch:
-				stream.Send(h.GetAllProxiesInfo(onlyMain))
 			}
 		}
-
 	}
 	return nil
 }