Spaces:

Reflectus
/

iper

Sleeping

App Files Files Community

GeminiBot commited on 14 days ago

Commit

3727a06

1 Parent(s): 2b6b3cb

Implement strict sequencer: start requests every 300ms to mimic human flow and avoid IP bans

Browse files

Files changed (1) hide show

src/duckai.ts +27 -59

src/duckai.ts CHANGED Viewed

@@ -3,53 +3,32 @@ import { createHash } from "node:crypto";
 import { Buffer } from "node:buffer";
 import UserAgent from "user-agents";
 let activeRequests = 0;
-const MAX_CONCURRENT_CHATS = 30; // Увеличиваем до 30 для плотного потока
-const requestQueue: (() => void)[] = [];
-// Переменные для контроля темпа (Rate Limit)
-let lastStartTime = 0;
-const MIN_START_INTERVAL = 150; // Начинать новый запрос каждые 150мс (~6.6 зап/сек)
 export class DuckAI {
-  // Ожидание слота + соблюдение темпа
-  private async acquireSlot(reqId: string): Promise<void> {
-      // 1. Ждем свободный слот из 20
-      if (activeRequests >= MAX_CONCURRENT_CHATS) {
-          console.log(`[${reqId}] [Queue] All slots full (${activeRequests}). Waiting...`);
-          await new Promise((resolve) => requestQueue.push(() => resolve()));
-      }
-      activeRequests++;
-      // 2. Соблюдаем темп старта (чтобы не пугать DDG всплесками)
       const now = Date.now();
-      const timeSinceLastStart = now - lastStartTime;
-      const wait = Math.max(0, MIN_START_INTERVAL - timeSinceLastStart);
-      lastStartTime = now + wait; // Бронируем время старта
-      if (wait > 0) {
-          // console.log(`[${reqId}] [Queue] Pacing: waiting ${wait}ms...`);
-          await new Promise(r => setTimeout(r, wait));
-      }
-  }
-  private releaseSlot() {
-      activeRequests--;
-      if (requestQueue.length > 0) {
-          const next = requestQueue.shift();
-          if (next) next();
       }
   }
   private async solveChallenge(vqdHash: string, reqId: string): Promise<string> {
-    const start = Date.now();
-    const memBefore = process.memoryUsage().heapUsed / 1024 / 1024;
     try {
         const jsScript = Buffer.from(vqdHash, 'base64').toString('utf-8');
         const dom = new JSDOM(
           `<iframe id="jsa" sandbox="allow-scripts allow-same-origin" srcdoc="<!DOCTYPE html>
     <html>
@@ -91,17 +70,17 @@ export class DuckAI {
         dom.window.close();
         return solved;
     } catch (e: any) {
-        console.error(`[${reqId}] [Challenge] ERROR: ${e.message}`);
-        throw e;
     }
   }
   async chat(request: any): Promise<string> {
     const reqId = Math.random().toString(36).substring(7).toUpperCase();
-    // Плавный вход в систему
-    await this.acquireSlot(reqId);
     const startTime = Date.now();
     const userAgent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36';
     const headers = {
@@ -112,29 +91,18 @@ export class DuckAI {
     };
     try {
-        console.log(`[${reqId}] [Chat] START (Active: ${activeRequests}, Queued: ${requestQueue.length})`);
-        let hashHeader = null;
-        let statusAttempt = 0;
-        while (!hashHeader && statusAttempt < 2) {
-            const statusRes = await fetch("https://duckduckgo.com/duckchat/v1/status?q=1", { headers });
-            hashHeader = statusRes.headers.get("x-vqd-hash-1");
-            if (!hashHeader) {
-                if (statusRes.status === 429) {
-                    await new Promise(r => setTimeout(r, 1000));
-                } else {
-                    throw new Error(`Status ${statusRes.status}: No VQD`);
-                }
-            }
-            statusAttempt++;
-        }
-        if (!hashHeader) throw new Error("Failed VQD after retries");
         const solvedVqd = await this.solveChallenge(hashHeader, reqId);
         const response = await fetch("https://duckduckgo.com/duckchat/v1/chat", {
             method: "POST",
             headers: { ...headers, "Content-Type": "application/json", "x-vqd-hash-1": solvedVqd },
@@ -167,9 +135,9 @@ export class DuckAI {
         console.error(`[${reqId}] [Chat] FAILED: ${error.message}`);
         throw error;
     } finally {
-        this.releaseSlot();
     }
   }
   getAvailableModels() { return ["gpt-4o-mini", "gpt-5-mini", "openai/gpt-oss-120b"]; }
-}

 import { Buffer } from "node:buffer";
 import UserAgent from "user-agents";
+// Глобальное управление потоком
 let activeRequests = 0;
+const MAX_CONCURRENT = 50; // Сколько всего запросов может "висеть" одновременно
+let lastRequestStartTime = 0;
+const MIN_GAP_MS = 300; // ЖЕСТКИЙ ИНТЕРВАЛ: 3.3 запроса в секунду (безопасный порог для одного IP)
 export class DuckAI {
+  // Функция "Диспетчер" - гарантирует, что запросы стартуют строго по очереди с паузой
+  private async waitInQueue(reqId: string): Promise<void> {
       const now = Date.now();
+      // Вычисляем, когда этому запросу разрешено стартовать
+      const targetStartTime = Math.max(now, lastRequestStartTime + MIN_GAP_MS);
+      lastRequestStartTime = targetStartTime;
+      const waitTime = targetStartTime - now;
+      if (waitTime > 0) {
+          // console.log(`[${reqId}] [Queue] Waiting ${waitTime}ms to maintain pace...`);
+          await new Promise(r => setTimeout(r, waitTime));
       }
   }
   private async solveChallenge(vqdHash: string, reqId: string): Promise<string> {
     try {
         const jsScript = Buffer.from(vqdHash, 'base64').toString('utf-8');
         const dom = new JSDOM(
           `<iframe id="jsa" sandbox="allow-scripts allow-same-origin" srcdoc="<!DOCTYPE html>
     <html>
         dom.window.close();
         return solved;
     } catch (e: any) {
+        throw new Error(`Challenge Failed: ${e.message}`);
     }
   }
   async chat(request: any): Promise<string> {
     const reqId = Math.random().toString(36).substring(7).toUpperCase();
+    // 1. Становимся в очередь на старт
+    await this.waitInQueue(reqId);
+    activeRequests++;
     const startTime = Date.now();
     const userAgent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36';
     const headers = {
     };
     try {
+        console.log(`[${reqId}] [Chat] EXECUTING (Parallel: ${activeRequests})`);
+        // Получаем токен
+        const statusRes = await fetch("https://duckduckgo.com/duckchat/v1/status?q=1", { headers });
+        const hashHeader = statusRes.headers.get("x-vqd-hash-1");
+        if (!hashHeader) throw new Error(`Status ${statusRes.status}: No VQD`);
+        // Решаем капчу
         const solvedVqd = await this.solveChallenge(hashHeader, reqId);
+        // Сам запрос
         const response = await fetch("https://duckduckgo.com/duckchat/v1/chat", {
             method: "POST",
             headers: { ...headers, "Content-Type": "application/json", "x-vqd-hash-1": solvedVqd },
         console.error(`[${reqId}] [Chat] FAILED: ${error.message}`);
         throw error;
     } finally {
+        activeRequests--;
     }
   }
   getAvailableModels() { return ["gpt-4o-mini", "gpt-5-mini", "openai/gpt-oss-120b"]; }
+}