From e1c966731991997b4b36c4a89403ded3f52d5b76 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=96=E7=95=8C?= <i@sekai.icu>
Date: Thu, 26 Mar 2026 16:03:46 +0800
Subject: [PATCH] Revert "fix(ocm): send rate limit status immediately on
 WebSocket connect"

This reverts commit 6721dff48a558750270b0d1804c217e9f126b648.
---
 service/ocm/service_websocket.go | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/service/ocm/service_websocket.go b/service/ocm/service_websocket.go
index 4f76179ef..4c552cbf5 100644
--- a/service/ocm/service_websocket.go
+++ b/service/ocm/service_websocket.go
@@ -570,11 +570,8 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn
 	}
 	defer s.statusObserver.UnSubscribe(subscription)
 
-	last := s.computeAggregatedUtilization(provider, userConfig)
-	err = writeWebSocketAggregatedStatus(clientConn, clientWriteAccess, last)
-	if err != nil {
-		return
-	}
+	var last aggregatedStatus
+	hasLast := false
 
 	for {
 		select {
@@ -585,6 +582,13 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn
 		case <-sessionClosed:
 			return
 		case <-firstRealRequest:
+			current := s.computeAggregatedUtilization(provider, userConfig)
+			err = writeWebSocketAggregatedStatus(clientConn, clientWriteAccess, current)
+			if err != nil {
+				return
+			}
+			last = current
+			hasLast = true
 			firstRealRequest = nil
 		case <-subscription:
 			for {
@@ -595,6 +599,9 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn
 				}
 			}
 		drained:
+			if !hasLast {
+				continue
+			}
 			current := s.computeAggregatedUtilization(provider, userConfig)
 			if current.equal(last) {
 				continue