deps: update undici to 5.27.0

nodejs · nodejs-github-bot · Oct 31, 2023 · Oct 29, 2023 · Oct 29, 2023 · 68c13f20a47c7648f9f885aabdcfe1ce823cd206
commit 68c13f20a47c7648f9f885aabdcfe1ce823cd206
diff --git a/deps/undici/src/index-fetch.js b/deps/undici/src/index-fetch.js
@@ -2,13 2,11 @@
 
 const fetchImpl = require('./lib/fetch').fetch
 
-module.exports.fetch = async function fetch (resource, init = undefined) {
- try {
- return await fetchImpl(resource, init)
- } catch (err) {
 module.exports.fetch = function fetch (resource, init = undefined) {
  return fetchImpl(resource, init).catch((err) => {
  Error.captureStackTrace(err, this)
  throw err
- }
  })
 }
 module.exports.FormData = require('./lib/fetch/formdata').FormData
 module.exports.Headers = require('./lib/fetch/headers').Headers

diff --git a/deps/undici/src/lib/core/request.js b/deps/undici/src/lib/core/request.js
@@ -222,6 222,14 @@ class Request {
  if (channels.bodySent.hasSubscribers) {
  channels.bodySent.publish({ request: this })
  }
 
  if (this[kHandler].onRequestSent) {
  try {
  this[kHandler].onRequestSent()
  } catch (err) {
  this.onError(err)
  }
  }
  }
 
  onConnect (abort) {

diff --git a/deps/undici/src/lib/fetch/body.js b/deps/undici/src/lib/fetch/body.js
@@ -26,6 26,8 @@ let ReadableStream = globalThis.ReadableStream
 
 /** @type {globalThis['File']} */
 const File = NativeFile ?? UndiciFile
 const textEncoder = new TextEncoder()
 const textDecoder = new TextDecoder()
 
 // https://fetch.spec.whatwg.org/#concept-bodyinit-extract
 function extractBody (object, keepalive = false) {
@@ -49,7 51,7 @@ function extractBody (object, keepalive = false) {
  stream = new ReadableStream({
  async pull (controller) {
  controller.enqueue(
- typeof source === 'string' ? new TextEncoder().encode(source) : source
  typeof source === 'string' ? textEncoder.encode(source) : source
  )
  queueMicrotask(() => readableStreamClose(controller))
  },
@@ -119,21 121,20 @@ function extractBody (object, keepalive = false) {
  // - That the content-length is calculated in advance.
  // - And that all parts are pre-encoded and ready to be sent.
 
- const enc = new TextEncoder()
  const blobParts = []
  const rn = new Uint8Array([13, 10]) // '\r\n'
  length = 0
  let hasUnknownSizeValue = false
 
  for (const [name, value] of object) {
  if (typeof value === 'string') {
- const chunk = enc.encode(prefix 
  const chunk = textEncoder.encode(prefix 
  `; name="${escape(normalizeLinefeeds(name))}"` 
  `\r\n\r\n${normalizeLinefeeds(value)}\r\n`)
  blobParts.push(chunk)
  length = chunk.byteLength
  } else {
- const chunk = enc.encode(`${prefix}; name="${escape(normalizeLinefeeds(name))}"` 
  const chunk = textEncoder.encode(`${prefix}; name="${escape(normalizeLinefeeds(name))}"` 
  (value.name ? `; filename="${escape(value.name)}"` : '') '\r\n' 
  `Content-Type: ${
  value.type || 'application/octet-stream'
@@ -147,7 148,7 @@ function extractBody (object, keepalive = false) {
  }
  }
 
- const chunk = enc.encode(`--${boundary}--`)
  const chunk = textEncoder.encode(`--${boundary}--`)
  blobParts.push(chunk)
  length = chunk.byteLength
  if (hasUnknownSizeValue) {
@@ -443,14 444,16 @@ function bodyMixinMethods (instance) {
  let text = ''
  // application/x-www-form-urlencoded parser will keep the BOM.
  // https://url.spec.whatwg.org/#concept-urlencoded-parser
- const textDecoder = new TextDecoder('utf-8', { ignoreBOM: true })
  // Note that streaming decoder is stateful and cannot be reused
  const streamingDecoder = new TextDecoder('utf-8', { ignoreBOM: true })
 
  for await (const chunk of consumeBody(this[kState].body)) {
  if (!isUint8Array(chunk)) {
  throw new TypeError('Expected Uint8Array chunk')
  }
- text = textDecoder.decode(chunk, { stream: true })
  text = streamingDecoder.decode(chunk, { stream: true })
  }
- text = textDecoder.decode()
  text = streamingDecoder.decode()
  entries = new URLSearchParams(text)
  } catch (err) {
  // istanbul ignore next: Unclear when new URLSearchParams can fail on a string.
@@ -565,7 568,7 @@ function utf8DecodeBytes (buffer) {
 
  // 3. Process a queue with an instance of UTF-8’s
  // decoder, ioQueue, output, and "replacement".
- const output = new TextDecoder().decode(buffer)
  const output = textDecoder.decode(buffer)
 
  // 4. Return output.
  return output

diff --git a/deps/undici/src/lib/fetch/constants.js b/deps/undici/src/lib/fetch/constants.js
@@ -3,10 3,12 @@
 const { MessageChannel, receiveMessageOnPort } = require('worker_threads')
 
 const corsSafeListedMethods = ['GET', 'HEAD', 'POST']
 const corsSafeListedMethodsSet = new Set(corsSafeListedMethods)
 
 const nullBodyStatus = [101, 204, 205, 304]
 
 const redirectStatus = [301, 302, 303, 307, 308]
 const redirectStatusSet = new Set(redirectStatus)
 
 // https://fetch.spec.whatwg.org/#block-bad-port
 const badPorts = [
@@ -18,6 20,8 @@ const badPorts = [
  '10080'
 ]
 
 const badPortsSet = new Set(badPorts)
 
 // https://w3c.github.io/webappsec-referrer-policy/#referrer-policies
 const referrerPolicy = [
  '',
@@ -30,10 34,12 @@ const referrerPolicy = [
  'strict-origin-when-cross-origin',
  'unsafe-url'
 ]
 const referrerPolicySet = new Set(referrerPolicy)
 
 const requestRedirect = ['follow', 'manual', 'error']
 
 const safeMethods = ['GET', 'HEAD', 'OPTIONS', 'TRACE']
 const safeMethodsSet = new Set(safeMethods)
 
 const requestMode = ['navigate', 'same-origin', 'no-cors', 'cors']
 
@@ -68,6 74,7 @@ const requestDuplex = [
 
 // http://fetch.spec.whatwg.org/#forbidden-method
 const forbiddenMethods = ['CONNECT', 'TRACE', 'TRACK']
 const forbiddenMethodsSet = new Set(forbiddenMethods)
 
 const subresource = [
  'audio',
@@ -83,6 90,7 @@ const subresource = [
  'xslt',
  ''
 ]
 const subresourceSet = new Set(subresource)
 
 /** @type {globalThis['DOMException']} */
 const DOMException = globalThis.DOMException ?? (() => {
@@ -132,5 140,12 @@ module.exports = {
  nullBodyStatus,
  safeMethods,
  badPorts,
- requestDuplex
  requestDuplex,
  subresourceSet,
  badPortsSet,
  redirectStatusSet,
  corsSafeListedMethodsSet,
  safeMethodsSet,
  forbiddenMethodsSet,
  referrerPolicySet
 }
diff --git a/deps/undici/src/lib/fetch/file.js b/deps/undici/src/lib/fetch/file.js
@@ -7,6 7,7 @@ const { isBlobLike } = require('./util')
 const { webidl } = require('./webidl')
 const { parseMIMEType, serializeAMimeType } = require('./dataURL')
 const { kEnumerableProperty } = require('../core/util')
 const encoder = new TextEncoder()
 
 class File extends Blob {
  constructor (fileBits, fileName, options = {}) {
@@ -280,7 281,7 @@ function processBlobParts (parts, options) {
  }
 
  // 3. Append the result of UTF-8 encoding s to bytes.
- bytes.push(new TextEncoder().encode(s))
  bytes.push(encoder.encode(s))
  } else if (
  types.isAnyArrayBuffer(element) ||
  types.isTypedArray(element)