From c837c43c3247ede46de2ea0655b957706ebe6c9d Mon Sep 17 00:00:00 2001
From: jmal <zhushilun084@gmail.com>
Date: Tue, 26 Mar 2024 14:19:02 +0800
Subject: [PATCH] chore: Optimize SSE connections

---
 src/sse/SSEClient.js | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/sse/SSEClient.js b/src/sse/SSEClient.js
index e1f7e8b..fcf84a6 100644
--- a/src/sse/SSEClient.js
+++ b/src/sse/SSEClient.js
@@ -1,4 +1,5 @@
 import Bus from "@/assets/js/bus";
+import _ from "lodash";
 import store from "@/store";
 import {generateUUID} from "ant-design-vue/lib/vc-select/util";
 
@@ -6,9 +7,11 @@ let eventSource = null;
 let timer = null;
 let lastHeartbeat = new Date().getTime();
 
-export function connectToSSE(username) {
+const uuid = generateUUID();
+
+const throttledConnectSSE = _.throttle(username => {
   if (typeof (EventSource) !== 'undefined') {
-    const url = `/api/events?username=${username}&uuid=${generateUUID()}`;
+    const url = `/api/events?username=${username}&uuid=${uuid}`;
     eventSource = new EventSource(url);
     eventSource.addEventListener('message', function (event) {
       if (event.data === 'h') {
@@ -39,10 +42,13 @@ export function connectToSSE(username) {
         connectToSSE(username);
       }
     }, 3000);
-
   } else {
     console.error('EventSource is not supported by the browser');
   }
+}, 3000);
+
+export function connectToSSE(username) {
+  throttledConnectSSE(username);
 }
 
 function onMessage(msg) {