deps: update undici to 5.27.0

PR-URL: #50463
Reviewed-By: Matthew Aitken <maitken033380023@gmail.com>
Reviewed-By: Mohammed Keyvanzadeh <mohammadkeyvanzade94@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>

Author: nodejs-github-bot

deps/undici/src/index-fetch.js

@@ -2,13 +2,11 @@
 
 constfetchImpl=require('./lib/fetch').fetch
 
-module.exports.fetch=asyncfunctionfetch(resource,init=undefined){
-try{
-returnawaitfetchImpl(resource,init)
-}catch(err){
+module.exports.fetch=functionfetch(resource,init=undefined){
+returnfetchImpl(resource,init).catch((err)=>{
 Error.captureStackTrace(err,this)
 throwerr
-}
+})
 }
 module.exports.FormData=require('./lib/fetch/formdata').FormData
 module.exports.Headers=require('./lib/fetch/headers').Headers

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){

deps/undici/src/lib/fetch/body.js

@@ -26,6 +26,8 @@ let ReadableStream = globalThis.ReadableStream
 
 /** @type {globalThis['File']} */
 constFile=NativeFile??UndiciFile
+consttextEncoder=newTextEncoder()
+consttextDecoder=newTextDecoder()
 
 // https://fetch.spec.whatwg.org/#concept-bodyinit-extract
 functionextractBody(object,keepalive=false){
@@ -49,7 +51,7 @@ function extractBody (object, keepalive = false) {
 stream=newReadableStream({
 asyncpull(controller){
 controller.enqueue(
-typeofsource==='string' ? newTextEncoder().encode(source) : source
+typeofsource==='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.
 
-constenc=newTextEncoder()
 constblobParts=[]
 constrn=newUint8Array([13,10])// '\r\n'
 length=0
 lethasUnknownSizeValue=false
 
 for(const[name,value]ofobject){
 if(typeofvalue==='string'){
-constchunk=enc.encode(prefix+
+constchunk=textEncoder.encode(prefix+
 `; name="${escape(normalizeLinefeeds(name))}"`+
 `\r\n\r\n${normalizeLinefeeds(value)}\r\n`)
 blobParts.push(chunk)
 length+=chunk.byteLength
 }else{
-constchunk=enc.encode(`${prefix}; name="${escape(normalizeLinefeeds(name))}"`+
+constchunk=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) {
 }
 }
 
-constchunk=enc.encode(`--${boundary}--`)
+constchunk=textEncoder.encode(`--${boundary}--`)
 blobParts.push(chunk)
 length+=chunk.byteLength
 if(hasUnknownSizeValue){
@@ -445,14 +446,16 @@ function bodyMixinMethods (instance) {
 lettext=''
 // application/x-www-form-urlencoded parser will keep the BOM.
 // https://url.spec.whatwg.org/#concept-urlencoded-parser
-consttextDecoder=newTextDecoder('utf-8',{ignoreBOM: true})
+// Note that streaming decoder is stateful and cannot be reused
+conststreamingDecoder=newTextDecoder('utf-8',{ignoreBOM: true})
+
 forawait(constchunkofconsumeBody(this[kState].body)){
 if(!isUint8Array(chunk)){
 thrownewTypeError('Expected Uint8Array chunk')
 }
-text+=textDecoder.decode(chunk,{stream: true})
+text+=streamingDecoder.decode(chunk,{stream: true})
 }
-text+=textDecoder.decode()
+text+=streamingDecoder.decode()
 entries=newURLSearchParams(text)
 }catch(err){
 // istanbul ignore next: Unclear when new URLSearchParams can fail on a string.
@@ -567,7 +570,7 @@ function utf8DecodeBytes (buffer) {
 
 // 3. Process a queue with an instance of UTF-8’s
 // decoder, ioQueue, output, and "replacement".
-constoutput=newTextDecoder().decode(buffer)
+constoutput=textDecoder.decode(buffer)
 
 // 4. Return output.
 returnoutput

deps/undici/src/lib/fetch/constants.js

@@ -3,10 +3,12 @@
 const{ MessageChannel, receiveMessageOnPort }=require('worker_threads')
 
 constcorsSafeListedMethods=['GET','HEAD','POST']
+constcorsSafeListedMethodsSet=newSet(corsSafeListedMethods)
 
 constnullBodyStatus=[101,204,205,304]
 
 constredirectStatus=[301,302,303,307,308]
+constredirectStatusSet=newSet(redirectStatus)
 
 // https://fetch.spec.whatwg.org/#block-bad-port
 constbadPorts=[
@@ -18,6 +20,8 @@ const badPorts = [
 '10080'
 ]
 
+constbadPortsSet=newSet(badPorts)
+
 // https://w3c.github.io/webappsec-referrer-policy/#referrer-policies
 constreferrerPolicy=[
 '',
@@ -30,10 +34,12 @@ const referrerPolicy = [
 'strict-origin-when-cross-origin',
 'unsafe-url'
 ]
+constreferrerPolicySet=newSet(referrerPolicy)
 
 constrequestRedirect=['follow','manual','error']
 
 constsafeMethods=['GET','HEAD','OPTIONS','TRACE']
+constsafeMethodsSet=newSet(safeMethods)
 
 constrequestMode=['navigate','same-origin','no-cors','cors']
 
@@ -68,6 +74,7 @@ const requestDuplex = [
 
 // http://fetch.spec.whatwg.org/#forbidden-method
 constforbiddenMethods=['CONNECT','TRACE','TRACK']
+constforbiddenMethodsSet=newSet(forbiddenMethods)
 
 constsubresource=[
 'audio',
@@ -83,6 +90,7 @@ const subresource = [
 'xslt',
 ''
 ]
+constsubresourceSet=newSet(subresource)
 
 /** @type {globalThis['DOMException']} */
 constDOMException=globalThis.DOMException??(()=>{
@@ -132,5 +140,12 @@ module.exports = {
  nullBodyStatus,
  safeMethods,
  badPorts,
- requestDuplex
+ requestDuplex,
+ subresourceSet,
+ badPortsSet,
+ redirectStatusSet,
+ corsSafeListedMethodsSet,
+ safeMethodsSet,
+ forbiddenMethodsSet,
+ referrerPolicySet
 }

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')
+constencoder=newTextEncoder()
 
 classFileextendsBlob{
 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(newTextEncoder().encode(s))
+bytes.push(encoder.encode(s))
 }elseif(
 types.isAnyArrayBuffer(element)||
 types.isTypedArray(element)