0&&(k=_[0]),k instanceof Error)throw k;var j=new Error("Unhandled error."+(k?" ("+k.message+")":""));throw j.context=k,j}var U=I[A];if(U===void 0)return!1;if(typeof U=="function")h(U,this,_);else for(var P=U.length,z=b(U,P),C=0;C0&&j.length>I&&!j.warned){j.warned=!0;var U=new Error("Possible EventEmitter memory leak detected. "+j.length+" "+String(_)+" listeners added. Use emitter.setMaxListeners() to increase limit");U.name="MaxListenersExceededWarning",U.emitter=A,U.type=_,U.count=j.length,a(U)}return A}n.prototype.addListener=function(A,_){return i(this,A,_,!1)},n.prototype.on=n.prototype.addListener,n.prototype.prependListener=function(A,_){return i(this,A,_,!0)};function l(){if(!this.fired)return this.target.removeListener(this.type,this.wrapFn),this.fired=!0,arguments.length===0?this.listener.call(this.target):this.listener.apply(this.target,arguments)}function d(A,_,C){var w={fired:!1,wrapFn:void 0,target:A,type:_,listener:C},I=l.bind(w);return I.listener=C,w.wrapFn=I,I}n.prototype.once=function(A,_){return t(_),this.on(A,d(this,A,_)),this},n.prototype.prependOnceListener=function(A,_){return t(_),this.prependListener(A,d(this,A,_)),this},n.prototype.removeListener=function(A,_){var C,w,I,k,j;if(t(_),w=this._events,w===void 0)return this;if(C=w[A],C===void 0)return this;if(C===_||C.listener===_)--this._eventsCount===0?this._events=Object.create(null):(delete w[A],w.removeListener&&this.emit("removeListener",A,C.listener||_));else if(typeof C!="function"){for(I=-1,k=C.length-1;k>=0;k--)if(C[k]===_||C[k].listener===_){j=C[k].listener,I=k;break}if(I<0)return this;I===0?C.shift():E(C,I),C.length===1&&(w[A]=C[0]),w.removeListener!==void 0&&this.emit("removeListener",A,j||_)}return this},n.prototype.off=n.prototype.removeListener,n.prototype.removeAllListeners=function(A){var _,C,w;if(C=this._events,C===void 0)return this;if(C.removeListener===void 0)return arguments.length===0?(this._events=Object.create(null),this._eventsCount=0):C[A]!==void 0&&(--this._eventsCount===0?this._events=Object.create(null):delete C[A]),this;if(arguments.length===0){var I=Object.keys(C),k;for(w=0;w=0;w--)this.removeListener(A,_[w]);return this};function p(A,_,C){var w=A._events;if(w===void 0)return[];var I=w[_];return I===void 0?[]:typeof I=="function"?C?[I.listener||I]:[I]:C?S(I):b(I,I.length)}n.prototype.listeners=function(A){return p(this,A,!0)},n.prototype.rawListeners=function(A){return p(this,A,!1)},n.listenerCount=function(A,_){return typeof A.listenerCount=="function"?A.listenerCount(_):g.call(A,_)},n.prototype.listenerCount=g;function g(A){var _=this._events;if(_!==void 0){var C=_[A];if(typeof C=="function")return 1;if(C!==void 0)return C.length}return 0}n.prototype.eventNames=function(){return this._eventsCount>0?s(this._events):[]};function b(A,_){for(var C=new Array(_),w=0;w<_;++w)C[w]=A[w];return C}function E(A,_){for(;_+1{ge(),me(),ye(),hr={},di=!1,nr=Kl(),nr.once,nr.once=function(f,h){return new Promise((s,a)=>{function c(...r){n!==void 0&&f.removeListener("error",n),s(r)}let n;h!=="error"&&(n=r=>{f.removeListener(name,c),a(r)},f.once("error",n)),f.once(h,c)})},nr.on=function(f,h){let s=[],a=[],c=null,n=!1,r={async next(){let i=s.shift();if(i)return createIterResult(i,!1);if(c){let l=Promise.reject(c);return c=null,l}return n?createIterResult(void 0,!0):new Promise((l,d)=>a.push({resolve:l,reject:d}))},async return(){f.removeListener(h,t),f.removeListener("error",e),n=!0;for(let i of a)i.resolve(createIterResult(void 0,!0));return createIterResult(void 0,!0)},throw(i){c=i,f.removeListener(h,t),f.removeListener("error",e)},[Symbol.asyncIterator](){return this}};return f.on(h,t),f.on("error",e),r;function t(...i){let l=a.shift();l?l.resolve(createIterResult(i,!1)):s.push(i)}function e(i){n=!0;let l=a.shift();l?l.reject(i):c=i,r.return()}},{EventEmitter:Ys,defaultMaxListeners:Js,init:Xs,listenerCount:Zs,on:ea,once:ta}=nr}),gt=Se((f,h)=>{ge(),me(),ye();var s=(st(),Ke(ot)),{format:a,inspect:c}=Qs(),{codes:{ERR_INVALID_ARG_TYPE:n}}=pt(),{kResistStopPropagation:r,AggregateError:t,SymbolDispose:e}=Ze(),i=globalThis.AbortSignal||gr().AbortSignal,l=globalThis.AbortController||gr().AbortController,d=Object.getPrototypeOf(async function(){}).constructor,p=globalThis.Blob||s.Blob,g=typeof p<"u"?function(S){return S instanceof p}:function(S){return!1},b=(S,x)=>{if(S!==void 0&&(S===null||typeof S!="object"||!("aborted"in S)))throw new n(x,"AbortSignal",S)},E=(S,x)=>{if(typeof S!="function")throw new n(x,"Function",S)};h.exports={AggregateError:t,kEmptyObject:Object.freeze({}),once(S){let x=!1;return function(...y){x||(x=!0,S.apply(this,y))}},createDeferredPromise:function(){let S,x;return{promise:new Promise((y,v)=>{S=y,x=v}),resolve:S,reject:x}},promisify(S){return new Promise((x,y)=>{S((v,...A)=>v?y(v):x(...A))})},debuglog(){return function(){}},format:a,inspect:c,types:{isAsyncFunction(S){return S instanceof d},isArrayBufferView(S){return ArrayBuffer.isView(S)}},isBlob:g,deprecate(S,x){return S},addAbortListener:(Zt(),Ke(qt)).addAbortListener||function(S,x){if(S===void 0)throw new n("signal","AbortSignal",S);b(S,"signal"),E(x,"listener");let y;return S.aborted?queueMicrotask(()=>x()):(S.addEventListener("abort",x,{__proto__:null,once:!0,[r]:!0}),y=()=>{S.removeEventListener("abort",x)}),{__proto__:null,[e](){var v;(v=y)===null||v===void 0||v()}}},AbortSignalAny:i.any||function(S){if(S.length===1)return S[0];let x=new l,y=()=>x.abort();return S.forEach(v=>{b(v,"signals"),v.addEventListener("abort",y,{once:!0})}),x.signal.addEventListener("abort",()=>{S.forEach(v=>v.removeEventListener("abort",y))},{once:!0}),x.signal}},h.exports.promisify.custom=Symbol.for("nodejs.util.promisify.custom")}),yr=Se((f,h)=>{ge(),me(),ye();var{ArrayIsArray:s,ArrayPrototypeIncludes:a,ArrayPrototypeJoin:c,ArrayPrototypeMap:n,NumberIsInteger:r,NumberIsNaN:t,NumberMAX_SAFE_INTEGER:e,NumberMIN_SAFE_INTEGER:i,NumberParseInt:l,ObjectPrototypeHasOwnProperty:d,RegExpPrototypeExec:p,String:g,StringPrototypeToUpperCase:b,StringPrototypeTrim:E}=Ze(),{hideStackFrames:S,codes:{ERR_SOCKET_BAD_PORT:x,ERR_INVALID_ARG_TYPE:y,ERR_INVALID_ARG_VALUE:v,ERR_OUT_OF_RANGE:A,ERR_UNKNOWN_SIGNAL:_}}=pt(),{normalizeEncoding:C}=gt(),{isAsyncFunction:w,isArrayBufferView:I}=gt().types,k={};function j(Q){return Q===(Q|0)}function U(Q){return Q===Q>>>0}var P=/^[0-7]+$/,z="must be a 32-bit unsigned integer or an octal string";function G(Q,_e,Oe){if(typeof Q>"u"&&(Q=Oe),typeof Q=="string"){if(p(P,Q)===null)throw new v(_e,Q,z);Q=l(Q,8)}return ne(Q,_e),Q}var q=S((Q,_e,Oe=i,fe=e)=>{if(typeof Q!="number")throw new y(_e,"number",Q);if(!r(Q))throw new A(_e,"an integer",Q);if(Qfe)throw new A(_e,`>= ${Oe} && <= ${fe}`,Q)}),he=S((Q,_e,Oe=-2147483648,fe=2147483647)=>{if(typeof Q!="number")throw new y(_e,"number",Q);if(!r(Q))throw new A(_e,"an integer",Q);if(Qfe)throw new A(_e,`>= ${Oe} && <= ${fe}`,Q)}),ne=S((Q,_e,Oe=!1)=>{if(typeof Q!="number")throw new y(_e,"number",Q);if(!r(Q))throw new A(_e,"an integer",Q);let fe=Oe?1:0,Be=4294967295;if(QBe)throw new A(_e,`>= ${fe} && <= ${Be}`,Q)});function te(Q,_e){if(typeof Q!="string")throw new y(_e,"string",Q)}function ce(Q,_e,Oe=void 0,fe){if(typeof Q!="number")throw new y(_e,"number",Q);if(Oe!=null&&Qfe||(Oe!=null||fe!=null)&&t(Q))throw new A(_e,`${Oe!=null?`>= ${Oe}`:""}${Oe!=null&&fe!=null?" && ":""}${fe!=null?`<= ${fe}`:""}`,Q)}var V=S((Q,_e,Oe)=>{if(!a(Oe,Q)){let fe="must be one of: "+c(n(Oe,Be=>typeof Be=="string"?`'${Be}'`:g(Be)),", ");throw new v(_e,Q,fe)}});function le(Q,_e){if(typeof Q!="boolean")throw new y(_e,"boolean",Q)}function M(Q,_e,Oe){return Q==null||!d(Q,_e)?Oe:Q[_e]}var ee=S((Q,_e,Oe=null)=>{let fe=M(Oe,"allowArray",!1),Be=M(Oe,"allowFunction",!1);if(!M(Oe,"nullable",!1)&&Q===null||!fe&&s(Q)||typeof Q!="object"&&(!Be||typeof Q!="function"))throw new y(_e,"Object",Q)}),Z=S((Q,_e)=>{if(Q!=null&&typeof Q!="object"&&typeof Q!="function")throw new y(_e,"a dictionary",Q)}),ue=S((Q,_e,Oe=0)=>{if(!s(Q))throw new y(_e,"Array",Q);if(Q.length{if(!I(Q))throw new y(_e,["Buffer","TypedArray","DataView"],Q)});function J(Q,_e){let Oe=C(_e),fe=Q.length;if(Oe==="hex"&&fe%2!==0)throw new v("encoding",_e,`is invalid for data of length ${fe}`)}function re(Q,_e="Port",Oe=!0){if(typeof Q!="number"&&typeof Q!="string"||typeof Q=="string"&&E(Q).length===0||+Q!==+Q>>>0||Q>65535||Q===0&&!Oe)throw new x(_e,Q,Oe);return Q|0}var we=S((Q,_e)=>{if(Q!==void 0&&(Q===null||typeof Q!="object"||!("aborted"in Q)))throw new y(_e,"AbortSignal",Q)}),pe=S((Q,_e)=>{if(typeof Q!="function")throw new y(_e,"Function",Q)}),L=S((Q,_e)=>{if(typeof Q!="function"||w(Q))throw new y(_e,"Function",Q)}),H=S((Q,_e)=>{if(Q!==void 0)throw new y(_e,"undefined",Q)});function se(Q,_e,Oe){if(!a(Oe,Q))throw new y(_e,`('${c(Oe,"|")}')`,Q)}var be=/^(?:<[^>]*>)(?:\s*;\s*[^;"\s]+(?:=(")?[^;"\s]*\1)?)*$/;function ve(Q,_e){if(typeof Q>"u"||!p(be,Q))throw new v(_e,Q,'must be an array or string of format "; rel=preload; as=style"')}function Ee(Q){if(typeof Q=="string")return ve(Q,"hints"),Q;if(s(Q)){let _e=Q.length,Oe="";if(_e===0)return Oe;for(let fe=0;fe<_e;fe++){let Be=Q[fe];ve(Be,"hints"),Oe+=Be,fe!==_e-1&&(Oe+=", ")}return Oe}throw new v("hints",Q,'must be an array or string of format "; rel=preload; as=style"')}h.exports={isInt32:j,isUint32:U,parseFileMode:G,validateArray:ue,validateStringArray:Ae,validateBooleanArray:Y,validateAbortSignalArray:W,validateBoolean:le,validateBuffer:X,validateDictionary:Z,validateEncoding:J,validateFunction:pe,validateInt32:he,validateInteger:q,validateNumber:ce,validateObject:ee,validateOneOf:V,validatePlainFunction:L,validatePort:re,validateSignalName:oe,validateString:te,validateUint32:ne,validateUndefined:H,validateUnion:se,validateAbortSignal:we,validateLinkHeaderValue:Ee}}),er=Se((f,h)=>{ge(),me(),ye();var s=h.exports={},a,c;function n(){throw new Error("setTimeout has not been defined")}function r(){throw new Error("clearTimeout has not been defined")}(function(){try{typeof setTimeout=="function"?a=setTimeout:a=n}catch{a=n}try{typeof clearTimeout=="function"?c=clearTimeout:c=r}catch{c=r}})();function t(x){if(a===setTimeout)return setTimeout(x,0);if((a===n||!a)&&setTimeout)return a=setTimeout,setTimeout(x,0);try{return a(x,0)}catch{try{return a.call(null,x,0)}catch{return a.call(this,x,0)}}}function e(x){if(c===clearTimeout)return clearTimeout(x);if((c===r||!c)&&clearTimeout)return c=clearTimeout,clearTimeout(x);try{return c(x)}catch{try{return c.call(null,x)}catch{return c.call(this,x)}}}var i=[],l=!1,d,p=-1;function g(){!l||!d||(l=!1,d.length?i=d.concat(i):p=-1,i.length&&b())}function b(){if(!l){var x=t(g);l=!0;for(var y=i.length;y;){for(d=i,i=[];++p1)for(var v=1;v{ge(),me(),ye();var{SymbolAsyncIterator:s,SymbolIterator:a,SymbolFor:c}=Ze(),n=c("nodejs.stream.destroyed"),r=c("nodejs.stream.errored"),t=c("nodejs.stream.readable"),e=c("nodejs.stream.writable"),i=c("nodejs.stream.disturbed"),l=c("nodejs.webstream.isClosedPromise"),d=c("nodejs.webstream.controllerErrorFunction");function p(M,ee=!1){var Z;return!!(M&&typeof M.pipe=="function"&&typeof M.on=="function"&&(!ee||typeof M.pause=="function"&&typeof M.resume=="function")&&(!M._writableState||((Z=M._readableState)===null||Z===void 0?void 0:Z.readable)!==!1)&&(!M._writableState||M._readableState))}function g(M){var ee;return!!(M&&typeof M.write=="function"&&typeof M.on=="function"&&(!M._readableState||((ee=M._writableState)===null||ee===void 0?void 0:ee.writable)!==!1))}function b(M){return!!(M&&typeof M.pipe=="function"&&M._readableState&&typeof M.on=="function"&&typeof M.write=="function")}function E(M){return M&&(M._readableState||M._writableState||typeof M.write=="function"&&typeof M.on=="function"||typeof M.pipe=="function"&&typeof M.on=="function")}function S(M){return!!(M&&!E(M)&&typeof M.pipeThrough=="function"&&typeof M.getReader=="function"&&typeof M.cancel=="function")}function x(M){return!!(M&&!E(M)&&typeof M.getWriter=="function"&&typeof M.abort=="function")}function y(M){return!!(M&&!E(M)&&typeof M.readable=="object"&&typeof M.writable=="object")}function v(M){return S(M)||x(M)||y(M)}function A(M,ee){return M==null?!1:ee===!0?typeof M[s]=="function":ee===!1?typeof M[a]=="function":typeof M[s]=="function"||typeof M[a]=="function"}function _(M){if(!E(M))return null;let ee=M._writableState,Z=M._readableState,ue=ee||Z;return!!(M.destroyed||M[n]||ue!=null&&ue.destroyed)}function C(M){if(!g(M))return null;if(M.writableEnded===!0)return!0;let ee=M._writableState;return ee!=null&&ee.errored?!1:typeof ee?.ended!="boolean"?null:ee.ended}function w(M,ee){if(!g(M))return null;if(M.writableFinished===!0)return!0;let Z=M._writableState;return Z!=null&&Z.errored?!1:typeof Z?.finished!="boolean"?null:!!(Z.finished||ee===!1&&Z.ended===!0&&Z.length===0)}function I(M){if(!p(M))return null;if(M.readableEnded===!0)return!0;let ee=M._readableState;return!ee||ee.errored?!1:typeof ee?.ended!="boolean"?null:ee.ended}function k(M,ee){if(!p(M))return null;let Z=M._readableState;return Z!=null&&Z.errored?!1:typeof Z?.endEmitted!="boolean"?null:!!(Z.endEmitted||ee===!1&&Z.ended===!0&&Z.length===0)}function j(M){return M&&M[t]!=null?M[t]:typeof M?.readable!="boolean"?null:_(M)?!1:p(M)&&M.readable&&!k(M)}function U(M){return M&&M[e]!=null?M[e]:typeof M?.writable!="boolean"?null:_(M)?!1:g(M)&&M.writable&&!C(M)}function P(M,ee){return E(M)?_(M)?!0:!(ee?.readable!==!1&&j(M)||ee?.writable!==!1&&U(M)):null}function z(M){var ee,Z;return E(M)?M.writableErrored?M.writableErrored:(ee=(Z=M._writableState)===null||Z===void 0?void 0:Z.errored)!==null&&ee!==void 0?ee:null:null}function G(M){var ee,Z;return E(M)?M.readableErrored?M.readableErrored:(ee=(Z=M._readableState)===null||Z===void 0?void 0:Z.errored)!==null&&ee!==void 0?ee:null:null}function q(M){if(!E(M))return null;if(typeof M.closed=="boolean")return M.closed;let ee=M._writableState,Z=M._readableState;return typeof ee?.closed=="boolean"||typeof Z?.closed=="boolean"?ee?.closed||Z?.closed:typeof M._closed=="boolean"&&he(M)?M._closed:null}function he(M){return typeof M._closed=="boolean"&&typeof M._defaultKeepAlive=="boolean"&&typeof M._removedConnection=="boolean"&&typeof M._removedContLen=="boolean"}function ne(M){return typeof M._sent100=="boolean"&&he(M)}function te(M){var ee;return typeof M._consuming=="boolean"&&typeof M._dumped=="boolean"&&((ee=M.req)===null||ee===void 0?void 0:ee.upgradeOrConnect)===void 0}function ce(M){if(!E(M))return null;let ee=M._writableState,Z=M._readableState,ue=ee||Z;return!ue&&ne(M)||!!(ue&&ue.autoDestroy&&ue.emitClose&&ue.closed===!1)}function V(M){var ee;return!!(M&&((ee=M[i])!==null&&ee!==void 0?ee:M.readableDidRead||M.readableAborted))}function le(M){var ee,Z,ue,Ae,Y,W,oe,X,J,re;return!!(M&&((ee=(Z=(ue=(Ae=(Y=(W=M[r])!==null&&W!==void 0?W:M.readableErrored)!==null&&Y!==void 0?Y:M.writableErrored)!==null&&Ae!==void 0?Ae:(oe=M._readableState)===null||oe===void 0?void 0:oe.errorEmitted)!==null&&ue!==void 0?ue:(X=M._writableState)===null||X===void 0?void 0:X.errorEmitted)!==null&&Z!==void 0?Z:(J=M._readableState)===null||J===void 0?void 0:J.errored)!==null&&ee!==void 0?ee:!((re=M._writableState)===null||re===void 0)&&re.errored))}h.exports={isDestroyed:_,kIsDestroyed:n,isDisturbed:V,kIsDisturbed:i,isErrored:le,kIsErrored:r,isReadable:j,kIsReadable:t,kIsClosedPromise:l,kControllerErrorFunction:d,kIsWritable:e,isClosed:q,isDuplexNodeStream:b,isFinished:P,isIterable:A,isReadableNodeStream:p,isReadableStream:S,isReadableEnded:I,isReadableFinished:k,isReadableErrored:G,isNodeStream:E,isWebStream:v,isWritable:U,isWritableNodeStream:g,isWritableStream:x,isWritableEnded:C,isWritableFinished:w,isWritableErrored:z,isServerRequest:te,isServerResponse:ne,willEmitClose:ce,isTransformStream:y}}),Vt=Se((f,h)=>{ge(),me(),ye();var s=er(),{AbortError:a,codes:c}=pt(),{ERR_INVALID_ARG_TYPE:n,ERR_STREAM_PREMATURE_CLOSE:r}=c,{kEmptyObject:t,once:e}=gt(),{validateAbortSignal:i,validateFunction:l,validateObject:d,validateBoolean:p}=yr(),{Promise:g,PromisePrototypeThen:b,SymbolDispose:E}=Ze(),{isClosed:S,isReadable:x,isReadableNodeStream:y,isReadableStream:v,isReadableFinished:A,isReadableErrored:_,isWritable:C,isWritableNodeStream:w,isWritableStream:I,isWritableFinished:k,isWritableErrored:j,isNodeStream:U,willEmitClose:P,kIsClosedPromise:z}=Ct(),G;function q(V){return V.setHeader&&typeof V.abort=="function"}var he=()=>{};function ne(V,le,M){var ee,Z;if(arguments.length===2?(M=le,le=t):le==null?le=t:d(le,"options"),l(M,"callback"),i(le.signal,"options.signal"),M=e(M),v(V)||I(V))return te(V,le,M);if(!U(V))throw new n("stream",["ReadableStream","WritableStream","Stream"],V);let ue=(ee=le.readable)!==null&&ee!==void 0?ee:y(V),Ae=(Z=le.writable)!==null&&Z!==void 0?Z:w(V),Y=V._writableState,W=V._readableState,oe=()=>{V.writable||re()},X=P(V)&&y(V)===ue&&w(V)===Ae,J=k(V,!1),re=()=>{J=!0,V.destroyed&&(X=!1),!(X&&(!V.readable||ue))&&(!ue||we)&&M.call(V)},we=A(V,!1),pe=()=>{we=!0,V.destroyed&&(X=!1),!(X&&(!V.writable||Ae))&&(!Ae||J)&&M.call(V)},L=Q=>{M.call(V,Q)},H=S(V),se=()=>{H=!0;let Q=j(V)||_(V);if(Q&&typeof Q!="boolean")return M.call(V,Q);if(ue&&!we&&y(V,!0)&&!A(V,!1))return M.call(V,new r);if(Ae&&!J&&!k(V,!1))return M.call(V,new r);M.call(V)},be=()=>{H=!0;let Q=j(V)||_(V);if(Q&&typeof Q!="boolean")return M.call(V,Q);M.call(V)},ve=()=>{V.req.on("finish",re)};q(V)?(V.on("complete",re),X||V.on("abort",se),V.req?ve():V.on("request",ve)):Ae&&!Y&&(V.on("end",oe),V.on("close",oe)),!X&&typeof V.aborted=="boolean"&&V.on("aborted",se),V.on("end",pe),V.on("finish",re),le.error!==!1&&V.on("error",L),V.on("close",se),H?s.nextTick(se):Y!=null&&Y.errorEmitted||W!=null&&W.errorEmitted?X||s.nextTick(be):(!ue&&(!X||x(V))&&(J||C(V)===!1)||!Ae&&(!X||C(V))&&(we||x(V)===!1)||W&&V.req&&V.aborted)&&s.nextTick(be);let Ee=()=>{M=he,V.removeListener("aborted",se),V.removeListener("complete",re),V.removeListener("abort",se),V.removeListener("request",ve),V.req&&V.req.removeListener("finish",re),V.removeListener("end",oe),V.removeListener("close",oe),V.removeListener("finish",re),V.removeListener("end",pe),V.removeListener("error",L),V.removeListener("close",se)};if(le.signal&&!H){let Q=()=>{let _e=M;Ee(),_e.call(V,new a(void 0,{cause:le.signal.reason}))};if(le.signal.aborted)s.nextTick(Q);else{G=G||gt().addAbortListener;let _e=G(le.signal,Q),Oe=M;M=e((...fe)=>{_e[E](),Oe.apply(V,fe)})}}return Ee}function te(V,le,M){let ee=!1,Z=he;if(le.signal)if(Z=()=>{ee=!0,M.call(V,new a(void 0,{cause:le.signal.reason}))},le.signal.aborted)s.nextTick(Z);else{G=G||gt().addAbortListener;let Ae=G(le.signal,Z),Y=M;M=e((...W)=>{Ae[E](),Y.apply(V,W)})}let ue=(...Ae)=>{ee||s.nextTick(()=>M.apply(V,Ae))};return b(V[z].promise,ue,ue),he}function ce(V,le){var M;let ee=!1;return le===null&&(le=t),(M=le)!==null&&M!==void 0&&M.cleanup&&(p(le.cleanup,"cleanup"),ee=le.cleanup),new g((Z,ue)=>{let Ae=ne(V,le,Y=>{ee&&Ae(),Y?ue(Y):Z()})})}h.exports=ne,h.exports.finished=ce}),sr=Se((f,h)=>{ge(),me(),ye();var s=er(),{aggregateTwoErrors:a,codes:{ERR_MULTIPLE_CALLBACK:c},AbortError:n}=pt(),{Symbol:r}=Ze(),{kIsDestroyed:t,isDestroyed:e,isFinished:i,isServerRequest:l}=Ct(),d=r("kDestroy"),p=r("kConstruct");function g(P,z,G){P&&(P.stack,z&&!z.errored&&(z.errored=P),G&&!G.errored&&(G.errored=P))}function b(P,z){let G=this._readableState,q=this._writableState,he=q||G;return q!=null&&q.destroyed||G!=null&&G.destroyed?(typeof z=="function"&&z(),this):(g(P,q,G),q&&(q.destroyed=!0),G&&(G.destroyed=!0),he.constructed?E(this,P,z):this.once(d,function(ne){E(this,a(ne,P),z)}),this)}function E(P,z,G){let q=!1;function he(ne){if(q)return;q=!0;let te=P._readableState,ce=P._writableState;g(ne,ce,te),ce&&(ce.closed=!0),te&&(te.closed=!0),typeof G=="function"&&G(ne),ne?s.nextTick(S,P,ne):s.nextTick(x,P)}try{P._destroy(z||null,he)}catch(ne){he(ne)}}function S(P,z){y(P,z),x(P)}function x(P){let z=P._readableState,G=P._writableState;G&&(G.closeEmitted=!0),z&&(z.closeEmitted=!0),(G!=null&&G.emitClose||z!=null&&z.emitClose)&&P.emit("close")}function y(P,z){let G=P._readableState,q=P._writableState;q!=null&&q.errorEmitted||G!=null&&G.errorEmitted||(q&&(q.errorEmitted=!0),G&&(G.errorEmitted=!0),P.emit("error",z))}function v(){let P=this._readableState,z=this._writableState;P&&(P.constructed=!0,P.closed=!1,P.closeEmitted=!1,P.destroyed=!1,P.errored=null,P.errorEmitted=!1,P.reading=!1,P.ended=P.readable===!1,P.endEmitted=P.readable===!1),z&&(z.constructed=!0,z.destroyed=!1,z.closed=!1,z.closeEmitted=!1,z.errored=null,z.errorEmitted=!1,z.finalCalled=!1,z.prefinished=!1,z.ended=z.writable===!1,z.ending=z.writable===!1,z.finished=z.writable===!1)}function A(P,z,G){let q=P._readableState,he=P._writableState;if(he!=null&&he.destroyed||q!=null&&q.destroyed)return this;q!=null&&q.autoDestroy||he!=null&&he.autoDestroy?P.destroy(z):z&&(z.stack,he&&!he.errored&&(he.errored=z),q&&!q.errored&&(q.errored=z),G?s.nextTick(y,P,z):y(P,z))}function _(P,z){if(typeof P._construct!="function")return;let G=P._readableState,q=P._writableState;G&&(G.constructed=!1),q&&(q.constructed=!1),P.once(p,z),!(P.listenerCount(p)>1)&&s.nextTick(C,P)}function C(P){let z=!1;function G(q){if(z){A(P,q??new c);return}z=!0;let he=P._readableState,ne=P._writableState,te=ne||he;he&&(he.constructed=!0),ne&&(ne.constructed=!0),te.destroyed?P.emit(d,q):q?A(P,q,!0):s.nextTick(w,P)}try{P._construct(q=>{s.nextTick(G,q)})}catch(q){s.nextTick(G,q)}}function w(P){P.emit(p)}function I(P){return P?.setHeader&&typeof P.abort=="function"}function k(P){P.emit("close")}function j(P,z){P.emit("error",z),s.nextTick(k,P)}function U(P,z){!P||e(P)||(!z&&!i(P)&&(z=new n),l(P)?(P.socket=null,P.destroy(z)):I(P)?P.abort():I(P.req)?P.req.abort():typeof P.destroy=="function"?P.destroy(z):typeof P.close=="function"?P.close():z?s.nextTick(j,P,z):s.nextTick(k,P),P.destroyed||(P[t]=!0))}h.exports={construct:_,destroyer:U,destroy:b,undestroy:v,errorOrDestroy:A}}),co=Se((f,h)=>{ge(),me(),ye();var{ArrayIsArray:s,ObjectSetPrototypeOf:a}=Ze(),{EventEmitter:c}=(Zt(),Ke(qt));function n(t){c.call(this,t)}a(n.prototype,c.prototype),a(n,c),n.prototype.pipe=function(t,e){let i=this;function l(x){t.writable&&t.write(x)===!1&&i.pause&&i.pause()}i.on("data",l);function d(){i.readable&&i.resume&&i.resume()}t.on("drain",d),!t._isStdio&&(!e||e.end!==!1)&&(i.on("end",g),i.on("close",b));let p=!1;function g(){p||(p=!0,t.end())}function b(){p||(p=!0,typeof t.destroy=="function"&&t.destroy())}function E(x){S(),c.listenerCount(this,"error")===0&&this.emit("error",x)}r(i,"error",E),r(t,"error",E);function S(){i.removeListener("data",l),t.removeListener("drain",d),i.removeListener("end",g),i.removeListener("close",b),i.removeListener("error",E),t.removeListener("error",E),i.removeListener("end",S),i.removeListener("close",S),t.removeListener("close",S)}return i.on("end",S),i.on("close",S),t.on("close",S),t.emit("pipe",i),t};function r(t,e,i){if(typeof t.prependListener=="function")return t.prependListener(e,i);!t._events||!t._events[e]?t.on(e,i):s(t._events[e])?t._events[e].unshift(i):t._events[e]=[i,t._events[e]]}h.exports={Stream:n,prependListener:r}}),Yr=Se((f,h)=>{ge(),me(),ye();var{SymbolDispose:s}=Ze(),{AbortError:a,codes:c}=pt(),{isNodeStream:n,isWebStream:r,kControllerErrorFunction:t}=Ct(),e=Vt(),{ERR_INVALID_ARG_TYPE:i}=c,l,d=(p,g)=>{if(typeof p!="object"||!("aborted"in p))throw new i(g,"AbortSignal",p)};h.exports.addAbortSignal=function(p,g){if(d(p,"signal"),!n(g)&&!r(g))throw new i("stream",["ReadableStream","WritableStream","Stream"],g);return h.exports.addAbortSignalNoValidate(p,g)},h.exports.addAbortSignalNoValidate=function(p,g){if(typeof p!="object"||!("aborted"in p))return g;let b=n(g)?()=>{g.destroy(new a(void 0,{cause:p.reason}))}:()=>{g[t](new a(void 0,{cause:p.reason}))};if(p.aborted)b();else{l=l||gt().addAbortListener;let E=l(p,b);e(g,E[s])}return g}}),Hl=Se((f,h)=>{ge(),me(),ye();var{StringPrototypeSlice:s,SymbolIterator:a,TypedArrayPrototypeSet:c,Uint8Array:n}=Ze(),{Buffer:r}=(st(),Ke(ot)),{inspect:t}=gt();h.exports=class{constructor(){this.head=null,this.tail=null,this.length=0}push(e){let i={data:e,next:null};this.length>0?this.tail.next=i:this.head=i,this.tail=i,++this.length}unshift(e){let i={data:e,next:this.head};this.length===0&&(this.tail=i),this.head=i,++this.length}shift(){if(this.length===0)return;let e=this.head.data;return this.length===1?this.head=this.tail=null:this.head=this.head.next,--this.length,e}clear(){this.head=this.tail=null,this.length=0}join(e){if(this.length===0)return"";let i=this.head,l=""+i.data;for(;(i=i.next)!==null;)l+=e+i.data;return l}concat(e){if(this.length===0)return r.alloc(0);let i=r.allocUnsafe(e>>>0),l=this.head,d=0;for(;l;)c(i,l.data,d),d+=l.data.length,l=l.next;return i}consume(e,i){let l=this.head.data;if(ep.length)i+=p,e-=p.length;else{e===p.length?(i+=p,++d,l.next?this.head=l.next:this.head=this.tail=null):(i+=s(p,0,e),this.head=l,l.data=s(p,e));break}++d}while((l=l.next)!==null);return this.length-=d,i}_getBuffer(e){let i=r.allocUnsafe(e),l=e,d=this.head,p=0;do{let g=d.data;if(e>g.length)c(i,g,l-e),e-=g.length;else{e===g.length?(c(i,g,l-e),++p,d.next?this.head=d.next:this.head=this.tail=null):(c(i,new n(g.buffer,g.byteOffset,e),l-e),this.head=d,d.data=g.slice(e));break}++p}while((d=d.next)!==null);return this.length-=p,i}[Symbol.for("nodejs.util.inspect.custom")](e,i){return t(this,{...i,depth:0,customInspect:!1})}}}),Jr=Se((f,h)=>{ge(),me(),ye();var{MathFloor:s,NumberIsInteger:a}=Ze(),{validateInteger:c}=yr(),{ERR_INVALID_ARG_VALUE:n}=pt().codes,r=16*1024,t=16;function e(p,g,b){return p.highWaterMark!=null?p.highWaterMark:g?p[b]:null}function i(p){return p?t:r}function l(p,g){c(g,"value",0),p?t=g:r=g}function d(p,g,b,E){let S=e(g,E,b);if(S!=null){if(!a(S)||S<0){let x=E?`options.${b}`:"options.highWaterMark";throw new n(x,S)}return s(S)}return i(p.objectMode)}h.exports={getHighWaterMark:d,getDefaultHighWaterMark:i,setDefaultHighWaterMark:l}}),Gl=Se((f,h)=>{ge(),me(),ye();var s=(st(),Ke(ot)),a=s.Buffer;function c(r,t){for(var e in r)t[e]=r[e]}a.from&&a.alloc&&a.allocUnsafe&&a.allocUnsafeSlow?h.exports=s:(c(s,f),f.Buffer=n);function n(r,t,e){return a(r,t,e)}n.prototype=Object.create(a.prototype),c(a,n),n.from=function(r,t,e){if(typeof r=="number")throw new TypeError("Argument must not be a number");return a(r,t,e)},n.alloc=function(r,t,e){if(typeof r!="number")throw new TypeError("Argument must be a number");var i=a(r);return t!==void 0?typeof e=="string"?i.fill(t,e):i.fill(t):i.fill(0),i},n.allocUnsafe=function(r){if(typeof r!="number")throw new TypeError("Argument must be a number");return a(r)},n.allocUnsafeSlow=function(r){if(typeof r!="number")throw new TypeError("Argument must be a number");return s.SlowBuffer(r)}}),Ql=Se(f=>{ge(),me(),ye();var h=Gl().Buffer,s=h.isEncoding||function(y){switch(y=""+y,y&&y.toLowerCase()){case"hex":case"utf8":case"utf-8":case"ascii":case"binary":case"base64":case"ucs2":case"ucs-2":case"utf16le":case"utf-16le":case"raw":return!0;default:return!1}};function a(y){if(!y)return"utf8";for(var v;;)switch(y){case"utf8":case"utf-8":return"utf8";case"ucs2":case"ucs-2":case"utf16le":case"utf-16le":return"utf16le";case"latin1":case"binary":return"latin1";case"base64":case"ascii":case"hex":return y;default:if(v)return;y=(""+y).toLowerCase(),v=!0}}function c(y){var v=a(y);if(typeof v!="string"&&(h.isEncoding===s||!s(y)))throw new Error("Unknown encoding: "+y);return v||y}f.StringDecoder=n;function n(y){this.encoding=c(y);var v;switch(this.encoding){case"utf16le":this.text=p,this.end=g,v=4;break;case"utf8":this.fillLast=i,v=4;break;case"base64":this.text=b,this.end=E,v=3;break;default:this.write=S,this.end=x;return}this.lastNeed=0,this.lastTotal=0,this.lastChar=h.allocUnsafe(v)}n.prototype.write=function(y){if(y.length===0)return"";var v,A;if(this.lastNeed){if(v=this.fillLast(y),v===void 0)return"";A=this.lastNeed,this.lastNeed=0}else A=0;return A>5===6?2:y>>4===14?3:y>>3===30?4:y>>6===2?-1:-2}function t(y,v,A){var _=v.length-1;if(_=0?(C>0&&(y.lastNeed=C-1),C):--_=0?(C>0&&(y.lastNeed=C-2),C):--_=0?(C>0&&(C===2?C=0:y.lastNeed=C-3),C):0))}function e(y,v,A){if((v[0]&192)!==128)return y.lastNeed=0,"ďż˝";if(y.lastNeed>1&&v.length>1){if((v[1]&192)!==128)return y.lastNeed=1,"ďż˝";if(y.lastNeed>2&&v.length>2&&(v[2]&192)!==128)return y.lastNeed=2,"ďż˝"}}function i(y){var v=this.lastTotal-this.lastNeed,A=e(this,y);if(A!==void 0)return A;if(this.lastNeed<=y.length)return y.copy(this.lastChar,v,0,this.lastNeed),this.lastChar.toString(this.encoding,0,this.lastTotal);y.copy(this.lastChar,v,0,y.length),this.lastNeed-=y.length}function l(y,v){var A=t(this,y,v);if(!this.lastNeed)return y.toString("utf8",v);this.lastTotal=A;var _=y.length-(A-this.lastNeed);return y.copy(this.lastChar,0,_),y.toString("utf8",v,_)}function d(y){var v=y&&y.length?this.write(y):"";return this.lastNeed?v+"ďż˝":v}function p(y,v){if((y.length-v)%2===0){var A=y.toString("utf16le",v);if(A){var _=A.charCodeAt(A.length-1);if(_>=55296&&_<=56319)return this.lastNeed=2,this.lastTotal=4,this.lastChar[0]=y[y.length-2],this.lastChar[1]=y[y.length-1],A.slice(0,-1)}return A}return this.lastNeed=1,this.lastTotal=2,this.lastChar[0]=y[y.length-1],y.toString("utf16le",v,y.length-1)}function g(y){var v=y&&y.length?this.write(y):"";if(this.lastNeed){var A=this.lastTotal-this.lastNeed;return v+this.lastChar.toString("utf16le",0,A)}return v}function b(y,v){var A=(y.length-v)%3;return A===0?y.toString("base64",v):(this.lastNeed=3-A,this.lastTotal=3,A===1?this.lastChar[0]=y[y.length-1]:(this.lastChar[0]=y[y.length-2],this.lastChar[1]=y[y.length-1]),y.toString("base64",v,y.length-A))}function E(y){var v=y&&y.length?this.write(y):"";return this.lastNeed?v+this.lastChar.toString("base64",0,3-this.lastNeed):v}function S(y){return y.toString(this.encoding)}function x(y){return y&&y.length?this.write(y):""}}),ra=Se((f,h)=>{ge(),me(),ye();var s=er(),{PromisePrototypeThen:a,SymbolAsyncIterator:c,SymbolIterator:n}=Ze(),{Buffer:r}=(st(),Ke(ot)),{ERR_INVALID_ARG_TYPE:t,ERR_STREAM_NULL_VALUES:e}=pt().codes;function i(l,d,p){let g;if(typeof d=="string"||d instanceof r)return new l({objectMode:!0,...p,read(){this.push(d),this.push(null)}});let b;if(d&&d[c])b=!0,g=d[c]();else if(d&&d[n])b=!1,g=d[n]();else throw new t("iterable",["Iterable"],d);let E=new l({objectMode:!0,highWaterMark:1,...p}),S=!1;E._read=function(){S||(S=!0,y())},E._destroy=function(v,A){a(x(v),()=>s.nextTick(A,v),_=>s.nextTick(A,_||v))};async function x(v){let A=v!=null,_=typeof g.throw=="function";if(A&&_){let{value:C,done:w}=await g.throw(v);if(await C,w)return}if(typeof g.return=="function"){let{value:C}=await g.return();await C}}async function y(){for(;;){try{let{value:v,done:A}=b?await g.next():g.next();if(A)E.push(null);else{let _=v&&typeof v.then=="function"?await v:v;if(_===null)throw S=!1,new e;if(E.push(_))continue;S=!1}}catch(v){E.destroy(v)}break}}return E}h.exports=i}),Xr=Se((f,h)=>{ge(),me(),ye();var s=er(),{ArrayPrototypeIndexOf:a,NumberIsInteger:c,NumberIsNaN:n,NumberParseInt:r,ObjectDefineProperties:t,ObjectKeys:e,ObjectSetPrototypeOf:i,Promise:l,SafeSet:d,SymbolAsyncDispose:p,SymbolAsyncIterator:g,Symbol:b}=Ze();h.exports=fe,fe.ReadableState=Oe;var{EventEmitter:E}=(Zt(),Ke(qt)),{Stream:S,prependListener:x}=co(),{Buffer:y}=(st(),Ke(ot)),{addAbortSignal:v}=Yr(),A=Vt(),_=gt().debuglog("stream",R=>{_=R}),C=Hl(),w=sr(),{getHighWaterMark:I,getDefaultHighWaterMark:k}=Jr(),{aggregateTwoErrors:j,codes:{ERR_INVALID_ARG_TYPE:U,ERR_METHOD_NOT_IMPLEMENTED:P,ERR_OUT_OF_RANGE:z,ERR_STREAM_PUSH_AFTER_EOF:G,ERR_STREAM_UNSHIFT_AFTER_END_EVENT:q},AbortError:he}=pt(),{validateObject:ne}=yr(),te=b("kPaused"),{StringDecoder:ce}=Ql(),V=ra();i(fe.prototype,S.prototype),i(fe,S);var le=()=>{},{errorOrDestroy:M}=w,ee=1,Z=2,ue=4,Ae=8,Y=16,W=32,oe=64,X=128,J=256,re=512,we=1024,pe=2048,L=4096,H=8192,se=16384,be=32768,ve=65536,Ee=1<<17,Q=1<<18;function _e(R){return{enumerable:!1,get(){return(this.state&R)!==0},set(F){F?this.state|=R:this.state&=~R}}}t(Oe.prototype,{objectMode:_e(ee),ended:_e(Z),endEmitted:_e(ue),reading:_e(Ae),constructed:_e(Y),sync:_e(W),needReadable:_e(oe),emittedReadable:_e(X),readableListening:_e(J),resumeScheduled:_e(re),errorEmitted:_e(we),emitClose:_e(pe),autoDestroy:_e(L),destroyed:_e(H),closed:_e(se),closeEmitted:_e(be),multiAwaitDrain:_e(ve),readingMore:_e(Ee),dataEmitted:_e(Q)});function Oe(R,F,Pe){typeof Pe!="boolean"&&(Pe=F instanceof kt()),this.state=pe|L|Y|W,R&&R.objectMode&&(this.state|=ee),Pe&&R&&R.readableObjectMode&&(this.state|=ee),this.highWaterMark=R?I(this,R,"readableHighWaterMark",Pe):k(!1),this.buffer=new C,this.length=0,this.pipes=[],this.flowing=null,this[te]=null,R&&R.emitClose===!1&&(this.state&=~pe),R&&R.autoDestroy===!1&&(this.state&=~L),this.errored=null,this.defaultEncoding=R&&R.defaultEncoding||"utf8",this.awaitDrainWriters=null,this.decoder=null,this.encoding=null,R&&R.encoding&&(this.decoder=new ce(R.encoding),this.encoding=R.encoding)}function fe(R){if(!(this instanceof fe))return new fe(R);let F=this instanceof kt();this._readableState=new Oe(R,this,F),R&&(typeof R.read=="function"&&(this._read=R.read),typeof R.destroy=="function"&&(this._destroy=R.destroy),typeof R.construct=="function"&&(this._construct=R.construct),R.signal&&!F&&v(R.signal,this)),S.call(this,R),w.construct(this,()=>{this._readableState.needReadable&&$(this,this._readableState)})}fe.prototype.destroy=w.destroy,fe.prototype._undestroy=w.undestroy,fe.prototype._destroy=function(R,F){F(R)},fe.prototype[E.captureRejectionSymbol]=function(R){this.destroy(R)},fe.prototype[p]=function(){let R;return this.destroyed||(R=this.readableEnded?null:new he,this.destroy(R)),new l((F,Pe)=>A(this,Te=>Te&&Te!==R?Pe(Te):F(null)))},fe.prototype.push=function(R,F){return Be(this,R,F,!1)},fe.prototype.unshift=function(R,F){return Be(this,R,F,!0)};function Be(R,F,Pe,Te){_("readableAddChunk",F);let Me=R._readableState,rt;if((Me.state&ee)===0&&(typeof F=="string"?(Pe=Pe||Me.defaultEncoding,Me.encoding!==Pe&&(Te&&Me.encoding?F=y.from(F,Pe).toString(Me.encoding):(F=y.from(F,Pe),Pe=""))):F instanceof y?Pe="":S._isUint8Array(F)?(F=S._uint8ArrayToBuffer(F),Pe=""):F!=null&&(rt=new U("chunk",["string","Buffer","Uint8Array"],F))),rt)M(R,rt);else if(F===null)Me.state&=~Ae,N(R,Me);else if((Me.state&ee)!==0||F&&F.length>0)if(Te)if((Me.state&ue)!==0)M(R,new q);else{if(Me.destroyed||Me.errored)return!1;o(R,Me,F,!0)}else if(Me.ended)M(R,new G);else{if(Me.destroyed||Me.errored)return!1;Me.state&=~Ae,Me.decoder&&!Pe?(F=Me.decoder.write(F),Me.objectMode||F.length!==0?o(R,Me,F,!1):$(R,Me)):o(R,Me,F,!1)}else Te||(Me.state&=~Ae,$(R,Me));return!Me.ended&&(Me.length0?((F.state&ve)!==0?F.awaitDrainWriters.clear():F.awaitDrainWriters=null,F.dataEmitted=!0,R.emit("data",Pe)):(F.length+=F.objectMode?1:Pe.length,Te?F.buffer.unshift(Pe):F.buffer.push(Pe),(F.state&oe)!==0&&K(R)),$(R,F)}fe.prototype.isPaused=function(){let R=this._readableState;return R[te]===!0||R.flowing===!1},fe.prototype.setEncoding=function(R){let F=new ce(R);this._readableState.decoder=F,this._readableState.encoding=this._readableState.decoder.encoding;let Pe=this._readableState.buffer,Te="";for(let Me of Pe)Te+=F.write(Me);return Pe.clear(),Te!==""&&Pe.push(Te),this._readableState.length=Te.length,this};var u=1073741824;function m(R){if(R>u)throw new z("size","<= 1GiB",R);return R--,R|=R>>>1,R|=R>>>2,R|=R>>>4,R|=R>>>8,R|=R>>>16,R++,R}function T(R,F){return R<=0||F.length===0&&F.ended?0:(F.state&ee)!==0?1:n(R)?F.flowing&&F.length?F.buffer.first().length:F.length:R<=F.length?R:F.ended?F.length:0}fe.prototype.read=function(R){_("read",R),R===void 0?R=NaN:c(R)||(R=r(R,10));let F=this._readableState,Pe=R;if(R>F.highWaterMark&&(F.highWaterMark=m(R)),R!==0&&(F.state&=~X),R===0&&F.needReadable&&((F.highWaterMark!==0?F.length>=F.highWaterMark:F.length>0)||F.ended))return _("read: emitReadable",F.length,F.ended),F.length===0&&F.ended?He(this):K(this),null;if(R=T(R,F),R===0&&F.ended)return F.length===0&&He(this),null;let Te=(F.state&oe)!==0;if(_("need readable",Te),(F.length===0||F.length-R0?Me=tt(R,F):Me=null,Me===null?(F.needReadable=F.length<=F.highWaterMark,R=0):(F.length-=R,F.multiAwaitDrain?F.awaitDrainWriters.clear():F.awaitDrainWriters=null),F.length===0&&(F.ended||(F.needReadable=!0),Pe!==R&&F.ended&&He(this)),Me!==null&&!F.errorEmitted&&!F.closeEmitted&&(F.dataEmitted=!0,this.emit("data",Me)),Me};function N(R,F){if(_("onEofChunk"),!F.ended){if(F.decoder){let Pe=F.decoder.end();Pe&&Pe.length&&(F.buffer.push(Pe),F.length+=F.objectMode?1:Pe.length)}F.ended=!0,F.sync?K(R):(F.needReadable=!1,F.emittedReadable=!0,de(R))}}function K(R){let F=R._readableState;_("emitReadable",F.needReadable,F.emittedReadable),F.needReadable=!1,F.emittedReadable||(_("emitReadable",F.flowing),F.emittedReadable=!0,s.nextTick(de,R))}function de(R){let F=R._readableState;_("emitReadable_",F.destroyed,F.length,F.ended),!F.destroyed&&!F.errored&&(F.length||F.ended)&&(R.emit("readable"),F.emittedReadable=!1),F.needReadable=!F.flowing&&!F.ended&&F.length<=F.highWaterMark,Fe(R)}function $(R,F){!F.readingMore&&F.constructed&&(F.readingMore=!0,s.nextTick(ie,R,F))}function ie(R,F){for(;!F.reading&&!F.ended&&(F.length1&&Te.pipes.includes(R)&&(_("false write response, pause",Te.awaitDrainWriters.size),Te.awaitDrainWriters.add(R)),Pe.pause()),mt||(mt=Re(Pe,R),R.on("drain",mt))}Pe.on("data",Ht);function Ht(Qe){_("ondata");let wt=R.write(Qe);_("dest.write",wt),wt===!1&&Kt()}function Et(Qe){if(_("onerror",Qe),At(),R.removeListener("error",Et),R.listenerCount("error")===0){let wt=R._writableState||R._readableState;wt&&!wt.errorEmitted?M(R,Qe):R.emit("error",Qe)}}x(R,"error",Et);function ze(){R.removeListener("finish",bt),At()}R.once("close",ze);function bt(){_("onfinish"),R.removeListener("close",ze),At()}R.once("finish",bt);function At(){_("unpipe"),Pe.unpipe(R)}return R.emit("pipe",Pe),R.writableNeedDrain===!0?Kt():Te.flowing||(_("pipe resume"),Pe.resume()),R};function Re(R,F){return function(){let Pe=R._readableState;Pe.awaitDrainWriters===F?(_("pipeOnDrain",1),Pe.awaitDrainWriters=null):Pe.multiAwaitDrain&&(_("pipeOnDrain",Pe.awaitDrainWriters.size),Pe.awaitDrainWriters.delete(F)),(!Pe.awaitDrainWriters||Pe.awaitDrainWriters.size===0)&&R.listenerCount("data")&&R.resume()}}fe.prototype.unpipe=function(R){let F=this._readableState,Pe={hasUnpiped:!1};if(F.pipes.length===0)return this;if(!R){let Me=F.pipes;F.pipes=[],this.pause();for(let rt=0;rt0,Te.flowing!==!1&&this.resume()):R==="readable"&&!Te.endEmitted&&!Te.readableListening&&(Te.readableListening=Te.needReadable=!0,Te.flowing=!1,Te.emittedReadable=!1,_("on readable",Te.length,Te.reading),Te.length?K(this):Te.reading||s.nextTick(Le,this)),Pe},fe.prototype.addListener=fe.prototype.on,fe.prototype.removeListener=function(R,F){let Pe=S.prototype.removeListener.call(this,R,F);return R==="readable"&&s.nextTick(ke,this),Pe},fe.prototype.off=fe.prototype.removeListener,fe.prototype.removeAllListeners=function(R){let F=S.prototype.removeAllListeners.apply(this,arguments);return(R==="readable"||R===void 0)&&s.nextTick(ke,this),F};function ke(R){let F=R._readableState;F.readableListening=R.listenerCount("readable")>0,F.resumeScheduled&&F[te]===!1?F.flowing=!0:R.listenerCount("data")>0?R.resume():F.readableListening||(F.flowing=null)}function Le(R){_("readable nexttick read 0"),R.read(0)}fe.prototype.resume=function(){let R=this._readableState;return R.flowing||(_("resume"),R.flowing=!R.readableListening,Ue(this,R)),R[te]=!1,this};function Ue(R,F){F.resumeScheduled||(F.resumeScheduled=!0,s.nextTick(Xe,R,F))}function Xe(R,F){_("resume",F.reading),F.reading||R.read(0),F.resumeScheduled=!1,R.emit("resume"),Fe(R),F.flowing&&!F.reading&&R.read(0)}fe.prototype.pause=function(){return _("call pause flowing=%j",this._readableState.flowing),this._readableState.flowing!==!1&&(_("pause"),this._readableState.flowing=!1,this.emit("pause")),this._readableState[te]=!0,this};function Fe(R){let F=R._readableState;for(_("flow",F.flowing);F.flowing&&R.read()!==null;);}fe.prototype.wrap=function(R){let F=!1;R.on("data",Te=>{!this.push(Te)&&R.pause&&(F=!0,R.pause())}),R.on("end",()=>{this.push(null)}),R.on("error",Te=>{M(this,Te)}),R.on("close",()=>{this.destroy()}),R.on("destroy",()=>{this.destroy()}),this._read=()=>{F&&R.resume&&(F=!1,R.resume())};let Pe=e(R);for(let Te=1;Te{Me=at?j(Me,at):null,Pe(),Pe=le});try{for(;;){let at=R.destroyed?null:R.read();if(at!==null)yield at;else{if(Me)throw Me;if(Me===null)return;await new l(Te)}}}catch(at){throw Me=j(Me,at),Me}finally{(Me||F?.destroyOnReturn!==!1)&&(Me===void 0||R._readableState.autoDestroy)?w.destroyer(R,null):(R.off("readable",Te),rt())}}t(fe.prototype,{readable:{__proto__:null,get(){let R=this._readableState;return!!R&&R.readable!==!1&&!R.destroyed&&!R.errorEmitted&&!R.endEmitted},set(R){this._readableState&&(this._readableState.readable=!!R)}},readableDidRead:{__proto__:null,enumerable:!1,get:function(){return this._readableState.dataEmitted}},readableAborted:{__proto__:null,enumerable:!1,get:function(){return!!(this._readableState.readable!==!1&&(this._readableState.destroyed||this._readableState.errored)&&!this._readableState.endEmitted)}},readableHighWaterMark:{__proto__:null,enumerable:!1,get:function(){return this._readableState.highWaterMark}},readableBuffer:{__proto__:null,enumerable:!1,get:function(){return this._readableState&&this._readableState.buffer}},readableFlowing:{__proto__:null,enumerable:!1,get:function(){return this._readableState.flowing},set:function(R){this._readableState&&(this._readableState.flowing=R)}},readableLength:{__proto__:null,enumerable:!1,get(){return this._readableState.length}},readableObjectMode:{__proto__:null,enumerable:!1,get(){return this._readableState?this._readableState.objectMode:!1}},readableEncoding:{__proto__:null,enumerable:!1,get(){return this._readableState?this._readableState.encoding:null}},errored:{__proto__:null,enumerable:!1,get(){return this._readableState?this._readableState.errored:null}},closed:{__proto__:null,get(){return this._readableState?this._readableState.closed:!1}},destroyed:{__proto__:null,enumerable:!1,get(){return this._readableState?this._readableState.destroyed:!1},set(R){this._readableState&&(this._readableState.destroyed=R)}},readableEnded:{__proto__:null,enumerable:!1,get(){return this._readableState?this._readableState.endEmitted:!1}}}),t(Oe.prototype,{pipesCount:{__proto__:null,get(){return this.pipes.length}},paused:{__proto__:null,get(){return this[te]!==!1},set(R){this[te]=!!R}}}),fe._fromList=tt;function tt(R,F){if(F.length===0)return null;let Pe;return F.objectMode?Pe=F.buffer.shift():!R||R>=F.length?(F.decoder?Pe=F.buffer.join(""):F.buffer.length===1?Pe=F.buffer.first():Pe=F.buffer.concat(F.length),F.buffer.clear()):Pe=F.buffer.consume(R,F.decoder),Pe}function He(R){let F=R._readableState;_("endReadable",F.endEmitted),F.endEmitted||(F.ended=!0,s.nextTick($e,F,R))}function $e(R,F){if(_("endReadableNT",R.endEmitted,R.length),!R.errored&&!R.closeEmitted&&!R.endEmitted&&R.length===0){if(R.endEmitted=!0,F.emit("end"),F.writable&&F.allowHalfOpen===!1)s.nextTick(nt,F);else if(R.autoDestroy){let Pe=F._writableState;(!Pe||Pe.autoDestroy&&(Pe.finished||Pe.writable===!1))&&F.destroy()}}}function nt(R){R.writable&&!R.writableEnded&&!R.destroyed&&R.end()}fe.from=function(R,F){return V(fe,R,F)};var dt;function lt(){return dt===void 0&&(dt={}),dt}fe.fromWeb=function(R,F){return lt().newStreamReadableFromReadableStream(R,F)},fe.toWeb=function(R,F){return lt().newReadableStreamFromStreamReadable(R,F)},fe.wrap=function(R,F){var Pe,Te;return new fe({objectMode:(Pe=(Te=R.readableObjectMode)!==null&&Te!==void 0?Te:R.objectMode)!==null&&Pe!==void 0?Pe:!0,...F,destroy(Me,rt){w.destroyer(R,Me),rt(Me)}}).wrap(R)}}),ho=Se((f,h)=>{ge(),me(),ye();var s=er(),{ArrayPrototypeSlice:a,Error:c,FunctionPrototypeSymbolHasInstance:n,ObjectDefineProperty:r,ObjectDefineProperties:t,ObjectSetPrototypeOf:e,StringPrototypeToLowerCase:i,Symbol:l,SymbolHasInstance:d}=Ze();h.exports=ne,ne.WritableState=q;var{EventEmitter:p}=(Zt(),Ke(qt)),g=co().Stream,{Buffer:b}=(st(),Ke(ot)),E=sr(),{addAbortSignal:S}=Yr(),{getHighWaterMark:x,getDefaultHighWaterMark:y}=Jr(),{ERR_INVALID_ARG_TYPE:v,ERR_METHOD_NOT_IMPLEMENTED:A,ERR_MULTIPLE_CALLBACK:_,ERR_STREAM_CANNOT_PIPE:C,ERR_STREAM_DESTROYED:w,ERR_STREAM_ALREADY_FINISHED:I,ERR_STREAM_NULL_VALUES:k,ERR_STREAM_WRITE_AFTER_END:j,ERR_UNKNOWN_ENCODING:U}=pt().codes,{errorOrDestroy:P}=E;e(ne.prototype,g.prototype),e(ne,g);function z(){}var G=l("kOnFinished");function q(L,H,se){typeof se!="boolean"&&(se=H instanceof kt()),this.objectMode=!!(L&&L.objectMode),se&&(this.objectMode=this.objectMode||!!(L&&L.writableObjectMode)),this.highWaterMark=L?x(this,L,"writableHighWaterMark",se):y(!1),this.finalCalled=!1,this.needDrain=!1,this.ending=!1,this.ended=!1,this.finished=!1,this.destroyed=!1;let be=!!(L&&L.decodeStrings===!1);this.decodeStrings=!be,this.defaultEncoding=L&&L.defaultEncoding||"utf8",this.length=0,this.writing=!1,this.corked=0,this.sync=!0,this.bufferProcessing=!1,this.onwrite=M.bind(void 0,H),this.writecb=null,this.writelen=0,this.afterWriteTickInfo=null,he(this),this.pendingcb=0,this.constructed=!0,this.prefinished=!1,this.errorEmitted=!1,this.emitClose=!L||L.emitClose!==!1,this.autoDestroy=!L||L.autoDestroy!==!1,this.errored=null,this.closed=!1,this.closeEmitted=!1,this[G]=[]}function he(L){L.buffered=[],L.bufferedIndex=0,L.allBuffers=!0,L.allNoop=!0}q.prototype.getBuffer=function(){return a(this.buffered,this.bufferedIndex)},r(q.prototype,"bufferedRequestCount",{__proto__:null,get(){return this.buffered.length-this.bufferedIndex}});function ne(L){let H=this instanceof kt();if(!H&&!n(ne,this))return new ne(L);this._writableState=new q(L,this,H),L&&(typeof L.write=="function"&&(this._write=L.write),typeof L.writev=="function"&&(this._writev=L.writev),typeof L.destroy=="function"&&(this._destroy=L.destroy),typeof L.final=="function"&&(this._final=L.final),typeof L.construct=="function"&&(this._construct=L.construct),L.signal&&S(L.signal,this)),g.call(this,L),E.construct(this,()=>{let se=this._writableState;se.writing||Ae(this,se),X(this,se)})}r(ne,d,{__proto__:null,value:function(L){return n(this,L)?!0:this!==ne?!1:L&&L._writableState instanceof q}}),ne.prototype.pipe=function(){P(this,new C)};function te(L,H,se,be){let ve=L._writableState;if(typeof se=="function")be=se,se=ve.defaultEncoding;else{if(!se)se=ve.defaultEncoding;else if(se!=="buffer"&&!b.isEncoding(se))throw new U(se);typeof be!="function"&&(be=z)}if(H===null)throw new k;if(!ve.objectMode)if(typeof H=="string")ve.decodeStrings!==!1&&(H=b.from(H,se),se="buffer");else if(H instanceof b)se="buffer";else if(g._isUint8Array(H))H=g._uint8ArrayToBuffer(H),se="buffer";else throw new v("chunk",["string","Buffer","Uint8Array"],H);let Ee;return ve.ending?Ee=new j:ve.destroyed&&(Ee=new w("write")),Ee?(s.nextTick(be,Ee),P(L,Ee,!0),Ee):(ve.pendingcb++,ce(L,ve,H,se,be))}ne.prototype.write=function(L,H,se){return te(this,L,H,se)===!0},ne.prototype.cork=function(){this._writableState.corked++},ne.prototype.uncork=function(){let L=this._writableState;L.corked&&(L.corked--,L.writing||Ae(this,L))},ne.prototype.setDefaultEncoding=function(L){if(typeof L=="string"&&(L=i(L)),!b.isEncoding(L))throw new U(L);return this._writableState.defaultEncoding=L,this};function ce(L,H,se,be,ve){let Ee=H.objectMode?1:se.length;H.length+=Ee;let Q=H.lengthse.bufferedIndex&&Ae(L,se),be?se.afterWriteTickInfo!==null&&se.afterWriteTickInfo.cb===ve?se.afterWriteTickInfo.count++:(se.afterWriteTickInfo={count:1,cb:ve,stream:L,state:se},s.nextTick(ee,se.afterWriteTickInfo)):Z(L,se,1,ve))}function ee({stream:L,state:H,count:se,cb:be}){return H.afterWriteTickInfo=null,Z(L,H,se,be)}function Z(L,H,se,be){for(!H.ending&&!L.destroyed&&H.length===0&&H.needDrain&&(H.needDrain=!1,L.emit("drain"));se-- >0;)H.pendingcb--,be();H.destroyed&&ue(H),X(L,H)}function ue(L){if(L.writing)return;for(let ve=L.bufferedIndex;ve1&&L._writev){H.pendingcb-=Ee-1;let _e=H.allNoop?z:fe=>{for(let Be=Q;Be256?(se.splice(0,Q),H.bufferedIndex=0):H.bufferedIndex=Q}H.bufferProcessing=!1}ne.prototype._write=function(L,H,se){if(this._writev)this._writev([{chunk:L,encoding:H}],se);else throw new A("_write()")},ne.prototype._writev=null,ne.prototype.end=function(L,H,se){let be=this._writableState;typeof L=="function"?(se=L,L=null,H=null):typeof H=="function"&&(se=H,H=null);let ve;if(L!=null){let Ee=te(this,L,H);Ee instanceof c&&(ve=Ee)}return be.corked&&(be.corked=1,this.uncork()),ve||(!be.errored&&!be.ending?(be.ending=!0,X(this,be,!0),be.ended=!0):be.finished?ve=new I("end"):be.destroyed&&(ve=new w("end"))),typeof se=="function"&&(ve||be.finished?s.nextTick(se,ve):be[G].push(se)),this};function Y(L){return L.ending&&!L.destroyed&&L.constructed&&L.length===0&&!L.errored&&L.buffered.length===0&&!L.finished&&!L.writing&&!L.errorEmitted&&!L.closeEmitted}function W(L,H){let se=!1;function be(ve){if(se){P(L,ve??_());return}if(se=!0,H.pendingcb--,ve){let Ee=H[G].splice(0);for(let Q=0;Q{Y(ve)?J(be,ve):ve.pendingcb--},L,H)):Y(H)&&(H.pendingcb++,J(L,H))))}function J(L,H){H.pendingcb--,H.finished=!0;let se=H[G].splice(0);for(let be=0;be{ge(),me(),ye();var s=er(),a=(st(),Ke(ot)),{isReadable:c,isWritable:n,isIterable:r,isNodeStream:t,isReadableNodeStream:e,isWritableNodeStream:i,isDuplexNodeStream:l,isReadableStream:d,isWritableStream:p}=Ct(),g=Vt(),{AbortError:b,codes:{ERR_INVALID_ARG_TYPE:E,ERR_INVALID_RETURN_VALUE:S}}=pt(),{destroyer:x}=sr(),y=kt(),v=Xr(),A=ho(),{createDeferredPromise:_}=gt(),C=ra(),w=globalThis.Blob||a.Blob,I=typeof w<"u"?function(G){return G instanceof w}:function(G){return!1},k=globalThis.AbortController||gr().AbortController,{FunctionPrototypeCall:j}=Ze(),U=class extends y{constructor(G){super(G),G?.readable===!1&&(this._readableState.readable=!1,this._readableState.ended=!0,this._readableState.endEmitted=!0),G?.writable===!1&&(this._writableState.writable=!1,this._writableState.ending=!0,this._writableState.ended=!0,this._writableState.finished=!0)}};h.exports=function G(q,he){if(l(q))return q;if(e(q))return z({readable:q});if(i(q))return z({writable:q});if(t(q))return z({writable:!1,readable:!1});if(d(q))return z({readable:v.fromWeb(q)});if(p(q))return z({writable:A.fromWeb(q)});if(typeof q=="function"){let{value:te,write:ce,final:V,destroy:le}=P(q);if(r(te))return C(U,te,{objectMode:!0,write:ce,final:V,destroy:le});let M=te?.then;if(typeof M=="function"){let ee,Z=j(M,te,ue=>{if(ue!=null)throw new S("nully","body",ue)},ue=>{x(ee,ue)});return ee=new U({objectMode:!0,readable:!1,write:ce,final(ue){V(async()=>{try{await Z,s.nextTick(ue,null)}catch(Ae){s.nextTick(ue,Ae)}})},destroy:le})}throw new S("Iterable, AsyncIterable or AsyncFunction",he,te)}if(I(q))return G(q.arrayBuffer());if(r(q))return C(U,q,{objectMode:!0,writable:!1});if(d(q?.readable)&&p(q?.writable))return U.fromWeb(q);if(typeof q?.writable=="object"||typeof q?.readable=="object"){let te=q!=null&&q.readable?e(q?.readable)?q?.readable:G(q.readable):void 0,ce=q!=null&&q.writable?i(q?.writable)?q?.writable:G(q.writable):void 0;return z({readable:te,writable:ce})}let ne=q?.then;if(typeof ne=="function"){let te;return j(ne,q,ce=>{ce!=null&&te.push(ce),te.push(null)},ce=>{x(te,ce)}),te=new U({objectMode:!0,writable:!1,read(){}})}throw new E(he,["Blob","ReadableStream","WritableStream","Stream","Iterable","AsyncIterable","Function","{ readable, writable } pair","Promise"],q)};function P(G){let{promise:q,resolve:he}=_(),ne=new k,te=ne.signal;return{value:G((async function*(){for(;;){let ce=q;q=null;let{chunk:V,done:le,cb:M}=await ce;if(s.nextTick(M),le)return;if(te.aborted)throw new b(void 0,{cause:te.reason});({promise:q,resolve:he}=_()),yield V}})(),{signal:te}),write(ce,V,le){let M=he;he=null,M({chunk:ce,done:!1,cb:le})},final(ce){let V=he;he=null,V({done:!0,cb:ce})},destroy(ce,V){ne.abort(),V(ce)}}}function z(G){let q=G.readable&&typeof G.readable.read!="function"?v.wrap(G.readable):G.readable,he=G.writable,ne=!!c(q),te=!!n(he),ce,V,le,M,ee;function Z(ue){let Ae=M;M=null,Ae?Ae(ue):ue&&ee.destroy(ue)}return ee=new U({readableObjectMode:!!(q!=null&&q.readableObjectMode),writableObjectMode:!!(he!=null&&he.writableObjectMode),readable:ne,writable:te}),te&&(g(he,ue=>{te=!1,ue&&x(q,ue),Z(ue)}),ee._write=function(ue,Ae,Y){he.write(ue,Ae)?Y():ce=Y},ee._final=function(ue){he.end(),V=ue},he.on("drain",function(){if(ce){let ue=ce;ce=null,ue()}}),he.on("finish",function(){if(V){let ue=V;V=null,ue()}})),ne&&(g(q,ue=>{ne=!1,ue&&x(q,ue),Z(ue)}),q.on("readable",function(){if(le){let ue=le;le=null,ue()}}),q.on("end",function(){ee.push(null)}),ee._read=function(){for(;;){let ue=q.read();if(ue===null){le=ee._read;return}if(!ee.push(ue))return}}),ee._destroy=function(ue,Ae){!ue&&M!==null&&(ue=new b),le=null,ce=null,V=null,M===null?Ae(ue):(M=Ae,x(he,ue),x(q,ue))},ee}}),kt=Se((f,h)=>{ge(),me(),ye();var{ObjectDefineProperties:s,ObjectGetOwnPropertyDescriptor:a,ObjectKeys:c,ObjectSetPrototypeOf:n}=Ze();h.exports=e;var r=Xr(),t=ho();n(e.prototype,r.prototype),n(e,r);{let p=c(t.prototype);for(let g=0;g{ge(),me(),ye();var{ObjectSetPrototypeOf:s,Symbol:a}=Ze();h.exports=e;var{ERR_METHOD_NOT_IMPLEMENTED:c}=pt().codes,n=kt(),{getHighWaterMark:r}=Jr();s(e.prototype,n.prototype),s(e,n);var t=a("kCallback");function e(d){if(!(this instanceof e))return new e(d);let p=d?r(this,d,"readableHighWaterMark",!0):null;p===0&&(d={...d,highWaterMark:null,readableHighWaterMark:p,writableHighWaterMark:d.writableHighWaterMark||0}),n.call(this,d),this._readableState.sync=!1,this[t]=null,d&&(typeof d.transform=="function"&&(this._transform=d.transform),typeof d.flush=="function"&&(this._flush=d.flush)),this.on("prefinish",l)}function i(d){typeof this._flush=="function"&&!this.destroyed?this._flush((p,g)=>{if(p){d?d(p):this.destroy(p);return}g!=null&&this.push(g),this.push(null),d&&d()}):(this.push(null),d&&d())}function l(){this._final!==i&&i.call(this)}e.prototype._final=i,e.prototype._transform=function(d,p,g){throw new c("_transform()")},e.prototype._write=function(d,p,g){let b=this._readableState,E=this._writableState,S=b.length;this._transform(d,p,(x,y)=>{if(x){g(x);return}y!=null&&this.push(y),E.ended||S===b.length||b.length{ge(),me(),ye();var{ObjectSetPrototypeOf:s}=Ze();h.exports=c;var a=na();s(c.prototype,a.prototype),s(c,a);function c(n){if(!(this instanceof c))return new c(n);a.call(this,n)}c.prototype._transform=function(n,r,t){t(null,n)}}),fo=Se((f,h)=>{ge(),me(),ye();var s=er(),{ArrayIsArray:a,Promise:c,SymbolAsyncIterator:n,SymbolDispose:r}=Ze(),t=Vt(),{once:e}=gt(),i=sr(),l=kt(),{aggregateTwoErrors:d,codes:{ERR_INVALID_ARG_TYPE:p,ERR_INVALID_RETURN_VALUE:g,ERR_MISSING_ARGS:b,ERR_STREAM_DESTROYED:E,ERR_STREAM_PREMATURE_CLOSE:S},AbortError:x}=pt(),{validateFunction:y,validateAbortSignal:v}=yr(),{isIterable:A,isReadable:_,isReadableNodeStream:C,isNodeStream:w,isTransformStream:I,isWebStream:k,isReadableStream:j,isReadableFinished:U}=Ct(),P=globalThis.AbortController||gr().AbortController,z,G,q;function he(ue,Ae,Y){let W=!1;ue.on("close",()=>{W=!0});let oe=t(ue,{readable:Ae,writable:Y},X=>{W=!X});return{destroy:X=>{W||(W=!0,i.destroyer(ue,X||new E("pipe")))},cleanup:oe}}function ne(ue){return y(ue[ue.length-1],"streams[stream.length - 1]"),ue.pop()}function te(ue){if(A(ue))return ue;if(C(ue))return ce(ue);throw new p("val",["Readable","Iterable","AsyncIterable"],ue)}async function*ce(ue){G||(G=Xr()),yield*G.prototype[n].call(ue)}async function V(ue,Ae,Y,{end:W}){let oe,X=null,J=pe=>{if(pe&&(oe=pe),X){let L=X;X=null,L()}},re=()=>new c((pe,L)=>{oe?L(oe):X=()=>{oe?L(oe):pe()}});Ae.on("drain",J);let we=t(Ae,{readable:!1},J);try{Ae.writableNeedDrain&&await re();for await(let pe of ue)Ae.write(pe)||await re();W&&(Ae.end(),await re()),Y()}catch(pe){Y(oe!==pe?d(oe,pe):pe)}finally{we(),Ae.off("drain",J)}}async function le(ue,Ae,Y,{end:W}){I(Ae)&&(Ae=Ae.writable);let oe=Ae.getWriter();try{for await(let X of ue)await oe.ready,oe.write(X).catch(()=>{});await oe.ready,W&&await oe.close(),Y()}catch(X){try{await oe.abort(X),Y(X)}catch(J){Y(J)}}}function M(...ue){return ee(ue,e(ne(ue)))}function ee(ue,Ae,Y){if(ue.length===1&&a(ue[0])&&(ue=ue[0]),ue.length<2)throw new b("streams");let W=new P,oe=W.signal,X=Y?.signal,J=[];v(X,"options.signal");function re(){ve(new x)}q=q||gt().addAbortListener;let we;X&&(we=q(X,re));let pe,L,H=[],se=0;function be(Oe){ve(Oe,--se===0)}function ve(Oe,fe){var Be;if(Oe&&(!pe||pe.code==="ERR_STREAM_PREMATURE_CLOSE")&&(pe=Oe),!(!pe&&!fe)){for(;H.length;)H.shift()(pe);(Be=we)===null||Be===void 0||Be[r](),W.abort(),fe&&(pe||J.forEach(o=>o()),s.nextTick(Ae,pe,L))}}let Ee;for(let Oe=0;Oe0,u=Be||Y?.end!==!1,m=Oe===ue.length-1;if(w(fe)){let T=function(N){N&&N.name!=="AbortError"&&N.code!=="ERR_STREAM_PREMATURE_CLOSE"&&be(N)};if(u){let{destroy:N,cleanup:K}=he(fe,Be,o);H.push(N),_(fe)&&m&&J.push(K)}fe.on("error",T),_(fe)&&m&&J.push(()=>{fe.removeListener("error",T)})}if(Oe===0)if(typeof fe=="function"){if(Ee=fe({signal:oe}),!A(Ee))throw new g("Iterable, AsyncIterable or Stream","source",Ee)}else A(fe)||C(fe)||I(fe)?Ee=fe:Ee=l.from(fe);else if(typeof fe=="function"){if(I(Ee)){var Q;Ee=te((Q=Ee)===null||Q===void 0?void 0:Q.readable)}else Ee=te(Ee);if(Ee=fe(Ee,{signal:oe}),Be){if(!A(Ee,!0))throw new g("AsyncIterable",`transform[${Oe-1}]`,Ee)}else{var _e;z||(z=ia());let T=new z({objectMode:!0}),N=(_e=Ee)===null||_e===void 0?void 0:_e.then;if(typeof N=="function")se++,N.call(Ee,$=>{L=$,$!=null&&T.write($),u&&T.end(),s.nextTick(be)},$=>{T.destroy($),s.nextTick(be,$)});else if(A(Ee,!0))se++,V(Ee,T,be,{end:u});else if(j(Ee)||I(Ee)){let $=Ee.readable||Ee;se++,V($,T,be,{end:u})}else throw new g("AsyncIterable or Promise","destination",Ee);Ee=T;let{destroy:K,cleanup:de}=he(Ee,!1,!0);H.push(K),m&&J.push(de)}}else if(w(fe)){if(C(Ee)){se+=2;let T=Z(Ee,fe,be,{end:u});_(fe)&&m&&J.push(T)}else if(I(Ee)||j(Ee)){let T=Ee.readable||Ee;se++,V(T,fe,be,{end:u})}else if(A(Ee))se++,V(Ee,fe,be,{end:u});else throw new p("val",["Readable","Iterable","AsyncIterable","ReadableStream","TransformStream"],Ee);Ee=fe}else if(k(fe)){if(C(Ee))se++,le(te(Ee),fe,be,{end:u});else if(j(Ee)||A(Ee))se++,le(Ee,fe,be,{end:u});else if(I(Ee))se++,le(Ee.readable,fe,be,{end:u});else throw new p("val",["Readable","Iterable","AsyncIterable","ReadableStream","TransformStream"],Ee);Ee=fe}else Ee=l.from(fe)}return(oe!=null&&oe.aborted||X!=null&&X.aborted)&&s.nextTick(re),Ee}function Z(ue,Ae,Y,{end:W}){let oe=!1;if(Ae.on("close",()=>{oe||Y(new S)}),ue.pipe(Ae,{end:!1}),W){let X=function(){oe=!0,Ae.end()};U(ue)?s.nextTick(X):ue.once("end",X)}else Y();return t(ue,{readable:!0,writable:!1},X=>{let J=ue._readableState;X&&X.code==="ERR_STREAM_PREMATURE_CLOSE"&&J&&J.ended&&!J.errored&&!J.errorEmitted?ue.once("end",Y).once("error",Y):Y(X)}),t(Ae,{readable:!1,writable:!0},Y)}h.exports={pipelineImpl:ee,pipeline:M}}),oa=Se((f,h)=>{ge(),me(),ye();var{pipeline:s}=fo(),a=kt(),{destroyer:c}=sr(),{isNodeStream:n,isReadable:r,isWritable:t,isWebStream:e,isTransformStream:i,isWritableStream:l,isReadableStream:d}=Ct(),{AbortError:p,codes:{ERR_INVALID_ARG_VALUE:g,ERR_MISSING_ARGS:b}}=pt(),E=Vt();h.exports=function(...S){if(S.length===0)throw new b("streams");if(S.length===1)return a.from(S[0]);let x=[...S];if(typeof S[0]=="function"&&(S[0]=a.from(S[0])),typeof S[S.length-1]=="function"){let P=S.length-1;S[P]=a.from(S[P])}for(let P=0;P0&&!(t(S[P])||l(S[P])||i(S[P])))throw new g(`streams[${P}]`,x[P],"must be writable")}let y,v,A,_,C;function w(P){let z=_;_=null,z?z(P):P?C.destroy(P):!U&&!j&&C.destroy()}let I=S[0],k=s(S,w),j=!!(t(I)||l(I)||i(I)),U=!!(r(k)||d(k)||i(k));if(C=new a({writableObjectMode:!!(I!=null&&I.writableObjectMode),readableObjectMode:!!(k!=null&&k.readableObjectMode),writable:j,readable:U}),j){if(n(I))C._write=function(z,G,q){I.write(z,G)?q():y=q},C._final=function(z){I.end(),v=z},I.on("drain",function(){if(y){let z=y;y=null,z()}});else if(e(I)){let z=(i(I)?I.writable:I).getWriter();C._write=async function(G,q,he){try{await z.ready,z.write(G).catch(()=>{}),he()}catch(ne){he(ne)}},C._final=async function(G){try{await z.ready,z.close().catch(()=>{}),v=G}catch(q){G(q)}}}let P=i(k)?k.readable:k;E(P,()=>{if(v){let z=v;v=null,z()}})}if(U){if(n(k))k.on("readable",function(){if(A){let P=A;A=null,P()}}),k.on("end",function(){C.push(null)}),C._read=function(){for(;;){let P=k.read();if(P===null){A=C._read;return}if(!C.push(P))return}};else if(e(k)){let P=(i(k)?k.readable:k).getReader();C._read=async function(){for(;;)try{let{value:z,done:G}=await P.read();if(!C.push(z))return;if(G){C.push(null);return}}catch{return}}}}return C._destroy=function(P,z){!P&&_!==null&&(P=new p),A=null,y=null,v=null,_===null?z(P):(_=z,n(k)&&c(k,P))},C}}),Jl=Se((f,h)=>{ge(),me(),ye();var s=globalThis.AbortController||gr().AbortController,{codes:{ERR_INVALID_ARG_VALUE:a,ERR_INVALID_ARG_TYPE:c,ERR_MISSING_ARGS:n,ERR_OUT_OF_RANGE:r},AbortError:t}=pt(),{validateAbortSignal:e,validateInteger:i,validateObject:l}=yr(),d=Ze().Symbol("kWeak"),p=Ze().Symbol("kResistStopPropagation"),{finished:g}=Vt(),b=oa(),{addAbortSignalNoValidate:E}=Yr(),{isWritable:S,isNodeStream:x}=Ct(),{deprecate:y}=gt(),{ArrayPrototypePush:v,Boolean:A,MathFloor:_,Number:C,NumberIsNaN:w,Promise:I,PromiseReject:k,PromiseResolve:j,PromisePrototypeThen:U,Symbol:P}=Ze(),z=P("kEmpty"),G=P("kEof");function q(X,J){if(J!=null&&l(J,"options"),J?.signal!=null&&e(J.signal,"options.signal"),x(X)&&!S(X))throw new a("stream",X,"must be writable");let re=b(this,X);return J!=null&&J.signal&&E(J.signal,re),re}function he(X,J){if(typeof X!="function")throw new c("fn",["Function","AsyncFunction"],X);J!=null&&l(J,"options"),J?.signal!=null&&e(J.signal,"options.signal");let re=1;J?.concurrency!=null&&(re=_(J.concurrency));let we=re-1;return J?.highWaterMark!=null&&(we=_(J.highWaterMark)),i(re,"options.concurrency",1),i(we,"options.highWaterMark",0),we+=re,(async function*(){let pe=gt().AbortSignalAny([J?.signal].filter(A)),L=this,H=[],se={signal:pe},be,ve,Ee=!1,Q=0;function _e(){Ee=!0,Oe()}function Oe(){Q-=1,fe()}function fe(){ve&&!Ee&&Q=we||Q>=re)&&await new I(u=>{ve=u})}H.push(G)}catch(o){let u=k(o);U(u,Oe,_e),H.push(u)}finally{Ee=!0,be&&(be(),be=null)}}Be();try{for(;;){for(;H.length>0;){let o=await H[0];if(o===G)return;if(pe.aborted)throw new t;o!==z&&(yield o),H.shift(),fe()}await new I(o=>{be=o})}}finally{Ee=!0,ve&&(ve(),ve=null)}}).call(this)}function ne(X=void 0){return X!=null&&l(X,"options"),X?.signal!=null&&e(X.signal,"options.signal"),(async function*(){let J=0;for await(let we of this){var re;if(X!=null&&(re=X.signal)!==null&&re!==void 0&&re.aborted)throw new t({cause:X.signal.reason});yield[J++,we]}}).call(this)}async function te(X,J=void 0){for await(let re of M.call(this,X,J))return!0;return!1}async function ce(X,J=void 0){if(typeof X!="function")throw new c("fn",["Function","AsyncFunction"],X);return!await te.call(this,async(...re)=>!await X(...re),J)}async function V(X,J){for await(let re of M.call(this,X,J))return re}async function le(X,J){if(typeof X!="function")throw new c("fn",["Function","AsyncFunction"],X);async function re(we,pe){return await X(we,pe),z}for await(let we of he.call(this,re,J));}function M(X,J){if(typeof X!="function")throw new c("fn",["Function","AsyncFunction"],X);async function re(we,pe){return await X(we,pe)?we:z}return he.call(this,re,J)}var ee=class extends n{constructor(){super("reduce"),this.message="Reduce of an empty stream requires an initial value"}};async function Z(X,J,re){var we;if(typeof X!="function")throw new c("reducer",["Function","AsyncFunction"],X);re!=null&&l(re,"options"),re?.signal!=null&&e(re.signal,"options.signal");let pe=arguments.length>1;if(re!=null&&(we=re.signal)!==null&&we!==void 0&&we.aborted){let ve=new t(void 0,{cause:re.signal.reason});throw this.once("error",()=>{}),await g(this.destroy(ve)),ve}let L=new s,H=L.signal;if(re!=null&&re.signal){let ve={once:!0,[d]:this,[p]:!0};re.signal.addEventListener("abort",()=>L.abort(),ve)}let se=!1;try{for await(let ve of this){var be;if(se=!0,re!=null&&(be=re.signal)!==null&&be!==void 0&&be.aborted)throw new t;pe?J=await X(J,ve,{signal:H}):(J=ve,pe=!0)}if(!se&&!pe)throw new ee}finally{L.abort()}return J}async function ue(X){X!=null&&l(X,"options"),X?.signal!=null&&e(X.signal,"options.signal");let J=[];for await(let we of this){var re;if(X!=null&&(re=X.signal)!==null&&re!==void 0&&re.aborted)throw new t(void 0,{cause:X.signal.reason});v(J,we)}return J}function Ae(X,J){let re=he.call(this,X,J);return(async function*(){for await(let we of re)yield*we}).call(this)}function Y(X){if(X=C(X),w(X))return 0;if(X<0)throw new r("number",">= 0",X);return X}function W(X,J=void 0){return J!=null&&l(J,"options"),J?.signal!=null&&e(J.signal,"options.signal"),X=Y(X),(async function*(){var re;if(J!=null&&(re=J.signal)!==null&&re!==void 0&&re.aborted)throw new t;for await(let pe of this){var we;if(J!=null&&(we=J.signal)!==null&&we!==void 0&&we.aborted)throw new t;X--<=0&&(yield pe)}}).call(this)}function oe(X,J=void 0){return J!=null&&l(J,"options"),J?.signal!=null&&e(J.signal,"options.signal"),X=Y(X),(async function*(){var re;if(J!=null&&(re=J.signal)!==null&&re!==void 0&&re.aborted)throw new t;for await(let pe of this){var we;if(J!=null&&(we=J.signal)!==null&&we!==void 0&&we.aborted)throw new t;if(X-- >0&&(yield pe),X<=0)return}}).call(this)}h.exports.streamReturningOperators={asIndexedPairs:y(ne,"readable.asIndexedPairs will be removed in a future version."),drop:W,filter:M,flatMap:Ae,map:he,take:oe,compose:q},h.exports.promiseReturningOperators={every:ce,forEach:le,reduce:Z,toArray:ue,some:te,find:V}}),sa=Se((f,h)=>{ge(),me(),ye();var{ArrayPrototypePop:s,Promise:a}=Ze(),{isIterable:c,isNodeStream:n,isWebStream:r}=Ct(),{pipelineImpl:t}=fo(),{finished:e}=Vt();aa();function i(...l){return new a((d,p)=>{let g,b,E=l[l.length-1];if(E&&typeof E=="object"&&!n(E)&&!c(E)&&!r(E)){let S=s(l);g=S.signal,b=S.end}t(l,(S,x)=>{S?p(S):d(x)},{signal:g,end:b})})}h.exports={finished:e,pipeline:i}}),aa=Se((f,h)=>{ge(),me(),ye();var{Buffer:s}=(st(),Ke(ot)),{ObjectDefineProperty:a,ObjectKeys:c,ReflectApply:n}=Ze(),{promisify:{custom:r}}=gt(),{streamReturningOperators:t,promiseReturningOperators:e}=Jl(),{codes:{ERR_ILLEGAL_CONSTRUCTOR:i}}=pt(),l=oa(),{setDefaultHighWaterMark:d,getDefaultHighWaterMark:p}=Jr(),{pipeline:g}=fo(),{destroyer:b}=sr(),E=Vt(),S=sa(),x=Ct(),y=h.exports=co().Stream;y.isDestroyed=x.isDestroyed,y.isDisturbed=x.isDisturbed,y.isErrored=x.isErrored,y.isReadable=x.isReadable,y.isWritable=x.isWritable,y.Readable=Xr();for(let A of c(t)){let _=function(...w){if(new.target)throw i();return y.Readable.from(n(C,this,w))},C=t[A];a(_,"name",{__proto__:null,value:C.name}),a(_,"length",{__proto__:null,value:C.length}),a(y.Readable.prototype,A,{__proto__:null,value:_,enumerable:!1,configurable:!0,writable:!0})}for(let A of c(e)){let _=function(...w){if(new.target)throw i();return n(C,this,w)},C=e[A];a(_,"name",{__proto__:null,value:C.name}),a(_,"length",{__proto__:null,value:C.length}),a(y.Readable.prototype,A,{__proto__:null,value:_,enumerable:!1,configurable:!0,writable:!0})}y.Writable=ho(),y.Duplex=kt(),y.Transform=na(),y.PassThrough=ia(),y.pipeline=g;var{addAbortSignal:v}=Yr();y.addAbortSignal=v,y.finished=E,y.destroy=b,y.compose=l,y.setDefaultHighWaterMark=d,y.getDefaultHighWaterMark=p,a(y,"promises",{__proto__:null,configurable:!0,enumerable:!0,get(){return S}}),a(g,r,{__proto__:null,enumerable:!0,get(){return S.pipeline}}),a(E,r,{__proto__:null,enumerable:!0,get(){return S.finished}}),y.Stream=y,y._isUint8Array=function(A){return A instanceof Uint8Array},y._uint8ArrayToBuffer=function(A){return s.from(A.buffer,A.byteOffset,A.byteLength)}}),tr=Se((f,h)=>{ge(),me(),ye();var s=aa(),a=sa(),c=s.Readable.destroy;h.exports=s.Readable,h.exports._uint8ArrayToBuffer=s._uint8ArrayToBuffer,h.exports._isUint8Array=s._isUint8Array,h.exports.isDisturbed=s.isDisturbed,h.exports.isErrored=s.isErrored,h.exports.isReadable=s.isReadable,h.exports.Readable=s.Readable,h.exports.Writable=s.Writable,h.exports.Duplex=s.Duplex,h.exports.Transform=s.Transform,h.exports.PassThrough=s.PassThrough,h.exports.addAbortSignal=s.addAbortSignal,h.exports.finished=s.finished,h.exports.destroy=s.destroy,h.exports.destroy=c,h.exports.pipeline=s.pipeline,h.exports.compose=s.compose,Object.defineProperty(s,"promises",{configurable:!0,enumerable:!0,get(){return a}}),h.exports.Stream=s.Stream,h.exports.default=h.exports}),Xl=Se((f,h)=>{ge(),me(),ye(),typeof Object.create=="function"?h.exports=function(s,a){a&&(s.super_=a,s.prototype=Object.create(a.prototype,{constructor:{value:s,enumerable:!1,writable:!0,configurable:!0}}))}:h.exports=function(s,a){if(a){s.super_=a;var c=function(){};c.prototype=a.prototype,s.prototype=new c,s.prototype.constructor=s}}}),Zl=Se((f,h)=>{ge(),me(),ye();var{Buffer:s}=(st(),Ke(ot)),a=Symbol.for("BufferList");function c(n){if(!(this instanceof c))return new c(n);c._init.call(this,n)}c._init=function(n){Object.defineProperty(this,a,{value:!0}),this._bufs=[],this.length=0,n&&this.append(n)},c.prototype._new=function(n){return new c(n)},c.prototype._offset=function(n){if(n===0)return[0,0];let r=0;for(let t=0;tthis.length||n<0)return;let r=this._offset(n);return this._bufs[r[0]][r[1]]},c.prototype.slice=function(n,r){return typeof n=="number"&&n<0&&(n+=this.length),typeof r=="number"&&r<0&&(r+=this.length),this.copy(null,0,n,r)},c.prototype.copy=function(n,r,t,e){if((typeof t!="number"||t<0)&&(t=0),(typeof e!="number"||e>this.length)&&(e=this.length),t>=this.length||e<=0)return n||s.alloc(0);let i=!!n,l=this._offset(t),d=e-t,p=d,g=i&&r||0,b=l[1];if(t===0&&e===this.length){if(!i)return this._bufs.length===1?this._bufs[0]:s.concat(this._bufs,this.length);for(let E=0;ES)this._bufs[E].copy(n,g,b),g+=S;else{this._bufs[E].copy(n,g,b,b+p),g+=S;break}p-=S,b&&(b=0)}return n.length>g?n.slice(0,g):n},c.prototype.shallowSlice=function(n,r){if(n=n||0,r=typeof r!="number"?this.length:r,n<0&&(n+=this.length),r<0&&(r+=this.length),n===r)return this._new();let t=this._offset(n),e=this._offset(r),i=this._bufs.slice(t[0],e[0]+1);return e[1]===0?i.pop():i[i.length-1]=i[i.length-1].slice(0,e[1]),t[1]!==0&&(i[0]=i[0].slice(t[1])),this._new(i)},c.prototype.toString=function(n,r,t){return this.slice(r,t).toString(n)},c.prototype.consume=function(n){if(n=Math.trunc(n),Number.isNaN(n)||n<=0)return this;for(;this._bufs.length;)if(n>=this._bufs[0].length)n-=this._bufs[0].length,this.length-=this._bufs[0].length,this._bufs.shift();else{this._bufs[0]=this._bufs[0].slice(n),this.length-=n;break}return this},c.prototype.duplicate=function(){let n=this._new();for(let r=0;r=0&&l=0&<his.length?this.length:r;let e=this._offset(r),i=e[0],l=e[1];for(;i=n.length){let p=d.indexOf(n,l);if(p!==-1)return this._reverseOffset([i,p]);l=d.length-n.length+1}else{let p=this._reverseOffset([i,l]);if(this._match(p,n))return p;l++}l=0}return-1},c.prototype._match=function(n,r){if(this.length-n{ge(),me(),ye();var s=tr().Duplex,a=Xl(),c=Zl();function n(r){if(!(this instanceof n))return new n(r);if(typeof r=="function"){this._callback=r;let t=(function(e){this._callback&&(this._callback(e),this._callback=null)}).bind(this);this.on("pipe",function(e){e.on("error",t)}),this.on("unpipe",function(e){e.removeListener("error",t)}),r=null}c._init.call(this,r),s.call(this)}a(n,s),Object.assign(n.prototype,c.prototype),n.prototype._new=function(r){return new n(r)},n.prototype._write=function(r,t,e){this._appendBuffer(r),typeof e=="function"&&e()},n.prototype._read=function(r){if(!this.length)return this.push(null);r=Math.min(r,this.length),this.push(this.slice(0,r)),this.consume(r)},n.prototype.end=function(r){s.prototype.end.call(this,r),this._callback&&(this._callback(null,this.slice()),this._callback=null)},n.prototype._destroy=function(r,t){this._bufs.length=0,this.length=0,t(r)},n.prototype._isBufferList=function(r){return r instanceof n||r instanceof c||n.isBufferList(r)},n.isBufferList=c.isBufferList,h.exports=n,h.exports.BufferListStream=n,h.exports.BufferList=c}),tu=Se((f,h)=>{ge(),me(),ye();var s=class{constructor(){this.cmd=null,this.retain=!1,this.qos=0,this.dup=!1,this.length=-1,this.topic=null,this.payload=null}};h.exports=s}),la=Se((f,h)=>{ge(),me(),ye();var s=h.exports,{Buffer:a}=(st(),Ke(ot));s.types={0:"reserved",1:"connect",2:"connack",3:"publish",4:"puback",5:"pubrec",6:"pubrel",7:"pubcomp",8:"subscribe",9:"suback",10:"unsubscribe",11:"unsuback",12:"pingreq",13:"pingresp",14:"disconnect",15:"auth"},s.requiredHeaderFlags={1:0,2:0,4:0,5:0,6:2,7:0,8:2,9:0,10:2,11:0,12:0,13:0,14:0,15:0},s.requiredHeaderFlagsErrors={};for(let n in s.requiredHeaderFlags){let r=s.requiredHeaderFlags[n];s.requiredHeaderFlagsErrors[n]="Invalid header flag bits, must be 0x"+r.toString(16)+" for "+s.types[n]+" packet"}s.codes={};for(let n in s.types){let r=s.types[n];s.codes[r]=n}s.CMD_SHIFT=4,s.CMD_MASK=240,s.DUP_MASK=8,s.QOS_MASK=3,s.QOS_SHIFT=1,s.RETAIN_MASK=1,s.VARBYTEINT_MASK=127,s.VARBYTEINT_FIN_MASK=128,s.VARBYTEINT_MAX=268435455,s.SESSIONPRESENT_MASK=1,s.SESSIONPRESENT_HEADER=a.from([s.SESSIONPRESENT_MASK]),s.CONNACK_HEADER=a.from([s.codes.connack<[0,1].map(t=>[0,1].map(e=>{let i=a.alloc(1);return i.writeUInt8(s.codes[n]<a.from([n])),s.EMPTY={pingreq:a.from([s.codes.pingreq<<4,0]),pingresp:a.from([s.codes.pingresp<<4,0]),disconnect:a.from([s.codes.disconnect<<4,0])},s.MQTT5_PUBACK_PUBREC_CODES={0:"Success",16:"No matching subscribers",128:"Unspecified error",131:"Implementation specific error",135:"Not authorized",144:"Topic Name invalid",145:"Packet identifier in use",151:"Quota exceeded",153:"Payload format invalid"},s.MQTT5_PUBREL_PUBCOMP_CODES={0:"Success",146:"Packet Identifier not found"},s.MQTT5_SUBACK_CODES={0:"Granted QoS 0",1:"Granted QoS 1",2:"Granted QoS 2",128:"Unspecified error",131:"Implementation specific error",135:"Not authorized",143:"Topic Filter invalid",145:"Packet Identifier in use",151:"Quota exceeded",158:"Shared Subscriptions not supported",161:"Subscription Identifiers not supported",162:"Wildcard Subscriptions not supported"},s.MQTT5_UNSUBACK_CODES={0:"Success",17:"No subscription existed",128:"Unspecified error",131:"Implementation specific error",135:"Not authorized",143:"Topic Filter invalid",145:"Packet Identifier in use"},s.MQTT5_DISCONNECT_CODES={0:"Normal disconnection",4:"Disconnect with Will Message",128:"Unspecified error",129:"Malformed Packet",130:"Protocol Error",131:"Implementation specific error",135:"Not authorized",137:"Server busy",139:"Server shutting down",141:"Keep Alive timeout",142:"Session taken over",143:"Topic Filter invalid",144:"Topic Name invalid",147:"Receive Maximum exceeded",148:"Topic Alias invalid",149:"Packet too large",150:"Message rate too high",151:"Quota exceeded",152:"Administrative action",153:"Payload format invalid",154:"Retain not supported",155:"QoS not supported",156:"Use another server",157:"Server moved",158:"Shared Subscriptions not supported",159:"Connection rate exceeded",160:"Maximum connect time",161:"Subscription Identifiers not supported",162:"Wildcard Subscriptions not supported"},s.MQTT5_AUTH_CODES={0:"Success",24:"Continue authentication",25:"Re-authenticate"}}),ru=Se((f,h)=>{ge(),me(),ye();var s=1e3,a=s*60,c=a*60,n=c*24,r=n*7,t=n*365.25;h.exports=function(p,g){g=g||{};var b=typeof p;if(b==="string"&&p.length>0)return e(p);if(b==="number"&&isFinite(p))return g.long?l(p):i(p);throw new Error("val is not a non-empty string or a valid number. val="+JSON.stringify(p))};function e(p){if(p=String(p),!(p.length>100)){var g=/^(-?(?:\d+)?\.?\d+) *(milliseconds?|msecs?|ms|seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|weeks?|w|years?|yrs?|y)?$/i.exec(p);if(g){var b=parseFloat(g[1]),E=(g[2]||"ms").toLowerCase();switch(E){case"years":case"year":case"yrs":case"yr":case"y":return b*t;case"weeks":case"week":case"w":return b*r;case"days":case"day":case"d":return b*n;case"hours":case"hour":case"hrs":case"hr":case"h":return b*c;case"minutes":case"minute":case"mins":case"min":case"m":return b*a;case"seconds":case"second":case"secs":case"sec":case"s":return b*s;case"milliseconds":case"millisecond":case"msecs":case"msec":case"ms":return b;default:return}}}}function i(p){var g=Math.abs(p);return g>=n?Math.round(p/n)+"d":g>=c?Math.round(p/c)+"h":g>=a?Math.round(p/a)+"m":g>=s?Math.round(p/s)+"s":p+"ms"}function l(p){var g=Math.abs(p);return g>=n?d(p,g,n,"day"):g>=c?d(p,g,c,"hour"):g>=a?d(p,g,a,"minute"):g>=s?d(p,g,s,"second"):p+" ms"}function d(p,g,b,E){var S=g>=b*1.5;return Math.round(p/b)+" "+E+(S?"s":"")}}),nu=Se((f,h)=>{ge(),me(),ye();function s(a){n.debug=n,n.default=n,n.coerce=d,n.disable=i,n.enable=t,n.enabled=l,n.humanize=ru(),n.destroy=p,Object.keys(a).forEach(g=>{n[g]=a[g]}),n.names=[],n.skips=[],n.formatters={};function c(g){let b=0;for(let E=0;E{if(I==="%%")return"%";w++;let j=n.formatters[k];if(typeof j=="function"){let U=v[w];I=j.call(A,U),v.splice(w,1),w--}return I}),n.formatArgs.call(A,v),(A.log||n.log).apply(A,v)}return y.namespace=g,y.useColors=n.useColors(),y.color=n.selectColor(g),y.extend=r,y.destroy=n.destroy,Object.defineProperty(y,"enabled",{enumerable:!0,configurable:!1,get:()=>E!==null?E:(S!==n.namespaces&&(S=n.namespaces,x=n.enabled(g)),x),set:v=>{E=v}}),typeof n.init=="function"&&n.init(y),y}function r(g,b){let E=n(this.namespace+(typeof b>"u"?":":b)+g);return E.log=this.log,E}function t(g){n.save(g),n.namespaces=g,n.names=[],n.skips=[];let b=(typeof g=="string"?g:"").trim().replace(/\s+/g,",").split(",").filter(Boolean);for(let E of b)E[0]==="-"?n.skips.push(E.slice(1)):n.names.push(E)}function e(g,b){let E=0,S=0,x=-1,y=0;for(;E"-"+b)].join(",");return n.enable(""),g}function l(g){for(let b of n.skips)if(e(g,b))return!1;for(let b of n.names)if(e(g,b))return!0;return!1}function d(g){return g instanceof Error?g.stack||g.message:g}function p(){console.warn("Instance method `debug.destroy()` is deprecated and no longer does anything. It will be removed in the next major version of `debug`.")}return n.enable(n.load()),n}h.exports=s}),Tt=Se((f,h)=>{ge(),me(),ye(),f.formatArgs=a,f.save=c,f.load=n,f.useColors=s,f.storage=r(),f.destroy=(()=>{let e=!1;return()=>{e||(e=!0,console.warn("Instance method `debug.destroy()` is deprecated and no longer does anything. It will be removed in the next major version of `debug`."))}})(),f.colors=["#0000CC","#0000FF","#0033CC","#0033FF","#0066CC","#0066FF","#0099CC","#0099FF","#00CC00","#00CC33","#00CC66","#00CC99","#00CCCC","#00CCFF","#3300CC","#3300FF","#3333CC","#3333FF","#3366CC","#3366FF","#3399CC","#3399FF","#33CC00","#33CC33","#33CC66","#33CC99","#33CCCC","#33CCFF","#6600CC","#6600FF","#6633CC","#6633FF","#66CC00","#66CC33","#9900CC","#9900FF","#9933CC","#9933FF","#99CC00","#99CC33","#CC0000","#CC0033","#CC0066","#CC0099","#CC00CC","#CC00FF","#CC3300","#CC3333","#CC3366","#CC3399","#CC33CC","#CC33FF","#CC6600","#CC6633","#CC9900","#CC9933","#CCCC00","#CCCC33","#FF0000","#FF0033","#FF0066","#FF0099","#FF00CC","#FF00FF","#FF3300","#FF3333","#FF3366","#FF3399","#FF33CC","#FF33FF","#FF6600","#FF6633","#FF9900","#FF9933","#FFCC00","#FFCC33"];function s(){if(typeof window<"u"&&window.process&&(window.process.type==="renderer"||window.process.__nwjs))return!0;if(typeof navigator<"u"&&navigator.userAgent&&navigator.userAgent.toLowerCase().match(/(edge|trident)\/(\d+)/))return!1;let e;return typeof document<"u"&&document.documentElement&&document.documentElement.style&&document.documentElement.style.WebkitAppearance||typeof window<"u"&&window.console&&(window.console.firebug||window.console.exception&&window.console.table)||typeof navigator<"u"&&navigator.userAgent&&(e=navigator.userAgent.toLowerCase().match(/firefox\/(\d+)/))&&parseInt(e[1],10)>=31||typeof navigator<"u"&&navigator.userAgent&&navigator.userAgent.toLowerCase().match(/applewebkit\/(\d+)/)}function a(e){if(e[0]=(this.useColors?"%c":"")+this.namespace+(this.useColors?" %c":" ")+e[0]+(this.useColors?"%c ":" ")+"+"+h.exports.humanize(this.diff),!this.useColors)return;let i="color: "+this.color;e.splice(1,0,i,"color: inherit");let l=0,d=0;e[0].replace(/%[a-zA-Z%]/g,p=>{p!=="%%"&&(l++,p==="%c"&&(d=l))}),e.splice(d,0,i)}f.log=console.debug||console.log||(()=>{});function c(e){try{e?f.storage.setItem("debug",e):f.storage.removeItem("debug")}catch{}}function n(){let e;try{e=f.storage.getItem("debug")||f.storage.getItem("DEBUG")}catch{}return!e&&typeof Ge<"u"&&"env"in Ge&&(e=Ge.env.DEBUG),e}function r(){try{return localStorage}catch{}}h.exports=nu()(f);var{formatters:t}=h.exports;t.j=function(e){try{return JSON.stringify(e)}catch(i){return"[UnexpectedJSONParseError]: "+i.message}}}),iu=Se((f,h)=>{ge(),me(),ye();var s=eu(),{EventEmitter:a}=(Zt(),Ke(qt)),c=tu(),n=la(),r=Tt()("mqtt-packet:parser"),t=class gi extends a{constructor(){super(),this.parser=this.constructor.parser}static parser(i){return this instanceof gi?(this.settings=i||{},this._states=["_parseHeader","_parseLength","_parsePayload","_newPacket"],this._resetState(),this):new gi().parser(i)}_resetState(){r("_resetState: resetting packet, error, _list, and _stateCounter"),this.packet=new c,this.error=null,this._list=s(),this._stateCounter=0}parse(i){for(this.error&&this._resetState(),this._list.append(i),r("parse: current state: %s",this._states[this._stateCounter]);(this.packet.length!==-1||this._list.length>0)&&this[this._states[this._stateCounter]]()&&!this.error;)this._stateCounter++,r("parse: state complete. _stateCounter is now: %d",this._stateCounter),r("parse: packet.length: %d, buffer list length: %d",this.packet.length,this._list.length),this._stateCounter>=this._states.length&&(this._stateCounter=0);return r("parse: exited while loop. packet: %d, buffer list length: %d",this.packet.length,this._list.length),this._list.length}_parseHeader(){let i=this._list.readUInt8(0),l=i>>n.CMD_SHIFT;this.packet.cmd=n.types[l];let d=i&15,p=n.requiredHeaderFlags[l];return p!=null&&d!==p?this._emitError(new Error(n.requiredHeaderFlagsErrors[l])):(this.packet.retain=(i&n.RETAIN_MASK)!==0,this.packet.qos=i>>n.QOS_SHIFT&n.QOS_MASK,this.packet.qos>2?this._emitError(new Error("Packet must not have both QoS bits set to 1")):(this.packet.dup=(i&n.DUP_MASK)!==0,r("_parseHeader: packet: %o",this.packet),this._list.consume(1),!0))}_parseLength(){let i=this._parseVarByteNum(!0);return i&&(this.packet.length=i.value,this._list.consume(i.bytes)),r("_parseLength %d",i.value),!!i}_parsePayload(){r("_parsePayload: payload %O",this._list);let i=!1;if(this.packet.length===0||this._list.length>=this.packet.length){switch(this._pos=0,this.packet.cmd){case"connect":this._parseConnect();break;case"connack":this._parseConnack();break;case"publish":this._parsePublish();break;case"puback":case"pubrec":case"pubrel":case"pubcomp":this._parseConfirmation();break;case"subscribe":this._parseSubscribe();break;case"suback":this._parseSuback();break;case"unsubscribe":this._parseUnsubscribe();break;case"unsuback":this._parseUnsuback();break;case"pingreq":case"pingresp":break;case"disconnect":this._parseDisconnect();break;case"auth":this._parseAuth();break;default:this._emitError(new Error("Not supported"))}i=!0}return r("_parsePayload complete result: %s",i),i}_parseConnect(){r("_parseConnect");let i,l,d,p,g={},b=this.packet,E=this._parseString();if(E===null)return this._emitError(new Error("Cannot parse protocolId"));if(E!=="MQTT"&&E!=="MQIsdp")return this._emitError(new Error("Invalid protocolId"));if(b.protocolId=E,this._pos>=this._list.length)return this._emitError(new Error("Packet too short"));if(b.protocolVersion=this._list.readUInt8(this._pos),b.protocolVersion>=128&&(b.bridgeMode=!0,b.protocolVersion=b.protocolVersion-128),b.protocolVersion!==3&&b.protocolVersion!==4&&b.protocolVersion!==5)return this._emitError(new Error("Invalid protocol version"));if(this._pos++,this._pos>=this._list.length)return this._emitError(new Error("Packet too short"));if(this._list.readUInt8(this._pos)&1)return this._emitError(new Error("Connect flag bit 0 must be 0, but got 1"));g.username=this._list.readUInt8(this._pos)&n.USERNAME_MASK,g.password=this._list.readUInt8(this._pos)&n.PASSWORD_MASK,g.will=this._list.readUInt8(this._pos)&n.WILL_FLAG_MASK;let S=!!(this._list.readUInt8(this._pos)&n.WILL_RETAIN_MASK),x=(this._list.readUInt8(this._pos)&n.WILL_QOS_MASK)>>n.WILL_QOS_SHIFT;if(g.will)b.will={},b.will.retain=S,b.will.qos=x;else{if(S)return this._emitError(new Error("Will Retain Flag must be set to zero when Will Flag is set to 0"));if(x)return this._emitError(new Error("Will QoS must be set to zero when Will Flag is set to 0"))}if(b.clean=(this._list.readUInt8(this._pos)&n.CLEAN_SESSION_MASK)!==0,this._pos++,b.keepalive=this._parseNum(),b.keepalive===-1)return this._emitError(new Error("Packet too short"));if(b.protocolVersion===5){let v=this._parseProperties();Object.getOwnPropertyNames(v).length&&(b.properties=v)}let y=this._parseString();if(y===null)return this._emitError(new Error("Packet too short"));if(b.clientId=y,r("_parseConnect: packet.clientId: %s",b.clientId),g.will){if(b.protocolVersion===5){let v=this._parseProperties();Object.getOwnPropertyNames(v).length&&(b.will.properties=v)}if(i=this._parseString(),i===null)return this._emitError(new Error("Cannot parse will topic"));if(b.will.topic=i,r("_parseConnect: packet.will.topic: %s",b.will.topic),l=this._parseBuffer(),l===null)return this._emitError(new Error("Cannot parse will payload"));b.will.payload=l,r("_parseConnect: packet.will.paylaod: %s",b.will.payload)}if(g.username){if(p=this._parseString(),p===null)return this._emitError(new Error("Cannot parse username"));b.username=p,r("_parseConnect: packet.username: %s",b.username)}if(g.password){if(d=this._parseBuffer(),d===null)return this._emitError(new Error("Cannot parse password"));b.password=d}return this.settings=b,r("_parseConnect: complete"),b}_parseConnack(){r("_parseConnack");let i=this.packet;if(this._list.length<1)return null;let l=this._list.readUInt8(this._pos++);if(l>1)return this._emitError(new Error("Invalid connack flags, bits 7-1 must be set to 0"));if(i.sessionPresent=!!(l&n.SESSIONPRESENT_MASK),this.settings.protocolVersion===5)this._list.length>=2?i.reasonCode=this._list.readUInt8(this._pos++):i.reasonCode=0;else{if(this._list.length<2)return null;i.returnCode=this._list.readUInt8(this._pos++)}if(i.returnCode===-1||i.reasonCode===-1)return this._emitError(new Error("Cannot parse return code"));if(this.settings.protocolVersion===5){let d=this._parseProperties();Object.getOwnPropertyNames(d).length&&(i.properties=d)}r("_parseConnack: complete")}_parsePublish(){r("_parsePublish");let i=this.packet;if(i.topic=this._parseString(),i.topic===null)return this._emitError(new Error("Cannot parse topic"));if(!(i.qos>0&&!this._parseMessageId())){if(this.settings.protocolVersion===5){let l=this._parseProperties();Object.getOwnPropertyNames(l).length&&(i.properties=l)}i.payload=this._list.slice(this._pos,i.length),r("_parsePublish: payload from buffer list: %o",i.payload)}}_parseSubscribe(){r("_parseSubscribe");let i=this.packet,l,d,p,g,b,E,S;if(i.subscriptions=[],!!this._parseMessageId()){if(this.settings.protocolVersion===5){let x=this._parseProperties();Object.getOwnPropertyNames(x).length&&(i.properties=x)}if(i.length<=0)return this._emitError(new Error("Malformed subscribe, no payload specified"));for(;this._pos=i.length)return this._emitError(new Error("Malformed Subscribe Payload"));if(d=this._parseByte(),this.settings.protocolVersion===5){if(d&192)return this._emitError(new Error("Invalid subscribe topic flag bits, bits 7-6 must be 0"))}else if(d&252)return this._emitError(new Error("Invalid subscribe topic flag bits, bits 7-2 must be 0"));if(p=d&n.SUBSCRIBE_OPTIONS_QOS_MASK,p>2)return this._emitError(new Error("Invalid subscribe QoS, must be <= 2"));if(E=(d>>n.SUBSCRIBE_OPTIONS_NL_SHIFT&n.SUBSCRIBE_OPTIONS_NL_MASK)!==0,b=(d>>n.SUBSCRIBE_OPTIONS_RAP_SHIFT&n.SUBSCRIBE_OPTIONS_RAP_MASK)!==0,g=d>>n.SUBSCRIBE_OPTIONS_RH_SHIFT&n.SUBSCRIBE_OPTIONS_RH_MASK,g>2)return this._emitError(new Error("Invalid retain handling, must be <= 2"));S={topic:l,qos:p},this.settings.protocolVersion===5?(S.nl=E,S.rap=b,S.rh=g):this.settings.bridgeMode&&(S.rh=0,S.rap=!0,S.nl=!0),r("_parseSubscribe: push subscription `%s` to subscription",S),i.subscriptions.push(S)}}}_parseSuback(){r("_parseSuback");let i=this.packet;if(this.packet.granted=[],!!this._parseMessageId()){if(this.settings.protocolVersion===5){let l=this._parseProperties();Object.getOwnPropertyNames(l).length&&(i.properties=l)}if(i.length<=0)return this._emitError(new Error("Malformed suback, no payload specified"));for(;this._pos2&&l!==128)return this._emitError(new Error("Invalid suback QoS, must be 0, 1, 2 or 128"));this.packet.granted.push(l)}}}_parseUnsubscribe(){r("_parseUnsubscribe");let i=this.packet;if(i.unsubscriptions=[],!!this._parseMessageId()){if(this.settings.protocolVersion===5){let l=this._parseProperties();Object.getOwnPropertyNames(l).length&&(i.properties=l)}if(i.length<=0)return this._emitError(new Error("Malformed unsubscribe, no payload specified"));for(;this._pos