Method makeRequest

outdated/gemini/gemini.ts:428–519

(url: string, options: HttpRequestOptions = {})

  }

  static async makeRequest(url: string, options: HttpRequestOptions = {}): Promise<HttpResponse> {
    return new Promise((resolve, reject) => {
      try {
        const parsedUrl = new URL(url);
        if (!['http:', 'https:'].includes(parsedUrl.protocol)) {
          reject(new Error('不支持的协议'));
          return;
        }
      } catch {
        reject(new Error('无效的URL'));
        return;
      }

      const { method = 'GET', headers = {}, data, timeout = 30000 } = options;
      const isHttps = url.startsWith('https:');
      const client = isHttps ? https : http;
      
      const req = client.request(url, {
        method,
        headers: {
          'Content-Type': 'application/json',
          'User-Agent': 'TeleBox/1.0',
          ...headers
        },
        timeout
      }, (res: any) => {

        res.setEncoding('utf8');
        let body = '';
        let dataLength = 0;
        const maxResponseSize = 10 * 1024 * 1024;

        res.on('data', (chunk: string) => {
          dataLength += chunk.length;
          if (dataLength > maxResponseSize) {
            req.destroy();
            reject(new Error('响应数据过大'));
            return;
          }
          body += chunk;
        });
        
        res.on('end', () => {
          try {

            const cleanBody = HttpClient.cleanResponseText(body);
            const parsedData = cleanBody ? JSON.parse(cleanBody) : {};
            resolve({
              status: res.statusCode || 0,
              data: parsedData,
              headers: res.headers
            });
          } catch (error) {

            resolve({
              status: res.statusCode || 0,
              data: HttpClient.cleanResponseText(body),
              headers: res.headers