mirror of
https://github.com/pnpm/action-setup
synced 2026-11-06 20:47:58 +01:00
chore: rebuild bundle after reverting bootstrap pnpm to 11.0.4
This commit is contained in:
1 file changed
+7
-7
Vendored
+7
-7
@@ -18,12 +18,12 @@ ${u(C)}\r
|
||||
`);d.push(I),s+=I.byteLength}else{let I=im.encode(`${c}; name="${l(u(E))}"`+(C.name?`; filename="${l(C.name)}"`:"")+`\r
|
||||
Content-Type: ${C.type||"application/octet-stream"}\r
|
||||
\r
|
||||
`);d.push(I,C,f),typeof C.size=="number"?s+=I.byteLength+C.size+f.byteLength:g=!0}let m=im.encode(`--${A}--`);d.push(m),s+=m.byteLength,g&&(s=null),i=t,n=async function*(){for(let E of d)E.stream?yield*E.stream():yield E},o="multipart/form-data; boundary="+A}else if(vP(t))i=t,s=t.size,t.type&&(o=t.type);else if(typeof t[Symbol.asyncIterator]=="function"){if(e)throw new TypeError("keepalive");if(rc.isDisturbed(t)||t.locked)throw new TypeError("Response body object should not be disturbed or locked");r=t instanceof xs?t:OX(t)}if((typeof i=="string"||rc.isBuffer(i))&&(s=Buffer.byteLength(i)),n!=null){let A;r=new xs({async start(){A=n(t)[Symbol.asyncIterator]()},async pull(c){let{value:l,done:u}=await A.next();return u?queueMicrotask(()=>{c.close()}):GX(r)||c.enqueue(new Uint8Array(l)),c.desiredSize>0},async cancel(c){await A.return()},type:void 0})}return[{stream:r,source:i,length:s},o]}function KX(t,e=!1){return xs||(xs=require("stream/web").ReadableStream),t instanceof xs&&(dQ(!rc.isDisturbed(t),"The body has already been consumed."),dQ(!t.locked,"The stream is locked.")),TP(t,e)}function XX(t){let[e,r]=t.stream.tee(),n=qX(r,{transfer:[r]}),[,i]=n.tee();return t.stream=e,{stream:i,length:t.length,source:t.source}}async function*_P(t){if(t)if(PP(t))yield t;else{let e=t.stream;if(rc.isDisturbed(e))throw new TypeError("The body has already been consumed.");if(e.locked)throw new TypeError("The stream is locked.");e[jX]=!0,yield*e}}function hQ(t){if(t.aborted)throw new kP("The operation was aborted.","AbortError")}function ZX(t){return{blob(){return sm(this,r=>{let n=n6(this);return n==="failure"?n="":n&&(n=WX(n)),new HX([r],{type:n})},t)},arrayBuffer(){return sm(this,r=>new Uint8Array(r).buffer,t)},text(){return sm(this,OP,t)},json(){return sm(this,r6,t)},async formData(){uQ.brandCheck(this,t),hQ(this[Ss]);let r=this.headers.get("Content-Type");if(/multipart\/form-data/.test(r)){let n={};for(let[a,A]of this.headers)n[a.toLowerCase()]=A;let i=new RP,s;try{s=new TX({headers:n,preservePath:!0})}catch(a){throw new kP(`${a}`,"AbortError")}s.on("field",(a,A)=>{i.append(a,A)}),s.on("file",(a,A,c,l,u)=>{let d=[];if(l==="base64"||l.toLowerCase()==="base64"){let f="";A.on("data",g=>{f+=g.toString().replace(/[\r\n]/gm,"");let m=f.length-f.length%4;d.push(Buffer.from(f.slice(0,m),"base64")),f=f.slice(m)}),A.on("end",()=>{d.push(Buffer.from(f,"base64")),i.append(a,new DP(d,c,{type:u}))})}else A.on("data",f=>{d.push(f)}),A.on("end",()=>{i.append(a,new DP(d,c,{type:u}))})});let o=new Promise((a,A)=>{s.on("finish",a),s.on("error",c=>A(new TypeError(c)))});if(this.body!==null)for await(let a of _P(this[Ss].body))s.write(a);return s.end(),await o,i}else if(/application\/x-www-form-urlencoded/.test(r)){let n;try{let s="",o=new TextDecoder("utf-8",{ignoreBOM:!0});for await(let a of _P(this[Ss].body)){if(!PP(a))throw new TypeError("Expected Uint8Array chunk");s+=o.decode(a,{stream:!0})}s+=o.decode(),n=new URLSearchParams(s)}catch(s){throw Object.assign(new TypeError,{cause:s})}let i=new RP;for(let[s,o]of n)i.append(s,o);return i}else throw await Promise.resolve(),hQ(this[Ss]),uQ.errors.exception({header:`${t.name}.formData`,message:"Could not parse content as FormData."})}}}function e6(t){Object.assign(t.prototype,ZX(t))}async function sm(t,e,r){if(uQ.brandCheck(t,r),hQ(t[Ss]),t6(t[Ss].body))throw new TypeError("Body is unusable");let n=FX(),i=o=>n.reject(o),s=o=>{try{n.resolve(e(o))}catch(a){i(a)}};return t[Ss].body==null?(s(new Uint8Array),n.promise):(await UX(t[Ss].body,s,i),n.promise)}function t6(t){return t!=null&&(t.stream.locked||rc.isDisturbed(t.stream))}function OP(t){return t.length===0?"":(t[0]===239&&t[1]===187&&t[2]===191&&(t=t.subarray(3)),$X.decode(t))}function r6(t){return JSON.parse(OP(t))}function n6(t){let{headersList:e}=t[Ss],r=e.get("content-type");return r===null?"failure":VX(r)}MP.exports={extractBody:TP,safelyExtractBody:KX,cloneBody:XX,mixinBody:e6}});var qP=h((M_e,UP)=>{"use strict";var{InvalidArgumentError:ft,NotSupportedError:i6}=at(),vs=require("assert"),{kHTTP2BuildRequest:s6,kHTTP2CopyHeaders:o6,kHTTP1BuildRequest:a6}=yt(),Xr=Fe(),LP=/^[\^_`a-zA-Z\-0-9!#$%&'*+.|~]+$/,FP=/[^\t\x20-\x7e\x80-\xff]/,A6=/[^\u0021-\u00ff]/,Ri=Symbol("handler"),$t={},gQ;try{let t=require("diagnostics_channel");$t.create=t.channel("undici:request:create"),$t.bodySent=t.channel("undici:request:bodySent"),$t.headers=t.channel("undici:request:headers"),$t.trailers=t.channel("undici:request:trailers"),$t.error=t.channel("undici:request:error")}catch{$t.create={hasSubscribers:!1},$t.bodySent={hasSubscribers:!1},$t.headers={hasSubscribers:!1},$t.trailers={hasSubscribers:!1},$t.error={hasSubscribers:!1}}var mQ=class t{constructor(e,{path:r,method:n,body:i,headers:s,query:o,idempotent:a,blocking:A,upgrade:c,headersTimeout:l,bodyTimeout:u,reset:d,throwOnError:f,expectContinue:g},m){if(typeof r!="string")throw new ft("path must be a string");if(r[0]!=="/"&&!(r.startsWith("http://")||r.startsWith("https://"))&&n!=="CONNECT")throw new ftLine truncated
|
||||
`);d.push(I,C,f),typeof C.size=="number"?s+=I.byteLength+C.size+f.byteLength:g=!0}let m=im.encode(`--${A}--`);d.push(m),s+=m.byteLength,g&&(s=null),i=t,n=async function*(){for(let E of d)E.stream?yield*E.stream():yield E},o="multipart/form-data; boundary="+A}else if(vP(t))i=t,s=t.size,t.type&&(o=t.type);else if(typeof t[Symbol.asyncIterator]=="function"){if(e)throw new TypeError("keepalive");if(rc.isDisturbed(t)||t.locked)throw new TypeError("Response body object should not be disturbed or locked");r=t instanceof xs?t:OX(t)}if((typeof i=="string"||rc.isBuffer(i))&&(s=Buffer.byteLength(i)),n!=null){let A;r=new xs({async start(){A=n(t)[Symbol.asyncIterator]()},async pull(c){let{value:l,done:u}=await A.next();return u?queueMicrotask(()=>{c.close()}):GX(r)||c.enqueue(new Uint8Array(l)),c.desiredSize>0},async cancel(c){await A.return()},type:void 0})}return[{stream:r,source:i,length:s},o]}function KX(t,e=!1){return xs||(xs=require("stream/web").ReadableStream),t instanceof xs&&(dQ(!rc.isDisturbed(t),"The body has already been consumed."),dQ(!t.locked,"The stream is locked.")),TP(t,e)}function XX(t){let[e,r]=t.stream.tee(),n=qX(r,{transfer:[r]}),[,i]=n.tee();return t.stream=e,{stream:i,length:t.length,source:t.source}}async function*_P(t){if(t)if(PP(t))yield t;else{let e=t.stream;if(rc.isDisturbed(e))throw new TypeError("The body has already been consumed.");if(e.locked)throw new TypeError("The stream is locked.");e[jX]=!0,yield*e}}function hQ(t){if(t.aborted)throw new kP("The operation was aborted.","AbortError")}function ZX(t){return{blob(){return sm(this,r=>{let n=nZ(this);return n==="failure"?n="":n&&(n=WX(n)),new HX([r],{type:n})},t)},arrayBuffer(){return sm(this,r=>new Uint8Array(r).buffer,t)},text(){return sm(this,OP,t)},json(){return sm(this,rZ,t)},async formData(){uQ.brandCheck(this,t),hQ(this[Ss]);let r=this.headers.get("Content-Type");if(/multipart\/form-data/.test(r)){let n={};for(let[a,A]of this.headers)n[a.toLowerCase()]=A;let i=new RP,s;try{s=new TX({headers:n,preservePath:!0})}catch(a){throw new kP(`${a}`,"AbortError")}s.on("field",(a,A)=>{i.append(a,A)}),s.on("file",(a,A,c,l,u)=>{let d=[];if(l==="base64"||l.toLowerCase()==="base64"){let f="";A.on("data",g=>{f+=g.toString().replace(/[\r\n]/gm,"");let m=f.length-f.length%4;d.push(Buffer.from(f.slice(0,m),"base64")),f=f.slice(m)}),A.on("end",()=>{d.push(Buffer.from(f,"base64")),i.append(a,new DP(d,c,{type:u}))})}else A.on("data",f=>{d.push(f)}),A.on("end",()=>{i.append(a,new DP(d,c,{type:u}))})});let o=new Promise((a,A)=>{s.on("finish",a),s.on("error",c=>A(new TypeError(c)))});if(this.body!==null)for await(let a of _P(this[Ss].body))s.write(a);return s.end(),await o,i}else if(/application\/x-www-form-urlencoded/.test(r)){let n;try{let s="",o=new TextDecoder("utf-8",{ignoreBOM:!0});for await(let a of _P(this[Ss].body)){if(!PP(a))throw new TypeError("Expected Uint8Array chunk");s+=o.decode(a,{stream:!0})}s+=o.decode(),n=new URLSearchParams(s)}catch(s){throw Object.assign(new TypeError,{cause:s})}let i=new RP;for(let[s,o]of n)i.append(s,o);return i}else throw await Promise.resolve(),hQ(this[Ss]),uQ.errors.exception({header:`${t.name}.formData`,message:"Could not parse content as FormData."})}}}function eZ(t){Object.assign(t.prototype,ZX(t))}async function sm(t,e,r){if(uQ.brandCheck(t,r),hQ(t[Ss]),tZ(t[Ss].body))throw new TypeError("Body is unusable");let n=FX(),i=o=>n.reject(o),s=o=>{try{n.resolve(e(o))}catch(a){i(a)}};return t[Ss].body==null?(s(new Uint8Array),n.promise):(await UX(t[Ss].body,s,i),n.promise)}function tZ(t){return t!=null&&(t.stream.locked||rc.isDisturbed(t.stream))}function OP(t){return t.length===0?"":(t[0]===239&&t[1]===187&&t[2]===191&&(t=t.subarray(3)),$X.decode(t))}function rZ(t){return JSON.parse(OP(t))}function nZ(t){let{headersList:e}=t[Ss],r=e.get("content-type");return r===null?"failure":VX(r)}MP.exports={extractBody:TP,safelyExtractBody:KX,cloneBody:XX,mixinBody:eZ}});var qP=h((M_e,UP)=>{"use strict";var{InvalidArgumentError:ft,NotSupportedError:iZ}=at(),vs=require("assert"),{kHTTP2BuildRequest:sZ,kHTTP2CopyHeaders:oZ,kHTTP1BuildRequest:aZ}=yt(),Xr=Fe(),LP=/^[\^_`a-zA-Z\-0-9!#$%&'*+.|~]+$/,FP=/[^\t\x20-\x7e\x80-\xff]/,AZ=/[^\u0021-\u00ff]/,Ri=Symbol("handler"),$t={},gQ;try{let t=require("diagnostics_channel");$t.create=t.channel("undici:request:create"),$t.bodySent=t.channel("undici:request:bodySent"),$t.headers=t.channel("undici:request:headers"),$t.trailers=t.channel("undici:request:trailers"),$t.error=t.channel("undici:request:error")}catch{$t.create={hasSubscribers:!1},$t.bodySent={hasSubscribers:!1},$t.headers={hasSubscribers:!1},$t.trailers={hasSubscribers:!1},$t.error={hasSubscribers:!1}}var mQ=class t{constructor(e,{path:r,method:n,body:i,headers:s,query:o,idempotent:a,blocking:A,upgrade:c,headersTimeout:l,bodyTimeout:u,reset:d,throwOnError:f,expectContinue:g},m){if(typeof r!="string")throw new ft("path must be a string");if(r[0]!=="/"&&!(r.startsWith("http://")||r.startsWith("https://"))&&n!=="CONNECT")throw new ftLine truncated
|
||||
`),this.body=E.stream,this.contentLength=E.length}else Xr.isBlobLike(i)&&this.contentType==null&&i.type&&(this.contentType=i.type,this.headers+=`content-type: ${i.type}\r
|
||||
`);Xr.validateHandler(m,n,c),this.servername=Xr.getServerName(this.host),this[Ri]=m,$t.create.hasSubscribers&&$t.create.publish({request:this})}onBodySent(e){if(this[Ri].onBodySent)try{return this[Ri].onBodySent(e)}catch(r){this.abort(r)}}onRequestSent(){if($t.bodySent.hasSubscribers&&$t.bodySent.publish({request:this}),this[Ri].onRequestSent)try{return this[Ri].onRequestSent()}catch(e){this.abort(e)}}onConnect(e){if(vs(!this.aborted),vs(!this.completed),this.error)e(this.error);else return this.abort=e,this[Ri].onConnect(e)}onHeaders(e,r,n,i){vs(!this.aborted),vs(!this.completed),$t.headers.hasSubscribers&&$t.headers.publish({request:this,response:{statusCode:e,headers:r,statusText:i}});try{return this[Ri].onHeaders(e,r,n,i)}catch(s){this.abort(s)}}onData(e){vs(!this.aborted),vs(!this.completed);try{return this[Ri].onData(e)}catch(r){return this.abort(r),!1}}onUpgrade(e,r,n){return vs(!this.aborted),vs(!this.completed),this[Ri].onUpgrade(e,r,n)}onComplete(e){this.onFinally(),vs(!this.aborted),this.completed=!0,$t.trailers.hasSubscribers&&$t.trailers.publish({request:this,trailers:e});try{return this[Ri].onComplete(e)}catch(r){this.onError(r)}}onError(e){if(this.onFinally(),$t.error.hasSubscribers&&$t.error.publish({request:this,error:e}),!this.aborted)return this.aborted=!0,this[Ri].onError(e)}onFinally(){this.errorHandler&&(this.body.off("error",this.errorHandler),this.errorHandler=null),this.endHandler&&(this.body.off("end",this.endHandler),this.endHandler=null)}addHeader(e,r){return Bd(this,e,r),this}static[a6](e,r,n){return new t(e,r,n)}static[s6](e,r,n){let i=r.headers;r={...r,headers:null};let s=new t(e,r,n);if(s.headers={},Array.isArray(i)){if(i.length%2!==0)throw new ft("headers array must be even");for(let o=0;o<i.length;o+=2)Bd(s,i[o],i[o+1],!0)}else if(i&&typeof i=="object"){let o=Object.keys(i);for(let a=0;a<o.length;a++){let A=o[a];Bd(s,A,i[A],!0)}}else if(i!=null)throw new ft("headers must be an object or an array");return s}static[o6](e){let r=e.split(`\r
|
||||
`);Xr.validateHandler(m,n,c),this.servername=Xr.getServerName(this.host),this[Ri]=m,$t.create.hasSubscribers&&$t.create.publish({request:this})}onBodySent(e){if(this[Ri].onBodySent)try{return this[Ri].onBodySent(e)}catch(r){this.abort(r)}}onRequestSent(){if($t.bodySent.hasSubscribers&&$t.bodySent.publish({request:this}),this[Ri].onRequestSent)try{return this[Ri].onRequestSent()}catch(e){this.abort(e)}}onConnect(e){if(vs(!this.aborted),vs(!this.completed),this.error)e(this.error);else return this.abort=e,this[Ri].onConnect(e)}onHeaders(e,r,n,i){vs(!this.aborted),vs(!this.completed),$t.headers.hasSubscribers&&$t.headers.publish({request:this,response:{statusCode:e,headers:r,statusText:i}});try{return this[Ri].onHeaders(e,r,n,i)}catch(s){this.abort(s)}}onData(e){vs(!this.aborted),vs(!this.completed);try{return this[Ri].onData(e)}catch(r){return this.abort(r),!1}}onUpgrade(e,r,n){return vs(!this.aborted),vs(!this.completed),this[Ri].onUpgrade(e,r,n)}onComplete(e){this.onFinally(),vs(!this.aborted),this.completed=!0,$t.trailers.hasSubscribers&&$t.trailers.publish({request:this,trailers:e});try{return this[Ri].onComplete(e)}catch(r){this.onError(r)}}onError(e){if(this.onFinally(),$t.error.hasSubscribers&&$t.error.publish({request:this,error:e}),!this.aborted)return this.aborted=!0,this[Ri].onError(e)}onFinally(){this.errorHandler&&(this.body.off("error",this.errorHandler),this.errorHandler=null),this.endHandler&&(this.body.off("end",this.endHandler),this.endHandler=null)}addHeader(e,r){return Bd(this,e,r),this}static[aZ](e,r,n){return new t(e,r,n)}static[sZ](e,r,n){let i=r.headers;r={...r,headers:null};let s=new t(e,r,n);if(s.headers={},Array.isArray(i)){if(i.length%2!==0)throw new ft("headers array must be even");for(let o=0;o<i.length;o+=2)Bd(s,i[o],i[o+1],!0)}else if(i&&typeof i=="object"){let o=Object.keys(i);for(let a=0;a<o.length;a++){let A=o[a];Bd(s,A,i[A],!0)}}else if(i!=null)throw new ft("headers must be an object or an array");return s}static[oZ](e){let r=e.split(`\r
|
||||
`),n={};for(let i of r){let[s,o]=i.split(": ");o==null||o.length===0||(n[s]?n[s]+=`,${o}`:n[s]=o)}return n}};function Ia(t,e,r){if(e&&typeof e=="object")throw new ft(`invalid ${t} header`);if(e=e!=null?`${e}`:"",FP.exec(e)!==null)throw new ft(`invalid ${t} header`);return r?e:`${t}: ${e}\r
|
||||
`}function Bd(t,e,r,n=!1){if(r&&typeof r=="object"&&!Array.isArray(r))throw new ft(`invalid ${e} header`);if(r===void 0)return;if(t.host===null&&e.length===4&&e.toLowerCase()==="host"){if(FP.exec(r)!==null)throw new ft(`invalid ${e} header`);t.host=r}else if(t.contentLength===null&&e.length===14&&e.toLowerCase()==="content-length"){if(t.contentLength=parseInt(r,10),!Number.isFinite(t.contentLength))throw new ft("invalid content-length header")}else if(t.contentType===null&&e.length===12&&e.toLowerCase()==="content-type")t.contentType=r,n?t.headers[e]=Ia(e,r,n):t.headers+=Ia(e,r);else{if(e.length===17&&e.toLowerCase()==="transfer-encoding")throw new ft("invalid transfer-encoding header");if(e.length===10&&e.toLowerCase()==="connection"){let i=typeof r=="string"?r.toLowerCase():null;if(i!=="close"&&i!=="keep-alive")throw new ft("invalid connection header");i==="close"&&(t.reset=!0)}else{if(e.length===10&&e.toLowerCase()==="keep-alive")throw new ft("invalid keep-alive header");if(e.length===7&&e.toLowerCase()==="upgrade")throw new ft("invalid upgrade header");if(e.length===6&&e.toLowerCase()==="expect")throw new i6("expect header not supported");if(LP.exec(e)===null)throw new ft("invalid header key");if(Array.isArray(r))for(let i=0;i<r.length;i++)n?t.headers[e]?t.headers[e]+=`,${Ia(e,r[i],n)}`:t.headers[e]=Ia(e,r[i],n):t.headers+=Ia(e,r[i]);else n?t.headers[e]=Ia(e,r,n):t.headers+=Ia(e,r)}}}UP.exports=mQ});var om=h((L_e,HP)=>{"use strict";var c6=require("events"),pQ=class extends c6{dispatch(){throw new Error("not implemented")}close(){throw new Error("not implemented")}destroy(){throw new Error("not implemented")}};HP.exports=pQ});var bd=h((F_e,zP)=>{"use strict";var l6=om(),{ClientDestroyedError:yQ,ClientClosedError:u6,InvalidArgumentError:nc}=at(),{kDestroy:d6,kClose:f6,kDispatch:EQ,kInterceptors:Ba}=yt(),ic=Symbol("destroyed"),Qd=Symbol("closed"),Rs=Symbol("onDestroyed"),sc=Symbol("onClosed"),am=Symbol("Intercepted Dispatch"),CQ=class extends l6{constructor(){super(),this[ic]=!1,this[Rs]=null,this[Qd]=!1,this[sc]=[]}get destroyed(){return this[ic]}get closed(){return this[Qd]}get interceptors(){return this[Ba]}set interceptors(e){if(e){for(let r=e.length-1;r>=0;r--)if(typeof this[Ba][r]!="function")throw new nc("interceptor must be an function")}this[Ba]=e}close(e){if(e===void 0)return new Promise((n,i)=>{this.close((s,o)=>s?i(s):n(o))});if(typeof e!="function")throw new nc("invalid callback");if(this[ic]){queueMicrotask(()=>e(new yQ,null));return}if(this[Qd]){this[sc]?this[sc].push(e):queueMicrotask(()=>e(null,null));return}this[Qd]=!0,this[sc].push(e);let r=()=>{let n=this[sc];this[sc]=null;for(let i=0;i<n.length;i++)n[i](null,null)};this[f6]().then(()=>this.destroy()).then(()=>{queueMicrotask(r)})}destroy(e,r){if(typeof e=="function"&&(r=e,e=null),r===void 0)return new Promise((i,s)=>{this.destroy(e,(o,a)=>o?s(o):i(a))});if(typeof r!="function")throw new nc("invalid callback");if(this[ic]){this[Rs]?this[Rs].push(r):queueMicrotask(()=>r(null,null));return}e||(e=new yQ),this[ic]=!0,this[Rs]=this[Rs]||[],this[Rs].push(r);let n=()=>{let i=this[Rs];this[Rs]=null;for(let s=0;s<i.length;s++)i[s](null,null)};this[d6](e).then(()=>{queueMicrotask(n)})}[am](e,r){if(!this[Ba]||this[Ba].length===0)return this[am]=this[EQ],this[EQ](e,r);let n=this[EQ].bind(this);for(let i=this[Ba].length-1;i>=0;i--)n=this[Ba][i](n);return this[am]=n,n(e,r)}dispatch(e,r){if(!r||typeof r!="object")throw new nc("handler must be an object");try{if(!e||typeof e!="object")throw new nc("opts must be an object.");if(this[ic]||this[Rs])throw new yQ;if(this[Qd])throw new u6;return this[am](e,r)}catch(n){if(typeof r.onError!="function")throw new nc("invalid onError method");return r.onError(n),!1}}};zP.exports=CQ});var Nd=h((H_e,YP)=>{"use strict";var h6=require("net"),jP=require("assert"),GP=Fe(),{InvalidArgumentError:g6,ConnectTimeoutError:m6}=at(),IQ,BQ;global.FinalizationRegistry&&!process.env.NODE_V8_COVERAGE?BQ=class{constructor(e){this._maxCachedSessions=e,this._sessionCache=new Map,this._sessionRegistry=new global.FinalizationRegistry(r=>{if(this._sessionCache.size<this._maxCachedSessions)return;let n=this._sessionCache.get(r);n!==void 0&&n.deref()===void 0&&this._sessionCache.delete(r)})}get(e){let r=this._sessionCache.get(e);return r?r.deref():null}set(e,r){this._maxCachedSessions!==0&&(this._sessionCache.set(e,new WeakRef(r)),this._sessionRegistry.register(r,e))}}:BQ=class{constructor(e){this._maxCachedSessions=e,this._sessionCache=new Map}get(e){return this._sessionCache.get(e)}set(e,r){if(this._maxCachedSessions!==0){if(this._sessionCache.size>=this._maxCachedSessions){let{value:n}=this._sessionCache.keys().next();this._sessionCache.delete(n)}this._sessionCache.set(e,r)}}};function p6({allowH2:t,maxCachedSessions:e,socketPath:r,timeout:n,...i}){if(e!=null&&(!Number.isInteger(e)||e<0))throw new g6("maxCachedSessions must be a positive integer or zero");let s={path:r,...i},o=new BQ(e??100);return n=n??1e4,t=t??!1,function({hostname:
Line truncated
|
||||
`,this[cT]=A??3e5,this[AT]=i??3e5,this[Dd]=I??!0,this[J6]=w,this[_d]=T,this[Eo]=null,this[uT]=k>-1?k:-1,this[$i]="h1",this[Sn]=null,this[gm]=Se?{openStreams:0,maxConcurrentStreams:H??100}:null,this[dT]=`${this[Br].hostname}${this[Br].port?`:${this[Br].port}`:""}`,this[Et]=[],this[Ct]=0,this[xn]=0}get pipelining(){return this[Io]}set pipelining(e){this[Io]=e,vn(this,!0)}get[Na](){return this[Et].length-this[xn]}get[St](){return this[xn]-this[Ct]}get[ba](){return this[Et].length-this[Ct]}get[Y6](){return!!this[_t]&&!this[ac]&&!this[_t].destroyed}get[RQ](){let e=this[_t];return e&&(e[Hr]||e[ks]||e[cc])||this[ba]>=(this[Io]||1)||this[Na]>0}[G6](e){mT(this),this.once("connect",e)}[$6](e,r){let n=e.origin||this[Br].origin,i=this[$i]==="h2"?vQ[X6](n,e,r):vQ[eZ](n,e,r);return this[Et].push(i),this[Qa]||(Ae.bodyLength(i.body)==null&&Ae.isIterable(i.body)?(this[Qa]=1,process.nextTick(vn,this)):vn(this,!0)),this[Qa]&&this[Co]!==2&&this[RQ]&&(this[Co]=2),this[Co]<2}async[V6](){return new Promise(e=>{this[ba]?this[Eo]=e:e(null)})}async[W6](e){return new Promise(r=>{let n=this[Et].splice(this[xn]);for(let s=0;s<n.length;s++){let o=n[s];zr(this,o,e)}let i=()=>{this[Eo]&&(this[Eo](),this[Eo]=null),r()};this[Sn]!=null&&(Ae.destroy(this[Sn],e),this[Sn]=null,this[gm]=null),this[_t]?Ae.destroy(this[_t].on("close",i),e):queueMicrotask(i),vn(this)})}};function AZ(t){ee(t.code!=="ERR_TLS_CERT_ALTNAME_INVALID"),this[_t][Qr]=t,Em(this[Wi],t)}function cZ(t,e,r){let n=new Vi(`HTTP/2: "frameError" received - type ${t}, code ${e}`);r===0&&(this[_t][Qr]=n,Em(this[Wi],n))}function lZ(){Ae.destroy(this,new Ac("other side closed")),Ae.destroy(this[_t],new Ac("other side closed"))}function uZ(t){let e=this[Wi],r=new Vi(`HTTP/2: "GOAWAY" frame received with code ${t}`);if(e[_t]=null,e[Sn]=null,e.destroyed){ee(this[Na]===0);let n=e[Et].splice(e[Ct]);for(let i=0;i<n.length;i++){let s=n[i];zr(this,s,r)}}else if(e[St]>0){let n=e[Et][e[Ct]];e[Et][e[Ct]++]=null,zr(e,n,r)}e[xn]=e[Ct],ee(e[St]===0),e.emit("disconnect",e[Br],[e],r),vn(e)}var Gi=VP(),dZ=lm(),fZ=Buffer.alloc(0);async function hZ(){let t=process.env.JEST_WORKER_ID?wQ():void 0,e;try{e=await WebAssembly.compile(Buffer.from(tT(),"base64"))}catch{e=await WebAssembly.compile(Buffer.from(t||wQ(),"base64"))}return await WebAssembly.instantiate(e,{env:{wasm_on_url:(r,n,i)=>0,wasm_on_status:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onStatus(new um(Yi.buffer,s,i))||0},wasm_on_message_begin:r=>(ee.strictEqual(tr.ptr,r),tr.onMessageBegin()||0),wasm_on_header_field:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onHeaderField(new um(Yi.buffer,s,i))||0},wasm_on_header_value:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onHeaderValue(new um(Yi.buffer,s,i))||0},wasm_on_headers_complete:(r,n,i,s)=>(ee.strictEqual(tr.ptr,r),tr.onHeadersComplete(n,!!i,!!s)||0),wasm_on_body:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onBody(new um(Yi.buffer,s,i))||0},wasm_on_message_complete:r=>(ee.strictEqual(tr.ptr,r),tr.onMessageComplete()||0)}})}var SQ=null,kQ=hZ();kQ.catch();var tr=null,Yi=null,dm=0,Ji=null,lc=1,hm=2,PQ=3,TQ=class{constructor(e,r,{exports:n}){ee(Number.isFinite(e[fm])&&e[fm]>0),this.llhttp=n,this.ptr=this.llhttp.llhttp_alloc(Gi.TYPE.RESPONSE),this.client=e,this.socket=r,this.timeout=null,this.timeoutValue=null,this.timeoutType=null,this.statusCode=null,this.statusText="",this.upgrade=!1,this.headers=[],this.headersSize=0,this.headersMaxSize=e[fm],this.shouldKeepAlive=!1,this.paused=!1,this.resume=this.resume.bind(this),this.bytesRead=0,this.keepAlive="",this.contentLength="",this.connection="",this.maxResponseSize=e[uT]}setTimeout(e,r){this.timeoutType=r,e!==this.timeoutValue?(xQ.clearTimeout(this.timeout),e?(this.timeout=xQ.setTimeout(gZ,e,this),this.timeout.unref&&this.timeout.unref()):this.timeout=null,this.timeoutValue=e):this.timeout&&this.timeout.refresh&&this.timeout.refresh()}resume(){this.socket.destroyed||!this.paused||(ee(this.ptr!=null),ee(tr==null),this.llhttp.llhttp_resume(this.ptr),ee(this.timeoutType===hm),this.timeout&&this.timeout.refresh&&this.timeout.refresh(),this.paused=!1,this.execute(this.socket.read()||fZ),this.readMore())}readMore(){for(;!this.paused&&this.ptr;){let e=this.socket.read();if(e===null)break;this.execute(e)}}execute(e){ee(this.ptr!=null),ee(tr==null),ee(!this.paused);let{socket:r,llhttp:n}=this;e.length>dm&&(Ji&&n.free(Ji),dm=Math.ceil(e.length/4096)*4096,Ji=n.malloc(dm)),new Uint8Array(n.memory.buffer,Ji,dm).set(e);try{let i;try{Yi=e,tr=this,i=n.llhttp_execute(this.ptr,Ji,e.length)}catch(o){throw o}finally{tr=null,Yi=null}let s=n.llhttp_get_error_pos(this.ptr)-Ji;if(i===Gi.ERROR.PAUSED_UPGRADE)this.onUpgrade(e.slice(s));else if(i===Gi.ERROR.PAUSED)this.paused=!0,r.unshift(e.slice(s));else if(i!==Gi.ERROR.OK){let o=n.llhttp_get_error_reason(this.ptr),a="";if(o){let A=new Uint8Array(n.memory.buffer,o).indexOf(0);a="Response does not match the HTTP/1.1 protocol ("+B
Line truncated
|
||||
`}function Bd(t,e,r,n=!1){if(r&&typeof r=="object"&&!Array.isArray(r))throw new ft(`invalid ${e} header`);if(r===void 0)return;if(t.host===null&&e.length===4&&e.toLowerCase()==="host"){if(FP.exec(r)!==null)throw new ft(`invalid ${e} header`);t.host=r}else if(t.contentLength===null&&e.length===14&&e.toLowerCase()==="content-length"){if(t.contentLength=parseInt(r,10),!Number.isFinite(t.contentLength))throw new ft("invalid content-length header")}else if(t.contentType===null&&e.length===12&&e.toLowerCase()==="content-type")t.contentType=r,n?t.headers[e]=Ia(e,r,n):t.headers+=Ia(e,r);else{if(e.length===17&&e.toLowerCase()==="transfer-encoding")throw new ft("invalid transfer-encoding header");if(e.length===10&&e.toLowerCase()==="connection"){let i=typeof r=="string"?r.toLowerCase():null;if(i!=="close"&&i!=="keep-alive")throw new ft("invalid connection header");i==="close"&&(t.reset=!0)}else{if(e.length===10&&e.toLowerCase()==="keep-alive")throw new ft("invalid keep-alive header");if(e.length===7&&e.toLowerCase()==="upgrade")throw new ft("invalid upgrade header");if(e.length===6&&e.toLowerCase()==="expect")throw new iZ("expect header not supported");if(LP.exec(e)===null)throw new ft("invalid header key");if(Array.isArray(r))for(let i=0;i<r.length;i++)n?t.headers[e]?t.headers[e]+=`,${Ia(e,r[i],n)}`:t.headers[e]=Ia(e,r[i],n):t.headers+=Ia(e,r[i]);else n?t.headers[e]=Ia(e,r,n):t.headers+=Ia(e,r)}}}UP.exports=mQ});var om=h((L_e,HP)=>{"use strict";var cZ=require("events"),pQ=class extends cZ{dispatch(){throw new Error("not implemented")}close(){throw new Error("not implemented")}destroy(){throw new Error("not implemented")}};HP.exports=pQ});var bd=h((F_e,zP)=>{"use strict";var lZ=om(),{ClientDestroyedError:yQ,ClientClosedError:uZ,InvalidArgumentError:nc}=at(),{kDestroy:dZ,kClose:fZ,kDispatch:EQ,kInterceptors:Ba}=yt(),ic=Symbol("destroyed"),Qd=Symbol("closed"),Rs=Symbol("onDestroyed"),sc=Symbol("onClosed"),am=Symbol("Intercepted Dispatch"),CQ=class extends lZ{constructor(){super(),this[ic]=!1,this[Rs]=null,this[Qd]=!1,this[sc]=[]}get destroyed(){return this[ic]}get closed(){return this[Qd]}get interceptors(){return this[Ba]}set interceptors(e){if(e){for(let r=e.length-1;r>=0;r--)if(typeof this[Ba][r]!="function")throw new nc("interceptor must be an function")}this[Ba]=e}close(e){if(e===void 0)return new Promise((n,i)=>{this.close((s,o)=>s?i(s):n(o))});if(typeof e!="function")throw new nc("invalid callback");if(this[ic]){queueMicrotask(()=>e(new yQ,null));return}if(this[Qd]){this[sc]?this[sc].push(e):queueMicrotask(()=>e(null,null));return}this[Qd]=!0,this[sc].push(e);let r=()=>{let n=this[sc];this[sc]=null;for(let i=0;i<n.length;i++)n[i](null,null)};this[fZ]().then(()=>this.destroy()).then(()=>{queueMicrotask(r)})}destroy(e,r){if(typeof e=="function"&&(r=e,e=null),r===void 0)return new Promise((i,s)=>{this.destroy(e,(o,a)=>o?s(o):i(a))});if(typeof r!="function")throw new nc("invalid callback");if(this[ic]){this[Rs]?this[Rs].push(r):queueMicrotask(()=>r(null,null));return}e||(e=new yQ),this[ic]=!0,this[Rs]=this[Rs]||[],this[Rs].push(r);let n=()=>{let i=this[Rs];this[Rs]=null;for(let s=0;s<i.length;s++)i[s](null,null)};this[dZ](e).then(()=>{queueMicrotask(n)})}[am](e,r){if(!this[Ba]||this[Ba].length===0)return this[am]=this[EQ],this[EQ](e,r);let n=this[EQ].bind(this);for(let i=this[Ba].length-1;i>=0;i--)n=this[Ba][i](n);return this[am]=n,n(e,r)}dispatch(e,r){if(!r||typeof r!="object")throw new nc("handler must be an object");try{if(!e||typeof e!="object")throw new nc("opts must be an object.");if(this[ic]||this[Rs])throw new yQ;if(this[Qd])throw new uZ;return this[am](e,r)}catch(n){if(typeof r.onError!="function")throw new nc("invalid onError method");return r.onError(n),!1}}};zP.exports=CQ});var Nd=h((H_e,YP)=>{"use strict";var hZ=require("net"),jP=require("assert"),GP=Fe(),{InvalidArgumentError:gZ,ConnectTimeoutError:mZ}=at(),IQ,BQ;global.FinalizationRegistry&&!process.env.NODE_V8_COVERAGE?BQ=class{constructor(e){this._maxCachedSessions=e,this._sessionCache=new Map,this._sessionRegistry=new global.FinalizationRegistry(r=>{if(this._sessionCache.size<this._maxCachedSessions)return;let n=this._sessionCache.get(r);n!==void 0&&n.deref()===void 0&&this._sessionCache.delete(r)})}get(e){let r=this._sessionCache.get(e);return r?r.deref():null}set(e,r){this._maxCachedSessions!==0&&(this._sessionCache.set(e,new WeakRef(r)),this._sessionRegistry.register(r,e))}}:BQ=class{constructor(e){this._maxCachedSessions=e,this._sessionCache=new Map}get(e){return this._sessionCache.get(e)}set(e,r){if(this._maxCachedSessions!==0){if(this._sessionCache.size>=this._maxCachedSessions){let{value:n}=this._sessionCache.keys().next();this._sessionCache.delete(n)}this._sessionCache.set(e,r)}}};function pZ({allowH2:t,maxCachedSessions:e,socketPath:r,timeout:n,...i}){if(e!=null&&(!Number.isInteger(e)||e<0))throw new gZ("maxCachedSessions must be a positive integer or zero");let s={path:r,...i},o=new BQ(e??100);return n=n??1e4,t=t??!1,function({hostname:
Line truncated
|
||||
`,this[cT]=A??3e5,this[AT]=i??3e5,this[Dd]=I??!0,this[JZ]=w,this[_d]=T,this[Eo]=null,this[uT]=k>-1?k:-1,this[$i]="h1",this[Sn]=null,this[gm]=Se?{openStreams:0,maxConcurrentStreams:H??100}:null,this[dT]=`${this[Br].hostname}${this[Br].port?`:${this[Br].port}`:""}`,this[Et]=[],this[Ct]=0,this[xn]=0}get pipelining(){return this[Io]}set pipelining(e){this[Io]=e,vn(this,!0)}get[Na](){return this[Et].length-this[xn]}get[St](){return this[xn]-this[Ct]}get[ba](){return this[Et].length-this[Ct]}get[YZ](){return!!this[_t]&&!this[ac]&&!this[_t].destroyed}get[RQ](){let e=this[_t];return e&&(e[Hr]||e[ks]||e[cc])||this[ba]>=(this[Io]||1)||this[Na]>0}[GZ](e){mT(this),this.once("connect",e)}[$Z](e,r){let n=e.origin||this[Br].origin,i=this[$i]==="h2"?vQ[XZ](n,e,r):vQ[e6](n,e,r);return this[Et].push(i),this[Qa]||(Ae.bodyLength(i.body)==null&&Ae.isIterable(i.body)?(this[Qa]=1,process.nextTick(vn,this)):vn(this,!0)),this[Qa]&&this[Co]!==2&&this[RQ]&&(this[Co]=2),this[Co]<2}async[VZ](){return new Promise(e=>{this[ba]?this[Eo]=e:e(null)})}async[WZ](e){return new Promise(r=>{let n=this[Et].splice(this[xn]);for(let s=0;s<n.length;s++){let o=n[s];zr(this,o,e)}let i=()=>{this[Eo]&&(this[Eo](),this[Eo]=null),r()};this[Sn]!=null&&(Ae.destroy(this[Sn],e),this[Sn]=null,this[gm]=null),this[_t]?Ae.destroy(this[_t].on("close",i),e):queueMicrotask(i),vn(this)})}};function A6(t){ee(t.code!=="ERR_TLS_CERT_ALTNAME_INVALID"),this[_t][Qr]=t,Em(this[Wi],t)}function c6(t,e,r){let n=new Vi(`HTTP/2: "frameError" received - type ${t}, code ${e}`);r===0&&(this[_t][Qr]=n,Em(this[Wi],n))}function l6(){Ae.destroy(this,new Ac("other side closed")),Ae.destroy(this[_t],new Ac("other side closed"))}function u6(t){let e=this[Wi],r=new Vi(`HTTP/2: "GOAWAY" frame received with code ${t}`);if(e[_t]=null,e[Sn]=null,e.destroyed){ee(this[Na]===0);let n=e[Et].splice(e[Ct]);for(let i=0;i<n.length;i++){let s=n[i];zr(this,s,r)}}else if(e[St]>0){let n=e[Et][e[Ct]];e[Et][e[Ct]++]=null,zr(e,n,r)}e[xn]=e[Ct],ee(e[St]===0),e.emit("disconnect",e[Br],[e],r),vn(e)}var Gi=VP(),d6=lm(),f6=Buffer.alloc(0);async function h6(){let t=process.env.JEST_WORKER_ID?wQ():void 0,e;try{e=await WebAssembly.compile(Buffer.from(tT(),"base64"))}catch{e=await WebAssembly.compile(Buffer.from(t||wQ(),"base64"))}return await WebAssembly.instantiate(e,{env:{wasm_on_url:(r,n,i)=>0,wasm_on_status:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onStatus(new um(Yi.buffer,s,i))||0},wasm_on_message_begin:r=>(ee.strictEqual(tr.ptr,r),tr.onMessageBegin()||0),wasm_on_header_field:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onHeaderField(new um(Yi.buffer,s,i))||0},wasm_on_header_value:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onHeaderValue(new um(Yi.buffer,s,i))||0},wasm_on_headers_complete:(r,n,i,s)=>(ee.strictEqual(tr.ptr,r),tr.onHeadersComplete(n,!!i,!!s)||0),wasm_on_body:(r,n,i)=>{ee.strictEqual(tr.ptr,r);let s=n-Ji+Yi.byteOffset;return tr.onBody(new um(Yi.buffer,s,i))||0},wasm_on_message_complete:r=>(ee.strictEqual(tr.ptr,r),tr.onMessageComplete()||0)}})}var SQ=null,kQ=h6();kQ.catch();var tr=null,Yi=null,dm=0,Ji=null,lc=1,hm=2,PQ=3,TQ=class{constructor(e,r,{exports:n}){ee(Number.isFinite(e[fm])&&e[fm]>0),this.llhttp=n,this.ptr=this.llhttp.llhttp_alloc(Gi.TYPE.RESPONSE),this.client=e,this.socket=r,this.timeout=null,this.timeoutValue=null,this.timeoutType=null,this.statusCode=null,this.statusText="",this.upgrade=!1,this.headers=[],this.headersSize=0,this.headersMaxSize=e[fm],this.shouldKeepAlive=!1,this.paused=!1,this.resume=this.resume.bind(this),this.bytesRead=0,this.keepAlive="",this.contentLength="",this.connection="",this.maxResponseSize=e[uT]}setTimeout(e,r){this.timeoutType=r,e!==this.timeoutValue?(xQ.clearTimeout(this.timeout),e?(this.timeout=xQ.setTimeout(g6,e,this),this.timeout.unref&&this.timeout.unref()):this.timeout=null,this.timeoutValue=e):this.timeout&&this.timeout.refresh&&this.timeout.refresh()}resume(){this.socket.destroyed||!this.paused||(ee(this.ptr!=null),ee(tr==null),this.llhttp.llhttp_resume(this.ptr),ee(this.timeoutType===hm),this.timeout&&this.timeout.refresh&&this.timeout.refresh(),this.paused=!1,this.execute(this.socket.read()||f6),this.readMore())}readMore(){for(;!this.paused&&this.ptr;){let e=this.socket.read();if(e===null)break;this.execute(e)}}execute(e){ee(this.ptr!=null),ee(tr==null),ee(!this.paused);let{socket:r,llhttp:n}=this;e.length>dm&&(Ji&&n.free(Ji),dm=Math.ceil(e.length/4096)*4096,Ji=n.malloc(dm)),new Uint8Array(n.memory.buffer,Ji,dm).set(e);try{let i;try{Yi=e,tr=this,i=n.llhttp_execute(this.ptr,Ji,e.length)}catch(o){throw o}finally{tr=null,Yi=null}let s=n.llhttp_get_error_pos(this.ptr)-Ji;if(i===Gi.ERROR.PAUSED_UPGRADE)this.onUpgrade(e.slice(s));else if(i===Gi.ERROR.PAUSED)this.paused=!0,r.unshift(e.slice(s));else if(i!==Gi.ERROR.OK){let o=n.llhttp_get_error_reason(this.ptr),a="";if(o){let A=new Uint8Array(n.memory.buffer,o).indexOf(0);a="Response does not match the HTTP/1.1 protocol ("+B
Line truncated
|
||||
`;return typeof s=="string"?g+=`host: ${s}\r
|
||||
`:g+=t[sT],o?g+=`connection: upgrade\r
|
||||
upgrade: ${o}\r
|
||||
@@ -34,7 +34,7 @@ upgrade: ${o}\r
|
||||
`,"latin1"):(ee(d===null,"no body must not have content length"),f.write(`${g}\r
|
||||
`,"latin1")),e.onRequestSent()):Ae.isBuffer(r)?(ee(d===r.byteLength,"buffer body must have content length"),f.cork(),f.write(`${g}content-length: ${d}\r
|
||||
\r
|
||||
`,"latin1"),f.write(r),f.uncork(),e.onBodySent(r),e.onRequestSent(),l||(f[Hr]=!0)):Ae.isBlobLike(r)?typeof r.stream=="function"?pm({body:r.stream(),client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):ET({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):Ae.isStream(r)?yT({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):Ae.isIterable(r)?pm({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):ee(!1),!0}function yZ(t,e,r){let{body:n,method:i,path:s,host:o,upgrade:a,expectContinue:A,signal:c,headers:l}=r,u;if(typeof l=="string"?u=vQ[Z6](l.trim()):u=l,a)return zr(t,r,new Error("Upgrade not supported for H2")),!1;try{r.onConnect(I=>{r.aborted||r.completed||zr(t,r,I||new MQ)})}catch(I){zr(t,r,I)}if(r.aborted)return!1;let d,f=t[gm];if(u[tZ]=o||t[dT],u[rZ]=i,i==="CONNECT")return e.ref(),d=e.request(u,{endStream:!1,signal:c}),d.id&&!d.pending?(r.onUpgrade(null,null,d),++f.openStreams):d.once("ready",()=>{r.onUpgrade(null,null,d),++f.openStreams}),d.once("close",()=>{f.openStreams-=1,f.openStreams===0&&e.unref()}),!0;u[nZ]=s,u[iZ]="https";let g=i==="PUT"||i==="POST"||i==="PATCH";n&&typeof n.read=="function"&&n.read(0);let m=Ae.bodyLength(n);if(m==null&&(m=r.contentLength),(m===0||!g)&&(m=null),pT(i)&&m>0&&r.contentLength!=null&&r.contentLength!==m){if(t[Dd])return zr(t,r,new _s),!1;process.emitWarning(new _s)}m!=null&&(ee(n,"no body must not have content length"),u[sZ]=`${m}`),e.ref();let E=i==="GET"||i==="HEAD";return A?(u[oZ]="100-continue",d=e.request(u,{endStream:E,signal:c}),d.once("continue",C)):(d=e.request(u,{endStream:E,signal:c}),C()),++f.openStreams,d.once("response",I=>{let{[aZ]:N,...w}=I;r.onHeaders(Number(N),w,d.resume.bind(d),"")===!1&&d.pause()}),d.once("end",()=>{r.onComplete([])}),d.on("data",I=>{r.onData(I)===!1&&d.pause()}),d.once("close",()=>{f.openStreams-=1,f.openStreams===0&&e.unref()}),d.once("error",function(I){t[Sn]&&!t[Sn].destroyed&&!this.closed&&!this.destroyed&&(f.streams-=1,Ae.destroy(d,I))}),d.once("frameError",(I,N)=>{let w=new Vi(`HTTP/2: "frameError" received - type ${I}, code ${N}`);zr(t,r,w),t[Sn]&&!t[Sn].destroyed&&!this.closed&&!this.destroyed&&(f.streams-=1,Ae.destroy(d,w))}),!0;function C(){n?Ae.isBuffer(n)?(ee(m===n.byteLength,"buffer body must have content length"),d.cork(),d.write(n),d.uncork(),d.end(),r.onBodySent(n),r.onRequestSent()):Ae.isBlobLike(n)?typeof n.stream=="function"?pm({client:t,request:r,contentLength:m,h2stream:d,expectsPayload:g,body:n.stream(),socket:t[_t],header:""}):ET({body:n,client:t,request:r,contentLength:m,expectsPayload:g,h2stream:d,header:"",socket:t[_t]}):Ae.isStream(n)?yT({body:n,client:t,request:r,contentLength:m,expectsPayload:g,socket:t[_t],h2stream:d,header:""}):Ae.isIterable(n)?pm({body:n,client:t,request:r,contentLength:m,expectsPayload:g,header:"",h2stream:d,socket:t[_t]}):ee(!1):r.onRequestSent()}}function yT({h2stream:t,body:e,client:r,request:n,socket:i,contentLength:s,header:o,expectsPayload:a}){if(ee(s!==0||r[St]===0,"stream body cannot be pipelined"),r[$i]==="h2"){let m=function(E){n.onBodySent(E)},g=T6(e,t,E=>{E?(Ae.destroy(e,E),Ae.destroy(t,E)):n.onRequestSent()});g.on("data",m),g.once("end",()=>{g.removeListener("data",m),Ae.destroy(g)});return}let A=!1,c=new ym({socket:i,request:n,contentLength:s,client:r,expectsPayload:a,header:o}),l=function(g){if(!A)try{!c.write(g)&&this.pause&&this.pause()}catch(m){Ae.destroy(this,m)}},u=function(){A||e.resume&&e.resume()},d=function(){if(A)return;let g=new MQ;queueMicrotask(()=>f(g))},f=function(g){if(!A){if(A=!0,ee(i.destroyed||i[ks]&&r[St]<=1),i.off("drain",u).off("error",f),e.removeListener("data",l).removeListener("end",f).removeListener("error",f).removeListener("close",d),!g)try{c.end()}catch(m){g=m}c.destroy(g),g&&(g.code!=="UND_ERR_INFO"||g.message!=="reset")?Ae.destroy(e,g):Ae.destroy(e)}};e.on("data",l).on("end",f).on("error",f).on("close",d),e.resume&&e.resume(),i.on("drain",u).on("error",f)}async function ET({h2stream:t,body:e,client:r,request:n,socket:i,contentLength:s,header:o,expectsPayload:a}){ee(s===e.size,"blob body must have content length");let A=r[$i]==="h2";try{if(s!=null&&s!==e.size)throw new _s;let c=Buffer.from(await e.arrayBuffer());A?(t.cork(),t.write(c),t.uncork()):(i.cork(),i.write(`${o}content-length: ${s}\r
|
||||
`,"latin1"),f.write(r),f.uncork(),e.onBodySent(r),e.onRequestSent(),l||(f[Hr]=!0)):Ae.isBlobLike(r)?typeof r.stream=="function"?pm({body:r.stream(),client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):ET({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):Ae.isStream(r)?yT({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):Ae.isIterable(r)?pm({body:r,client:t,request:e,socket:f,contentLength:d,header:g,expectsPayload:l}):ee(!1),!0}function y6(t,e,r){let{body:n,method:i,path:s,host:o,upgrade:a,expectContinue:A,signal:c,headers:l}=r,u;if(typeof l=="string"?u=vQ[ZZ](l.trim()):u=l,a)return zr(t,r,new Error("Upgrade not supported for H2")),!1;try{r.onConnect(I=>{r.aborted||r.completed||zr(t,r,I||new MQ)})}catch(I){zr(t,r,I)}if(r.aborted)return!1;let d,f=t[gm];if(u[t6]=o||t[dT],u[r6]=i,i==="CONNECT")return e.ref(),d=e.request(u,{endStream:!1,signal:c}),d.id&&!d.pending?(r.onUpgrade(null,null,d),++f.openStreams):d.once("ready",()=>{r.onUpgrade(null,null,d),++f.openStreams}),d.once("close",()=>{f.openStreams-=1,f.openStreams===0&&e.unref()}),!0;u[n6]=s,u[i6]="https";let g=i==="PUT"||i==="POST"||i==="PATCH";n&&typeof n.read=="function"&&n.read(0);let m=Ae.bodyLength(n);if(m==null&&(m=r.contentLength),(m===0||!g)&&(m=null),pT(i)&&m>0&&r.contentLength!=null&&r.contentLength!==m){if(t[Dd])return zr(t,r,new _s),!1;process.emitWarning(new _s)}m!=null&&(ee(n,"no body must not have content length"),u[s6]=`${m}`),e.ref();let E=i==="GET"||i==="HEAD";return A?(u[o6]="100-continue",d=e.request(u,{endStream:E,signal:c}),d.once("continue",C)):(d=e.request(u,{endStream:E,signal:c}),C()),++f.openStreams,d.once("response",I=>{let{[a6]:N,...w}=I;r.onHeaders(Number(N),w,d.resume.bind(d),"")===!1&&d.pause()}),d.once("end",()=>{r.onComplete([])}),d.on("data",I=>{r.onData(I)===!1&&d.pause()}),d.once("close",()=>{f.openStreams-=1,f.openStreams===0&&e.unref()}),d.once("error",function(I){t[Sn]&&!t[Sn].destroyed&&!this.closed&&!this.destroyed&&(f.streams-=1,Ae.destroy(d,I))}),d.once("frameError",(I,N)=>{let w=new Vi(`HTTP/2: "frameError" received - type ${I}, code ${N}`);zr(t,r,w),t[Sn]&&!t[Sn].destroyed&&!this.closed&&!this.destroyed&&(f.streams-=1,Ae.destroy(d,w))}),!0;function C(){n?Ae.isBuffer(n)?(ee(m===n.byteLength,"buffer body must have content length"),d.cork(),d.write(n),d.uncork(),d.end(),r.onBodySent(n),r.onRequestSent()):Ae.isBlobLike(n)?typeof n.stream=="function"?pm({client:t,request:r,contentLength:m,h2stream:d,expectsPayload:g,body:n.stream(),socket:t[_t],header:""}):ET({body:n,client:t,request:r,contentLength:m,expectsPayload:g,h2stream:d,header:"",socket:t[_t]}):Ae.isStream(n)?yT({body:n,client:t,request:r,contentLength:m,expectsPayload:g,socket:t[_t],h2stream:d,header:""}):Ae.isIterable(n)?pm({body:n,client:t,request:r,contentLength:m,expectsPayload:g,header:"",h2stream:d,socket:t[_t]}):ee(!1):r.onRequestSent()}}function yT({h2stream:t,body:e,client:r,request:n,socket:i,contentLength:s,header:o,expectsPayload:a}){if(ee(s!==0||r[St]===0,"stream body cannot be pipelined"),r[$i]==="h2"){let m=function(E){n.onBodySent(E)},g=TZ(e,t,E=>{E?(Ae.destroy(e,E),Ae.destroy(t,E)):n.onRequestSent()});g.on("data",m),g.once("end",()=>{g.removeListener("data",m),Ae.destroy(g)});return}let A=!1,c=new ym({socket:i,request:n,contentLength:s,client:r,expectsPayload:a,header:o}),l=function(g){if(!A)try{!c.write(g)&&this.pause&&this.pause()}catch(m){Ae.destroy(this,m)}},u=function(){A||e.resume&&e.resume()},d=function(){if(A)return;let g=new MQ;queueMicrotask(()=>f(g))},f=function(g){if(!A){if(A=!0,ee(i.destroyed||i[ks]&&r[St]<=1),i.off("drain",u).off("error",f),e.removeListener("data",l).removeListener("end",f).removeListener("error",f).removeListener("close",d),!g)try{c.end()}catch(m){g=m}c.destroy(g),g&&(g.code!=="UND_ERR_INFO"||g.message!=="reset")?Ae.destroy(e,g):Ae.destroy(e)}};e.on("data",l).on("end",f).on("error",f).on("close",d),e.resume&&e.resume(),i.on("drain",u).on("error",f)}async function ET({h2stream:t,body:e,client:r,request:n,socket:i,contentLength:s,header:o,expectsPayload:a}){ee(s===e.size,"blob body must have content length");let A=r[$i]==="h2";try{if(s!=null&&s!==e.size)throw new _s;let c=Buffer.from(await e.arrayBuffer());A?(t.cork(),t.write(c),t.uncork()):(i.cork(),i.write(`${o}content-length: ${s}\r
|
||||
\r
|
||||
`,"latin1"),i.write(c),i.uncork()),n.onBodySent(c),n.onRequestSent(),a||(i[Hr]=!0),vn(r)}catch(c){Ae.destroy(A?t:i,c)}}async function pm({h2stream:t,body:e,client:r,request:n,socket:i,contentLength:s,header:o,expectsPayload:a}){ee(s!==0||r[St]===0,"iterator body cannot be pipelined");let A=null;function c(){if(A){let d=A;A=null,d()}}let l=()=>new Promise((d,f)=>{ee(A===null),i[Qr]?f(i[Qr]):A=d});if(r[$i]==="h2"){t.on("close",c).on("drain",c);try{for await(let d of e){if(i[Qr])throw i[Qr];let f=t.write(d);n.onBodySent(d),f||await l()}}catch(d){t.destroy(d)}finally{n.onRequestSent(),t.end(),t.off("close",c).off("drain",c)}return}i.on("close",c).on("drain",c);let u=new ym({socket:i,request:n,contentLength:s,client:r,expectsPayload:a,header:o});try{for await(let d of e){if(i[Qr])throw i[Qr];u.write(d)||await l()}u.end()}catch(d){u.destroy(d)}finally{i.off("close",c).off("drain",c)}}var ym=class{constructor({socket:e,request:r,contentLength:n,client:i,expectsPayload:s,header:o}){this.socket=e,this.request=r,this.contentLength=n,this.client=i,this.bytesWritten=0,this.expectsPayload=s,this.header=o,e[ks]=!0}write(e){let{socket:r,request:n,contentLength:i,client:s,bytesWritten:o,expectsPayload:a,header:A}=this;if(r[Qr])throw r[Qr];if(r.destroyed)return!1;let c=Buffer.byteLength(e);if(!c)return!0;if(i!==null&&o+c>i){if(s[Dd])throw new _s;process.emitWarning(new _s)}r.cork(),o===0&&(a||(r[Hr]=!0),i===null?r.write(`${A}transfer-encoding: chunked\r
|
||||
`,"latin1"):r.write(`${A}content-length: ${i}\r
|
||||
@@ -47,7 +47,7 @@ ${c.toString(16)}\r
|
||||
`,"latin1"):r===null&&e.write(`\r
|
||||
0\r
|
||||
\r
|
||||
`,"latin1"),r!==null&&i!==r){if(n[Dd])throw new _s;process.emitWarning(new _s)}e[Dt].timeout&&e[Dt].timeoutType===lc&&e[Dt].timeout.refresh&&e[Dt].timeout.refresh(),vn(n)}}destroy(e){let{socket:r,client:n}=this;r[ks]=!1,e&&(ee(n[St]<=1,"pipeline should only contain this request"),Ae.destroy(r,e))}};function zr(t,e,r){try{e.onError(r),ee(e.aborted)}catch(n){t.emit("error",n)}}CT.exports=_Q});var BT=h((K_e,IT)=>{"use strict";var Cm=class{constructor(){this.bottom=0,this.top=0,this.list=new Array(2048),this.next=null}isEmpty(){return this.top===this.bottom}isFull(){return(this.top+1&2047)===this.bottom}push(e){this.list[this.top]=e,this.top=this.top+1&2047}shift(){let e=this.list[this.bottom];return e===void 0?null:(this.list[this.bottom]=void 0,this.bottom=this.bottom+1&2047,e)}};IT.exports=class{constructor(){this.head=this.tail=new Cm}isEmpty(){return this.head.isEmpty()}push(e){this.head.isFull()&&(this.head=this.head.next=new Cm),this.head.push(e)}shift(){let e=this.tail,r=e.shift();return e.isEmpty()&&e.next!==null&&(this.tail=e.next),r}}});var bT=h((X_e,QT)=>{var{kFree:EZ,kConnected:CZ,kPending:IZ,kQueued:BZ,kRunning:QZ,kSize:bZ}=yt(),wa=Symbol("pool"),LQ=class{constructor(e){this[wa]=e}get connected(){return this[wa][CZ]}get free(){return this[wa][EZ]}get pending(){return this[wa][IZ]}get queued(){return this[wa][BZ]}get running(){return this[wa][QZ]}get size(){return this[wa][bZ]}};QT.exports=LQ});var jQ=h((Z_e,PT)=>{"use strict";var NZ=bd(),wZ=BT(),{kConnected:FQ,kSize:NT,kRunning:wT,kPending:xT,kQueued:Pd,kBusy:xZ,kFree:SZ,kUrl:vZ,kClose:RZ,kDestroy:DZ,kDispatch:_Z}=yt(),kZ=bT(),Zr=Symbol("clients"),jr=Symbol("needDrain"),Td=Symbol("queue"),UQ=Symbol("closed resolve"),qQ=Symbol("onDrain"),ST=Symbol("onConnect"),vT=Symbol("onDisconnect"),RT=Symbol("onConnectionError"),HQ=Symbol("get dispatcher"),_T=Symbol("add client"),kT=Symbol("remove client"),DT=Symbol("stats"),zQ=class extends NZ{constructor(){super(),this[Td]=new wZ,this[Zr]=[],this[Pd]=0;let e=this;this[qQ]=function(n,i){let s=e[Td],o=!1;for(;!o;){let a=s.shift();if(!a)break;e[Pd]--,o=!this.dispatch(a.opts,a.handler)}this[jr]=o,!this[jr]&&e[jr]&&(e[jr]=!1,e.emit("drain",n,[e,...i])),e[UQ]&&s.isEmpty()&&Promise.all(e[Zr].map(a=>a.close())).then(e[UQ])},this[ST]=(r,n)=>{e.emit("connect",r,[e,...n])},this[vT]=(r,n,i)=>{e.emit("disconnect",r,[e,...n],i)},this[RT]=(r,n,i)=>{e.emit("connectionError",r,[e,...n],i)},this[DT]=new kZ(this)}get[xZ](){return this[jr]}get[FQ](){return this[Zr].filter(e=>e[FQ]).length}get[SZ](){return this[Zr].filter(e=>e[FQ]&&!e[jr]).length}get[xT](){let e=this[Pd];for(let{[xT]:r}of this[Zr])e+=r;return e}get[wT](){let e=0;for(let{[wT]:r}of this[Zr])e+=r;return e}get[NT](){let e=this[Pd];for(let{[NT]:r}of this[Zr])e+=r;return e}get stats(){return this[DT]}async[RZ](){return this[Td].isEmpty()?Promise.all(this[Zr].map(e=>e.close())):new Promise(e=>{this[UQ]=e})}async[DZ](e){for(;;){let r=this[Td].shift();if(!r)break;r.handler.onError(e)}return Promise.all(this[Zr].map(r=>r.destroy(e)))}[_Z](e,r){let n=this[HQ]();return n?n.dispatch(e,r)||(n[jr]=!0,this[jr]=!this[HQ]()):(this[jr]=!0,this[Td].push({opts:e,handler:r}),this[Pd]++),!this[jr]}[_T](e){return e.on("drain",this[qQ]).on("connect",this[ST]).on("disconnect",this[vT]).on("connectionError",this[RT]),this[Zr].push(e),this[jr]&&process.nextTick(()=>{this[jr]&&this[qQ](e[vZ],[this,e])}),this}[kT](e){e.close(()=>{let r=this[Zr].indexOf(e);r!==-1&&this[Zr].splice(r,1)}),this[jr]=this[Zr].some(r=>!r[jr]&&r.closed!==!0&&r.destroyed!==!0)}};PT.exports={PoolBase:zQ,kClients:Zr,kNeedDrain:jr,kAddClient:_T,kRemoveClient:kT,kGetDispatcher:HQ}});var uc=h((eke,MT)=>{"use strict";var{PoolBase:PZ,kClients:Im,kNeedDrain:TZ,kAddClient:OZ,kGetDispatcher:MZ}=jQ(),LZ=kd(),{InvalidArgumentError:GQ}=at(),YQ=Fe(),{kUrl:TT,kInterceptors:FZ}=yt(),UZ=Nd(),JQ=Symbol("options"),VQ=Symbol("connections"),OT=Symbol("factory");function qZ(t,e){return new LZ(t,e)}var WQ=class extends PZ{constructor(e,{connections:r,factory:n=qZ,connect:i,connectTimeout:s,tls:o,maxCachedSessions:a,socketPath:A,autoSelectFamily:c,autoSelectFamilyAttemptTimeout:l,allowH2:u,...d}={}){if(super(),r!=null&&(!Number.isFinite(r)||r<0))throw new GQ("invalid connections");if(typeof n!="function")throw new GQ("factory must be a function.");if(i!=null&&typeof i!="function"&&typeof i!="object")throw new GQ("connect must be a function or an object");typeof i!="function"&&(i=UZ({...o,maxCachedSessions:a,allowH2:u,socketPath:A,timeout:s,...YQ.nodeHasAutoSelectFamily&&c?{autoSelectFamily:c,autoSelectFamilyAttemptTimeout:l}:void 0,...i})),this[FZ]=d.interceptors&&d.interceptors.Pool&&Array.isArray(d.interceptors.Pool)?d.interceptors.Pool:[],this[VQ]=r||null,this[TT]=YQ.parseOrigin(e),this[JQ]={...YQ.deepClone(d),connect:i,allowH2:u},this[JQ].interceptors=d.interceptors?{...d.interceptors}:void 0,this[OT]=n,this.on("connectionError",(f,g,m)=>{for(let E of g){let C=this[Im].indexOf(E);C!==-1&&this[Im].splice(C,1)}})}[MZ](){let e=this[Im].fin
Line truncated
|
||||
`,"latin1"),r!==null&&i!==r){if(n[Dd])throw new _s;process.emitWarning(new _s)}e[Dt].timeout&&e[Dt].timeoutType===lc&&e[Dt].timeout.refresh&&e[Dt].timeout.refresh(),vn(n)}}destroy(e){let{socket:r,client:n}=this;r[ks]=!1,e&&(ee(n[St]<=1,"pipeline should only contain this request"),Ae.destroy(r,e))}};function zr(t,e,r){try{e.onError(r),ee(e.aborted)}catch(n){t.emit("error",n)}}CT.exports=_Q});var BT=h((K_e,IT)=>{"use strict";var Cm=class{constructor(){this.bottom=0,this.top=0,this.list=new Array(2048),this.next=null}isEmpty(){return this.top===this.bottom}isFull(){return(this.top+1&2047)===this.bottom}push(e){this.list[this.top]=e,this.top=this.top+1&2047}shift(){let e=this.list[this.bottom];return e===void 0?null:(this.list[this.bottom]=void 0,this.bottom=this.bottom+1&2047,e)}};IT.exports=class{constructor(){this.head=this.tail=new Cm}isEmpty(){return this.head.isEmpty()}push(e){this.head.isFull()&&(this.head=this.head.next=new Cm),this.head.push(e)}shift(){let e=this.tail,r=e.shift();return e.isEmpty()&&e.next!==null&&(this.tail=e.next),r}}});var bT=h((X_e,QT)=>{var{kFree:E6,kConnected:C6,kPending:I6,kQueued:B6,kRunning:Q6,kSize:b6}=yt(),wa=Symbol("pool"),LQ=class{constructor(e){this[wa]=e}get connected(){return this[wa][C6]}get free(){return this[wa][E6]}get pending(){return this[wa][I6]}get queued(){return this[wa][B6]}get running(){return this[wa][Q6]}get size(){return this[wa][b6]}};QT.exports=LQ});var jQ=h((Z_e,PT)=>{"use strict";var N6=bd(),w6=BT(),{kConnected:FQ,kSize:NT,kRunning:wT,kPending:xT,kQueued:Pd,kBusy:x6,kFree:S6,kUrl:v6,kClose:R6,kDestroy:D6,kDispatch:_6}=yt(),k6=bT(),Zr=Symbol("clients"),jr=Symbol("needDrain"),Td=Symbol("queue"),UQ=Symbol("closed resolve"),qQ=Symbol("onDrain"),ST=Symbol("onConnect"),vT=Symbol("onDisconnect"),RT=Symbol("onConnectionError"),HQ=Symbol("get dispatcher"),_T=Symbol("add client"),kT=Symbol("remove client"),DT=Symbol("stats"),zQ=class extends N6{constructor(){super(),this[Td]=new w6,this[Zr]=[],this[Pd]=0;let e=this;this[qQ]=function(n,i){let s=e[Td],o=!1;for(;!o;){let a=s.shift();if(!a)break;e[Pd]--,o=!this.dispatch(a.opts,a.handler)}this[jr]=o,!this[jr]&&e[jr]&&(e[jr]=!1,e.emit("drain",n,[e,...i])),e[UQ]&&s.isEmpty()&&Promise.all(e[Zr].map(a=>a.close())).then(e[UQ])},this[ST]=(r,n)=>{e.emit("connect",r,[e,...n])},this[vT]=(r,n,i)=>{e.emit("disconnect",r,[e,...n],i)},this[RT]=(r,n,i)=>{e.emit("connectionError",r,[e,...n],i)},this[DT]=new k6(this)}get[x6](){return this[jr]}get[FQ](){return this[Zr].filter(e=>e[FQ]).length}get[S6](){return this[Zr].filter(e=>e[FQ]&&!e[jr]).length}get[xT](){let e=this[Pd];for(let{[xT]:r}of this[Zr])e+=r;return e}get[wT](){let e=0;for(let{[wT]:r}of this[Zr])e+=r;return e}get[NT](){let e=this[Pd];for(let{[NT]:r}of this[Zr])e+=r;return e}get stats(){return this[DT]}async[R6](){return this[Td].isEmpty()?Promise.all(this[Zr].map(e=>e.close())):new Promise(e=>{this[UQ]=e})}async[D6](e){for(;;){let r=this[Td].shift();if(!r)break;r.handler.onError(e)}return Promise.all(this[Zr].map(r=>r.destroy(e)))}[_6](e,r){let n=this[HQ]();return n?n.dispatch(e,r)||(n[jr]=!0,this[jr]=!this[HQ]()):(this[jr]=!0,this[Td].push({opts:e,handler:r}),this[Pd]++),!this[jr]}[_T](e){return e.on("drain",this[qQ]).on("connect",this[ST]).on("disconnect",this[vT]).on("connectionError",this[RT]),this[Zr].push(e),this[jr]&&process.nextTick(()=>{this[jr]&&this[qQ](e[v6],[this,e])}),this}[kT](e){e.close(()=>{let r=this[Zr].indexOf(e);r!==-1&&this[Zr].splice(r,1)}),this[jr]=this[Zr].some(r=>!r[jr]&&r.closed!==!0&&r.destroyed!==!0)}};PT.exports={PoolBase:zQ,kClients:Zr,kNeedDrain:jr,kAddClient:_T,kRemoveClient:kT,kGetDispatcher:HQ}});var uc=h((eke,MT)=>{"use strict";var{PoolBase:P6,kClients:Im,kNeedDrain:T6,kAddClient:O6,kGetDispatcher:M6}=jQ(),L6=kd(),{InvalidArgumentError:GQ}=at(),YQ=Fe(),{kUrl:TT,kInterceptors:F6}=yt(),U6=Nd(),JQ=Symbol("options"),VQ=Symbol("connections"),OT=Symbol("factory");function q6(t,e){return new L6(t,e)}var WQ=class extends P6{constructor(e,{connections:r,factory:n=q6,connect:i,connectTimeout:s,tls:o,maxCachedSessions:a,socketPath:A,autoSelectFamily:c,autoSelectFamilyAttemptTimeout:l,allowH2:u,...d}={}){if(super(),r!=null&&(!Number.isFinite(r)||r<0))throw new GQ("invalid connections");if(typeof n!="function")throw new GQ("factory must be a function.");if(i!=null&&typeof i!="function"&&typeof i!="object")throw new GQ("connect must be a function or an object");typeof i!="function"&&(i=U6({...o,maxCachedSessions:a,allowH2:u,socketPath:A,timeout:s,...YQ.nodeHasAutoSelectFamily&&c?{autoSelectFamily:c,autoSelectFamilyAttemptTimeout:l}:void 0,...i})),this[F6]=d.interceptors&&d.interceptors.Pool&&Array.isArray(d.interceptors.Pool)?d.interceptors.Pool:[],this[VQ]=r||null,this[TT]=YQ.parseOrigin(e),this[JQ]={...YQ.deepClone(d),connect:i,allowH2:u},this[JQ].interceptors=d.interceptors?{...d.interceptors}:void 0,this[OT]=n,this.on("connectionError",(f,g,m)=>{for(let E of g){let C=this[Im].indexOf(E);C!==-1&&this[Im].splice(C,1)}})}[M6](){let e=this[Im].fin
Line truncated
|
||||
${n.count} ${n.noun} ${n.is} pending:
|
||||
|
||||
${e.format(r)}
|
||||
@@ -260,7 +260,7 @@ ${r.comment}`:r.comment}this.doc.range[2]=r.offset;break}default:this.errors.pus
|
||||
`)+1;for(;r!==0;)this.onNewLine(this.offset+r),r=this.source.indexOf(`
|
||||
`,r)+1}yield*this.pop();break;default:yield*this.pop(),yield*this.step()}}*blockMap(e){let r=e.items[e.items.length-1];switch(this.type){case"newline":if(this.onKeyLine=!1,r.value){let n="end"in r.value?r.value.end:void 0;(Array.isArray(n)?n[n.length-1]:void 0)?.type==="comment"?n?.push(this.sourceToken):e.items.push({start:[this.sourceToken]})}else r.sep?r.sep.push(this.sourceToken):r.start.push(this.sourceToken);return;case"space":case"comment":if(r.value)e.items.push({start:[this.sourceToken]});else if(r.sep)r.sep.push(this.sourceToken);else{if(this.atIndentedComment(r.start,e.indent)){let i=e.items[e.items.length-2]?.value?.end;if(Array.isArray(i)){Array.prototype.push.apply(i,r.start),i.push(this.sourceToken),e.items.pop();return}}r.start.push(this.sourceToken)}return}if(this.indent>=e.indent){let n=!this.onKeyLine&&this.indent===e.indent,i=n&&(r.sep||r.explicitKey)&&this.type!=="seq-item-ind",s=[];if(i&&r.sep&&!r.value){let o=[];for(let a=0;a<r.sep.length;++a){let A=r.sep[a];switch(A.type){case"newline":o.push(a);break;case"space":break;case"comment":A.indent>e.indent&&(o.length=0);break;default:o.length=0}}o.length>=2&&(s=r.sep.splice(o[1]))}switch(this.type){case"anchor":case"tag":i||r.value?(s.push(this.sourceToken),e.items.push({start:s}),this.onKeyLine=!0):r.sep?r.sep.push(this.sourceToken):r.start.push(this.sourceToken);return;case"explicit-key-ind":!r.sep&&!r.explicitKey?(r.start.push(this.sourceToken),r.explicitKey=!0):i||r.value?(s.push(this.sourceToken),e.items.push({start:s,explicitKey:!0})):this.stack.push({type:"block-map",offset:this.offset,indent:this.indent,items:[{start:[this.sourceToken],explicitKey:!0}]}),this.onKeyLine=!0;return;case"map-value-ind":if(r.explicitKey)if(r.sep)if(r.value)e.items.push({start:[],key:null,sep:[this.sourceToken]});else if(NA(r.sep,"map-value-ind"))this.stack.push({type:"block-map",offset:this.offset,indent:this.indent,items:[{start:s,key:null,sep:[this.sourceToken]}]});else if(l9(r.key)&&!NA(r.sep,"newline")){let o=td(r.start),a=r.key,A=r.sep;A.push(this.sourceToken),delete r.key,delete r.sep,this.stack.push({type:"block-map",offset:this.offset,indent:this.indent,items:[{start:o,key:a,sep:A}]})}else s.length>0?r.sep=r.sep.concat(s,this.sourceToken):r.sep.push(this.sourceToken);else if(NA(r.start,"newline"))Object.assign(r,{key:null,sep:[this.sourceToken]});else{let o=td(r.start);this.stack.push({type:"block-map",offset:this.offset,indent:this.indent,items:[{start:o,key:null,sep:[this.sourceToken]}]})}else r.sep?r.value||i?e.items.push({start:s,key:null,sep:[this.sourceToken]}):NA(r.sep,"map-value-ind")?this.stack.push({type:"block-map",offset:this.offset,indent:this.indent,items:[{start:[],key:null,sep:[this.sourceToken]}]}):r.sep.push(this.sourceToken):Object.assign(r,{key:null,sep:[this.sourceToken]});this.onKeyLine=!0;return;case"alias":case"scalar":case"single-quoted-scalar":case"double-quoted-scalar":{let o=this.flowScalar(this.type);i||r.value?(e.items.push({start:s,key:o,sep:[]}),this.onKeyLine=!0):r.sep?this.stack.push(o):(Object.assign(r,{key:o,sep:[]}),this.onKeyLine=!0);return}default:{let o=this.startBlockValue(e);if(o){n&&o.type!=="block-seq"&&e.items.push({start:s}),this.stack.push(o);return}}}}yield*this.pop(),yield*this.step()}*blockSequence(e){let r=e.items[e.items.length-1];switch(this.type){case"newline":if(r.value){let n="end"in r.value?r.value.end:void 0;(Array.isArray(n)?n[n.length-1]:void 0)?.type==="comment"?n?.push(this.sourceToken):e.items.push({start:[this.sourceToken]})}else r.start.push(this.sourceToken);return;case"space":case"comment":if(r.value)e.items.push({start:[this.sourceToken]});else{if(this.atIndentedComment(r.start,e.indent)){let i=e.items[e.items.length-2]?.value?.end;if(Array.isArray(i)){Array.prototype.push.apply(i,r.start),i.push(this.sourceToken),e.items.pop();return}}r.start.push(this.sourceToken)}return;case"anchor":case"tag":if(r.value||this.indent<=e.indent)break;r.start.push(this.sourceToken);return;case"seq-item-ind":if(this.indent!==e.indent)break;r.value||NA(r.start,"seq-item-ind")?e.items.push({start:[this.sourceToken]}):r.start.push(this.sourceToken);return}if(this.indent>e.indent){let n=this.startBlockValue(e);if(n){this.stack.push(n);return}}yield*this.pop(),yield*this.step()}*flowCollection(e){let r=e.items[e.items.length-1];if(this.type==="flow-error-end"){let n;do yield*this.pop(),n=this.peek(1);while(n&&n.type==="flow-collection")}else if(e.end.length===0){switch(this.type){case"comma":case"explicit-key-ind":!r||r.sep?e.items.push({start:[this.sourceToken]}):r.start.push(this.sourceToken);return;case"map-value-ind":!r||r.value?e.items.push({start:[],key:null,sep:[this.sourceToken]}):r.sep?r.sep.push(this.sourceToken):Object.assign(r,{key:null,sep:[this.sourceToken]});return;case"space":case"comment":case"newline":case"anchor":case"tag":!r||r.value?e.items.push({start:[this.sourceToken]}):r.sep?r.sep.push(this.sourceToken):r.start.push(this.sourceToken);return;case"alias":case"scalar":case"singl
Line truncated
|
||||
`)+1;for(;r!==0;)this.onNewLine(this.offset+r),r=this.source.indexOf(`
|
||||
`,r)+1}return{type:e,offset:this.offset,indent:this.indent,source:this.source}}startBlockValue(e){switch(this.type){case"alias":case"scalar":case"single-quoted-scalar":case"double-quoted-scalar":return this.flowScalar(this.type);case"block-scalar-header":return{type:"block-scalar",offset:this.offset,indent:this.indent,props:[this.sourceToken],source:""};case"flow-map-start":case"flow-seq-start":return{type:"flow-collection",offset:this.offset,indent:this.indent,start:this.sourceToken,items:[],end:[]};case"seq-item-ind":return{type:"block-seq",offset:this.offset,indent:this.indent,items:[{start:[this.sourceToken]}]};case"explicit-key-ind":{this.onKeyLine=!0;let r=rB(e),n=td(r);return n.push(this.sourceToken),{type:"block-map",offset:this.offset,indent:this.indent,items:[{start:n,explicitKey:!0}]}}case"map-value-ind":{this.onKeyLine=!0;let r=rB(e),n=td(r);return{type:"block-map",offset:this.offset,indent:this.indent,items:[{start:n,key:null,sep:[this.sourceToken]}]}}}return null}atIndentedComment(e,r){return this.type!=="comment"||this.indent<=r?!1:e.every(n=>n.type==="newline"||n.type==="space")}*documentEnd(e){this.type!=="doc-mode"&&(e.end?e.end.push(this.sourceToken):e.end=[this.sourceToken],this.type==="newline"&&(yield*this.pop()))}*lineEnd(e){switch(this.type){case"comma":case"doc-start":case"doc-end":case"flow-seq-end":case"flow-map-end":case"map-value-ind":yield*this.pop(),yield*this.step();break;case"newline":this.onKeyLine=!1;default:e.end?e.end.push(this.sourceToken):e.end=[this.sourceToken],this.type==="newline"&&(yield*this.pop())}}};u9.Parser=g_});var m9=h(Rg=>{"use strict";var d9=r_(),fRe=Ig(),vg=bg(),hRe=eD(),gRe=qe(),mRe=h_(),f9=m_();function h9(t){let e=t.prettyErrors!==!1;return{lineCounter:t.lineCounter||e&&new mRe.LineCounter||null,prettyErrors:e}}function pRe(t,e={}){let{lineCounter:r,prettyErrors:n}=h9(e),i=new f9.Parser(r?.addNewLine),s=new d9.Composer(e),o=Array.from(s.compose(i.parse(t)));if(n&&r)for(let a of o)a.errors.forEach(vg.prettifyError(t,r)),a.warnings.forEach(vg.prettifyError(t,r));return o.length>0?o:Object.assign([],{empty:!0},s.streamInfo())}function g9(t,e={}){let{lineCounter:r,prettyErrors:n}=h9(e),i=new f9.Parser(r?.addNewLine),s=new d9.Composer(e),o=null;for(let a of s.compose(i.parse(t),!0,t.length))if(!o)o=a;else if(o.options.logLevel!=="silent"){o.errors.push(new vg.YAMLParseError(a.range.slice(0,2),"MULTIPLE_DOCS","Source contains multiple documents; please use YAML.parseAllDocuments()"));break}return n&&r&&(o.errors.forEach(vg.prettifyError(t,r)),o.warnings.forEach(vg.prettifyError(t,r))),o}function yRe(t,e,r){let n;typeof e=="function"?n=e:r===void 0&&e&&typeof e=="object"&&(r=e);let i=g9(t,r);if(!i)return null;if(i.warnings.forEach(s=>hRe.warn(i.options.logLevel,s)),i.errors.length>0){if(i.options.logLevel!=="silent")throw i.errors[0];i.errors=[]}return i.toJS(Object.assign({reviver:n},r))}function ERe(t,e,r){let n=null;if(typeof e=="function"||Array.isArray(e)?n=e:r===void 0&&e&&(r=e),typeof r=="string"&&(r=r.length),typeof r=="number"){let i=Math.round(r);r=i<1?void 0:i>8?{indent:8}:{indent:i}}if(t===void 0){let{keepUndefined:i}=r??e??{};if(!i)return}return gRe.isDocument(t)&&!n?t.toString(r):new fRe.Document(t,n,r).toString(r)}Rg.parse=yRe;Rg.parseAllDocuments=pRe;Rg.parseDocument=g9;Rg.stringify=ERe});var y_=h(et=>{"use strict";var CRe=r_(),IRe=Ig(),BRe=OD(),p_=bg(),QRe=ig(),ha=qe(),bRe=la(),NRe=er(),wRe=da(),xRe=fa(),SRe=eB(),vRe=d_(),RRe=h_(),DRe=m_(),nB=m9(),p9=eg();et.Composer=CRe.Composer;et.Document=IRe.Document;et.Schema=BRe.Schema;et.YAMLError=p_.YAMLError;et.YAMLParseError=p_.YAMLParseError;et.YAMLWarning=p_.YAMLWarning;et.Alias=QRe.Alias;et.isAlias=ha.isAlias;et.isCollection=ha.isCollection;et.isDocument=ha.isDocument;et.isMap=ha.isMap;et.isNode=ha.isNode;et.isPair=ha.isPair;et.isScalar=ha.isScalar;et.isSeq=ha.isSeq;et.Pair=bRe.Pair;et.Scalar=NRe.Scalar;et.YAMLMap=wRe.YAMLMap;et.YAMLSeq=xRe.YAMLSeq;et.CST=SRe;et.Lexer=vRe.Lexer;et.LineCounter=RRe.LineCounter;et.Parser=DRe.Parser;et.parse=nB.parse;et.parseAllDocuments=nB.parseAllDocuments;et.parseDocument=nB.parseDocument;et.stringify=nB.stringify;et.visit=p9.visit;et.visitAsync=p9.visitAsync});var hd=pt(ot());var g4=pt(ZC()),Gu=pt(ot());var l4=pt(ZC()),Ci=pt(ot()),u4=pt(rf()),d4=pt(c4()),f4=pt(require("os"));async function h4(t){let e=await WNe();(0,Ci.saveState)("cache_path",e);let r=await(0,d4.hashFiles)(t.cacheDependencyPath);if(!r)throw new Error("Some specified paths were not resolved, unable to cache dependencies.");let n=`pnpm-cache-${process.env.RUNNER_OS}-${f4.default.arch()}-${r}`;(0,Ci.debug)(`Primary key is ${n}`),(0,Ci.saveState)("cache_primary_key",n);let i=await(0,l4.restoreCache)([e],n);if((0,Ci.setOutput)("cache-hit",!!i),!i){(0,Ci.info)("Cache is not found");return}(0,Ci.saveState)("cache_restored_key",i),(0,Ci.info)(`Cache restored from key: ${i}`)}async function WNe(){let{stdout:t}=await(0,u4.getExecOutput)("pnpm store path --silent"),e=t.trim();return(0,Ci.debug)(`Cache folLine truncated
|
||||
`,r)+1}return{type:e,offset:this.offset,indent:this.indent,source:this.source}}startBlockValue(e){switch(this.type){case"alias":case"scalar":case"single-quoted-scalar":case"double-quoted-scalar":return this.flowScalar(this.type);case"block-scalar-header":return{type:"block-scalar",offset:this.offset,indent:this.indent,props:[this.sourceToken],source:""};case"flow-map-start":case"flow-seq-start":return{type:"flow-collection",offset:this.offset,indent:this.indent,start:this.sourceToken,items:[],end:[]};case"seq-item-ind":return{type:"block-seq",offset:this.offset,indent:this.indent,items:[{start:[this.sourceToken]}]};case"explicit-key-ind":{this.onKeyLine=!0;let r=rB(e),n=td(r);return n.push(this.sourceToken),{type:"block-map",offset:this.offset,indent:this.indent,items:[{start:n,explicitKey:!0}]}}case"map-value-ind":{this.onKeyLine=!0;let r=rB(e),n=td(r);return{type:"block-map",offset:this.offset,indent:this.indent,items:[{start:n,key:null,sep:[this.sourceToken]}]}}}return null}atIndentedComment(e,r){return this.type!=="comment"||this.indent<=r?!1:e.every(n=>n.type==="newline"||n.type==="space")}*documentEnd(e){this.type!=="doc-mode"&&(e.end?e.end.push(this.sourceToken):e.end=[this.sourceToken],this.type==="newline"&&(yield*this.pop()))}*lineEnd(e){switch(this.type){case"comma":case"doc-start":case"doc-end":case"flow-seq-end":case"flow-map-end":case"map-value-ind":yield*this.pop(),yield*this.step();break;case"newline":this.onKeyLine=!1;default:e.end?e.end.push(this.sourceToken):e.end=[this.sourceToken],this.type==="newline"&&(yield*this.pop())}}};u9.Parser=g_});var m9=h(Rg=>{"use strict";var d9=r_(),fRe=Ig(),vg=bg(),hRe=eD(),gRe=qe(),mRe=h_(),f9=m_();function h9(t){let e=t.prettyErrors!==!1;return{lineCounter:t.lineCounter||e&&new mRe.LineCounter||null,prettyErrors:e}}function pRe(t,e={}){let{lineCounter:r,prettyErrors:n}=h9(e),i=new f9.Parser(r?.addNewLine),s=new d9.Composer(e),o=Array.from(s.compose(i.parse(t)));if(n&&r)for(let a of o)a.errors.forEach(vg.prettifyError(t,r)),a.warnings.forEach(vg.prettifyError(t,r));return o.length>0?o:Object.assign([],{empty:!0},s.streamInfo())}function g9(t,e={}){let{lineCounter:r,prettyErrors:n}=h9(e),i=new f9.Parser(r?.addNewLine),s=new d9.Composer(e),o=null;for(let a of s.compose(i.parse(t),!0,t.length))if(!o)o=a;else if(o.options.logLevel!=="silent"){o.errors.push(new vg.YAMLParseError(a.range.slice(0,2),"MULTIPLE_DOCS","Source contains multiple documents; please use YAML.parseAllDocuments()"));break}return n&&r&&(o.errors.forEach(vg.prettifyError(t,r)),o.warnings.forEach(vg.prettifyError(t,r))),o}function yRe(t,e,r){let n;typeof e=="function"?n=e:r===void 0&&e&&typeof e=="object"&&(r=e);let i=g9(t,r);if(!i)return null;if(i.warnings.forEach(s=>hRe.warn(i.options.logLevel,s)),i.errors.length>0){if(i.options.logLevel!=="silent")throw i.errors[0];i.errors=[]}return i.toJS(Object.assign({reviver:n},r))}function ERe(t,e,r){let n=null;if(typeof e=="function"||Array.isArray(e)?n=e:r===void 0&&e&&(r=e),typeof r=="string"&&(r=r.length),typeof r=="number"){let i=Math.round(r);r=i<1?void 0:i>8?{indent:8}:{indent:i}}if(t===void 0){let{keepUndefined:i}=r??e??{};if(!i)return}return gRe.isDocument(t)&&!n?t.toString(r):new fRe.Document(t,n,r).toString(r)}Rg.parse=yRe;Rg.parseAllDocuments=pRe;Rg.parseDocument=g9;Rg.stringify=ERe});var y_=h(et=>{"use strict";var CRe=r_(),IRe=Ig(),BRe=OD(),p_=bg(),QRe=ig(),ha=qe(),bRe=la(),NRe=er(),wRe=da(),xRe=fa(),SRe=eB(),vRe=d_(),RRe=h_(),DRe=m_(),nB=m9(),p9=eg();et.Composer=CRe.Composer;et.Document=IRe.Document;et.Schema=BRe.Schema;et.YAMLError=p_.YAMLError;et.YAMLParseError=p_.YAMLParseError;et.YAMLWarning=p_.YAMLWarning;et.Alias=QRe.Alias;et.isAlias=ha.isAlias;et.isCollection=ha.isCollection;et.isDocument=ha.isDocument;et.isMap=ha.isMap;et.isNode=ha.isNode;et.isPair=ha.isPair;et.isScalar=ha.isScalar;et.isSeq=ha.isSeq;et.Pair=bRe.Pair;et.Scalar=NRe.Scalar;et.YAMLMap=wRe.YAMLMap;et.YAMLSeq=xRe.YAMLSeq;et.CST=SRe;et.Lexer=vRe.Lexer;et.LineCounter=RRe.LineCounter;et.Parser=DRe.Parser;et.parse=nB.parse;et.parseAllDocuments=nB.parseAllDocuments;et.parseDocument=nB.parseDocument;et.stringify=nB.stringify;et.visit=p9.visit;et.visitAsync=p9.visitAsync});var hd=pt(ot());var g4=pt(ZC()),Gu=pt(ot());var l4=pt(ZC()),Ci=pt(ot()),u4=pt(rf()),d4=pt(c4()),f4=pt(require("os"));async function h4(t){let e=await WNe();(0,Ci.saveState)("cache_path",e);let r=await(0,d4.hashFiles)(t.cacheDependencyPath);if(!r)throw new Error("Some specified paths were not resolved, unable to cache dependencies.");let n=`pnpm-cache-${process.env.RUNNER_OS}-${f4.default.arch()}-${r}`;(0,Ci.debug)(`Primary key is ${n}`),(0,Ci.saveState)("cache_primary_key",n);let i=await(0,l4.restoreCache)([e],n);if((0,Ci.setOutput)("cache-hit",!!i),!i){(0,Ci.info)("Cache is not found");return}(0,Ci.saveState)("cache_restored_key",i),(0,Ci.info)(`Cache restored from key: ${i}`)}async function WNe(){let{stdout:t}=await(0,u4.getExecOutput)("pnpm store path --silent"),e=t.trim();return(0,Ci.debug)(`Cache folLine truncated
|
||||
- version ${e} in the GitHub Action config with the key "version"
|
||||
- version ${i} in the package.json with the key "packageManager"
|
||||
Remove one of these versions to avoid version mismatch errors like ERR_PNPM_BAD_PM_VERSION`);return e}if(!(typeof i=="string"&&i.startsWith("pnpm@"))&&!(s?.packageManager?.name==="pnpm"&&s.packageManager.version))throw n?new Error(`No pnpm version is specified.
|
||||
|
||||
Reference in new issue
Block a user