deps: update undici to 5.21.0

PR-URL: #47063
Reviewed-By: Filip Skokan <panva.ip@gmail.com>
Reviewed-By: Yagiz Nizipli <yagiz@nizipli.com>
Reviewed-By: Mohammed Keyvanzadeh <mohammadkeyvanzade94@gmail.com>

Author: nodejs-github-bot

deps/undici/src/README.md

@@ -407,7 +407,7 @@ Refs: https://fetch.spec.whatwg.org/#atomic-http-redirect-handling
 
 ## Workarounds
 
-###Network address family autoselection.
+###Network address family autoselection.
 
 If you experience problem when connecting to a remote server that is resolved by your DNS servers to a IPv6 (AAAA record)
 first, there are chances that your local router or ISP might have problem connecting to IPv6 networks. In that case

deps/undici/src/docs/api/ProxyAgent.md

@@ -19,6 +19,7 @@ Extends: [`AgentOptions`](Agent.md#parameter-agentoptions)
 ***uri**`string` (required) - It can be passed either by a string or a object containing `uri` as string.
 ***token**`string` (optional) - It can be passed by a string of token for authentication.
 ***auth**`string` (**deprecated**) - Use token.
+***clientFactory**`(origin: URL, opts: Object) => Dispatcher` - Default: `(origin, opts) => new Pool(origin, opts)`
 
 Examples:
 
@@ -83,7 +84,8 @@ import { setGlobalDispatcher, request, ProxyAgent } from 'undici';
 
 constproxyAgent=newProxyAgent({
  uri:'my.proxy.server',
- token:'Bearer xxxx'
+// token: 'Bearer xxxx'
+ token:`Basic ${Buffer.from('username:password').toString('base64')}`
 });
 setGlobalDispatcher(proxyAgent);
 

deps/undici/src/lib/api/api-stream.js

@@ -1,10 +1,11 @@
 'use strict'
 
-const{ finished }=require('stream')
+const{ finished, PassThrough}=require('stream')
 const{
  InvalidArgumentError,
  InvalidReturnValueError,
- RequestAbortedError
+ RequestAbortedError,
+ ResponseStatusCodeError
 }=require('../core/errors')
 constutil=require('../core/util')
 const{ AsyncResource }=require('async_hooks')
@@ -16,7 +17,7 @@ class StreamHandler extends AsyncResource {
 thrownewInvalidArgumentError('invalid opts')
 }
 
-const{ signal, method, opaque, body, onInfo, responseHeaders }=opts
+const{ signal, method, opaque, body, onInfo, responseHeaders, throwOnError}=opts
 
 try{
 if(typeofcallback!=='function'){
@@ -57,6 +58,7 @@ class StreamHandler extends AsyncResource {
 this.trailers=null
 this.body=body
 this.onInfo=onInfo||null
+this.throwOnError=throwOnError||false
 
 if(util.isStream(body)){
 body.on('error',(err)=>{
@@ -76,8 +78,8 @@ class StreamHandler extends AsyncResource {
 this.context=context
 }
 
-onHeaders(statusCode,rawHeaders,resume){
-const{ factory, opaque, context }=this
+onHeaders(statusCode,rawHeaders,resume,statusMessage){
+const{ factory, opaque, context, callback}=this
 
 if(statusCode<200){
 if(this.onInfo){
@@ -96,6 +98,32 @@ class StreamHandler extends AsyncResource {
  context
 })
 
+if(this.throwOnError&&statusCode>=400){
+constheaders=this.responseHeaders==='raw' ? util.parseRawHeaders(rawHeaders) : util.parseHeaders(rawHeaders)
+constchunks=[]
+constpt=newPassThrough()
+pt
+.on('data',(chunk)=>chunks.push(chunk))
+.on('end',()=>{
+constpayload=Buffer.concat(chunks).toString('utf8')
+this.runInAsyncScope(
+callback,
+null,
+newResponseStatusCodeError(
+`Response status code ${statusCode}${statusMessage ? `: ${statusMessage}` : ''}`,
+statusCode,
+headers,
+payload
+)
+)
+})
+.on('error',(err)=>{
+this.onError(err)
+})
+this.res=pt
+return
+}
+
 if(
 !res||
 typeofres.write!=='function'||

deps/undici/src/lib/api/readable.js

@@ -4,7 +4,7 @@
 
 constassert=require('assert')
 const{ Readable }=require('stream')
-const{ RequestAbortedError, NotSupportedError }=require('../core/errors')
+const{ RequestAbortedError, NotSupportedError, InvalidArgumentError}=require('../core/errors')
 constutil=require('../core/util')
 const{ ReadableStreamFrom, toUSVString }=require('../core/util')
 
@@ -146,15 +146,31 @@ module.exports = class BodyReadable extends Readable {
 
 asyncdump(opts){
 letlimit=opts&&Number.isFinite(opts.limit) ? opts.limit : 262144
+constsignal=opts&&opts.signal
+constabortFn=()=>{
+this.destroy()
+}
+if(signal){
+if(typeofsignal!=='object'||!('aborted'insignal)){
+thrownewInvalidArgumentError('signal must be an AbortSignal')
+}
+util.throwIfAborted(signal)
+signal.addEventListener('abort',abortFn,{once: true})
+}
 try{
 forawait(constchunkofthis){
+util.throwIfAborted(signal)
 limit-=Buffer.byteLength(chunk)
 if(limit<0){
 return
 }
 }
 }catch{
-// Do nothing...
+util.throwIfAborted(signal)
+}finally{
+if(signal){
+signal.removeEventListener('abort',abortFn)
+}
 }
 }
 }

deps/undici/src/lib/client.js

@@ -1,3 +1,5 @@
+// @ts-check
+
 'use strict'
 
 /* global WebAssembly */
@@ -85,7 +87,15 @@ try {
 channels.connected={hasSubscribers: false}
 }
 
+/**
+ * @type {import('../types/client').default}
+ */
 classClientextendsDispatcherBase{
+/**
+ *
+ * @param {string|URL} url
+ * @param {import('../types/client').Client.Options} options
+ */
 constructor(url,{
  interceptors,
  maxHeaderSize,
@@ -1658,6 +1668,8 @@ class AsyncWriter {
 process.emitWarning(newRequestContentLengthMismatchError())
 }
 
+socket.cork()
+
 if(bytesWritten===0){
 if(!expectsPayload){
 socket[kReset]=true
@@ -1678,6 +1690,8 @@ class AsyncWriter {
 
 constret=socket.write(chunk)
 
+socket.uncork()
+
 request.onBodySent(chunk)
 
 if(!ret){

deps/undici/src/lib/core/util.js

@@ -15,7 +15,7 @@ const [nodeMajor, nodeMinor] = process.versions.node.split('.').map(v => Number(
 functionnop(){}
 
 functionisStream(obj){
-returnobj&&typeofobj.pipe==='function'
+returnobj&&typeofobj==='object'&&typeofobj.pipe==='function'&&typeofobj.on==='function'
 }
 
 // based on https://github.com/node-fetch/fetch-blob/blob/8ab587d34080de94140b54f07168451e7d0b655e/index.js#L229-L241 (MIT License)
@@ -46,6 +46,12 @@ function buildURL (url, queryParams) {
 functionparseURL(url){
 if(typeofurl==='string'){
 url=newURL(url)
+
+if(!/^https?:/.test(url.origin||url.protocol)){
+thrownewInvalidArgumentError('invalid protocol')
+}
+
+returnurl
 }
 
 if(!url||typeofurl!=='object'){
@@ -375,23 +381,34 @@ function ReadableStreamFrom (iterable) {
 
 // The chunk should be a FormData instance and contains
 // all the required methods.
-functionisFormDataLike(chunk){
-return(chunk&&
-chunk.constructor&&chunk.constructor.name==='FormData'&&
-typeofchunk==='object'&&
-(typeofchunk.append==='function'&&
-typeofchunk.delete==='function'&&
-typeofchunk.get==='function'&&
-typeofchunk.getAll==='function'&&
-typeofchunk.has==='function'&&
-typeofchunk.set==='function'&&
-typeofchunk.entries==='function'&&
-typeofchunk.keys==='function'&&
-typeofchunk.values==='function'&&
-typeofchunk.forEach==='function')
+functionisFormDataLike(object){
+return(
+object&&
+typeofobject==='object'&&
+typeofobject.append==='function'&&
+typeofobject.delete==='function'&&
+typeofobject.get==='function'&&
+typeofobject.getAll==='function'&&
+typeofobject.has==='function'&&
+typeofobject.set==='function'&&
+object[Symbol.toStringTag]==='FormData'
 )
 }
 
+functionthrowIfAborted(signal){
+if(!signal){return}
+if(typeofsignal.throwIfAborted==='function'){
+signal.throwIfAborted()
+}else{
+if(signal.aborted){
+// DOMException not available < v17.0.0
+consterr=newError('The operation was aborted')
+err.name='AbortError'
+throwerr
+}
+}
+}
+
 constkEnumerableProperty=Object.create(null)
 kEnumerableProperty.enumerable=true
 
@@ -423,6 +440,7 @@ module.exports = {
  getSocketInfo,
  isFormDataLike,
  buildURL,
+ throwIfAborted,
  nodeMajor,
  nodeMinor,
 nodeHasAutoSelectFamily: nodeMajor>18||(nodeMajor===18&&nodeMinor>=13)

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

@@ -1,6 +1,5 @@
 constassert=require('assert')
 const{ atob }=require('buffer')
-const{ format }=require('url')
 const{ isValidHTTPToken, isomorphicDecode }=require('./util')
 
 constencoder=newTextEncoder()
@@ -118,7 +117,17 @@ function dataURLProcessor (dataURL) {
  * @param {boolean} excludeFragment
  */
 functionURLSerializer(url,excludeFragment=false){
-returnformat(url,{fragment: !excludeFragment})
+consthref=url.href
+
+if(!excludeFragment){
+returnhref
+}
+
+consthash=href.lastIndexOf('#')
+if(hash===-1){
+returnhref
+}
+returnhref.slice(0,hash)
 }
 
 // https://infra.spec.whatwg.org/#collect-a-sequence-of-code-points

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

@@ -297,7 +297,7 @@ function finalizeAndReportTiming (response, initiatorType = 'other') {
 // capability.
 // TODO: given global’s relevant settings object’s cross-origin isolated
 // capability?
-response.timingInfo.endTime=coarsenedSharedCurrentTime()
+timingInfo.endTime=coarsenedSharedCurrentTime()
 
 // 10. Set response’s timing info to timingInfo.
 response.timingInfo=timingInfo

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

@@ -9,7 +9,8 @@ const util = require('../core/util')
 const{
  isValidHTTPToken,
  sameOrigin,
- normalizeMethod
+ normalizeMethod,
+ makePolicyContainer
 }=require('./util')
 const{
  forbiddenMethods,
@@ -51,10 +52,14 @@ class Request {
 input=webidl.converters.RequestInfo(input)
 init=webidl.converters.RequestInit(init)
 
-// TODO
+// https://html.spec.whatwg.org/multipage/webappapis.html#environment-settings-object
 this[kRealm]={
 settingsObject: {
-baseUrl: getGlobalOrigin()
+baseUrl: getGlobalOrigin(),
+getorigin(){
+returnthis.baseUrl?.origin
+},
+policyContainer: makePolicyContainer()
 }
 }
 
@@ -349,14 +354,17 @@ class Request {
 if(signal.aborted){
 ac.abort(signal.reason)
 }else{
-constacRef=newWeakRef(ac)
 constabort=function(){
-acRef.deref()?.abort(this.reason)
+ac.abort(this.reason)
 }
 
-if(getEventListeners(signal,'abort').length>=defaultMaxListeners){
-setMaxListeners(100,signal)
-}
+// Third-party AbortControllers may not work with these.
+// See https://github.com/nodejs/undici/pull/1910#issuecomment-1464495619
+try{
+if(getEventListeners(signal,'abort').length>=defaultMaxListeners){
+setMaxListeners(100,signal)
+}
+}catch{}
 
 signal.addEventListener('abort',abort,{once: true})
 requestFinalizer.register(this,{ signal, abort })