Function request

electron/lib/request.ts:121–219

* 发起 HTTP/HTTPS 请求 * @param options - 请求选项或 URL 字符串 * @returns Promise 响应对象 * @example * // 基本用法 * const response = await request('https://api.example.com/data'); * const data = response.json(); * * // POST 请求 * const response = await request({ * url: 'https://api.example.com/u

(options: string | RequestOptions)

 * });
 */
async function request(options: string | RequestOptions): Promise<Response> {
  const config = normalizeOptions(options)

  return new Promise((resolve, reject) => {
    try {
      const req = net.request(config as ClientRequestConstructorOptions)

      // 设置请求头
      if (config.headers) {
        Object.keys(config.headers).forEach((key) => {
          req.setHeader(key, config.headers![key])
        })
      }

      // 超时处理
      let timeoutId: NodeJS.Timeout | null = null
      if (config.timeout && config.timeout > 0) {
        timeoutId = setTimeout(() => {
          req.abort()
          reject(new RequestError('Request timeout'))
        }, config.timeout)
      }

      // 处理响应
      req.on('response', (response: IncomingMessage) => {
        // 清除超时定时器
        if (timeoutId) {
          clearTimeout(timeoutId)
          timeoutId = null
        }

        let data = ''

        response.on('data', (chunk: Buffer) => {
          data += chunk.toString()
        })

        response.on('end', () => {
          const result: Response = {
            status: response.statusCode,
            statusText: response.statusMessage || '',
            headers: response.headers,
            data,
            ok: response.statusCode >= 200 && response.statusCode < 300,
            json: <T = any>(): T => {
              try {
                return JSON.parse(data) as T
              } catch (e) {
                throw new RequestError(
                  'Response body is not valid JSON',
                  response.statusCode,
                  result,
                )
              }
            },
            text: () => data,
          }