deps: update undici to 6.18.2

PR-URL: #53255
Reviewed-By: Marco Ippolito <marcoippolito54@gmail.com>
Reviewed-By: Matthew Aitken <maitken033380023@gmail.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

Author: nodejs-github-bot

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

@@ -46,6 +46,9 @@ It represents the retry state for a given request.
 -**dispatch**`(options: Dispatch.DispatchOptions, handlers: Dispatch.DispatchHandlers) => Promise<Dispatch.DispatchResponse>` (required) - Dispatch function to be called after every retry.
 -**handler** Extends [`Dispatch.DispatchHandlers`](Dispatcher.md#dispatcherdispatchoptions-handler) (required) - Handler function to be called after the request is successful or the retries are exhausted.
 
+>__Note__: The `RetryHandler` does not retry over stateful bodies (e.g. streams, AsyncIterable) as those, once consumed, are left in an state that cannot be reutilized. For these situations the `RetryHandler` will identify
+>the body as stateful and will not retry the request rejecting with the error `UND_ERR_REQ_RETRY`.
+
 Examples:
 
 ```js

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

@@ -20,6 +20,7 @@ module.exports = {
 kHost: Symbol('host'),
 kNoRef: Symbol('no ref'),
 kBodyUsed: Symbol('used'),
+kBody: Symbol('abstracted request body'),
 kRunning: Symbol('running'),
 kBlocking: Symbol('blocking'),
 kPending: Symbol('pending'),

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

@@ -1,19 +1,72 @@
 'use strict'
 
 constassert=require('node:assert')
-const{ kDestroyed, kBodyUsed, kListeners }=require('./symbols')
+const{ kDestroyed, kBodyUsed, kListeners, kBody}=require('./symbols')
 const{ IncomingMessage }=require('node:http')
 conststream=require('node:stream')
 constnet=require('node:net')
-const{ InvalidArgumentError }=require('./errors')
 const{ Blob }=require('node:buffer')
 constnodeUtil=require('node:util')
 const{ stringify }=require('node:querystring')
+const{EventEmitter: EE}=require('node:events')
+const{ InvalidArgumentError }=require('./errors')
 const{ headerNameLowerCasedRecord }=require('./constants')
 const{ tree }=require('./tree')
 
 const[nodeMajor,nodeMinor]=process.versions.node.split('.').map(v=>Number(v))
 
+classBodyAsyncIterable{
+constructor(body){
+this[kBody]=body
+this[kBodyUsed]=false
+}
+
+async*[Symbol.asyncIterator](){
+assert(!this[kBodyUsed],'disturbed')
+this[kBodyUsed]=true
+yield*this[kBody]
+}
+}
+
+functionwrapRequestBody(body){
+if(isStream(body)){
+// TODO (fix): Provide some way for the user to cache the file to e.g. /tmp
+// so that it can be dispatched again?
+// TODO (fix): Do we need 100-expect support to provide a way to do this properly?
+if(bodyLength(body)===0){
+body
+.on('data',function(){
+assert(false)
+})
+}
+
+if(typeofbody.readableDidRead!=='boolean'){
+body[kBodyUsed]=false
+EE.prototype.on.call(body,'data',function(){
+this[kBodyUsed]=true
+})
+}
+
+returnbody
+}elseif(body&&typeofbody.pipeTo==='function'){
+// TODO (fix): We can't access ReadableStream internal state
+// to determine whether or not it has been disturbed. This is just
+// a workaround.
+returnnewBodyAsyncIterable(body)
+}elseif(
+body&&
+typeofbody!=='string'&&
+!ArrayBuffer.isView(body)&&
+isIterable(body)
+){
+// TODO: Should we allow re-using iterable if !this.opts.idempotent
+// or through some other flag?
+returnnewBodyAsyncIterable(body)
+}else{
+returnbody
+}
+}
+
 functionnop(){}
 
 functionisStream(obj){
@@ -634,5 +687,6 @@ module.exports = {
  isHttpOrHttpsPrefixed,
  nodeMajor,
  nodeMinor,
-safeHTTPMethods: ['GET','HEAD','OPTIONS','TRACE']
+safeHTTPMethods: ['GET','HEAD','OPTIONS','TRACE'],
+ wrapRequestBody
 }

deps/undici/src/lib/handler/retry-handler.js

@@ -3,7 +3,12 @@ const assert = require('node:assert')
 
 const{ kRetryHandlerDefaultRetry }=require('../core/symbols')
 const{ RequestRetryError }=require('../core/errors')
-const{ isDisturbed, parseHeaders, parseRangeHeader }=require('../core/util')
+const{
+ isDisturbed,
+ parseHeaders,
+ parseRangeHeader,
+ wrapRequestBody
+}=require('../core/util')
 
 functioncalculateRetryAfterHeader(retryAfter){
 constcurrent=Date.now()
@@ -29,7 +34,7 @@ class RetryHandler {
 
 this.dispatch=handlers.dispatch
 this.handler=handlers.handler
-this.opts=dispatchOpts
+this.opts={ ...dispatchOpts,body: wrapRequestBody(opts.body)}
 this.abort=null
 this.aborted=false
 this.retryOpts={
@@ -174,7 +179,9 @@ class RetryHandler {
 this.abort(
 newRequestRetryError('Request failed',statusCode,{
  headers,
-count: this.retryCount
+data: {
+count: this.retryCount
+}
 })
 )
 returnfalse
@@ -278,7 +285,7 @@ class RetryHandler {
 
 consterr=newRequestRetryError('Request failed',statusCode,{
  headers,
-count: this.retryCount
+data: {count: this.retryCount}
 })
 
 this.abort(err)

deps/undici/src/lib/web/cookies/index.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const{ parseSetCookie }=require('./parse')
-const{ stringify, getHeadersList}=require('./util')
+const{ stringify }=require('./util')
 const{ webidl }=require('../fetch/webidl')
 const{ Headers }=require('../fetch/headers')
 
@@ -78,14 +78,13 @@ function getSetCookies (headers) {
 
 webidl.brandCheck(headers,Headers,{strict: false})
 
-constcookies=getHeadersList(headers).cookies
+constcookies=headers.getSetCookie()
 
 if(!cookies){
 return[]
 }
 
-// In older versions of undici, cookies is a list of name:value.
-returncookies.map((pair)=>parseSetCookie(Array.isArray(pair) ? pair[1] : pair))
+returncookies.map((pair)=>parseSetCookie(pair))
 }
 
 /**

deps/undici/src/lib/web/cookies/util.js

@@ -1,8 +1,5 @@
 'use strict'
 
-constassert=require('node:assert')
-const{getHeadersList: internalGetHeadersList}=require('../fetch/headers')
-
 /**
  * @param {string} value
  * @returns {boolean}
@@ -275,35 +272,11 @@ function stringify (cookie) {
 returnout.join('; ')
 }
 
-letkHeadersListNode
-
-functiongetHeadersList(headers){
-try{
-returninternalGetHeadersList(headers)
-}catch{
-// fall-through
-}
-
-if(!kHeadersListNode){
-kHeadersListNode=Object.getOwnPropertySymbols(headers).find(
-(symbol)=>symbol.description==='headers list'
-)
-
-assert(kHeadersListNode,'Headers cannot be parsed')
-}
-
-constheadersList=headers[kHeadersListNode]
-assert(headersList)
-
-returnheadersList
-}
-
 module.exports={
  isCTLExcludingHtab,
  validateCookieName,
  validateCookiePath,
  validateCookieValue,
  toIMFDate,
- stringify,
- getHeadersList
+ stringify
 }

deps/undici/src/lib/web/fetch/headers.js

@@ -641,14 +641,6 @@ Object.defineProperties(Headers.prototype, {
 },
 [util.inspect.custom]: {
 enumerable: false
-},
-// Compatibility for global headers
-[Symbol('headers list')]: {
-configurable: false,
-enumerable: false,
-get: function(){
-returngetHeadersList(this)
-}
 }
 })