/*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */;const escape=e=>e.replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22");constnormalizeLinefeeds=e=>e.replace(/\r?\n|\r/g,"\r\n");consti=[];consto=newUint8Array([13,10]);u=0;letr=false;for(const[t,A]ofe){if(typeofA==="string"){conste=S.encode(s+`; name="${escape(normalizeLinefeeds(t))}"`+`\r\n\r\n${normalizeLinefeeds(A)}\r\n`);i.push(e);u+=e.byteLength}else{conste=S.encode(`${s}; name="${escape(normalizeLinefeeds(t))}"`+(A.name?`; filename="${escape(A.name)}"`:"")+"\r\n"+`Content-Type: ${A.type||"application/octet-stream"}\r\n\r\n`);i.push(e,A,o);if(typeofA.size==="number"){u+=e.byteLength+A.size+o.byteLength}else{r=true}}}constA=S.encode(`--${t}--`);i.push(A);u+=A.byteLength;if(r){u=null}l=e;c=asyncfunction*(){for(consteofi){if(e.stream){yield*e.stream()}else{yielde}}};p="multipart/form-data; boundary="+t}elseif(A(e)){l=e;u=e.size;if(e.type){p=e.type}}elseif(typeofe[Symbol.asyncIterator]==="function"){if(t){thrownewTypeError("keepalive")}if(o.isDisturbed(e)||e.locked){thrownewTypeError("Response body object should not be disturbed or locked")}i=einstanceofx?e:r(e)}if(typeofl==="string"||o.isBuffer(l)){u=Buffer.byteLength(l)}if(c!=null){lett;i=newx({asyncstart(){t=c(e)[Symbol.asyncIterator]()},asyncpull(e){const{value:s,done:o}=awaitt.next();if(o){queueMicrotask((()=>{e.close()}))}else{if(!I(i)){e.enqueue(newUint8Array(s))}}returne.desiredSize>0},asynccancel(e){awaitt.return()},type:undefined})}constg={stream:i,source:l,length:u};return[g,p]}functionsafelyExtractBody(e,t=false){if(!x){x=s(3774).ReadableStream}if(einstanceofx){B(!o.isDisturbed(e),"The body has already been consumed.");B(!e.locked,"The stream is locked.")}returnextractBody(e,t)}functioncloneBody(e){const[t,s]=e.stream.tee();consti=h(s,{transfer:[s]});const[,o]=i.tee();e.stream=t;return{stream:o,length:e.length,source:e.source}}asyncfunction*consumeBody(e){if(e){if(b(e)){yielde}else{constt=e.stream;if(o.isDisturbed(t)){thrownewTypeError("The body has already been consumed.")}if(t.locked){thrownewTypeError("The stream is locked.")}t[Q]=true;yield*t}}}functionthrowIfAborted(e){if(e.aborted){thrownewd("The operation was aborted.","AbortError")}}functionbodyMixinMethods(e){constt={blob(){returnspecConsumeBody(this,(e=>{lett=bodyMimeType(this);if(t==="failure"){t=""}elseif(t){t=k(t)}returnnewE([e],{type:t})}),e)},arrayBuffer(){returnspecConsumeBody(this,(e=>newUint8Array(e).buffer),e)},text(){returnspecConsumeBody(this,utf8DecodeBytes,e)},json(){returnspecConsumeBody(this,parseJSONFromBytes,e)},asyncformData(){g.brandCheck(this,e);throwIfAborted(this[p]);constt=this.headers.get("Content-Type");if(/multipart\/form-data/.test(t)){conste={};for(const[t,s]ofthis.headers)e[t.toLowerCase()]=s;constt=newu;lets;try{s=newi({headers:e,preservePath:true})}catch(e){thrownewd(`${e}`,"AbortError")}s.on("field",((e,s)=>{t.append(e,s)}));s.on("file",((e,s,i,o,r)=>{constA=[];if(o==="base64"||o.toLowerCase()==="base64"){leto="";s.on("data",(e=>{o+=e.toString().replace(/[\r\n]/gm,"");constt=o.length-o.length%4;A.push(Buffer.from(o.slice(0,t),"base64"));o=o.slice(t)}));s.on("end",(()=>{A.push(Buffer.from(o,"base64"));t.append(e,newD(A,i,{type:r}))}))}else{s.on("data",(e=>{A.push(e)}));s.on("end",(()=>{t.append(e,newD(A,i,{type:r}))}))}}));consto=newPromise(((e,t)=>{s.on("finish",e);s.on("error",(e=>t(newTypeError(e))))}));if(this.body!==null)forawait(consteofconsumeBody(this[p].body))s.write(e);s.end();awaito;returnt}elseif(/application\/x-www-form-urlencoded/.test(t)){lete;try{lett="";consts=newTextDecoder("utf-8",{ignoreBOM:true});forawait(consteofconsumeBody(this[p].body)){if(!b(e)){thrownewTypeError("Expected Uint8Array chunk")}t+=s.decode(e,{stream:true})}t+=s.decode();e=newURLSearchParams(t)}catch(e){throwObject.assign(newTypeError,{cause:e})}constt=newu;for(const[s,i]ofe){t.append(s,i)}returnt}else{awaitPromise.resolve();throwIfAborted(this[p]);throwg.errors.exception({he
/*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> */r[o-4]=this.maskKey[0];r[o-3]=this.maskKey[1];r[o-2]=this.maskKey[2];r[o-1]=this.maskKey[3];r[1]=s;if(s===126){r.writeUInt16BE(t,2)}elseif(s===127){r[2]=r[3]=0;r.writeUIntBE(t,4,6)}r[1]|=128;for(lete=0;e<t;e++){r[o+e]=this.frameData[e]^this.maskKey[e%4]}returnr}}e.exports={WebsocketFrameSend:WebsocketFrameSend}},3171:(e,t,s)=>{"use strict";const{Writable:i}=s(2203);consto=s(1637);const{parserStates:r,opcodes:A,states:n,emptyBuffer:a}=s(5913);const{kReadyState:c,kSentClose:l,kResponse:u,kReceivedClose:p}=s(2933);const{isValidStatusCode:g,failWebsocketConnection:d,websocketMessageReceived:h}=s(3574);const{WebsocketFrameSend:E}=s(1237);constC={};C.ping=o.channel("undici:websocket:ping");C.pong=o.channel("undici:websocket:pong");classByteParserextendsi{#A=[];#n=0;#a=r.INFO;#c={};#l=[];constructor(e){super();this.ws=e}_write(e,t,s){this.#A.push(e);this.#n+=e.length;this.run(s)}run(e){while(true){if(this.#a===r.INFO){if(this.#n<2){returne()}constt=this.consume(2);this.#c.fin=(t[0]&128)!==0;this.#c.opcode=t[0]&15;this.#c.originalOpcode??=this.#c.opcode;this.#c.fragmented=!this.#c.fin&&this.#c.opcode!==A.CONTINUATION;if(this.#c.fragmented&&this.#c.opcode!==A.BINARY&&this.#c.opcode!==A.TEXT){d(this.ws,"Invalid frame type was fragmented.");return}consts=t[1]&127;if(s<=125){this.#c.payloadLength=s;this.#a=r.READ_DATA}elseif(s===126){this.#a=r.PAYLOADLENGTH_16}elseif(s===127){this.#a=r.PAYLOADLENGTH_64}if(this.#c.fragmented&&s>125){d(this.ws,"Fragmented frame exceeded 125 bytes.");return}elseif((this.#c.opcode===A.PING||this.#c.opcode===A.PONG||this.#c.opcode===A.CLOSE)&&s>125){d(this.ws,"Payload length for control frame exceeded 125 bytes.");return}elseif(this.#c.opcode===A.CLOSE){if(s===1){d(this.ws,"Received close frame with a 1-byte body.");return}conste=this.consume(s);this.#c.closeInfo=this.parseCloseBody(false,e);if(!this.ws[l]){conste=Buffer.allocUnsafe(2);e.writeUInt16BE(this.#c.closeInfo.code,0);constt=newE(e);this.ws[u].socket.write(t.createFrame(A.CLOSE),(e=>{if(!e){this.ws[l]=true}}))}this.ws[c]=n.CLOSING;this.ws[p]=true;this.end();return}elseif(this.#c.opcode===A.PING){constt=this.consume(s);if(!this.ws[p]){conste=newE(t);this.ws[u].socket.write(e.createFrame(A.PONG));if(C.ping.hasSubscribers){C.ping.publish({payload:t})}}this.#a=r.INFO;if(this.#n>0){continue}else{e();return}}elseif(this.#c.opcode===A.PONG){constt=this.consume(s);if(C.pong.hasSubscribers){C.pong.publish({payload:t})}if(this.#n>0){continue}else{e();return}}}elseif(this.#a===r.PAYLOADLENGTH_16){if(this.#n<2){returne()}constt=this.consume(2);this.#c.payloadLength=t.readUInt16BE(0);this.#a=r.READ_DATA}elseif(this.#a===r.PAYLOADLENGTH_64){if(this.#n<8){returne()}constt=this.consume(8);consts=t.readUInt32BE(0);if(s>2**31-1){d(this.ws,"Received payload length > 2^31 bytes.");return}consti=t.readUInt32BE(4);this.#c.payloadLength=(s<<8)+i;this.#a=r.READ_DATA}elseif(this.#a===r.READ_DATA){if(this.#n<this.#c.payloadLength){returne()}elseif(this.#n>=this.#c.payloadLength){conste=this.consume(this.#c.payloadLength);this.#l.push(e);if(!this.#c.fragmented||this.#c.fin&&this.#c.opcode===A.CONTINUATION){conste=Buffer.concat(this.#l);h(this.ws,this.#c.originalOpcode,e);this.#c={};this.#l.length=0}this.#a=r.INFO}}if(this.#n>0){continue}else{e();break}}}consume(e){if(e>this.#n){returnnull}elseif(e===0){returna}if(this.#A[0].length===e){this.#n-=this.#A[0].length;returnthis.#A.shift()}constt=Buffer.allocUnsafe(e);lets=0;while(s!==e){consti=this.#A[0];const{length:o}=i;if(o+s===e){t.set(this.#A.shift(),s);break}elseif(o+s>e){t.set(i.subarray(0,e-s),s);this.#A[0]=i.subarray(e-s);break}else{t.set(this.#A.shift(),s);s+=i.length}}this.#n-=e;returnt}parseCloseBody(e,t){lets;if(t.length>=2){s=t.readUInt16BE(0)}if(e){if(!g(s)){returnnull}return{code:s}}leti=t.subarray(2);if(i[0]===239&&i[1]===187&&i[2]===191){i=i.subarray(3)}if(s!==undefined&&!g(s)){returnnull}try{i=newTextDecoder("utf-8",{fatal:true}).decode(i)}catch{returnnull}return{code:s,reason:i}}getclosingIn
