Function proxyHttp

yaml-flow-editor/vite.config.ts:294–351

(
    req: IncomingMessage,
    res: ServerResponse,
    targetUrl: string
  )

  }

  async function proxyHttp(
    req: IncomingMessage,
    res: ServerResponse,
    targetUrl: string
  ): Promise<void> {
    const method = (req.method || 'GET').toUpperCase()
    const body =
      method === 'GET' || method === 'HEAD' ? undefined : await readBody(req, 20 * 1024 * 1024)

    // Drop hop-by-hop headers; keep the rest.
    const headers: Record<string, string> = {}
    for (const [k, v] of Object.entries(req.headers)) {
      if (!v) continue
      const key = k.toLowerCase()
      if (
        key === 'host' ||
        key === 'connection' ||
        key === 'upgrade' ||
        key === 'proxy-connection' ||
        key === 'keep-alive' ||
        key === 'transfer-encoding' ||
        key === 'content-length' ||
        key === 'te' ||
        key === 'trailer'
      ) {
        continue
      }
      if (Array.isArray(v)) headers[k] = v.join(', ')
      else headers[k] = String(v)
    }

    const upstream = await fetch(targetUrl, {
      method,
      headers,
      body,
      redirect: 'manual',
    })

    res.statusCode = upstream.status
    upstream.headers.forEach((value, key) => {
      const lk = key.toLowerCase()
      if (lk === 'transfer-encoding') return
      res.setHeader(key, value)
    })

    if (!upstream.body) {
      res.end()
      return
    }

    const nodeStream = Readable.fromWeb(upstream.body as any)
    await new Promise<void>((resolve) => {
      nodeStream.on('error', () => resolve())
      res.on('close', () => resolve())
      nodeStream.pipe(res)
      nodeStream.on('end', () => resolve())
    })
  }