Revert "feat: Implement and integrate a `wreq-js` based TLS client for all network requests."

package-lock.json

@@ -1,20 +1,19 @@
 {
   "name": "antigravity-claude-proxy",
-  "version": "2.7.4",
+  "version": "2.5.0",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "antigravity-claude-proxy",
-      "version": "2.7.4",
+      "version": "2.5.0",
       "license": "MIT",
       "dependencies": {
         "async-mutex": "^0.5.0",
         "better-sqlite3": "^12.5.0",
         "cors": "^2.8.5",
         "express": "^4.18.2",
-        "undici": "^7.20.0",
-        "wreq-js": "^2.0.1"
+        "undici": "^7.20.0"
       },
       "bin": {
         "antigravity-claude-proxy": "bin/cli.js"
@@ -2823,24 +2822,6 @@
       "integrity": "sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ==",
       "license": "ISC"
     },
-    "node_modules/wreq-js": {
-      "version": "2.0.1",
-      "resolved": "https://registry.npmjs.org/wreq-js/-/wreq-js-2.0.1.tgz",
-      "integrity": "sha512-7GcZpzVtRX/A5pqu2QXTcqKTiYJZZRIRiosJ94GT1+taQivysZmjvkwzk8IvLz1oE1P1rGWG8ujDLCYxusM1aQ==",
-      "cpu": [
-        "x64",
-        "arm64"
-      ],
-      "license": "MIT",
-      "os": [
-        "darwin",
-        "linux",
-        "win32"
-      ],
-      "engines": {
-        "node": ">=20.0.0"
-      }
-    },
     "node_modules/y18n": {
       "version": "5.0.8",
       "resolved": "https://registry.npmjs.org/y18n/-/y18n-5.0.8.tgz",

package.json

@@ -63,8 +63,7 @@
     "better-sqlite3": "^12.5.0",
     "cors": "^2.8.5",
     "express": "^4.18.2",
-    "undici": "^7.20.0",
-    "wreq-js": "^2.0.1"
+    "undici": "^7.20.0"
   },
   "devDependencies": {
     "@tailwindcss/forms": "^0.5.7",

src/index.js

@@ -12,7 +12,6 @@ import { logger } from './utils/logger.js';
 import { config } from './config.js';
 import { getStrategyLabel, STRATEGY_NAMES, DEFAULT_STRATEGY } from './account-manager/strategies/index.js';
 import { getPackageVersion } from './utils/helpers.js';
-import tlsClient from './utils/tls-client.js';
 import path from 'path';
 import os from 'os';
 
@@ -160,15 +159,8 @@ ${environmentSection}
 });
 
 // Graceful shutdown
-const shutdown = async () => {
+const shutdown = () => {
     logger.info('Shutting down server...');
-
-    try {
-        await tlsClient.exit();
-    } catch (err) {
-        logger.error('Error shutting down TLS client:', err);
-    }
-
     server.close(() => {
         logger.success('Server stopped');
         process.exit(0);

src/utils/helpers.js

@@ -2,7 +2,6 @@ import { readFileSync } from 'fs';
 import { fileURLToPath } from 'url';
 import path from 'path';
 import { config } from '../config.js';
-import tlsClient from './tls-client.js';
 
 /**
  * Shared Utility Functions
@@ -87,7 +86,7 @@ export async function throttledFetch(url, options) {
             await sleep(delayMs);
         }
     }
-    return tlsClient.fetch(url, options);
+    return fetch(url, options);
 }
 
 /**

src/utils/tls-client.js

@@ -1,102 +0,0 @@
-import { createRequire } from 'module';
-import { Readable } from 'stream';
-import { getPlatformUserAgent } from '../constants.js';
-
-const require = createRequire(import.meta.url);
-const { createSession } = require('wreq-js');
-
-class TlsClient {
-    constructor() {
-        this.userAgent = getPlatformUserAgent();
-        this.session = null;
-    }
-
-    async getSession() {
-        if (this.session) return this.session;
-        this.session = await createSession({
-            browser: 'chrome_124',
-            os: 'macos',
-            userAgent: this.userAgent
-        });
-        return this.session;
-    }
-
-    async fetch(url, options = {}) {
-        const session = await this.getSession();
-        const method = (options.method || 'GET').toUpperCase();
-
-        const wreqOptions = {
-            method,
-            headers: options.headers,
-            body: options.body,
-            redirect: options.redirect === 'manual' ? 'manual' : 'follow',
-        };
-
-        try {
-            const response = await session.fetch(url, wreqOptions);
-            return new ResponseWrapper(response);
-        } catch (error) {
-            console.error('wreq-js fetch failed:', error);
-            throw error;
-        }
-    }
-
-    async exit() {
-        if (this.session) {
-            await this.session.close();
-            this.session = null;
-        }
-    }
-}
-
-class ResponseWrapper {
-    constructor(wreqResponse) {
-        this.status = wreqResponse.status;
-        this.statusText = wreqResponse.statusText || (this.status === 200 ? 'OK' : `Status ${this.status}`);
-        this.headers = new Headers(wreqResponse.headers);
-        this.url = wreqResponse.url;
-        this.ok = this.status >= 200 && this.status < 300;
-
-        if (wreqResponse.body) {
-            if (typeof wreqResponse.body.getReader === 'function') {
-                this.body = wreqResponse.body;
-            } else {
-                this.body = Readable.toWeb(wreqResponse.body);
-            }
-        } else {
-            this.body = null;
-        }
-    }
-
-    async text() {
-        if (!this.body) return '';
-        const reader = this.body.getReader();
-        const chunks = [];
-        while (true) {
-            const { done, value } = await reader.read();
-            if (done) break;
-            chunks.push(typeof value === 'string' ? Buffer.from(value) : value);
-        }
-        return Buffer.concat(chunks).toString('utf8');
-    }
-
-    async json() {
-        const text = await this.text();
-        return JSON.parse(text);
-    }
-}
-
-class Headers {
-    constructor(headersObj = {}) {
-        this.map = new Map();
-        for (const [key, value] of Object.entries(headersObj)) {
-            this.map.set(key.toLowerCase(), Array.isArray(value) ? value.join(', ') : value);
-        }
-    }
-
-    get(name) { return this.map.get(name.toLowerCase()) || null; }
-    has(name) { return this.map.has(name.toLowerCase()); }
-    forEach(callback) { this.map.forEach(callback); }
-}
-
-export default new TlsClient();