diff options
author | 2023-06-27 14:05:59 +0300 | |
---|---|---|
committer | 2023-06-27 14:05:59 +0300 | |
commit | b305309e64900cc720e859eb4bc7123bc24668cb (patch) | |
tree | d00b00e917dd34b313e6daeb42a89a24c4065e75 /src | |
parent | c96f3b303b07312d320f3f07299aac0f93d4640f (diff) | |
download | bun-b305309e64900cc720e859eb4bc7123bc24668cb.tar.gz bun-b305309e64900cc720e859eb4bc7123bc24668cb.tar.zst bun-b305309e64900cc720e859eb4bc7123bc24668cb.zip |
minor build diffs (#3427)
Diffstat (limited to 'src')
-rw-r--r-- | src/js/out/modules/node/assert.js | 84 | ||||
-rw-r--r-- | src/js/out/modules/node/fs.promises.js | 2 | ||||
-rw-r--r-- | src/js/out/modules/node/path.js | 2 | ||||
-rw-r--r-- | src/js/out/modules/node/path.posix.js | 2 | ||||
-rw-r--r-- | src/js/out/modules/node/stream.consumers.js | 2 | ||||
-rw-r--r-- | src/js/out/modules/node/stream.js | 4 |
6 files changed, 48 insertions, 48 deletions
diff --git a/src/js/out/modules/node/assert.js b/src/js/out/modules/node/assert.js index bdaa04547..dbcaf0a02 100644 --- a/src/js/out/modules/node/assert.js +++ b/src/js/out/modules/node/assert.js @@ -1,53 +1,53 @@ -import U1 from"node:util";var w1=function(){throw new Error("CallTracker is not supported yet")},{Bun:K1}=globalThis[Symbol.for("Bun.lazy")]("primordials"),X1=K1.deepEquals,Y1=(b1,Z)=>function(){return Z||(0,b1[Object.keys(b1)[0]])((Z={exports:{}}).exports,Z),Z.exports},B1=Y1({"assert/build/internal/errors.js"(b1,Z){function J(T){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?J=function(w){return typeof w}:J=function(w){return w&&typeof Symbol=="function"&&w.constructor===Symbol&&w!==Symbol.prototype?"symbol":typeof w},J(T)}function z(T,w){if(!(T instanceof w))throw new TypeError("Cannot call a class as a function")}function X(T,w){return w&&(J(w)==="object"||typeof w=="function")?w:U(T)}function U(T){if(T===void 0)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return T}function $(T){return $=Object.setPrototypeOf?Object.getPrototypeOf:function(w){return w.__proto__||Object.getPrototypeOf(w)},$(T)}function K(T,w){if(typeof w!="function"&&w!==null)throw new TypeError("Super expression must either be null or a function");T.prototype=Object.create(w&&w.prototype,{constructor:{value:T,writable:!0,configurable:!0}}),w&&W(T,w)}function W(T,w){return W=Object.setPrototypeOf||function(O,F){return O.__proto__=F,O},W(T,w)}var Y={},B,V;function D(T,w,O){O||(O=Error);function F(I,P,A){return typeof w=="string"?w:w(I,P,A)}var N=function(I){K(P,I);function P(A,S,j){var R;return z(this,P),R=X(this,$(P).call(this,F(A,S,j))),R.code=T,R}return P}(O);Y[T]=N}function M(T,w){if(Array.isArray(T)){var O=T.length;return T=T.map(function(F){return String(F)}),O>2?"one of ".concat(w," ").concat(T.slice(0,O-1).join(", "),", or ")+T[O-1]:O===2?"one of ".concat(w," ").concat(T[0]," or ").concat(T[1]):"of ".concat(w," ").concat(T[0])}else return"of ".concat(w," ").concat(String(T))}function q(T,w,O){return T.substr(!O||O<0?0:+O,w.length)===w}function v(T,w,O){return(O===void 0||O>T.length)&&(O=T.length),T.substring(O-w.length,O)===w}function G(T,w,O){return typeof O!="number"&&(O=0),O+w.length>T.length?!1:T.indexOf(w,O)!==-1}D("ERR_AMBIGUOUS_ARGUMENT",'The "%s" argument is ambiguous. %s',TypeError),D("ERR_INVALID_ARG_TYPE",function(T,w,O){B===void 0&&(B=$1()),B(typeof T=="string","'name' must be a string");var F;typeof w=="string"&&q(w,"not ")?(F="must not be",w=w.replace(/^not /,"")):F="must be";var N;if(v(T," argument"))N="The ".concat(T," ").concat(F," ").concat(M(w,"type"));else{var I=G(T,".")?"property":"argument";N='The "'.concat(T,'" ').concat(I," ").concat(F," ").concat(M(w,"type"))}return N+=". Received type ".concat(J(O)),N},TypeError),D("ERR_INVALID_ARG_VALUE",function(T,w){var O=arguments.length>2&&arguments[2]!==void 0?arguments[2]:"is invalid",F=V.inspect(w);return F.length>128&&(F="".concat(F.slice(0,128),"...")),"The argument '".concat(T,"' ").concat(O,". Received ").concat(F)},TypeError,RangeError),D("ERR_INVALID_RETURN_VALUE",function(T,w,O){var F;return O&&O.constructor&&O.constructor.name?F="instance of ".concat(O.constructor.name):F="type ".concat(J(O)),"Expected ".concat(T,' to be returned from the "').concat(w,'"')+" function but got ".concat(F,".")},TypeError),D("ERR_MISSING_ARGS",function(){for(var T=arguments.length,w=new Array(T),O=0;O<T;O++)w[O]=arguments[O];B===void 0&&(B=$1()),B(w.length>0,"At least one arg needs to be specified");var F="The ",N=w.length;switch(w=w.map(function(I){return'"'.concat(I,'"')}),N){case 1:F+="".concat(w[0]," argument");break;case 2:F+="".concat(w[0]," and ").concat(w[1]," arguments");break;default:F+=w.slice(0,N-1).join(", "),F+=", and ".concat(w[N-1]," arguments");break}return"".concat(F," must be specified")},TypeError),Z.exports.codes=Y}}),G1=Y1({"assert/build/internal/assert/assertion_error.js"(b1,Z){function J(b){for(var h=1;h<arguments.length;h++){var k=arguments[h]!=null?arguments[h]:{},m=Object.keys(k);typeof Object.getOwnPropertySymbols=="function"&&(m=m.concat(Object.getOwnPropertySymbols(k).filter(function(x){return Object.getOwnPropertyDescriptor(k,x).enumerable}))),m.forEach(function(x){z(b,x,k[x])})}return b}function z(b,h,k){return(h in b)?Object.defineProperty(b,h,{value:k,enumerable:!0,configurable:!0,writable:!0}):b[h]=k,b}function X(b,h){if(!(b instanceof h))throw new TypeError("Cannot call a class as a function")}function U(b,h){for(var k=0;k<h.length;k++){var m=h[k];m.enumerable=m.enumerable||!1,m.configurable=!0,("value"in m)&&(m.writable=!0),Object.defineProperty(b,m.key,m)}}function $(b,h,k){return h&&U(b.prototype,h),k&&U(b,k),b}function K(b,h){return h&&(G(h)==="object"||typeof h=="function")?h:W(b)}function W(b){if(b===void 0)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return b}function Y(b,h){if(typeof h!="function"&&h!==null)throw new TypeError("Super expression must either be null or a function");b.prototype=Object.create(h&&h.prototype,{constructor:{value:b,writable:!0,configurable:!0}}),h&&q(b,h)}function B(b){var h=typeof Map=="function"?new Map:void 0;return B=function(k){if(k===null||!M(k))return k;if(typeof k!="function")throw new TypeError("Super expression must either be null or a function");if(typeof h!="undefined"){if(h.has(k))return h.get(k);h.set(k,m)}function m(){return D(k,arguments,v(this).constructor)}return m.prototype=Object.create(k.prototype,{constructor:{value:m,enumerable:!1,writable:!0,configurable:!0}}),q(m,k)},B(b)}function V(){if(typeof Reflect=="undefined"||!Reflect.construct||Reflect.construct.sham)return!1;if(typeof Proxy=="function")return!0;try{return Date.prototype.toString.call(Reflect.construct(Date,[],function(){})),!0}catch{return!1}}function D(b,h,k){return V()?D=Reflect.construct:D=function(m,x,y){var g=[null];g.push.apply(g,x);var d=Function.bind.apply(m,g),_=new d;return y&&q(_,y.prototype),_},D.apply(null,arguments)}function M(b){return Function.toString.call(b).indexOf("[native code]")!==-1}function q(b,h){return q=Object.setPrototypeOf||function(k,m){return k.__proto__=m,k},q(b,h)}function v(b){return v=Object.setPrototypeOf?Object.getPrototypeOf:function(h){return h.__proto__||Object.getPrototypeOf(h)},v(b)}function G(b){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?G=function(h){return typeof h}:G=function(h){return h&&typeof Symbol=="function"&&h.constructor===Symbol&&h!==Symbol.prototype?"symbol":typeof h},G(b)}var T=U1.inspect,w=B1(),O=w.codes.ERR_INVALID_ARG_TYPE;function F(b,h,k){return(k===void 0||k>b.length)&&(k=b.length),b.substring(k-h.length,k)===h}function N(b,h){if(h=Math.floor(h),b.length==0||h==0)return"";var k=b.length*h;for(h=Math.floor(Math.log(h)/Math.log(2));h;)b+=b,h--;return b+=b.substring(0,k-b.length),b}var I="",P="",A="",S="",j={deepStrictEqual:"Expected values to be strictly deep-equal:",strictEqual:"Expected values to be strictly equal:",strictEqualObject:'Expected "actual" to be reference-equal to "expected":',deepEqual:"Expected values to be loosely deep-equal:",equal:"Expected values to be loosely equal:",notDeepStrictEqual:'Expected "actual" not to be strictly deep-equal to:',notStrictEqual:'Expected "actual" to be strictly unequal to:',notStrictEqualObject:'Expected "actual" not to be reference-equal to "expected":',notDeepEqual:'Expected "actual" not to be loosely deep-equal to:',notEqual:'Expected "actual" to be loosely unequal to:',notIdentical:"Values identical but not reference-equal:"},R=10;function f(b){var h=Object.keys(b),k=Object.create(Object.getPrototypeOf(b));return h.forEach(function(m){k[m]=b[m]}),Object.defineProperty(k,"message",{value:b.message}),k}function C(b){return T(b,{compact:!1,customInspect:!1,depth:1000,maxArrayLength:Infinity,showHidden:!1,breakLength:Infinity,showProxy:!1,sorted:!0,getters:!0})}function E(b,h,k){var m="",x="",y=0,g="",d=!1,_=C(b),u=_.split(` -`),n=C(h).split(` -`),i=0,p="";if(k==="strictEqual"&&G(b)==="object"&&G(h)==="object"&&b!==null&&h!==null&&(k="strictEqualObject"),u.length===1&&n.length===1&&u[0]!==n[0]){var l=u[0].length+n[0].length;if(l<=R){if((G(b)!=="object"||b===null)&&(G(h)!=="object"||h===null)&&(b!==0||h!==0))return"".concat(j[k],` +import J from"node:util";var f1=function(){throw new Error("CallTracker is not supported yet")},{Bun:j1}=globalThis[Symbol.for("Bun.lazy")]("primordials"),O=j1.deepEquals,N=(X,_)=>function(){return _||(0,X[Object.keys(X)[0]])((_={exports:{}}).exports,_),_.exports},z=N({"assert/build/internal/errors.js"(X,_){function u(H1){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?u=function(Q1){return typeof Q1}:u=function(Q1){return Q1&&typeof Symbol=="function"&&Q1.constructor===Symbol&&Q1!==Symbol.prototype?"symbol":typeof Q1},u(H1)}function n(H1,Q1){if(!(H1 instanceof Q1))throw new TypeError("Cannot call a class as a function")}function i(H1,Q1){return Q1&&(u(Q1)==="object"||typeof Q1=="function")?Q1:U(H1)}function U(H1){if(H1===void 0)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return H1}function p(H1){return p=Object.setPrototypeOf?Object.getPrototypeOf:function(Q1){return Q1.__proto__||Object.getPrototypeOf(Q1)},p(H1)}function l(H1,Q1){if(typeof Q1!="function"&&Q1!==null)throw new TypeError("Super expression must either be null or a function");H1.prototype=Object.create(Q1&&Q1.prototype,{constructor:{value:H1,writable:!0,configurable:!0}}),Q1&&c(H1,Q1)}function c(H1,Q1){return c=Object.setPrototypeOf||function(Z1,W){return Z1.__proto__=W,Z1},c(H1,Q1)}var o={},$,a;function t(H1,Q1,Z1){Z1||(Z1=Error);function W(z1,X1,U1){return typeof Q1=="string"?Q1:Q1(z1,X1,U1)}var J1=function(z1){l(X1,z1);function X1(U1,Y,$1){var K1;return n(this,X1),K1=i(this,p(X1).call(this,W(U1,Y,$1))),K1.code=H1,K1}return X1}(Z1);o[H1]=J1}function r(H1,Q1){if(Array.isArray(H1)){var Z1=H1.length;return H1=H1.map(function(W){return String(W)}),Z1>2?"one of ".concat(Q1," ").concat(H1.slice(0,Z1-1).join(", "),", or ")+H1[Z1-1]:Z1===2?"one of ".concat(Q1," ").concat(H1[0]," or ").concat(H1[1]):"of ".concat(Q1," ").concat(H1[0])}else return"of ".concat(Q1," ").concat(String(H1))}function s(H1,Q1,Z1){return H1.substr(!Z1||Z1<0?0:+Z1,Q1.length)===Q1}function K(H1,Q1,Z1){return(Z1===void 0||Z1>H1.length)&&(Z1=H1.length),H1.substring(Z1-Q1.length,Z1)===Q1}function e(H1,Q1,Z1){return typeof Z1!="number"&&(Z1=0),Z1+Q1.length>H1.length?!1:H1.indexOf(Q1,Z1)!==-1}t("ERR_AMBIGUOUS_ARGUMENT",'The "%s" argument is ambiguous. %s',TypeError),t("ERR_INVALID_ARG_TYPE",function(H1,Q1,Z1){$===void 0&&($=F()),$(typeof H1=="string","'name' must be a string");var W;typeof Q1=="string"&&s(Q1,"not ")?(W="must not be",Q1=Q1.replace(/^not /,"")):W="must be";var J1;if(K(H1," argument"))J1="The ".concat(H1," ").concat(W," ").concat(r(Q1,"type"));else{var z1=e(H1,".")?"property":"argument";J1='The "'.concat(H1,'" ').concat(z1," ").concat(W," ").concat(r(Q1,"type"))}return J1+=". Received type ".concat(u(Z1)),J1},TypeError),t("ERR_INVALID_ARG_VALUE",function(H1,Q1){var Z1=arguments.length>2&&arguments[2]!==void 0?arguments[2]:"is invalid",W=a.inspect(Q1);return W.length>128&&(W="".concat(W.slice(0,128),"...")),"The argument '".concat(H1,"' ").concat(Z1,". Received ").concat(W)},TypeError,RangeError),t("ERR_INVALID_RETURN_VALUE",function(H1,Q1,Z1){var W;return Z1&&Z1.constructor&&Z1.constructor.name?W="instance of ".concat(Z1.constructor.name):W="type ".concat(u(Z1)),"Expected ".concat(H1,' to be returned from the "').concat(Q1,'"')+" function but got ".concat(W,".")},TypeError),t("ERR_MISSING_ARGS",function(){for(var H1=arguments.length,Q1=new Array(H1),Z1=0;Z1<H1;Z1++)Q1[Z1]=arguments[Z1];$===void 0&&($=F()),$(Q1.length>0,"At least one arg needs to be specified");var W="The ",J1=Q1.length;switch(Q1=Q1.map(function(z1){return'"'.concat(z1,'"')}),J1){case 1:W+="".concat(Q1[0]," argument");break;case 2:W+="".concat(Q1[0]," and ").concat(Q1[1]," arguments");break;default:W+=Q1.slice(0,J1-1).join(", "),W+=", and ".concat(Q1[J1-1]," arguments");break}return"".concat(W," must be specified")},TypeError),_.exports.codes=o}}),I=N({"assert/build/internal/assert/assertion_error.js"(X,_){function u(V1){for(var D1=1;D1<arguments.length;D1++){var M1=arguments[D1]!=null?arguments[D1]:{},V=Object.keys(M1);typeof Object.getOwnPropertySymbols=="function"&&(V=V.concat(Object.getOwnPropertySymbols(M1).filter(function(q1){return Object.getOwnPropertyDescriptor(M1,q1).enumerable}))),V.forEach(function(q1){n(V1,q1,M1[q1])})}return V1}function n(V1,D1,M1){return(D1 in V1)?Object.defineProperty(V1,D1,{value:M1,enumerable:!0,configurable:!0,writable:!0}):V1[D1]=M1,V1}function i(V1,D1){if(!(V1 instanceof D1))throw new TypeError("Cannot call a class as a function")}function U(V1,D1){for(var M1=0;M1<D1.length;M1++){var V=D1[M1];V.enumerable=V.enumerable||!1,V.configurable=!0,("value"in V)&&(V.writable=!0),Object.defineProperty(V1,V.key,V)}}function p(V1,D1,M1){return D1&&U(V1.prototype,D1),M1&&U(V1,M1),V1}function l(V1,D1){return D1&&(e(D1)==="object"||typeof D1=="function")?D1:c(V1)}function c(V1){if(V1===void 0)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return V1}function o(V1,D1){if(typeof D1!="function"&&D1!==null)throw new TypeError("Super expression must either be null or a function");V1.prototype=Object.create(D1&&D1.prototype,{constructor:{value:V1,writable:!0,configurable:!0}}),D1&&s(V1,D1)}function $(V1){var D1=typeof Map=="function"?new Map:void 0;return $=function(M1){if(M1===null||!r(M1))return M1;if(typeof M1!="function")throw new TypeError("Super expression must either be null or a function");if(typeof D1!="undefined"){if(D1.has(M1))return D1.get(M1);D1.set(M1,V)}function V(){return t(M1,arguments,K(this).constructor)}return V.prototype=Object.create(M1.prototype,{constructor:{value:V,enumerable:!1,writable:!0,configurable:!0}}),s(V,M1)},$(V1)}function a(){if(typeof Reflect=="undefined"||!Reflect.construct||Reflect.construct.sham)return!1;if(typeof Proxy=="function")return!0;try{return Date.prototype.toString.call(Reflect.construct(Date,[],function(){})),!0}catch{return!1}}function t(V1,D1,M1){return a()?t=Reflect.construct:t=function(V,q1,v1){var G1=[null];G1.push.apply(G1,q1);var T1=Function.bind.apply(V,G1),D=new T1;return v1&&s(D,v1.prototype),D},t.apply(null,arguments)}function r(V1){return Function.toString.call(V1).indexOf("[native code]")!==-1}function s(V1,D1){return s=Object.setPrototypeOf||function(M1,V){return M1.__proto__=V,M1},s(V1,D1)}function K(V1){return K=Object.setPrototypeOf?Object.getPrototypeOf:function(D1){return D1.__proto__||Object.getPrototypeOf(D1)},K(V1)}function e(V1){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?e=function(D1){return typeof D1}:e=function(D1){return D1&&typeof Symbol=="function"&&D1.constructor===Symbol&&D1!==Symbol.prototype?"symbol":typeof D1},e(V1)}var H1=J.inspect,Q1=z(),Z1=Q1.codes.ERR_INVALID_ARG_TYPE;function W(V1,D1,M1){return(M1===void 0||M1>V1.length)&&(M1=V1.length),V1.substring(M1-D1.length,M1)===D1}function J1(V1,D1){if(D1=Math.floor(D1),V1.length==0||D1==0)return"";var M1=V1.length*D1;for(D1=Math.floor(Math.log(D1)/Math.log(2));D1;)V1+=V1,D1--;return V1+=V1.substring(0,M1-V1.length),V1}var z1="",X1="",U1="",Y="",$1={deepStrictEqual:"Expected values to be strictly deep-equal:",strictEqual:"Expected values to be strictly equal:",strictEqualObject:'Expected "actual" to be reference-equal to "expected":',deepEqual:"Expected values to be loosely deep-equal:",equal:"Expected values to be loosely equal:",notDeepStrictEqual:'Expected "actual" not to be strictly deep-equal to:',notStrictEqual:'Expected "actual" to be strictly unequal to:',notStrictEqualObject:'Expected "actual" not to be reference-equal to "expected":',notDeepEqual:'Expected "actual" not to be loosely deep-equal to:',notEqual:'Expected "actual" to be loosely unequal to:',notIdentical:"Values identical but not reference-equal:"},K1=10;function W1(V1){var D1=Object.keys(V1),M1=Object.create(Object.getPrototypeOf(V1));return D1.forEach(function(V){M1[V]=V1[V]}),Object.defineProperty(M1,"message",{value:V1.message}),M1}function Y1(V1){return H1(V1,{compact:!1,customInspect:!1,depth:1000,maxArrayLength:Infinity,showHidden:!1,breakLength:Infinity,showProxy:!1,sorted:!0,getters:!0})}function B(V1,D1,M1){var V="",q1="",v1=0,G1="",T1=!1,D=Y1(V1),w1=D.split(` +`),O1=Y1(D1).split(` +`),M=0,H="";if(M1==="strictEqual"&&e(V1)==="object"&&e(D1)==="object"&&V1!==null&&D1!==null&&(M1="strictEqualObject"),w1.length===1&&O1.length===1&&w1[0]!==O1[0]){var q=w1[0].length+O1[0].length;if(q<=K1){if((e(V1)!=="object"||V1===null)&&(e(D1)!=="object"||D1===null)&&(V1!==0||D1!==0))return"".concat($1[M1],` -`)+"".concat(u[0]," !== ").concat(n[0],` -`)}else if(k!=="strictEqualObject"){var c=process.stderr&&process.stderr.isTTY?process.stderr.columns:80;if(l<c){for(;u[0][i]===n[0][i];)i++;i>2&&(p=` - `.concat(N(" ",i),"^"),i=0)}}}for(var o=u[u.length-1],a=n[n.length-1];o===a&&(i++<2?g=` - `.concat(o).concat(g):m=o,u.pop(),n.pop(),!(u.length===0||n.length===0));)o=u[u.length-1],a=n[n.length-1];var t=Math.max(u.length,n.length);if(t===0){var r=_.split(` -`);if(r.length>30)for(r[26]="".concat(I,"...").concat(S);r.length>27;)r.pop();return"".concat(j.notIdentical,` +`)+"".concat(w1[0]," !== ").concat(O1[0],` +`)}else if(M1!=="strictEqualObject"){var F1=process.stderr&&process.stderr.isTTY?process.stderr.columns:80;if(q<F1){for(;w1[0][M]===O1[0][M];)M++;M>2&&(H=` + `.concat(J1(" ",M),"^"),M=0)}}}for(var N1=w1[w1.length-1],v=O1[O1.length-1];N1===v&&(M++<2?G1=` + `.concat(N1).concat(G1):V=N1,w1.pop(),O1.pop(),!(w1.length===0||O1.length===0));)N1=w1[w1.length-1],v=O1[O1.length-1];var Q=Math.max(w1.length,O1.length);if(Q===0){var G=D.split(` +`);if(G.length>30)for(G[26]="".concat(z1,"...").concat(Y);G.length>27;)G.pop();return"".concat($1.notIdentical,` -`).concat(r.join(` +`).concat(G.join(` `),` -`)}i>3&&(g=` -`.concat(I,"...").concat(S).concat(g),d=!0),m!==""&&(g=` - `.concat(m).concat(g),m="");var s=0,e=j[k]+` -`.concat(P,"+ actual").concat(S," ").concat(A,"- expected").concat(S),H1=" ".concat(I,"...").concat(S," Lines skipped");for(i=0;i<t;i++){var Q1=i-y;if(u.length<i+1)Q1>1&&i>2&&(Q1>4?(x+=` -`.concat(I,"...").concat(S),d=!0):Q1>3&&(x+=` - `.concat(n[i-2]),s++),x+=` - `.concat(n[i-1]),s++),y=i,m+=` -`.concat(A,"-").concat(S," ").concat(n[i]),s++;else if(n.length<i+1)Q1>1&&i>2&&(Q1>4?(x+=` -`.concat(I,"...").concat(S),d=!0):Q1>3&&(x+=` - `.concat(u[i-2]),s++),x+=` - `.concat(u[i-1]),s++),y=i,x+=` -`.concat(P,"+").concat(S," ").concat(u[i]),s++;else{var Z1=n[i],J1=u[i],z1=J1!==Z1&&(!F(J1,",")||J1.slice(0,-1)!==Z1);z1&&F(Z1,",")&&Z1.slice(0,-1)===J1&&(z1=!1,J1+=","),z1?(Q1>1&&i>2&&(Q1>4?(x+=` -`.concat(I,"...").concat(S),d=!0):Q1>3&&(x+=` - `.concat(u[i-2]),s++),x+=` - `.concat(u[i-1]),s++),y=i,x+=` -`.concat(P,"+").concat(S," ").concat(J1),m+=` -`.concat(A,"-").concat(S," ").concat(Z1),s+=2):(x+=m,m="",(Q1===1||i===0)&&(x+=` - `.concat(J1),s++))}if(s>20&&i<t-2)return"".concat(e).concat(H1,` -`).concat(x,` -`).concat(I,"...").concat(S).concat(m,` -`)+"".concat(I,"...").concat(S)}return"".concat(e).concat(d?H1:"",` -`).concat(x).concat(m).concat(g).concat(p)}var L=function(b){Y(h,b);function h(k){var m;if(X(this,h),G(k)!=="object"||k===null)throw new O("options","Object",k);var{message:x,operator:y,stackStartFn:g,actual:d,expected:_}=k,u=Error.stackTraceLimit;if(Error.stackTraceLimit=0,x!=null)m=K(this,v(h).call(this,String(x)));else if(process.stderr&&process.stderr.isTTY&&(process.stderr&&process.stderr.getColorDepth&&process.stderr.getColorDepth()!==1?(I="[34m",P="[32m",S="[39m",A="[31m"):(I="",P="",S="",A="")),G(d)==="object"&&d!==null&&G(_)==="object"&&_!==null&&("stack"in d)&&d instanceof Error&&("stack"in _)&&_ instanceof Error&&(d=f(d),_=f(_)),y==="deepStrictEqual"||y==="strictEqual")m=K(this,v(h).call(this,E(d,_,y)));else if(y==="notDeepStrictEqual"||y==="notStrictEqual"){var n=j[y],i=C(d).split(` -`);if(y==="notStrictEqual"&&G(d)==="object"&&d!==null&&(n=j.notStrictEqualObject),i.length>30)for(i[26]="".concat(I,"...").concat(S);i.length>27;)i.pop();i.length===1?m=K(this,v(h).call(this,"".concat(n," ").concat(i[0]))):m=K(this,v(h).call(this,"".concat(n,` +`)}M>3&&(G1=` +`.concat(z1,"...").concat(Y).concat(G1),T1=!0),V!==""&&(G1=` + `.concat(V).concat(G1),V="");var I1=0,P1=$1[M1]+` +`.concat(X1,"+ actual").concat(Y," ").concat(U1,"- expected").concat(Y),T=" ".concat(z1,"...").concat(Y," Lines skipped");for(M=0;M<Q;M++){var Z=M-v1;if(w1.length<M+1)Z>1&&M>2&&(Z>4?(q1+=` +`.concat(z1,"...").concat(Y),T1=!0):Z>3&&(q1+=` + `.concat(O1[M-2]),I1++),q1+=` + `.concat(O1[M-1]),I1++),v1=M,V+=` +`.concat(U1,"-").concat(Y," ").concat(O1[M]),I1++;else if(O1.length<M+1)Z>1&&M>2&&(Z>4?(q1+=` +`.concat(z1,"...").concat(Y),T1=!0):Z>3&&(q1+=` + `.concat(w1[M-2]),I1++),q1+=` + `.concat(w1[M-1]),I1++),v1=M,q1+=` +`.concat(X1,"+").concat(Y," ").concat(w1[M]),I1++;else{var w=O1[M],A1=w1[M],S1=A1!==w&&(!W(A1,",")||A1.slice(0,-1)!==w);S1&&W(w,",")&&w.slice(0,-1)===A1&&(S1=!1,A1+=","),S1?(Z>1&&M>2&&(Z>4?(q1+=` +`.concat(z1,"...").concat(Y),T1=!0):Z>3&&(q1+=` + `.concat(w1[M-2]),I1++),q1+=` + `.concat(w1[M-1]),I1++),v1=M,q1+=` +`.concat(X1,"+").concat(Y," ").concat(A1),V+=` +`.concat(U1,"-").concat(Y," ").concat(w),I1+=2):(q1+=V,V="",(Z===1||M===0)&&(q1+=` + `.concat(A1),I1++))}if(I1>20&&M<Q-2)return"".concat(P1).concat(T,` +`).concat(q1,` +`).concat(z1,"...").concat(Y).concat(V,` +`)+"".concat(z1,"...").concat(Y)}return"".concat(P1).concat(T1?T:"",` +`).concat(q1).concat(V).concat(G1).concat(H)}var B1=function(V1){o(D1,V1);function D1(M1){var V;if(i(this,D1),e(M1)!=="object"||M1===null)throw new Z1("options","Object",M1);var{message:q1,operator:v1,stackStartFn:G1,actual:T1,expected:D}=M1,w1=Error.stackTraceLimit;if(Error.stackTraceLimit=0,q1!=null)V=l(this,K(D1).call(this,String(q1)));else if(process.stderr&&process.stderr.isTTY&&(process.stderr&&process.stderr.getColorDepth&&process.stderr.getColorDepth()!==1?(z1="[34m",X1="[32m",Y="[39m",U1="[31m"):(z1="",X1="",Y="",U1="")),e(T1)==="object"&&T1!==null&&e(D)==="object"&&D!==null&&("stack"in T1)&&T1 instanceof Error&&("stack"in D)&&D instanceof Error&&(T1=W1(T1),D=W1(D)),v1==="deepStrictEqual"||v1==="strictEqual")V=l(this,K(D1).call(this,B(T1,D,v1)));else if(v1==="notDeepStrictEqual"||v1==="notStrictEqual"){var O1=$1[v1],M=Y1(T1).split(` +`);if(v1==="notStrictEqual"&&e(T1)==="object"&&T1!==null&&(O1=$1.notStrictEqualObject),M.length>30)for(M[26]="".concat(z1,"...").concat(Y);M.length>27;)M.pop();M.length===1?V=l(this,K(D1).call(this,"".concat(O1," ").concat(M[0]))):V=l(this,K(D1).call(this,"".concat(O1,` -`).concat(i.join(` +`).concat(M.join(` `),` -`)))}else{var p=C(d),l="",c=j[y];y==="notDeepEqual"||y==="notEqual"?(p="".concat(j[y],` +`)))}else{var H=Y1(T1),q="",F1=$1[v1];v1==="notDeepEqual"||v1==="notEqual"?(H="".concat($1[v1],` -`).concat(p),p.length>1024&&(p="".concat(p.slice(0,1021),"..."))):(l="".concat(C(_)),p.length>512&&(p="".concat(p.slice(0,509),"...")),l.length>512&&(l="".concat(l.slice(0,509),"...")),y==="deepEqual"||y==="equal"?p="".concat(c,` +`).concat(H),H.length>1024&&(H="".concat(H.slice(0,1021),"..."))):(q="".concat(Y1(D)),H.length>512&&(H="".concat(H.slice(0,509),"...")),q.length>512&&(q="".concat(q.slice(0,509),"...")),v1==="deepEqual"||v1==="equal"?H="".concat(F1,` -`).concat(p,` +`).concat(H,` should equal -`):l=" ".concat(y," ").concat(l)),m=K(this,v(h).call(this,"".concat(p).concat(l)))}return Error.stackTraceLimit=u,m.generatedMessage=!x,Object.defineProperty(W(m),"name",{value:"AssertionError [ERR_ASSERTION]",enumerable:!1,writable:!0,configurable:!0}),m.code="ERR_ASSERTION",m.actual=d,m.expected=_,m.operator=y,Error.captureStackTrace&&Error.captureStackTrace(W(m),g),m.stack,m.name="AssertionError",K(m)}return $(h,[{key:"toString",value:function(){return"".concat(this.name," [").concat(this.code,"]: ").concat(this.message)}},{key:T.custom,value:function(k,m){return T(this,J({},m,{customInspect:!1,depth:0}))}}]),h}(B(Error));Z.exports=L}}),$1=Y1({"assert/build/assert.js"(b1,Z){function J(y){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?J=function(g){return typeof g}:J=function(g){return g&&typeof Symbol=="function"&&g.constructor===Symbol&&g!==Symbol.prototype?"symbol":typeof g},J(y)}function z(y,g){if(!(y instanceof g))throw new TypeError("Cannot call a class as a function")}var X=B1(),U=X.codes,$=U.ERR_AMBIGUOUS_ARGUMENT,K=U.ERR_INVALID_ARG_TYPE,W=U.ERR_INVALID_ARG_VALUE,Y=U.ERR_INVALID_RETURN_VALUE,B=U.ERR_MISSING_ARGS,V=G1(),D=U1,M=D.inspect,q=U1.types,v=q.isPromise,G=q.isRegExp,T=Object.assign,w=Object.is,O=new Map,F=!1,N=Z.exports=j,I={};function P(y){throw y.message instanceof Error?y.message:new V(y)}function A(y,g,d,_,u){var n=arguments.length,i;if(n===0)i="Failed";else if(n===1)d=y,y=void 0;else{if(F===!1){F=!0;var p=process.emitWarning?process.emitWarning:console.warn.bind(console);p("assert.fail() with more than one argument is deprecated. Please use assert.strictEqual() instead or only pass a message.","DeprecationWarning","DEP0094")}n===2&&(_="!=")}if(d instanceof Error)throw d;var l={actual:y,expected:g,operator:_===void 0?"fail":_,stackStartFn:u||A};d!==void 0&&(l.message=d);var c=new V(l);throw i&&(c.message=i,c.generatedMessage=!0),c}N.fail=A,N.AssertionError=V;function S(y,g,d,_){if(!d){var u=!1;if(g===0)u=!0,_="No value argument passed to `assert.ok()`";else if(_ instanceof Error)throw _;var n=new V({actual:d,expected:!0,message:_,operator:"==",stackStartFn:y});throw n.generatedMessage=u,n}}function j(){for(var y=arguments.length,g=new Array(y),d=0;d<y;d++)g[d]=arguments[d];S.apply(void 0,[j,g.length].concat(g))}N.ok=j,N.equal=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");g!=d&&P({actual:g,expected:d,message:_,operator:"==",stackStartFn:y})},N.notEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");g==d&&P({actual:g,expected:d,message:_,operator:"!=",stackStartFn:y})},N.deepEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");X1(g,d,!1)||P({actual:g,expected:d,message:_,operator:"deepEqual",stackStartFn:y})},N.notDeepEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");X1(g,d,!1)&&P({actual:g,expected:d,message:_,operator:"notDeepEqual",stackStartFn:y})},N.deepStrictEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");X1(g,d,!0)||P({actual:g,expected:d,message:_,operator:"deepStrictEqual",stackStartFn:y})},N.notDeepStrictEqual=R;function R(y,g,d){if(arguments.length<2)throw new B("actual","expected");X1(y,g,!0)&&P({actual:y,expected:g,message:d,operator:"notDeepStrictEqual",stackStartFn:R})}N.strictEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");w(g,d)||P({actual:g,expected:d,message:_,operator:"strictEqual",stackStartFn:y})},N.notStrictEqual=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");w(g,d)&&P({actual:g,expected:d,message:_,operator:"notStrictEqual",stackStartFn:y})},N.match=function y(g,d,_){if(arguments.length<2)throw new B("actual","expected");if(!G(d))throw new K("expected","RegExp",d);d.test(g)||P({actual:g,expected:d,message:_,operator:"match",stackStartFn:y})};var f=function y(g,d,_){var u=this;z(this,y),d.forEach(function(n){(n in g)&&(_!==void 0&&typeof _[n]=="string"&&G(g[n])&&g[n].test(_[n])?u[n]=_[n]:u[n]=g[n])})};function C(y,g,d,_,u,n){if(!(d in y)||!X1(y[d],g[d],!0)){if(!_){var i=new f(y,u),p=new f(g,u,y),l=new V({actual:i,expected:p,operator:"deepStrictEqual",stackStartFn:n});throw l.actual=y,l.expected=g,l.operator=n.name,l}P({actual:y,expected:g,message:_,operator:n.name,stackStartFn:n})}}function E(y,g,d,_){if(typeof g!="function"){if(G(g))return g.test(y);if(arguments.length===2)throw new K("expected",["Function","RegExp"],g);if(J(y)!=="object"||y===null){var u=new V({actual:y,expected:g,message:d,operator:"deepStrictEqual",stackStartFn:_});throw u.operator=_.name,u}var n=Object.keys(g);if(g instanceof Error)n.push("name","message");else if(n.length===0)throw new W("error",g,"may not be an empty object");return n.forEach(function(i){return typeof y[i]=="string"&&G(g[i])&&g[i].test(y[i])||C(y,g,i,d,n,_)}),!0}return g.prototype!==void 0&&y instanceof g?!0:Error.isPrototypeOf(g)?!1:g.call({},y)===!0}function L(y){if(typeof y!="function")throw new K("fn","Function",y);try{y()}catch(g){return g}return I}function b(y){return v(y)||y!==null&&J(y)==="object"&&typeof y.then=="function"&&typeof y.catch=="function"}function h(y){return Promise.resolve().then(function(){var g;if(typeof y=="function"){if(g=y(),!b(g))throw new Y("instance of Promise","promiseFn",g)}else if(b(y))g=y;else throw new K("promiseFn",["Function","Promise"],y);return Promise.resolve().then(function(){return g}).then(function(){return I}).catch(function(d){return d})})}function k(y,g,d,_){if(typeof d=="string"){if(arguments.length===4)throw new K("error",["Object","Error","Function","RegExp"],d);if(J(g)==="object"&&g!==null){if(g.message===d)throw new $("error/message",'The error message "'.concat(g.message,'" is identical to the message.'))}else if(g===d)throw new $("error/message",'The error "'.concat(g,'" is identical to the message.'));_=d,d=void 0}else if(d!=null&&J(d)!=="object"&&typeof d!="function")throw new K("error",["Object","Error","Function","RegExp"],d);if(g===I){var u="";d&&d.name&&(u+=" (".concat(d.name,")")),u+=_?": ".concat(_):".";var n=y.name==="rejects"?"rejection":"exception";P({actual:void 0,expected:d,operator:y.name,message:"Missing expected ".concat(n).concat(u),stackStartFn:y})}if(d&&!E(g,d,_,y))throw g}function m(y,g,d,_){if(g!==I){if(typeof d=="string"&&(_=d,d=void 0),!d||E(g,d)){var u=_?": ".concat(_):".",n=y.name==="doesNotReject"?"rejection":"exception";P({actual:g,expected:d,operator:y.name,message:"Got unwanted ".concat(n).concat(u,` -`)+'Actual message: "'.concat(g&&g.message,'"'),stackStartFn:y})}throw g}}N.throws=function y(g){for(var d=arguments.length,_=new Array(d>1?d-1:0),u=1;u<d;u++)_[u-1]=arguments[u];k.apply(void 0,[y,L(g)].concat(_))},N.rejects=function y(g){for(var d=arguments.length,_=new Array(d>1?d-1:0),u=1;u<d;u++)_[u-1]=arguments[u];return h(g).then(function(n){return k.apply(void 0,[y,n].concat(_))})},N.doesNotThrow=function y(g){for(var d=arguments.length,_=new Array(d>1?d-1:0),u=1;u<d;u++)_[u-1]=arguments[u];m.apply(void 0,[y,L(g)].concat(_))},N.doesNotReject=function y(g){for(var d=arguments.length,_=new Array(d>1?d-1:0),u=1;u<d;u++)_[u-1]=arguments[u];return h(g).then(function(n){return m.apply(void 0,[y,n].concat(_))})},N.ifError=function y(g){if(g!=null){var d="ifError got unwanted exception: ";J(g)==="object"&&typeof g.message=="string"?g.message.length===0&&g.constructor?d+=g.constructor.name:d+=g.message:d+=M(g);var _=new V({actual:g,expected:null,operator:"ifError",message:d,stackStartFn:y}),u=g.stack;if(typeof u=="string"){var n=u.split(` -`);n.shift();for(var i=_.stack.split(` -`),p=0;p<n.length;p++){var l=i.indexOf(n[p]);if(l!==-1){i=i.slice(0,l);break}}_.stack="".concat(i.join(` +`):q=" ".concat(v1," ").concat(q)),V=l(this,K(D1).call(this,"".concat(H).concat(q)))}return Error.stackTraceLimit=w1,V.generatedMessage=!q1,Object.defineProperty(c(V),"name",{value:"AssertionError [ERR_ASSERTION]",enumerable:!1,writable:!0,configurable:!0}),V.code="ERR_ASSERTION",V.actual=T1,V.expected=D,V.operator=v1,Error.captureStackTrace&&Error.captureStackTrace(c(V),G1),V.stack,V.name="AssertionError",l(V)}return p(D1,[{key:"toString",value:function(){return"".concat(this.name," [").concat(this.code,"]: ").concat(this.message)}},{key:H1.custom,value:function(M1,V){return H1(this,u({},V,{customInspect:!1,depth:0}))}}]),D1}($(Error));_.exports=B1}}),F=N({"assert/build/assert.js"(X,_){function u(v1){return typeof Symbol=="function"&&typeof Symbol.iterator=="symbol"?u=function(G1){return typeof G1}:u=function(G1){return G1&&typeof Symbol=="function"&&G1.constructor===Symbol&&G1!==Symbol.prototype?"symbol":typeof G1},u(v1)}function n(v1,G1){if(!(v1 instanceof G1))throw new TypeError("Cannot call a class as a function")}var i=z(),U=i.codes,p=U.ERR_AMBIGUOUS_ARGUMENT,l=U.ERR_INVALID_ARG_TYPE,c=U.ERR_INVALID_ARG_VALUE,o=U.ERR_INVALID_RETURN_VALUE,$=U.ERR_MISSING_ARGS,a=I(),t=J,r=t.inspect,s=J.types,K=s.isPromise,e=s.isRegExp,H1=Object.assign,Q1=Object.is,Z1=new Map,W=!1,J1=_.exports=$1,z1={};function X1(v1){throw v1.message instanceof Error?v1.message:new a(v1)}function U1(v1,G1,T1,D,w1){var O1=arguments.length,M;if(O1===0)M="Failed";else if(O1===1)T1=v1,v1=void 0;else{if(W===!1){W=!0;var H=process.emitWarning?process.emitWarning:console.warn.bind(console);H("assert.fail() with more than one argument is deprecated. Please use assert.strictEqual() instead or only pass a message.","DeprecationWarning","DEP0094")}O1===2&&(D="!=")}if(T1 instanceof Error)throw T1;var q={actual:v1,expected:G1,operator:D===void 0?"fail":D,stackStartFn:w1||U1};T1!==void 0&&(q.message=T1);var F1=new a(q);throw M&&(F1.message=M,F1.generatedMessage=!0),F1}J1.fail=U1,J1.AssertionError=a;function Y(v1,G1,T1,D){if(!T1){var w1=!1;if(G1===0)w1=!0,D="No value argument passed to `assert.ok()`";else if(D instanceof Error)throw D;var O1=new a({actual:T1,expected:!0,message:D,operator:"==",stackStartFn:v1});throw O1.generatedMessage=w1,O1}}function $1(){for(var v1=arguments.length,G1=new Array(v1),T1=0;T1<v1;T1++)G1[T1]=arguments[T1];Y.apply(void 0,[$1,G1.length].concat(G1))}J1.ok=$1,J1.equal=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");G1!=T1&&X1({actual:G1,expected:T1,message:D,operator:"==",stackStartFn:v1})},J1.notEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");G1==T1&&X1({actual:G1,expected:T1,message:D,operator:"!=",stackStartFn:v1})},J1.deepEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");O(G1,T1,!1)||X1({actual:G1,expected:T1,message:D,operator:"deepEqual",stackStartFn:v1})},J1.notDeepEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");O(G1,T1,!1)&&X1({actual:G1,expected:T1,message:D,operator:"notDeepEqual",stackStartFn:v1})},J1.deepStrictEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");O(G1,T1,!0)||X1({actual:G1,expected:T1,message:D,operator:"deepStrictEqual",stackStartFn:v1})},J1.notDeepStrictEqual=K1;function K1(v1,G1,T1){if(arguments.length<2)throw new $("actual","expected");O(v1,G1,!0)&&X1({actual:v1,expected:G1,message:T1,operator:"notDeepStrictEqual",stackStartFn:K1})}J1.strictEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");Q1(G1,T1)||X1({actual:G1,expected:T1,message:D,operator:"strictEqual",stackStartFn:v1})},J1.notStrictEqual=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");Q1(G1,T1)&&X1({actual:G1,expected:T1,message:D,operator:"notStrictEqual",stackStartFn:v1})},J1.match=function v1(G1,T1,D){if(arguments.length<2)throw new $("actual","expected");if(!e(T1))throw new l("expected","RegExp",T1);T1.test(G1)||X1({actual:G1,expected:T1,message:D,operator:"match",stackStartFn:v1})};var W1=function v1(G1,T1,D){var w1=this;n(this,v1),T1.forEach(function(O1){(O1 in G1)&&(D!==void 0&&typeof D[O1]=="string"&&e(G1[O1])&&G1[O1].test(D[O1])?w1[O1]=D[O1]:w1[O1]=G1[O1])})};function Y1(v1,G1,T1,D,w1,O1){if(!(T1 in v1)||!O(v1[T1],G1[T1],!0)){if(!D){var M=new W1(v1,w1),H=new W1(G1,w1,v1),q=new a({actual:M,expected:H,operator:"deepStrictEqual",stackStartFn:O1});throw q.actual=v1,q.expected=G1,q.operator=O1.name,q}X1({actual:v1,expected:G1,message:D,operator:O1.name,stackStartFn:O1})}}function B(v1,G1,T1,D){if(typeof G1!="function"){if(e(G1))return G1.test(v1);if(arguments.length===2)throw new l("expected",["Function","RegExp"],G1);if(u(v1)!=="object"||v1===null){var w1=new a({actual:v1,expected:G1,message:T1,operator:"deepStrictEqual",stackStartFn:D});throw w1.operator=D.name,w1}var O1=Object.keys(G1);if(G1 instanceof Error)O1.push("name","message");else if(O1.length===0)throw new c("error",G1,"may not be an empty object");return O1.forEach(function(M){return typeof v1[M]=="string"&&e(G1[M])&&G1[M].test(v1[M])||Y1(v1,G1,M,T1,O1,D)}),!0}return G1.prototype!==void 0&&v1 instanceof G1?!0:Error.isPrototypeOf(G1)?!1:G1.call({},v1)===!0}function B1(v1){if(typeof v1!="function")throw new l("fn","Function",v1);try{v1()}catch(G1){return G1}return z1}function V1(v1){return K(v1)||v1!==null&&u(v1)==="object"&&typeof v1.then=="function"&&typeof v1.catch=="function"}function D1(v1){return Promise.resolve().then(function(){var G1;if(typeof v1=="function"){if(G1=v1(),!V1(G1))throw new o("instance of Promise","promiseFn",G1)}else if(V1(v1))G1=v1;else throw new l("promiseFn",["Function","Promise"],v1);return Promise.resolve().then(function(){return G1}).then(function(){return z1}).catch(function(T1){return T1})})}function M1(v1,G1,T1,D){if(typeof T1=="string"){if(arguments.length===4)throw new l("error",["Object","Error","Function","RegExp"],T1);if(u(G1)==="object"&&G1!==null){if(G1.message===T1)throw new p("error/message",'The error message "'.concat(G1.message,'" is identical to the message.'))}else if(G1===T1)throw new p("error/message",'The error "'.concat(G1,'" is identical to the message.'));D=T1,T1=void 0}else if(T1!=null&&u(T1)!=="object"&&typeof T1!="function")throw new l("error",["Object","Error","Function","RegExp"],T1);if(G1===z1){var w1="";T1&&T1.name&&(w1+=" (".concat(T1.name,")")),w1+=D?": ".concat(D):".";var O1=v1.name==="rejects"?"rejection":"exception";X1({actual:void 0,expected:T1,operator:v1.name,message:"Missing expected ".concat(O1).concat(w1),stackStartFn:v1})}if(T1&&!B(G1,T1,D,v1))throw G1}function V(v1,G1,T1,D){if(G1!==z1){if(typeof T1=="string"&&(D=T1,T1=void 0),!T1||B(G1,T1)){var w1=D?": ".concat(D):".",O1=v1.name==="doesNotReject"?"rejection":"exception";X1({actual:G1,expected:T1,operator:v1.name,message:"Got unwanted ".concat(O1).concat(w1,` +`)+'Actual message: "'.concat(G1&&G1.message,'"'),stackStartFn:v1})}throw G1}}J1.throws=function v1(G1){for(var T1=arguments.length,D=new Array(T1>1?T1-1:0),w1=1;w1<T1;w1++)D[w1-1]=arguments[w1];M1.apply(void 0,[v1,B1(G1)].concat(D))},J1.rejects=function v1(G1){for(var T1=arguments.length,D=new Array(T1>1?T1-1:0),w1=1;w1<T1;w1++)D[w1-1]=arguments[w1];return D1(G1).then(function(O1){return M1.apply(void 0,[v1,O1].concat(D))})},J1.doesNotThrow=function v1(G1){for(var T1=arguments.length,D=new Array(T1>1?T1-1:0),w1=1;w1<T1;w1++)D[w1-1]=arguments[w1];V.apply(void 0,[v1,B1(G1)].concat(D))},J1.doesNotReject=function v1(G1){for(var T1=arguments.length,D=new Array(T1>1?T1-1:0),w1=1;w1<T1;w1++)D[w1-1]=arguments[w1];return D1(G1).then(function(O1){return V.apply(void 0,[v1,O1].concat(D))})},J1.ifError=function v1(G1){if(G1!=null){var T1="ifError got unwanted exception: ";u(G1)==="object"&&typeof G1.message=="string"?G1.message.length===0&&G1.constructor?T1+=G1.constructor.name:T1+=G1.message:T1+=r(G1);var D=new a({actual:G1,expected:null,operator:"ifError",message:T1,stackStartFn:v1}),w1=G1.stack;if(typeof w1=="string"){var O1=w1.split(` +`);O1.shift();for(var M=D.stack.split(` +`),H=0;H<O1.length;H++){var q=M.indexOf(O1[H]);if(q!==-1){M=M.slice(0,q);break}}D.stack="".concat(M.join(` `),` -`).concat(n.join(` -`))}throw _}};function x(){for(var y=arguments.length,g=new Array(y),d=0;d<y;d++)g[d]=arguments[d];S.apply(void 0,[x,g.length].concat(g))}N.strict=T(x,N,{equal:N.strictEqual,deepEqual:N.deepStrictEqual,notEqual:N.notStrictEqual,notDeepEqual:N.notDeepStrictEqual}),N.strict.strict=N.strict}}),T1=$1();T1[Symbol.for("CommonJS")]=0;T1["CallTracker"]=w1;var{AssertionError:O1,assert:V1,deepEqual:M1,deepStrictEqual:F1,doesNotReject:N1,doesNotThrow:I1,equal:P1,fail:A1,ifError:S1,notDeepEqual:j1,notDeepStrictEqual:R1,notEqual:f1,notStrictEqual:H,ok:C1,rejects:q1,strict:Q,strictEqual:D1,throws:E1}=T1,L1=T1;export{E1 as throws,D1 as strictEqual,Q as strict,q1 as rejects,C1 as ok,H as notStrictEqual,f1 as notEqual,R1 as notDeepStrictEqual,j1 as notDeepEqual,S1 as ifError,A1 as fail,P1 as equal,I1 as doesNotThrow,N1 as doesNotReject,L1 as default,F1 as deepStrictEqual,M1 as deepEqual,V1 as assert,O1 as AssertionError}; +`).concat(O1.join(` +`))}throw D}};function q1(){for(var v1=arguments.length,G1=new Array(v1),T1=0;T1<v1;T1++)G1[T1]=arguments[T1];Y.apply(void 0,[q1,G1.length].concat(G1))}J1.strict=H1(q1,J1,{equal:J1.strictEqual,deepEqual:J1.deepStrictEqual,notEqual:J1.notStrictEqual,notDeepEqual:J1.notDeepStrictEqual}),J1.strict.strict=J1.strict}}),R=F();R[Symbol.for("CommonJS")]=0;R["CallTracker"]=f1;var{AssertionError:f,assert:x,deepEqual:P,deepStrictEqual:C,doesNotReject:C1,doesNotThrow:E,equal:y,fail:A,ifError:L,notDeepEqual:E1,notDeepStrictEqual:b,notEqual:g,notStrictEqual:S,ok:h,rejects:L1,strict:k,strictEqual:d,throws:j}=R,b1=R;export{j as throws,d as strictEqual,k as strict,L1 as rejects,h as ok,S as notStrictEqual,g as notEqual,b as notDeepStrictEqual,E1 as notDeepEqual,L as ifError,A as fail,y as equal,E as doesNotThrow,C1 as doesNotReject,b1 as default,C as deepStrictEqual,P as deepEqual,x as assert,f as AssertionError}; diff --git a/src/js/out/modules/node/fs.promises.js b/src/js/out/modules/node/fs.promises.js index 549ba0c9c..ef0d9efff 100644 --- a/src/js/out/modules/node/fs.promises.js +++ b/src/js/out/modules/node/fs.promises.js @@ -1 +1 @@ -function J(S,q={}){const z=[];if(S instanceof URL)throw new TypeError("Watch URLs are not supported yet");else if(Buffer.isBuffer(S))S=S.toString();else if(typeof S!=="string")throw new TypeError("Expected path to be a string or Buffer");let A=null;if(typeof q==="string")q={encoding:q};return H.watch(S,q||{},(B,C)=>{if(z.push({eventType:B,filename:C}),A){const D=A;A=null,D()}}),{async*[Symbol.asyncIterator](){let B=!1;while(!B){while(z.length){let C=z.shift();if(C.eventType==="close"){B=!0;break}if(C.eventType==="error")throw B=!0,C.filename;yield C}await new Promise((C)=>A=C)}}}}var H=Bun.fs(),G="::bunternal::",I={[G]:(S)=>{var q={[G]:function(z,A,B){var C;try{C=S.apply(H,B),B=void 0}catch(D){B=void 0,A(D);return}z(C)}}[G];return async function(...z){return await new Promise((A,B)=>{process.nextTick(q,A,B,z)})}}}[G],K=I(H.accessSync),L=I(H.appendFileSync),M=I(H.closeSync),N=I(H.copyFileSync),O=I(H.existsSync),P=I(H.chownSync),Q=I(H.chmodSync),U=I(H.fchmodSync),V=I(H.fchownSync),X=I(H.fstatSync),Y=I(H.fsyncSync),Z=I(H.ftruncateSync),_=I(H.futimesSync),$=I(H.lchmodSync),T=I(H.lchownSync),W=I(H.linkSync),k=I(H.lstatSync),E=I(H.mkdirSync),x=I(H.mkdtempSync),F=I(H.openSync),R=I(H.readSync),g=I(H.writeSync),h=I(H.readdirSync),j=I(H.readFileSync),w=I(H.writeFileSync),b=I(H.readlinkSync),u=I(H.realpathSync),d=I(H.renameSync),c=I(H.statSync),v=I(H.symlinkSync),a=I(H.truncateSync),y=I(H.unlinkSync),l=I(H.utimesSync),p=I(H.lutimesSync),m=I(H.rmSync),n=I(H.rmdirSync),t=(S,q,z)=>{return new Promise((A,B)=>{try{var C=H.writevSync(S,q,z)}catch(D){B(D);return}A({bytesWritten:C,buffers:q})})},o=(S,q,z)=>{return new Promise((A,B)=>{try{var C=H.readvSync(S,q,z)}catch(D){B(D);return}A({bytesRead:C,buffers:q})})},r={access:K,appendFile:L,close:M,copyFile:N,exists:O,chown:P,chmod:Q,fchmod:U,fchown:V,fstat:X,fsync:Y,ftruncate:Z,futimes:_,lchmod:$,lchown:T,link:W,lstat:k,mkdir:E,mkdtemp:x,open:F,read:R,write:g,readdir:h,readFile:j,writeFile:w,readlink:b,realpath:u,rename:d,stat:c,symlink:v,truncate:a,unlink:y,utimes:l,lutimes:p,rm:m,rmdir:n,watch:J,writev:t,readv:o,constants,[Symbol.for("CommonJS")]:0};export{t as writev,w as writeFile,g as write,J as watch,l as utimes,y as unlink,a as truncate,v as symlink,c as stat,n as rmdir,m as rm,d as rename,u as realpath,o as readv,b as readlink,h as readdir,j as readFile,R as read,F as open,x as mkdtemp,E as mkdir,p as lutimes,k as lstat,W as link,T as lchown,$ as lchmod,_ as futimes,Z as ftruncate,Y as fsync,X as fstat,V as fchown,U as fchmod,O as exists,r as default,N as copyFile,M as close,P as chown,Q as chmod,L as appendFile,K as access}; +function z(i,S={}){const L=[];if(i instanceof URL)throw new TypeError("Watch URLs are not supported yet");else if(Buffer.isBuffer(i))i=i.toString();else if(typeof i!=="string")throw new TypeError("Expected path to be a string or Buffer");let n=null;if(typeof S==="string")S={encoding:S};return V.watch(i,S||{},(r,a)=>{if(L.push({eventType:r,filename:a}),n){const E=n;n=null,E()}}),{async*[Symbol.asyncIterator](){let r=!1;while(!r){while(L.length){let a=L.shift();if(a.eventType==="close"){r=!0;break}if(a.eventType==="error")throw r=!0,a.filename;yield a}await new Promise((a)=>n=a)}}}}var V=Bun.fs(),_="::bunternal::",q={[_]:(i)=>{var S={[_]:function(L,n,r){var a;try{a=i.apply(V,r),r=void 0}catch(E){r=void 0,n(E);return}L(a)}}[_];return async function(...L){return await new Promise((n,r)=>{process.nextTick(S,n,r,L)})}}}[_],k=q(V.accessSync),X=q(V.appendFileSync),l=q(V.closeSync),b=q(V.copyFileSync),R=q(V.existsSync),h=q(V.chownSync),j=q(V.chmodSync),N=q(V.fchmodSync),A=q(V.fchownSync),B=q(V.fstatSync),d=q(V.fsyncSync),P=q(V.ftruncateSync),p=q(V.futimesSync),O=q(V.lchmodSync),o=q(V.lchownSync),K=q(V.linkSync),Z=q(V.lstatSync),C=q(V.mkdirSync),D=q(V.mkdtempSync),y=q(V.openSync),c=q(V.readSync),G=q(V.writeSync),U=q(V.readdirSync),m=q(V.readFileSync),Q=q(V.writeFileSync),H=q(V.readlinkSync),v=q(V.realpathSync),x=q(V.renameSync),F=q(V.statSync),$=q(V.symlinkSync),W=q(V.truncateSync),w=q(V.unlinkSync),t=q(V.utimesSync),Y=q(V.lutimesSync),g=q(V.rmSync),T=q(V.rmdirSync),I=(i,S,L)=>{return new Promise((n,r)=>{try{var a=V.writevSync(i,S,L)}catch(E){r(E);return}n({bytesWritten:a,buffers:S})})},J=(i,S,L)=>{return new Promise((n,r)=>{try{var a=V.readvSync(i,S,L)}catch(E){r(E);return}n({bytesRead:a,buffers:S})})},M={access:k,appendFile:X,close:l,copyFile:b,exists:R,chown:h,chmod:j,fchmod:N,fchown:A,fstat:B,fsync:d,ftruncate:P,futimes:p,lchmod:O,lchown:o,link:K,lstat:Z,mkdir:C,mkdtemp:D,open:y,read:c,write:G,readdir:U,readFile:m,writeFile:Q,readlink:H,realpath:v,rename:x,stat:F,symlink:$,truncate:W,unlink:w,utimes:t,lutimes:Y,rm:g,rmdir:T,watch:z,writev:I,readv:J,constants,[Symbol.for("CommonJS")]:0};export{I as writev,Q as writeFile,G as write,z as watch,t as utimes,w as unlink,W as truncate,$ as symlink,F as stat,T as rmdir,g as rm,x as rename,v as realpath,J as readv,H as readlink,U as readdir,m as readFile,c as read,y as open,D as mkdtemp,C as mkdir,Y as lutimes,Z as lstat,K as link,o as lchown,O as lchmod,p as futimes,P as ftruncate,d as fsync,B as fstat,A as fchown,N as fchmod,R as exists,M as default,b as copyFile,l as close,h as chown,j as chmod,X as appendFile,k as access}; diff --git a/src/js/out/modules/node/path.js b/src/js/out/modules/node/path.js index 4e6003c7d..f8cc1ec08 100644 --- a/src/js/out/modules/node/path.js +++ b/src/js/out/modules/node/path.js @@ -1 +1 @@ -var H=function(i){var G=f({basename:i.basename.bind(i),dirname:i.dirname.bind(i),extname:i.extname.bind(i),format:i.format.bind(i),isAbsolute:i.isAbsolute.bind(i),join:i.join.bind(i),normalize:i.normalize.bind(i),parse:i.parse.bind(i),relative:i.relative.bind(i),resolve:i.resolve.bind(i),toNamespacedPath:i.toNamespacedPath.bind(i),sep:i.sep,delimiter:i.delimiter});return G.default=G,G},f=(i)=>Object.assign(Object.create(null),i),m=H(Bun._Path()),I=H(Bun._Path(!1)),g=H(Bun._Path(!0));m.win32=g;m.posix=I;var{basename:J,dirname:k,extname:K,format:q,isAbsolute:L,join:v,normalize:N,parse:y,relative:O,resolve:C,toNamespacedPath:z,sep:D,delimiter:A,__esModule:E}=m;m[Symbol.for("CommonJS")]=0;m.__esModule=!0;var F=m;export{g as win32,z as toNamespacedPath,D as sep,C as resolve,O as relative,I as posix,y as parse,N as normalize,v as join,L as isAbsolute,q as format,K as extname,k as dirname,A as delimiter,F as default,f as createModule,J as basename,E as __esModule}; +var g=function(i){var f=m({basename:i.basename.bind(i),dirname:i.dirname.bind(i),extname:i.extname.bind(i),format:i.format.bind(i),isAbsolute:i.isAbsolute.bind(i),join:i.join.bind(i),normalize:i.normalize.bind(i),parse:i.parse.bind(i),relative:i.relative.bind(i),resolve:i.resolve.bind(i),toNamespacedPath:i.toNamespacedPath.bind(i),sep:i.sep,delimiter:i.delimiter});return f.default=f,f},m=(i)=>Object.assign(Object.create(null),i),k=g(Bun._Path()),q=g(Bun._Path(!1)),v=g(Bun._Path(!0));k.win32=v;k.posix=q;var{basename:y,dirname:z,extname:A,format:B,isAbsolute:C,join:D,normalize:E,parse:F,relative:G,resolve:H,toNamespacedPath:I,sep:J,delimiter:K,__esModule:L}=k;k[Symbol.for("CommonJS")]=0;k.__esModule=!0;var O=k;export{v as win32,I as toNamespacedPath,J as sep,H as resolve,G as relative,q as posix,F as parse,E as normalize,D as join,C as isAbsolute,B as format,A as extname,z as dirname,K as delimiter,O as default,m as createModule,y as basename,L as __esModule}; diff --git a/src/js/out/modules/node/path.posix.js b/src/js/out/modules/node/path.posix.js index ca08d44b8..64e8a62f5 100644 --- a/src/js/out/modules/node/path.posix.js +++ b/src/js/out/modules/node/path.posix.js @@ -1 +1 @@ -var r=function(i){return{basename:i.basename.bind(i),dirname:i.dirname.bind(i),extname:i.extname.bind(i),format:i.format.bind(i),isAbsolute:i.isAbsolute.bind(i),join:i.join.bind(i),normalize:i.normalize.bind(i),parse:i.parse.bind(i),relative:i.relative.bind(i),resolve:i.resolve.bind(i),toNamespacedPath:i.toNamespacedPath.bind(i),sep:i.sep,delimiter:i.delimiter}},k=r(Bun._Path(!1));k[Symbol.for("CommonJS")]=0;var{basename:e,dirname:m,extname:d,format:l,isAbsolute:s,join:c,normalize:f,parse:g,relative:q,resolve:t,toNamespacedPath:v,sep:w,delimiter:x}=k,z=k;export{v as toNamespacedPath,w as sep,t as resolve,q as relative,g as parse,f as normalize,c as join,s as isAbsolute,l as format,d as extname,m as dirname,x as delimiter,z as default,e as basename}; +var i=function(e){return{basename:e.basename.bind(e),dirname:e.dirname.bind(e),extname:e.extname.bind(e),format:e.format.bind(e),isAbsolute:e.isAbsolute.bind(e),join:e.join.bind(e),normalize:e.normalize.bind(e),parse:e.parse.bind(e),relative:e.relative.bind(e),resolve:e.resolve.bind(e),toNamespacedPath:e.toNamespacedPath.bind(e),sep:e.sep,delimiter:e.delimiter}},r=i(Bun._Path(!1));r[Symbol.for("CommonJS")]=0;var{basename:d,dirname:l,extname:s,format:c,isAbsolute:f,join:g,normalize:k,parse:m,relative:q,resolve:t,toNamespacedPath:v,sep:w,delimiter:x}=r,z=r;export{v as toNamespacedPath,w as sep,t as resolve,q as relative,m as parse,k as normalize,g as join,f as isAbsolute,c as format,s as extname,l as dirname,x as delimiter,z as default,d as basename}; diff --git a/src/js/out/modules/node/stream.consumers.js b/src/js/out/modules/node/stream.consumers.js index 8e3592104..20bbb7de4 100644 --- a/src/js/out/modules/node/stream.consumers.js +++ b/src/js/out/modules/node/stream.consumers.js @@ -1 +1 @@ -var{Bun:k}=globalThis[Symbol.for("Bun.lazy")]("primordials"),p=k.readableStreamToArrayBuffer,o=k.readableStreamToText,h=(c)=>k.readableStreamToText(c).then(JSON.parse),g=async(c)=>{return new Buffer(await p(c))},i=k.readableStreamToBlob,q={[Symbol.for("CommonJS")]:0,arrayBuffer:p,text:o,json:h,buffer:g,blob:i};export{o as text,h as json,q as default,g as buffer,i as blob,p as arrayBuffer}; +var{Bun:o}=globalThis[Symbol.for("Bun.lazy")]("primordials"),p=o.readableStreamToArrayBuffer,c=o.readableStreamToText,g=(h)=>o.readableStreamToText(h).then(JSON.parse),i=async(h)=>{return new Buffer(await p(h))},k=o.readableStreamToBlob,q={[Symbol.for("CommonJS")]:0,arrayBuffer:p,text:c,json:g,buffer:i,blob:k};export{c as text,g as json,q as default,i as buffer,k as blob,p as arrayBuffer}; diff --git a/src/js/out/modules/node/stream.js b/src/js/out/modules/node/stream.js index 31a1d64c6..f96818bd6 100644 --- a/src/js/out/modules/node/stream.js +++ b/src/js/out/modules/node/stream.js @@ -1,2 +1,2 @@ -import{EventEmitter as CQ} from"bun:events_native";import{StringDecoder as Eq} from"node:string_decoder";var M=function(B){return typeof B==="object"&&B!==null&&B instanceof ReadableStream},F=function(B,Y){if(typeof B!=="boolean")throw new yQ(Y,"boolean",B)};var yQ=function(B,Y,U){return new Error(`The argument '${B}' is invalid. Received '${U}' for type '${Y}'`)},xq=function(B,Y,U){return new Error(`The value '${Y}' is invalid for argument '${B}'. Reason: ${U}`)},P=function(B,Y){var[U,H,X,q,J,Q,Z]=globalThis[Symbol.for("Bun.lazy")](B),K=[!1],oq=function(rq,m,tq,c){if(m>0){const eq=tq.subarray(0,m),d=tq.subarray(m);if(eq.byteLength>0)rq.push(eq);if(c)rq.push(null);return d.byteLength>0?d:void 0}if(c)rq.push(null);return tq},p=function(rq,m,tq,c){if(m.byteLength>0)rq.push(m);if(c)rq.push(null);return tq},sq=process.env.BUN_DISABLE_DYNAMIC_CHUNK_SIZE!=="1";const u=new FinalizationRegistry((rq)=>rq&&J(rq)),aq=512;var b=class rq extends Y{#q;#Q=1;#X=!1;#J=void 0;#H;#K=!1;#Z=!sq;#B;constructor(m,tq={}){super(tq);if(typeof tq.highWaterMark==="number")this.#H=tq.highWaterMark;else this.#H=262144;this.#q=m,this.#X=!1,this.#J=void 0,this.#K=!1,this.#B={},u.register(this,this.#q,this.#B)}_read(m){if(OQ&&Gq("NativeReadable._read",this.__id),this.#K){OQ&&Gq("pendingRead is true",this.__id);return}var tq=this.#q;if(OQ&&Gq("ptr @ NativeReadable._read",tq,this.__id),tq===0){this.push(null);return}if(!this.#X)OQ&&Gq("NativeReadable not constructed yet",this.__id),this.#Y(tq);return this.#V(this.#$(m),tq)}#Y(m){this.#X=!0;const tq=H(m,this.#H);if(OQ&&Gq("NativeReadable internal `start` result",tq,this.__id),typeof tq==="number"&&tq>1)this.#Z=!0,OQ&&Gq("NativeReadable resized",this.__id),this.#H=Math.min(this.#H,tq);if(Z){const c=Z(m);if(OQ&&Gq("NativeReadable drain result",c,this.__id),(c?.byteLength??0)>0)this.push(c)}}#$(m=this.#H){var tq=this.#J;if(OQ&&Gq("chunk @ #getRemainingChunk",tq,this.__id),tq?.byteLength??0<aq){var c=m>aq?m:aq;this.#J=tq=new Buffer(c)}return tq}push(m,tq){return OQ&&Gq("NativeReadable push -- result, encoding",m,tq,this.__id),super.push(...arguments)}#z(m,tq,c){if(OQ&&Gq("result, isClosed @ #handleResult",m,c,this.__id),typeof m==="number"){if(m>=this.#H&&!this.#Z&&!c)this.#H*=2,this.#Z=!0;return oq(this,m,tq,c)}else if(typeof m==="boolean")return this.push(null),tq?.byteLength??0>0?tq:void 0;else if(ArrayBuffer.isView(m)){if(m.byteLength>=this.#H&&!this.#Z&&!c)this.#H*=2,this.#Z=!0,OQ&&Gq("Resized",this.__id);return p(this,m,tq,c)}else throw OQ&&Gq("Unknown result type",m,this.__id),new Error("Invalid result from pull")}#V(m,tq){OQ&&Gq("#internalRead()",this.__id),K[0]=!1;var c=U(tq,m,K);if(Lq(c))return this.#K=!0,c.then((eq)=>{this.#K=!1,OQ&&Gq("pending no longerrrrrrrr (result returned from pull)",this.__id),this.#J=this.#z(eq,m,K[0])},(eq)=>{OQ&&Gq("error from pull",eq,this.__id),errorOrDestroy(this,eq)});else this.#J=this.#z(c,m,K[0])}_destroy(m,tq){var c=this.#q;if(c===0){tq(m);return}if(u.unregister(this.#B),this.#q=0,Q)Q(c,!1);OQ&&Gq("NativeReadable destroyed",this.__id),X(c,m),tq(m)}ref(){var m=this.#q;if(m===0)return;if(this.#Q++===0)Q(m,!0)}unref(){var m=this.#q;if(m===0)return;if(this.#Q--===1)Q(m,!1)}};if(!Q)b.prototype.ref=void 0,b.prototype.unref=void 0;return b},O=function(B,Y){return x[B]||=P(B,Y)},_=function(B,Y,U){if(!(Y&&typeof Y==="object"&&Y instanceof ReadableStream))return;const H=vQ(Y);if(!H){Gq("no native readable stream");return}const{stream:X,data:q}=H;return new(O(q,B))(X,U)},{isPromise:Lq,isCallable:Nq,direct:vQ,Object:Fq}=globalThis[Symbol.for("Bun.lazy")]("primordials");globalThis.__IDS_TO_TRACK=process.env.DEBUG_TRACK_EE?.length?process.env.DEBUG_TRACK_EE.split(","):process.env.DEBUG_STREAMS?.length?process.env.DEBUG_STREAMS.split(","):null;var SQ=!!process.env.DEBUG_TRACK_EE,OQ=!!(process.env.DEBUG||process.env.DEBUG_STREAMS||SQ),Gq=OQ?globalThis.__IDS_TO_TRACK?(...B)=>{const Y=B[B.length-1];if(!globalThis.__IDS_TO_TRACK.includes(Y))return;console.log(`ID: ${Y}`,...B.slice(0,-1))}:(...B)=>console.log(...B.slice(0,-1)):()=>{},Iq=Fq.create,gQ=Fq.defineProperty,V=Fq.getOwnPropertyDescriptor,fQ=Fq.getOwnPropertyNames,Tq=Fq.getPrototypeOf,kQ=Fq.prototype.hasOwnProperty,W=Fq.setPrototypeOf,G=(B,Y)=>function U(){return Y||(0,B[fQ(B)[0]])((Y={exports:{}}).exports,Y),Y.exports};var _Q=process.nextTick;var Pq=Array.isArray,DQ=G({"node_modules/readable-stream/lib/ours/primordials.js"(B,Y){Y.exports={ArrayIsArray(U){return Array.isArray(U)},ArrayPrototypeIncludes(U,H){return U.includes(H)},ArrayPrototypeIndexOf(U,H){return U.indexOf(H)},ArrayPrototypeJoin(U,H){return U.join(H)},ArrayPrototypeMap(U,H){return U.map(H)},ArrayPrototypePop(U,H){return U.pop(H)},ArrayPrototypePush(U,H){return U.push(H)},ArrayPrototypeSlice(U,H,X){return U.slice(H,X)},Error,FunctionPrototypeCall(U,H,...X){return U.call(H,...X)},FunctionPrototypeSymbolHasInstance(U,H){return Function.prototype[Symbol.hasInstance].call(U,H)},MathFloor:Math.floor,Number,NumberIsInteger:Number.isInteger,NumberIsNaN:Number.isNaN,NumberMAX_SAFE_INTEGER:Number.MAX_SAFE_INTEGER,NumberMIN_SAFE_INTEGER:Number.MIN_SAFE_INTEGER,NumberParseInt:Number.parseInt,ObjectDefineProperties(U,H){return Fq.defineProperties(U,H)},ObjectDefineProperty(U,H,X){return Fq.defineProperty(U,H,X)},ObjectGetOwnPropertyDescriptor(U,H){return Fq.getOwnPropertyDescriptor(U,H)},ObjectKeys(U){return Fq.keys(U)},ObjectSetPrototypeOf(U,H){return Fq.setPrototypeOf(U,H)},Promise,PromisePrototypeCatch(U,H){return U.catch(H)},PromisePrototypeThen(U,H,X){return U.then(H,X)},PromiseReject(U){return Promise.reject(U)},ReflectApply:Reflect.apply,RegExpPrototypeTest(U,H){return U.test(H)},SafeSet:Set,String,StringPrototypeSlice(U,H,X){return U.slice(H,X)},StringPrototypeToLowerCase(U){return U.toLowerCase()},StringPrototypeToUpperCase(U){return U.toUpperCase()},StringPrototypeTrim(U){return U.trim()},Symbol,SymbolAsyncIterator:Symbol.asyncIterator,SymbolHasInstance:Symbol.hasInstance,SymbolIterator:Symbol.iterator,TypedArrayPrototypeSet(U,H,X){return U.set(H,X)},Uint8Array}}}),jq=G({"node_modules/readable-stream/lib/ours/util.js"(B,Y){var U=Fq.getPrototypeOf(async function(){}).constructor,H=typeof Blob!=="undefined"?function q(J){return J instanceof Blob}:function q(J){return!1},X=class extends Error{constructor(q){if(!Array.isArray(q))throw new TypeError(`Expected input to be an Array, got ${typeof q}`);let J="";for(let Q=0;Q<q.length;Q++)J+=` ${q[Q].stack} -`;super(J);this.name="AggregateError",this.errors=q}};Y.exports={AggregateError:X,once(q){let J=!1;return function(...Q){if(J)return;J=!0,q.apply(this,Q)}},createDeferredPromise:function(){let q,J;return{promise:new Promise((Z,K)=>{q=Z,J=K}),resolve:q,reject:J}},promisify(q){return new Promise((J,Q)=>{q((Z,...K)=>{if(Z)return Q(Z);return J(...K)})})},debuglog(){return function(){}},format(q,...J){return q.replace(/%([sdifj])/g,function(...[Q,Z]){const K=J.shift();if(Z==="f")return K.toFixed(6);else if(Z==="j")return JSON.stringify(K);else if(Z==="s"&&typeof K==="object")return`${K.constructor!==Fq?K.constructor.name:""} {}`.trim();else return K.toString()})},inspect(q){switch(typeof q){case"string":if(q.includes("'")){if(!q.includes('"'))return`"${q}"`;else if(!q.includes("`")&&!q.includes("${"))return`\`${q}\``}return`'${q}'`;case"number":if(isNaN(q))return"NaN";else if(Fq.is(q,-0))return String(q);return q;case"bigint":return`${String(q)}n`;case"boolean":case"undefined":return String(q);case"object":return"{}"}},types:{isAsyncFunction(q){return q instanceof U},isArrayBufferView(q){return ArrayBuffer.isView(q)}},isBlob:H},Y.exports.promisify.custom=Symbol.for("nodejs.util.promisify.custom")}}),hQ=G({"node_modules/readable-stream/lib/ours/errors.js"(B,Y){var{format:U,inspect:H,AggregateError:X}=jq(),q=globalThis.AggregateError||X,J=Symbol("kIsNodeError"),Q=["string","function","number","object","Function","Object","boolean","bigint","symbol"],Z=/^([A-Z][a-z0-9]*)+$/,K="__node_internal_",oq={};function p(tq,c){if(!tq)throw new oq.ERR_INTERNAL_ASSERTION(c)}function sq(tq){let c="",eq=tq.length;const d=tq[0]==="-"?1:0;for(;eq>=d+4;eq-=3)c=`_${tq.slice(eq-3,eq)}${c}`;return`${tq.slice(0,eq)}${c}`}function u(tq,c,eq){if(typeof c==="function")return p(c.length<=eq.length,`Code: ${tq}; The provided arguments length (${eq.length}) does not match the required ones (${c.length}).`),c(...eq);const d=(c.match(/%[dfijoOs]/g)||[]).length;if(p(d===eq.length,`Code: ${tq}; The provided arguments length (${eq.length}) does not match the required ones (${d}).`),eq.length===0)return c;return U(c,...eq)}function aq(tq,c,eq){if(!eq)eq=Error;class d extends eq{constructor(...qQ){super(u(tq,c,qQ))}toString(){return`${this.name} [${tq}]: ${this.message}`}}Fq.defineProperties(d.prototype,{name:{value:eq.name,writable:!0,enumerable:!1,configurable:!0},toString:{value(){return`${this.name} [${tq}]: ${this.message}`},writable:!0,enumerable:!1,configurable:!0}}),d.prototype.code=tq,d.prototype[J]=!0,oq[tq]=d}function b(tq){const c=K+tq.name;return Fq.defineProperty(tq,"name",{value:c}),tq}function rq(tq,c){if(tq&&c&&tq!==c){if(Array.isArray(c.errors))return c.errors.push(tq),c;const eq=new q([c,tq],c.message);return eq.code=c.code,eq}return tq||c}var m=class extends Error{constructor(tq="The operation was aborted",c=void 0){if(c!==void 0&&typeof c!=="object")throw new oq.ERR_INVALID_ARG_TYPE("options","Object",c);super(tq,c);this.code="ABORT_ERR",this.name="AbortError"}};aq("ERR_ASSERTION","%s",Error),aq("ERR_INVALID_ARG_TYPE",(tq,c,eq)=>{if(p(typeof tq==="string","'name' must be a string"),!Array.isArray(c))c=[c];let d="The ";if(tq.endsWith(" argument"))d+=`${tq} `;else d+=`"${tq}" ${tq.includes(".")?"property":"argument"} `;d+="must be ";const qQ=[],l=[],QQ=[];for(let XQ of c)if(p(typeof XQ==="string","All expected entries have to be of type string"),Q.includes(XQ))qQ.push(XQ.toLowerCase());else if(Z.test(XQ))l.push(XQ);else p(XQ!=="object",'The value "object" should be written as "Object"'),QQ.push(XQ);if(l.length>0){const XQ=qQ.indexOf("object");if(XQ!==-1)qQ.splice(qQ,XQ,1),l.push("Object")}if(qQ.length>0){switch(qQ.length){case 1:d+=`of type ${qQ[0]}`;break;case 2:d+=`one of type ${qQ[0]} or ${qQ[1]}`;break;default:{const XQ=qQ.pop();d+=`one of type ${qQ.join(", ")}, or ${XQ}`}}if(l.length>0||QQ.length>0)d+=" or "}if(l.length>0){switch(l.length){case 1:d+=`an instance of ${l[0]}`;break;case 2:d+=`an instance of ${l[0]} or ${l[1]}`;break;default:{const XQ=l.pop();d+=`an instance of ${l.join(", ")}, or ${XQ}`}}if(QQ.length>0)d+=" or "}switch(QQ.length){case 0:break;case 1:if(QQ[0].toLowerCase()!==QQ[0])d+="an ";d+=`${QQ[0]}`;break;case 2:d+=`one of ${QQ[0]} or ${QQ[1]}`;break;default:{const XQ=QQ.pop();d+=`one of ${QQ.join(", ")}, or ${XQ}`}}if(eq==null)d+=`. Received ${eq}`;else if(typeof eq==="function"&&eq.name)d+=`. Received function ${eq.name}`;else if(typeof eq==="object"){var i;if((i=eq.constructor)!==null&&i!==void 0&&i.name)d+=`. Received an instance of ${eq.constructor.name}`;else{const XQ=H(eq,{depth:-1});d+=`. Received ${XQ}`}}else{let XQ=H(eq,{colors:!1});if(XQ.length>25)XQ=`${XQ.slice(0,25)}...`;d+=`. Received type ${typeof eq} (${XQ})`}return d},TypeError),aq("ERR_INVALID_ARG_VALUE",(tq,c,eq="is invalid")=>{let d=H(c);if(d.length>128)d=d.slice(0,128)+"...";return`The ${tq.includes(".")?"property":"argument"} '${tq}' ${eq}. Received ${d}`},TypeError),aq("ERR_INVALID_RETURN_VALUE",(tq,c,eq)=>{var d;const qQ=eq!==null&&eq!==void 0&&(d=eq.constructor)!==null&&d!==void 0&&d.name?`instance of ${eq.constructor.name}`:`type ${typeof eq}`;return`Expected ${tq} to be returned from the "${c}" function but got ${qQ}.`},TypeError),aq("ERR_MISSING_ARGS",(...tq)=>{p(tq.length>0,"At least one arg needs to be specified");let c;const eq=tq.length;switch(tq=(Array.isArray(tq)?tq:[tq]).map((d)=>`"${d}"`).join(" or "),eq){case 1:c+=`The ${tq[0]} argument`;break;case 2:c+=`The ${tq[0]} and ${tq[1]} arguments`;break;default:{const d=tq.pop();c+=`The ${tq.join(", ")}, and ${d} arguments`}break}return`${c} must be specified`},TypeError),aq("ERR_OUT_OF_RANGE",(tq,c,eq)=>{p(c,'Missing "range" argument');let d;if(Number.isInteger(eq)&&Math.abs(eq)>4294967296)d=sq(String(eq));else if(typeof eq==="bigint"){if(d=String(eq),eq>2n**32n||eq<-(2n**32n))d=sq(d);d+="n"}else d=H(eq);return`The value of "${tq}" is out of range. It must be ${c}. Received ${d}`},RangeError),aq("ERR_MULTIPLE_CALLBACK","Callback called multiple times",Error),aq("ERR_METHOD_NOT_IMPLEMENTED","The %s method is not implemented",Error),aq("ERR_STREAM_ALREADY_FINISHED","Cannot call %s after a stream was finished",Error),aq("ERR_STREAM_CANNOT_PIPE","Cannot pipe, not readable",Error),aq("ERR_STREAM_DESTROYED","Cannot call %s after a stream was destroyed",Error),aq("ERR_STREAM_NULL_VALUES","May not write null values to stream",TypeError),aq("ERR_STREAM_PREMATURE_CLOSE","Premature close",Error),aq("ERR_STREAM_PUSH_AFTER_EOF","stream.push() after EOF",Error),aq("ERR_STREAM_UNSHIFT_AFTER_END_EVENT","stream.unshift() after end event",Error),aq("ERR_STREAM_WRITE_AFTER_END","write after end",Error),aq("ERR_UNKNOWN_ENCODING","Unknown encoding: %s",TypeError),Y.exports={AbortError:m,aggregateTwoErrors:b(rq),hideStackFrames:b,codes:oq}}}),L=G({"node_modules/readable-stream/lib/internal/validators.js"(B,Y){var{ArrayIsArray:U,ArrayPrototypeIncludes:H,ArrayPrototypeJoin:X,ArrayPrototypeMap:q,NumberIsInteger:J,NumberMAX_SAFE_INTEGER:Q,NumberMIN_SAFE_INTEGER:Z,NumberParseInt:K,RegExpPrototypeTest:oq,String:p,StringPrototypeToUpperCase:sq,StringPrototypeTrim:u}=DQ(),{hideStackFrames:aq,codes:{ERR_SOCKET_BAD_PORT:b,ERR_INVALID_ARG_TYPE:rq,ERR_INVALID_ARG_VALUE:m,ERR_OUT_OF_RANGE:tq,ERR_UNKNOWN_SIGNAL:c}}=hQ(),{normalizeEncoding:eq}=jq(),{isAsyncFunction:d,isArrayBufferView:qQ}=jq().types,l={};function QQ(UQ){return UQ===(UQ|0)}function i(UQ){return UQ===UQ>>>0}var XQ=/^[0-7]+$/,n="must be a 32-bit unsigned integer or an octal string";function JQ(UQ,Qq,WQ){if(typeof UQ==="undefined")UQ=WQ;if(typeof UQ==="string"){if(!oq(XQ,UQ))throw new m(Qq,UQ,n);UQ=K(UQ,8)}return HQ(UQ,Qq,0,4294967295),UQ}var o=aq((UQ,Qq,WQ=Z,Xq=Q)=>{if(typeof UQ!=="number")throw new rq(Qq,"number",UQ);if(!J(UQ))throw new tq(Qq,"an integer",UQ);if(UQ<WQ||UQ>Xq)throw new tq(Qq,`>= ${WQ} && <= ${Xq}`,UQ)}),HQ=aq((UQ,Qq,WQ=-2147483648,Xq=2147483647)=>{if(typeof UQ!=="number")throw new rq(Qq,"number",UQ);if(!QQ(UQ)){if(!J(UQ))throw new tq(Qq,"an integer",UQ);throw new tq(Qq,`>= ${WQ} && <= ${Xq}`,UQ)}if(UQ<WQ||UQ>Xq)throw new tq(Qq,`>= ${WQ} && <= ${Xq}`,UQ)}),s=aq((UQ,Qq,WQ)=>{if(typeof UQ!=="number")throw new rq(Qq,"number",UQ);if(!i(UQ)){if(!J(UQ))throw new tq(Qq,"an integer",UQ);throw new tq(Qq,`>= ${WQ?1:0} && < 4294967296`,UQ)}if(WQ&&UQ===0)throw new tq(Qq,">= 1 && < 4294967296",UQ)});function KQ(UQ,Qq){if(typeof UQ!=="string")throw new rq(Qq,"string",UQ)}function a(UQ,Qq){if(typeof UQ!=="number")throw new rq(Qq,"number",UQ)}var ZQ=aq((UQ,Qq,WQ)=>{if(!H(WQ,UQ)){const GQ="must be one of: "+X(q(WQ,(Jq)=>typeof Jq==="string"?`'${Jq}'`:p(Jq)),", ");throw new m(Qq,UQ,GQ)}});function r(UQ,Qq){if(typeof UQ!=="boolean")throw new rq(Qq,"boolean",UQ)}var BQ=aq((UQ,Qq,WQ)=>{const Xq=WQ==null,GQ=Xq?!1:WQ.allowArray,Jq=Xq?!1:WQ.allowFunction;if(!(Xq?!1:WQ.nullable)&&UQ===null||!GQ&&U(UQ)||typeof UQ!=="object"&&(!Jq||typeof UQ!=="function"))throw new rq(Qq,"Object",UQ)}),$=aq((UQ,Qq,WQ=0)=>{if(!U(UQ))throw new rq(Qq,"Array",UQ);if(UQ.length<WQ){const Xq=`must be longer than ${WQ}`;throw new m(Qq,UQ,Xq)}});function YQ(UQ,Qq="signal"){if(KQ(UQ,Qq),l[UQ]===void 0){if(l[sq(UQ)]!==void 0)throw new c(UQ+" (signals must use all capital letters)");throw new c(UQ)}}var z=aq((UQ,Qq="buffer")=>{if(!qQ(UQ))throw new rq(Qq,["Buffer","TypedArray","DataView"],UQ)});function $Q(UQ,Qq){const WQ=eq(Qq),Xq=UQ.length;if(WQ==="hex"&&Xq%2!==0)throw new m("encoding",Qq,`is invalid for data of length ${Xq}`)}function t(UQ,Qq="Port",WQ=!0){if(typeof UQ!=="number"&&typeof UQ!=="string"||typeof UQ==="string"&&u(UQ).length===0||+UQ!==+UQ>>>0||UQ>65535||UQ===0&&!WQ)throw new b(Qq,UQ,WQ);return UQ|0}var zQ=aq((UQ,Qq)=>{if(UQ!==void 0&&(UQ===null||typeof UQ!=="object"||!("aborted"in UQ)))throw new rq(Qq,"AbortSignal",UQ)}),e=aq((UQ,Qq)=>{if(typeof UQ!=="function")throw new rq(Qq,"Function",UQ)}),VQ=aq((UQ,Qq)=>{if(typeof UQ!=="function"||d(UQ))throw new rq(Qq,"Function",UQ)}),qq=aq((UQ,Qq)=>{if(UQ!==void 0)throw new rq(Qq,"undefined",UQ)});Y.exports={isInt32:QQ,isUint32:i,parseFileMode:JQ,validateArray:$,validateBoolean:r,validateBuffer:z,validateEncoding:$Q,validateFunction:e,validateInt32:HQ,validateInteger:o,validateNumber:a,validateObject:BQ,validateOneOf:ZQ,validatePlainFunction:VQ,validatePort:t,validateSignalName:YQ,validateString:KQ,validateUint32:s,validateUndefined:qq,validateAbortSignal:zQ}}}),j=G({"node_modules/readable-stream/lib/internal/streams/utils.js"(B,Y){var{Symbol:U,SymbolAsyncIterator:H,SymbolIterator:X}=DQ(),q=U("kDestroyed"),J=U("kIsErrored"),Q=U("kIsReadable"),Z=U("kIsDisturbed");function K(s,KQ=!1){var a;return!!(s&&typeof s.pipe==="function"&&typeof s.on==="function"&&(!KQ||typeof s.pause==="function"&&typeof s.resume==="function")&&(!s._writableState||((a=s._readableState)===null||a===void 0?void 0:a.readable)!==!1)&&(!s._writableState||s._readableState))}function oq(s){var KQ;return!!(s&&typeof s.write==="function"&&typeof s.on==="function"&&(!s._readableState||((KQ=s._writableState)===null||KQ===void 0?void 0:KQ.writable)!==!1))}function p(s){return!!(s&&typeof s.pipe==="function"&&s._readableState&&typeof s.on==="function"&&typeof s.write==="function")}function sq(s){return s&&(s._readableState||s._writableState||typeof s.write==="function"&&typeof s.on==="function"||typeof s.pipe==="function"&&typeof s.on==="function")}function u(s,KQ){if(s==null)return!1;if(KQ===!0)return typeof s[H]==="function";if(KQ===!1)return typeof s[X]==="function";return typeof s[H]==="function"||typeof s[X]==="function"}function aq(s){if(!sq(s))return null;const{_writableState:KQ,_readableState:a}=s,ZQ=KQ||a;return!!(s.destroyed||s[q]||ZQ!==null&&ZQ!==void 0&&ZQ.destroyed)}function b(s){if(!oq(s))return null;if(s.writableEnded===!0)return!0;const KQ=s._writableState;if(KQ!==null&&KQ!==void 0&&KQ.errored)return!1;if(typeof(KQ===null||KQ===void 0?void 0:KQ.ended)!=="boolean")return null;return KQ.ended}function rq(s,KQ){if(!oq(s))return null;if(s.writableFinished===!0)return!0;const a=s._writableState;if(a!==null&&a!==void 0&&a.errored)return!1;if(typeof(a===null||a===void 0?void 0:a.finished)!=="boolean")return null;return!!(a.finished||KQ===!1&&a.ended===!0&&a.length===0)}function m(s){if(!K(s))return null;if(s.readableEnded===!0)return!0;const KQ=s._readableState;if(!KQ||KQ.errored)return!1;if(typeof(KQ===null||KQ===void 0?void 0:KQ.ended)!=="boolean")return null;return KQ.ended}function tq(s,KQ){if(!K(s))return null;const a=s._readableState;if(a!==null&&a!==void 0&&a.errored)return!1;if(typeof(a===null||a===void 0?void 0:a.endEmitted)!=="boolean")return null;return!!(a.endEmitted||KQ===!1&&a.ended===!0&&a.length===0)}function c(s){if(s&&s[Q]!=null)return s[Q];if(typeof(s===null||s===void 0?void 0:s.readable)!=="boolean")return null;if(aq(s))return!1;return K(s)&&s.readable&&!tq(s)}function eq(s){if(typeof(s===null||s===void 0?void 0:s.writable)!=="boolean")return null;if(aq(s))return!1;return oq(s)&&s.writable&&!b(s)}function d(s,KQ){if(!sq(s))return null;if(aq(s))return!0;if((KQ===null||KQ===void 0?void 0:KQ.readable)!==!1&&c(s))return!1;if((KQ===null||KQ===void 0?void 0:KQ.writable)!==!1&&eq(s))return!1;return!0}function qQ(s){var KQ,a;if(!sq(s))return null;if(s.writableErrored)return s.writableErrored;return(KQ=(a=s._writableState)===null||a===void 0?void 0:a.errored)!==null&&KQ!==void 0?KQ:null}function l(s){var KQ,a;if(!sq(s))return null;if(s.readableErrored)return s.readableErrored;return(KQ=(a=s._readableState)===null||a===void 0?void 0:a.errored)!==null&&KQ!==void 0?KQ:null}function QQ(s){if(!sq(s))return null;if(typeof s.closed==="boolean")return s.closed;const{_writableState:KQ,_readableState:a}=s;if(typeof(KQ===null||KQ===void 0?void 0:KQ.closed)==="boolean"||typeof(a===null||a===void 0?void 0:a.closed)==="boolean")return(KQ===null||KQ===void 0?void 0:KQ.closed)||(a===null||a===void 0?void 0:a.closed);if(typeof s._closed==="boolean"&&i(s))return s._closed;return null}function i(s){return typeof s._closed==="boolean"&&typeof s._defaultKeepAlive==="boolean"&&typeof s._removedConnection==="boolean"&&typeof s._removedContLen==="boolean"}function XQ(s){return typeof s._sent100==="boolean"&&i(s)}function n(s){var KQ;return typeof s._consuming==="boolean"&&typeof s._dumped==="boolean"&&((KQ=s.req)===null||KQ===void 0?void 0:KQ.upgradeOrConnect)===void 0}function JQ(s){if(!sq(s))return null;const{_writableState:KQ,_readableState:a}=s,ZQ=KQ||a;return!ZQ&&XQ(s)||!!(ZQ&&ZQ.autoDestroy&&ZQ.emitClose&&ZQ.closed===!1)}function o(s){var KQ;return!!(s&&((KQ=s[Z])!==null&&KQ!==void 0?KQ:s.readableDidRead||s.readableAborted))}function HQ(s){var KQ,a,ZQ,r,BQ,$,YQ,z,$Q,t;return!!(s&&((KQ=(a=(ZQ=(r=(BQ=($=s[J])!==null&&$!==void 0?$:s.readableErrored)!==null&&BQ!==void 0?BQ:s.writableErrored)!==null&&r!==void 0?r:(YQ=s._readableState)===null||YQ===void 0?void 0:YQ.errorEmitted)!==null&&ZQ!==void 0?ZQ:(z=s._writableState)===null||z===void 0?void 0:z.errorEmitted)!==null&&a!==void 0?a:($Q=s._readableState)===null||$Q===void 0?void 0:$Q.errored)!==null&&KQ!==void 0?KQ:(t=s._writableState)===null||t===void 0?void 0:t.errored))}Y.exports={kDestroyed:q,isDisturbed:o,kIsDisturbed:Z,isErrored:HQ,kIsErrored:J,isReadable:c,kIsReadable:Q,isClosed:QQ,isDestroyed:aq,isDuplexNodeStream:p,isFinished:d,isIterable:u,isReadableNodeStream:K,isReadableEnded:m,isReadableFinished:tq,isReadableErrored:l,isNodeStream:sq,isWritable:eq,isWritableNodeStream:oq,isWritableEnded:b,isWritableFinished:rq,isWritableErrored:qQ,isServerRequest:n,isServerResponse:XQ,willEmitClose:JQ}}}),N=G({"node_modules/readable-stream/lib/internal/streams/end-of-stream.js"(B,Y){var{AbortError:U,codes:H}=hQ(),{ERR_INVALID_ARG_TYPE:X,ERR_STREAM_PREMATURE_CLOSE:q}=H,{once:J}=jq(),{validateAbortSignal:Q,validateFunction:Z,validateObject:K}=L(),{Promise:oq}=DQ(),{isClosed:p,isReadable:sq,isReadableNodeStream:u,isReadableFinished:aq,isReadableErrored:b,isWritable:rq,isWritableNodeStream:m,isWritableFinished:tq,isWritableErrored:c,isNodeStream:eq,willEmitClose:d}=j();function qQ(XQ){return XQ.setHeader&&typeof XQ.abort==="function"}var l=()=>{};function QQ(XQ,n,JQ){var o,HQ;if(arguments.length===2)JQ=n,n={};else if(n==null)n={};else K(n,"options");Z(JQ,"callback"),Q(n.signal,"options.signal"),JQ=J(JQ);const s=(o=n.readable)!==null&&o!==void 0?o:u(XQ),KQ=(HQ=n.writable)!==null&&HQ!==void 0?HQ:m(XQ);if(!eq(XQ))throw new X("stream","Stream",XQ);const{_writableState:a,_readableState:ZQ}=XQ,r=()=>{if(!XQ.writable)YQ()};let BQ=d(XQ)&&u(XQ)===s&&m(XQ)===KQ,$=tq(XQ,!1);const YQ=()=>{if($=!0,XQ.destroyed)BQ=!1;if(BQ&&(!XQ.readable||s))return;if(!s||z)JQ.call(XQ)};let z=aq(XQ,!1);const $Q=()=>{if(z=!0,XQ.destroyed)BQ=!1;if(BQ&&(!XQ.writable||KQ))return;if(!KQ||$)JQ.call(XQ)},t=(UQ)=>{JQ.call(XQ,UQ)};let zQ=p(XQ);const e=()=>{zQ=!0;const UQ=c(XQ)||b(XQ);if(UQ&&typeof UQ!=="boolean")return JQ.call(XQ,UQ);if(s&&!z&&u(XQ,!0)){if(!aq(XQ,!1))return JQ.call(XQ,new q)}if(KQ&&!$){if(!tq(XQ,!1))return JQ.call(XQ,new q)}JQ.call(XQ)},VQ=()=>{XQ.req.on("finish",YQ)};if(qQ(XQ)){if(XQ.on("complete",YQ),!BQ)XQ.on("abort",e);if(XQ.req)VQ();else XQ.on("request",VQ)}else if(KQ&&!a)XQ.on("end",r),XQ.on("close",r);if(!BQ&&typeof XQ.aborted==="boolean")XQ.on("aborted",e);if(XQ.on("end",$Q),XQ.on("finish",YQ),n.error!==!1)XQ.on("error",t);if(XQ.on("close",e),zQ)_Q(e);else if(a!==null&&a!==void 0&&a.errorEmitted||ZQ!==null&&ZQ!==void 0&&ZQ.errorEmitted){if(!BQ)_Q(e)}else if(!s&&(!BQ||sq(XQ))&&($||rq(XQ)===!1))_Q(e);else if(!KQ&&(!BQ||rq(XQ))&&(z||sq(XQ)===!1))_Q(e);else if(ZQ&&XQ.req&&XQ.aborted)_Q(e);const qq=()=>{if(JQ=l,XQ.removeListener("aborted",e),XQ.removeListener("complete",YQ),XQ.removeListener("abort",e),XQ.removeListener("request",VQ),XQ.req)XQ.req.removeListener("finish",YQ);XQ.removeListener("end",r),XQ.removeListener("close",r),XQ.removeListener("finish",YQ),XQ.removeListener("end",$Q),XQ.removeListener("error",t),XQ.removeListener("close",e)};if(n.signal&&!zQ){const UQ=()=>{const Qq=JQ;qq(),Qq.call(XQ,new U(void 0,{cause:n.signal.reason}))};if(n.signal.aborted)_Q(UQ);else{const Qq=JQ;JQ=J((...WQ)=>{n.signal.removeEventListener("abort",UQ),Qq.apply(XQ,WQ)}),n.signal.addEventListener("abort",UQ)}}return qq}function i(XQ,n){return new oq((JQ,o)=>{QQ(XQ,n,(HQ)=>{if(HQ)o(HQ);else JQ()})})}Y.exports=QQ,Y.exports.finished=i}}),A=G({"node_modules/readable-stream/lib/internal/streams/operators.js"(B,Y){var{codes:{ERR_INVALID_ARG_TYPE:U,ERR_MISSING_ARGS:H,ERR_OUT_OF_RANGE:X},AbortError:q}=hQ(),{validateAbortSignal:J,validateInteger:Q,validateObject:Z}=L(),K=DQ().Symbol("kWeak"),{finished:oq}=N(),{ArrayPrototypePush:p,MathFloor:sq,Number:u,NumberIsNaN:aq,Promise:b,PromiseReject:rq,PromisePrototypeCatch:m,Symbol:tq}=DQ(),c=tq("kEmpty"),eq=tq("kEof");function d(r,BQ){if(typeof r!=="function")throw new U("fn",["Function","AsyncFunction"],r);if(BQ!=null)Z(BQ,"options");if((BQ===null||BQ===void 0?void 0:BQ.signal)!=null)J(BQ.signal,"options.signal");let $=1;if((BQ===null||BQ===void 0?void 0:BQ.concurrency)!=null)$=sq(BQ.concurrency);return Q($,"concurrency",1),async function*YQ(){var z,$Q;const t=new AbortController,zQ=this,e=[],VQ=t.signal,qq={signal:VQ},UQ=()=>t.abort();if(BQ!==null&&BQ!==void 0&&(z=BQ.signal)!==null&&z!==void 0&&z.aborted)UQ();BQ===null||BQ===void 0||($Q=BQ.signal)===null||$Q===void 0||$Q.addEventListener("abort",UQ);let Qq,WQ,Xq=!1;function GQ(){Xq=!0}async function Jq(){try{for await(let FQ of zQ){var MQ;if(Xq)return;if(VQ.aborted)throw new q;try{FQ=r(FQ,qq)}catch(Kq){FQ=rq(Kq)}if(FQ===c)continue;if(typeof((MQ=FQ)===null||MQ===void 0?void 0:MQ.catch)==="function")FQ.catch(GQ);if(e.push(FQ),Qq)Qq(),Qq=null;if(!Xq&&e.length&&e.length>=$)await new b((Kq)=>{WQ=Kq})}e.push(eq)}catch(FQ){const Kq=rq(FQ);m(Kq,GQ),e.push(Kq)}finally{var Hq;if(Xq=!0,Qq)Qq(),Qq=null;BQ===null||BQ===void 0||(Hq=BQ.signal)===null||Hq===void 0||Hq.removeEventListener("abort",UQ)}}Jq();try{while(!0){while(e.length>0){const MQ=await e[0];if(MQ===eq)return;if(VQ.aborted)throw new q;if(MQ!==c)yield MQ;if(e.shift(),WQ)WQ(),WQ=null}await new b((MQ)=>{Qq=MQ})}}finally{if(t.abort(),Xq=!0,WQ)WQ(),WQ=null}}.call(this)}function qQ(r=void 0){if(r!=null)Z(r,"options");if((r===null||r===void 0?void 0:r.signal)!=null)J(r.signal,"options.signal");return async function*BQ(){let $=0;for await(let z of this){var YQ;if(r!==null&&r!==void 0&&(YQ=r.signal)!==null&&YQ!==void 0&&YQ.aborted)throw new q({cause:r.signal.reason});yield[$++,z]}}.call(this)}async function l(r,BQ=void 0){for await(let $ of n.call(this,r,BQ))return!0;return!1}async function QQ(r,BQ=void 0){if(typeof r!=="function")throw new U("fn",["Function","AsyncFunction"],r);return!await l.call(this,async(...$)=>{return!await r(...$)},BQ)}async function i(r,BQ){for await(let $ of n.call(this,r,BQ))return $;return}async function XQ(r,BQ){if(typeof r!=="function")throw new U("fn",["Function","AsyncFunction"],r);async function $(YQ,z){return await r(YQ,z),c}for await(let YQ of d.call(this,$,BQ));}function n(r,BQ){if(typeof r!=="function")throw new U("fn",["Function","AsyncFunction"],r);async function $(YQ,z){if(await r(YQ,z))return YQ;return c}return d.call(this,$,BQ)}var JQ=class extends H{constructor(){super("reduce");this.message="Reduce of an empty stream requires an initial value"}};async function o(r,BQ,$){var YQ;if(typeof r!=="function")throw new U("reducer",["Function","AsyncFunction"],r);if($!=null)Z($,"options");if(($===null||$===void 0?void 0:$.signal)!=null)J($.signal,"options.signal");let z=arguments.length>1;if($!==null&&$!==void 0&&(YQ=$.signal)!==null&&YQ!==void 0&&YQ.aborted){const VQ=new q(void 0,{cause:$.signal.reason});throw this.once("error",()=>{}),await oq(this.destroy(VQ)),VQ}const $Q=new AbortController,t=$Q.signal;if($!==null&&$!==void 0&&$.signal){const VQ={once:!0,[K]:this};$.signal.addEventListener("abort",()=>$Q.abort(),VQ)}let zQ=!1;try{for await(let VQ of this){var e;if(zQ=!0,$!==null&&$!==void 0&&(e=$.signal)!==null&&e!==void 0&&e.aborted)throw new q;if(!z)BQ=VQ,z=!0;else BQ=await r(BQ,VQ,{signal:t})}if(!zQ&&!z)throw new JQ}finally{$Q.abort()}return BQ}async function HQ(r){if(r!=null)Z(r,"options");if((r===null||r===void 0?void 0:r.signal)!=null)J(r.signal,"options.signal");const BQ=[];for await(let YQ of this){var $;if(r!==null&&r!==void 0&&($=r.signal)!==null&&$!==void 0&&$.aborted)throw new q(void 0,{cause:r.signal.reason});p(BQ,YQ)}return BQ}function s(r,BQ){const $=d.call(this,r,BQ);return async function*YQ(){for await(let z of $)yield*z}.call(this)}function KQ(r){if(r=u(r),aq(r))return 0;if(r<0)throw new X("number",">= 0",r);return r}function a(r,BQ=void 0){if(BQ!=null)Z(BQ,"options");if((BQ===null||BQ===void 0?void 0:BQ.signal)!=null)J(BQ.signal,"options.signal");return r=KQ(r),async function*$(){var YQ;if(BQ!==null&&BQ!==void 0&&(YQ=BQ.signal)!==null&&YQ!==void 0&&YQ.aborted)throw new q;for await(let $Q of this){var z;if(BQ!==null&&BQ!==void 0&&(z=BQ.signal)!==null&&z!==void 0&&z.aborted)throw new q;if(r--<=0)yield $Q}}.call(this)}function ZQ(r,BQ=void 0){if(BQ!=null)Z(BQ,"options");if((BQ===null||BQ===void 0?void 0:BQ.signal)!=null)J(BQ.signal,"options.signal");return r=KQ(r),async function*$(){var YQ;if(BQ!==null&&BQ!==void 0&&(YQ=BQ.signal)!==null&&YQ!==void 0&&YQ.aborted)throw new q;for await(let $Q of this){var z;if(BQ!==null&&BQ!==void 0&&(z=BQ.signal)!==null&&z!==void 0&&z.aborted)throw new q;if(r-- >0)yield $Q;else return}}.call(this)}Y.exports.streamReturningOperators={asIndexedPairs:qQ,drop:a,filter:n,flatMap:s,map:d,take:ZQ},Y.exports.promiseReturningOperators={every:QQ,forEach:XQ,reduce:o,toArray:HQ,some:l,find:i}}}),Oq=G({"node_modules/readable-stream/lib/internal/streams/destroy.js"(B,Y){var{aggregateTwoErrors:U,codes:{ERR_MULTIPLE_CALLBACK:H},AbortError:X}=hQ(),{Symbol:q}=DQ(),{kDestroyed:J,isDestroyed:Q,isFinished:Z,isServerRequest:K}=j(),oq="#kDestroy",p="#kConstruct";function sq(n,JQ,o){if(n){if(n.stack,JQ&&!JQ.errored)JQ.errored=n;if(o&&!o.errored)o.errored=n}}function u(n,JQ){const o=this._readableState,HQ=this._writableState,s=HQ||o;if(HQ&&HQ.destroyed||o&&o.destroyed){if(typeof JQ==="function")JQ();return this}if(sq(n,HQ,o),HQ)HQ.destroyed=!0;if(o)o.destroyed=!0;if(!s.constructed)this.once(oq,(KQ)=>{aq(this,U(KQ,n),JQ)});else aq(this,n,JQ);return this}function aq(n,JQ,o){let HQ=!1;function s(KQ){if(HQ)return;HQ=!0;const{_readableState:a,_writableState:ZQ}=n;if(sq(KQ,ZQ,a),ZQ)ZQ.closed=!0;if(a)a.closed=!0;if(typeof o==="function")o(KQ);if(KQ)_Q(b,n,KQ);else _Q(rq,n)}try{n._destroy(JQ||null,s)}catch(KQ){s(KQ)}}function b(n,JQ){m(n,JQ),rq(n)}function rq(n){const{_readableState:JQ,_writableState:o}=n;if(o)o.closeEmitted=!0;if(JQ)JQ.closeEmitted=!0;if(o&&o.emitClose||JQ&&JQ.emitClose)n.emit("close")}function m(n,JQ){const o=n?._readableState,HQ=n?._writableState;if(HQ?.errorEmitted||o?.errorEmitted)return;if(HQ)HQ.errorEmitted=!0;if(o)o.errorEmitted=!0;n?.emit?.("error",JQ)}function tq(){const n=this._readableState,JQ=this._writableState;if(n)n.constructed=!0,n.closed=!1,n.closeEmitted=!1,n.destroyed=!1,n.errored=null,n.errorEmitted=!1,n.reading=!1,n.ended=n.readable===!1,n.endEmitted=n.readable===!1;if(JQ)JQ.constructed=!0,JQ.destroyed=!1,JQ.closed=!1,JQ.closeEmitted=!1,JQ.errored=null,JQ.errorEmitted=!1,JQ.finalCalled=!1,JQ.prefinished=!1,JQ.ended=JQ.writable===!1,JQ.ending=JQ.writable===!1,JQ.finished=JQ.writable===!1}function c(n,JQ,o){const HQ=n?._readableState,s=n?._writableState;if(s&&s.destroyed||HQ&&HQ.destroyed)return this;if(HQ&&HQ.autoDestroy||s&&s.autoDestroy)n.destroy(JQ);else if(JQ){if(Error.captureStackTrace(JQ),s&&!s.errored)s.errored=JQ;if(HQ&&!HQ.errored)HQ.errored=JQ;if(o)_Q(m,n,JQ);else m(n,JQ)}}function eq(n,JQ){if(typeof n._construct!=="function")return;const{_readableState:o,_writableState:HQ}=n;if(o)o.constructed=!1;if(HQ)HQ.constructed=!1;if(n.once(p,JQ),n.listenerCount(p)>1)return;_Q(d,n)}function d(n){let JQ=!1;function o(HQ){if(JQ){c(n,HQ!==null&&HQ!==void 0?HQ:new H);return}JQ=!0;const{_readableState:s,_writableState:KQ}=n,a=KQ||s;if(s)s.constructed=!0;if(KQ)KQ.constructed=!0;if(a.destroyed)n.emit(oq,HQ);else if(HQ)c(n,HQ,!0);else _Q(qQ,n)}try{n._construct(o)}catch(HQ){o(HQ)}}function qQ(n){n.emit(p)}function l(n){return n&&n.setHeader&&typeof n.abort==="function"}function QQ(n){n.emit("close")}function i(n,JQ){n.emit("error",JQ),_Q(QQ,n)}function XQ(n,JQ){if(!n||Q(n))return;if(!JQ&&!Z(n))JQ=new X;if(K(n))n.socket=null,n.destroy(JQ);else if(l(n))n.abort();else if(l(n.req))n.req.abort();else if(typeof n.destroy==="function")n.destroy(JQ);else if(typeof n.close==="function")n.close();else if(JQ)_Q(i,n);else _Q(QQ,n);if(!n.destroyed)n[J]=!0}Y.exports={construct:eq,destroyer:XQ,destroy:u,undestroy:tq,errorOrDestroy:c}}}),pQ=G({"node_modules/readable-stream/lib/internal/streams/legacy.js"(B,Y){var{ArrayIsArray:U,ObjectSetPrototypeOf:H}=DQ();function X(J){if(!(this instanceof X))return new X(J);CQ.call(this,J)}H(X.prototype,CQ.prototype),H(X,CQ),X.prototype.pipe=function(J,Q){const Z=this;function K(rq){if(J.writable&&J.write(rq)===!1&&Z.pause)Z.pause()}Z.on("data",K);function oq(){if(Z.readable&&Z.resume)Z.resume()}if(J.on("drain",oq),!J._isStdio&&(!Q||Q.end!==!1))Z.on("end",sq),Z.on("close",u);let p=!1;function sq(){if(p)return;p=!0,J.end()}function u(){if(p)return;if(p=!0,typeof J.destroy==="function")J.destroy()}function aq(rq){if(b(),CQ.listenerCount(this,"error")===0)this.emit("error",rq)}q(Z,"error",aq),q(J,"error",aq);function b(){Z.removeListener("data",K),J.removeListener("drain",oq),Z.removeListener("end",sq),Z.removeListener("close",u),Z.removeListener("error",aq),J.removeListener("error",aq),Z.removeListener("end",b),Z.removeListener("close",b),J.removeListener("close",b)}return Z.on("end",b),Z.on("close",b),J.on("close",b),J.emit("pipe",Z),J};function q(J,Q,Z){if(typeof J.prependListener==="function")return J.prependListener(Q,Z);if(!J._events||!J._events[Q])J.on(Q,Z);else if(U(J._events[Q]))J._events[Q].unshift(Z);else J._events[Q]=[Z,J._events[Q]]}Y.exports={Stream:X,prependListener:q}}}),_q=G({"node_modules/readable-stream/lib/internal/streams/add-abort-signal.js"(B,Y){var{AbortError:U,codes:H}=hQ(),X=N(),{ERR_INVALID_ARG_TYPE:q}=H,J=(Z,K)=>{if(typeof Z!=="object"||!("aborted"in Z))throw new q(K,"AbortSignal",Z)};function Q(Z){return!!(Z&&typeof Z.pipe==="function")}Y.exports.addAbortSignal=function Z(K,oq){if(J(K,"signal"),!Q(oq))throw new q("stream","stream.Stream",oq);return Y.exports.addAbortSignalNoValidate(K,oq)},Y.exports.addAbortSignalNoValidate=function(Z,K){if(typeof Z!=="object"||!("aborted"in Z))return K;const oq=()=>{K.destroy(new U(void 0,{cause:Z.reason}))};if(Z.aborted)oq();else Z.addEventListener("abort",oq),X(K,()=>Z.removeEventListener("abort",oq));return K}}}),uQ=G({"node_modules/readable-stream/lib/internal/streams/state.js"(B,Y){var{MathFloor:U,NumberIsInteger:H}=DQ(),{ERR_INVALID_ARG_VALUE:X}=hQ().codes;function q(Z,K,oq){return Z.highWaterMark!=null?Z.highWaterMark:K?Z[oq]:null}function J(Z){return Z?16:16384}function Q(Z,K,oq,p){const sq=q(K,p,oq);if(sq!=null){if(!H(sq)||sq<0){const u=p?`options.${oq}`:"options.highWaterMark";throw new X(u,sq)}return U(sq)}return J(Z.objectMode)}Y.exports={getHighWaterMark:Q,getDefaultHighWaterMark:J}}}),Cq=G({"node_modules/readable-stream/lib/internal/streams/from.js"(B,Y){var{PromisePrototypeThen:U,SymbolAsyncIterator:H,SymbolIterator:X}=DQ(),{ERR_INVALID_ARG_TYPE:q,ERR_STREAM_NULL_VALUES:J}=hQ().codes;function Q(Z,K,oq){let p;if(typeof K==="string"||K instanceof Buffer)return new Z({objectMode:!0,...oq,read(){this.push(K),this.push(null)}});let sq;if(K&&K[H])sq=!0,p=K[H]();else if(K&&K[X])sq=!1,p=K[X]();else throw new q("iterable",["Iterable"],K);const u=new Z({objectMode:!0,highWaterMark:1,...oq});let aq=!1;u._read=function(){if(!aq)aq=!0,rq()},u._destroy=function(m,tq){U(b(m),()=>_Q(tq,m),(c)=>_Q(tq,c||m))};async function b(m){const tq=m!==void 0&&m!==null,c=typeof p.throw==="function";if(tq&&c){const{value:eq,done:d}=await p.throw(m);if(await eq,d)return}if(typeof p.return==="function"){const{value:eq}=await p.return();await eq}}async function rq(){for(;;){try{const{value:m,done:tq}=sq?await p.next():p.next();if(tq)u.push(null);else{const c=m&&typeof m.then==="function"?await m:m;if(c===null)throw aq=!1,new J;else if(u.push(c))continue;else aq=!1}}catch(m){u.destroy(m)}break}}return u}Y.exports=Q}}),bQ,Dq,mQ=G({"node_modules/readable-stream/lib/internal/streams/readable.js"(B,Y){var{ArrayPrototypeIndexOf:U,NumberIsInteger:H,NumberIsNaN:X,NumberParseInt:q,ObjectDefineProperties:J,ObjectKeys:Q,ObjectSetPrototypeOf:Z,Promise:K,SafeSet:oq,SymbolAsyncIterator:p,Symbol:sq}=DQ(),u=globalThis[Symbol.for("Bun.lazy")]("bun:stream").ReadableState,{Stream:aq,prependListener:b}=pQ();function rq(FQ){if(!(this instanceof rq))return new rq(FQ);const Kq=this instanceof wQ();if(this._readableState=new u(FQ,this,Kq),FQ){const{read:LQ,destroy:Zq,construct:jQ,signal:Bq}=FQ;if(typeof LQ==="function")this._read=LQ;if(typeof Zq==="function")this._destroy=Zq;if(typeof jQ==="function")this._construct=jQ;if(Bq&&!Kq)c(Bq,this)}aq.call(this,FQ),n.construct(this,()=>{if(this._readableState.needReadable)i(this,this._readableState)})}Z(rq.prototype,aq.prototype),Z(rq,aq),rq.prototype.on=function(FQ,Kq){const LQ=aq.prototype.on.call(this,FQ,Kq),Zq=this._readableState;if(FQ==="data")if(Zq.readableListening=this.listenerCount("readable")>0,Zq.flowing!==!1)OQ&&Gq("in flowing mode!",this.__id),this.resume();else OQ&&Gq("in readable mode!",this.__id);else if(FQ==="readable"){if(OQ&&Gq("readable listener added!",this.__id),!Zq.endEmitted&&!Zq.readableListening){if(Zq.readableListening=Zq.needReadable=!0,Zq.flowing=!1,Zq.emittedReadable=!1,OQ&&Gq("on readable - state.length, reading, emittedReadable",Zq.length,Zq.reading,Zq.emittedReadable,this.__id),Zq.length)XQ(this,Zq);else if(!Zq.reading)_Q(qq,this)}else if(Zq.endEmitted)OQ&&Gq("end already emitted...",this.__id)}return LQ};class m extends rq{#q;#Q;#X;#J;constructor(FQ,Kq){const{objectMode:LQ,highWaterMark:Zq,encoding:jQ,signal:Bq}=FQ;super({objectMode:LQ,highWaterMark:Zq,encoding:jQ,signal:Bq});this.#X=[],this.#q=void 0,this.#J=Kq,this.#Q=!1}#H(){var FQ=this.#X,Kq=0,LQ=FQ.length;for(;Kq<LQ;Kq++){const Zq=FQ[Kq];if(FQ[Kq]=void 0,!this.push(Zq,void 0))return this.#X=FQ.slice(Kq+1),!0}if(LQ>0)this.#X=[];return!1}#K(FQ){FQ.releaseLock(),this.#q=void 0,this.#Q=!0,this.push(null);return}async _read(){OQ&&Gq("ReadableFromWeb _read()",this.__id);var FQ=this.#J,Kq=this.#q;if(FQ)Kq=this.#q=FQ.getReader(),this.#J=void 0;else if(this.#H())return;var LQ;try{do{var Zq=!1,jQ;const Bq=Kq.readMany();if(Lq(Bq)){if({done:Zq,value:jQ}=await Bq,this.#Q){this.#X.push(...jQ);return}}else({done:Zq,value:jQ}=Bq);if(Zq){this.#K(Kq);return}if(!this.push(jQ[0])){this.#X=jQ.slice(1);return}for(let NQ=1,Yq=jQ.length;NQ<Yq;NQ++)if(!this.push(jQ[NQ])){this.#X=jQ.slice(NQ+1);return}}while(!this.#Q)}catch(Bq){LQ=Bq}finally{if(LQ)throw LQ}}_destroy(FQ,Kq){if(!this.#Q){var LQ=this.#q;if(LQ)this.#q=void 0,LQ.cancel(FQ).finally(()=>{this.#Q=!0,Kq(FQ)});return}try{Kq(FQ)}catch(Zq){globalThis.reportError(Zq)}}}Dq=m;function tq(FQ,Kq={}){if(!M(FQ))throw new o("readableStream","ReadableStream",FQ);ZQ(Kq,"options");const{highWaterMark:LQ,encoding:Zq,objectMode:jQ=!1,signal:Bq}=Kq;if(Zq!==void 0&&!Buffer.isEncoding(Zq))throw new xq(Zq,"options.encoding");return F(jQ,"options.objectMode"),_(rq,FQ,Kq)||new m({highWaterMark:LQ,encoding:Zq,objectMode:jQ,signal:Bq},FQ)}Y.exports=rq,bQ=tq;var{addAbortSignal:c}=_q(),eq=N();const{maybeReadMore:d,resume:qQ,emitReadable:l,onEofChunk:QQ}=globalThis[Symbol.for("Bun.lazy")]("bun:stream");function i(FQ,Kq){process.nextTick(d,FQ,Kq)}function XQ(FQ,Kq){OQ&&Gq("NativeReadable - emitReadable",FQ.__id),l(FQ,Kq)}var n=Oq(),{aggregateTwoErrors:JQ,codes:{ERR_INVALID_ARG_TYPE:o,ERR_METHOD_NOT_IMPLEMENTED:HQ,ERR_OUT_OF_RANGE:s,ERR_STREAM_PUSH_AFTER_EOF:KQ,ERR_STREAM_UNSHIFT_AFTER_END_EVENT:a}}=hQ(),{validateObject:ZQ}=L(),r=Cq(),BQ=()=>{},{errorOrDestroy:$}=n;rq.prototype.destroy=n.destroy,rq.prototype._undestroy=n.undestroy,rq.prototype._destroy=function(FQ,Kq){Kq(FQ)},rq.prototype[CQ.captureRejectionSymbol]=function(FQ){this.destroy(FQ)},rq.prototype.push=function(FQ,Kq){return YQ(this,FQ,Kq,!1)},rq.prototype.unshift=function(FQ,Kq){return YQ(this,FQ,Kq,!0)};function YQ(FQ,Kq,LQ,Zq){OQ&&Gq("readableAddChunk",Kq,FQ.__id);const jQ=FQ._readableState;let Bq;if(!jQ.objectMode){if(typeof Kq==="string"){if(LQ=LQ||jQ.defaultEncoding,jQ.encoding!==LQ)if(Zq&&jQ.encoding)Kq=Buffer.from(Kq,LQ).toString(jQ.encoding);else Kq=Buffer.from(Kq,LQ),LQ=""}else if(Kq instanceof Buffer)LQ="";else if(aq._isUint8Array(Kq)){if(Zq||!jQ.decoder)Kq=aq._uint8ArrayToBuffer(Kq);LQ=""}else if(Kq!=null)Bq=new o("chunk",["string","Buffer","Uint8Array"],Kq)}if(Bq)$(FQ,Bq);else if(Kq===null)jQ.reading=!1,QQ(FQ,jQ);else if(jQ.objectMode||Kq&&Kq.length>0)if(Zq)if(jQ.endEmitted)$(FQ,new a);else if(jQ.destroyed||jQ.errored)return!1;else z(FQ,jQ,Kq,!0);else if(jQ.ended)$(FQ,new KQ);else if(jQ.destroyed||jQ.errored)return!1;else if(jQ.reading=!1,jQ.decoder&&!LQ)if(Kq=jQ.decoder.write(Kq),jQ.objectMode||Kq.length!==0)z(FQ,jQ,Kq,!1);else i(FQ,jQ);else z(FQ,jQ,Kq,!1);else if(!Zq)jQ.reading=!1,i(FQ,jQ);return!jQ.ended&&(jQ.length<jQ.highWaterMark||jQ.length===0)}function z(FQ,Kq,LQ,Zq){if(OQ&&Gq("adding chunk",FQ.__id),OQ&&Gq("chunk",LQ.toString(),FQ.__id),Kq.flowing&&Kq.length===0&&!Kq.sync&&FQ.listenerCount("data")>0){if(Kq.multiAwaitDrain)Kq.awaitDrainWriters.clear();else Kq.awaitDrainWriters=null;Kq.dataEmitted=!0,FQ.emit("data",LQ)}else{if(Kq.length+=Kq.objectMode?1:LQ.length,Zq)Kq.buffer.unshift(LQ);else Kq.buffer.push(LQ);if(OQ&&Gq("needReadable @ addChunk",Kq.needReadable,FQ.__id),Kq.needReadable)XQ(FQ,Kq)}i(FQ,Kq)}rq.prototype.isPaused=function(){const FQ=this._readableState;return FQ.paused===!0||FQ.flowing===!1},rq.prototype.setEncoding=function(FQ){const Kq=new Eq(FQ);this._readableState.decoder=Kq,this._readableState.encoding=this._readableState.decoder.encoding;const LQ=this._readableState.buffer;let Zq="";for(let jQ=LQ.length;jQ>0;jQ--)Zq+=Kq.write(LQ.shift());if(Zq!=="")LQ.push(Zq);return this._readableState.length=Zq.length,this};var $Q=1073741824;function t(FQ){if(FQ>$Q)throw new s("size","<= 1GiB",FQ);else FQ--,FQ|=FQ>>>1,FQ|=FQ>>>2,FQ|=FQ>>>4,FQ|=FQ>>>8,FQ|=FQ>>>16,FQ++;return FQ}function zQ(FQ,Kq){if(FQ<=0||Kq.length===0&&Kq.ended)return 0;if(Kq.objectMode)return 1;if(X(FQ)){if(Kq.flowing&&Kq.length)return Kq.buffer.first().length;return Kq.length}if(FQ<=Kq.length)return FQ;return Kq.ended?Kq.length:0}rq.prototype.read=function(FQ){if(OQ&&Gq("read - n =",FQ,this.__id),!H(FQ))FQ=q(FQ,10);const Kq=this._readableState,LQ=FQ;if(FQ>Kq.highWaterMark)Kq.highWaterMark=t(FQ);if(FQ!==0)Kq.emittedReadable=!1;if(FQ===0&&Kq.needReadable&&((Kq.highWaterMark!==0?Kq.length>=Kq.highWaterMark:Kq.length>0)||Kq.ended)){if(OQ&&Gq("read: emitReadable or endReadable",Kq.length,Kq.ended,this.__id),Kq.length===0&&Kq.ended)Xq(this);else XQ(this,Kq);return null}if(FQ=zQ(FQ,Kq),FQ===0&&Kq.ended){if(OQ&&Gq("read: calling endReadable if length 0 -- length, state.ended",Kq.length,Kq.ended,this.__id),Kq.length===0)Xq(this);return null}let Zq=Kq.needReadable;if(OQ&&Gq("need readable",Zq,this.__id),Kq.length===0||Kq.length-FQ<Kq.highWaterMark)Zq=!0,OQ&&Gq("length less than watermark",Zq,this.__id);if(Kq.ended||Kq.reading||Kq.destroyed||Kq.errored||!Kq.constructed)OQ&&Gq("state.constructed?",Kq.constructed,this.__id),Zq=!1,OQ&&Gq("reading, ended or constructing",Zq,this.__id);else if(Zq){if(OQ&&Gq("do read",this.__id),Kq.reading=!0,Kq.sync=!0,Kq.length===0)Kq.needReadable=!0;try{var jQ=this._read(Kq.highWaterMark);if(Lq(jQ)){OQ&&Gq("async _read",this.__id);const NQ=Bun.peek(jQ);if(OQ&&Gq("peeked promise",NQ,this.__id),NQ!==jQ)jQ=NQ}if(Lq(jQ)&&jQ?.then&&Nq(jQ.then))OQ&&Gq("async _read result.then setup",this.__id),jQ.then(BQ,function(NQ){$(this,NQ)})}catch(NQ){$(this,NQ)}if(Kq.sync=!1,!Kq.reading)FQ=zQ(LQ,Kq)}OQ&&Gq("n @ fromList",FQ,this.__id);let Bq;if(FQ>0)Bq=WQ(FQ,Kq);else Bq=null;if(OQ&&Gq("ret @ read",Bq,this.__id),Bq===null)Kq.needReadable=Kq.length<=Kq.highWaterMark,OQ&&Gq("state.length while ret = null",Kq.length,this.__id),FQ=0;else if(Kq.length-=FQ,Kq.multiAwaitDrain)Kq.awaitDrainWriters.clear();else Kq.awaitDrainWriters=null;if(Kq.length===0){if(!Kq.ended)Kq.needReadable=!0;if(LQ!==FQ&&Kq.ended)Xq(this)}if(Bq!==null&&!Kq.errorEmitted&&!Kq.closeEmitted)Kq.dataEmitted=!0,this.emit("data",Bq);return Bq},rq.prototype._read=function(FQ){throw new HQ("_read()")},rq.prototype.pipe=function(FQ,Kq){const LQ=this,Zq=this._readableState;if(Zq.pipes.length===1){if(!Zq.multiAwaitDrain)Zq.multiAwaitDrain=!0,Zq.awaitDrainWriters=new oq(Zq.awaitDrainWriters?[Zq.awaitDrainWriters]:[])}Zq.pipes.push(FQ),OQ&&Gq("pipe count=%d opts=%j",Zq.pipes.length,Kq,LQ.__id);const Bq=(!Kq||Kq.end!==!1)&&FQ!==process.stdout&&FQ!==process.stderr?Yq:PQ;if(Zq.endEmitted)_Q(Bq);else LQ.once("end",Bq);FQ.on("unpipe",NQ);function NQ(Wq,xQ){if(OQ&&Gq("onunpipe",LQ.__id),Wq===LQ){if(xQ&&xQ.hasUnpiped===!1)xQ.hasUnpiped=!0,EQ()}}function Yq(){OQ&&Gq("onend",LQ.__id),FQ.end()}let AQ,$q=!1;function EQ(){if(OQ&&Gq("cleanup",LQ.__id),FQ.removeListener("close",TQ),FQ.removeListener("finish",Uq),AQ)FQ.removeListener("drain",AQ);if(FQ.removeListener("error",Vq),FQ.removeListener("unpipe",NQ),LQ.removeListener("end",Yq),LQ.removeListener("end",PQ),LQ.removeListener("data",IQ),$q=!0,AQ&&Zq.awaitDrainWriters&&(!FQ._writableState||FQ._writableState.needDrain))AQ()}function zq(){if(!$q){if(Zq.pipes.length===1&&Zq.pipes[0]===FQ)OQ&&Gq("false write response, pause",0,LQ.__id),Zq.awaitDrainWriters=FQ,Zq.multiAwaitDrain=!1;else if(Zq.pipes.length>1&&Zq.pipes.includes(FQ))OQ&&Gq("false write response, pause",Zq.awaitDrainWriters.size,LQ.__id),Zq.awaitDrainWriters.add(FQ);LQ.pause()}if(!AQ)AQ=e(LQ,FQ),FQ.on("drain",AQ)}LQ.on("data",IQ);function IQ(Wq){OQ&&Gq("ondata",LQ.__id);const xQ=FQ.write(Wq);if(OQ&&Gq("dest.write",xQ,LQ.__id),xQ===!1)zq()}function Vq(Wq){if(Gq("onerror",Wq),PQ(),FQ.removeListener("error",Vq),FQ.listenerCount("error")===0){const xQ=FQ._writableState||FQ._readableState;if(xQ&&!xQ.errorEmitted)$(FQ,Wq);else FQ.emit("error",Wq)}}b(FQ,"error",Vq);function TQ(){FQ.removeListener("finish",Uq),PQ()}FQ.once("close",TQ);function Uq(){Gq("onfinish"),FQ.removeListener("close",TQ),PQ()}FQ.once("finish",Uq);function PQ(){Gq("unpipe"),LQ.unpipe(FQ)}if(FQ.emit("pipe",LQ),FQ.writableNeedDrain===!0){if(Zq.flowing)zq()}else if(!Zq.flowing)Gq("pipe resume"),LQ.resume();return FQ};function e(FQ,Kq){return function LQ(){const Zq=FQ._readableState;if(Zq.awaitDrainWriters===Kq)Gq("pipeOnDrain",1),Zq.awaitDrainWriters=null;else if(Zq.multiAwaitDrain)Gq("pipeOnDrain",Zq.awaitDrainWriters.size),Zq.awaitDrainWriters.delete(Kq);if((!Zq.awaitDrainWriters||Zq.awaitDrainWriters.size===0)&&FQ.listenerCount("data"))FQ.resume()}}rq.prototype.unpipe=function(FQ){const Kq=this._readableState,LQ={hasUnpiped:!1};if(Kq.pipes.length===0)return this;if(!FQ){const jQ=Kq.pipes;Kq.pipes=[],this.pause();for(let Bq=0;Bq<jQ.length;Bq++)jQ[Bq].emit("unpipe",this,{hasUnpiped:!1});return this}const Zq=U(Kq.pipes,FQ);if(Zq===-1)return this;if(Kq.pipes.splice(Zq,1),Kq.pipes.length===0)this.pause();return FQ.emit("unpipe",this,LQ),this},rq.prototype.addListener=rq.prototype.on,rq.prototype.removeListener=function(FQ,Kq){const LQ=aq.prototype.removeListener.call(this,FQ,Kq);if(FQ==="readable")_Q(VQ,this);return LQ},rq.prototype.off=rq.prototype.removeListener,rq.prototype.removeAllListeners=function(FQ){const Kq=aq.prototype.removeAllListeners.apply(this,arguments);if(FQ==="readable"||FQ===void 0)_Q(VQ,this);return Kq};function VQ(FQ){const Kq=FQ._readableState;if(Kq.readableListening=FQ.listenerCount("readable")>0,Kq.resumeScheduled&&Kq.paused===!1)Kq.flowing=!0;else if(FQ.listenerCount("data")>0)FQ.resume();else if(!Kq.readableListening)Kq.flowing=null}function qq(FQ){OQ&&Gq("on readable nextTick, calling read(0)",FQ.__id),FQ.read(0)}rq.prototype.resume=function(){const FQ=this._readableState;if(!FQ.flowing)OQ&&Gq("resume",this.__id),FQ.flowing=!FQ.readableListening,qQ(this,FQ);return FQ.paused=!1,this},rq.prototype.pause=function(){if(OQ&&Gq("call pause flowing=%j",this._readableState.flowing,this.__id),this._readableState.flowing!==!1)OQ&&Gq("pause",this.__id),this._readableState.flowing=!1,this.emit("pause");return this._readableState.paused=!0,this},rq.prototype.wrap=function(FQ){let Kq=!1;FQ.on("data",(Zq)=>{if(!this.push(Zq)&&FQ.pause)Kq=!0,FQ.pause()}),FQ.on("end",()=>{this.push(null)}),FQ.on("error",(Zq)=>{$(this,Zq)}),FQ.on("close",()=>{this.destroy()}),FQ.on("destroy",()=>{this.destroy()}),this._read=()=>{if(Kq&&FQ.resume)Kq=!1,FQ.resume()};const LQ=Q(FQ);for(let Zq=1;Zq<LQ.length;Zq++){const jQ=LQ[Zq];if(this[jQ]===void 0&&typeof FQ[jQ]==="function")this[jQ]=FQ[jQ].bind(FQ)}return this},rq.prototype[p]=function(){return UQ(this)},rq.prototype.iterator=function(FQ){if(FQ!==void 0)ZQ(FQ,"options");return UQ(this,FQ)};function UQ(FQ,Kq){if(typeof FQ.read!=="function")FQ=rq.wrap(FQ,{objectMode:!0});const LQ=Qq(FQ,Kq);return LQ.stream=FQ,LQ}async function*Qq(FQ,Kq){let LQ=BQ;function Zq(NQ){if(this===FQ)LQ(),LQ=BQ;else LQ=NQ}FQ.on("readable",Zq);let jQ;const Bq=eq(FQ,{writable:!1},(NQ)=>{jQ=NQ?JQ(jQ,NQ):null,LQ(),LQ=BQ});try{while(!0){const NQ=FQ.destroyed?null:FQ.read();if(NQ!==null)yield NQ;else if(jQ)throw jQ;else if(jQ===null)return;else await new K(Zq)}}catch(NQ){throw jQ=JQ(jQ,NQ),jQ}finally{if((jQ||(Kq===null||Kq===void 0?void 0:Kq.destroyOnReturn)!==!1)&&(jQ===void 0||FQ._readableState.autoDestroy))n.destroyer(FQ,null);else FQ.off("readable",Zq),Bq()}}J(rq.prototype,{readable:{get(){const FQ=this._readableState;return!!FQ&&FQ.readable!==!1&&!FQ.destroyed&&!FQ.errorEmitted&&!FQ.endEmitted},set(FQ){if(this._readableState)this._readableState.readable=!!FQ}},readableDidRead:{enumerable:!1,get:function(){return this._readableState.dataEmitted}},readableAborted:{enumerable:!1,get:function(){return!!(this._readableState.readable!==!1&&(this._readableState.destroyed||this._readableState.errored)&&!this._readableState.endEmitted)}},readableHighWaterMark:{enumerable:!1,get:function(){return this._readableState.highWaterMark}},readableBuffer:{enumerable:!1,get:function(){return this._readableState&&this._readableState.buffer}},readableFlowing:{enumerable:!1,get:function(){return this._readableState.flowing},set:function(FQ){if(this._readableState)this._readableState.flowing=FQ}},readableLength:{enumerable:!1,get(){return this._readableState.length}},readableObjectMode:{enumerable:!1,get(){return this._readableState?this._readableState.objectMode:!1}},readableEncoding:{enumerable:!1,get(){return this._readableState?this._readableState.encoding:null}},errored:{enumerable:!1,get(){return this._readableState?this._readableState.errored:null}},closed:{get(){return this._readableState?this._readableState.closed:!1}},destroyed:{enumerable:!1,get(){return this._readableState?this._readableState.destroyed:!1},set(FQ){if(!this._readableState)return;this._readableState.destroyed=FQ}},readableEnded:{enumerable:!1,get(){return this._readableState?this._readableState.endEmitted:!1}}}),rq._fromList=WQ;function WQ(FQ,Kq){if(Kq.length===0)return null;let LQ;if(Kq.objectMode)LQ=Kq.buffer.shift();else if(!FQ||FQ>=Kq.length){if(Kq.decoder)LQ=Kq.buffer.join("");else if(Kq.buffer.length===1)LQ=Kq.buffer.first();else LQ=Kq.buffer.concat(Kq.length);Kq.buffer.clear()}else LQ=Kq.buffer.consume(FQ,Kq.decoder);return LQ}function Xq(FQ){const Kq=FQ._readableState;if(OQ&&Gq("endEmitted @ endReadable",Kq.endEmitted,FQ.__id),!Kq.endEmitted)Kq.ended=!0,_Q(GQ,Kq,FQ)}function GQ(FQ,Kq){if(OQ&&Gq("endReadableNT -- endEmitted, state.length",FQ.endEmitted,FQ.length,Kq.__id),!FQ.errored&&!FQ.closeEmitted&&!FQ.endEmitted&&FQ.length===0){if(FQ.endEmitted=!0,Kq.emit("end"),OQ&&Gq("end emitted @ endReadableNT",Kq.__id),Kq.writable&&Kq.allowHalfOpen===!1)_Q(Jq,Kq);else if(FQ.autoDestroy){const LQ=Kq._writableState;if(!LQ||LQ.autoDestroy&&(LQ.finished||LQ.writable===!1))Kq.destroy()}}}function Jq(FQ){if(FQ.writable&&!FQ.writableEnded&&!FQ.destroyed)FQ.end()}rq.from=function(FQ,Kq){return r(rq,FQ,Kq)};var MQ={newStreamReadableFromReadableStream:tq};function Hq(){if(MQ===void 0)MQ={};return MQ}rq.fromWeb=function(FQ,Kq){return Hq().newStreamReadableFromReadableStream(FQ,Kq)},rq.toWeb=function(FQ){return Hq().newReadableStreamFromStreamReadable(FQ)},rq.wrap=function(FQ,Kq){var LQ,Zq;return new rq({objectMode:(LQ=(Zq=FQ.readableObjectMode)!==null&&Zq!==void 0?Zq:FQ.objectMode)!==null&&LQ!==void 0?LQ:!0,...Kq,destroy(jQ,Bq){n.destroyer(FQ,jQ),Bq(jQ)}}).wrap(FQ)}}}),wq=G({"node_modules/readable-stream/lib/internal/streams/writable.js"(B,Y){var{ArrayPrototypeSlice:U,Error:H,FunctionPrototypeSymbolHasInstance:X,ObjectDefineProperty:q,ObjectDefineProperties:J,ObjectSetPrototypeOf:Q,StringPrototypeToLowerCase:Z,Symbol:K,SymbolHasInstance:oq}=DQ(),p=pQ().Stream,sq=Oq(),{addAbortSignal:u}=_q(),{getHighWaterMark:aq,getDefaultHighWaterMark:b}=uQ(),{ERR_INVALID_ARG_TYPE:rq,ERR_METHOD_NOT_IMPLEMENTED:m,ERR_MULTIPLE_CALLBACK:tq,ERR_STREAM_CANNOT_PIPE:c,ERR_STREAM_DESTROYED:eq,ERR_STREAM_ALREADY_FINISHED:d,ERR_STREAM_NULL_VALUES:qQ,ERR_STREAM_WRITE_AFTER_END:l,ERR_UNKNOWN_ENCODING:QQ}=hQ().codes,{errorOrDestroy:i}=sq;function XQ(WQ={}){const Xq=this instanceof wQ();if(!Xq&&!X(XQ,this))return new XQ(WQ);if(this._writableState=new o(WQ,this,Xq),WQ){if(typeof WQ.write==="function")this._write=WQ.write;if(typeof WQ.writev==="function")this._writev=WQ.writev;if(typeof WQ.destroy==="function")this._destroy=WQ.destroy;if(typeof WQ.final==="function")this._final=WQ.final;if(typeof WQ.construct==="function")this._construct=WQ.construct;if(WQ.signal)u(WQ.signal,this)}p.call(this,WQ),sq.construct(this,()=>{const GQ=this._writableState;if(!GQ.writing)z(this,GQ);e(this,GQ)})}Q(XQ.prototype,p.prototype),Q(XQ,p),Y.exports=XQ;function n(){}var JQ=K("kOnFinished");function o(WQ,Xq,GQ){if(typeof GQ!=="boolean")GQ=Xq instanceof wQ();if(this.objectMode=!!(WQ&&WQ.objectMode),GQ)this.objectMode=this.objectMode||!!(WQ&&WQ.writableObjectMode);this.highWaterMark=WQ?aq(this,WQ,"writableHighWaterMark",GQ):b(!1),this.finalCalled=!1,this.needDrain=!1,this.ending=!1,this.ended=!1,this.finished=!1,this.destroyed=!1;const Jq=!!(WQ&&WQ.decodeStrings===!1);this.decodeStrings=!Jq,this.defaultEncoding=WQ&&WQ.defaultEncoding||"utf8",this.length=0,this.writing=!1,this.corked=0,this.sync=!0,this.bufferProcessing=!1,this.onwrite=r.bind(void 0,Xq),this.writecb=null,this.writelen=0,this.afterWriteTickInfo=null,HQ(this),this.pendingcb=0,this.constructed=!0,this.prefinished=!1,this.errorEmitted=!1,this.emitClose=!WQ||WQ.emitClose!==!1,this.autoDestroy=!WQ||WQ.autoDestroy!==!1,this.errored=null,this.closed=!1,this.closeEmitted=!1,this[JQ]=[]}function HQ(WQ){WQ.buffered=[],WQ.bufferedIndex=0,WQ.allBuffers=!0,WQ.allNoop=!0}o.prototype.getBuffer=function WQ(){return U(this.buffered,this.bufferedIndex)},q(o.prototype,"bufferedRequestCount",{get(){return this.buffered.length-this.bufferedIndex}}),q(XQ,oq,{value:function(WQ){if(X(this,WQ))return!0;if(this!==XQ)return!1;return WQ&&WQ._writableState instanceof o}}),XQ.prototype.pipe=function(){i(this,new c)};function s(WQ,Xq,GQ,Jq){const MQ=WQ._writableState;if(typeof GQ==="function")Jq=GQ,GQ=MQ.defaultEncoding;else{if(!GQ)GQ=MQ.defaultEncoding;else if(GQ!=="buffer"&&!Buffer.isEncoding(GQ))throw new QQ(GQ);if(typeof Jq!=="function")Jq=n}if(Xq===null)throw new qQ;else if(!MQ.objectMode)if(typeof Xq==="string"){if(MQ.decodeStrings!==!1)Xq=Buffer.from(Xq,GQ),GQ="buffer"}else if(Xq instanceof Buffer)GQ="buffer";else if(p._isUint8Array(Xq))Xq=p._uint8ArrayToBuffer(Xq),GQ="buffer";else throw new rq("chunk",["string","Buffer","Uint8Array"],Xq);let Hq;if(MQ.ending)Hq=new l;else if(MQ.destroyed)Hq=new eq("write");if(Hq)return _Q(Jq,Hq),i(WQ,Hq,!0),Hq;return MQ.pendingcb++,KQ(WQ,MQ,Xq,GQ,Jq)}XQ.prototype.write=function(WQ,Xq,GQ){return s(this,WQ,Xq,GQ)===!0},XQ.prototype.cork=function(){this._writableState.corked++},XQ.prototype.uncork=function(){const WQ=this._writableState;if(WQ.corked){if(WQ.corked--,!WQ.writing)z(this,WQ)}},XQ.prototype.setDefaultEncoding=function WQ(Xq){if(typeof Xq==="string")Xq=Z(Xq);if(!Buffer.isEncoding(Xq))throw new QQ(Xq);return this._writableState.defaultEncoding=Xq,this};function KQ(WQ,Xq,GQ,Jq,MQ){const Hq=Xq.objectMode?1:GQ.length;Xq.length+=Hq;const FQ=Xq.length<Xq.highWaterMark;if(!FQ)Xq.needDrain=!0;if(Xq.writing||Xq.corked||Xq.errored||!Xq.constructed){if(Xq.buffered.push({chunk:GQ,encoding:Jq,callback:MQ}),Xq.allBuffers&&Jq!=="buffer")Xq.allBuffers=!1;if(Xq.allNoop&&MQ!==n)Xq.allNoop=!1}else Xq.writelen=Hq,Xq.writecb=MQ,Xq.writing=!0,Xq.sync=!0,WQ._write(GQ,Jq,Xq.onwrite),Xq.sync=!1;return FQ&&!Xq.errored&&!Xq.destroyed}function a(WQ,Xq,GQ,Jq,MQ,Hq,FQ){if(Xq.writelen=Jq,Xq.writecb=FQ,Xq.writing=!0,Xq.sync=!0,Xq.destroyed)Xq.onwrite(new eq("write"));else if(GQ)WQ._writev(MQ,Xq.onwrite);else WQ._write(MQ,Hq,Xq.onwrite);Xq.sync=!1}function ZQ(WQ,Xq,GQ,Jq){--Xq.pendingcb,Jq(GQ),YQ(Xq),i(WQ,GQ)}function r(WQ,Xq){const GQ=WQ._writableState,Jq=GQ.sync,MQ=GQ.writecb;if(typeof MQ!=="function"){i(WQ,new tq);return}if(GQ.writing=!1,GQ.writecb=null,GQ.length-=GQ.writelen,GQ.writelen=0,Xq){if(Error.captureStackTrace(Xq),!GQ.errored)GQ.errored=Xq;if(WQ._readableState&&!WQ._readableState.errored)WQ._readableState.errored=Xq;if(Jq)_Q(ZQ,WQ,GQ,Xq,MQ);else ZQ(WQ,GQ,Xq,MQ)}else{if(GQ.buffered.length>GQ.bufferedIndex)z(WQ,GQ);if(Jq)if(GQ.afterWriteTickInfo!==null&&GQ.afterWriteTickInfo.cb===MQ)GQ.afterWriteTickInfo.count++;else GQ.afterWriteTickInfo={count:1,cb:MQ,stream:WQ,state:GQ},_Q(BQ,GQ.afterWriteTickInfo);else $(WQ,GQ,1,MQ)}}function BQ({stream:WQ,state:Xq,count:GQ,cb:Jq}){return Xq.afterWriteTickInfo=null,$(WQ,Xq,GQ,Jq)}function $(WQ,Xq,GQ,Jq){if(!Xq.ending&&!WQ.destroyed&&Xq.length===0&&Xq.needDrain)Xq.needDrain=!1,WQ.emit("drain");while(GQ-- >0)Xq.pendingcb--,Jq();if(Xq.destroyed)YQ(Xq);e(WQ,Xq)}function YQ(WQ){if(WQ.writing)return;for(let MQ=WQ.bufferedIndex;MQ<WQ.buffered.length;++MQ){var Xq;const{chunk:Hq,callback:FQ}=WQ.buffered[MQ],Kq=WQ.objectMode?1:Hq.length;WQ.length-=Kq,FQ((Xq=WQ.errored)!==null&&Xq!==void 0?Xq:new eq("write"))}const GQ=WQ[JQ].splice(0);for(let MQ=0;MQ<GQ.length;MQ++){var Jq;GQ[MQ]((Jq=WQ.errored)!==null&&Jq!==void 0?Jq:new eq("end"))}HQ(WQ)}function z(WQ,Xq){if(Xq.corked||Xq.bufferProcessing||Xq.destroyed||!Xq.constructed)return;const{buffered:GQ,bufferedIndex:Jq,objectMode:MQ}=Xq,Hq=GQ.length-Jq;if(!Hq)return;let FQ=Jq;if(Xq.bufferProcessing=!0,Hq>1&&WQ._writev){Xq.pendingcb-=Hq-1;const Kq=Xq.allNoop?n:(Zq)=>{for(let jQ=FQ;jQ<GQ.length;++jQ)GQ[jQ].callback(Zq)},LQ=Xq.allNoop&&FQ===0?GQ:U(GQ,FQ);LQ.allBuffers=Xq.allBuffers,a(WQ,Xq,!0,Xq.length,LQ,"",Kq),HQ(Xq)}else{do{const{chunk:Kq,encoding:LQ,callback:Zq}=GQ[FQ];GQ[FQ++]=null;const jQ=MQ?1:Kq.length;a(WQ,Xq,!1,jQ,Kq,LQ,Zq)}while(FQ<GQ.length&&!Xq.writing);if(FQ===GQ.length)HQ(Xq);else if(FQ>256)GQ.splice(0,FQ),Xq.bufferedIndex=0;else Xq.bufferedIndex=FQ}Xq.bufferProcessing=!1}XQ.prototype._write=function(WQ,Xq,GQ){if(this._writev)this._writev([{chunk:WQ,encoding:Xq}],GQ);else throw new m("_write()")},XQ.prototype._writev=null,XQ.prototype.end=function(WQ,Xq,GQ,Jq=!1){const MQ=this._writableState;if(OQ&&Gq("end",MQ,this.__id),typeof WQ==="function")GQ=WQ,WQ=null,Xq=null;else if(typeof Xq==="function")GQ=Xq,Xq=null;let Hq;if(WQ!==null&&WQ!==void 0){let FQ;if(!Jq)FQ=s(this,WQ,Xq);else FQ=this.write(WQ,Xq);if(FQ instanceof H)Hq=FQ}if(MQ.corked)MQ.corked=1,this.uncork();if(Hq)this.emit("error",Hq);else if(!MQ.errored&&!MQ.ending)MQ.ending=!0,e(this,MQ,!0),MQ.ended=!0;else if(MQ.finished)Hq=new d("end");else if(MQ.destroyed)Hq=new eq("end");if(typeof GQ==="function")if(Hq||MQ.finished)_Q(GQ,Hq);else MQ[JQ].push(GQ);return this};function $Q(WQ,Xq){var GQ=WQ.ending&&!WQ.destroyed&&WQ.constructed&&WQ.length===0&&!WQ.errored&&WQ.buffered.length===0&&!WQ.finished&&!WQ.writing&&!WQ.errorEmitted&&!WQ.closeEmitted;return Gq("needFinish",GQ,Xq),GQ}function t(WQ,Xq){let GQ=!1;function Jq(MQ){if(GQ){i(WQ,MQ!==null&&MQ!==void 0?MQ:tq());return}if(GQ=!0,Xq.pendingcb--,MQ){const Hq=Xq[JQ].splice(0);for(let FQ=0;FQ<Hq.length;FQ++)Hq[FQ](MQ);i(WQ,MQ,Xq.sync)}else if($Q(Xq))Xq.prefinished=!0,WQ.emit("prefinish"),Xq.pendingcb++,_Q(VQ,WQ,Xq)}Xq.sync=!0,Xq.pendingcb++;try{WQ._final(Jq)}catch(MQ){Jq(MQ)}Xq.sync=!1}function zQ(WQ,Xq){if(!Xq.prefinished&&!Xq.finalCalled)if(typeof WQ._final==="function"&&!Xq.destroyed)Xq.finalCalled=!0,t(WQ,Xq);else Xq.prefinished=!0,WQ.emit("prefinish")}function e(WQ,Xq,GQ){if(OQ&&Gq("finishMaybe -- state, sync",Xq,GQ,WQ.__id),!$Q(Xq,WQ.__id))return;if(zQ(WQ,Xq),Xq.pendingcb===0){if(GQ)Xq.pendingcb++,_Q((Jq,MQ)=>{if($Q(MQ))VQ(Jq,MQ);else MQ.pendingcb--},WQ,Xq);else if($Q(Xq))Xq.pendingcb++,VQ(WQ,Xq)}}function VQ(WQ,Xq){Xq.pendingcb--,Xq.finished=!0;const GQ=Xq[JQ].splice(0);for(let Jq=0;Jq<GQ.length;Jq++)GQ[Jq]();if(WQ.emit("finish"),Xq.autoDestroy){const Jq=WQ._readableState;if(!Jq||Jq.autoDestroy&&(Jq.endEmitted||Jq.readable===!1))WQ.destroy()}}J(XQ.prototype,{closed:{get(){return this._writableState?this._writableState.closed:!1}},destroyed:{get(){return this._writableState?this._writableState.destroyed:!1},set(WQ){if(this._writableState)this._writableState.destroyed=WQ}},writable:{get(){const WQ=this._writableState;return!!WQ&&WQ.writable!==!1&&!WQ.destroyed&&!WQ.errored&&!WQ.ending&&!WQ.ended},set(WQ){if(this._writableState)this._writableState.writable=!!WQ}},writableFinished:{get(){return this._writableState?this._writableState.finished:!1}},writableObjectMode:{get(){return this._writableState?this._writableState.objectMode:!1}},writableBuffer:{get(){return this._writableState&&this._writableState.getBuffer()}},writableEnded:{get(){return this._writableState?this._writableState.ending:!1}},writableNeedDrain:{get(){const WQ=this._writableState;if(!WQ)return!1;return!WQ.destroyed&&!WQ.ending&&WQ.needDrain}},writableHighWaterMark:{get(){return this._writableState&&this._writableState.highWaterMark}},writableCorked:{get(){return this._writableState?this._writableState.corked:0}},writableLength:{get(){return this._writableState&&this._writableState.length}},errored:{enumerable:!1,get(){return this._writableState?this._writableState.errored:null}},writableAborted:{enumerable:!1,get:function(){return!!(this._writableState.writable!==!1&&(this._writableState.destroyed||this._writableState.errored)&&!this._writableState.finished)}}});var qq=sq.destroy;XQ.prototype.destroy=function(WQ,Xq){const GQ=this._writableState;if(!GQ.destroyed&&(GQ.bufferedIndex<GQ.buffered.length||GQ[JQ].length))_Q(YQ,GQ);return qq.call(this,WQ,Xq),this},XQ.prototype._undestroy=sq.undestroy,XQ.prototype._destroy=function(WQ,Xq){Xq(WQ)},XQ.prototype[CQ.captureRejectionSymbol]=function(WQ){this.destroy(WQ)};var UQ;function Qq(){if(UQ===void 0)UQ={};return UQ}XQ.fromWeb=function(WQ,Xq){return Qq().newStreamWritableFromWritableStream(WQ,Xq)},XQ.toWeb=function(WQ){return Qq().newWritableStreamFromStreamWritable(WQ)}}}),cQ=G({"node_modules/readable-stream/lib/internal/streams/duplexify.js"(B,Y){var{isReadable:U,isWritable:H,isIterable:X,isNodeStream:q,isReadableNodeStream:J,isWritableNodeStream:Q,isDuplexNodeStream:Z}=j(),K=N(),{AbortError:oq,codes:{ERR_INVALID_ARG_TYPE:p,ERR_INVALID_RETURN_VALUE:sq}}=hQ(),{destroyer:u}=Oq(),aq=wQ(),b=mQ(),{createDeferredPromise:rq}=jq(),m=Cq(),tq=typeof Blob!=="undefined"?function l(QQ){return QQ instanceof Blob}:function l(QQ){return!1},{FunctionPrototypeCall:c}=DQ();class eq extends aq{constructor(l){super(l);if((l===null||l===void 0?void 0:l.readable)===!1)this._readableState.readable=!1,this._readableState.ended=!0,this._readableState.endEmitted=!0;if((l===null||l===void 0?void 0:l.writable)===!1)this._writableState.writable=!1,this._writableState.ending=!0,this._writableState.ended=!0,this._writableState.finished=!0}}Y.exports=function l(QQ,i){if(Z(QQ))return QQ;if(J(QQ))return qQ({readable:QQ});if(Q(QQ))return qQ({writable:QQ});if(q(QQ))return qQ({writable:!1,readable:!1});if(typeof QQ==="function"){const{value:n,write:JQ,final:o,destroy:HQ}=d(QQ);if(X(n))return m(eq,n,{objectMode:!0,write:JQ,final:o,destroy:HQ});const s=n===null||n===void 0?void 0:n.then;if(typeof s==="function"){let KQ;const a=c(s,n,(ZQ)=>{if(ZQ!=null)throw new sq("nully","body",ZQ)},(ZQ)=>{u(KQ,ZQ)});return KQ=new eq({objectMode:!0,readable:!1,write:JQ,final(ZQ){o(async()=>{try{await a,_Q(ZQ,null)}catch(r){_Q(ZQ,r)}})},destroy:HQ})}throw new sq("Iterable, AsyncIterable or AsyncFunction",i,n)}if(tq(QQ))return l(QQ.arrayBuffer());if(X(QQ))return m(eq,QQ,{objectMode:!0,writable:!1});if(typeof(QQ===null||QQ===void 0?void 0:QQ.writable)==="object"||typeof(QQ===null||QQ===void 0?void 0:QQ.readable)==="object"){const n=QQ!==null&&QQ!==void 0&&QQ.readable?J(QQ===null||QQ===void 0?void 0:QQ.readable)?QQ===null||QQ===void 0?void 0:QQ.readable:l(QQ.readable):void 0,JQ=QQ!==null&&QQ!==void 0&&QQ.writable?Q(QQ===null||QQ===void 0?void 0:QQ.writable)?QQ===null||QQ===void 0?void 0:QQ.writable:l(QQ.writable):void 0;return qQ({readable:n,writable:JQ})}const XQ=QQ===null||QQ===void 0?void 0:QQ.then;if(typeof XQ==="function"){let n;return c(XQ,QQ,(JQ)=>{if(JQ!=null)n.push(JQ);n.push(null)},(JQ)=>{u(n,JQ)}),n=new eq({objectMode:!0,writable:!1,read(){}})}throw new p(i,["Blob","ReadableStream","WritableStream","Stream","Iterable","AsyncIterable","Function","{ readable, writable } pair","Promise"],QQ)};function d(l){let{promise:QQ,resolve:i}=rq();const XQ=new AbortController,n=XQ.signal;return{value:l(async function*(){while(!0){const o=QQ;QQ=null;const{chunk:HQ,done:s,cb:KQ}=await o;if(_Q(KQ),s)return;if(n.aborted)throw new oq(void 0,{cause:n.reason});({promise:QQ,resolve:i}=rq()),yield HQ}}(),{signal:n}),write(o,HQ,s){const KQ=i;i=null,KQ({chunk:o,done:!1,cb:s})},final(o){const HQ=i;i=null,HQ({done:!0,cb:o})},destroy(o,HQ){XQ.abort(),HQ(o)}}}function qQ(l){const QQ=l.readable&&typeof l.readable.read!=="function"?b.wrap(l.readable):l.readable,i=l.writable;let XQ=!!U(QQ),n=!!H(i),JQ,o,HQ,s,KQ;function a(ZQ){const r=s;if(s=null,r)r(ZQ);else if(ZQ)KQ.destroy(ZQ);else if(!XQ&&!n)KQ.destroy()}if(KQ=new eq({readableObjectMode:!!(QQ!==null&&QQ!==void 0&&QQ.readableObjectMode),writableObjectMode:!!(i!==null&&i!==void 0&&i.writableObjectMode),readable:XQ,writable:n}),n)K(i,(ZQ)=>{if(n=!1,ZQ)u(QQ,ZQ);a(ZQ)}),KQ._write=function(ZQ,r,BQ){if(i.write(ZQ,r))BQ();else JQ=BQ},KQ._final=function(ZQ){i.end(),o=ZQ},i.on("drain",function(){if(JQ){const ZQ=JQ;JQ=null,ZQ()}}),i.on("finish",function(){if(o){const ZQ=o;o=null,ZQ()}});if(XQ)K(QQ,(ZQ)=>{if(XQ=!1,ZQ)u(QQ,ZQ);a(ZQ)}),QQ.on("readable",function(){if(HQ){const ZQ=HQ;HQ=null,ZQ()}}),QQ.on("end",function(){KQ.push(null)}),KQ._read=function(){while(!0){const ZQ=QQ.read();if(ZQ===null){HQ=KQ._read;return}if(!KQ.push(ZQ))return}};return KQ._destroy=function(ZQ,r){if(!ZQ&&s!==null)ZQ=new oq;if(HQ=null,JQ=null,o=null,s===null)r(ZQ);else s=r,u(i,ZQ),u(QQ,ZQ)},KQ}}}),wQ=G({"node_modules/readable-stream/lib/internal/streams/duplex.js"(B,Y){var{ObjectDefineProperties:U,ObjectGetOwnPropertyDescriptor:H,ObjectKeys:X,ObjectSetPrototypeOf:q}=DQ(),J=mQ();function Q(sq){if(!(this instanceof Q))return new Q(sq);if(J.call(this,sq),Mq.call(this,sq),sq){if(this.allowHalfOpen=sq.allowHalfOpen!==!1,sq.readable===!1)this._readableState.readable=!1,this._readableState.ended=!0,this._readableState.endEmitted=!0;if(sq.writable===!1)this._writableState.writable=!1,this._writableState.ending=!0,this._writableState.ended=!0,this._writableState.finished=!0}else this.allowHalfOpen=!0}Y.exports=Q,q(Q.prototype,J.prototype),q(Q,J);for(var Z in Mq.prototype)if(!Q.prototype[Z])Q.prototype[Z]=Mq.prototype[Z];U(Q.prototype,{writable:H(Mq.prototype,"writable"),writableHighWaterMark:H(Mq.prototype,"writableHighWaterMark"),writableObjectMode:H(Mq.prototype,"writableObjectMode"),writableBuffer:H(Mq.prototype,"writableBuffer"),writableLength:H(Mq.prototype,"writableLength"),writableFinished:H(Mq.prototype,"writableFinished"),writableCorked:H(Mq.prototype,"writableCorked"),writableEnded:H(Mq.prototype,"writableEnded"),writableNeedDrain:H(Mq.prototype,"writableNeedDrain"),destroyed:{get(){if(this._readableState===void 0||this._writableState===void 0)return!1;return this._readableState.destroyed&&this._writableState.destroyed},set(sq){if(this._readableState&&this._writableState)this._readableState.destroyed=sq,this._writableState.destroyed=sq}}});var K;function oq(){if(K===void 0)K={};return K}Q.fromWeb=function(sq,u){return oq().newStreamDuplexFromReadableWritablePair(sq,u)},Q.toWeb=function(sq){return oq().newReadableWritablePairFromDuplex(sq)};var p;Q.from=function(sq){if(!p)p=cQ();return p(sq,"body")}}}),vq=G({"node_modules/readable-stream/lib/internal/streams/transform.js"(B,Y){var{ObjectSetPrototypeOf:U,Symbol:H}=DQ(),{ERR_METHOD_NOT_IMPLEMENTED:X}=hQ().codes,q=wQ();function J(oq){if(!(this instanceof J))return new J(oq);if(q.call(this,oq),this._readableState.sync=!1,this[Q]=null,oq){if(typeof oq.transform==="function")this._transform=oq.transform;if(typeof oq.flush==="function")this._flush=oq.flush}this.on("prefinish",K.bind(this))}U(J.prototype,q.prototype),U(J,q),Y.exports=J;var Q=H("kCallback");function Z(oq){if(typeof this._flush==="function"&&!this.destroyed)this._flush((p,sq)=>{if(p){if(oq)oq(p);else this.destroy(p);return}if(sq!=null)this.push(sq);if(this.push(null),oq)oq()});else if(this.push(null),oq)oq()}function K(){if(this._final!==Z)Z.call(this)}J.prototype._final=Z,J.prototype._transform=function(oq,p,sq){throw new X("_transform()")},J.prototype._write=function(oq,p,sq){const u=this._readableState,aq=this._writableState,b=u.length;this._transform(oq,p,(rq,m)=>{if(rq){sq(rq);return}if(m!=null)this.push(m);if(aq.ended||b===u.length||u.length<u.highWaterMark||u.highWaterMark===0||u.length===0)sq();else this[Q]=sq})},J.prototype._read=function(){if(this[Q]){const oq=this[Q];this[Q]=null,oq()}}}}),dQ=G({"node_modules/readable-stream/lib/internal/streams/passthrough.js"(B,Y){var{ObjectSetPrototypeOf:U}=DQ(),H=vq();function X(q){if(!(this instanceof X))return new X(q);H.call(this,q)}U(X.prototype,H.prototype),U(X,H),X.prototype._transform=function(q,J,Q){Q(null,q)},Y.exports=X}}),Rq=G({"node_modules/readable-stream/lib/internal/streams/pipeline.js"(B,Y){var{ArrayIsArray:U,Promise:H,SymbolAsyncIterator:X}=DQ(),q=N(),{once:J}=jq(),Q=Oq(),Z=wQ(),{aggregateTwoErrors:K,codes:{ERR_INVALID_ARG_TYPE:oq,ERR_INVALID_RETURN_VALUE:p,ERR_MISSING_ARGS:sq,ERR_STREAM_DESTROYED:u},AbortError:aq}=hQ(),{validateFunction:b,validateAbortSignal:rq}=L(),{isIterable:m,isReadable:tq,isReadableNodeStream:c,isNodeStream:eq}=j(),d,qQ;function l(s,KQ,a){let ZQ=!1;s.on("close",()=>{ZQ=!0});const r=q(s,{readable:KQ,writable:a},(BQ)=>{ZQ=!BQ});return{destroy:(BQ)=>{if(ZQ)return;ZQ=!0,Q.destroyer(s,BQ||new u("pipe"))},cleanup:r}}function QQ(s){return b(s[s.length-1],"streams[stream.length - 1]"),s.pop()}function i(s){if(m(s))return s;else if(c(s))return XQ(s);throw new oq("val",["Readable","Iterable","AsyncIterable"],s)}async function*XQ(s){if(!qQ)qQ=mQ();yield*qQ.prototype[X].call(s)}async function n(s,KQ,a,{end:ZQ}){let r,BQ=null;const $=($Q)=>{if($Q)r=$Q;if(BQ){const t=BQ;BQ=null,t()}},YQ=()=>new H(($Q,t)=>{if(r)t(r);else BQ=()=>{if(r)t(r);else $Q()}});KQ.on("drain",$);const z=q(KQ,{readable:!1},$);try{if(KQ.writableNeedDrain)await YQ();for await(let $Q of s)if(!KQ.write($Q))await YQ();if(ZQ)KQ.end();await YQ(),a()}catch($Q){a(r!==$Q?K(r,$Q):$Q)}finally{z(),KQ.off("drain",$)}}function JQ(...s){return o(s,J(QQ(s)))}function o(s,KQ,a){if(s.length===1&&U(s[0]))s=s[0];if(s.length<2)throw new sq("streams");const ZQ=new AbortController,r=ZQ.signal,BQ=a===null||a===void 0?void 0:a.signal,$=[];rq(BQ,"options.signal");function YQ(){VQ(new aq)}BQ===null||BQ===void 0||BQ.addEventListener("abort",YQ);let z,$Q;const t=[];let zQ=0;function e(Qq){VQ(Qq,--zQ===0)}function VQ(Qq,WQ){if(Qq&&(!z||z.code==="ERR_STREAM_PREMATURE_CLOSE"))z=Qq;if(!z&&!WQ)return;while(t.length)t.shift()(z);if(BQ===null||BQ===void 0||BQ.removeEventListener("abort",YQ),ZQ.abort(),WQ){if(!z)$.forEach((Xq)=>Xq());_Q(KQ,z,$Q)}}let qq;for(let Qq=0;Qq<s.length;Qq++){const WQ=s[Qq],Xq=Qq<s.length-1,GQ=Qq>0,Jq=Xq||(a===null||a===void 0?void 0:a.end)!==!1,MQ=Qq===s.length-1;if(eq(WQ)){let Hq=function(FQ){if(FQ&&FQ.name!=="AbortError"&&FQ.code!=="ERR_STREAM_PREMATURE_CLOSE")e(FQ)};if(Jq){const{destroy:FQ,cleanup:Kq}=l(WQ,Xq,GQ);if(t.push(FQ),tq(WQ)&&MQ)$.push(Kq)}if(WQ.on("error",Hq),tq(WQ)&&MQ)$.push(()=>{WQ.removeListener("error",Hq)})}if(Qq===0)if(typeof WQ==="function"){if(qq=WQ({signal:r}),!m(qq))throw new p("Iterable, AsyncIterable or Stream","source",qq)}else if(m(WQ)||c(WQ))qq=WQ;else qq=Z.from(WQ);else if(typeof WQ==="function")if(qq=i(qq),qq=WQ(qq,{signal:r}),Xq){if(!m(qq,!0))throw new p("AsyncIterable",`transform[${Qq-1}]`,qq)}else{var UQ;if(!d)d=dQ();const Hq=new d({objectMode:!0}),FQ=(UQ=qq)===null||UQ===void 0?void 0:UQ.then;if(typeof FQ==="function")zQ++,FQ.call(qq,(Zq)=>{if($Q=Zq,Zq!=null)Hq.write(Zq);if(Jq)Hq.end();_Q(e)},(Zq)=>{Hq.destroy(Zq),_Q(e,Zq)});else if(m(qq,!0))zQ++,n(qq,Hq,e,{end:Jq});else throw new p("AsyncIterable or Promise","destination",qq);qq=Hq;const{destroy:Kq,cleanup:LQ}=l(qq,!1,!0);if(t.push(Kq),MQ)$.push(LQ)}else if(eq(WQ)){if(c(qq)){zQ+=2;const Hq=HQ(qq,WQ,e,{end:Jq});if(tq(WQ)&&MQ)$.push(Hq)}else if(m(qq))zQ++,n(qq,WQ,e,{end:Jq});else throw new oq("val",["Readable","Iterable","AsyncIterable"],qq);qq=WQ}else qq=Z.from(WQ)}if(r!==null&&r!==void 0&&r.aborted||BQ!==null&&BQ!==void 0&&BQ.aborted)_Q(YQ);return qq}function HQ(s,KQ,a,{end:ZQ}){if(s.pipe(KQ,{end:ZQ}),ZQ)s.once("end",()=>KQ.end());else a();return q(s,{readable:!0,writable:!1},(r)=>{const BQ=s._readableState;if(r&&r.code==="ERR_STREAM_PREMATURE_CLOSE"&&BQ&&BQ.ended&&!BQ.errored&&!BQ.errorEmitted)s.once("end",a).once("error",a);else a(r)}),q(KQ,{readable:!1,writable:!0},a)}Y.exports={pipelineImpl:o,pipeline:JQ}}}),lQ=G({"node_modules/readable-stream/lib/internal/streams/compose.js"(B,Y){var{pipeline:U}=Rq(),H=wQ(),{destroyer:X}=Oq(),{isNodeStream:q,isReadable:J,isWritable:Q}=j(),{AbortError:Z,codes:{ERR_INVALID_ARG_VALUE:K,ERR_MISSING_ARGS:oq}}=hQ();Y.exports=function p(...sq){if(sq.length===0)throw new oq("streams");if(sq.length===1)return H.from(sq[0]);const u=[...sq];if(typeof sq[0]==="function")sq[0]=H.from(sq[0]);if(typeof sq[sq.length-1]==="function"){const QQ=sq.length-1;sq[QQ]=H.from(sq[QQ])}for(let QQ=0;QQ<sq.length;++QQ){if(!q(sq[QQ]))continue;if(QQ<sq.length-1&&!J(sq[QQ]))throw new K(`streams[${QQ}]`,u[QQ],"must be readable");if(QQ>0&&!Q(sq[QQ]))throw new K(`streams[${QQ}]`,u[QQ],"must be writable")}let aq,b,rq,m,tq;function c(QQ){const i=m;if(m=null,i)i(QQ);else if(QQ)tq.destroy(QQ);else if(!l&&!qQ)tq.destroy()}const eq=sq[0],d=U(sq,c),qQ=!!Q(eq),l=!!J(d);if(tq=new H({writableObjectMode:!!(eq!==null&&eq!==void 0&&eq.writableObjectMode),readableObjectMode:!!(d!==null&&d!==void 0&&d.writableObjectMode),writable:qQ,readable:l}),qQ)tq._write=function(QQ,i,XQ){if(eq.write(QQ,i))XQ();else aq=XQ},tq._final=function(QQ){eq.end(),b=QQ},eq.on("drain",function(){if(aq){const QQ=aq;aq=null,QQ()}}),d.on("finish",function(){if(b){const QQ=b;b=null,QQ()}});if(l)d.on("readable",function(){if(rq){const QQ=rq;rq=null,QQ()}}),d.on("end",function(){tq.push(null)}),tq._read=function(){while(!0){const QQ=d.read();if(QQ===null){rq=tq._read;return}if(!tq.push(QQ))return}};return tq._destroy=function(QQ,i){if(!QQ&&m!==null)QQ=new Z;if(rq=null,aq=null,b=null,m===null)i(QQ);else m=i,X(d,QQ)},tq}}}),E=G({"node_modules/readable-stream/lib/stream/promises.js"(B,Y){var{ArrayPrototypePop:U,Promise:H}=DQ(),{isIterable:X,isNodeStream:q}=j(),{pipelineImpl:J}=Rq(),{finished:Q}=N();function Z(...K){return new H((oq,p)=>{let sq,u;const aq=K[K.length-1];if(aq&&typeof aq==="object"&&!q(aq)&&!X(aq)){const b=U(K);sq=b.signal,u=b.end}J(K,(b,rq)=>{if(b)p(b);else oq(rq)},{signal:sq,end:u})})}Y.exports={finished:Q,pipeline:Z}}}),I=G({"node_modules/readable-stream/lib/stream.js"(B,Y){var{ObjectDefineProperty:U,ObjectKeys:H,ReflectApply:X}=DQ(),{promisify:{custom:q}}=jq(),{streamReturningOperators:J,promiseReturningOperators:Q}=A(),{codes:{ERR_ILLEGAL_CONSTRUCTOR:Z}}=hQ(),K=lQ(),{pipeline:oq}=Rq(),{destroyer:p}=Oq(),sq=N(),u=E(),aq=j(),b=Y.exports=pQ().Stream;b.isDisturbed=aq.isDisturbed,b.isErrored=aq.isErrored,b.isWritable=aq.isWritable,b.isReadable=aq.isReadable,b.Readable=mQ();for(let m of H(J)){let tq=function(...eq){if(new.target)throw Z();return b.Readable.from(X(c,this,eq))};const c=J[m];U(tq,"name",{value:c.name}),U(tq,"length",{value:c.length}),U(b.Readable.prototype,m,{value:tq,enumerable:!1,configurable:!0,writable:!0})}for(let m of H(Q)){let tq=function(...eq){if(new.target)throw Z();return X(c,this,eq)};const c=Q[m];U(tq,"name",{value:c.name}),U(tq,"length",{value:c.length}),U(b.Readable.prototype,m,{value:tq,enumerable:!1,configurable:!0,writable:!0})}b.Writable=wq(),b.Duplex=wQ(),b.Transform=vq(),b.PassThrough=dQ(),b.pipeline=oq;var{addAbortSignal:rq}=_q();b.addAbortSignal=rq,b.finished=sq,b.destroy=p,b.compose=K,U(b,"promises",{configurable:!0,enumerable:!0,get(){return u}}),U(oq,q,{enumerable:!0,get(){return u.pipeline}}),U(sq,q,{enumerable:!0,get(){return u.finished}}),b.Stream=b,b._isUint8Array=function m(tq){return tq instanceof Uint8Array},b._uint8ArrayToBuffer=function m(tq){return new Buffer(tq.buffer,tq.byteOffset,tq.byteLength)}}}),T=G({"node_modules/readable-stream/lib/ours/index.js"(B,Y){const U=I(),H=E(),X=U.Readable.destroy;Y.exports=U,Y.exports._uint8ArrayToBuffer=U._uint8ArrayToBuffer,Y.exports._isUint8Array=U._isUint8Array,Y.exports.isDisturbed=U.isDisturbed,Y.exports.isErrored=U.isErrored,Y.exports.isWritable=U.isWritable,Y.exports.isReadable=U.isReadable,Y.exports.Readable=U.Readable,Y.exports.Writable=U.Writable,Y.exports.Duplex=U.Duplex,Y.exports.Transform=U.Transform,Y.exports.PassThrough=U.PassThrough,Y.exports.addAbortSignal=U.addAbortSignal,Y.exports.finished=U.finished,Y.exports.destroy=U.destroy,Y.exports.destroy=X,Y.exports.pipeline=U.pipeline,Y.exports.compose=U.compose,Y.exports._getNativeReadableStreamPrototype=O,Y.exports.NativeWritable=bq,Fq.defineProperty(U,"promises",{configurable:!0,enumerable:!0,get(){return H}}),Y.exports.Stream=U.Stream,Y.exports.default=Y.exports}}),x={0:void 0,1:void 0,2:void 0,3:void 0,4:void 0,5:void 0},Mq=wq(),bq=class B extends Mq{#q;#Q;#X=!0;_construct;_destroy;_final;constructor(Y,U={}){super(U);this._construct=this.#J,this._destroy=this.#K,this._final=this.#Z,this.#q=Y}#J(Y){this._writableState.constructed=!0,this.constructed=!0,Y()}#H(){if(typeof this.#q==="object")if(typeof this.#q.write==="function")this.#Q=this.#q;else throw new Error("Invalid FileSink");else this.#Q=Bun.file(this.#q).writer()}write(Y,U,H,X=this.#X){if(!X)return this.#X=!1,super.write(Y,U,H);if(!this.#Q)this.#H();var q=this.#Q,J=q.write(Y);if(Lq(J))return J.then(()=>{this.emit("drain"),q.flush(!0)}),!1;if(q.flush(!0),H)H(null,Y.byteLength);return!0}end(Y,U,H,X=this.#X){return super.end(Y,U,H,X)}#K(Y,U){if(this._writableState.destroyed=!0,U)U(Y)}#Z(Y){if(this.#Q)this.#Q.end();if(Y)Y()}ref(){if(!this.#Q)this.#H();this.#Q.ref()}unref(){if(!this.#Q)return;this.#Q.unref()}},C=T();C[Symbol.for("CommonJS")]=0;C[Symbol.for("::bunternal::")]={_ReadableFromWeb:bQ,_ReadableFromWebForUndici:Dq};var nq=C,D=C._uint8ArrayToBuffer,w=C._isUint8Array,v=C.isDisturbed,R=C.isErrored,S=C.isWritable,g=C.isReadable,f=C.Readable,Mq=C.Writable,k=C.Duplex,y=C.Transform,h=C.PassThrough,Sq=C.addAbortSignal,gq=C.finished,fq=C.destroy,kq=C.pipeline,yq=C.compose,hq=C.Stream,pq=C["eos"]=N,uq=C._getNativeReadableStreamPrototype,bq=C.NativeWritable,mq=hq.promises;export{mq as promises,kq as pipeline,S as isWritable,g as isReadable,R as isErrored,v as isDisturbed,gq as finished,pq as eos,fq as destroy,nq as default,yq as compose,Sq as addAbortSignal,D as _uint8ArrayToBuffer,w as _isUint8Array,uq as _getNativeReadableStreamPrototype,Mq as Writable,y as Transform,hq as Stream,f as Readable,h as PassThrough,bq as NativeWritable,k as Duplex}; +import{EventEmitter as Pq} from"bun:events_native";import{StringDecoder as Sq} from"node:string_decoder";var cq=function(q){return typeof q==="object"&&q!==null&&q instanceof ReadableStream},dq=function(q,Q){if(typeof q!=="boolean")throw new iq(Q,"boolean",q)};var iq=function(q,Q,X){return new Error(`The argument '${q}' is invalid. Received '${X}' for type '${Q}'`)},nq=function(q,Q,X){return new Error(`The value '${Q}' is invalid for argument '${q}'. Reason: ${X}`)},FQ=function(q,Q){var[X,J,H,K,Z,B,Y]=globalThis[Symbol.for("Bun.lazy")](q),$=[!1],z=function(F,L,j,N){if(L>0){const A=j.subarray(0,L),E=j.subarray(L);if(A.byteLength>0)F.push(A);if(N)F.push(null);return E.byteLength>0?E:void 0}if(N)F.push(null);return j},V=function(F,L,j,N){if(L.byteLength>0)F.push(L);if(N)F.push(null);return j},U=process.env.BUN_DISABLE_DYNAMIC_CHUNK_SIZE!=="1";const W=new FinalizationRegistry((F)=>F&&Z(F)),G=512;var M=class F extends Q{#q;#Q=1;#X=!1;#J=void 0;#H;#K=!1;#Z=!U;#B;constructor(L,j={}){super(j);if(typeof j.highWaterMark==="number")this.#H=j.highWaterMark;else this.#H=262144;this.#q=L,this.#X=!1,this.#J=void 0,this.#K=!1,this.#B={},W.register(this,this.#q,this.#B)}_read(L){if(Aq&&Nq("NativeReadable._read",this.__id),this.#K){Aq&&Nq("pendingRead is true",this.__id);return}var j=this.#q;if(Aq&&Nq("ptr @ NativeReadable._read",j,this.__id),j===0){this.push(null);return}if(!this.#X)Aq&&Nq("NativeReadable not constructed yet",this.__id),this.#Y(j);return this.#V(this.#$(L),j)}#Y(L){this.#X=!0;const j=J(L,this.#H);if(Aq&&Nq("NativeReadable internal `start` result",j,this.__id),typeof j==="number"&&j>1)this.#Z=!0,Aq&&Nq("NativeReadable resized",this.__id),this.#H=Math.min(this.#H,j);if(Y){const N=Y(L);if(Aq&&Nq("NativeReadable drain result",N,this.__id),(N?.byteLength??0)>0)this.push(N)}}#$(L=this.#H){var j=this.#J;if(Aq&&Nq("chunk @ #getRemainingChunk",j,this.__id),j?.byteLength??0<G){var N=L>G?L:G;this.#J=j=new Buffer(N)}return j}push(L,j){return Aq&&Nq("NativeReadable push -- result, encoding",L,j,this.__id),super.push(...arguments)}#z(L,j,N){if(Aq&&Nq("result, isClosed @ #handleResult",L,N,this.__id),typeof L==="number"){if(L>=this.#H&&!this.#Z&&!N)this.#H*=2,this.#Z=!0;return z(this,L,j,N)}else if(typeof L==="boolean")return this.push(null),j?.byteLength??0>0?j:void 0;else if(ArrayBuffer.isView(L)){if(L.byteLength>=this.#H&&!this.#Z&&!N)this.#H*=2,this.#Z=!0,Aq&&Nq("Resized",this.__id);return V(this,L,j,N)}else throw Aq&&Nq("Unknown result type",L,this.__id),new Error("Invalid result from pull")}#V(L,j){Aq&&Nq("#internalRead()",this.__id),$[0]=!1;var N=X(j,L,$);if(xq(N))return this.#K=!0,N.then((A)=>{this.#K=!1,Aq&&Nq("pending no longerrrrrrrr (result returned from pull)",this.__id),this.#J=this.#z(A,L,$[0])},(A)=>{Aq&&Nq("error from pull",A,this.__id),errorOrDestroy(this,A)});else this.#J=this.#z(N,L,$[0])}_destroy(L,j){var N=this.#q;if(N===0){j(L);return}if(W.unregister(this.#B),this.#q=0,B)B(N,!1);Aq&&Nq("NativeReadable destroyed",this.__id),H(N,L),j(L)}ref(){var L=this.#q;if(L===0)return;if(this.#Q++===0)B(L,!0)}unref(){var L=this.#q;if(L===0)return;if(this.#Q--===1)B(L,!1)}};if(!B)M.prototype.ref=void 0,M.prototype.unref=void 0;return M},jQ=function(q,Q){return LQ[q]||=FQ(q,Q)},NQ=function(q,Q,X){if(!(Q&&typeof Q==="object"&&Q instanceof ReadableStream))return;const J=wq(Q);if(!J){Nq("no native readable stream");return}const{stream:H,data:K}=J;return new(jQ(K,q))(H,X)},{isPromise:xq,isCallable:Dq,direct:wq,Object:Tq}=globalThis[Symbol.for("Bun.lazy")]("primordials");globalThis.__IDS_TO_TRACK=process.env.DEBUG_TRACK_EE?.length?process.env.DEBUG_TRACK_EE.split(","):process.env.DEBUG_STREAMS?.length?process.env.DEBUG_STREAMS.split(","):null;var gq=!!process.env.DEBUG_TRACK_EE,Aq=!!(process.env.DEBUG||process.env.DEBUG_STREAMS||gq),Nq=Aq?globalThis.__IDS_TO_TRACK?(...q)=>{const Q=q[q.length-1];if(!globalThis.__IDS_TO_TRACK.includes(Q))return;console.log(`ID: ${Q}`,...q.slice(0,-1))}:(...q)=>console.log(...q.slice(0,-1)):()=>{},fq=Tq.create,kq=Tq.defineProperty,yq=Tq.getOwnPropertyDescriptor,hq=Tq.getOwnPropertyNames,pq=Tq.getPrototypeOf,uq=Tq.prototype.hasOwnProperty,bq=Tq.setPrototypeOf,mq=(q,Q)=>function X(){return Q||(0,q[hq(q)[0]])((Q={exports:{}}).exports,Q),Q.exports};var Iq=process.nextTick;var lq=Array.isArray,Oq=mq({"node_modules/readable-stream/lib/ours/primordials.js"(q,Q){Q.exports={ArrayIsArray(X){return Array.isArray(X)},ArrayPrototypeIncludes(X,J){return X.includes(J)},ArrayPrototypeIndexOf(X,J){return X.indexOf(J)},ArrayPrototypeJoin(X,J){return X.join(J)},ArrayPrototypeMap(X,J){return X.map(J)},ArrayPrototypePop(X,J){return X.pop(J)},ArrayPrototypePush(X,J){return X.push(J)},ArrayPrototypeSlice(X,J,H){return X.slice(J,H)},Error,FunctionPrototypeCall(X,J,...H){return X.call(J,...H)},FunctionPrototypeSymbolHasInstance(X,J){return Function.prototype[Symbol.hasInstance].call(X,J)},MathFloor:Math.floor,Number,NumberIsInteger:Number.isInteger,NumberIsNaN:Number.isNaN,NumberMAX_SAFE_INTEGER:Number.MAX_SAFE_INTEGER,NumberMIN_SAFE_INTEGER:Number.MIN_SAFE_INTEGER,NumberParseInt:Number.parseInt,ObjectDefineProperties(X,J){return Tq.defineProperties(X,J)},ObjectDefineProperty(X,J,H){return Tq.defineProperty(X,J,H)},ObjectGetOwnPropertyDescriptor(X,J){return Tq.getOwnPropertyDescriptor(X,J)},ObjectKeys(X){return Tq.keys(X)},ObjectSetPrototypeOf(X,J){return Tq.setPrototypeOf(X,J)},Promise,PromisePrototypeCatch(X,J){return X.catch(J)},PromisePrototypeThen(X,J,H){return X.then(J,H)},PromiseReject(X){return Promise.reject(X)},ReflectApply:Reflect.apply,RegExpPrototypeTest(X,J){return X.test(J)},SafeSet:Set,String,StringPrototypeSlice(X,J,H){return X.slice(J,H)},StringPrototypeToLowerCase(X){return X.toLowerCase()},StringPrototypeToUpperCase(X){return X.toUpperCase()},StringPrototypeTrim(X){return X.trim()},Symbol,SymbolAsyncIterator:Symbol.asyncIterator,SymbolHasInstance:Symbol.hasInstance,SymbolIterator:Symbol.iterator,TypedArrayPrototypeSet(X,J,H){return X.set(J,H)},Uint8Array}}}),_q=mq({"node_modules/readable-stream/lib/ours/util.js"(q,Q){var X=Tq.getPrototypeOf(async function(){}).constructor,J=typeof Blob!=="undefined"?function K(Z){return Z instanceof Blob}:function K(Z){return!1},H=class extends Error{constructor(K){if(!Array.isArray(K))throw new TypeError(`Expected input to be an Array, got ${typeof K}`);let Z="";for(let B=0;B<K.length;B++)Z+=` ${K[B].stack} +`;super(Z);this.name="AggregateError",this.errors=K}};Q.exports={AggregateError:H,once(K){let Z=!1;return function(...B){if(Z)return;Z=!0,K.apply(this,B)}},createDeferredPromise:function(){let K,Z;return{promise:new Promise((Y,$)=>{K=Y,Z=$}),resolve:K,reject:Z}},promisify(K){return new Promise((Z,B)=>{K((Y,...$)=>{if(Y)return B(Y);return Z(...$)})})},debuglog(){return function(){}},format(K,...Z){return K.replace(/%([sdifj])/g,function(...[B,Y]){const $=Z.shift();if(Y==="f")return $.toFixed(6);else if(Y==="j")return JSON.stringify($);else if(Y==="s"&&typeof $==="object")return`${$.constructor!==Tq?$.constructor.name:""} {}`.trim();else return $.toString()})},inspect(K){switch(typeof K){case"string":if(K.includes("'")){if(!K.includes('"'))return`"${K}"`;else if(!K.includes("`")&&!K.includes("${"))return`\`${K}\``}return`'${K}'`;case"number":if(isNaN(K))return"NaN";else if(Tq.is(K,-0))return String(K);return K;case"bigint":return`${String(K)}n`;case"boolean":case"undefined":return String(K);case"object":return"{}"}},types:{isAsyncFunction(K){return K instanceof X},isArrayBufferView(K){return ArrayBuffer.isView(K)}},isBlob:J},Q.exports.promisify.custom=Symbol.for("nodejs.util.promisify.custom")}}),oq=mq({"node_modules/readable-stream/lib/ours/errors.js"(q,Q){var{format:X,inspect:J,AggregateError:H}=_q(),K=globalThis.AggregateError||H,Z=Symbol("kIsNodeError"),B=["string","function","number","object","Function","Object","boolean","bigint","symbol"],Y=/^([A-Z][a-z0-9]*)+$/,$="__node_internal_",z={};function V(j,N){if(!j)throw new z.ERR_INTERNAL_ASSERTION(N)}function U(j){let N="",A=j.length;const E=j[0]==="-"?1:0;for(;A>=E+4;A-=3)N=`_${j.slice(A-3,A)}${N}`;return`${j.slice(0,A)}${N}`}function W(j,N,A){if(typeof N==="function")return V(N.length<=A.length,`Code: ${j}; The provided arguments length (${A.length}) does not match the required ones (${N.length}).`),N(...A);const E=(N.match(/%[dfijoOs]/g)||[]).length;if(V(E===A.length,`Code: ${j}; The provided arguments length (${A.length}) does not match the required ones (${E}).`),A.length===0)return N;return X(N,...A)}function G(j,N,A){if(!A)A=Error;class E extends A{constructor(...I){super(W(j,N,I))}toString(){return`${this.name} [${j}]: ${this.message}`}}Tq.defineProperties(E.prototype,{name:{value:A.name,writable:!0,enumerable:!1,configurable:!0},toString:{value(){return`${this.name} [${j}]: ${this.message}`},writable:!0,enumerable:!1,configurable:!0}}),E.prototype.code=j,E.prototype[Z]=!0,z[j]=E}function M(j){const N=$+j.name;return Tq.defineProperty(j,"name",{value:N}),j}function F(j,N){if(j&&N&&j!==N){if(Array.isArray(N.errors))return N.errors.push(j),N;const A=new K([N,j],N.message);return A.code=N.code,A}return j||N}var L=class extends Error{constructor(j="The operation was aborted",N=void 0){if(N!==void 0&&typeof N!=="object")throw new z.ERR_INVALID_ARG_TYPE("options","Object",N);super(j,N);this.code="ABORT_ERR",this.name="AbortError"}};G("ERR_ASSERTION","%s",Error),G("ERR_INVALID_ARG_TYPE",(j,N,A)=>{if(V(typeof j==="string","'name' must be a string"),!Array.isArray(N))N=[N];let E="The ";if(j.endsWith(" argument"))E+=`${j} `;else E+=`"${j}" ${j.includes(".")?"property":"argument"} `;E+="must be ";const I=[],T=[],P=[];for(let O of N)if(V(typeof O==="string","All expected entries have to be of type string"),B.includes(O))I.push(O.toLowerCase());else if(Y.test(O))T.push(O);else V(O!=="object",'The value "object" should be written as "Object"'),P.push(O);if(T.length>0){const O=I.indexOf("object");if(O!==-1)I.splice(I,O,1),T.push("Object")}if(I.length>0){switch(I.length){case 1:E+=`of type ${I[0]}`;break;case 2:E+=`one of type ${I[0]} or ${I[1]}`;break;default:{const O=I.pop();E+=`one of type ${I.join(", ")}, or ${O}`}}if(T.length>0||P.length>0)E+=" or "}if(T.length>0){switch(T.length){case 1:E+=`an instance of ${T[0]}`;break;case 2:E+=`an instance of ${T[0]} or ${T[1]}`;break;default:{const O=T.pop();E+=`an instance of ${T.join(", ")}, or ${O}`}}if(P.length>0)E+=" or "}switch(P.length){case 0:break;case 1:if(P[0].toLowerCase()!==P[0])E+="an ";E+=`${P[0]}`;break;case 2:E+=`one of ${P[0]} or ${P[1]}`;break;default:{const O=P.pop();E+=`one of ${P.join(", ")}, or ${O}`}}if(A==null)E+=`. Received ${A}`;else if(typeof A==="function"&&A.name)E+=`. Received function ${A.name}`;else if(typeof A==="object"){var x;if((x=A.constructor)!==null&&x!==void 0&&x.name)E+=`. Received an instance of ${A.constructor.name}`;else{const O=J(A,{depth:-1});E+=`. Received ${O}`}}else{let O=J(A,{colors:!1});if(O.length>25)O=`${O.slice(0,25)}...`;E+=`. Received type ${typeof A} (${O})`}return E},TypeError),G("ERR_INVALID_ARG_VALUE",(j,N,A="is invalid")=>{let E=J(N);if(E.length>128)E=E.slice(0,128)+"...";return`The ${j.includes(".")?"property":"argument"} '${j}' ${A}. Received ${E}`},TypeError),G("ERR_INVALID_RETURN_VALUE",(j,N,A)=>{var E;const I=A!==null&&A!==void 0&&(E=A.constructor)!==null&&E!==void 0&&E.name?`instance of ${A.constructor.name}`:`type ${typeof A}`;return`Expected ${j} to be returned from the "${N}" function but got ${I}.`},TypeError),G("ERR_MISSING_ARGS",(...j)=>{V(j.length>0,"At least one arg needs to be specified");let N;const A=j.length;switch(j=(Array.isArray(j)?j:[j]).map((E)=>`"${E}"`).join(" or "),A){case 1:N+=`The ${j[0]} argument`;break;case 2:N+=`The ${j[0]} and ${j[1]} arguments`;break;default:{const E=j.pop();N+=`The ${j.join(", ")}, and ${E} arguments`}break}return`${N} must be specified`},TypeError),G("ERR_OUT_OF_RANGE",(j,N,A)=>{V(N,'Missing "range" argument');let E;if(Number.isInteger(A)&&Math.abs(A)>4294967296)E=U(String(A));else if(typeof A==="bigint"){if(E=String(A),A>2n**32n||A<-(2n**32n))E=U(E);E+="n"}else E=J(A);return`The value of "${j}" is out of range. It must be ${N}. Received ${E}`},RangeError),G("ERR_MULTIPLE_CALLBACK","Callback called multiple times",Error),G("ERR_METHOD_NOT_IMPLEMENTED","The %s method is not implemented",Error),G("ERR_STREAM_ALREADY_FINISHED","Cannot call %s after a stream was finished",Error),G("ERR_STREAM_CANNOT_PIPE","Cannot pipe, not readable",Error),G("ERR_STREAM_DESTROYED","Cannot call %s after a stream was destroyed",Error),G("ERR_STREAM_NULL_VALUES","May not write null values to stream",TypeError),G("ERR_STREAM_PREMATURE_CLOSE","Premature close",Error),G("ERR_STREAM_PUSH_AFTER_EOF","stream.push() after EOF",Error),G("ERR_STREAM_UNSHIFT_AFTER_END_EVENT","stream.unshift() after end event",Error),G("ERR_STREAM_WRITE_AFTER_END","write after end",Error),G("ERR_UNKNOWN_ENCODING","Unknown encoding: %s",TypeError),Q.exports={AbortError:L,aggregateTwoErrors:M(F),hideStackFrames:M,codes:z}}}),sq=mq({"node_modules/readable-stream/lib/internal/validators.js"(q,Q){var{ArrayIsArray:X,ArrayPrototypeIncludes:J,ArrayPrototypeJoin:H,ArrayPrototypeMap:K,NumberIsInteger:Z,NumberMAX_SAFE_INTEGER:B,NumberMIN_SAFE_INTEGER:Y,NumberParseInt:$,RegExpPrototypeTest:z,String:V,StringPrototypeToUpperCase:U,StringPrototypeTrim:W}=Oq(),{hideStackFrames:G,codes:{ERR_SOCKET_BAD_PORT:M,ERR_INVALID_ARG_TYPE:F,ERR_INVALID_ARG_VALUE:L,ERR_OUT_OF_RANGE:j,ERR_UNKNOWN_SIGNAL:N}}=oq(),{normalizeEncoding:A}=_q(),{isAsyncFunction:E,isArrayBufferView:I}=_q().types,T={};function P(i){return i===(i|0)}function x(i){return i===i>>>0}var O=/^[0-7]+$/,_="must be a 32-bit unsigned integer or an octal string";function C(i,n,o){if(typeof i==="undefined")i=o;if(typeof i==="string"){if(!z(O,i))throw new L(n,i,_);i=$(i,8)}return w(i,n,0,4294967295),i}var D=G((i,n,o=Y,s=B)=>{if(typeof i!=="number")throw new F(n,"number",i);if(!Z(i))throw new j(n,"an integer",i);if(i<o||i>s)throw new j(n,`>= ${o} && <= ${s}`,i)}),w=G((i,n,o=-2147483648,s=2147483647)=>{if(typeof i!=="number")throw new F(n,"number",i);if(!P(i)){if(!Z(i))throw new j(n,"an integer",i);throw new j(n,`>= ${o} && <= ${s}`,i)}if(i<o||i>s)throw new j(n,`>= ${o} && <= ${s}`,i)}),v=G((i,n,o)=>{if(typeof i!=="number")throw new F(n,"number",i);if(!x(i)){if(!Z(i))throw new j(n,"an integer",i);throw new j(n,`>= ${o?1:0} && < 4294967296`,i)}if(o&&i===0)throw new j(n,">= 1 && < 4294967296",i)});function R(i,n){if(typeof i!=="string")throw new F(n,"string",i)}function S(i,n){if(typeof i!=="number")throw new F(n,"number",i)}var g=G((i,n,o)=>{if(!J(o,i)){const a="must be one of: "+H(K(o,(r)=>typeof r==="string"?`'${r}'`:V(r)),", ");throw new L(n,i,a)}});function f(i,n){if(typeof i!=="boolean")throw new F(n,"boolean",i)}var k=G((i,n,o)=>{const s=o==null,a=s?!1:o.allowArray,r=s?!1:o.allowFunction;if(!(s?!1:o.nullable)&&i===null||!a&&X(i)||typeof i!=="object"&&(!r||typeof i!=="function"))throw new F(n,"Object",i)}),y=G((i,n,o=0)=>{if(!X(i))throw new F(n,"Array",i);if(i.length<o){const s=`must be longer than ${o}`;throw new L(n,i,s)}});function h(i,n="signal"){if(R(i,n),T[i]===void 0){if(T[U(i)]!==void 0)throw new N(i+" (signals must use all capital letters)");throw new N(i)}}var p=G((i,n="buffer")=>{if(!I(i))throw new F(n,["Buffer","TypedArray","DataView"],i)});function u(i,n){const o=A(n),s=i.length;if(o==="hex"&&s%2!==0)throw new L("encoding",n,`is invalid for data of length ${s}`)}function b(i,n="Port",o=!0){if(typeof i!=="number"&&typeof i!=="string"||typeof i==="string"&&W(i).length===0||+i!==+i>>>0||i>65535||i===0&&!o)throw new M(n,i,o);return i|0}var m=G((i,n)=>{if(i!==void 0&&(i===null||typeof i!=="object"||!("aborted"in i)))throw new F(n,"AbortSignal",i)}),c=G((i,n)=>{if(typeof i!=="function")throw new F(n,"Function",i)}),d=G((i,n)=>{if(typeof i!=="function"||E(i))throw new F(n,"Function",i)}),l=G((i,n)=>{if(i!==void 0)throw new F(n,"undefined",i)});Q.exports={isInt32:P,isUint32:x,parseFileMode:C,validateArray:y,validateBoolean:f,validateBuffer:p,validateEncoding:u,validateFunction:c,validateInt32:w,validateInteger:D,validateNumber:S,validateObject:k,validateOneOf:g,validatePlainFunction:d,validatePort:b,validateSignalName:h,validateString:R,validateUint32:v,validateUndefined:l,validateAbortSignal:m}}}),aq=mq({"node_modules/readable-stream/lib/internal/streams/utils.js"(q,Q){var{Symbol:X,SymbolAsyncIterator:J,SymbolIterator:H}=Oq(),K=X("kDestroyed"),Z=X("kIsErrored"),B=X("kIsReadable"),Y=X("kIsDisturbed");function $(v,R=!1){var S;return!!(v&&typeof v.pipe==="function"&&typeof v.on==="function"&&(!R||typeof v.pause==="function"&&typeof v.resume==="function")&&(!v._writableState||((S=v._readableState)===null||S===void 0?void 0:S.readable)!==!1)&&(!v._writableState||v._readableState))}function z(v){var R;return!!(v&&typeof v.write==="function"&&typeof v.on==="function"&&(!v._readableState||((R=v._writableState)===null||R===void 0?void 0:R.writable)!==!1))}function V(v){return!!(v&&typeof v.pipe==="function"&&v._readableState&&typeof v.on==="function"&&typeof v.write==="function")}function U(v){return v&&(v._readableState||v._writableState||typeof v.write==="function"&&typeof v.on==="function"||typeof v.pipe==="function"&&typeof v.on==="function")}function W(v,R){if(v==null)return!1;if(R===!0)return typeof v[J]==="function";if(R===!1)return typeof v[H]==="function";return typeof v[J]==="function"||typeof v[H]==="function"}function G(v){if(!U(v))return null;const{_writableState:R,_readableState:S}=v,g=R||S;return!!(v.destroyed||v[K]||g!==null&&g!==void 0&&g.destroyed)}function M(v){if(!z(v))return null;if(v.writableEnded===!0)return!0;const R=v._writableState;if(R!==null&&R!==void 0&&R.errored)return!1;if(typeof(R===null||R===void 0?void 0:R.ended)!=="boolean")return null;return R.ended}function F(v,R){if(!z(v))return null;if(v.writableFinished===!0)return!0;const S=v._writableState;if(S!==null&&S!==void 0&&S.errored)return!1;if(typeof(S===null||S===void 0?void 0:S.finished)!=="boolean")return null;return!!(S.finished||R===!1&&S.ended===!0&&S.length===0)}function L(v){if(!$(v))return null;if(v.readableEnded===!0)return!0;const R=v._readableState;if(!R||R.errored)return!1;if(typeof(R===null||R===void 0?void 0:R.ended)!=="boolean")return null;return R.ended}function j(v,R){if(!$(v))return null;const S=v._readableState;if(S!==null&&S!==void 0&&S.errored)return!1;if(typeof(S===null||S===void 0?void 0:S.endEmitted)!=="boolean")return null;return!!(S.endEmitted||R===!1&&S.ended===!0&&S.length===0)}function N(v){if(v&&v[B]!=null)return v[B];if(typeof(v===null||v===void 0?void 0:v.readable)!=="boolean")return null;if(G(v))return!1;return $(v)&&v.readable&&!j(v)}function A(v){if(typeof(v===null||v===void 0?void 0:v.writable)!=="boolean")return null;if(G(v))return!1;return z(v)&&v.writable&&!M(v)}function E(v,R){if(!U(v))return null;if(G(v))return!0;if((R===null||R===void 0?void 0:R.readable)!==!1&&N(v))return!1;if((R===null||R===void 0?void 0:R.writable)!==!1&&A(v))return!1;return!0}function I(v){var R,S;if(!U(v))return null;if(v.writableErrored)return v.writableErrored;return(R=(S=v._writableState)===null||S===void 0?void 0:S.errored)!==null&&R!==void 0?R:null}function T(v){var R,S;if(!U(v))return null;if(v.readableErrored)return v.readableErrored;return(R=(S=v._readableState)===null||S===void 0?void 0:S.errored)!==null&&R!==void 0?R:null}function P(v){if(!U(v))return null;if(typeof v.closed==="boolean")return v.closed;const{_writableState:R,_readableState:S}=v;if(typeof(R===null||R===void 0?void 0:R.closed)==="boolean"||typeof(S===null||S===void 0?void 0:S.closed)==="boolean")return(R===null||R===void 0?void 0:R.closed)||(S===null||S===void 0?void 0:S.closed);if(typeof v._closed==="boolean"&&x(v))return v._closed;return null}function x(v){return typeof v._closed==="boolean"&&typeof v._defaultKeepAlive==="boolean"&&typeof v._removedConnection==="boolean"&&typeof v._removedContLen==="boolean"}function O(v){return typeof v._sent100==="boolean"&&x(v)}function _(v){var R;return typeof v._consuming==="boolean"&&typeof v._dumped==="boolean"&&((R=v.req)===null||R===void 0?void 0:R.upgradeOrConnect)===void 0}function C(v){if(!U(v))return null;const{_writableState:R,_readableState:S}=v,g=R||S;return!g&&O(v)||!!(g&&g.autoDestroy&&g.emitClose&&g.closed===!1)}function D(v){var R;return!!(v&&((R=v[Y])!==null&&R!==void 0?R:v.readableDidRead||v.readableAborted))}function w(v){var R,S,g,f,k,y,h,p,u,b;return!!(v&&((R=(S=(g=(f=(k=(y=v[Z])!==null&&y!==void 0?y:v.readableErrored)!==null&&k!==void 0?k:v.writableErrored)!==null&&f!==void 0?f:(h=v._readableState)===null||h===void 0?void 0:h.errorEmitted)!==null&&g!==void 0?g:(p=v._writableState)===null||p===void 0?void 0:p.errorEmitted)!==null&&S!==void 0?S:(u=v._readableState)===null||u===void 0?void 0:u.errored)!==null&&R!==void 0?R:(b=v._writableState)===null||b===void 0?void 0:b.errored))}Q.exports={kDestroyed:K,isDisturbed:D,kIsDisturbed:Y,isErrored:w,kIsErrored:Z,isReadable:N,kIsReadable:B,isClosed:P,isDestroyed:G,isDuplexNodeStream:V,isFinished:E,isIterable:W,isReadableNodeStream:$,isReadableEnded:L,isReadableFinished:j,isReadableErrored:T,isNodeStream:U,isWritable:A,isWritableNodeStream:z,isWritableEnded:M,isWritableFinished:F,isWritableErrored:I,isServerRequest:_,isServerResponse:O,willEmitClose:C}}}),rq=mq({"node_modules/readable-stream/lib/internal/streams/end-of-stream.js"(q,Q){var{AbortError:X,codes:J}=oq(),{ERR_INVALID_ARG_TYPE:H,ERR_STREAM_PREMATURE_CLOSE:K}=J,{once:Z}=_q(),{validateAbortSignal:B,validateFunction:Y,validateObject:$}=sq(),{Promise:z}=Oq(),{isClosed:V,isReadable:U,isReadableNodeStream:W,isReadableFinished:G,isReadableErrored:M,isWritable:F,isWritableNodeStream:L,isWritableFinished:j,isWritableErrored:N,isNodeStream:A,willEmitClose:E}=aq();function I(O){return O.setHeader&&typeof O.abort==="function"}var T=()=>{};function P(O,_,C){var D,w;if(arguments.length===2)C=_,_={};else if(_==null)_={};else $(_,"options");Y(C,"callback"),B(_.signal,"options.signal"),C=Z(C);const v=(D=_.readable)!==null&&D!==void 0?D:W(O),R=(w=_.writable)!==null&&w!==void 0?w:L(O);if(!A(O))throw new H("stream","Stream",O);const{_writableState:S,_readableState:g}=O,f=()=>{if(!O.writable)h()};let k=E(O)&&W(O)===v&&L(O)===R,y=j(O,!1);const h=()=>{if(y=!0,O.destroyed)k=!1;if(k&&(!O.readable||v))return;if(!v||p)C.call(O)};let p=G(O,!1);const u=()=>{if(p=!0,O.destroyed)k=!1;if(k&&(!O.writable||R))return;if(!R||y)C.call(O)},b=(i)=>{C.call(O,i)};let m=V(O);const c=()=>{m=!0;const i=N(O)||M(O);if(i&&typeof i!=="boolean")return C.call(O,i);if(v&&!p&&W(O,!0)){if(!G(O,!1))return C.call(O,new K)}if(R&&!y){if(!j(O,!1))return C.call(O,new K)}C.call(O)},d=()=>{O.req.on("finish",h)};if(I(O)){if(O.on("complete",h),!k)O.on("abort",c);if(O.req)d();else O.on("request",d)}else if(R&&!S)O.on("end",f),O.on("close",f);if(!k&&typeof O.aborted==="boolean")O.on("aborted",c);if(O.on("end",u),O.on("finish",h),_.error!==!1)O.on("error",b);if(O.on("close",c),m)Iq(c);else if(S!==null&&S!==void 0&&S.errorEmitted||g!==null&&g!==void 0&&g.errorEmitted){if(!k)Iq(c)}else if(!v&&(!k||U(O))&&(y||F(O)===!1))Iq(c);else if(!R&&(!k||F(O))&&(p||U(O)===!1))Iq(c);else if(g&&O.req&&O.aborted)Iq(c);const l=()=>{if(C=T,O.removeListener("aborted",c),O.removeListener("complete",h),O.removeListener("abort",c),O.removeListener("request",d),O.req)O.req.removeListener("finish",h);O.removeListener("end",f),O.removeListener("close",f),O.removeListener("finish",h),O.removeListener("end",u),O.removeListener("error",b),O.removeListener("close",c)};if(_.signal&&!m){const i=()=>{const n=C;l(),n.call(O,new X(void 0,{cause:_.signal.reason}))};if(_.signal.aborted)Iq(i);else{const n=C;C=Z((...o)=>{_.signal.removeEventListener("abort",i),n.apply(O,o)}),_.signal.addEventListener("abort",i)}}return l}function x(O,_){return new z((C,D)=>{P(O,_,(w)=>{if(w)D(w);else C()})})}Q.exports=P,Q.exports.finished=x}}),tq=mq({"node_modules/readable-stream/lib/internal/streams/operators.js"(q,Q){var{codes:{ERR_INVALID_ARG_TYPE:X,ERR_MISSING_ARGS:J,ERR_OUT_OF_RANGE:H},AbortError:K}=oq(),{validateAbortSignal:Z,validateInteger:B,validateObject:Y}=sq(),$=Oq().Symbol("kWeak"),{finished:z}=rq(),{ArrayPrototypePush:V,MathFloor:U,Number:W,NumberIsNaN:G,Promise:M,PromiseReject:F,PromisePrototypeCatch:L,Symbol:j}=Oq(),N=j("kEmpty"),A=j("kEof");function E(f,k){if(typeof f!=="function")throw new X("fn",["Function","AsyncFunction"],f);if(k!=null)Y(k,"options");if((k===null||k===void 0?void 0:k.signal)!=null)Z(k.signal,"options.signal");let y=1;if((k===null||k===void 0?void 0:k.concurrency)!=null)y=U(k.concurrency);return B(y,"concurrency",1),async function*h(){var p,u;const b=new AbortController,m=this,c=[],d=b.signal,l={signal:d},i=()=>b.abort();if(k!==null&&k!==void 0&&(p=k.signal)!==null&&p!==void 0&&p.aborted)i();k===null||k===void 0||(u=k.signal)===null||u===void 0||u.addEventListener("abort",i);let n,o,s=!1;function a(){s=!0}async function r(){try{for await(let qq of m){var t;if(s)return;if(d.aborted)throw new K;try{qq=f(qq,l)}catch(Qq){qq=F(Qq)}if(qq===N)continue;if(typeof((t=qq)===null||t===void 0?void 0:t.catch)==="function")qq.catch(a);if(c.push(qq),n)n(),n=null;if(!s&&c.length&&c.length>=y)await new M((Qq)=>{o=Qq})}c.push(A)}catch(qq){const Qq=F(qq);L(Qq,a),c.push(Qq)}finally{var e;if(s=!0,n)n(),n=null;k===null||k===void 0||(e=k.signal)===null||e===void 0||e.removeEventListener("abort",i)}}r();try{while(!0){while(c.length>0){const t=await c[0];if(t===A)return;if(d.aborted)throw new K;if(t!==N)yield t;if(c.shift(),o)o(),o=null}await new M((t)=>{n=t})}}finally{if(b.abort(),s=!0,o)o(),o=null}}.call(this)}function I(f=void 0){if(f!=null)Y(f,"options");if((f===null||f===void 0?void 0:f.signal)!=null)Z(f.signal,"options.signal");return async function*k(){let y=0;for await(let p of this){var h;if(f!==null&&f!==void 0&&(h=f.signal)!==null&&h!==void 0&&h.aborted)throw new K({cause:f.signal.reason});yield[y++,p]}}.call(this)}async function T(f,k=void 0){for await(let y of _.call(this,f,k))return!0;return!1}async function P(f,k=void 0){if(typeof f!=="function")throw new X("fn",["Function","AsyncFunction"],f);return!await T.call(this,async(...y)=>{return!await f(...y)},k)}async function x(f,k){for await(let y of _.call(this,f,k))return y;return}async function O(f,k){if(typeof f!=="function")throw new X("fn",["Function","AsyncFunction"],f);async function y(h,p){return await f(h,p),N}for await(let h of E.call(this,y,k));}function _(f,k){if(typeof f!=="function")throw new X("fn",["Function","AsyncFunction"],f);async function y(h,p){if(await f(h,p))return h;return N}return E.call(this,y,k)}var C=class extends J{constructor(){super("reduce");this.message="Reduce of an empty stream requires an initial value"}};async function D(f,k,y){var h;if(typeof f!=="function")throw new X("reducer",["Function","AsyncFunction"],f);if(y!=null)Y(y,"options");if((y===null||y===void 0?void 0:y.signal)!=null)Z(y.signal,"options.signal");let p=arguments.length>1;if(y!==null&&y!==void 0&&(h=y.signal)!==null&&h!==void 0&&h.aborted){const d=new K(void 0,{cause:y.signal.reason});throw this.once("error",()=>{}),await z(this.destroy(d)),d}const u=new AbortController,b=u.signal;if(y!==null&&y!==void 0&&y.signal){const d={once:!0,[$]:this};y.signal.addEventListener("abort",()=>u.abort(),d)}let m=!1;try{for await(let d of this){var c;if(m=!0,y!==null&&y!==void 0&&(c=y.signal)!==null&&c!==void 0&&c.aborted)throw new K;if(!p)k=d,p=!0;else k=await f(k,d,{signal:b})}if(!m&&!p)throw new C}finally{u.abort()}return k}async function w(f){if(f!=null)Y(f,"options");if((f===null||f===void 0?void 0:f.signal)!=null)Z(f.signal,"options.signal");const k=[];for await(let h of this){var y;if(f!==null&&f!==void 0&&(y=f.signal)!==null&&y!==void 0&&y.aborted)throw new K(void 0,{cause:f.signal.reason});V(k,h)}return k}function v(f,k){const y=E.call(this,f,k);return async function*h(){for await(let p of y)yield*p}.call(this)}function R(f){if(f=W(f),G(f))return 0;if(f<0)throw new H("number",">= 0",f);return f}function S(f,k=void 0){if(k!=null)Y(k,"options");if((k===null||k===void 0?void 0:k.signal)!=null)Z(k.signal,"options.signal");return f=R(f),async function*y(){var h;if(k!==null&&k!==void 0&&(h=k.signal)!==null&&h!==void 0&&h.aborted)throw new K;for await(let u of this){var p;if(k!==null&&k!==void 0&&(p=k.signal)!==null&&p!==void 0&&p.aborted)throw new K;if(f--<=0)yield u}}.call(this)}function g(f,k=void 0){if(k!=null)Y(k,"options");if((k===null||k===void 0?void 0:k.signal)!=null)Z(k.signal,"options.signal");return f=R(f),async function*y(){var h;if(k!==null&&k!==void 0&&(h=k.signal)!==null&&h!==void 0&&h.aborted)throw new K;for await(let u of this){var p;if(k!==null&&k!==void 0&&(p=k.signal)!==null&&p!==void 0&&p.aborted)throw new K;if(f-- >0)yield u;else return}}.call(this)}Q.exports.streamReturningOperators={asIndexedPairs:I,drop:S,filter:_,flatMap:v,map:E,take:g},Q.exports.promiseReturningOperators={every:P,forEach:O,reduce:D,toArray:w,some:T,find:x}}}),eq=mq({"node_modules/readable-stream/lib/internal/streams/destroy.js"(q,Q){var{aggregateTwoErrors:X,codes:{ERR_MULTIPLE_CALLBACK:J},AbortError:H}=oq(),{Symbol:K}=Oq(),{kDestroyed:Z,isDestroyed:B,isFinished:Y,isServerRequest:$}=aq(),z="#kDestroy",V="#kConstruct";function U(_,C,D){if(_){if(_.stack,C&&!C.errored)C.errored=_;if(D&&!D.errored)D.errored=_}}function W(_,C){const D=this._readableState,w=this._writableState,v=w||D;if(w&&w.destroyed||D&&D.destroyed){if(typeof C==="function")C();return this}if(U(_,w,D),w)w.destroyed=!0;if(D)D.destroyed=!0;if(!v.constructed)this.once(z,(R)=>{G(this,X(R,_),C)});else G(this,_,C);return this}function G(_,C,D){let w=!1;function v(R){if(w)return;w=!0;const{_readableState:S,_writableState:g}=_;if(U(R,g,S),g)g.closed=!0;if(S)S.closed=!0;if(typeof D==="function")D(R);if(R)Iq(M,_,R);else Iq(F,_)}try{_._destroy(C||null,v)}catch(R){v(R)}}function M(_,C){L(_,C),F(_)}function F(_){const{_readableState:C,_writableState:D}=_;if(D)D.closeEmitted=!0;if(C)C.closeEmitted=!0;if(D&&D.emitClose||C&&C.emitClose)_.emit("close")}function L(_,C){const D=_?._readableState,w=_?._writableState;if(w?.errorEmitted||D?.errorEmitted)return;if(w)w.errorEmitted=!0;if(D)D.errorEmitted=!0;_?.emit?.("error",C)}function j(){const _=this._readableState,C=this._writableState;if(_)_.constructed=!0,_.closed=!1,_.closeEmitted=!1,_.destroyed=!1,_.errored=null,_.errorEmitted=!1,_.reading=!1,_.ended=_.readable===!1,_.endEmitted=_.readable===!1;if(C)C.constructed=!0,C.destroyed=!1,C.closed=!1,C.closeEmitted=!1,C.errored=null,C.errorEmitted=!1,C.finalCalled=!1,C.prefinished=!1,C.ended=C.writable===!1,C.ending=C.writable===!1,C.finished=C.writable===!1}function N(_,C,D){const w=_?._readableState,v=_?._writableState;if(v&&v.destroyed||w&&w.destroyed)return this;if(w&&w.autoDestroy||v&&v.autoDestroy)_.destroy(C);else if(C){if(Error.captureStackTrace(C),v&&!v.errored)v.errored=C;if(w&&!w.errored)w.errored=C;if(D)Iq(L,_,C);else L(_,C)}}function A(_,C){if(typeof _._construct!=="function")return;const{_readableState:D,_writableState:w}=_;if(D)D.constructed=!1;if(w)w.constructed=!1;if(_.once(V,C),_.listenerCount(V)>1)return;Iq(E,_)}function E(_){let C=!1;function D(w){if(C){N(_,w!==null&&w!==void 0?w:new J);return}C=!0;const{_readableState:v,_writableState:R}=_,S=R||v;if(v)v.constructed=!0;if(R)R.constructed=!0;if(S.destroyed)_.emit(z,w);else if(w)N(_,w,!0);else Iq(I,_)}try{_._construct(D)}catch(w){D(w)}}function I(_){_.emit(V)}function T(_){return _&&_.setHeader&&typeof _.abort==="function"}function P(_){_.emit("close")}function x(_,C){_.emit("error",C),Iq(P,_)}function O(_,C){if(!_||B(_))return;if(!C&&!Y(_))C=new H;if($(_))_.socket=null,_.destroy(C);else if(T(_))_.abort();else if(T(_.req))_.req.abort();else if(typeof _.destroy==="function")_.destroy(C);else if(typeof _.close==="function")_.close();else if(C)Iq(x,_);else Iq(P,_);if(!_.destroyed)_[Z]=!0}Q.exports={construct:A,destroyer:O,destroy:W,undestroy:j,errorOrDestroy:N}}}),qQ=mq({"node_modules/readable-stream/lib/internal/streams/legacy.js"(q,Q){var{ArrayIsArray:X,ObjectSetPrototypeOf:J}=Oq();function H(Z){if(!(this instanceof H))return new H(Z);Pq.call(this,Z)}J(H.prototype,Pq.prototype),J(H,Pq),H.prototype.pipe=function(Z,B){const Y=this;function $(F){if(Z.writable&&Z.write(F)===!1&&Y.pause)Y.pause()}Y.on("data",$);function z(){if(Y.readable&&Y.resume)Y.resume()}if(Z.on("drain",z),!Z._isStdio&&(!B||B.end!==!1))Y.on("end",U),Y.on("close",W);let V=!1;function U(){if(V)return;V=!0,Z.end()}function W(){if(V)return;if(V=!0,typeof Z.destroy==="function")Z.destroy()}function G(F){if(M(),Pq.listenerCount(this,"error")===0)this.emit("error",F)}K(Y,"error",G),K(Z,"error",G);function M(){Y.removeListener("data",$),Z.removeListener("drain",z),Y.removeListener("end",U),Y.removeListener("close",W),Y.removeListener("error",G),Z.removeListener("error",G),Y.removeListener("end",M),Y.removeListener("close",M),Z.removeListener("close",M)}return Y.on("end",M),Y.on("close",M),Z.on("close",M),Z.emit("pipe",Y),Z};function K(Z,B,Y){if(typeof Z.prependListener==="function")return Z.prependListener(B,Y);if(!Z._events||!Z._events[B])Z.on(B,Y);else if(X(Z._events[B]))Z._events[B].unshift(Y);else Z._events[B]=[Y,Z._events[B]]}Q.exports={Stream:H,prependListener:K}}}),QQ=mq({"node_modules/readable-stream/lib/internal/streams/add-abort-signal.js"(q,Q){var{AbortError:X,codes:J}=oq(),H=rq(),{ERR_INVALID_ARG_TYPE:K}=J,Z=(Y,$)=>{if(typeof Y!=="object"||!("aborted"in Y))throw new K($,"AbortSignal",Y)};function B(Y){return!!(Y&&typeof Y.pipe==="function")}Q.exports.addAbortSignal=function Y($,z){if(Z($,"signal"),!B(z))throw new K("stream","stream.Stream",z);return Q.exports.addAbortSignalNoValidate($,z)},Q.exports.addAbortSignalNoValidate=function(Y,$){if(typeof Y!=="object"||!("aborted"in Y))return $;const z=()=>{$.destroy(new X(void 0,{cause:Y.reason}))};if(Y.aborted)z();else Y.addEventListener("abort",z),H($,()=>Y.removeEventListener("abort",z));return $}}}),XQ=mq({"node_modules/readable-stream/lib/internal/streams/state.js"(q,Q){var{MathFloor:X,NumberIsInteger:J}=Oq(),{ERR_INVALID_ARG_VALUE:H}=oq().codes;function K(Y,$,z){return Y.highWaterMark!=null?Y.highWaterMark:$?Y[z]:null}function Z(Y){return Y?16:16384}function B(Y,$,z,V){const U=K($,V,z);if(U!=null){if(!J(U)||U<0){const W=V?`options.${z}`:"options.highWaterMark";throw new H(W,U)}return X(U)}return Z(Y.objectMode)}Q.exports={getHighWaterMark:B,getDefaultHighWaterMark:Z}}}),JQ=mq({"node_modules/readable-stream/lib/internal/streams/from.js"(q,Q){var{PromisePrototypeThen:X,SymbolAsyncIterator:J,SymbolIterator:H}=Oq(),{ERR_INVALID_ARG_TYPE:K,ERR_STREAM_NULL_VALUES:Z}=oq().codes;function B(Y,$,z){let V;if(typeof $==="string"||$ instanceof Buffer)return new Y({objectMode:!0,...z,read(){this.push($),this.push(null)}});let U;if($&&$[J])U=!0,V=$[J]();else if($&&$[H])U=!1,V=$[H]();else throw new K("iterable",["Iterable"],$);const W=new Y({objectMode:!0,highWaterMark:1,...z});let G=!1;W._read=function(){if(!G)G=!0,F()},W._destroy=function(L,j){X(M(L),()=>Iq(j,L),(N)=>Iq(j,N||L))};async function M(L){const j=L!==void 0&&L!==null,N=typeof V.throw==="function";if(j&&N){const{value:A,done:E}=await V.throw(L);if(await A,E)return}if(typeof V.return==="function"){const{value:A}=await V.return();await A}}async function F(){for(;;){try{const{value:L,done:j}=U?await V.next():V.next();if(j)W.push(null);else{const N=L&&typeof L.then==="function"?await L:L;if(N===null)throw G=!1,new Z;else if(W.push(N))continue;else G=!1}}catch(L){W.destroy(L)}break}}return W}Q.exports=B}}),HQ,KQ,ZQ=mq({"node_modules/readable-stream/lib/internal/streams/readable.js"(q,Q){var{ArrayPrototypeIndexOf:X,NumberIsInteger:J,NumberIsNaN:H,NumberParseInt:K,ObjectDefineProperties:Z,ObjectKeys:B,ObjectSetPrototypeOf:Y,Promise:$,SafeSet:z,SymbolAsyncIterator:V,Symbol:U}=Oq(),W=globalThis[Symbol.for("Bun.lazy")]("bun:stream").ReadableState,{Stream:G,prependListener:M}=qQ();function F(qq){if(!(this instanceof F))return new F(qq);const Qq=this instanceof Cq();if(this._readableState=new W(qq,this,Qq),qq){const{read:Xq,destroy:Jq,construct:Hq,signal:Kq}=qq;if(typeof Xq==="function")this._read=Xq;if(typeof Jq==="function")this._destroy=Jq;if(typeof Hq==="function")this._construct=Hq;if(Kq&&!Qq)N(Kq,this)}G.call(this,qq),_.construct(this,()=>{if(this._readableState.needReadable)x(this,this._readableState)})}Y(F.prototype,G.prototype),Y(F,G),F.prototype.on=function(qq,Qq){const Xq=G.prototype.on.call(this,qq,Qq),Jq=this._readableState;if(qq==="data")if(Jq.readableListening=this.listenerCount("readable")>0,Jq.flowing!==!1)Aq&&Nq("in flowing mode!",this.__id),this.resume();else Aq&&Nq("in readable mode!",this.__id);else if(qq==="readable"){if(Aq&&Nq("readable listener added!",this.__id),!Jq.endEmitted&&!Jq.readableListening){if(Jq.readableListening=Jq.needReadable=!0,Jq.flowing=!1,Jq.emittedReadable=!1,Aq&&Nq("on readable - state.length, reading, emittedReadable",Jq.length,Jq.reading,Jq.emittedReadable,this.__id),Jq.length)O(this,Jq);else if(!Jq.reading)Iq(l,this)}else if(Jq.endEmitted)Aq&&Nq("end already emitted...",this.__id)}return Xq};class L extends F{#q;#Q;#X;#J;constructor(qq,Qq){const{objectMode:Xq,highWaterMark:Jq,encoding:Hq,signal:Kq}=qq;super({objectMode:Xq,highWaterMark:Jq,encoding:Hq,signal:Kq});this.#X=[],this.#q=void 0,this.#J=Qq,this.#Q=!1}#H(){var qq=this.#X,Qq=0,Xq=qq.length;for(;Qq<Xq;Qq++){const Jq=qq[Qq];if(qq[Qq]=void 0,!this.push(Jq,void 0))return this.#X=qq.slice(Qq+1),!0}if(Xq>0)this.#X=[];return!1}#K(qq){qq.releaseLock(),this.#q=void 0,this.#Q=!0,this.push(null);return}async _read(){Aq&&Nq("ReadableFromWeb _read()",this.__id);var qq=this.#J,Qq=this.#q;if(qq)Qq=this.#q=qq.getReader(),this.#J=void 0;else if(this.#H())return;var Xq;try{do{var Jq=!1,Hq;const Kq=Qq.readMany();if(xq(Kq)){if({done:Jq,value:Hq}=await Kq,this.#Q){this.#X.push(...Hq);return}}else({done:Jq,value:Hq}=Kq);if(Jq){this.#K(Qq);return}if(!this.push(Hq[0])){this.#X=Hq.slice(1);return}for(let Zq=1,Bq=Hq.length;Zq<Bq;Zq++)if(!this.push(Hq[Zq])){this.#X=Hq.slice(Zq+1);return}}while(!this.#Q)}catch(Kq){Xq=Kq}finally{if(Xq)throw Xq}}_destroy(qq,Qq){if(!this.#Q){var Xq=this.#q;if(Xq)this.#q=void 0,Xq.cancel(qq).finally(()=>{this.#Q=!0,Qq(qq)});return}try{Qq(qq)}catch(Jq){globalThis.reportError(Jq)}}}KQ=L;function j(qq,Qq={}){if(!cq(qq))throw new D("readableStream","ReadableStream",qq);g(Qq,"options");const{highWaterMark:Xq,encoding:Jq,objectMode:Hq=!1,signal:Kq}=Qq;if(Jq!==void 0&&!Buffer.isEncoding(Jq))throw new nq(Jq,"options.encoding");return dq(Hq,"options.objectMode"),NQ(F,qq,Qq)||new L({highWaterMark:Xq,encoding:Jq,objectMode:Hq,signal:Kq},qq)}Q.exports=F,HQ=j;var{addAbortSignal:N}=QQ(),A=rq();const{maybeReadMore:E,resume:I,emitReadable:T,onEofChunk:P}=globalThis[Symbol.for("Bun.lazy")]("bun:stream");function x(qq,Qq){process.nextTick(E,qq,Qq)}function O(qq,Qq){Aq&&Nq("NativeReadable - emitReadable",qq.__id),T(qq,Qq)}var _=eq(),{aggregateTwoErrors:C,codes:{ERR_INVALID_ARG_TYPE:D,ERR_METHOD_NOT_IMPLEMENTED:w,ERR_OUT_OF_RANGE:v,ERR_STREAM_PUSH_AFTER_EOF:R,ERR_STREAM_UNSHIFT_AFTER_END_EVENT:S}}=oq(),{validateObject:g}=sq(),f=JQ(),k=()=>{},{errorOrDestroy:y}=_;F.prototype.destroy=_.destroy,F.prototype._undestroy=_.undestroy,F.prototype._destroy=function(qq,Qq){Qq(qq)},F.prototype[Pq.captureRejectionSymbol]=function(qq){this.destroy(qq)},F.prototype.push=function(qq,Qq){return h(this,qq,Qq,!1)},F.prototype.unshift=function(qq,Qq){return h(this,qq,Qq,!0)};function h(qq,Qq,Xq,Jq){Aq&&Nq("readableAddChunk",Qq,qq.__id);const Hq=qq._readableState;let Kq;if(!Hq.objectMode){if(typeof Qq==="string"){if(Xq=Xq||Hq.defaultEncoding,Hq.encoding!==Xq)if(Jq&&Hq.encoding)Qq=Buffer.from(Qq,Xq).toString(Hq.encoding);else Qq=Buffer.from(Qq,Xq),Xq=""}else if(Qq instanceof Buffer)Xq="";else if(G._isUint8Array(Qq)){if(Jq||!Hq.decoder)Qq=G._uint8ArrayToBuffer(Qq);Xq=""}else if(Qq!=null)Kq=new D("chunk",["string","Buffer","Uint8Array"],Qq)}if(Kq)y(qq,Kq);else if(Qq===null)Hq.reading=!1,P(qq,Hq);else if(Hq.objectMode||Qq&&Qq.length>0)if(Jq)if(Hq.endEmitted)y(qq,new S);else if(Hq.destroyed||Hq.errored)return!1;else p(qq,Hq,Qq,!0);else if(Hq.ended)y(qq,new R);else if(Hq.destroyed||Hq.errored)return!1;else if(Hq.reading=!1,Hq.decoder&&!Xq)if(Qq=Hq.decoder.write(Qq),Hq.objectMode||Qq.length!==0)p(qq,Hq,Qq,!1);else x(qq,Hq);else p(qq,Hq,Qq,!1);else if(!Jq)Hq.reading=!1,x(qq,Hq);return!Hq.ended&&(Hq.length<Hq.highWaterMark||Hq.length===0)}function p(qq,Qq,Xq,Jq){if(Aq&&Nq("adding chunk",qq.__id),Aq&&Nq("chunk",Xq.toString(),qq.__id),Qq.flowing&&Qq.length===0&&!Qq.sync&&qq.listenerCount("data")>0){if(Qq.multiAwaitDrain)Qq.awaitDrainWriters.clear();else Qq.awaitDrainWriters=null;Qq.dataEmitted=!0,qq.emit("data",Xq)}else{if(Qq.length+=Qq.objectMode?1:Xq.length,Jq)Qq.buffer.unshift(Xq);else Qq.buffer.push(Xq);if(Aq&&Nq("needReadable @ addChunk",Qq.needReadable,qq.__id),Qq.needReadable)O(qq,Qq)}x(qq,Qq)}F.prototype.isPaused=function(){const qq=this._readableState;return qq.paused===!0||qq.flowing===!1},F.prototype.setEncoding=function(qq){const Qq=new Sq(qq);this._readableState.decoder=Qq,this._readableState.encoding=this._readableState.decoder.encoding;const Xq=this._readableState.buffer;let Jq="";for(let Hq=Xq.length;Hq>0;Hq--)Jq+=Qq.write(Xq.shift());if(Jq!=="")Xq.push(Jq);return this._readableState.length=Jq.length,this};var u=1073741824;function b(qq){if(qq>u)throw new v("size","<= 1GiB",qq);else qq--,qq|=qq>>>1,qq|=qq>>>2,qq|=qq>>>4,qq|=qq>>>8,qq|=qq>>>16,qq++;return qq}function m(qq,Qq){if(qq<=0||Qq.length===0&&Qq.ended)return 0;if(Qq.objectMode)return 1;if(H(qq)){if(Qq.flowing&&Qq.length)return Qq.buffer.first().length;return Qq.length}if(qq<=Qq.length)return qq;return Qq.ended?Qq.length:0}F.prototype.read=function(qq){if(Aq&&Nq("read - n =",qq,this.__id),!J(qq))qq=K(qq,10);const Qq=this._readableState,Xq=qq;if(qq>Qq.highWaterMark)Qq.highWaterMark=b(qq);if(qq!==0)Qq.emittedReadable=!1;if(qq===0&&Qq.needReadable&&((Qq.highWaterMark!==0?Qq.length>=Qq.highWaterMark:Qq.length>0)||Qq.ended)){if(Aq&&Nq("read: emitReadable or endReadable",Qq.length,Qq.ended,this.__id),Qq.length===0&&Qq.ended)s(this);else O(this,Qq);return null}if(qq=m(qq,Qq),qq===0&&Qq.ended){if(Aq&&Nq("read: calling endReadable if length 0 -- length, state.ended",Qq.length,Qq.ended,this.__id),Qq.length===0)s(this);return null}let Jq=Qq.needReadable;if(Aq&&Nq("need readable",Jq,this.__id),Qq.length===0||Qq.length-qq<Qq.highWaterMark)Jq=!0,Aq&&Nq("length less than watermark",Jq,this.__id);if(Qq.ended||Qq.reading||Qq.destroyed||Qq.errored||!Qq.constructed)Aq&&Nq("state.constructed?",Qq.constructed,this.__id),Jq=!1,Aq&&Nq("reading, ended or constructing",Jq,this.__id);else if(Jq){if(Aq&&Nq("do read",this.__id),Qq.reading=!0,Qq.sync=!0,Qq.length===0)Qq.needReadable=!0;try{var Hq=this._read(Qq.highWaterMark);if(xq(Hq)){Aq&&Nq("async _read",this.__id);const Zq=Bun.peek(Hq);if(Aq&&Nq("peeked promise",Zq,this.__id),Zq!==Hq)Hq=Zq}if(xq(Hq)&&Hq?.then&&Dq(Hq.then))Aq&&Nq("async _read result.then setup",this.__id),Hq.then(k,function(Zq){y(this,Zq)})}catch(Zq){y(this,Zq)}if(Qq.sync=!1,!Qq.reading)qq=m(Xq,Qq)}Aq&&Nq("n @ fromList",qq,this.__id);let Kq;if(qq>0)Kq=o(qq,Qq);else Kq=null;if(Aq&&Nq("ret @ read",Kq,this.__id),Kq===null)Qq.needReadable=Qq.length<=Qq.highWaterMark,Aq&&Nq("state.length while ret = null",Qq.length,this.__id),qq=0;else if(Qq.length-=qq,Qq.multiAwaitDrain)Qq.awaitDrainWriters.clear();else Qq.awaitDrainWriters=null;if(Qq.length===0){if(!Qq.ended)Qq.needReadable=!0;if(Xq!==qq&&Qq.ended)s(this)}if(Kq!==null&&!Qq.errorEmitted&&!Qq.closeEmitted)Qq.dataEmitted=!0,this.emit("data",Kq);return Kq},F.prototype._read=function(qq){throw new w("_read()")},F.prototype.pipe=function(qq,Qq){const Xq=this,Jq=this._readableState;if(Jq.pipes.length===1){if(!Jq.multiAwaitDrain)Jq.multiAwaitDrain=!0,Jq.awaitDrainWriters=new z(Jq.awaitDrainWriters?[Jq.awaitDrainWriters]:[])}Jq.pipes.push(qq),Aq&&Nq("pipe count=%d opts=%j",Jq.pipes.length,Qq,Xq.__id);const Kq=(!Qq||Qq.end!==!1)&&qq!==process.stdout&&qq!==process.stderr?Bq:Fq;if(Jq.endEmitted)Iq(Kq);else Xq.once("end",Kq);qq.on("unpipe",Zq);function Zq(Lq,jq){if(Aq&&Nq("onunpipe",Xq.__id),Lq===Xq){if(jq&&jq.hasUnpiped===!1)jq.hasUnpiped=!0,zq()}}function Bq(){Aq&&Nq("onend",Xq.__id),qq.end()}let Yq,$q=!1;function zq(){if(Aq&&Nq("cleanup",Xq.__id),qq.removeListener("close",Gq),qq.removeListener("finish",Mq),Yq)qq.removeListener("drain",Yq);if(qq.removeListener("error",Wq),qq.removeListener("unpipe",Zq),Xq.removeListener("end",Bq),Xq.removeListener("end",Fq),Xq.removeListener("data",Uq),$q=!0,Yq&&Jq.awaitDrainWriters&&(!qq._writableState||qq._writableState.needDrain))Yq()}function Vq(){if(!$q){if(Jq.pipes.length===1&&Jq.pipes[0]===qq)Aq&&Nq("false write response, pause",0,Xq.__id),Jq.awaitDrainWriters=qq,Jq.multiAwaitDrain=!1;else if(Jq.pipes.length>1&&Jq.pipes.includes(qq))Aq&&Nq("false write response, pause",Jq.awaitDrainWriters.size,Xq.__id),Jq.awaitDrainWriters.add(qq);Xq.pause()}if(!Yq)Yq=c(Xq,qq),qq.on("drain",Yq)}Xq.on("data",Uq);function Uq(Lq){Aq&&Nq("ondata",Xq.__id);const jq=qq.write(Lq);if(Aq&&Nq("dest.write",jq,Xq.__id),jq===!1)Vq()}function Wq(Lq){if(Nq("onerror",Lq),Fq(),qq.removeListener("error",Wq),qq.listenerCount("error")===0){const jq=qq._writableState||qq._readableState;if(jq&&!jq.errorEmitted)y(qq,Lq);else qq.emit("error",Lq)}}M(qq,"error",Wq);function Gq(){qq.removeListener("finish",Mq),Fq()}qq.once("close",Gq);function Mq(){Nq("onfinish"),qq.removeListener("close",Gq),Fq()}qq.once("finish",Mq);function Fq(){Nq("unpipe"),Xq.unpipe(qq)}if(qq.emit("pipe",Xq),qq.writableNeedDrain===!0){if(Jq.flowing)Vq()}else if(!Jq.flowing)Nq("pipe resume"),Xq.resume();return qq};function c(qq,Qq){return function Xq(){const Jq=qq._readableState;if(Jq.awaitDrainWriters===Qq)Nq("pipeOnDrain",1),Jq.awaitDrainWriters=null;else if(Jq.multiAwaitDrain)Nq("pipeOnDrain",Jq.awaitDrainWriters.size),Jq.awaitDrainWriters.delete(Qq);if((!Jq.awaitDrainWriters||Jq.awaitDrainWriters.size===0)&&qq.listenerCount("data"))qq.resume()}}F.prototype.unpipe=function(qq){const Qq=this._readableState,Xq={hasUnpiped:!1};if(Qq.pipes.length===0)return this;if(!qq){const Hq=Qq.pipes;Qq.pipes=[],this.pause();for(let Kq=0;Kq<Hq.length;Kq++)Hq[Kq].emit("unpipe",this,{hasUnpiped:!1});return this}const Jq=X(Qq.pipes,qq);if(Jq===-1)return this;if(Qq.pipes.splice(Jq,1),Qq.pipes.length===0)this.pause();return qq.emit("unpipe",this,Xq),this},F.prototype.addListener=F.prototype.on,F.prototype.removeListener=function(qq,Qq){const Xq=G.prototype.removeListener.call(this,qq,Qq);if(qq==="readable")Iq(d,this);return Xq},F.prototype.off=F.prototype.removeListener,F.prototype.removeAllListeners=function(qq){const Qq=G.prototype.removeAllListeners.apply(this,arguments);if(qq==="readable"||qq===void 0)Iq(d,this);return Qq};function d(qq){const Qq=qq._readableState;if(Qq.readableListening=qq.listenerCount("readable")>0,Qq.resumeScheduled&&Qq.paused===!1)Qq.flowing=!0;else if(qq.listenerCount("data")>0)qq.resume();else if(!Qq.readableListening)Qq.flowing=null}function l(qq){Aq&&Nq("on readable nextTick, calling read(0)",qq.__id),qq.read(0)}F.prototype.resume=function(){const qq=this._readableState;if(!qq.flowing)Aq&&Nq("resume",this.__id),qq.flowing=!qq.readableListening,I(this,qq);return qq.paused=!1,this},F.prototype.pause=function(){if(Aq&&Nq("call pause flowing=%j",this._readableState.flowing,this.__id),this._readableState.flowing!==!1)Aq&&Nq("pause",this.__id),this._readableState.flowing=!1,this.emit("pause");return this._readableState.paused=!0,this},F.prototype.wrap=function(qq){let Qq=!1;qq.on("data",(Jq)=>{if(!this.push(Jq)&&qq.pause)Qq=!0,qq.pause()}),qq.on("end",()=>{this.push(null)}),qq.on("error",(Jq)=>{y(this,Jq)}),qq.on("close",()=>{this.destroy()}),qq.on("destroy",()=>{this.destroy()}),this._read=()=>{if(Qq&&qq.resume)Qq=!1,qq.resume()};const Xq=B(qq);for(let Jq=1;Jq<Xq.length;Jq++){const Hq=Xq[Jq];if(this[Hq]===void 0&&typeof qq[Hq]==="function")this[Hq]=qq[Hq].bind(qq)}return this},F.prototype[V]=function(){return i(this)},F.prototype.iterator=function(qq){if(qq!==void 0)g(qq,"options");return i(this,qq)};function i(qq,Qq){if(typeof qq.read!=="function")qq=F.wrap(qq,{objectMode:!0});const Xq=n(qq,Qq);return Xq.stream=qq,Xq}async function*n(qq,Qq){let Xq=k;function Jq(Zq){if(this===qq)Xq(),Xq=k;else Xq=Zq}qq.on("readable",Jq);let Hq;const Kq=A(qq,{writable:!1},(Zq)=>{Hq=Zq?C(Hq,Zq):null,Xq(),Xq=k});try{while(!0){const Zq=qq.destroyed?null:qq.read();if(Zq!==null)yield Zq;else if(Hq)throw Hq;else if(Hq===null)return;else await new $(Jq)}}catch(Zq){throw Hq=C(Hq,Zq),Hq}finally{if((Hq||(Qq===null||Qq===void 0?void 0:Qq.destroyOnReturn)!==!1)&&(Hq===void 0||qq._readableState.autoDestroy))_.destroyer(qq,null);else qq.off("readable",Jq),Kq()}}Z(F.prototype,{readable:{get(){const qq=this._readableState;return!!qq&&qq.readable!==!1&&!qq.destroyed&&!qq.errorEmitted&&!qq.endEmitted},set(qq){if(this._readableState)this._readableState.readable=!!qq}},readableDidRead:{enumerable:!1,get:function(){return this._readableState.dataEmitted}},readableAborted:{enumerable:!1,get:function(){return!!(this._readableState.readable!==!1&&(this._readableState.destroyed||this._readableState.errored)&&!this._readableState.endEmitted)}},readableHighWaterMark:{enumerable:!1,get:function(){return this._readableState.highWaterMark}},readableBuffer:{enumerable:!1,get:function(){return this._readableState&&this._readableState.buffer}},readableFlowing:{enumerable:!1,get:function(){return this._readableState.flowing},set:function(qq){if(this._readableState)this._readableState.flowing=qq}},readableLength:{enumerable:!1,get(){return this._readableState.length}},readableObjectMode:{enumerable:!1,get(){return this._readableState?this._readableState.objectMode:!1}},readableEncoding:{enumerable:!1,get(){return this._readableState?this._readableState.encoding:null}},errored:{enumerable:!1,get(){return this._readableState?this._readableState.errored:null}},closed:{get(){return this._readableState?this._readableState.closed:!1}},destroyed:{enumerable:!1,get(){return this._readableState?this._readableState.destroyed:!1},set(qq){if(!this._readableState)return;this._readableState.destroyed=qq}},readableEnded:{enumerable:!1,get(){return this._readableState?this._readableState.endEmitted:!1}}}),F._fromList=o;function o(qq,Qq){if(Qq.length===0)return null;let Xq;if(Qq.objectMode)Xq=Qq.buffer.shift();else if(!qq||qq>=Qq.length){if(Qq.decoder)Xq=Qq.buffer.join("");else if(Qq.buffer.length===1)Xq=Qq.buffer.first();else Xq=Qq.buffer.concat(Qq.length);Qq.buffer.clear()}else Xq=Qq.buffer.consume(qq,Qq.decoder);return Xq}function s(qq){const Qq=qq._readableState;if(Aq&&Nq("endEmitted @ endReadable",Qq.endEmitted,qq.__id),!Qq.endEmitted)Qq.ended=!0,Iq(a,Qq,qq)}function a(qq,Qq){if(Aq&&Nq("endReadableNT -- endEmitted, state.length",qq.endEmitted,qq.length,Qq.__id),!qq.errored&&!qq.closeEmitted&&!qq.endEmitted&&qq.length===0){if(qq.endEmitted=!0,Qq.emit("end"),Aq&&Nq("end emitted @ endReadableNT",Qq.__id),Qq.writable&&Qq.allowHalfOpen===!1)Iq(r,Qq);else if(qq.autoDestroy){const Xq=Qq._writableState;if(!Xq||Xq.autoDestroy&&(Xq.finished||Xq.writable===!1))Qq.destroy()}}}function r(qq){if(qq.writable&&!qq.writableEnded&&!qq.destroyed)qq.end()}F.from=function(qq,Qq){return f(F,qq,Qq)};var t={newStreamReadableFromReadableStream:j};function e(){if(t===void 0)t={};return t}F.fromWeb=function(qq,Qq){return e().newStreamReadableFromReadableStream(qq,Qq)},F.toWeb=function(qq){return e().newReadableStreamFromStreamReadable(qq)},F.wrap=function(qq,Qq){var Xq,Jq;return new F({objectMode:(Xq=(Jq=qq.readableObjectMode)!==null&&Jq!==void 0?Jq:qq.objectMode)!==null&&Xq!==void 0?Xq:!0,...Qq,destroy(Hq,Kq){_.destroyer(qq,Hq),Kq(Hq)}}).wrap(qq)}}}),BQ=mq({"node_modules/readable-stream/lib/internal/streams/writable.js"(q,Q){var{ArrayPrototypeSlice:X,Error:J,FunctionPrototypeSymbolHasInstance:H,ObjectDefineProperty:K,ObjectDefineProperties:Z,ObjectSetPrototypeOf:B,StringPrototypeToLowerCase:Y,Symbol:$,SymbolHasInstance:z}=Oq(),V=qQ().Stream,U=eq(),{addAbortSignal:W}=QQ(),{getHighWaterMark:G,getDefaultHighWaterMark:M}=XQ(),{ERR_INVALID_ARG_TYPE:F,ERR_METHOD_NOT_IMPLEMENTED:L,ERR_MULTIPLE_CALLBACK:j,ERR_STREAM_CANNOT_PIPE:N,ERR_STREAM_DESTROYED:A,ERR_STREAM_ALREADY_FINISHED:E,ERR_STREAM_NULL_VALUES:I,ERR_STREAM_WRITE_AFTER_END:T,ERR_UNKNOWN_ENCODING:P}=oq().codes,{errorOrDestroy:x}=U;function O(o={}){const s=this instanceof Cq();if(!s&&!H(O,this))return new O(o);if(this._writableState=new D(o,this,s),o){if(typeof o.write==="function")this._write=o.write;if(typeof o.writev==="function")this._writev=o.writev;if(typeof o.destroy==="function")this._destroy=o.destroy;if(typeof o.final==="function")this._final=o.final;if(typeof o.construct==="function")this._construct=o.construct;if(o.signal)W(o.signal,this)}V.call(this,o),U.construct(this,()=>{const a=this._writableState;if(!a.writing)p(this,a);c(this,a)})}B(O.prototype,V.prototype),B(O,V),Q.exports=O;function _(){}var C=$("kOnFinished");function D(o,s,a){if(typeof a!=="boolean")a=s instanceof Cq();if(this.objectMode=!!(o&&o.objectMode),a)this.objectMode=this.objectMode||!!(o&&o.writableObjectMode);this.highWaterMark=o?G(this,o,"writableHighWaterMark",a):M(!1),this.finalCalled=!1,this.needDrain=!1,this.ending=!1,this.ended=!1,this.finished=!1,this.destroyed=!1;const r=!!(o&&o.decodeStrings===!1);this.decodeStrings=!r,this.defaultEncoding=o&&o.defaultEncoding||"utf8",this.length=0,this.writing=!1,this.corked=0,this.sync=!0,this.bufferProcessing=!1,this.onwrite=f.bind(void 0,s),this.writecb=null,this.writelen=0,this.afterWriteTickInfo=null,w(this),this.pendingcb=0,this.constructed=!0,this.prefinished=!1,this.errorEmitted=!1,this.emitClose=!o||o.emitClose!==!1,this.autoDestroy=!o||o.autoDestroy!==!1,this.errored=null,this.closed=!1,this.closeEmitted=!1,this[C]=[]}function w(o){o.buffered=[],o.bufferedIndex=0,o.allBuffers=!0,o.allNoop=!0}D.prototype.getBuffer=function o(){return X(this.buffered,this.bufferedIndex)},K(D.prototype,"bufferedRequestCount",{get(){return this.buffered.length-this.bufferedIndex}}),K(O,z,{value:function(o){if(H(this,o))return!0;if(this!==O)return!1;return o&&o._writableState instanceof D}}),O.prototype.pipe=function(){x(this,new N)};function v(o,s,a,r){const t=o._writableState;if(typeof a==="function")r=a,a=t.defaultEncoding;else{if(!a)a=t.defaultEncoding;else if(a!=="buffer"&&!Buffer.isEncoding(a))throw new P(a);if(typeof r!=="function")r=_}if(s===null)throw new I;else if(!t.objectMode)if(typeof s==="string"){if(t.decodeStrings!==!1)s=Buffer.from(s,a),a="buffer"}else if(s instanceof Buffer)a="buffer";else if(V._isUint8Array(s))s=V._uint8ArrayToBuffer(s),a="buffer";else throw new F("chunk",["string","Buffer","Uint8Array"],s);let e;if(t.ending)e=new T;else if(t.destroyed)e=new A("write");if(e)return Iq(r,e),x(o,e,!0),e;return t.pendingcb++,R(o,t,s,a,r)}O.prototype.write=function(o,s,a){return v(this,o,s,a)===!0},O.prototype.cork=function(){this._writableState.corked++},O.prototype.uncork=function(){const o=this._writableState;if(o.corked){if(o.corked--,!o.writing)p(this,o)}},O.prototype.setDefaultEncoding=function o(s){if(typeof s==="string")s=Y(s);if(!Buffer.isEncoding(s))throw new P(s);return this._writableState.defaultEncoding=s,this};function R(o,s,a,r,t){const e=s.objectMode?1:a.length;s.length+=e;const qq=s.length<s.highWaterMark;if(!qq)s.needDrain=!0;if(s.writing||s.corked||s.errored||!s.constructed){if(s.buffered.push({chunk:a,encoding:r,callback:t}),s.allBuffers&&r!=="buffer")s.allBuffers=!1;if(s.allNoop&&t!==_)s.allNoop=!1}else s.writelen=e,s.writecb=t,s.writing=!0,s.sync=!0,o._write(a,r,s.onwrite),s.sync=!1;return qq&&!s.errored&&!s.destroyed}function S(o,s,a,r,t,e,qq){if(s.writelen=r,s.writecb=qq,s.writing=!0,s.sync=!0,s.destroyed)s.onwrite(new A("write"));else if(a)o._writev(t,s.onwrite);else o._write(t,e,s.onwrite);s.sync=!1}function g(o,s,a,r){--s.pendingcb,r(a),h(s),x(o,a)}function f(o,s){const a=o._writableState,r=a.sync,t=a.writecb;if(typeof t!=="function"){x(o,new j);return}if(a.writing=!1,a.writecb=null,a.length-=a.writelen,a.writelen=0,s){if(Error.captureStackTrace(s),!a.errored)a.errored=s;if(o._readableState&&!o._readableState.errored)o._readableState.errored=s;if(r)Iq(g,o,a,s,t);else g(o,a,s,t)}else{if(a.buffered.length>a.bufferedIndex)p(o,a);if(r)if(a.afterWriteTickInfo!==null&&a.afterWriteTickInfo.cb===t)a.afterWriteTickInfo.count++;else a.afterWriteTickInfo={count:1,cb:t,stream:o,state:a},Iq(k,a.afterWriteTickInfo);else y(o,a,1,t)}}function k({stream:o,state:s,count:a,cb:r}){return s.afterWriteTickInfo=null,y(o,s,a,r)}function y(o,s,a,r){if(!s.ending&&!o.destroyed&&s.length===0&&s.needDrain)s.needDrain=!1,o.emit("drain");while(a-- >0)s.pendingcb--,r();if(s.destroyed)h(s);c(o,s)}function h(o){if(o.writing)return;for(let t=o.bufferedIndex;t<o.buffered.length;++t){var s;const{chunk:e,callback:qq}=o.buffered[t],Qq=o.objectMode?1:e.length;o.length-=Qq,qq((s=o.errored)!==null&&s!==void 0?s:new A("write"))}const a=o[C].splice(0);for(let t=0;t<a.length;t++){var r;a[t]((r=o.errored)!==null&&r!==void 0?r:new A("end"))}w(o)}function p(o,s){if(s.corked||s.bufferProcessing||s.destroyed||!s.constructed)return;const{buffered:a,bufferedIndex:r,objectMode:t}=s,e=a.length-r;if(!e)return;let qq=r;if(s.bufferProcessing=!0,e>1&&o._writev){s.pendingcb-=e-1;const Qq=s.allNoop?_:(Jq)=>{for(let Hq=qq;Hq<a.length;++Hq)a[Hq].callback(Jq)},Xq=s.allNoop&&qq===0?a:X(a,qq);Xq.allBuffers=s.allBuffers,S(o,s,!0,s.length,Xq,"",Qq),w(s)}else{do{const{chunk:Qq,encoding:Xq,callback:Jq}=a[qq];a[qq++]=null;const Hq=t?1:Qq.length;S(o,s,!1,Hq,Qq,Xq,Jq)}while(qq<a.length&&!s.writing);if(qq===a.length)w(s);else if(qq>256)a.splice(0,qq),s.bufferedIndex=0;else s.bufferedIndex=qq}s.bufferProcessing=!1}O.prototype._write=function(o,s,a){if(this._writev)this._writev([{chunk:o,encoding:s}],a);else throw new L("_write()")},O.prototype._writev=null,O.prototype.end=function(o,s,a,r=!1){const t=this._writableState;if(Aq&&Nq("end",t,this.__id),typeof o==="function")a=o,o=null,s=null;else if(typeof s==="function")a=s,s=null;let e;if(o!==null&&o!==void 0){let qq;if(!r)qq=v(this,o,s);else qq=this.write(o,s);if(qq instanceof J)e=qq}if(t.corked)t.corked=1,this.uncork();if(e)this.emit("error",e);else if(!t.errored&&!t.ending)t.ending=!0,c(this,t,!0),t.ended=!0;else if(t.finished)e=new E("end");else if(t.destroyed)e=new A("end");if(typeof a==="function")if(e||t.finished)Iq(a,e);else t[C].push(a);return this};function u(o,s){var a=o.ending&&!o.destroyed&&o.constructed&&o.length===0&&!o.errored&&o.buffered.length===0&&!o.finished&&!o.writing&&!o.errorEmitted&&!o.closeEmitted;return Nq("needFinish",a,s),a}function b(o,s){let a=!1;function r(t){if(a){x(o,t!==null&&t!==void 0?t:j());return}if(a=!0,s.pendingcb--,t){const e=s[C].splice(0);for(let qq=0;qq<e.length;qq++)e[qq](t);x(o,t,s.sync)}else if(u(s))s.prefinished=!0,o.emit("prefinish"),s.pendingcb++,Iq(d,o,s)}s.sync=!0,s.pendingcb++;try{o._final(r)}catch(t){r(t)}s.sync=!1}function m(o,s){if(!s.prefinished&&!s.finalCalled)if(typeof o._final==="function"&&!s.destroyed)s.finalCalled=!0,b(o,s);else s.prefinished=!0,o.emit("prefinish")}function c(o,s,a){if(Aq&&Nq("finishMaybe -- state, sync",s,a,o.__id),!u(s,o.__id))return;if(m(o,s),s.pendingcb===0){if(a)s.pendingcb++,Iq((r,t)=>{if(u(t))d(r,t);else t.pendingcb--},o,s);else if(u(s))s.pendingcb++,d(o,s)}}function d(o,s){s.pendingcb--,s.finished=!0;const a=s[C].splice(0);for(let r=0;r<a.length;r++)a[r]();if(o.emit("finish"),s.autoDestroy){const r=o._readableState;if(!r||r.autoDestroy&&(r.endEmitted||r.readable===!1))o.destroy()}}Z(O.prototype,{closed:{get(){return this._writableState?this._writableState.closed:!1}},destroyed:{get(){return this._writableState?this._writableState.destroyed:!1},set(o){if(this._writableState)this._writableState.destroyed=o}},writable:{get(){const o=this._writableState;return!!o&&o.writable!==!1&&!o.destroyed&&!o.errored&&!o.ending&&!o.ended},set(o){if(this._writableState)this._writableState.writable=!!o}},writableFinished:{get(){return this._writableState?this._writableState.finished:!1}},writableObjectMode:{get(){return this._writableState?this._writableState.objectMode:!1}},writableBuffer:{get(){return this._writableState&&this._writableState.getBuffer()}},writableEnded:{get(){return this._writableState?this._writableState.ending:!1}},writableNeedDrain:{get(){const o=this._writableState;if(!o)return!1;return!o.destroyed&&!o.ending&&o.needDrain}},writableHighWaterMark:{get(){return this._writableState&&this._writableState.highWaterMark}},writableCorked:{get(){return this._writableState?this._writableState.corked:0}},writableLength:{get(){return this._writableState&&this._writableState.length}},errored:{enumerable:!1,get(){return this._writableState?this._writableState.errored:null}},writableAborted:{enumerable:!1,get:function(){return!!(this._writableState.writable!==!1&&(this._writableState.destroyed||this._writableState.errored)&&!this._writableState.finished)}}});var l=U.destroy;O.prototype.destroy=function(o,s){const a=this._writableState;if(!a.destroyed&&(a.bufferedIndex<a.buffered.length||a[C].length))Iq(h,a);return l.call(this,o,s),this},O.prototype._undestroy=U.undestroy,O.prototype._destroy=function(o,s){s(o)},O.prototype[Pq.captureRejectionSymbol]=function(o){this.destroy(o)};var i;function n(){if(i===void 0)i={};return i}O.fromWeb=function(o,s){return n().newStreamWritableFromWritableStream(o,s)},O.toWeb=function(o){return n().newWritableStreamFromStreamWritable(o)}}}),YQ=mq({"node_modules/readable-stream/lib/internal/streams/duplexify.js"(q,Q){var{isReadable:X,isWritable:J,isIterable:H,isNodeStream:K,isReadableNodeStream:Z,isWritableNodeStream:B,isDuplexNodeStream:Y}=aq(),$=rq(),{AbortError:z,codes:{ERR_INVALID_ARG_TYPE:V,ERR_INVALID_RETURN_VALUE:U}}=oq(),{destroyer:W}=eq(),G=Cq(),M=ZQ(),{createDeferredPromise:F}=_q(),L=JQ(),j=typeof Blob!=="undefined"?function T(P){return P instanceof Blob}:function T(P){return!1},{FunctionPrototypeCall:N}=Oq();class A extends G{constructor(T){super(T);if((T===null||T===void 0?void 0:T.readable)===!1)this._readableState.readable=!1,this._readableState.ended=!0,this._readableState.endEmitted=!0;if((T===null||T===void 0?void 0:T.writable)===!1)this._writableState.writable=!1,this._writableState.ending=!0,this._writableState.ended=!0,this._writableState.finished=!0}}Q.exports=function T(P,x){if(Y(P))return P;if(Z(P))return I({readable:P});if(B(P))return I({writable:P});if(K(P))return I({writable:!1,readable:!1});if(typeof P==="function"){const{value:_,write:C,final:D,destroy:w}=E(P);if(H(_))return L(A,_,{objectMode:!0,write:C,final:D,destroy:w});const v=_===null||_===void 0?void 0:_.then;if(typeof v==="function"){let R;const S=N(v,_,(g)=>{if(g!=null)throw new U("nully","body",g)},(g)=>{W(R,g)});return R=new A({objectMode:!0,readable:!1,write:C,final(g){D(async()=>{try{await S,Iq(g,null)}catch(f){Iq(g,f)}})},destroy:w})}throw new U("Iterable, AsyncIterable or AsyncFunction",x,_)}if(j(P))return T(P.arrayBuffer());if(H(P))return L(A,P,{objectMode:!0,writable:!1});if(typeof(P===null||P===void 0?void 0:P.writable)==="object"||typeof(P===null||P===void 0?void 0:P.readable)==="object"){const _=P!==null&&P!==void 0&&P.readable?Z(P===null||P===void 0?void 0:P.readable)?P===null||P===void 0?void 0:P.readable:T(P.readable):void 0,C=P!==null&&P!==void 0&&P.writable?B(P===null||P===void 0?void 0:P.writable)?P===null||P===void 0?void 0:P.writable:T(P.writable):void 0;return I({readable:_,writable:C})}const O=P===null||P===void 0?void 0:P.then;if(typeof O==="function"){let _;return N(O,P,(C)=>{if(C!=null)_.push(C);_.push(null)},(C)=>{W(_,C)}),_=new A({objectMode:!0,writable:!1,read(){}})}throw new V(x,["Blob","ReadableStream","WritableStream","Stream","Iterable","AsyncIterable","Function","{ readable, writable } pair","Promise"],P)};function E(T){let{promise:P,resolve:x}=F();const O=new AbortController,_=O.signal;return{value:T(async function*(){while(!0){const D=P;P=null;const{chunk:w,done:v,cb:R}=await D;if(Iq(R),v)return;if(_.aborted)throw new z(void 0,{cause:_.reason});({promise:P,resolve:x}=F()),yield w}}(),{signal:_}),write(D,w,v){const R=x;x=null,R({chunk:D,done:!1,cb:v})},final(D){const w=x;x=null,w({done:!0,cb:D})},destroy(D,w){O.abort(),w(D)}}}function I(T){const P=T.readable&&typeof T.readable.read!=="function"?M.wrap(T.readable):T.readable,x=T.writable;let O=!!X(P),_=!!J(x),C,D,w,v,R;function S(g){const f=v;if(v=null,f)f(g);else if(g)R.destroy(g);else if(!O&&!_)R.destroy()}if(R=new A({readableObjectMode:!!(P!==null&&P!==void 0&&P.readableObjectMode),writableObjectMode:!!(x!==null&&x!==void 0&&x.writableObjectMode),readable:O,writable:_}),_)$(x,(g)=>{if(_=!1,g)W(P,g);S(g)}),R._write=function(g,f,k){if(x.write(g,f))k();else C=k},R._final=function(g){x.end(),D=g},x.on("drain",function(){if(C){const g=C;C=null,g()}}),x.on("finish",function(){if(D){const g=D;D=null,g()}});if(O)$(P,(g)=>{if(O=!1,g)W(P,g);S(g)}),P.on("readable",function(){if(w){const g=w;w=null,g()}}),P.on("end",function(){R.push(null)}),R._read=function(){while(!0){const g=P.read();if(g===null){w=R._read;return}if(!R.push(g))return}};return R._destroy=function(g,f){if(!g&&v!==null)g=new z;if(w=null,C=null,D=null,v===null)f(g);else v=f,W(x,g),W(P,g)},R}}}),Cq=mq({"node_modules/readable-stream/lib/internal/streams/duplex.js"(q,Q){var{ObjectDefineProperties:X,ObjectGetOwnPropertyDescriptor:J,ObjectKeys:H,ObjectSetPrototypeOf:K}=Oq(),Z=ZQ();function B(U){if(!(this instanceof B))return new B(U);if(Z.call(this,U),Eq.call(this,U),U){if(this.allowHalfOpen=U.allowHalfOpen!==!1,U.readable===!1)this._readableState.readable=!1,this._readableState.ended=!0,this._readableState.endEmitted=!0;if(U.writable===!1)this._writableState.writable=!1,this._writableState.ending=!0,this._writableState.ended=!0,this._writableState.finished=!0}else this.allowHalfOpen=!0}Q.exports=B,K(B.prototype,Z.prototype),K(B,Z);for(var Y in Eq.prototype)if(!B.prototype[Y])B.prototype[Y]=Eq.prototype[Y];X(B.prototype,{writable:J(Eq.prototype,"writable"),writableHighWaterMark:J(Eq.prototype,"writableHighWaterMark"),writableObjectMode:J(Eq.prototype,"writableObjectMode"),writableBuffer:J(Eq.prototype,"writableBuffer"),writableLength:J(Eq.prototype,"writableLength"),writableFinished:J(Eq.prototype,"writableFinished"),writableCorked:J(Eq.prototype,"writableCorked"),writableEnded:J(Eq.prototype,"writableEnded"),writableNeedDrain:J(Eq.prototype,"writableNeedDrain"),destroyed:{get(){if(this._readableState===void 0||this._writableState===void 0)return!1;return this._readableState.destroyed&&this._writableState.destroyed},set(U){if(this._readableState&&this._writableState)this._readableState.destroyed=U,this._writableState.destroyed=U}}});var $;function z(){if($===void 0)$={};return $}B.fromWeb=function(U,W){return z().newStreamDuplexFromReadableWritablePair(U,W)},B.toWeb=function(U){return z().newReadableWritablePairFromDuplex(U)};var V;B.from=function(U){if(!V)V=YQ();return V(U,"body")}}}),$Q=mq({"node_modules/readable-stream/lib/internal/streams/transform.js"(q,Q){var{ObjectSetPrototypeOf:X,Symbol:J}=Oq(),{ERR_METHOD_NOT_IMPLEMENTED:H}=oq().codes,K=Cq();function Z(z){if(!(this instanceof Z))return new Z(z);if(K.call(this,z),this._readableState.sync=!1,this[B]=null,z){if(typeof z.transform==="function")this._transform=z.transform;if(typeof z.flush==="function")this._flush=z.flush}this.on("prefinish",$.bind(this))}X(Z.prototype,K.prototype),X(Z,K),Q.exports=Z;var B=J("kCallback");function Y(z){if(typeof this._flush==="function"&&!this.destroyed)this._flush((V,U)=>{if(V){if(z)z(V);else this.destroy(V);return}if(U!=null)this.push(U);if(this.push(null),z)z()});else if(this.push(null),z)z()}function $(){if(this._final!==Y)Y.call(this)}Z.prototype._final=Y,Z.prototype._transform=function(z,V,U){throw new H("_transform()")},Z.prototype._write=function(z,V,U){const W=this._readableState,G=this._writableState,M=W.length;this._transform(z,V,(F,L)=>{if(F){U(F);return}if(L!=null)this.push(L);if(G.ended||M===W.length||W.length<W.highWaterMark||W.highWaterMark===0||W.length===0)U();else this[B]=U})},Z.prototype._read=function(){if(this[B]){const z=this[B];this[B]=null,z()}}}}),zQ=mq({"node_modules/readable-stream/lib/internal/streams/passthrough.js"(q,Q){var{ObjectSetPrototypeOf:X}=Oq(),J=$Q();function H(K){if(!(this instanceof H))return new H(K);J.call(this,K)}X(H.prototype,J.prototype),X(H,J),H.prototype._transform=function(K,Z,B){B(null,K)},Q.exports=H}}),VQ=mq({"node_modules/readable-stream/lib/internal/streams/pipeline.js"(q,Q){var{ArrayIsArray:X,Promise:J,SymbolAsyncIterator:H}=Oq(),K=rq(),{once:Z}=_q(),B=eq(),Y=Cq(),{aggregateTwoErrors:$,codes:{ERR_INVALID_ARG_TYPE:z,ERR_INVALID_RETURN_VALUE:V,ERR_MISSING_ARGS:U,ERR_STREAM_DESTROYED:W},AbortError:G}=oq(),{validateFunction:M,validateAbortSignal:F}=sq(),{isIterable:L,isReadable:j,isReadableNodeStream:N,isNodeStream:A}=aq(),E,I;function T(v,R,S){let g=!1;v.on("close",()=>{g=!0});const f=K(v,{readable:R,writable:S},(k)=>{g=!k});return{destroy:(k)=>{if(g)return;g=!0,B.destroyer(v,k||new W("pipe"))},cleanup:f}}function P(v){return M(v[v.length-1],"streams[stream.length - 1]"),v.pop()}function x(v){if(L(v))return v;else if(N(v))return O(v);throw new z("val",["Readable","Iterable","AsyncIterable"],v)}async function*O(v){if(!I)I=ZQ();yield*I.prototype[H].call(v)}async function _(v,R,S,{end:g}){let f,k=null;const y=(u)=>{if(u)f=u;if(k){const b=k;k=null,b()}},h=()=>new J((u,b)=>{if(f)b(f);else k=()=>{if(f)b(f);else u()}});R.on("drain",y);const p=K(R,{readable:!1},y);try{if(R.writableNeedDrain)await h();for await(let u of v)if(!R.write(u))await h();if(g)R.end();await h(),S()}catch(u){S(f!==u?$(f,u):u)}finally{p(),R.off("drain",y)}}function C(...v){return D(v,Z(P(v)))}function D(v,R,S){if(v.length===1&&X(v[0]))v=v[0];if(v.length<2)throw new U("streams");const g=new AbortController,f=g.signal,k=S===null||S===void 0?void 0:S.signal,y=[];F(k,"options.signal");function h(){d(new G)}k===null||k===void 0||k.addEventListener("abort",h);let p,u;const b=[];let m=0;function c(n){d(n,--m===0)}function d(n,o){if(n&&(!p||p.code==="ERR_STREAM_PREMATURE_CLOSE"))p=n;if(!p&&!o)return;while(b.length)b.shift()(p);if(k===null||k===void 0||k.removeEventListener("abort",h),g.abort(),o){if(!p)y.forEach((s)=>s());Iq(R,p,u)}}let l;for(let n=0;n<v.length;n++){const o=v[n],s=n<v.length-1,a=n>0,r=s||(S===null||S===void 0?void 0:S.end)!==!1,t=n===v.length-1;if(A(o)){let e=function(qq){if(qq&&qq.name!=="AbortError"&&qq.code!=="ERR_STREAM_PREMATURE_CLOSE")c(qq)};if(r){const{destroy:qq,cleanup:Qq}=T(o,s,a);if(b.push(qq),j(o)&&t)y.push(Qq)}if(o.on("error",e),j(o)&&t)y.push(()=>{o.removeListener("error",e)})}if(n===0)if(typeof o==="function"){if(l=o({signal:f}),!L(l))throw new V("Iterable, AsyncIterable or Stream","source",l)}else if(L(o)||N(o))l=o;else l=Y.from(o);else if(typeof o==="function")if(l=x(l),l=o(l,{signal:f}),s){if(!L(l,!0))throw new V("AsyncIterable",`transform[${n-1}]`,l)}else{var i;if(!E)E=zQ();const e=new E({objectMode:!0}),qq=(i=l)===null||i===void 0?void 0:i.then;if(typeof qq==="function")m++,qq.call(l,(Jq)=>{if(u=Jq,Jq!=null)e.write(Jq);if(r)e.end();Iq(c)},(Jq)=>{e.destroy(Jq),Iq(c,Jq)});else if(L(l,!0))m++,_(l,e,c,{end:r});else throw new V("AsyncIterable or Promise","destination",l);l=e;const{destroy:Qq,cleanup:Xq}=T(l,!1,!0);if(b.push(Qq),t)y.push(Xq)}else if(A(o)){if(N(l)){m+=2;const e=w(l,o,c,{end:r});if(j(o)&&t)y.push(e)}else if(L(l))m++,_(l,o,c,{end:r});else throw new z("val",["Readable","Iterable","AsyncIterable"],l);l=o}else l=Y.from(o)}if(f!==null&&f!==void 0&&f.aborted||k!==null&&k!==void 0&&k.aborted)Iq(h);return l}function w(v,R,S,{end:g}){if(v.pipe(R,{end:g}),g)v.once("end",()=>R.end());else S();return K(v,{readable:!0,writable:!1},(f)=>{const k=v._readableState;if(f&&f.code==="ERR_STREAM_PREMATURE_CLOSE"&&k&&k.ended&&!k.errored&&!k.errorEmitted)v.once("end",S).once("error",S);else S(f)}),K(R,{readable:!1,writable:!0},S)}Q.exports={pipelineImpl:D,pipeline:C}}}),UQ=mq({"node_modules/readable-stream/lib/internal/streams/compose.js"(q,Q){var{pipeline:X}=VQ(),J=Cq(),{destroyer:H}=eq(),{isNodeStream:K,isReadable:Z,isWritable:B}=aq(),{AbortError:Y,codes:{ERR_INVALID_ARG_VALUE:$,ERR_MISSING_ARGS:z}}=oq();Q.exports=function V(...U){if(U.length===0)throw new z("streams");if(U.length===1)return J.from(U[0]);const W=[...U];if(typeof U[0]==="function")U[0]=J.from(U[0]);if(typeof U[U.length-1]==="function"){const P=U.length-1;U[P]=J.from(U[P])}for(let P=0;P<U.length;++P){if(!K(U[P]))continue;if(P<U.length-1&&!Z(U[P]))throw new $(`streams[${P}]`,W[P],"must be readable");if(P>0&&!B(U[P]))throw new $(`streams[${P}]`,W[P],"must be writable")}let G,M,F,L,j;function N(P){const x=L;if(L=null,x)x(P);else if(P)j.destroy(P);else if(!T&&!I)j.destroy()}const A=U[0],E=X(U,N),I=!!B(A),T=!!Z(E);if(j=new J({writableObjectMode:!!(A!==null&&A!==void 0&&A.writableObjectMode),readableObjectMode:!!(E!==null&&E!==void 0&&E.writableObjectMode),writable:I,readable:T}),I)j._write=function(P,x,O){if(A.write(P,x))O();else G=O},j._final=function(P){A.end(),M=P},A.on("drain",function(){if(G){const P=G;G=null,P()}}),E.on("finish",function(){if(M){const P=M;M=null,P()}});if(T)E.on("readable",function(){if(F){const P=F;F=null,P()}}),E.on("end",function(){j.push(null)}),j._read=function(){while(!0){const P=E.read();if(P===null){F=j._read;return}if(!j.push(P))return}};return j._destroy=function(P,x){if(!P&&L!==null)P=new Y;if(F=null,G=null,M=null,L===null)x(P);else L=x,H(E,P)},j}}}),WQ=mq({"node_modules/readable-stream/lib/stream/promises.js"(q,Q){var{ArrayPrototypePop:X,Promise:J}=Oq(),{isIterable:H,isNodeStream:K}=aq(),{pipelineImpl:Z}=VQ(),{finished:B}=rq();function Y(...$){return new J((z,V)=>{let U,W;const G=$[$.length-1];if(G&&typeof G==="object"&&!K(G)&&!H(G)){const M=X($);U=M.signal,W=M.end}Z($,(M,F)=>{if(M)V(M);else z(F)},{signal:U,end:W})})}Q.exports={finished:B,pipeline:Y}}}),GQ=mq({"node_modules/readable-stream/lib/stream.js"(q,Q){var{ObjectDefineProperty:X,ObjectKeys:J,ReflectApply:H}=Oq(),{promisify:{custom:K}}=_q(),{streamReturningOperators:Z,promiseReturningOperators:B}=tq(),{codes:{ERR_ILLEGAL_CONSTRUCTOR:Y}}=oq(),$=UQ(),{pipeline:z}=VQ(),{destroyer:V}=eq(),U=rq(),W=WQ(),G=aq(),M=Q.exports=qQ().Stream;M.isDisturbed=G.isDisturbed,M.isErrored=G.isErrored,M.isWritable=G.isWritable,M.isReadable=G.isReadable,M.Readable=ZQ();for(let L of J(Z)){let j=function(...A){if(new.target)throw Y();return M.Readable.from(H(N,this,A))};const N=Z[L];X(j,"name",{value:N.name}),X(j,"length",{value:N.length}),X(M.Readable.prototype,L,{value:j,enumerable:!1,configurable:!0,writable:!0})}for(let L of J(B)){let j=function(...A){if(new.target)throw Y();return H(N,this,A)};const N=B[L];X(j,"name",{value:N.name}),X(j,"length",{value:N.length}),X(M.Readable.prototype,L,{value:j,enumerable:!1,configurable:!0,writable:!0})}M.Writable=BQ(),M.Duplex=Cq(),M.Transform=$Q(),M.PassThrough=zQ(),M.pipeline=z;var{addAbortSignal:F}=QQ();M.addAbortSignal=F,M.finished=U,M.destroy=V,M.compose=$,X(M,"promises",{configurable:!0,enumerable:!0,get(){return W}}),X(z,K,{enumerable:!0,get(){return W.pipeline}}),X(U,K,{enumerable:!0,get(){return W.finished}}),M.Stream=M,M._isUint8Array=function L(j){return j instanceof Uint8Array},M._uint8ArrayToBuffer=function L(j){return new Buffer(j.buffer,j.byteOffset,j.byteLength)}}}),MQ=mq({"node_modules/readable-stream/lib/ours/index.js"(q,Q){const X=GQ(),J=WQ(),H=X.Readable.destroy;Q.exports=X,Q.exports._uint8ArrayToBuffer=X._uint8ArrayToBuffer,Q.exports._isUint8Array=X._isUint8Array,Q.exports.isDisturbed=X.isDisturbed,Q.exports.isErrored=X.isErrored,Q.exports.isWritable=X.isWritable,Q.exports.isReadable=X.isReadable,Q.exports.Readable=X.Readable,Q.exports.Writable=X.Writable,Q.exports.Duplex=X.Duplex,Q.exports.Transform=X.Transform,Q.exports.PassThrough=X.PassThrough,Q.exports.addAbortSignal=X.addAbortSignal,Q.exports.finished=X.finished,Q.exports.destroy=X.destroy,Q.exports.destroy=H,Q.exports.pipeline=X.pipeline,Q.exports.compose=X.compose,Q.exports._getNativeReadableStreamPrototype=jQ,Q.exports.NativeWritable=pQ,Tq.defineProperty(X,"promises",{configurable:!0,enumerable:!0,get(){return J}}),Q.exports.Stream=X.Stream,Q.exports.default=Q.exports}}),LQ={0:void 0,1:void 0,2:void 0,3:void 0,4:void 0,5:void 0},Eq=BQ(),pQ=class q extends Eq{#q;#Q;#X=!0;_construct;_destroy;_final;constructor(Q,X={}){super(X);this._construct=this.#J,this._destroy=this.#K,this._final=this.#Z,this.#q=Q}#J(Q){this._writableState.constructed=!0,this.constructed=!0,Q()}#H(){if(typeof this.#q==="object")if(typeof this.#q.write==="function")this.#Q=this.#q;else throw new Error("Invalid FileSink");else this.#Q=Bun.file(this.#q).writer()}write(Q,X,J,H=this.#X){if(!H)return this.#X=!1,super.write(Q,X,J);if(!this.#Q)this.#H();var K=this.#Q,Z=K.write(Q);if(xq(Z))return Z.then(()=>{this.emit("drain"),K.flush(!0)}),!1;if(K.flush(!0),J)J(null,Q.byteLength);return!0}end(Q,X,J,H=this.#X){return super.end(Q,X,J,H)}#K(Q,X){if(this._writableState.destroyed=!0,X)X(Q)}#Z(Q){if(this.#Q)this.#Q.end();if(Q)Q()}ref(){if(!this.#Q)this.#H();this.#Q.ref()}unref(){if(!this.#Q)return;this.#Q.unref()}},AQ=MQ();AQ[Symbol.for("CommonJS")]=0;AQ[Symbol.for("::bunternal::")]={_ReadableFromWeb:HQ,_ReadableFromWebForUndici:KQ};var lQ=AQ,EQ=AQ._uint8ArrayToBuffer,IQ=AQ._isUint8Array,TQ=AQ.isDisturbed,PQ=AQ.isErrored,xQ=AQ.isWritable,OQ=AQ.isReadable,_Q=AQ.Readable,Eq=AQ.Writable,CQ=AQ.Duplex,DQ=AQ.Transform,wQ=AQ.PassThrough,vQ=AQ.addAbortSignal,RQ=AQ.finished,SQ=AQ.destroy,gQ=AQ.pipeline,fQ=AQ.compose,kQ=AQ.Stream,yQ=AQ["eos"]=rq,hQ=AQ._getNativeReadableStreamPrototype,pQ=AQ.NativeWritable,uQ=kQ.promises;export{uQ as promises,gQ as pipeline,xQ as isWritable,OQ as isReadable,PQ as isErrored,TQ as isDisturbed,RQ as finished,yQ as eos,SQ as destroy,lQ as default,fQ as compose,vQ as addAbortSignal,EQ as _uint8ArrayToBuffer,IQ as _isUint8Array,hQ as _getNativeReadableStreamPrototype,Eq as Writable,DQ as Transform,kQ as Stream,_Q as Readable,wQ as PassThrough,pQ as NativeWritable,CQ as Duplex}; |