delay sending request

This commit is contained in:
被遗忘的记忆
2024-08-30 09:34:30 +08:00
committed by GitHub
parent 42f4412ea8
commit 0b073a93d7
+13 -4
View File
@@ -784,8 +784,6 @@ class YouProvider {
req_param.append("use_personalization_extraction", "false"); req_param.append("use_personalization_extraction", "false");
req_param.append("domain", "youchat"); req_param.append("domain", "youchat");
req_param.append("mkt", "ja-JP"); req_param.append("mkt", "ja-JP");
const cid = `c0_${uuidV4()}`;
await page.goto(`https://you.com/search?q=${encodeURIComponent(userQuery)}&fromSearchBar=true&tbm=youchat&chatMode=custom&cid=${cid}`, {waitUntil: "domcontentloaded"});
if (uploadedFile) if (uploadedFile)
req_param.append("userFiles", JSON.stringify([{ req_param.append("userFiles", JSON.stringify([{
user_filename: randomFileName, user_filename: randomFileName,
@@ -794,10 +792,21 @@ class YouProvider {
}])); }]));
req_param.append("chat", JSON.stringify(userMessage)); req_param.append("chat", JSON.stringify(userMessage));
const url = "https://you.com/api/streamingSearch?" + req_param.toString(); const url = "https://you.com/api/streamingSearch?" + req_param.toString();
console.log("正在发送请求"); const cid = `c0_${uuidV4()}`;
emitter.emit("start", traceId); await page.goto(`https://you.com/search?q=${encodeURIComponent(userQuery)}&fromSearchBar=true&tbm=youchat&chatMode=custom&cid=${cid}`, {waitUntil: "domcontentloaded"});
// 延迟发送请求 Promise
const delayedRequest = new Promise((resolve) => {
setTimeout(() => {
console.log("正在发送请求");
emitter.emit("start", traceId);
resolve();
}, 2000); // 2秒延迟
});
try { try {
await delayedRequest;
await page.evaluate( await page.evaluate(
async (url, traceId, customEndMarker) => { async (url, traceId, customEndMarker) => {
function checkEndMarker(response, marker) { function checkEndMarker(response, marker) {