From 0dc1c1bf098d64fa484ef75531003006e39f29fb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=A2=AB=E9=81=97=E5=BF=98=E7=9A=84=E8=AE=B0=E5=BF=86?=
 <32097237+YIWANG-sketch@users.noreply.github.com>
Date: Fri, 13 Dec 2024 21:07:42 +0800
Subject: [PATCH] adjust heartbeat

---
 you_providers/youProvider.mjs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/you_providers/youProvider.mjs b/you_providers/youProvider.mjs
index 10e3bc5..19fe0c9 100644
--- a/you_providers/youProvider.mjs
+++ b/you_providers/youProvider.mjs
@@ -600,7 +600,7 @@ class YouProvider {
         }
 
         await page.goto("https://you.com", {waitUntil: 'domcontentloaded'});
-        await sleep(3000);
+        await sleep(2000);
 
         //打印messages完整结构
         // console.log(messages);
@@ -962,7 +962,7 @@ class YouProvider {
         let buffer = '';
         let clientPointer = 0; // 客户端指针
         let proxyPointer = 0;  // 反代指针
-        let heartbeatInterval = null;
+        let heartbeatInterval = null; // 心跳计时器
         const self = this;
         page.exposeFunction("callback" + traceId, async (event, data) => {
             if (isEnding) return;
@@ -986,6 +986,7 @@ class YouProvider {
 
                     if (!responseStarted) {
                         responseStarted = true;
+
                         startTime = Date.now();
                         clearTimeout(responseTimeout);
                         // 自定义终止符延迟触发
@@ -1096,7 +1097,6 @@ class YouProvider {
                     finalResponse += ` (${errorMessage})`;
                     isEnding = true;
                     setTimeout(async () => {
-                        ``
                         await cleanup();
                         emitter.emit("end", traceId);
                     }, 1000);
@@ -1424,12 +1424,12 @@ class YouProvider {
             if (stream) {
                 heartbeatInterval = setInterval(() => {
                     if (!isEnding && !clientState.isClosed()) {
-                        emitter.emit("completion", traceId, "");
+                        emitter.emit("completion", traceId, " ");
                     } else {
                         clearInterval(heartbeatInterval);
                         heartbeatInterval = null;
                     }
-                }, 10000);
+                }, 5000);
             }
 
             // 初始执行 setupEventSource