Function newRequest

src/request.ts:553–611

(
  incoming: IncomingMessage | Http2ServerRequest,
  defaultHostname?: string
)

Object.setPrototypeOf(requestPrototype, Request.prototype)

export const newRequest = (
  incoming: IncomingMessage | Http2ServerRequest,
  defaultHostname?: string
) => {
  const req = Object.create(requestPrototype)
  req[incomingKey] = incoming
  req[methodKey] = normalizeIncomingMethod(incoming.method)

  const incomingUrl = incoming.url || ''

  // handle absolute URL in request.url
  if (
    incomingUrl[0] !== '/' && // short-circuit for performance. most requests are relative URL.
    (incomingUrl.startsWith('http://') || incomingUrl.startsWith('https://'))
  ) {
    if (incoming instanceof Http2ServerRequest) {
      throw new RequestError('Absolute URL for :path is not allowed in HTTP/2') // RFC 9113 8.3.1.
    }

    try {
      const url = new URL(incomingUrl)
      req[urlKey] = url.href
    } catch (e) {
      throw new RequestError('Invalid absolute URL', { cause: e })
    }

    return req
  }

  // Otherwise, relative URL
  const host =
    (incoming instanceof Http2ServerRequest ? incoming.authority : incoming.headers.host) ||
    defaultHostname
  if (!host) {
    throw new RequestError('Missing host header')
  }

  let scheme: string
  if (incoming instanceof Http2ServerRequest) {
    scheme = incoming.scheme
    if (!(scheme === 'http' || scheme === 'https')) {
      throw new RequestError('Unsupported scheme')
    }
  } else {
    scheme = incoming.socket && (incoming.socket as TLSSocket).encrypted ? 'https' : 'http'
  }

  try {
    req[urlKey] = buildUrl(scheme, host, incomingUrl)
  } catch (e) {
    if (e instanceof RequestError) {
      throw e
    } else {
      throw new RequestError('Invalid URL', { cause: e })
    }
  }

  return req