"use strict";var no=Object.create;var Ie=Object.defineProperty;var io=Object.getOwnPropertyDescriptor;var so=Object.getOwnPropertyNames;var oo=Object.getPrototypeOf,ao=Object.prototype.hasOwnProperty;var uo=(r,e,t)=>e in r?Ie(r,e,{enumerable:!0,configurable:!0,writable:!0,value:t}): r[e]=t;var a=(r,e)=>Ie(r,"name",{value:e,configurable:!0});var z=(r,e)=>()=>(r&&(e=r(r=0)),e);var I=(r,e)=>()=>(e||r((e={exports:{}}).exports,e),e.exports),te=(r,e)=>{for(var t in e) Ie(r,t,{get:e[t],enumerable:!0})},In=(r,e,t,n)=>{if(e&&typeof e=="object"||typeof e== "function")for(let i of so(e))!ao.call(r,i)&&i!==t&&Ie(r,i,{get:()=>e[i],enumerable:!(n= io(e,i))||n.enumerable});return r};var Pe=(r,e,t)=>(t=r!=null?no(oo(r)):{},In(e||!r||!r.__esModule?Ie(t,"default",{ value:r,enumerable:!0}):t,r)),N=r=>In(Ie({},"__esModule",{value:!0}),r);var _=(r,e,t)=>uo(r,typeof e!="symbol"?e+"":e,t);var Ln=I(it=>{"use strict";p();it.byteLength=ho;it.toByteArray=fo;it.fromByteArray= mo;var oe=[],re=[],co=typeof Uint8Array<"u"?Uint8Array:Array,Rt="ABCDEFGHIJKLMNO\ PQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";for(Ae=0,Pn=Rt.length;Ae0)throw new Error("Invalid string. Length must be a multip\ le of 4");var t=r.indexOf("=");t===-1&&(t=e);var n=t===e?0:4-t%4;return[t,n]}a(Bn, "getLens");function ho(r){var e=Bn(r),t=e[0],n=e[1];return(t+n)*3/4-n}a(ho,"byte\ Length");function lo(r,e,t){return(e+t)*3/4-t}a(lo,"_byteLength");function fo(r){ var e,t=Bn(r),n=t[0],i=t[1],s=new co(lo(r,n,i)),o=0,u=i>0?n-4:n,c;for(c=0;c>16&255,s[o++]=e>>8&255,s[o++]=e&255;return i===2&&(e= re[r.charCodeAt(c)]<<2|re[r.charCodeAt(c+1)]>>4,s[o++]=e&255),i===1&&(e=re[r.charCodeAt( c)]<<10|re[r.charCodeAt(c+1)]<<4|re[r.charCodeAt(c+2)]>>2,s[o++]=e>>8&255,s[o++]= e&255),s}a(fo,"toByteArray");function po(r){return oe[r>>18&63]+oe[r>>12&63]+oe[r>> 6&63]+oe[r&63]}a(po,"tripletToBase64");function yo(r,e,t){for(var n,i=[],s=e;su?u:o+s));return n===1?(e=r[t-1],i.push(oe[e>>2]+ oe[e<<4&63]+"==")):n===2&&(e=(r[t-2]<<8)+r[t-1],i.push(oe[e>>10]+oe[e>>4&63]+oe[e<< 2&63]+"=")),i.join("")}a(mo,"fromByteArray")});var Rn=I(Ft=>{p();Ft.read=function(r,e,t,n,i){var s,o,u=i*8-n-1,c=(1<> 1,l=-7,d=t?i-1:0,b=t?-1:1,C=r[e+d];for(d+=b,s=C&(1<<-l)-1,C>>=-l,l+=u;l>0;s=s*256+ r[e+d],d+=b,l-=8);for(o=s&(1<<-l)-1,s>>=-l,l+=n;l>0;o=o*256+r[e+d],d+=b,l-=8);if(s=== 0)s=1-h;else{if(s===c)return o?NaN:(C?-1:1)*(1/0);o=o+Math.pow(2,n),s=s-h}return(C? -1:1)*o*Math.pow(2,s-n)};Ft.write=function(r,e,t,n,i,s){var o,u,c,h=s*8-i-1,l=(1<< h)-1,d=l>>1,b=i===23?Math.pow(2,-24)-Math.pow(2,-77):0,C=n?0:s-1,B=n?1:-1,j=e<0|| e===0&&1/e<0?1:0;for(e=Math.abs(e),isNaN(e)||e===1/0?(u=isNaN(e)?1:0,o=l):(o=Math. floor(Math.log(e)/Math.LN2),e*(c=Math.pow(2,-o))<1&&(o--,c*=2),o+d>=1?e+=b/c:e+= b*Math.pow(2,1-d),e*c>=2&&(o++,c/=2),o+d>=l?(u=0,o=l):o+d>=1?(u=(e*c-1)*Math.pow( 2,i),o=o+d):(u=e*Math.pow(2,d-1)*Math.pow(2,i),o=0));i>=8;r[t+C]=u&255,C+=B,u/=256, i-=8);for(o=o<0;r[t+C]=o&255,C+=B,o/=256,h-=8);r[t+C-B]|=j*128}});var zn=I(Fe=>{"use strict";p();var Mt=Ln(),Le=Rn(),Fn=typeof Symbol=="function"&& typeof Symbol.for=="function"?Symbol.for("nodejs.util.inspect.custom"):null;Fe.Buffer= f;Fe.SlowBuffer=xo;Fe.INSPECT_MAX_BYTES=50;var st=2147483647;Fe.kMaxLength=st;f. TYPED_ARRAY_SUPPORT=go();!f.TYPED_ARRAY_SUPPORT&&typeof console<"u"&&typeof console. error=="function"&&console.error("This browser lacks typed array (Uint8Array) su\ pport which is required by `buffer` v5.x. Use `buffer` v4.x if you require old b\ rowser support.");function go(){try{let r=new Uint8Array(1),e={foo:a(function(){ return 42},"foo")};return Object.setPrototypeOf(e,Uint8Array.prototype),Object.setPrototypeOf( r,e),r.foo()===42}catch{return!1}}a(go,"typedArraySupport");Object.defineProperty( f.prototype,"parent",{enumerable:!0,get:a(function(){if(f.isBuffer(this))return this. buffer},"get")});Object.defineProperty(f.prototype,"offset",{enumerable:!0,get:a( function(){if(f.isBuffer(this))return this.byteOffset},"get")});function fe(r){if(r> st)throw new RangeError('The value "'+r+'" is invalid for option "size"');let e=new Uint8Array( r);return Object.setPrototypeOf(e,f.prototype),e}a(fe,"createBuffer");function f(r,e,t){ if(typeof r=="number"){if(typeof e=="string")throw new TypeError('The "string" a\ rgument must be of type string. Received type number');return Ut(r)}return On(r, e,t)}a(f,"Buffer");f.poolSize=8192;function On(r,e,t){if(typeof r=="string")return bo( r,e);if(ArrayBuffer.isView(r))return So(r);if(r==null)throw new TypeError("The f\ irst argument must be one of type string, Buffer, ArrayBuffer, Array, or Array-l\ ike Object. Received type "+typeof r);if(ae(r,ArrayBuffer)||r&&ae(r.buffer,ArrayBuffer)|| typeof SharedArrayBuffer<"u"&&(ae(r,SharedArrayBuffer)||r&&ae(r.buffer,SharedArrayBuffer))) return kt(r,e,t);if(typeof r=="number")throw new TypeError('The "value" argument\ must not be of type number. Received type number');let n=r.valueOf&&r.valueOf(); if(n!=null&&n!==r)return f.from(n,e,t);let i=Eo(r);if(i)return i;if(typeof Symbol< "u"&&Symbol.toPrimitive!=null&&typeof r[Symbol.toPrimitive]=="function")return f. from(r[Symbol.toPrimitive]("string"),e,t);throw new TypeError("The first argumen\ t must be one of type string, Buffer, ArrayBuffer, Array, or Array-like Object. \ Received type "+typeof r)}a(On,"from");f.from=function(r,e,t){return On(r,e,t)}; Object.setPrototypeOf(f.prototype,Uint8Array.prototype);Object.setPrototypeOf(f, Uint8Array);function Un(r){if(typeof r!="number")throw new TypeError('"size" arg\ ument must be of type number');if(r<0)throw new RangeError('The value "'+r+'" is\ invalid for option "size"')}a(Un,"assertSize");function wo(r,e,t){return Un(r), r<=0?fe(r):e!==void 0?typeof t=="string"?fe(r).fill(e,t):fe(r).fill(e):fe(r)}a(wo, "alloc");f.alloc=function(r,e,t){return wo(r,e,t)};function Ut(r){return Un(r),fe( r<0?0:Nt(r)|0)}a(Ut,"allocUnsafe");f.allocUnsafe=function(r){return Ut(r)};f.allocUnsafeSlow= function(r){return Ut(r)};function bo(r,e){if((typeof e!="string"||e==="")&&(e="\ utf8"),!f.isEncoding(e))throw new TypeError("Unknown encoding: "+e);let t=Nn(r,e)| 0,n=fe(t),i=n.write(r,e);return i!==t&&(n=n.slice(0,i)),n}a(bo,"fromString");function Dt(r){ let e=r.length<0?0:Nt(r.length)|0,t=fe(e);for(let n=0;n= st)throw new RangeError("Attempt to allocate Buffer larger than maximum size: 0x"+ st.toString(16)+" bytes");return r|0}a(Nt,"checked");function xo(r){return+r!=r&& (r=0),f.alloc(+r)}a(xo,"SlowBuffer");f.isBuffer=a(function(e){return e!=null&&e. _isBuffer===!0&&e!==f.prototype},"isBuffer");f.compare=a(function(e,t){if(ae(e,Uint8Array)&& (e=f.from(e,e.offset,e.byteLength)),ae(t,Uint8Array)&&(t=f.from(t,t.offset,t.byteLength)), !f.isBuffer(e)||!f.isBuffer(t))throw new TypeError('The "buf1", "buf2" arguments\ must be one of type Buffer or Uint8Array');if(e===t)return 0;let n=e.length,i=t. length;for(let s=0,o=Math.min(n,i);si.length?(f.isBuffer( o)||(o=f.from(o)),o.copy(i,s)):Uint8Array.prototype.set.call(i,o,s);else if(f.isBuffer( o))o.copy(i,s);else throw new TypeError('"list" argument must be an Array of Buf\ fers');s+=o.length}return i},"concat");function Nn(r,e){if(f.isBuffer(r))return r. length;if(ArrayBuffer.isView(r)||ae(r,ArrayBuffer))return r.byteLength;if(typeof r!= "string")throw new TypeError('The "string" argument must be one of type string, \ Buffer, or ArrayBuffer. Received type '+typeof r);let t=r.length,n=arguments.length> 2&&arguments[2]===!0;if(!n&&t===0)return 0;let i=!1;for(;;)switch(e){case"ascii":case"\ latin1":case"binary":return t;case"utf8":case"utf-8":return Ot(r).length;case"uc\ s2":case"ucs-2":case"utf16le":case"utf-16le":return t*2;case"hex":return t>>>1;case"\ base64":return Kn(r).length;default:if(i)return n?-1:Ot(r).length;e=(""+e).toLowerCase(), i=!0}}a(Nn,"byteLength");f.byteLength=Nn;function vo(r,e,t){let n=!1;if((e===void 0|| e<0)&&(e=0),e>this.length||((t===void 0||t>this.length)&&(t=this.length),t<=0)|| (t>>>=0,e>>>=0,t<=e))return"";for(r||(r="utf8");;)switch(r){case"hex":return Fo( this,e,t);case"utf8":case"utf-8":return Qn(this,e,t);case"ascii":return Lo(this, e,t);case"latin1":case"binary":return Ro(this,e,t);case"base64":return Po(this,e, t);case"ucs2":case"ucs-2":case"utf16le":case"utf-16le":return Mo(this,e,t);default: if(n)throw new TypeError("Unknown encoding: "+r);r=(r+"").toLowerCase(),n=!0}}a( vo,"slowToString");f.prototype._isBuffer=!0;function Ce(r,e,t){let n=r[e];r[e]=r[t], r[t]=n}a(Ce,"swap");f.prototype.swap16=a(function(){let e=this.length;if(e%2!==0) throw new RangeError("Buffer size must be a multiple of 16-bits");for(let t=0;t< e;t+=2)Ce(this,t,t+1);return this},"swap16");f.prototype.swap32=a(function(){let e=this. length;if(e%4!==0)throw new RangeError("Buffer size must be a multiple of 32-bit\ s");for(let t=0;tt&&(e+=" ... "),""},"inspect");Fn&&(f.prototype[Fn]=f.prototype.inspect);f.prototype.compare= a(function(e,t,n,i,s){if(ae(e,Uint8Array)&&(e=f.from(e,e.offset,e.byteLength)),!f. isBuffer(e))throw new TypeError('The "target" argument must be one of type Buffe\ r or Uint8Array. Received type '+typeof e);if(t===void 0&&(t=0),n===void 0&&(n=e? e.length:0),i===void 0&&(i=0),s===void 0&&(s=this.length),t<0||n>e.length||i<0|| s>this.length)throw new RangeError("out of range index");if(i>=s&&t>=n)return 0; if(i>=s)return-1;if(t>=n)return 1;if(t>>>=0,n>>>=0,i>>>=0,s>>>=0,this===e)return 0; let o=s-i,u=n-t,c=Math.min(o,u),h=this.slice(i,s),l=e.slice(t,n);for(let d=0;d2147483647?t=2147483647: t<-2147483648&&(t=-2147483648),t=+t,Qt(t)&&(t=i?0:r.length-1),t<0&&(t=r.length+t), t>=r.length){if(i)return-1;t=r.length-1}else if(t<0)if(i)t=0;else return-1;if(typeof e== "string"&&(e=f.from(e,n)),f.isBuffer(e))return e.length===0?-1:Mn(r,e,t,n,i);if(typeof e== "number")return e=e&255,typeof Uint8Array.prototype.indexOf=="function"?i?Uint8Array. prototype.indexOf.call(r,e,t):Uint8Array.prototype.lastIndexOf.call(r,e,t):Mn(r, [e],t,n,i);throw new TypeError("val must be string, number or Buffer")}a(qn,"bid\ irectionalIndexOf");function Mn(r,e,t,n,i){let s=1,o=r.length,u=e.length;if(n!== void 0&&(n=String(n).toLowerCase(),n==="ucs2"||n==="ucs-2"||n==="utf16le"||n==="\ utf-16le")){if(r.length<2||e.length<2)return-1;s=2,o/=2,u/=2,t/=2}function c(l,d){ return s===1?l[d]:l.readUInt16BE(d*s)}a(c,"read");let h;if(i){let l=-1;for(h=t;h< o;h++)if(c(r,h)===c(e,l===-1?0:h-l)){if(l===-1&&(l=h),h-l+1===u)return l*s}else l!== -1&&(h-=h-l),l=-1}else for(t+u>o&&(t=o-u),h=t;h>=0;h--){let l=!0;for(let d=0;di&&(n=i)):n=i;let s=e.length;n> s/2&&(n=s/2);let o;for(o=0;o>>0,isFinite(n)? (n=n>>>0,i===void 0&&(i="utf8")):(i=n,n=void 0);else throw new Error("Buffer.wri\ te(string, encoding, offset[, length]) is no longer supported");let s=this.length- t;if((n===void 0||n>s)&&(n=s),e.length>0&&(n<0||t<0)||t>this.length)throw new RangeError( "Attempt to write outside buffer bounds");i||(i="utf8");let o=!1;for(;;)switch(i){case"\ hex":return _o(this,e,t,n);case"utf8":case"utf-8":return Ao(this,e,t,n);case"asc\ ii":case"latin1":case"binary":return Co(this,e,t,n);case"base64":return To(this, e,t,n);case"ucs2":case"ucs-2":case"utf16le":case"utf-16le":return Io(this,e,t,n);default: if(o)throw new TypeError("Unknown encoding: "+i);i=(""+i).toLowerCase(),o=!0}},"\ write");f.prototype.toJSON=a(function(){return{type:"Buffer",data:Array.prototype. slice.call(this._arr||this,0)}},"toJSON");function Po(r,e,t){return e===0&&t===r. length?Mt.fromByteArray(r):Mt.fromByteArray(r.slice(e,t))}a(Po,"base64Slice");function Qn(r,e,t){ t=Math.min(r.length,t);let n=[],i=e;for(;i239?4:s>223? 3:s>191?2:1;if(i+u<=t){let c,h,l,d;switch(u){case 1:s<128&&(o=s);break;case 2:c= r[i+1],(c&192)===128&&(d=(s&31)<<6|c&63,d>127&&(o=d));break;case 3:c=r[i+1],h=r[i+ 2],(c&192)===128&&(h&192)===128&&(d=(s&15)<<12|(c&63)<<6|h&63,d>2047&&(d<55296|| d>57343)&&(o=d));break;case 4:c=r[i+1],h=r[i+2],l=r[i+3],(c&192)===128&&(h&192)=== 128&&(l&192)===128&&(d=(s&15)<<18|(c&63)<<12|(h&63)<<6|l&63,d>65535&&d<1114112&& (o=d))}}o===null?(o=65533,u=1):o>65535&&(o-=65536,n.push(o>>>10&1023|55296),o=56320| o&1023),n.push(o),i+=u}return Bo(n)}a(Qn,"utf8Slice");var Dn=4096;function Bo(r){ let e=r.length;if(e<=Dn)return String.fromCharCode.apply(String,r);let t="",n=0; for(;nn)&&(t=n);let i="";for(let s=e;sn&&(e=n),t<0?(t+=n,t<0&&(t=0)):t>n&&(t=n),tt)throw new RangeError( "Trying to access beyond buffer length")}a(q,"checkOffset");f.prototype.readUintLE= f.prototype.readUIntLE=a(function(e,t,n){e=e>>>0,t=t>>>0,n||q(e,t,this.length);let i=this[e], s=1,o=0;for(;++o>>0,t=t>>>0,n||q(e,t,this. length);let i=this[e+--t],s=1;for(;t>0&&(s*=256);)i+=this[e+--t]*s;return i},"re\ adUIntBE");f.prototype.readUint8=f.prototype.readUInt8=a(function(e,t){return e= e>>>0,t||q(e,1,this.length),this[e]},"readUInt8");f.prototype.readUint16LE=f.prototype. readUInt16LE=a(function(e,t){return e=e>>>0,t||q(e,2,this.length),this[e]|this[e+ 1]<<8},"readUInt16LE");f.prototype.readUint16BE=f.prototype.readUInt16BE=a(function(e,t){ return e=e>>>0,t||q(e,2,this.length),this[e]<<8|this[e+1]},"readUInt16BE");f.prototype. readUint32LE=f.prototype.readUInt32LE=a(function(e,t){return e=e>>>0,t||q(e,4,this. length),(this[e]|this[e+1]<<8|this[e+2]<<16)+this[e+3]*16777216},"readUInt32LE"); f.prototype.readUint32BE=f.prototype.readUInt32BE=a(function(e,t){return e=e>>>0, t||q(e,4,this.length),this[e]*16777216+(this[e+1]<<16|this[e+2]<<8|this[e+3])},"\ readUInt32BE");f.prototype.readBigUInt64LE=we(a(function(e){e=e>>>0,Re(e,"offset"); let t=this[e],n=this[e+7];(t===void 0||n===void 0)&&We(e,this.length-8);let i=t+ this[++e]*2**8+this[++e]*2**16+this[++e]*2**24,s=this[++e]+this[++e]*2**8+this[++e]* 2**16+n*2**24;return BigInt(i)+(BigInt(s)<>>0,Re(e,"offset");let t=this[e],n=this[e+7]; (t===void 0||n===void 0)&&We(e,this.length-8);let i=t*2**24+this[++e]*2**16+this[++e]* 2**8+this[++e],s=this[++e]*2**24+this[++e]*2**16+this[++e]*2**8+n;return(BigInt( i)<>>0,t=t>>>0,n||q(e,t,this.length);let i=this[e],s=1,o=0;for(;++o=s&&(i-=Math.pow(2,8*t)),i},"readIntLE");f.prototype. readIntBE=a(function(e,t,n){e=e>>>0,t=t>>>0,n||q(e,t,this.length);let i=t,s=1,o=this[e+ --i];for(;i>0&&(s*=256);)o+=this[e+--i]*s;return s*=128,o>=s&&(o-=Math.pow(2,8*t)), o},"readIntBE");f.prototype.readInt8=a(function(e,t){return e=e>>>0,t||q(e,1,this. length),this[e]&128?(255-this[e]+1)*-1:this[e]},"readInt8");f.prototype.readInt16LE= a(function(e,t){e=e>>>0,t||q(e,2,this.length);let n=this[e]|this[e+1]<<8;return n& 32768?n|4294901760:n},"readInt16LE");f.prototype.readInt16BE=a(function(e,t){e=e>>> 0,t||q(e,2,this.length);let n=this[e+1]|this[e]<<8;return n&32768?n|4294901760:n}, "readInt16BE");f.prototype.readInt32LE=a(function(e,t){return e=e>>>0,t||q(e,4,this. length),this[e]|this[e+1]<<8|this[e+2]<<16|this[e+3]<<24},"readInt32LE");f.prototype. readInt32BE=a(function(e,t){return e=e>>>0,t||q(e,4,this.length),this[e]<<24|this[e+ 1]<<16|this[e+2]<<8|this[e+3]},"readInt32BE");f.prototype.readBigInt64LE=we(a(function(e){ e=e>>>0,Re(e,"offset");let t=this[e],n=this[e+7];(t===void 0||n===void 0)&&We(e, this.length-8);let i=this[e+4]+this[e+5]*2**8+this[e+6]*2**16+(n<<24);return(BigInt( i)<>>0,Re(e,"offset"); let t=this[e],n=this[e+7];(t===void 0||n===void 0)&&We(e,this.length-8);let i=(t<< 24)+this[++e]*2**16+this[++e]*2**8+this[++e];return(BigInt(i)<>>0,t||q(e,4,this.length),Le.read(this,e, !0,23,4)},"readFloatLE");f.prototype.readFloatBE=a(function(e,t){return e=e>>>0, t||q(e,4,this.length),Le.read(this,e,!1,23,4)},"readFloatBE");f.prototype.readDoubleLE= a(function(e,t){return e=e>>>0,t||q(e,8,this.length),Le.read(this,e,!0,52,8)},"r\ eadDoubleLE");f.prototype.readDoubleBE=a(function(e,t){return e=e>>>0,t||q(e,8,this. length),Le.read(this,e,!1,52,8)},"readDoubleBE");function Y(r,e,t,n,i,s){if(!f.isBuffer( r))throw new TypeError('"buffer" argument must be a Buffer instance');if(e>i||e< s)throw new RangeError('"value" argument is out of bounds');if(t+n>r.length)throw new RangeError( "Index out of range")}a(Y,"checkInt");f.prototype.writeUintLE=f.prototype.writeUIntLE= a(function(e,t,n,i){if(e=+e,t=t>>>0,n=n>>>0,!i){let u=Math.pow(2,8*n)-1;Y(this,e, t,n,u,0)}let s=1,o=0;for(this[t]=e&255;++o>>0,n=n>>>0,!i){let u=Math.pow(2,8*n)-1;Y(this,e,t,n,u,0)}let s=n-1, o=1;for(this[t+s]=e&255;--s>=0&&(o*=256);)this[t+s]=e/o&255;return t+n},"writeUI\ ntBE");f.prototype.writeUint8=f.prototype.writeUInt8=a(function(e,t,n){return e= +e,t=t>>>0,n||Y(this,e,t,1,255,0),this[t]=e&255,t+1},"writeUInt8");f.prototype.writeUint16LE= f.prototype.writeUInt16LE=a(function(e,t,n){return e=+e,t=t>>>0,n||Y(this,e,t,2, 65535,0),this[t]=e&255,this[t+1]=e>>>8,t+2},"writeUInt16LE");f.prototype.writeUint16BE= f.prototype.writeUInt16BE=a(function(e,t,n){return e=+e,t=t>>>0,n||Y(this,e,t,2, 65535,0),this[t]=e>>>8,this[t+1]=e&255,t+2},"writeUInt16BE");f.prototype.writeUint32LE= f.prototype.writeUInt32LE=a(function(e,t,n){return e=+e,t=t>>>0,n||Y(this,e,t,4, 4294967295,0),this[t+3]=e>>>24,this[t+2]=e>>>16,this[t+1]=e>>>8,this[t]=e&255,t+ 4},"writeUInt32LE");f.prototype.writeUint32BE=f.prototype.writeUInt32BE=a(function(e,t,n){ return e=+e,t=t>>>0,n||Y(this,e,t,4,4294967295,0),this[t]=e>>>24,this[t+1]=e>>>16, this[t+2]=e>>>8,this[t+3]=e&255,t+4},"writeUInt32BE");function jn(r,e,t,n,i){Vn( e,n,i,r,t,7);let s=Number(e&BigInt(4294967295));r[t++]=s,s=s>>8,r[t++]=s,s=s>>8, r[t++]=s,s=s>>8,r[t++]=s;let o=Number(e>>BigInt(32)&BigInt(4294967295));return r[t++]= o,o=o>>8,r[t++]=o,o=o>>8,r[t++]=o,o=o>>8,r[t++]=o,t}a(jn,"wrtBigUInt64LE");function Wn(r,e,t,n,i){ Vn(e,n,i,r,t,7);let s=Number(e&BigInt(4294967295));r[t+7]=s,s=s>>8,r[t+6]=s,s=s>> 8,r[t+5]=s,s=s>>8,r[t+4]=s;let o=Number(e>>BigInt(32)&BigInt(4294967295));return r[t+ 3]=o,o=o>>8,r[t+2]=o,o=o>>8,r[t+1]=o,o=o>>8,r[t]=o,t+8}a(Wn,"wrtBigUInt64BE");f. prototype.writeBigUInt64LE=we(a(function(e,t=0){return jn(this,e,t,BigInt(0),BigInt( "0xffffffffffffffff"))},"writeBigUInt64LE"));f.prototype.writeBigUInt64BE=we(a(function(e,t=0){ return Wn(this,e,t,BigInt(0),BigInt("0xffffffffffffffff"))},"writeBigUInt64BE")); f.prototype.writeIntLE=a(function(e,t,n,i){if(e=+e,t=t>>>0,!i){let c=Math.pow(2, 8*n-1);Y(this,e,t,n,c-1,-c)}let s=0,o=1,u=0;for(this[t]=e&255;++s>0)-u&255;return t+n},"writeIntL\ E");f.prototype.writeIntBE=a(function(e,t,n,i){if(e=+e,t=t>>>0,!i){let c=Math.pow( 2,8*n-1);Y(this,e,t,n,c-1,-c)}let s=n-1,o=1,u=0;for(this[t+s]=e&255;--s>=0&&(o*= 256);)e<0&&u===0&&this[t+s+1]!==0&&(u=1),this[t+s]=(e/o>>0)-u&255;return t+n},"w\ riteIntBE");f.prototype.writeInt8=a(function(e,t,n){return e=+e,t=t>>>0,n||Y(this, e,t,1,127,-128),e<0&&(e=255+e+1),this[t]=e&255,t+1},"writeInt8");f.prototype.writeInt16LE= a(function(e,t,n){return e=+e,t=t>>>0,n||Y(this,e,t,2,32767,-32768),this[t]=e&255, this[t+1]=e>>>8,t+2},"writeInt16LE");f.prototype.writeInt16BE=a(function(e,t,n){ return e=+e,t=t>>>0,n||Y(this,e,t,2,32767,-32768),this[t]=e>>>8,this[t+1]=e&255, t+2},"writeInt16BE");f.prototype.writeInt32LE=a(function(e,t,n){return e=+e,t=t>>> 0,n||Y(this,e,t,4,2147483647,-2147483648),this[t]=e&255,this[t+1]=e>>>8,this[t+2]= e>>>16,this[t+3]=e>>>24,t+4},"writeInt32LE");f.prototype.writeInt32BE=a(function(e,t,n){ return e=+e,t=t>>>0,n||Y(this,e,t,4,2147483647,-2147483648),e<0&&(e=4294967295+e+ 1),this[t]=e>>>24,this[t+1]=e>>>16,this[t+2]=e>>>8,this[t+3]=e&255,t+4},"writeIn\ t32BE");f.prototype.writeBigInt64LE=we(a(function(e,t=0){return jn(this,e,t,-BigInt( "0x8000000000000000"),BigInt("0x7fffffffffffffff"))},"writeBigInt64LE"));f.prototype. writeBigInt64BE=we(a(function(e,t=0){return Wn(this,e,t,-BigInt("0x8000000000000\ 000"),BigInt("0x7fffffffffffffff"))},"writeBigInt64BE"));function Hn(r,e,t,n,i,s){ if(t+n>r.length)throw new RangeError("Index out of range");if(t<0)throw new RangeError( "Index out of range")}a(Hn,"checkIEEE754");function Gn(r,e,t,n,i){return e=+e,t= t>>>0,i||Hn(r,e,t,4,34028234663852886e22,-34028234663852886e22),Le.write(r,e,t,n, 23,4),t+4}a(Gn,"writeFloat");f.prototype.writeFloatLE=a(function(e,t,n){return Gn( this,e,t,!0,n)},"writeFloatLE");f.prototype.writeFloatBE=a(function(e,t,n){return Gn( this,e,t,!1,n)},"writeFloatBE");function $n(r,e,t,n,i){return e=+e,t=t>>>0,i||Hn( r,e,t,8,17976931348623157e292,-17976931348623157e292),Le.write(r,e,t,n,52,8),t+8} a($n,"writeDouble");f.prototype.writeDoubleLE=a(function(e,t,n){return $n(this,e, t,!0,n)},"writeDoubleLE");f.prototype.writeDoubleBE=a(function(e,t,n){return $n( this,e,t,!1,n)},"writeDoubleBE");f.prototype.copy=a(function(e,t,n,i){if(!f.isBuffer( e))throw new TypeError("argument should be a Buffer");if(n||(n=0),!i&&i!==0&&(i= this.length),t>=e.length&&(t=e.length),t||(t=0),i>0&&i=this.length)throw new RangeError("Index out of range");if(i<0)throw new RangeError( "sourceEnd out of bounds");i>this.length&&(i=this.length),e.length-t>>0, n=n===void 0?this.length:n>>>0,e||(e=0);let s;if(typeof e=="number")for(s=t;s2**32?i=kn(String(t)):typeof t=="bigint"&&(i=String(t), (t>BigInt(2)**BigInt(32)||t<-(BigInt(2)**BigInt(32)))&&(i=kn(i)),i+="n"),n+=` It\ must be ${e}. Received ${i}`,n},RangeError);function kn(r){let e="",t=r.length, n=r[0]==="-"?1:0;for(;t>=n+4;t-=3)e=`_${r.slice(t-3,t)}${e}`;return`${r.slice(0, t)}${e}`}a(kn,"addNumericalSeparator");function Do(r,e,t){Re(e,"offset"),(r[e]=== void 0||r[e+t]===void 0)&&We(e,r.length-(t+1))}a(Do,"checkBounds");function Vn(r,e,t,n,i,s){ if(r>t||r3?e===0||e===BigInt(0)?u= `>= 0${o} and < 2${o} ** ${(s+1)*8}${o}`:u=`>= -(2${o} ** ${(s+1)*8-1}${o}) and \ < 2 ** ${(s+1)*8-1}${o}`:u=`>= ${e}${o} and <= ${t}${o}`,new Be.ERR_OUT_OF_RANGE( "value",u,r)}Do(n,i,s)}a(Vn,"checkIntBI");function Re(r,e){if(typeof r!="number") throw new Be.ERR_INVALID_ARG_TYPE(e,"number",r)}a(Re,"validateNumber");function We(r,e,t){ throw Math.floor(r)!==r?(Re(r,t),new Be.ERR_OUT_OF_RANGE(t||"offset","an integer", r)):e<0?new Be.ERR_BUFFER_OUT_OF_BOUNDS:new Be.ERR_OUT_OF_RANGE(t||"offset",`>= ${t? 1:0} and <= ${e}`,r)}a(We,"boundsError");var ko=/[^+/0-9A-Za-z-_]/g;function Oo(r){ if(r=r.split("=")[0],r=r.trim().replace(ko,""),r.length<2)return"";for(;r.length% 4!==0;)r=r+"=";return r}a(Oo,"base64clean");function Ot(r,e){e=e||1/0;let t,n=r. length,i=null,s=[];for(let o=0;o55295&&t<57344){if(!i){ if(t>56319){(e-=3)>-1&&s.push(239,191,189);continue}else if(o+1===n){(e-=3)>-1&& s.push(239,191,189);continue}i=t;continue}if(t<56320){(e-=3)>-1&&s.push(239,191, 189),i=t;continue}t=(i-55296<<10|t-56320)+65536}else i&&(e-=3)>-1&&s.push(239,191, 189);if(i=null,t<128){if((e-=1)<0)break;s.push(t)}else if(t<2048){if((e-=2)<0)break; s.push(t>>6|192,t&63|128)}else if(t<65536){if((e-=3)<0)break;s.push(t>>12|224,t>> 6&63|128,t&63|128)}else if(t<1114112){if((e-=4)<0)break;s.push(t>>18|240,t>>12&63| 128,t>>6&63|128,t&63|128)}else throw new Error("Invalid code point")}return s}a( Ot,"utf8ToBytes");function Uo(r){let e=[];for(let t=0;t>8,i=t%256,s.push(i),s.push(n);return s} a(No,"utf16leToBytes");function Kn(r){return Mt.toByteArray(Oo(r))}a(Kn,"base64T\ oBytes");function ot(r,e,t,n){let i;for(i=0;i=e.length||i>=r.length);++i) e[i+t]=r[i];return i}a(ot,"blitBuffer");function ae(r,e){return r instanceof e|| r!=null&&r.constructor!=null&&r.constructor.name!=null&&r.constructor.name===e.name} a(ae,"isInstance");function Qt(r){return r!==r}a(Qt,"numberIsNaN");var qo=function(){ let r="0123456789abcdef",e=new Array(256);for(let t=0;t<16;++t){let n=t*16;for(let i=0;i< 16;++i)e[n+i]=r[t]+r[i]}return e}();function we(r){return typeof BigInt>"u"?Qo:r} a(we,"defineBigIntMethod");function Qo(){throw new Error("BigInt not supported")} a(Qo,"BufferBigIntNotDefined")});var S,E,x,g,y,m,p=z(()=>{"use strict";S=globalThis,E=globalThis.setImmediate??(r=>setTimeout( r,0)),x=globalThis.clearImmediate??(r=>clearTimeout(r)),g=globalThis.crypto??{}; g.subtle??(g.subtle={});y=typeof globalThis.Buffer=="function"&&typeof globalThis. Buffer.allocUnsafe=="function"?globalThis.Buffer:zn().Buffer,m=globalThis.process?? {};m.env??(m.env={});try{m.nextTick(()=>{})}catch{let e=Promise.resolve();m.nextTick= e.then.bind(e)}});var be=I((rh,jt)=>{"use strict";p();var Me=typeof Reflect=="object"?Reflect:null, Yn=Me&&typeof Me.apply=="function"?Me.apply:a(function(e,t,n){return Function.prototype. apply.call(e,t,n)},"ReflectApply"),at;Me&&typeof Me.ownKeys=="function"?at=Me.ownKeys: Object.getOwnPropertySymbols?at=a(function(e){return Object.getOwnPropertyNames( e).concat(Object.getOwnPropertySymbols(e))},"ReflectOwnKeys"):at=a(function(e){return Object. getOwnPropertyNames(e)},"ReflectOwnKeys");function jo(r){console&&console.warn&& console.warn(r)}a(jo,"ProcessEmitWarning");var Jn=Number.isNaN||a(function(e){return e!== e},"NumberIsNaN");function L(){L.init.call(this)}a(L,"EventEmitter");jt.exports= L;jt.exports.once=$o;L.EventEmitter=L;L.prototype._events=void 0;L.prototype._eventsCount= 0;L.prototype._maxListeners=void 0;var Zn=10;function ut(r){if(typeof r!="functi\ on")throw new TypeError('The "listener" argument must be of type Function. Recei\ ved type '+typeof r)}a(ut,"checkListener");Object.defineProperty(L,"defaultMaxLi\ steners",{enumerable:!0,get:a(function(){return Zn},"get"),set:a(function(r){if(typeof r!= "number"||r<0||Jn(r))throw new RangeError('The value of "defaultMaxListeners" is\ out of range. It must be a non-negative number. Received '+r+".");Zn=r},"set")}); L.init=function(){(this._events===void 0||this._events===Object.getPrototypeOf(this). _events)&&(this._events=Object.create(null),this._eventsCount=0),this._maxListeners= this._maxListeners||void 0};L.prototype.setMaxListeners=a(function(e){if(typeof e!= "number"||e<0||Jn(e))throw new RangeError('The value of "n" is out of range. It \ must be a non-negative number. Received '+e+".");return this._maxListeners=e,this}, "setMaxListeners");function Xn(r){return r._maxListeners===void 0?L.defaultMaxListeners: r._maxListeners}a(Xn,"_getMaxListeners");L.prototype.getMaxListeners=a(function(){ return Xn(this)},"getMaxListeners");L.prototype.emit=a(function(e){for(var t=[], n=1;n 0&&(o=t[0]),o instanceof Error)throw o;var u=new Error("Unhandled error."+(o?" ("+ o.message+")":""));throw u.context=o,u}var c=s[e];if(c===void 0)return!1;if(typeof c== "function")Yn(c,this,t);else for(var h=c.length,l=ii(c,h),n=0;n0&&o.length>i&&!o.warned){o.warned=!0;var u=new Error("Po\ ssible EventEmitter memory leak detected. "+o.length+" "+String(e)+" listeners a\ dded. Use emitter.setMaxListeners() to increase limit");u.name="MaxListenersExce\ ededWarning",u.emitter=r,u.type=e,u.count=o.length,jo(u)}return r}a(ei,"_addList\ ener");L.prototype.addListener=a(function(e,t){return ei(this,e,t,!1)},"addListe\ ner");L.prototype.on=L.prototype.addListener;L.prototype.prependListener=a(function(e,t){ return ei(this,e,t,!0)},"prependListener");function Wo(){if(!this.fired)return this. target.removeListener(this.type,this.wrapFn),this.fired=!0,arguments.length===0? this.listener.call(this.target):this.listener.apply(this.target,arguments)}a(Wo, "onceWrapper");function ti(r,e,t){var n={fired:!1,wrapFn:void 0,target:r,type:e, listener:t},i=Wo.bind(n);return i.listener=t,n.wrapFn=i,i}a(ti,"_onceWrap");L.prototype. once=a(function(e,t){return ut(t),this.on(e,ti(this,e,t)),this},"once");L.prototype. prependOnceListener=a(function(e,t){return ut(t),this.prependListener(e,ti(this, e,t)),this},"prependOnceListener");L.prototype.removeListener=a(function(e,t){var n, i,s,o,u;if(ut(t),i=this._events,i===void 0)return this;if(n=i[e],n===void 0)return this; if(n===t||n.listener===t)--this._eventsCount===0?this._events=Object.create(null): (delete i[e],i.removeListener&&this.emit("removeListener",e,n.listener||t));else if(typeof n!= "function"){for(s=-1,o=n.length-1;o>=0;o--)if(n[o]===t||n[o].listener===t){u=n[o]. listener,s=o;break}if(s<0)return this;s===0?n.shift():Ho(n,s),n.length===1&&(i[e]= n[0]),i.removeListener!==void 0&&this.emit("removeListener",e,u||t)}return this}, "removeListener");L.prototype.off=L.prototype.removeListener;L.prototype.removeAllListeners= a(function(e){var t,n,i;if(n=this._events,n===void 0)return this;if(n.removeListener=== void 0)return arguments.length===0?(this._events=Object.create(null),this._eventsCount= 0):n[e]!==void 0&&(--this._eventsCount===0?this._events=Object.create(null):delete n[e]), this;if(arguments.length===0){var s=Object.keys(n),o;for(i=0;i=0;i--)this.removeListener(e,t[i]);return this},"removeAllListeners");function ri(r,e,t){ var n=r._events;if(n===void 0)return[];var i=n[e];return i===void 0?[]:typeof i== "function"?t?[i.listener||i]:[i]:t?Go(i):ii(i,i.length)}a(ri,"_listeners");L.prototype. listeners=a(function(e){return ri(this,e,!0)},"listeners");L.prototype.rawListeners= a(function(e){return ri(this,e,!1)},"rawListeners");L.listenerCount=function(r,e){ return typeof r.listenerCount=="function"?r.listenerCount(e):ni.call(r,e)};L.prototype. listenerCount=ni;function ni(r){var e=this._events;if(e!==void 0){var t=e[r];if(typeof t== "function")return 1;if(t!==void 0)return t.length}return 0}a(ni,"listenerCount"); L.prototype.eventNames=a(function(){return this._eventsCount>0?at(this._events): []},"eventNames");function ii(r,e){for(var t=new Array(e),n=0;nKo});var Ko,Ge=z(()=>{"use strict";p();Ko={}});function $e(r){let e=1779033703,t=3144134277,n=1013904242,i=2773480762,s=1359893119, o=2600822924,u=528734635,c=1541459225,h=0,l=0,d=[1116352408,1899447441,3049323471, 3921009573,961987163,1508970993,2453635748,2870763221,3624381080,310598401,607225278, 1426881987,1925078388,2162078206,2614888103,3248222580,3835390401,4022224774,264347078, 604807628,770255983,1249150122,1555081692,1996064986,2554220882,2821834349,2952996808, 3210313671,3336571891,3584528711,113926993,338241895,666307205,773529912,1294757372, 1396182291,1695183700,1986661051,2177026350,2456956037,2730485921,2820302411,3259730800, 3345764771,3516065817,3600352804,4094571909,275423344,430227734,506948616,659060556, 883997877,958139571,1322822218,1537002063,1747873779,1955562222,2024104815,2227730452, 2361852424,2428436474,2756734187,3204031479,3329325298],b=a((A,w)=>A>>>w|A<<32-w, "rrot"),C=new Uint32Array(64),B=new Uint8Array(64),j=a(()=>{for(let R=0,G=0;R<16;R++, G+=4)C[R]=B[G]<<24|B[G+1]<<16|B[G+2]<<8|B[G+3];for(let R=16;R<64;R++){let G=b(C[R- 15],7)^b(C[R-15],18)^C[R-15]>>>3,he=b(C[R-2],17)^b(C[R-2],19)^C[R-2]>>>10;C[R]=C[R- 16]+G+C[R-7]+he|0}let A=e,w=t,P=n,V=i,O=s,W=o,ce=u,ee=c;for(let R=0;R<64;R++){let G=b( O,6)^b(O,11)^b(O,25),he=O&W^~O&ce,ye=ee+G+he+d[R]+C[R]|0,ve=b(A,2)^b(A,13)^b(A,22), le=A&w^A&P^w&P,Te=ve+le|0;ee=ce,ce=W,W=O,O=V+ye|0,V=P,P=w,w=A,A=ye+Te|0}e=e+A|0, t=t+w|0,n=n+P|0,i=i+V|0,s=s+O|0,o=o+W|0,u=u+ce|0,c=c+ee|0,l=0},"process"),X=a(A=>{ typeof A=="string"&&(A=new TextEncoder().encode(A));for(let w=0;w{if(B[l++]=128,l==64&&j(),l+8>64){ for(;l<64;)B[l++]=0;j()}for(;l<58;)B[l++]=0;let A=h*8;B[l++]=A/1099511627776&255, B[l++]=A/4294967296&255,B[l++]=A>>>24,B[l++]=A>>>16&255,B[l++]=A>>>8&255,B[l++]= A&255,j();let w=new Uint8Array(32);return w[0]=e>>>24,w[1]=e>>>16&255,w[2]=e>>>8& 255,w[3]=e&255,w[4]=t>>>24,w[5]=t>>>16&255,w[6]=t>>>8&255,w[7]=t&255,w[8]=n>>>24, w[9]=n>>>16&255,w[10]=n>>>8&255,w[11]=n&255,w[12]=i>>>24,w[13]=i>>>16&255,w[14]= i>>>8&255,w[15]=i&255,w[16]=s>>>24,w[17]=s>>>16&255,w[18]=s>>>8&255,w[19]=s&255, w[20]=o>>>24,w[21]=o>>>16&255,w[22]=o>>>8&255,w[23]=o&255,w[24]=u>>>24,w[25]=u>>> 16&255,w[26]=u>>>8&255,w[27]=u&255,w[28]=c>>>24,w[29]=c>>>16&255,w[30]=c>>>8&255, w[31]=c&255,w},"digest");return r===void 0?{add:X,digest:de}:(X(r),de())}var oi=z( ()=>{"use strict";p();a($e,"sha256")});var U,Ve,ai=z(()=>{"use strict";p();U=class U{constructor(){_(this,"_dataLength", 0);_(this,"_bufferLength",0);_(this,"_state",new Int32Array(4));_(this,"_buffer", new ArrayBuffer(68));_(this,"_buffer8");_(this,"_buffer32");this._buffer8=new Uint8Array( this._buffer,0,68),this._buffer32=new Uint32Array(this._buffer,0,17),this.start()}static hashByteArray(e,t=!1){ return this.onePassHasher.start().appendByteArray(e).end(t)}static hashStr(e,t=!1){ return this.onePassHasher.start().appendStr(e).end(t)}static hashAsciiStr(e,t=!1){ return this.onePassHasher.start().appendAsciiStr(e).end(t)}static _hex(e){let t=U. hexChars,n=U.hexOut,i,s,o,u;for(u=0;u<4;u+=1)for(s=u*8,i=e[u],o=0;o<8;o+=2)n[s+1+ o]=t.charAt(i&15),i>>>=4,n[s+0+o]=t.charAt(i&15),i>>>=4;return n.join("")}static _md5cycle(e,t){ let n=e[0],i=e[1],s=e[2],o=e[3];n+=(i&s|~i&o)+t[0]-680876936|0,n=(n<<7|n>>>25)+i| 0,o+=(n&i|~n&s)+t[1]-389564586|0,o=(o<<12|o>>>20)+n|0,s+=(o&n|~o&i)+t[2]+606105819| 0,s=(s<<17|s>>>15)+o|0,i+=(s&o|~s&n)+t[3]-1044525330|0,i=(i<<22|i>>>10)+s|0,n+=(i& s|~i&o)+t[4]-176418897|0,n=(n<<7|n>>>25)+i|0,o+=(n&i|~n&s)+t[5]+1200080426|0,o=(o<< 12|o>>>20)+n|0,s+=(o&n|~o&i)+t[6]-1473231341|0,s=(s<<17|s>>>15)+o|0,i+=(s&o|~s&n)+ t[7]-45705983|0,i=(i<<22|i>>>10)+s|0,n+=(i&s|~i&o)+t[8]+1770035416|0,n=(n<<7|n>>> 25)+i|0,o+=(n&i|~n&s)+t[9]-1958414417|0,o=(o<<12|o>>>20)+n|0,s+=(o&n|~o&i)+t[10]- 42063|0,s=(s<<17|s>>>15)+o|0,i+=(s&o|~s&n)+t[11]-1990404162|0,i=(i<<22|i>>>10)+s| 0,n+=(i&s|~i&o)+t[12]+1804603682|0,n=(n<<7|n>>>25)+i|0,o+=(n&i|~n&s)+t[13]-40341101| 0,o=(o<<12|o>>>20)+n|0,s+=(o&n|~o&i)+t[14]-1502002290|0,s=(s<<17|s>>>15)+o|0,i+= (s&o|~s&n)+t[15]+1236535329|0,i=(i<<22|i>>>10)+s|0,n+=(i&o|s&~o)+t[1]-165796510| 0,n=(n<<5|n>>>27)+i|0,o+=(n&s|i&~s)+t[6]-1069501632|0,o=(o<<9|o>>>23)+n|0,s+=(o& i|n&~i)+t[11]+643717713|0,s=(s<<14|s>>>18)+o|0,i+=(s&n|o&~n)+t[0]-373897302|0,i= (i<<20|i>>>12)+s|0,n+=(i&o|s&~o)+t[5]-701558691|0,n=(n<<5|n>>>27)+i|0,o+=(n&s|i& ~s)+t[10]+38016083|0,o=(o<<9|o>>>23)+n|0,s+=(o&i|n&~i)+t[15]-660478335|0,s=(s<<14| s>>>18)+o|0,i+=(s&n|o&~n)+t[4]-405537848|0,i=(i<<20|i>>>12)+s|0,n+=(i&o|s&~o)+t[9]+ 568446438|0,n=(n<<5|n>>>27)+i|0,o+=(n&s|i&~s)+t[14]-1019803690|0,o=(o<<9|o>>>23)+ n|0,s+=(o&i|n&~i)+t[3]-187363961|0,s=(s<<14|s>>>18)+o|0,i+=(s&n|o&~n)+t[8]+1163531501| 0,i=(i<<20|i>>>12)+s|0,n+=(i&o|s&~o)+t[13]-1444681467|0,n=(n<<5|n>>>27)+i|0,o+=(n& s|i&~s)+t[2]-51403784|0,o=(o<<9|o>>>23)+n|0,s+=(o&i|n&~i)+t[7]+1735328473|0,s=(s<< 14|s>>>18)+o|0,i+=(s&n|o&~n)+t[12]-1926607734|0,i=(i<<20|i>>>12)+s|0,n+=(i^s^o)+ t[5]-378558|0,n=(n<<4|n>>>28)+i|0,o+=(n^i^s)+t[8]-2022574463|0,o=(o<<11|o>>>21)+ n|0,s+=(o^n^i)+t[11]+1839030562|0,s=(s<<16|s>>>16)+o|0,i+=(s^o^n)+t[14]-35309556| 0,i=(i<<23|i>>>9)+s|0,n+=(i^s^o)+t[1]-1530992060|0,n=(n<<4|n>>>28)+i|0,o+=(n^i^s)+ t[4]+1272893353|0,o=(o<<11|o>>>21)+n|0,s+=(o^n^i)+t[7]-155497632|0,s=(s<<16|s>>> 16)+o|0,i+=(s^o^n)+t[10]-1094730640|0,i=(i<<23|i>>>9)+s|0,n+=(i^s^o)+t[13]+681279174| 0,n=(n<<4|n>>>28)+i|0,o+=(n^i^s)+t[0]-358537222|0,o=(o<<11|o>>>21)+n|0,s+=(o^n^i)+ t[3]-722521979|0,s=(s<<16|s>>>16)+o|0,i+=(s^o^n)+t[6]+76029189|0,i=(i<<23|i>>>9)+ s|0,n+=(i^s^o)+t[9]-640364487|0,n=(n<<4|n>>>28)+i|0,o+=(n^i^s)+t[12]-421815835|0, o=(o<<11|o>>>21)+n|0,s+=(o^n^i)+t[15]+530742520|0,s=(s<<16|s>>>16)+o|0,i+=(s^o^n)+ t[2]-995338651|0,i=(i<<23|i>>>9)+s|0,n+=(s^(i|~o))+t[0]-198630844|0,n=(n<<6|n>>> 26)+i|0,o+=(i^(n|~s))+t[7]+1126891415|0,o=(o<<10|o>>>22)+n|0,s+=(n^(o|~i))+t[14]- 1416354905|0,s=(s<<15|s>>>17)+o|0,i+=(o^(s|~n))+t[5]-57434055|0,i=(i<<21|i>>>11)+ s|0,n+=(s^(i|~o))+t[12]+1700485571|0,n=(n<<6|n>>>26)+i|0,o+=(i^(n|~s))+t[3]-1894986606| 0,o=(o<<10|o>>>22)+n|0,s+=(n^(o|~i))+t[10]-1051523|0,s=(s<<15|s>>>17)+o|0,i+=(o^ (s|~n))+t[1]-2054922799|0,i=(i<<21|i>>>11)+s|0,n+=(s^(i|~o))+t[8]+1873313359|0,n= (n<<6|n>>>26)+i|0,o+=(i^(n|~s))+t[15]-30611744|0,o=(o<<10|o>>>22)+n|0,s+=(n^(o|~i))+ t[6]-1560198380|0,s=(s<<15|s>>>17)+o|0,i+=(o^(s|~n))+t[13]+1309151649|0,i=(i<<21| i>>>11)+s|0,n+=(s^(i|~o))+t[4]-145523070|0,n=(n<<6|n>>>26)+i|0,o+=(i^(n|~s))+t[11]- 1120210379|0,o=(o<<10|o>>>22)+n|0,s+=(n^(o|~i))+t[2]+718787259|0,s=(s<<15|s>>>17)+ o|0,i+=(o^(s|~n))+t[9]-343485551|0,i=(i<<21|i>>>11)+s|0,e[0]=n+e[0]|0,e[1]=i+e[1]| 0,e[2]=s+e[2]|0,e[3]=o+e[3]|0}start(){return this._dataLength=0,this._bufferLength= 0,this._state.set(U.stateIdentity),this}appendStr(e){let t=this._buffer8,n=this. _buffer32,i=this._bufferLength,s,o;for(o=0;o>>6)+192,t[i++]=s&63|128;else if(s<55296|| s>56319)t[i++]=(s>>>12)+224,t[i++]=s>>>6&63|128,t[i++]=s&63|128;else{if(s=(s-55296)* 1024+(e.charCodeAt(++o)-56320)+65536,s>1114111)throw new Error("Unicode standard\ supports code points up to U+10FFFF");t[i++]=(s>>>18)+240,t[i++]=s>>>12&63|128, t[i++]=s>>>6&63|128,t[i++]=s&63|128}i>=64&&(this._dataLength+=64,U._md5cycle(this. _state,n),i-=64,n[0]=n[16])}return this._bufferLength=i,this}appendAsciiStr(e){let t=this. _buffer8,n=this._buffer32,i=this._bufferLength,s,o=0;for(;;){for(s=Math.min(e.length- o,64-i);s--;)t[i++]=e.charCodeAt(o++);if(i<64)break;this._dataLength+=64,U._md5cycle( this._state,n),i=0}return this._bufferLength=i,this}appendByteArray(e){let t=this. _buffer8,n=this._buffer32,i=this._bufferLength,s,o=0;for(;;){for(s=Math.min(e.length- o,64-i);s--;)t[i++]=e[o++];if(i<64)break;this._dataLength+=64,U._md5cycle(this._state, n),i=0}return this._bufferLength=i,this}getState(){let e=this._state;return{buffer:String. fromCharCode.apply(null,Array.from(this._buffer8)),buflen:this._bufferLength,length:this. _dataLength,state:[e[0],e[1],e[2],e[3]]}}setState(e){let t=e.buffer,n=e.state,i=this. _state,s;for(this._dataLength=e.length,this._bufferLength=e.buflen,i[0]=n[0],i[1]= n[1],i[2]=n[2],i[3]=n[3],s=0;s>2)+1;this._dataLength+= t;let o=this._dataLength*8;if(n[t]=128,n[t+1]=n[t+2]=n[t+3]=0,i.set(U.buffer32Identity. subarray(s),s),t>55&&(U._md5cycle(this._state,i),i.set(U.buffer32Identity)),o<=4294967295) i[14]=o;else{let u=o.toString(16).match(/(.*?)(.{0,8})$/);if(u===null)return;let c=parseInt( u[2],16),h=parseInt(u[1],16)||0;i[14]=c,i[15]=h}return U._md5cycle(this._state,i), e?this._state:U._hex(this._state)}};a(U,"Md5"),_(U,"stateIdentity",new Int32Array( [1732584193,-271733879,-1732584194,271733878])),_(U,"buffer32Identity",new Int32Array( [0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0])),_(U,"hexChars","0123456789abcdef"),_(U,"hexO\ ut",[]),_(U,"onePassHasher",new U);Ve=U});var Wt={};te(Wt,{createHash:()=>Yo,createHmac:()=>Zo,randomBytes:()=>zo});function zo(r){ return g.getRandomValues(y.alloc(r))}function Yo(r){if(r==="sha256")return{update:a( function(e){return{digest:a(function(){return y.from($e(e))},"digest")}},"update")}; if(r==="md5")return{update:a(function(e){return{digest:a(function(){return typeof e== "string"?Ve.hashStr(e):Ve.hashByteArray(e)},"digest")}},"update")};throw new Error( `Hash type '${r}' not supported`)}function Zo(r,e){if(r!=="sha256")throw new Error( `Only sha256 is supported (requested: '${r}')`);return{update:a(function(t){return{ digest:a(function(){typeof e=="string"&&(e=new TextEncoder().encode(e)),typeof t== "string"&&(t=new TextEncoder().encode(t));let n=e.length;if(n>64)e=$e(e);else if(n< 64){let c=new Uint8Array(64);c.set(e),e=c}let i=new Uint8Array(64),s=new Uint8Array( 64);for(let c=0;c<64;c++)i[c]=54^e[c],s[c]=92^e[c];let o=new Uint8Array(t.length+ 64);o.set(i,0),o.set(t,64);let u=new Uint8Array(96);return u.set(s,0),u.set($e(o), 64),y.from($e(u))},"digest")}},"update")}}var Ht=z(()=>{"use strict";p();oi();ai(); a(zo,"randomBytes");a(Yo,"createHash");a(Zo,"createHmac")});var $t=I(ui=>{"use strict";p();ui.parse=function(r,e){return new Gt(r,e).parse()}; var ct=class ct{constructor(e,t){this.source=e,this.transform=t||Jo,this.position= 0,this.entries=[],this.recorded=[],this.dimension=0}isEof(){return this.position>= this.source.length}nextCharacter(){var e=this.source[this.position++];return e=== "\\"?{value:this.source[this.position++],escaped:!0}:{value:e,escaped:!1}}record(e){ this.recorded.push(e)}newEntry(e){var t;(this.recorded.length>0||e)&&(t=this.recorded. join(""),t==="NULL"&&!e&&(t=null),t!==null&&(t=this.transform(t)),this.entries.push( t),this.recorded=[])}consumeDimensions(){if(this.source[0]==="[")for(;!this.isEof();){ var e=this.nextCharacter();if(e.value==="=")break}}parse(e){var t,n,i;for(this.consumeDimensions();!this. isEof();)if(t=this.nextCharacter(),t.value==="{"&&!i)this.dimension++,this.dimension> 1&&(n=new ct(this.source.substr(this.position-1),this.transform),this.entries.push( n.parse(!0)),this.position+=n.position-2);else if(t.value==="}"&&!i){if(this.dimension--, !this.dimension&&(this.newEntry(),e))return this.entries}else t.value==='"'&&!t. escaped?(i&&this.newEntry(!0),i=!i):t.value===","&&!i?this.newEntry():this.record( t.value);if(this.dimension!==0)throw new Error("array dimension not balanced");return this. entries}};a(ct,"ArrayParser");var Gt=ct;function Jo(r){return r}a(Jo,"identity")});var Vt=I((bh,ci)=>{p();var Xo=$t();ci.exports={create:a(function(r,e){return{parse:a( function(){return Xo.parse(r,e)},"parse")}},"create")}});var fi=I((xh,li)=>{"use strict";p();var ea=/(\d{1,})-(\d{2})-(\d{2}) (\d{2}):(\d{2}):(\d{2})(\.\d{1,})?.*?( BC)?$/, ta=/^(\d{1,})-(\d{2})-(\d{2})( BC)?$/,ra=/([Z+-])(\d{2})?:?(\d{2})?:?(\d{2})?/,na=/^-?infinity$/; li.exports=a(function(e){if(na.test(e))return Number(e.replace("i","I"));var t=ea. exec(e);if(!t)return ia(e)||null;var n=!!t[8],i=parseInt(t[1],10);n&&(i=hi(i));var s=parseInt( t[2],10)-1,o=t[3],u=parseInt(t[4],10),c=parseInt(t[5],10),h=parseInt(t[6],10),l=t[7]; l=l?1e3*parseFloat(l):0;var d,b=sa(e);return b!=null?(d=new Date(Date.UTC(i,s,o, u,c,h,l)),Kt(i)&&d.setUTCFullYear(i),b!==0&&d.setTime(d.getTime()-b)):(d=new Date( i,s,o,u,c,h,l),Kt(i)&&d.setFullYear(i)),d},"parseDate");function ia(r){var e=ta. exec(r);if(e){var t=parseInt(e[1],10),n=!!e[4];n&&(t=hi(t));var i=parseInt(e[2], 10)-1,s=e[3],o=new Date(t,i,s);return Kt(t)&&o.setFullYear(t),o}}a(ia,"getDate"); function sa(r){if(r.endsWith("+00"))return 0;var e=ra.exec(r.split(" ")[1]);if(e){ var t=e[1];if(t==="Z")return 0;var n=t==="-"?-1:1,i=parseInt(e[2],10)*3600+parseInt( e[3]||0,10)*60+parseInt(e[4]||0,10);return i*n*1e3}}a(sa,"timeZoneOffset");function hi(r){ return-(r-1)}a(hi,"bcYearToNegativeYear");function Kt(r){return r>=0&&r<100}a(Kt, "is0To99")});var di=I((Ah,pi)=>{p();pi.exports=aa;var oa=Object.prototype.hasOwnProperty;function aa(r){ for(var e=1;e{"use strict";p();var ua=di();mi.exports=De;function De(r){if(!(this instanceof De))return new De(r);ua(this,Sa(r))}a(De,"PostgresInterval");var ca=["seconds","\ minutes","hours","days","months","years"];De.prototype.toPostgres=function(){var r=ca. filter(this.hasOwnProperty,this);return this.milliseconds&&r.indexOf("seconds")< 0&&r.push("seconds"),r.length===0?"0":r.map(function(e){var t=this[e]||0;return e=== "seconds"&&this.milliseconds&&(t=(t+this.milliseconds/1e3).toFixed(6).replace(/\.?0+$/, "")),t+" "+e},this).join(" ")};var ha={years:"Y",months:"M",days:"D",hours:"H",minutes:"\ M",seconds:"S"},la=["years","months","days"],fa=["hours","minutes","seconds"];De. prototype.toISOString=De.prototype.toISO=function(){var r=la.map(t,this).join(""), e=fa.map(t,this).join("");return"P"+r+"T"+e;function t(n){var i=this[n]||0;return n=== "seconds"&&this.milliseconds&&(i=(i+this.milliseconds/1e3).toFixed(6).replace(/0+$/, "")),i+ha[n]}};var zt="([+-]?\\d+)",pa=zt+"\\s+years?",da=zt+"\\s+mons?",ya=zt+"\ \\s+days?",ma="([+-])?([\\d]*):(\\d\\d):(\\d\\d)\\.?(\\d{1,6})?",ga=new RegExp([ pa,da,ya,ma].map(function(r){return"("+r+")?"}).join("\\s*")),yi={years:2,months:4, days:6,hours:9,minutes:10,seconds:11,milliseconds:12},wa=["hours","minutes","sec\ onds","milliseconds"];function ba(r){var e=r+"000000".slice(r.length);return parseInt( e,10)/1e3}a(ba,"parseMilliseconds");function Sa(r){if(!r)return{};var e=ga.exec( r),t=e[8]==="-";return Object.keys(yi).reduce(function(n,i){var s=yi[i],o=e[s];return!o|| (o=i==="milliseconds"?ba(o):parseInt(o,10),!o)||(t&&~wa.indexOf(i)&&(o*=-1),n[i]= o),n},{})}a(Sa,"parse")});var bi=I((Lh,wi)=>{"use strict";p();wi.exports=a(function(e){if(/^\\x/.test(e))return new y( e.substr(2),"hex");for(var t="",n=0;n{p();var Ke=$t(),ze=Vt(),ht=fi(),Ei=gi(),xi=bi();function lt(r){ return a(function(t){return t===null?t:r(t)},"nullAllowed")}a(lt,"allowNull");function vi(r){ return r===null?r:r==="TRUE"||r==="t"||r==="true"||r==="y"||r==="yes"||r==="on"|| r==="1"}a(vi,"parseBool");function Ea(r){return r?Ke.parse(r,vi):null}a(Ea,"pars\ eBoolArray");function xa(r){return parseInt(r,10)}a(xa,"parseBaseTenInt");function Yt(r){ return r?Ke.parse(r,lt(xa)):null}a(Yt,"parseIntegerArray");function va(r){return r? Ke.parse(r,lt(function(e){return _i(e).trim()})):null}a(va,"parseBigIntegerArray"); var _a=a(function(r){if(!r)return null;var e=ze.create(r,function(t){return t!== null&&(t=er(t)),t});return e.parse()},"parsePointArray"),Zt=a(function(r){if(!r) return null;var e=ze.create(r,function(t){return t!==null&&(t=parseFloat(t)),t}); return e.parse()},"parseFloatArray"),ne=a(function(r){if(!r)return null;var e=ze. create(r);return e.parse()},"parseStringArray"),Jt=a(function(r){if(!r)return null; var e=ze.create(r,function(t){return t!==null&&(t=ht(t)),t});return e.parse()},"\ parseDateArray"),Aa=a(function(r){if(!r)return null;var e=ze.create(r,function(t){ return t!==null&&(t=Ei(t)),t});return e.parse()},"parseIntervalArray"),Ca=a(function(r){ return r?Ke.parse(r,lt(xi)):null},"parseByteAArray"),Xt=a(function(r){return parseInt( r,10)},"parseInteger"),_i=a(function(r){var e=String(r);return/^\d+$/.test(e)?e: r},"parseBigInteger"),Si=a(function(r){return r?Ke.parse(r,lt(JSON.parse)):null}, "parseJsonArray"),er=a(function(r){return r[0]!=="("?null:(r=r.substring(1,r.length- 1).split(","),{x:parseFloat(r[0]),y:parseFloat(r[1])})},"parsePoint"),Ta=a(function(r){ if(r[0]!=="<"&&r[1]!=="(")return null;for(var e="(",t="",n=!1,i=2;i{"use strict";p();var Z=1e6;function Pa(r){var e=r.readInt32BE( 0),t=r.readUInt32BE(4),n="";e<0&&(e=~e+(t===0),t=~t+1>>>0,n="-");var i="",s,o,u, c,h,l;{if(s=e%Z,e=e/Z>>>0,o=4294967296*s+t,t=o/Z>>>0,u=""+(o-Z*t),t===0&&e===0)return n+ u+i;for(c="",h=6-u.length,l=0;l>>0,o=4294967296* s+t,t=o/Z>>>0,u=""+(o-Z*t),t===0&&e===0)return n+u+i;for(c="",h=6-u.length,l=0;l< h;l++)c+="0";i=c+u+i}{if(s=e%Z,e=e/Z>>>0,o=4294967296*s+t,t=o/Z>>>0,u=""+(o-Z*t), t===0&&e===0)return n+u+i;for(c="",h=6-u.length,l=0;l{p();var Ba=Ii(),F=a(function(r,e,t,n,i){t=t||0,n=n||!1,i=i||function(C,B,j){ return C*Math.pow(2,j)+B};var s=t>>3,o=a(function(C){return n?~C&255:C},"inv"),u=255, c=8-t%8;e>t%8);var h=0;t%8+e>=8&&(h=i(0,o(r[s])& u,c));for(var l=e+t>>3,d=s+1;d0&& (h=i(h,o(r[l])>>8-b,b)),h},"parseBits"),Li=a(function(r,e,t){var n=Math.pow(2,t- 1)-1,i=F(r,1),s=F(r,t,1);if(s===0)return 0;var o=1,u=a(function(h,l,d){h===0&&(h= 1);for(var b=1;b<=d;b++)o/=2,(l&1<0&&(h+=o);return h},"parsePrecisionBits"), c=F(r,e,t+1,!1,u);return s==Math.pow(2,t+1)-1?c===0?i===0?1/0:-1/0:NaN:(i===0?1: -1)*Math.pow(2,s-n)*c},"parseFloatFromBits"),La=a(function(r){return F(r,1)==1?-1* (F(r,15,1,!0)+1):F(r,15,1)},"parseInt16"),Pi=a(function(r){return F(r,1)==1?-1*(F( r,31,1,!0)+1):F(r,31,1)},"parseInt32"),Ra=a(function(r){return Li(r,23,8)},"pars\ eFloat32"),Fa=a(function(r){return Li(r,52,11)},"parseFloat64"),Ma=a(function(r){ var e=F(r,16,32);if(e==49152)return NaN;for(var t=Math.pow(1e4,F(r,16,16)),n=0,i=[], s=F(r,16),o=0;o>3,(i+=l<<3)>>3), d;console.log("ERROR: ElementType not implemented: "+h)},"parseElement"),c=a(function(h,l){ var d=[],b;if(h.length>1){var C=h.shift();for(b=0;b0},"parseBool"),Oa=a(function(r){r(20,Ba),r(21,La),r(23,Pi),r(26, Pi),r(1700,Ma),r(700,Ra),r(701,Fa),r(16,ka),r(1114,Bi.bind(null,!1)),r(1184,Bi.bind( null,!0)),r(1e3,Ye),r(1007,Ye),r(1016,Ye),r(1008,Ye),r(1009,Ye),r(25,Da)},"init"); Ri.exports={init:Oa}});var Di=I((Wh,Mi)=>{p();Mi.exports={BOOL:16,BYTEA:17,CHAR:18,INT8:20,INT2:21,INT4:23, REGPROC:24,TEXT:25,OID:26,TID:27,XID:28,CID:29,JSON:114,XML:142,PG_NODE_TREE:194, SMGR:210,PATH:602,POLYGON:604,CIDR:650,FLOAT4:700,FLOAT8:701,ABSTIME:702,RELTIME:703, TINTERVAL:704,CIRCLE:718,MACADDR8:774,MONEY:790,MACADDR:829,INET:869,ACLITEM:1033, BPCHAR:1042,VARCHAR:1043,DATE:1082,TIME:1083,TIMESTAMP:1114,TIMESTAMPTZ:1184,INTERVAL:1186, TIMETZ:1266,BIT:1560,VARBIT:1562,NUMERIC:1700,REFCURSOR:1790,REGPROCEDURE:2202,REGOPER:2203, REGOPERATOR:2204,REGCLASS:2205,REGTYPE:2206,UUID:2950,TXID_SNAPSHOT:2970,PG_LSN:3220, PG_NDISTINCT:3361,PG_DEPENDENCIES:3402,TSVECTOR:3614,TSQUERY:3615,GTSVECTOR:3642, REGCONFIG:3734,REGDICTIONARY:3769,JSONB:3802,REGNAMESPACE:4089,REGROLE:4096}});var Xe=I(Je=>{p();var Ua=Ci(),Na=Fi(),qa=Vt(),Qa=Di();Je.getTypeParser=ja;Je.setTypeParser= Wa;Je.arrayParser=qa;Je.builtins=Qa;var Ze={text:{},binary:{}};function ki(r){return String( r)}a(ki,"noParse");function ja(r,e){return e=e||"text",Ze[e]&&Ze[e][r]||ki}a(ja, "getTypeParser");function Wa(r,e,t){typeof e=="function"&&(t=e,e="text"),Ze[e][r]= t}a(Wa,"setTypeParser");Ua.init(function(r,e){Ze.text[r]=e});Na.init(function(r,e){ Ze.binary[r]=e})});var et=I((Kh,tr)=>{"use strict";p();tr.exports={host:"localhost",user:m.platform=== "win32"?m.env.USERNAME:m.env.USER,database:void 0,password:null,connectionString:void 0, port:5432,rows:0,binary:!1,max:10,idleTimeoutMillis:3e4,client_encoding:"",ssl:!1, application_name:void 0,fallback_application_name:void 0,options:void 0,parseInputDatesAsUTC:!1, statement_timeout:!1,lock_timeout:!1,idle_in_transaction_session_timeout:!1,query_timeout:!1, connect_timeout:0,keepalives:1,keepalives_idle:0};var ke=Xe(),Ha=ke.getTypeParser( 20,"text"),Ga=ke.getTypeParser(1016,"text");tr.exports.__defineSetter__("parseIn\ t8",function(r){ke.setTypeParser(20,"text",r?ke.getTypeParser(23,"text"):Ha),ke. setTypeParser(1016,"text",r?ke.getTypeParser(1007,"text"):Ga)})});var tt=I((Yh,Ui)=>{"use strict";p();var $a=(Ht(),N(Wt)),Va=et();function Ka(r){var e=r. replace(/\\/g,"\\\\").replace(/"/g,'\\"');return'"'+e+'"'}a(Ka,"escapeElement"); function Oi(r){for(var e="{",t=0;t0&&(e=e+","),r[t]===null||typeof r[t]> "u"?e=e+"NULL":Array.isArray(r[t])?e=e+Oi(r[t]):r[t]instanceof y?e+="\\\\x"+r[t]. toString("hex"):e+=Ka(ft(r[t]));return e=e+"}",e}a(Oi,"arrayString");var ft=a(function(r,e){ if(r==null)return null;if(r instanceof y)return r;if(ArrayBuffer.isView(r)){var t=y. from(r.buffer,r.byteOffset,r.byteLength);return t.length===r.byteLength?t:t.slice( r.byteOffset,r.byteOffset+r.byteLength)}return r instanceof Date?Va.parseInputDatesAsUTC? Za(r):Ya(r):Array.isArray(r)?Oi(r):typeof r=="object"?za(r,e):r.toString()},"pre\ pareValue");function za(r,e){if(r&&typeof r.toPostgres=="function"){if(e=e||[],e. indexOf(r)!==-1)throw new Error('circular reference detected while preparing "'+ r+'" for query');return e.push(r),ft(r.toPostgres(ft),e)}return JSON.stringify(r)} a(za,"prepareObject");function H(r,e){for(r=""+r;r.length{"use strict";p();var nr=(Ht(),N(Wt));function eu(r){if(r.indexOf( "SCRAM-SHA-256")===-1)throw new Error("SASL: Only mechanism SCRAM-SHA-256 is cur\ rently supported");let e=nr.randomBytes(18).toString("base64");return{mechanism:"\ SCRAM-SHA-256",clientNonce:e,response:"n,,n=*,r="+e,message:"SASLInitialResponse"}} a(eu,"startSession");function tu(r,e,t){if(r.message!=="SASLInitialResponse")throw new Error( "SASL: Last message was not SASLInitialResponse");if(typeof e!="string")throw new Error( "SASL: SCRAM-SERVER-FIRST-MESSAGE: client password must be a string");if(typeof t!= "string")throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: serverData must be a\ string");let n=iu(t);if(n.nonce.startsWith(r.clientNonce)){if(n.nonce.length=== r.clientNonce.length)throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: server n\ once is too short")}else throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: serv\ er nonce does not start with client nonce");var i=y.from(n.salt,"base64"),s=au(e, i,n.iteration),o=Oe(s,"Client Key"),u=ou(o),c="n=*,r="+r.clientNonce,h="r="+n.nonce+ ",s="+n.salt+",i="+n.iteration,l="c=biws,r="+n.nonce,d=c+","+h+","+l,b=Oe(u,d),C=Qi( o,b),B=C.toString("base64"),j=Oe(s,"Server Key"),X=Oe(j,d);r.message="SASLRespon\ se",r.serverSignature=X.toString("base64"),r.response=l+",p="+B}a(tu,"continueSe\ ssion");function ru(r,e){if(r.message!=="SASLResponse")throw new Error("SASL: La\ st message was not SASLResponse");if(typeof e!="string")throw new Error("SASL: S\ CRAM-SERVER-FINAL-MESSAGE: serverData must be a string");let{serverSignature:t}=su( e);if(t!==r.serverSignature)throw new Error("SASL: SCRAM-SERVER-FINAL-MESSAGE: s\ erver signature does not match")}a(ru,"finalizeSession");function nu(r){if(typeof r!= "string")throw new TypeError("SASL: text must be a string");return r.split("").map( (e,t)=>r.charCodeAt(t)).every(e=>e>=33&&e<=43||e>=45&&e<=126)}a(nu,"isPrintableC\ hars");function Ni(r){return/^(?:[a-zA-Z0-9+/]{4})*(?:[a-zA-Z0-9+/]{2}==|[a-zA-Z0-9+/]{3}=)?$/. test(r)}a(Ni,"isBase64");function qi(r){if(typeof r!="string")throw new TypeError( "SASL: attribute pairs text must be a string");return new Map(r.split(",").map(e=>{ if(!/^.=/.test(e))throw new Error("SASL: Invalid attribute pair entry");let t=e[0], n=e.substring(2);return[t,n]}))}a(qi,"parseAttributePairs");function iu(r){let e=qi( r),t=e.get("r");if(t){if(!nu(t))throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAG\ E: nonce must only contain printable characters")}else throw new Error("SASL: SC\ RAM-SERVER-FIRST-MESSAGE: nonce missing");let n=e.get("s");if(n){if(!Ni(n))throw new Error( "SASL: SCRAM-SERVER-FIRST-MESSAGE: salt must be base64")}else throw new Error("S\ ASL: SCRAM-SERVER-FIRST-MESSAGE: salt missing");let i=e.get("i");if(i){if(!/^[1-9][0-9]*$/. test(i))throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: invalid iteration cou\ nt")}else throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: iteration missing"); let s=parseInt(i,10);return{nonce:t,salt:n,iteration:s}}a(iu,"parseServerFirstMe\ ssage");function su(r){let t=qi(r).get("v");if(t){if(!Ni(t))throw new Error("SAS\ L: SCRAM-SERVER-FINAL-MESSAGE: server signature must be base64")}else throw new Error( "SASL: SCRAM-SERVER-FINAL-MESSAGE: server signature is missing");return{serverSignature:t}} a(su,"parseServerFinalMessage");function Qi(r,e){if(!y.isBuffer(r))throw new TypeError( "first argument must be a Buffer");if(!y.isBuffer(e))throw new TypeError("second\ argument must be a Buffer");if(r.length!==e.length)throw new Error("Buffer leng\ ths must match");if(r.length===0)throw new Error("Buffers cannot be empty");return y. from(r.map((t,n)=>r[n]^e[n]))}a(Qi,"xorBuffers");function ou(r){return nr.createHash( "sha256").update(r).digest()}a(ou,"sha256");function Oe(r,e){return nr.createHmac( "sha256",r).update(e).digest()}a(Oe,"hmacSha256");function au(r,e,t){for(var n=Oe( r,y.concat([e,y.from([0,0,0,1])])),i=n,s=0;suu});function uu(...r){return r.join("/")}var sr=z(()=>{ "use strict";p();a(uu,"join")});var or={};te(or,{stat:()=>cu});function cu(r,e){e(new Error("No filesystem"))}var ar=z( ()=>{"use strict";p();a(cu,"stat")});var ur={};te(ur,{default:()=>hu});var hu,cr=z(()=>{"use strict";p();hu={}});var Hi={};te(Hi,{StringDecoder:()=>hr});var lr,hr,Gi=z(()=>{"use strict";p();lr= class lr{constructor(e){_(this,"td");this.td=new TextDecoder(e)}write(e){return this. td.decode(e,{stream:!0})}end(e){return this.td.decode(e)}};a(lr,"StringDecoder"); hr=lr});var zi=I((cl,Ki)=>{"use strict";p();var{Transform:lu}=(cr(),N(ur)),{StringDecoder:fu}=(Gi(),N(Hi)), Se=Symbol("last"),pt=Symbol("decoder");function pu(r,e,t){let n;if(this.overflow){ if(n=this[pt].write(r).split(this.matcher),n.length===1)return t();n.shift(),this. overflow=!1}else this[Se]+=this[pt].write(r),n=this[Se].split(this.matcher);this[Se]= n.pop();for(let i=0;ithis.maxLength,this.overflow&&!this.skipOverflow){ t(new Error("maximum buffer reached"));return}t()}a(pu,"transform");function du(r){ if(this[Se]+=this[pt].end(),this[Se])try{Vi(this,this.mapper(this[Se]))}catch(e){ return r(e)}r()}a(du,"flush");function Vi(r,e){e!==void 0&&r.push(e)}a(Vi,"push"); function $i(r){return r}a($i,"noop");function yu(r,e,t){switch(r=r||/\r?\n/,e=e|| $i,t=t||{},arguments.length){case 1:typeof r=="function"?(e=r,r=/\r?\n/):typeof r== "object"&&!(r instanceof RegExp)&&!r[Symbol.split]&&(t=r,r=/\r?\n/);break;case 2: typeof r=="function"?(t=e,e=r,r=/\r?\n/):typeof e=="object"&&(t=e,e=$i)}t=Object. assign({},t),t.autoDestroy=!0,t.transform=pu,t.flush=du,t.readableObjectMode=!0; let n=new lu(t);return n[Se]="",n[pt]=new fu("utf8"),n.matcher=r,n.mapper=e,n.maxLength= t.maxLength,n.skipOverflow=t.skipOverflow||!1,n.overflow=!1,n._destroy=function(i,s){ this._writableState.errorEmitted=!1,s(i)},n}a(yu,"split");Ki.exports=yu});var Ji=I((fl,pe)=>{"use strict";p();var Yi=(sr(),N(ir)),mu=(cr(),N(ur)).Stream,gu=zi(), Zi=(Ge(),N(He)),wu=5432,dt=m.platform==="win32",rt=m.stderr,bu=56,Su=7,Eu=61440, xu=32768;function vu(r){return(r&Eu)==xu}a(vu,"isRegFile");var Ue=["host","port", "database","user","password"],fr=Ue.length,_u=Ue[fr-1];function pr(){var r=rt instanceof mu&&rt.writable===!0;if(r){var e=Array.prototype.slice.call(arguments).concat(` `);rt.write(Zi.format.apply(Zi,e))}}a(pr,"warn");Object.defineProperty(pe.exports, "isWin",{get:a(function(){return dt},"get"),set:a(function(r){dt=r},"set")});pe. exports.warnTo=function(r){var e=rt;return rt=r,e};pe.exports.getFileName=function(r){ var e=r||m.env,t=e.PGPASSFILE||(dt?Yi.join(e.APPDATA||"./","postgresql","pgpass.\ conf"):Yi.join(e.HOME||"./",".pgpass"));return t};pe.exports.usePgPass=function(r,e){ return Object.prototype.hasOwnProperty.call(m.env,"PGPASSWORD")?!1:dt?!0:(e=e||"\ ",vu(r.mode)?r.mode&(bu|Su)?(pr('WARNING: password file "%s" has group or \ world access; permissions should be u=rw (0600) or less',e),!1):!0:(pr('WARNING:\ password file "%s" is not a plain file',e),!1))};var Au=pe.exports.match=function(r,e){ return Ue.slice(0,-1).reduce(function(t,n,i){return i==1&&Number(r[n]||wu)===Number( e[n])?t&&!0:t&&(e[n]==="*"||e[n]===r[n])},!0)};pe.exports.getPassword=function(r,e,t){ var n,i=e.pipe(gu());function s(c){var h=Cu(c);h&&Tu(h)&&Au(r,h)&&(n=h[_u],i.end())} a(s,"onLine");var o=a(function(){e.destroy(),t(n)},"onEnd"),u=a(function(c){e.destroy(), pr("WARNING: error on reading file: %s",c),t(void 0)},"onErr");e.on("error",u),i. on("data",s).on("end",o).on("error",u)};var Cu=pe.exports.parseLine=function(r){ if(r.length<11||r.match(/^\s+#/))return null;for(var e="",t="",n=0,i=0,s=0,o={}, u=!1,c=a(function(l,d,b){var C=r.substring(d,b);Object.hasOwnProperty.call(m.env, "PGPASS_NO_DEESCAPE")||(C=C.replace(/\\([:\\])/g,"$1")),o[Ue[l]]=C},"addToObj"), h=0;h=0&&e==":"&&t!=="\\"&&(c(n,i,h+1),i=h+2,n+=1)}return o=Object.keys(o).length=== fr?o:null,o},Tu=pe.exports.isValidEntry=function(r){for(var e={0:function(o){return o. length>0},1:function(o){return o==="*"?!0:(o=Number(o),isFinite(o)&&o>0&&o<9007199254740992&& Math.floor(o)===o)},2:function(o){return o.length>0},3:function(o){return o.length> 0},4:function(o){return o.length>0}},t=0;t{"use strict";p();var yl=(sr(),N(ir)),Xi=(ar(),N(or)),yt=Ji(); dr.exports=function(r,e){var t=yt.getFileName();Xi.stat(t,function(n,i){if(n||!yt. usePgPass(i,t))return e(void 0);var s=Xi.createReadStream(t);yt.getPassword(r,s, e)})};dr.exports.warnTo=yt.warnTo});var gt=I((wl,ts)=>{"use strict";p();var Iu=Xe();function mt(r){this._types=r||Iu, this.text={},this.binary={}}a(mt,"TypeOverrides");mt.prototype.getOverrides=function(r){ switch(r){case"text":return this.text;case"binary":return this.binary;default:return{}}}; mt.prototype.setTypeParser=function(r,e,t){typeof e=="function"&&(t=e,e="text"), this.getOverrides(e)[r]=t};mt.prototype.getTypeParser=function(r,e){return e=e|| "text",this.getOverrides(e)[r]||this._types.getTypeParser(r,e)};ts.exports=mt});var rs={};te(rs,{default:()=>Pu});var Pu,ns=z(()=>{"use strict";p();Pu={}});var is={};te(is,{parse:()=>yr});function yr(r,e=!1){let{protocol:t}=new URL(r),n="\ http:"+r.substring(t.length),{username:i,password:s,host:o,hostname:u,port:c,pathname:h, search:l,searchParams:d,hash:b}=new URL(n);s=decodeURIComponent(s),i=decodeURIComponent( i),h=decodeURIComponent(h);let C=i+":"+s,B=e?Object.fromEntries(d.entries()):l;return{ href:r,protocol:t,auth:C,username:i,password:s,host:o,hostname:u,port:c,pathname:h, search:l,query:B,hash:b}}var mr=z(()=>{"use strict";p();a(yr,"parse")});var os=I((_l,ss)=>{"use strict";p();var Bu=(mr(),N(is)),gr=(ar(),N(or));function wr(r){ if(r.charAt(0)==="/"){var t=r.split(" ");return{host:t[0],database:t[1]}}var e=Bu. parse(/ |%[^a-f0-9]|%[a-f0-9][^a-f0-9]/i.test(r)?encodeURI(r).replace(/\%25(\d\d)/g, "%$1"):r,!0),t=e.query;for(var n in t)Array.isArray(t[n])&&(t[n]=t[n][t[n].length- 1]);var i=(e.auth||":").split(":");if(t.user=i[0],t.password=i.splice(1).join(":"), t.port=e.port,e.protocol=="socket:")return t.host=decodeURI(e.pathname),t.database= e.query.db,t.client_encoding=e.query.encoding,t;t.host||(t.host=e.hostname);var s=e. pathname;if(!t.host&&s&&/^%2f/i.test(s)){var o=s.split("/");t.host=decodeURIComponent( o[0]),s=o.splice(1).join("/")}switch(s&&s.charAt(0)==="/"&&(s=s.slice(1)||null), t.database=s&&decodeURI(s),(t.ssl==="true"||t.ssl==="1")&&(t.ssl=!0),t.ssl==="0"&& (t.ssl=!1),(t.sslcert||t.sslkey||t.sslrootcert||t.sslmode)&&(t.ssl={}),t.sslcert&& (t.ssl.cert=gr.readFileSync(t.sslcert).toString()),t.sslkey&&(t.ssl.key=gr.readFileSync( t.sslkey).toString()),t.sslrootcert&&(t.ssl.ca=gr.readFileSync(t.sslrootcert).toString()), t.sslmode){case"disable":{t.ssl=!1;break}case"prefer":case"require":case"verify-\ ca":case"verify-full":break;case"no-verify":{t.ssl.rejectUnauthorized=!1;break}} return t}a(wr,"parse");ss.exports=wr;wr.parse=wr});var wt=I((Tl,cs)=>{"use strict";p();var Lu=(ns(),N(rs)),us=et(),as=os().parse,$=a( function(r,e,t){return t===void 0?t=m.env["PG"+r.toUpperCase()]:t===!1||(t=m.env[t]), e[r]||t||us[r]},"val"),Ru=a(function(){switch(m.env.PGSSLMODE){case"disable":return!1;case"\ prefer":case"require":case"verify-ca":case"verify-full":return!0;case"no-verify": return{rejectUnauthorized:!1}}return us.ssl},"readSSLConfigFromEnvironment"),Ne=a( function(r){return"'"+(""+r).replace(/\\/g,"\\\\").replace(/'/g,"\\'")+"'"},"quo\ teParamValue"),ie=a(function(r,e,t){var n=e[t];n!=null&&r.push(t+"="+Ne(n))},"ad\ d"),Sr=class Sr{constructor(e){e=typeof e=="string"?as(e):e||{},e.connectionString&& (e=Object.assign({},e,as(e.connectionString))),this.user=$("user",e),this.database= $("database",e),this.database===void 0&&(this.database=this.user),this.port=parseInt( $("port",e),10),this.host=$("host",e),Object.defineProperty(this,"password",{configurable:!0, enumerable:!1,writable:!0,value:$("password",e)}),this.binary=$("binary",e),this. options=$("options",e),this.ssl=typeof e.ssl>"u"?Ru():e.ssl,typeof this.ssl=="st\ ring"&&this.ssl==="true"&&(this.ssl=!0),this.ssl==="no-verify"&&(this.ssl={rejectUnauthorized:!1}), this.ssl&&this.ssl.key&&Object.defineProperty(this.ssl,"key",{enumerable:!1}),this. client_encoding=$("client_encoding",e),this.replication=$("replication",e),this. isDomainSocket=!(this.host||"").indexOf("/"),this.application_name=$("applicatio\ n_name",e,"PGAPPNAME"),this.fallback_application_name=$("fallback_application_na\ me",e,!1),this.statement_timeout=$("statement_timeout",e,!1),this.lock_timeout=$( "lock_timeout",e,!1),this.idle_in_transaction_session_timeout=$("idle_in_transac\ tion_session_timeout",e,!1),this.query_timeout=$("query_timeout",e,!1),e.connectionTimeoutMillis=== void 0?this.connect_timeout=m.env.PGCONNECT_TIMEOUT||0:this.connect_timeout=Math. floor(e.connectionTimeoutMillis/1e3),e.keepAlive===!1?this.keepalives=0:e.keepAlive=== !0&&(this.keepalives=1),typeof e.keepAliveInitialDelayMillis=="number"&&(this.keepalives_idle= Math.floor(e.keepAliveInitialDelayMillis/1e3))}getLibpqConnectionString(e){var t=[]; ie(t,this,"user"),ie(t,this,"password"),ie(t,this,"port"),ie(t,this,"application\ _name"),ie(t,this,"fallback_application_name"),ie(t,this,"connect_timeout"),ie(t, this,"options");var n=typeof this.ssl=="object"?this.ssl:this.ssl?{sslmode:this. ssl}:{};if(ie(t,n,"sslmode"),ie(t,n,"sslca"),ie(t,n,"sslkey"),ie(t,n,"sslcert"), ie(t,n,"sslrootcert"),this.database&&t.push("dbname="+Ne(this.database)),this.replication&& t.push("replication="+Ne(this.replication)),this.host&&t.push("host="+Ne(this.host)), this.isDomainSocket)return e(null,t.join(" "));this.client_encoding&&t.push("cli\ ent_encoding="+Ne(this.client_encoding)),Lu.lookup(this.host,function(i,s){return i? e(i,null):(t.push("hostaddr="+Ne(s)),e(null,t.join(" ")))})}};a(Sr,"ConnectionPa\ rameters");var br=Sr;cs.exports=br});var fs=I((Bl,ls)=>{"use strict";p();var Fu=Xe(),hs=/^([A-Za-z]+)(?: (\d+))?(?: (\d+))?/, xr=class xr{constructor(e,t){this.command=null,this.rowCount=null,this.oid=null, this.rows=[],this.fields=[],this._parsers=void 0,this._types=t,this.RowCtor=null, this.rowAsArray=e==="array",this.rowAsArray&&(this.parseRow=this._parseRowAsArray)}addCommandComplete(e){ var t;e.text?t=hs.exec(e.text):t=hs.exec(e.command),t&&(this.command=t[1],t[3]?(this. oid=parseInt(t[2],10),this.rowCount=parseInt(t[3],10)):t[2]&&(this.rowCount=parseInt( t[2],10)))}_parseRowAsArray(e){for(var t=new Array(e.length),n=0,i=e.length;n{"use strict";p();var{EventEmitter:Mu}=be(),ps=fs(),ds=tt(),_r=class _r extends Mu{constructor(e,t,n){ super(),e=ds.normalizeQueryConfig(e,t,n),this.text=e.text,this.values=e.values,this. rows=e.rows,this.types=e.types,this.name=e.name,this.binary=e.binary,this.portal= e.portal||"",this.callback=e.callback,this._rowMode=e.rowMode,m.domain&&e.callback&& (this.callback=m.domain.bind(e.callback)),this._result=new ps(this._rowMode,this. types),this._results=this._result,this.isPreparedStatement=!1,this._canceledDueToError= !1,this._promise=null}requiresPreparation(){return this.name||this.rows?!0:!this. text||!this.values?!1:this.values.length>0}_checkForMultirow(){this._result.command&& (Array.isArray(this._results)||(this._results=[this._result]),this._result=new ps( this._rowMode,this.types),this._results.push(this._result))}handleRowDescription(e){ this._checkForMultirow(),this._result.addFields(e.fields),this._accumulateRows=this. callback||!this.listeners("row").length}handleDataRow(e){let t;if(!this._canceledDueToError){ try{t=this._result.parseRow(e.fields)}catch(n){this._canceledDueToError=n;return} this.emit("row",t,this._result),this._accumulateRows&&this._result.addRow(t)}}handleCommandComplete(e,t){ this._checkForMultirow(),this._result.addCommandComplete(e),this.rows&&t.sync()}handleEmptyQuery(e){ this.rows&&e.sync()}handleError(e,t){if(this._canceledDueToError&&(e=this._canceledDueToError, this._canceledDueToError=!1),this.callback)return this.callback(e);this.emit("er\ ror",e)}handleReadyForQuery(e){if(this._canceledDueToError)return this.handleError( this._canceledDueToError,e);if(this.callback)try{this.callback(null,this._results)}catch(t){ m.nextTick(()=>{throw t})}this.emit("end",this._results)}submit(e){if(typeof this. text!="string"&&typeof this.name!="string")return new Error("A query must have e\ ither text or a name. Supplying neither is unsupported.");let t=e.parsedStatements[this. name];return this.text&&t&&this.text!==t?new Error(`Prepared statements must be \ unique - '${this.name}' was used for a different statement`):this.values&&!Array. isArray(this.values)?new Error("Query values must be an array"):(this.requiresPreparation()? this.prepare(e):e.query(this.text),null)}hasBeenParsed(e){return this.name&&e.parsedStatements[this. name]}handlePortalSuspended(e){this._getRows(e,this.rows)}_getRows(e,t){e.execute( {portal:this.portal,rows:t}),t?e.flush():e.sync()}prepare(e){this.isPreparedStatement= !0,this.hasBeenParsed(e)||e.parse({text:this.text,name:this.name,types:this.types}); try{e.bind({portal:this.portal,statement:this.name,values:this.values,binary:this. binary,valueMapper:ds.prepareValue})}catch(t){this.handleError(t,e);return}e.describe( {type:"P",name:this.portal||""}),this._getRows(e,this.rows)}handleCopyInResponse(e){ e.sendCopyFail("No source stream defined")}handleCopyData(e,t){}};a(_r,"Query"); var vr=_r;ys.exports=vr});var bs={};te(bs,{Socket:()=>Ee,isIP:()=>Du});function Du(r){return 0}var ws,gs,v, Ee,bt=z(()=>{"use strict";p();ws=Pe(be(),1);a(Du,"isIP");gs=/^[^.]+\./,v=class v extends ws.EventEmitter{constructor(){ super(...arguments);_(this,"opts",{});_(this,"connecting",!1);_(this,"pending",!0); _(this,"writable",!0);_(this,"encrypted",!1);_(this,"authorized",!1);_(this,"des\ troyed",!1);_(this,"ws",null);_(this,"writeBuffer");_(this,"tlsState",0);_(this, "tlsRead");_(this,"tlsWrite")}static get poolQueryViaFetch(){return v.opts.poolQueryViaFetch?? v.defaults.poolQueryViaFetch}static set poolQueryViaFetch(t){v.opts.poolQueryViaFetch= t}static get fetchEndpoint(){return v.opts.fetchEndpoint??v.defaults.fetchEndpoint}static set fetchEndpoint(t){ v.opts.fetchEndpoint=t}static get fetchConnectionCache(){return!0}static set fetchConnectionCache(t){ console.warn("The `fetchConnectionCache` option is deprecated (now always `true`\ )")}static get fetchFunction(){return v.opts.fetchFunction??v.defaults.fetchFunction}static set fetchFunction(t){ v.opts.fetchFunction=t}static get webSocketConstructor(){return v.opts.webSocketConstructor?? v.defaults.webSocketConstructor}static set webSocketConstructor(t){v.opts.webSocketConstructor= t}get webSocketConstructor(){return this.opts.webSocketConstructor??v.webSocketConstructor}set webSocketConstructor(t){ this.opts.webSocketConstructor=t}static get wsProxy(){return v.opts.wsProxy??v.defaults. wsProxy}static set wsProxy(t){v.opts.wsProxy=t}get wsProxy(){return this.opts.wsProxy?? v.wsProxy}set wsProxy(t){this.opts.wsProxy=t}static get coalesceWrites(){return v. opts.coalesceWrites??v.defaults.coalesceWrites}static set coalesceWrites(t){v.opts. coalesceWrites=t}get coalesceWrites(){return this.opts.coalesceWrites??v.coalesceWrites}set coalesceWrites(t){ this.opts.coalesceWrites=t}static get useSecureWebSocket(){return v.opts.useSecureWebSocket?? v.defaults.useSecureWebSocket}static set useSecureWebSocket(t){v.opts.useSecureWebSocket= t}get useSecureWebSocket(){return this.opts.useSecureWebSocket??v.useSecureWebSocket}set useSecureWebSocket(t){ this.opts.useSecureWebSocket=t}static get forceDisablePgSSL(){return v.opts.forceDisablePgSSL?? v.defaults.forceDisablePgSSL}static set forceDisablePgSSL(t){v.opts.forceDisablePgSSL= t}get forceDisablePgSSL(){return this.opts.forceDisablePgSSL??v.forceDisablePgSSL}set forceDisablePgSSL(t){ this.opts.forceDisablePgSSL=t}static get disableSNI(){return v.opts.disableSNI?? v.defaults.disableSNI}static set disableSNI(t){v.opts.disableSNI=t}get disableSNI(){ return this.opts.disableSNI??v.disableSNI}set disableSNI(t){this.opts.disableSNI= t}static get pipelineConnect(){return v.opts.pipelineConnect??v.defaults.pipelineConnect}static set pipelineConnect(t){ v.opts.pipelineConnect=t}get pipelineConnect(){return this.opts.pipelineConnect?? v.pipelineConnect}set pipelineConnect(t){this.opts.pipelineConnect=t}static get subtls(){ return v.opts.subtls??v.defaults.subtls}static set subtls(t){v.opts.subtls=t}get subtls(){ return this.opts.subtls??v.subtls}set subtls(t){this.opts.subtls=t}static get pipelineTLS(){ return v.opts.pipelineTLS??v.defaults.pipelineTLS}static set pipelineTLS(t){v.opts. pipelineTLS=t}get pipelineTLS(){return this.opts.pipelineTLS??v.pipelineTLS}set pipelineTLS(t){ this.opts.pipelineTLS=t}static get rootCerts(){return v.opts.rootCerts??v.defaults. rootCerts}static set rootCerts(t){v.opts.rootCerts=t}get rootCerts(){return this. opts.rootCerts??v.rootCerts}set rootCerts(t){this.opts.rootCerts=t}wsProxyAddrForHost(t,n){ let i=this.wsProxy;if(i===void 0)throw new Error("No WebSocket proxy is configur\ ed. Please see https://github.com/neondatabase/serverless/blob/main/CONFIG.md#ws\ proxy-string--host-string-port-number--string--string");return typeof i=="functi\ on"?i(t,n):`${i}?address=${t}:${n}`}setNoDelay(){return this}setKeepAlive(){return this}ref(){ return this}unref(){return this}connect(t,n,i){this.connecting=!0,i&&this.once("\ connect",i);let s=a(()=>{this.connecting=!1,this.pending=!1,this.emit("connect"), this.emit("ready")},"handleWebSocketOpen"),o=a((c,h=!1)=>{c.binaryType="arraybuf\ fer",c.addEventListener("error",l=>{this.emit("error",l),this.emit("close")}),c. addEventListener("message",l=>{if(this.tlsState===0){let d=y.from(l.data);this.emit( "data",d)}}),c.addEventListener("close",()=>{this.emit("close")}),h?s():c.addEventListener( "open",s)},"configureWebSocket"),u;try{u=this.wsProxyAddrForHost(n,typeof t=="st\ ring"?parseInt(t,10):t)}catch(c){this.emit("error",c),this.emit("close");return} try{let h=(this.useSecureWebSocket?"wss:":"ws:")+"//"+u;if(this.webSocketConstructor!== void 0)this.ws=new this.webSocketConstructor(h),o(this.ws);else try{this.ws=new WebSocket( h),o(this.ws)}catch{this.ws=new __unstable_WebSocket(h),o(this.ws)}}catch(c){let l=(this. useSecureWebSocket?"https:":"http:")+"//"+u;fetch(l,{headers:{Upgrade:"websocket"}}). then(d=>{if(this.ws=d.webSocket,this.ws==null)throw c;this.ws.accept(),o(this.ws, !0)}).catch(d=>{this.emit("error",new Error(`All attempts to open a WebSocket to\ connect to the database failed. Please refer to https://github.com/neondatabase\ /serverless/blob/main/CONFIG.md#websocketconstructor-typeof-websocket--undefined\ . Details: ${d.message}`)),this.emit("close")})}}async startTls(t){if(this.subtls=== void 0)throw new Error("For Postgres SSL connections, you must set `neonConfig.s\ ubtls` to the subtls library. See https://github.com/neondatabase/serverless/blo\ b/main/CONFIG.md for more information.");this.tlsState=1;let n=this.subtls.TrustedCert. fromPEM(this.rootCerts),i=new this.subtls.WebSocketReadQueue(this.ws),s=i.read.bind( i),o=this.rawWrite.bind(this),[u,c]=await this.subtls.startTls(t,n,s,o,{useSNI:!this. disableSNI,expectPreData:this.pipelineTLS?new Uint8Array([83]):void 0});this.tlsRead= u,this.tlsWrite=c,this.tlsState=2,this.encrypted=!0,this.authorized=!0,this.emit( "secureConnection",this),this.tlsReadLoop()}async tlsReadLoop(){for(;;){let t=await this. tlsRead();if(t===void 0)break;{let n=y.from(t);this.emit("data",n)}}}rawWrite(t){ if(!this.coalesceWrites){this.ws.send(t);return}if(this.writeBuffer===void 0)this. writeBuffer=t,setTimeout(()=>{this.ws.send(this.writeBuffer),this.writeBuffer=void 0}, 0);else{let n=new Uint8Array(this.writeBuffer.length+t.length);n.set(this.writeBuffer), n.set(t,this.writeBuffer.length),this.writeBuffer=n}}write(t,n="utf8",i=s=>{}){return t. length===0?(i(),!0):(typeof t=="string"&&(t=y.from(t,n)),this.tlsState===0?(this. rawWrite(t),i()):this.tlsState===1?this.once("secureConnection",()=>{this.write( t,n,i)}):(this.tlsWrite(t),i()),!0)}end(t=y.alloc(0),n="utf8",i=()=>{}){return this. write(t,n,()=>{this.ws.close(),i()}),this}destroy(){return this.destroyed=!0,this. end()}};a(v,"Socket"),_(v,"defaults",{poolQueryViaFetch:!1,fetchEndpoint:a((t,n,i)=>{ let s;return i?.jwtAuth?s=t.replace(gs,"apiauth."):s=t.replace(gs,"api."),"https\ ://"+s+"/sql"},"fetchEndpoint"),fetchConnectionCache:!0,fetchFunction:void 0,webSocketConstructor:void 0, wsProxy:a(t=>t+"/v2","wsProxy"),useSecureWebSocket:!0,forceDisablePgSSL:!0,coalesceWrites:!0, pipelineConnect:"password",subtls:void 0,rootCerts:"",pipelineTLS:!1,disableSNI:!1}), _(v,"opts",{});Ee=v});var Xr=I(T=>{"use strict";p();Object.defineProperty(T,"__esModule",{value:!0});T. NoticeMessage=T.DataRowMessage=T.CommandCompleteMessage=T.ReadyForQueryMessage=T. NotificationResponseMessage=T.BackendKeyDataMessage=T.AuthenticationMD5Password= T.ParameterStatusMessage=T.ParameterDescriptionMessage=T.RowDescriptionMessage=T. Field=T.CopyResponse=T.CopyDataMessage=T.DatabaseError=T.copyDone=T.emptyQuery=T. replicationStart=T.portalSuspended=T.noData=T.closeComplete=T.bindComplete=T.parseComplete= void 0;T.parseComplete={name:"parseComplete",length:5};T.bindComplete={name:"bin\ dComplete",length:5};T.closeComplete={name:"closeComplete",length:5};T.noData={name:"\ noData",length:5};T.portalSuspended={name:"portalSuspended",length:5};T.replicationStart= {name:"replicationStart",length:4};T.emptyQuery={name:"emptyQuery",length:4};T.copyDone= {name:"copyDone",length:4};var Nr=class Nr extends Error{constructor(e,t,n){super( e),this.length=t,this.name=n}};a(Nr,"DatabaseError");var Ar=Nr;T.DatabaseError=Ar; var qr=class qr{constructor(e,t){this.length=e,this.chunk=t,this.name="copyData"}}; a(qr,"CopyDataMessage");var Cr=qr;T.CopyDataMessage=Cr;var Qr=class Qr{constructor(e,t,n,i){ this.length=e,this.name=t,this.binary=n,this.columnTypes=new Array(i)}};a(Qr,"Co\ pyResponse");var Tr=Qr;T.CopyResponse=Tr;var jr=class jr{constructor(e,t,n,i,s,o,u){ this.name=e,this.tableID=t,this.columnID=n,this.dataTypeID=i,this.dataTypeSize=s, this.dataTypeModifier=o,this.format=u}};a(jr,"Field");var Ir=jr;T.Field=Ir;var Wr=class Wr{constructor(e,t){ this.length=e,this.fieldCount=t,this.name="rowDescription",this.fields=new Array( this.fieldCount)}};a(Wr,"RowDescriptionMessage");var Pr=Wr;T.RowDescriptionMessage= Pr;var Hr=class Hr{constructor(e,t){this.length=e,this.parameterCount=t,this.name= "parameterDescription",this.dataTypeIDs=new Array(this.parameterCount)}};a(Hr,"P\ arameterDescriptionMessage");var Br=Hr;T.ParameterDescriptionMessage=Br;var Gr=class Gr{constructor(e,t,n){ this.length=e,this.parameterName=t,this.parameterValue=n,this.name="parameterSta\ tus"}};a(Gr,"ParameterStatusMessage");var Lr=Gr;T.ParameterStatusMessage=Lr;var $r=class $r{constructor(e,t){ this.length=e,this.salt=t,this.name="authenticationMD5Password"}};a($r,"Authenti\ cationMD5Password");var Rr=$r;T.AuthenticationMD5Password=Rr;var Vr=class Vr{constructor(e,t,n){ this.length=e,this.processID=t,this.secretKey=n,this.name="backendKeyData"}};a(Vr, "BackendKeyDataMessage");var Fr=Vr;T.BackendKeyDataMessage=Fr;var Kr=class Kr{constructor(e,t,n,i){ this.length=e,this.processId=t,this.channel=n,this.payload=i,this.name="notifica\ tion"}};a(Kr,"NotificationResponseMessage");var Mr=Kr;T.NotificationResponseMessage= Mr;var zr=class zr{constructor(e,t){this.length=e,this.status=t,this.name="ready\ ForQuery"}};a(zr,"ReadyForQueryMessage");var Dr=zr;T.ReadyForQueryMessage=Dr;var Yr=class Yr{constructor(e,t){ this.length=e,this.text=t,this.name="commandComplete"}};a(Yr,"CommandCompleteMes\ sage");var kr=Yr;T.CommandCompleteMessage=kr;var Zr=class Zr{constructor(e,t){this. length=e,this.fields=t,this.name="dataRow",this.fieldCount=t.length}};a(Zr,"Data\ RowMessage");var Or=Zr;T.DataRowMessage=Or;var Jr=class Jr{constructor(e,t){this. length=e,this.message=t,this.name="notice"}};a(Jr,"NoticeMessage");var Ur=Jr;T.NoticeMessage= Ur});var Ss=I(St=>{"use strict";p();Object.defineProperty(St,"__esModule",{value:!0}); St.Writer=void 0;var tn=class tn{constructor(e=256){this.size=e,this.offset=5,this. headerPosition=0,this.buffer=y.allocUnsafe(e)}ensure(e){var t=this.buffer.length- this.offset;if(t>1)+e;this.buffer=y.allocUnsafe( i),n.copy(this.buffer)}}addInt32(e){return this.ensure(4),this.buffer[this.offset++]= e>>>24&255,this.buffer[this.offset++]=e>>>16&255,this.buffer[this.offset++]=e>>> 8&255,this.buffer[this.offset++]=e>>>0&255,this}addInt16(e){return this.ensure(2), this.buffer[this.offset++]=e>>>8&255,this.buffer[this.offset++]=e>>>0&255,this}addCString(e){ if(!e)this.ensure(1);else{var t=y.byteLength(e);this.ensure(t+1),this.buffer.write( e,this.offset,"utf-8"),this.offset+=t}return this.buffer[this.offset++]=0,this}addString(e=""){ var t=y.byteLength(e);return this.ensure(t),this.buffer.write(e,this.offset),this. offset+=t,this}add(e){return this.ensure(e.length),e.copy(this.buffer,this.offset), this.offset+=e.length,this}join(e){if(e){this.buffer[this.headerPosition]=e;let t=this. offset-(this.headerPosition+1);this.buffer.writeInt32BE(t,this.headerPosition+1)} return this.buffer.slice(e?0:5,this.offset)}flush(e){var t=this.join(e);return this. offset=5,this.headerPosition=0,this.buffer=y.allocUnsafe(this.size),t}};a(tn,"Wr\ iter");var en=tn;St.Writer=en});var xs=I(xt=>{"use strict";p();Object.defineProperty(xt,"__esModule",{value:!0}); xt.serialize=void 0;var rn=Ss(),M=new rn.Writer,ku=a(r=>{M.addInt16(3).addInt16( 0);for(let n of Object.keys(r))M.addCString(n).addCString(r[n]);M.addCString("cl\ ient_encoding").addCString("UTF8");var e=M.addCString("").flush(),t=e.length+4;return new rn. Writer().addInt32(t).add(e).flush()},"startup"),Ou=a(()=>{let r=y.allocUnsafe(8); return r.writeInt32BE(8,0),r.writeInt32BE(80877103,4),r},"requestSsl"),Uu=a(r=>M. addCString(r).flush(112),"password"),Nu=a(function(r,e){return M.addCString(r).addInt32( y.byteLength(e)).addString(e),M.flush(112)},"sendSASLInitialResponseMessage"),qu=a( function(r){return M.addString(r).flush(112)},"sendSCRAMClientFinalMessage"),Qu=a( r=>M.addCString(r).flush(81),"query"),Es=[],ju=a(r=>{let e=r.name||"";e.length>63&& (console.error("Warning! Postgres only supports 63 characters for query names."), console.error("You supplied %s (%s)",e,e.length),console.error("This can cause c\ onflicts and silent errors executing queries"));let t=r.types||Es;for(var n=t.length, i=M.addCString(e).addCString(r.text).addInt16(n),s=0;s{let e=r.portal||"",t=r.statement|| "",n=r.binary||!1,i=r.values||Es,s=i.length;return M.addCString(e).addCString(t), M.addInt16(s),Wu(i,r.valueMapper),M.addInt16(s),M.add(qe.flush()),M.addInt16(n?1: 0),M.flush(66)},"bind"),Gu=y.from([69,0,0,0,9,0,0,0,0,0]),$u=a(r=>{if(!r||!r.portal&& !r.rows)return Gu;let e=r.portal||"",t=r.rows||0,n=y.byteLength(e),i=4+n+1+4,s=y. allocUnsafe(1+i);return s[0]=69,s.writeInt32BE(i,1),s.write(e,5,"utf-8"),s[n+5]= 0,s.writeUInt32BE(t,s.length-4),s},"execute"),Vu=a((r,e)=>{let t=y.allocUnsafe(16); return t.writeInt32BE(16,0),t.writeInt16BE(1234,4),t.writeInt16BE(5678,6),t.writeInt32BE( r,8),t.writeInt32BE(e,12),t},"cancel"),nn=a((r,e)=>{let n=4+y.byteLength(e)+1,i=y. allocUnsafe(1+n);return i[0]=r,i.writeInt32BE(n,1),i.write(e,5,"utf-8"),i[n]=0,i}, "cstringMessage"),Ku=M.addCString("P").flush(68),zu=M.addCString("S").flush(68), Yu=a(r=>r.name?nn(68,`${r.type}${r.name||""}`):r.type==="P"?Ku:zu,"describe"),Zu=a( r=>{let e=`${r.type}${r.name||""}`;return nn(67,e)},"close"),Ju=a(r=>M.add(r).flush( 100),"copyData"),Xu=a(r=>nn(102,r),"copyFail"),Et=a(r=>y.from([r,0,0,0,4]),"code\ OnlyBuffer"),ec=Et(72),tc=Et(83),rc=Et(88),nc=Et(99),ic={startup:ku,password:Uu, requestSsl:Ou,sendSASLInitialResponseMessage:Nu,sendSCRAMClientFinalMessage:qu,query:Qu, parse:ju,bind:Hu,execute:$u,describe:Yu,close:Zu,flush:a(()=>ec,"flush"),sync:a( ()=>tc,"sync"),end:a(()=>rc,"end"),copyData:Ju,copyDone:a(()=>nc,"copyDone"),copyFail:Xu, cancel:Vu};xt.serialize=ic});var vs=I(vt=>{"use strict";p();Object.defineProperty(vt,"__esModule",{value:!0}); vt.BufferReader=void 0;var sc=y.allocUnsafe(0),on=class on{constructor(e=0){this. offset=e,this.buffer=sc,this.encoding="utf-8"}setBuffer(e,t){this.offset=e,this. buffer=t}int16(){let e=this.buffer.readInt16BE(this.offset);return this.offset+= 2,e}byte(){let e=this.buffer[this.offset];return this.offset++,e}int32(){let e=this. buffer.readInt32BE(this.offset);return this.offset+=4,e}string(e){let t=this.buffer. toString(this.encoding,this.offset,this.offset+e);return this.offset+=e,t}cstring(){ let e=this.offset,t=e;for(;this.buffer[t++]!==0;);return this.offset=t,this.buffer. toString(this.encoding,e,t-1)}bytes(e){let t=this.buffer.slice(this.offset,this. offset+e);return this.offset+=e,t}};a(on,"BufferReader");var sn=on;vt.BufferReader= sn});var Cs=I(_t=>{"use strict";p();Object.defineProperty(_t,"__esModule",{value:!0}); _t.Parser=void 0;var D=Xr(),oc=vs(),an=1,ac=4,_s=an+ac,As=y.allocUnsafe(0),cn=class cn{constructor(e){ if(this.buffer=As,this.bufferLength=0,this.bufferOffset=0,this.reader=new oc.BufferReader, e?.mode==="binary")throw new Error("Binary mode not supported yet");this.mode=e?. mode||"text"}parse(e,t){this.mergeBuffer(e);let n=this.bufferOffset+this.bufferLength, i=this.bufferOffset;for(;i+_s<=n;){let s=this.buffer[i],o=this.buffer.readUInt32BE( i+an),u=an+o;if(u+i<=n){let c=this.handlePacket(i+_s,s,o,this.buffer);t(c),i+=u}else break}i===n?(this.buffer=As,this.bufferLength=0,this.bufferOffset=0):(this.bufferLength= n-i,this.bufferOffset=i)}mergeBuffer(e){if(this.bufferLength>0){let t=this.bufferLength+ e.byteLength;if(t+this.bufferOffset>this.buffer.byteLength){let i;if(t<=this.buffer. byteLength&&this.bufferOffset>=this.bufferLength)i=this.buffer;else{let s=this.buffer. byteLength*2;for(;t>=s;)s*=2;i=y.allocUnsafe(s)}this.buffer.copy(i,0,this.bufferOffset, this.bufferOffset+this.bufferLength),this.buffer=i,this.bufferOffset=0}e.copy(this. buffer,this.bufferOffset+this.bufferLength),this.bufferLength=t}else this.buffer= e,this.bufferOffset=0,this.bufferLength=e.byteLength}handlePacket(e,t,n,i){switch(t){case 50: return D.bindComplete;case 49:return D.parseComplete;case 51:return D.closeComplete;case 110: return D.noData;case 115:return D.portalSuspended;case 99:return D.copyDone;case 87: return D.replicationStart;case 73:return D.emptyQuery;case 68:return this.parseDataRowMessage( e,n,i);case 67:return this.parseCommandCompleteMessage(e,n,i);case 90:return this. parseReadyForQueryMessage(e,n,i);case 65:return this.parseNotificationMessage(e, n,i);case 82:return this.parseAuthenticationResponse(e,n,i);case 83:return this. parseParameterStatusMessage(e,n,i);case 75:return this.parseBackendKeyData(e,n,i);case 69: return this.parseErrorMessage(e,n,i,"error");case 78:return this.parseErrorMessage( e,n,i,"notice");case 84:return this.parseRowDescriptionMessage(e,n,i);case 116:return this. parseParameterDescriptionMessage(e,n,i);case 71:return this.parseCopyInMessage(e, n,i);case 72:return this.parseCopyOutMessage(e,n,i);case 100:return this.parseCopyData( e,n,i);default:return new D.DatabaseError("received invalid response: "+t.toString( 16),n,"error")}}parseReadyForQueryMessage(e,t,n){this.reader.setBuffer(e,n);let i=this. reader.string(1);return new D.ReadyForQueryMessage(t,i)}parseCommandCompleteMessage(e,t,n){ this.reader.setBuffer(e,n);let i=this.reader.cstring();return new D.CommandCompleteMessage( t,i)}parseCopyData(e,t,n){let i=n.slice(e,e+(t-4));return new D.CopyDataMessage( t,i)}parseCopyInMessage(e,t,n){return this.parseCopyMessage(e,t,n,"copyInRespons\ e")}parseCopyOutMessage(e,t,n){return this.parseCopyMessage(e,t,n,"copyOutRespon\ se")}parseCopyMessage(e,t,n,i){this.reader.setBuffer(e,n);let s=this.reader.byte()!== 0,o=this.reader.int16(),u=new D.CopyResponse(t,i,s,o);for(let c=0;c{"use strict";p();Object.defineProperty(xe,"__esModule",{value:!0}); xe.DatabaseError=xe.serialize=xe.parse=void 0;var uc=Xr();Object.defineProperty( xe,"DatabaseError",{enumerable:!0,get:a(function(){return uc.DatabaseError},"get")}); var cc=xs();Object.defineProperty(xe,"serialize",{enumerable:!0,get:a(function(){ return cc.serialize},"get")});var hc=Cs();function lc(r,e){let t=new hc.Parser;return r. on("data",n=>t.parse(n,e)),new Promise(n=>r.on("end",()=>n()))}a(lc,"parse");xe. parse=lc});var Ts={};te(Ts,{connect:()=>fc});function fc({socket:r,servername:e}){return r. startTls(e),r}var Is=z(()=>{"use strict";p();a(fc,"connect")});var pn=I((sf,Ls)=>{"use strict";p();var Ps=(bt(),N(bs)),pc=be().EventEmitter,{parse:dc, serialize:Q}=hn(),Bs=Q.flush(),yc=Q.sync(),mc=Q.end(),fn=class fn extends pc{constructor(e){ super(),e=e||{},this.stream=e.stream||new Ps.Socket,this._keepAlive=e.keepAlive, this._keepAliveInitialDelayMillis=e.keepAliveInitialDelayMillis,this.lastBuffer= !1,this.parsedStatements={},this.ssl=e.ssl||!1,this._ending=!1,this._emitMessage= !1;var t=this;this.on("newListener",function(n){n==="message"&&(t._emitMessage=!0)})}connect(e,t){ var n=this;this._connecting=!0,this.stream.setNoDelay(!0),this.stream.connect(e, t),this.stream.once("connect",function(){n._keepAlive&&n.stream.setKeepAlive(!0, n._keepAliveInitialDelayMillis),n.emit("connect")});let i=a(function(s){n._ending&& (s.code==="ECONNRESET"||s.code==="EPIPE")||n.emit("error",s)},"reportStreamError"); if(this.stream.on("error",i),this.stream.on("close",function(){n.emit("end")}),!this. ssl)return this.attachListeners(this.stream);this.stream.once("data",function(s){ var o=s.toString("utf8");switch(o){case"S":break;case"N":return n.stream.end(),n. emit("error",new Error("The server does not support SSL connections"));default:return n. stream.end(),n.emit("error",new Error("There was an error establishing an SSL co\ nnection"))}var u=(Is(),N(Ts));let c={socket:n.stream};n.ssl!==!0&&(Object.assign( c,n.ssl),"key"in n.ssl&&(c.key=n.ssl.key)),Ps.isIP(t)===0&&(c.servername=t);try{ n.stream=u.connect(c)}catch(h){return n.emit("error",h)}n.attachListeners(n.stream), n.stream.on("error",i),n.emit("sslconnect")})}attachListeners(e){e.on("end",()=>{ this.emit("end")}),dc(e,t=>{var n=t.name==="error"?"errorMessage":t.name;this._emitMessage&& this.emit("message",t),this.emit(n,t)})}requestSsl(){this.stream.write(Q.requestSsl())}startup(e){ this.stream.write(Q.startup(e))}cancel(e,t){this._send(Q.cancel(e,t))}password(e){ this._send(Q.password(e))}sendSASLInitialResponseMessage(e,t){this._send(Q.sendSASLInitialResponseMessage( e,t))}sendSCRAMClientFinalMessage(e){this._send(Q.sendSCRAMClientFinalMessage(e))}_send(e){ return this.stream.writable?this.stream.write(e):!1}query(e){this._send(Q.query( e))}parse(e){this._send(Q.parse(e))}bind(e){this._send(Q.bind(e))}execute(e){this. _send(Q.execute(e))}flush(){this.stream.writable&&this.stream.write(Bs)}sync(){this. _ending=!0,this._send(Bs),this._send(yc)}ref(){this.stream.ref()}unref(){this.stream. unref()}end(){if(this._ending=!0,!this._connecting||!this.stream.writable){this. stream.end();return}return this.stream.write(mc,()=>{this.stream.end()})}close(e){ this._send(Q.close(e))}describe(e){this._send(Q.describe(e))}sendCopyFromChunk(e){ this._send(Q.copyData(e))}endCopyFrom(){this._send(Q.copyDone())}sendCopyFail(e){ this._send(Q.copyFail(e))}};a(fn,"Connection");var ln=fn;Ls.exports=ln});var Ms=I((cf,Fs)=>{"use strict";p();var gc=be().EventEmitter,uf=(Ge(),N(He)),wc=tt(), dn=Wi(),bc=es(),Sc=gt(),Ec=wt(),Rs=ms(),xc=et(),vc=pn(),yn=class yn extends gc{constructor(e){ super(),this.connectionParameters=new Ec(e),this.user=this.connectionParameters. user,this.database=this.connectionParameters.database,this.port=this.connectionParameters. port,this.host=this.connectionParameters.host,Object.defineProperty(this,"passwo\ rd",{configurable:!0,enumerable:!1,writable:!0,value:this.connectionParameters.password}), this.replication=this.connectionParameters.replication;var t=e||{};this._Promise= t.Promise||S.Promise,this._types=new Sc(t.types),this._ending=!1,this._connecting= !1,this._connected=!1,this._connectionError=!1,this._queryable=!0,this.connection= t.connection||new vc({stream:t.stream,ssl:this.connectionParameters.ssl,keepAlive:t. keepAlive||!1,keepAliveInitialDelayMillis:t.keepAliveInitialDelayMillis||0,encoding:this. connectionParameters.client_encoding||"utf8"}),this.queryQueue=[],this.binary=t. binary||xc.binary,this.processID=null,this.secretKey=null,this.ssl=this.connectionParameters. ssl||!1,this.ssl&&this.ssl.key&&Object.defineProperty(this.ssl,"key",{enumerable:!1}), this._connectionTimeoutMillis=t.connectionTimeoutMillis||0}_errorAllQueries(e){let t=a( n=>{m.nextTick(()=>{n.handleError(e,this.connection)})},"enqueueError");this.activeQuery&& (t(this.activeQuery),this.activeQuery=null),this.queryQueue.forEach(t),this.queryQueue. length=0}_connect(e){var t=this,n=this.connection;if(this._connectionCallback=e, this._connecting||this._connected){let i=new Error("Client has already been conn\ ected. You cannot reuse a client.");m.nextTick(()=>{e(i)});return}this._connecting= !0,this.connectionTimeoutHandle,this._connectionTimeoutMillis>0&&(this.connectionTimeoutHandle= setTimeout(()=>{n._ending=!0,n.stream.destroy(new Error("timeout expired"))},this. _connectionTimeoutMillis)),this.host&&this.host.indexOf("/")===0?n.connect(this. host+"/.s.PGSQL."+this.port):n.connect(this.port,this.host),n.on("connect",function(){ t.ssl?n.requestSsl():n.startup(t.getStartupConf())}),n.on("sslconnect",function(){ n.startup(t.getStartupConf())}),this._attachListeners(n),n.once("end",()=>{let i=this. _ending?new Error("Connection terminated"):new Error("Connection terminated unex\ pectedly");clearTimeout(this.connectionTimeoutHandle),this._errorAllQueries(i),this. _ending||(this._connecting&&!this._connectionError?this._connectionCallback?this. _connectionCallback(i):this._handleErrorEvent(i):this._connectionError||this._handleErrorEvent( i)),m.nextTick(()=>{this.emit("end")})})}connect(e){if(e){this._connect(e);return} return new this._Promise((t,n)=>{this._connect(i=>{i?n(i):t()})})}_attachListeners(e){ e.on("authenticationCleartextPassword",this._handleAuthCleartextPassword.bind(this)), e.on("authenticationMD5Password",this._handleAuthMD5Password.bind(this)),e.on("a\ uthenticationSASL",this._handleAuthSASL.bind(this)),e.on("authenticationSASLCont\ inue",this._handleAuthSASLContinue.bind(this)),e.on("authenticationSASLFinal",this. _handleAuthSASLFinal.bind(this)),e.on("backendKeyData",this._handleBackendKeyData. bind(this)),e.on("error",this._handleErrorEvent.bind(this)),e.on("errorMessage", this._handleErrorMessage.bind(this)),e.on("readyForQuery",this._handleReadyForQuery. bind(this)),e.on("notice",this._handleNotice.bind(this)),e.on("rowDescription",this. _handleRowDescription.bind(this)),e.on("dataRow",this._handleDataRow.bind(this)), e.on("portalSuspended",this._handlePortalSuspended.bind(this)),e.on("emptyQuery", this._handleEmptyQuery.bind(this)),e.on("commandComplete",this._handleCommandComplete. bind(this)),e.on("parseComplete",this._handleParseComplete.bind(this)),e.on("cop\ yInResponse",this._handleCopyInResponse.bind(this)),e.on("copyData",this._handleCopyData. bind(this)),e.on("notification",this._handleNotification.bind(this))}_checkPgPass(e){ let t=this.connection;typeof this.password=="function"?this._Promise.resolve().then( ()=>this.password()).then(n=>{if(n!==void 0){if(typeof n!="string"){t.emit("erro\ r",new TypeError("Password must be a string"));return}this.connectionParameters. password=this.password=n}else this.connectionParameters.password=this.password=null; e()}).catch(n=>{t.emit("error",n)}):this.password!==null?e():bc(this.connectionParameters, n=>{n!==void 0&&(this.connectionParameters.password=this.password=n),e()})}_handleAuthCleartextPassword(e){ this._checkPgPass(()=>{this.connection.password(this.password)})}_handleAuthMD5Password(e){ this._checkPgPass(()=>{let t=wc.postgresMd5PasswordHash(this.user,this.password, e.salt);this.connection.password(t)})}_handleAuthSASL(e){this._checkPgPass(()=>{ this.saslSession=dn.startSession(e.mechanisms),this.connection.sendSASLInitialResponseMessage( this.saslSession.mechanism,this.saslSession.response)})}_handleAuthSASLContinue(e){ dn.continueSession(this.saslSession,this.password,e.data),this.connection.sendSCRAMClientFinalMessage( this.saslSession.response)}_handleAuthSASLFinal(e){dn.finalizeSession(this.saslSession, e.data),this.saslSession=null}_handleBackendKeyData(e){this.processID=e.processID, this.secretKey=e.secretKey}_handleReadyForQuery(e){this._connecting&&(this._connecting= !1,this._connected=!0,clearTimeout(this.connectionTimeoutHandle),this._connectionCallback&& (this._connectionCallback(null,this),this._connectionCallback=null),this.emit("c\ onnect"));let{activeQuery:t}=this;this.activeQuery=null,this.readyForQuery=!0,t&& t.handleReadyForQuery(this.connection),this._pulseQueryQueue()}_handleErrorWhileConnecting(e){ if(!this._connectionError){if(this._connectionError=!0,clearTimeout(this.connectionTimeoutHandle), this._connectionCallback)return this._connectionCallback(e);this.emit("error",e)}}_handleErrorEvent(e){ if(this._connecting)return this._handleErrorWhileConnecting(e);this._queryable=!1, this._errorAllQueries(e),this.emit("error",e)}_handleErrorMessage(e){if(this._connecting) return this._handleErrorWhileConnecting(e);let t=this.activeQuery;if(!t){this._handleErrorEvent( e);return}this.activeQuery=null,t.handleError(e,this.connection)}_handleRowDescription(e){ this.activeQuery.handleRowDescription(e)}_handleDataRow(e){this.activeQuery.handleDataRow( e)}_handlePortalSuspended(e){this.activeQuery.handlePortalSuspended(this.connection)}_handleEmptyQuery(e){ this.activeQuery.handleEmptyQuery(this.connection)}_handleCommandComplete(e){this. activeQuery.handleCommandComplete(e,this.connection)}_handleParseComplete(e){this. activeQuery.name&&(this.connection.parsedStatements[this.activeQuery.name]=this. activeQuery.text)}_handleCopyInResponse(e){this.activeQuery.handleCopyInResponse( this.connection)}_handleCopyData(e){this.activeQuery.handleCopyData(e,this.connection)}_handleNotification(e){ this.emit("notification",e)}_handleNotice(e){this.emit("notice",e)}getStartupConf(){ var e=this.connectionParameters,t={user:e.user,database:e.database},n=e.application_name|| e.fallback_application_name;return n&&(t.application_name=n),e.replication&&(t.replication= ""+e.replication),e.statement_timeout&&(t.statement_timeout=String(parseInt(e.statement_timeout, 10))),e.lock_timeout&&(t.lock_timeout=String(parseInt(e.lock_timeout,10))),e.idle_in_transaction_session_timeout&& (t.idle_in_transaction_session_timeout=String(parseInt(e.idle_in_transaction_session_timeout, 10))),e.options&&(t.options=e.options),t}cancel(e,t){if(e.activeQuery===t){var n=this. connection;this.host&&this.host.indexOf("/")===0?n.connect(this.host+"/.s.PGSQL."+ this.port):n.connect(this.port,this.host),n.on("connect",function(){n.cancel(e.processID, e.secretKey)})}else e.queryQueue.indexOf(t)!==-1&&e.queryQueue.splice(e.queryQueue. indexOf(t),1)}setTypeParser(e,t,n){return this._types.setTypeParser(e,t,n)}getTypeParser(e,t){ return this._types.getTypeParser(e,t)}escapeIdentifier(e){return'"'+e.replace(/"/g, '""')+'"'}escapeLiteral(e){for(var t=!1,n="'",i=0;i{this.activeQuery.handleError(e,this.connection),this.readyForQuery= !0,this._pulseQueryQueue()})}else this.hasExecuted&&(this.activeQuery=null,this. emit("drain"))}query(e,t,n){var i,s,o,u,c;if(e==null)throw new TypeError("Client\ was passed a null or undefined query");return typeof e.submit=="function"?(o=e. query_timeout||this.connectionParameters.query_timeout,s=i=e,typeof t=="function"&& (i.callback=i.callback||t)):(o=this.connectionParameters.query_timeout,i=new Rs( e,t,n),i.callback||(s=new this._Promise((h,l)=>{i.callback=(d,b)=>d?l(d):h(b)}))), o&&(c=i.callback,u=setTimeout(()=>{var h=new Error("Query read timeout");m.nextTick( ()=>{i.handleError(h,this.connection)}),c(h),i.callback=()=>{};var l=this.queryQueue. indexOf(i);l>-1&&this.queryQueue.splice(l,1),this._pulseQueryQueue()},o),i.callback= (h,l)=>{clearTimeout(u),c(h,l)}),this.binary&&!i.binary&&(i.binary=!0),i._result&& !i._result._types&&(i._result._types=this._types),this._queryable?this._ending?(m. nextTick(()=>{i.handleError(new Error("Client was closed and is not queryable"), this.connection)}),s):(this.queryQueue.push(i),this._pulseQueryQueue(),s):(m.nextTick( ()=>{i.handleError(new Error("Client has encountered a connection error and is n\ ot queryable"),this.connection)}),s)}ref(){this.connection.ref()}unref(){this.connection. unref()}end(e){if(this._ending=!0,!this.connection._connecting)if(e)e();else return this. _Promise.resolve();if(this.activeQuery||!this._queryable?this.connection.stream. destroy():this.connection.end(),e)this.connection.once("end",e);else return new this. _Promise(t=>{this.connection.once("end",t)})}};a(yn,"Client");var At=yn;At.Query= Rs;Fs.exports=At});var Us=I((ff,Os)=>{"use strict";p();var _c=be().EventEmitter,Ds=a(function(){},"\ NOOP"),ks=a((r,e)=>{let t=r.findIndex(e);return t===-1?void 0:r.splice(t,1)[0]}, "removeWhere"),wn=class wn{constructor(e,t,n){this.client=e,this.idleListener=t, this.timeoutId=n}};a(wn,"IdleItem");var mn=wn,bn=class bn{constructor(e){this.callback= e}};a(bn,"PendingItem");var Qe=bn;function Ac(){throw new Error("Release called \ on client which has already been released to the pool.")}a(Ac,"throwOnDoubleRele\ ase");function Ct(r,e){if(e)return{callback:e,result:void 0};let t,n,i=a(function(o,u){ o?t(o):n(u)},"cb"),s=new r(function(o,u){n=o,t=u}).catch(o=>{throw Error.captureStackTrace( o),o});return{callback:i,result:s}}a(Ct,"promisify");function Cc(r,e){return a(function t(n){ n.client=e,e.removeListener("error",t),e.on("error",()=>{r.log("additional clien\ t error after disconnection due to error",n)}),r._remove(e),r.emit("error",n,e)}, "idleListener")}a(Cc,"makeIdleListener");var Sn=class Sn extends _c{constructor(e,t){ super(),this.options=Object.assign({},e),e!=null&&"password"in e&&Object.defineProperty( this.options,"password",{configurable:!0,enumerable:!1,writable:!0,value:e.password}), e!=null&&e.ssl&&e.ssl.key&&Object.defineProperty(this.options.ssl,"key",{enumerable:!1}), this.options.max=this.options.max||this.options.poolSize||10,this.options.maxUses= this.options.maxUses||1/0,this.options.allowExitOnIdle=this.options.allowExitOnIdle|| !1,this.options.maxLifetimeSeconds=this.options.maxLifetimeSeconds||0,this.log=this. options.log||function(){},this.Client=this.options.Client||t||Tt().Client,this.Promise= this.options.Promise||S.Promise,typeof this.options.idleTimeoutMillis>"u"&&(this. options.idleTimeoutMillis=1e4),this._clients=[],this._idle=[],this._expired=new WeakSet, this._pendingQueue=[],this._endCallback=void 0,this.ending=!1,this.ended=!1}_isFull(){ return this._clients.length>=this.options.max}_pulseQueue(){if(this.log("pulse q\ ueue"),this.ended){this.log("pulse queue ended");return}if(this.ending){this.log( "pulse queue on ending"),this._idle.length&&this._idle.slice().map(t=>{this._remove( t.client)}),this._clients.length||(this.ended=!0,this._endCallback());return}if(!this. _pendingQueue.length){this.log("no queued requests");return}if(!this._idle.length&& this._isFull())return;let e=this._pendingQueue.shift();if(this._idle.length){let t=this. _idle.pop();clearTimeout(t.timeoutId);let n=t.client;n.ref&&n.ref();let i=t.idleListener; return this._acquireClient(n,e,i,!1)}if(!this._isFull())return this.newClient(e); throw new Error("unexpected condition")}_remove(e){let t=ks(this._idle,n=>n.client=== e);t!==void 0&&clearTimeout(t.timeoutId),this._clients=this._clients.filter(n=>n!== e),e.end(),this.emit("remove",e)}connect(e){if(this.ending){let i=new Error("Can\ not use a pool after calling end on the pool");return e?e(i):this.Promise.reject( i)}let t=Ct(this.Promise,e),n=t.result;if(this._isFull()||this._idle.length){if(this. _idle.length&&m.nextTick(()=>this._pulseQueue()),!this.options.connectionTimeoutMillis) return this._pendingQueue.push(new Qe(t.callback)),n;let i=a((u,c,h)=>{clearTimeout( o),t.callback(u,c,h)},"queueCallback"),s=new Qe(i),o=setTimeout(()=>{ks(this._pendingQueue, u=>u.callback===i),s.timedOut=!0,t.callback(new Error("timeout exceeded when try\ ing to connect"))},this.options.connectionTimeoutMillis);return this._pendingQueue. push(s),n}return this.newClient(new Qe(t.callback)),n}newClient(e){let t=new this. Client(this.options);this._clients.push(t);let n=Cc(this,t);this.log("checking c\ lient timeout");let i,s=!1;this.options.connectionTimeoutMillis&&(i=setTimeout(()=>{ this.log("ending client due to timeout"),s=!0,t.connection?t.connection.stream.destroy(): t.end()},this.options.connectionTimeoutMillis)),this.log("connecting new client"), t.connect(o=>{if(i&&clearTimeout(i),t.on("error",n),o)this.log("client failed to\ connect",o),this._clients=this._clients.filter(u=>u!==t),s&&(o.message="Connect\ ion terminated due to connection timeout"),this._pulseQueue(),e.timedOut||e.callback( o,void 0,Ds);else{if(this.log("new client connected"),this.options.maxLifetimeSeconds!== 0){let u=setTimeout(()=>{this.log("ending client due to expired lifetime"),this. _expired.add(t),this._idle.findIndex(h=>h.client===t)!==-1&&this._acquireClient( t,new Qe((h,l,d)=>d()),n,!1)},this.options.maxLifetimeSeconds*1e3);u.unref(),t.once( "end",()=>clearTimeout(u))}return this._acquireClient(t,e,n,!0)}})}_acquireClient(e,t,n,i){ i&&this.emit("connect",e),this.emit("acquire",e),e.release=this._releaseOnce(e,n), e.removeListener("error",n),t.timedOut?i&&this.options.verify?this.options.verify( e,e.release):e.release():i&&this.options.verify?this.options.verify(e,s=>{if(s)return e. release(s),t.callback(s,void 0,Ds);t.callback(void 0,e,e.release)}):t.callback(void 0, e,e.release)}_releaseOnce(e,t){let n=!1;return i=>{n&&Ac(),n=!0,this._release(e, t,i)}}_release(e,t,n){if(e.on("error",t),e._poolUseCount=(e._poolUseCount||0)+1, this.emit("release",n,e),n||this.ending||!e._queryable||e._ending||e._poolUseCount>= this.options.maxUses){e._poolUseCount>=this.options.maxUses&&this.log("remove ex\ pended client"),this._remove(e),this._pulseQueue();return}if(this._expired.has(e)){ this.log("remove expired client"),this._expired.delete(e),this._remove(e),this._pulseQueue(); return}let s;this.options.idleTimeoutMillis&&(s=setTimeout(()=>{this.log("remove\ idle client"),this._remove(e)},this.options.idleTimeoutMillis),this.options.allowExitOnIdle&& s.unref()),this.options.allowExitOnIdle&&e.unref(),this._idle.push(new mn(e,t,s)), this._pulseQueue()}query(e,t,n){if(typeof e=="function"){let s=Ct(this.Promise,e); return E(function(){return s.callback(new Error("Passing a function as the first\ parameter to pool.query is not supported"))}),s.result}typeof t=="function"&&(n= t,t=void 0);let i=Ct(this.Promise,n);return n=i.callback,this.connect((s,o)=>{if(s) return n(s);let u=!1,c=a(h=>{u||(u=!0,o.release(h),n(h))},"onError");o.once("err\ or",c),this.log("dispatching query");try{o.query(e,t,(h,l)=>{if(this.log("query \ dispatched"),o.removeListener("error",c),!u)return u=!0,o.release(h),h?n(h):n(void 0, l)})}catch(h){return o.release(h),n(h)}}),i.result}end(e){if(this.log("ending"), this.ending){let n=new Error("Called end on pool more than once");return e?e(n): this.Promise.reject(n)}this.ending=!0;let t=Ct(this.Promise,e);return this._endCallback= t.callback,this._pulseQueue(),t.result}get waitingCount(){return this._pendingQueue. length}get idleCount(){return this._idle.length}get expiredCount(){return this._clients. reduce((e,t)=>e+(this._expired.has(t)?1:0),0)}get totalCount(){return this._clients. length}};a(Sn,"Pool");var gn=Sn;Os.exports=gn});var Ns={};te(Ns,{default:()=>Tc});var Tc,qs=z(()=>{"use strict";p();Tc={}});var Qs=I((mf,Ic)=>{Ic.exports={name:"pg",version:"8.8.0",description:"PostgreSQL\ client - pure javascript & libpq with the same API",keywords:["database","libpq", "pg","postgre","postgres","postgresql","rdbms"],homepage:"https://github.com/bri\ anc/node-postgres",repository:{type:"git",url:"git://github.com/brianc/node-post\ gres.git",directory:"packages/pg"},author:"Brian Carlson ",main:"./lib",dependencies:{"buffer-writer":"2.0.0","packet-reader":"1.0.0", "pg-connection-string":"^2.5.0","pg-pool":"^3.5.2","pg-protocol":"^1.5.0","pg-ty\ pes":"^2.1.0",pgpass:"1.x"},devDependencies:{async:"2.6.4",bluebird:"3.5.2",co:"\ 4.6.0","pg-copy-streams":"0.3.0"},peerDependencies:{"pg-native":">=3.0.1"},peerDependenciesMeta:{ "pg-native":{optional:!0}},scripts:{test:"make test-all"},files:["lib","SPONSORS\ .md"],license:"MIT",engines:{node:">= 8.0.0"},gitHead:"c99fb2c127ddf8d712500db2c\ 7b9a5491a178655"}});var Hs=I((gf,Ws)=>{"use strict";p();var js=be().EventEmitter,Pc=(Ge(),N(He)),En=tt(), je=Ws.exports=function(r,e,t){js.call(this),r=En.normalizeQueryConfig(r,e,t),this. text=r.text,this.values=r.values,this.name=r.name,this.callback=r.callback,this. state="new",this._arrayMode=r.rowMode==="array",this._emitRowEvents=!1,this.on("\ newListener",function(n){n==="row"&&(this._emitRowEvents=!0)}.bind(this))};Pc.inherits( je,js);var Bc={sqlState:"code",statementPosition:"position",messagePrimary:"mess\ age",context:"where",schemaName:"schema",tableName:"table",columnName:"column",dataTypeName:"\ dataType",constraintName:"constraint",sourceFile:"file",sourceLine:"line",sourceFunction:"\ routine"};je.prototype.handleError=function(r){var e=this.native.pq.resultErrorFields(); if(e)for(var t in e){var n=Bc[t]||t;r[n]=e[t]}this.callback?this.callback(r):this. emit("error",r),this.state="error"};je.prototype.then=function(r,e){return this. _getPromise().then(r,e)};je.prototype.catch=function(r){return this._getPromise(). catch(r)};je.prototype._getPromise=function(){return this._promise?this._promise: (this._promise=new Promise(function(r,e){this._once("end",r),this._once("error", e)}.bind(this)),this._promise)};je.prototype.submit=function(r){this.state="runn\ ing";var e=this;this.native=r.native,r.native.arrayMode=this._arrayMode;var t=a( function(s,o,u){if(r.native.arrayMode=!1,E(function(){e.emit("_done")}),s)return e. handleError(s);e._emitRowEvents&&(u.length>1?o.forEach((c,h)=>{c.forEach(l=>{e.emit( "row",l,u[h])})}):o.forEach(function(c){e.emit("row",c,u)})),e.state="end",e.emit( "end",u),e.callback&&e.callback(null,u)},"after");if(m.domain&&(t=m.domain.bind( t)),this.name){this.name.length>63&&(console.error("Warning! Postgres only suppo\ rts 63 characters for query names."),console.error("You supplied %s (%s)",this.name, this.name.length),console.error("This can cause conflicts and silent errors exec\ uting queries"));var n=(this.values||[]).map(En.prepareValue);if(r.namedQueries[this. name]){if(this.text&&r.namedQueries[this.name]!==this.text){let s=new Error(`Pre\ pared statements must be unique - '${this.name}' was used for a different statem\ ent`);return t(s)}return r.native.execute(this.name,n,t)}return r.native.prepare( this.name,this.text,n.length,function(s){return s?t(s):(r.namedQueries[e.name]=e. text,e.native.execute(e.name,n,t))})}else if(this.values){if(!Array.isArray(this. values)){let s=new Error("Query values must be an array");return t(s)}var i=this. values.map(En.prepareValue);r.native.query(this.text,i,t)}else r.native.query(this. text,t)}});var Ks=I((Ef,Vs)=>{"use strict";p();var Lc=(qs(),N(Ns)),Rc=gt(),Sf=Qs(),Gs=be(). EventEmitter,Fc=(Ge(),N(He)),Mc=wt(),$s=Hs(),J=Vs.exports=function(r){Gs.call(this), r=r||{},this._Promise=r.Promise||S.Promise,this._types=new Rc(r.types),this.native= new Lc({types:this._types}),this._queryQueue=[],this._ending=!1,this._connecting= !1,this._connected=!1,this._queryable=!0;var e=this.connectionParameters=new Mc( r);this.user=e.user,Object.defineProperty(this,"password",{configurable:!0,enumerable:!1, writable:!0,value:e.password}),this.database=e.database,this.host=e.host,this.port= e.port,this.namedQueries={}};J.Query=$s;Fc.inherits(J,Gs);J.prototype._errorAllQueries= function(r){let e=a(t=>{m.nextTick(()=>{t.native=this.native,t.handleError(r)})}, "enqueueError");this._hasActiveQuery()&&(e(this._activeQuery),this._activeQuery= null),this._queryQueue.forEach(e),this._queryQueue.length=0};J.prototype._connect= function(r){var e=this;if(this._connecting){m.nextTick(()=>r(new Error("Client h\ as already been connected. You cannot reuse a client.")));return}this._connecting= !0,this.connectionParameters.getLibpqConnectionString(function(t,n){if(t)return r( t);e.native.connect(n,function(i){if(i)return e.native.end(),r(i);e._connected=!0, e.native.on("error",function(s){e._queryable=!1,e._errorAllQueries(s),e.emit("er\ ror",s)}),e.native.on("notification",function(s){e.emit("notification",{channel:s. relname,payload:s.extra})}),e.emit("connect"),e._pulseQueryQueue(!0),r()})})};J. prototype.connect=function(r){if(r){this._connect(r);return}return new this._Promise( (e,t)=>{this._connect(n=>{n?t(n):e()})})};J.prototype.query=function(r,e,t){var n, i,s,o,u;if(r==null)throw new TypeError("Client was passed a null or undefined qu\ ery");if(typeof r.submit=="function")s=r.query_timeout||this.connectionParameters. query_timeout,i=n=r,typeof e=="function"&&(r.callback=e);else if(s=this.connectionParameters. query_timeout,n=new $s(r,e,t),!n.callback){let c,h;i=new this._Promise((l,d)=>{c= l,h=d}),n.callback=(l,d)=>l?h(l):c(d)}return s&&(u=n.callback,o=setTimeout(()=>{ var c=new Error("Query read timeout");m.nextTick(()=>{n.handleError(c,this.connection)}), u(c),n.callback=()=>{};var h=this._queryQueue.indexOf(n);h>-1&&this._queryQueue. splice(h,1),this._pulseQueryQueue()},s),n.callback=(c,h)=>{clearTimeout(o),u(c,h)}), this._queryable?this._ending?(n.native=this.native,m.nextTick(()=>{n.handleError( new Error("Client was closed and is not queryable"))}),i):(this._queryQueue.push( n),this._pulseQueryQueue(),i):(n.native=this.native,m.nextTick(()=>{n.handleError( new Error("Client has encountered a connection error and is not queryable"))}),i)}; J.prototype.end=function(r){var e=this;this._ending=!0,this._connected||this.once( "connect",this.end.bind(this,r));var t;return r||(t=new this._Promise(function(n,i){ r=a(s=>s?i(s):n(),"cb")})),this.native.end(function(){e._errorAllQueries(new Error( "Connection terminated")),m.nextTick(()=>{e.emit("end"),r&&r()})}),t};J.prototype. _hasActiveQuery=function(){return this._activeQuery&&this._activeQuery.state!=="\ error"&&this._activeQuery.state!=="end"};J.prototype._pulseQueryQueue=function(r){ if(this._connected&&!this._hasActiveQuery()){var e=this._queryQueue.shift();if(!e){ r||this.emit("drain");return}this._activeQuery=e,e.submit(this);var t=this;e.once( "_done",function(){t._pulseQueryQueue()})}};J.prototype.cancel=function(r){this. _activeQuery===r?this.native.cancel(function(){}):this._queryQueue.indexOf(r)!== -1&&this._queryQueue.splice(this._queryQueue.indexOf(r),1)};J.prototype.ref=function(){}; J.prototype.unref=function(){};J.prototype.setTypeParser=function(r,e,t){return this. _types.setTypeParser(r,e,t)};J.prototype.getTypeParser=function(r,e){return this. _types.getTypeParser(r,e)}});var xn=I((_f,zs)=>{"use strict";p();zs.exports=Ks()});var Tt=I((Cf,nt)=>{"use strict";p();var Dc=Ms(),kc=et(),Oc=pn(),Uc=Us(),{DatabaseError:Nc}=hn(), qc=a(r=>{var e;return e=class extends Uc{constructor(n){super(n,r)}},a(e,"BoundP\ ool"),e},"poolFactory"),vn=a(function(r){this.defaults=kc,this.Client=r,this.Query= this.Client.Query,this.Pool=qc(this.Client),this._pools=[],this.Connection=Oc,this. types=Xe(),this.DatabaseError=Nc},"PG");typeof m.env.NODE_PG_FORCE_NATIVE<"u"?nt. exports=new vn(xn()):(nt.exports=new vn(Dc),Object.defineProperty(nt.exports,"na\ tive",{configurable:!0,enumerable:!1,get(){var r=null;try{r=new vn(xn())}catch(e){ if(e.code!=="MODULE_NOT_FOUND")throw e}return Object.defineProperty(nt.exports,"\ native",{value:r}),r}}))});var Gc={};te(Gc,{Client:()=>Pt,ClientBase:()=>se.ClientBase,Connection:()=>se.Connection, DatabaseError:()=>se.DatabaseError,NeonDbError:()=>ue,Pool:()=>An,Query:()=>se.Query, defaults:()=>se.defaults,neon:()=>_n,neonConfig:()=>Ee,types:()=>se.types});module. exports=N(Gc);p();var Bt=Pe(Tt());bt();p();bt();mr();var Js=Pe(tt()),Xs=Pe(gt());var It=class It extends Error{constructor(t){super(t);_(this,"name","NeonDbError"); _(this,"severity");_(this,"code");_(this,"detail");_(this,"hint");_(this,"positi\ on");_(this,"internalPosition");_(this,"internalQuery");_(this,"where");_(this,"\ schema");_(this,"table");_(this,"column");_(this,"dataType");_(this,"constraint"); _(this,"file");_(this,"line");_(this,"routine");_(this,"sourceError");"captureSt\ ackTrace"in Error&&typeof Error.captureStackTrace=="function"&&Error.captureStackTrace( this,It)}};a(It,"NeonDbError");var ue=It,Ys="transaction() expects an array of q\ ueries, or a function returning an array of queries",Qc=["severity","code","deta\ il","hint","position","internalPosition","internalQuery","where","schema","table", "column","dataType","constraint","file","line","routine"];function _n(r,{arrayMode:e, fullResults:t,fetchOptions:n,isolationLevel:i,readOnly:s,deferrable:o,queryCallback:u, resultCallback:c,authToken:h}={}){if(!r)throw new Error("No database connection \ string was provided to `neon()`. Perhaps an environment variable has not been se\ t?");let l;try{l=yr(r)}catch{throw new Error("Database connection string provide\ d to `neon()` is not a valid URL. Connection string: "+String(r))}let{protocol:d, username:b,hostname:C,port:B,pathname:j}=l;if(d!=="postgres:"&&d!=="postgresql:"|| !b||!C||!j)throw new Error("Database connection string format for `neon()` shoul\ d be: postgresql://user:password@host.tld/dbname?option=value");function X(A,...w){ let P,V;if(typeof A=="string")P=A,V=w[1],w=w[0]??[];else{P="";for(let W=0;W(0,Js.prepareValue)(W));let O={query:P, params:w};return u&&u(O),jc(de,O,V)}a(X,"resolve"),X.transaction=async(A,w)=>{if(typeof A== "function"&&(A=A(X)),!Array.isArray(A))throw new Error(Ys);A.forEach(O=>{if(O[Symbol. toStringTag]!=="NeonQueryPromise")throw new Error(Ys)});let P=A.map(O=>O.parameterizedQuery), V=A.map(O=>O.opts??{});return de(P,V,w)};async function de(A,w,P){let{fetchEndpoint:V, fetchFunction:O}=Ee,W=typeof V=="function"?V(C,B,{jwtAuth:h!==void 0}):V,ce=Array. isArray(A)?{queries:A}:A,ee=n??{},R=e??!1,G=t??!1,he=i,ye=s,ve=o;P!==void 0&&(P. fetchOptions!==void 0&&(ee={...ee,...P.fetchOptions}),P.arrayMode!==void 0&&(R=P. arrayMode),P.fullResults!==void 0&&(G=P.fullResults),P.isolationLevel!==void 0&& (he=P.isolationLevel),P.readOnly!==void 0&&(ye=P.readOnly),P.deferrable!==void 0&& (ve=P.deferrable)),w!==void 0&&!Array.isArray(w)&&w.fetchOptions!==void 0&&(ee={ ...ee,...w.fetchOptions});let le={"Neon-Connection-String":r,"Neon-Raw-Text-Outp\ ut":"true","Neon-Array-Mode":"true"},Te=await Wc(h);Te&&(le.Authorization=`Beare\ r ${Te}`),Array.isArray(A)&&(he!==void 0&&(le["Neon-Batch-Isolation-Level"]=he), ye!==void 0&&(le["Neon-Batch-Read-Only"]=String(ye)),ve!==void 0&&(le["Neon-Batc\ h-Deferrable"]=String(ve)));let me;try{me=await(O??fetch)(W,{method:"POST",body:JSON. stringify(ce),headers:le,...ee})}catch(K){let k=new ue(`Error connecting to data\ base: ${K.message}`);throw k.sourceError=K,k}if(me.ok){let K=await me.json();if(Array. isArray(A)){let k=K.results;if(!Array.isArray(k))throw new ue("Neon internal err\ or: unexpected result format");return k.map((ge,_e)=>{let Lt=w[_e]??{},to=Lt.arrayMode?? R,ro=Lt.fullResults??G;return Zs(ge,{arrayMode:to,fullResults:ro,parameterizedQuery:A[_e], resultCallback:c,types:Lt.types})})}else{let k=w??{},ge=k.arrayMode??R,_e=k.fullResults?? G;return Zs(K,{arrayMode:ge,fullResults:_e,parameterizedQuery:A,resultCallback:c, types:k.types})}}else{let{status:K}=me;if(K===400){let k=await me.json(),ge=new ue( k.message);for(let _e of Qc)ge[_e]=k[_e]??void 0;throw ge}else{let k=await me.text(); throw new ue(`Server error (HTTP status ${K}): ${k}`)}}}return a(de,"execute"),X} a(_n,"neon");function jc(r,e,t){return{[Symbol.toStringTag]:"NeonQueryPromise",parameterizedQuery:e, opts:t,then:a((n,i)=>r(e,t).then(n,i),"then"),catch:a(n=>r(e,t).catch(n),"catch"), finally:a(n=>r(e,t).finally(n),"finally")}}a(jc,"createNeonQueryPromise");function Zs(r,{ arrayMode:e,fullResults:t,parameterizedQuery:n,resultCallback:i,types:s}){let o=new Xs.default( s),u=r.fields.map(l=>l.name),c=r.fields.map(l=>o.getTypeParser(l.dataTypeID)),h=e=== !0?r.rows.map(l=>l.map((d,b)=>d===null?null:c[b](d))):r.rows.map(l=>Object.fromEntries( l.map((d,b)=>[u[b],d===null?null:c[b](d)])));return i&&i(n,r,h,{arrayMode:e,fullResults:t}), t?(r.viaNeonFetch=!0,r.rowAsArray=e,r.rows=h,r._parsers=c,r._types=o,r):h}a(Zs,"\ processQueryResult");async function Wc(r){if(typeof r=="string")return r;if(typeof r== "function")try{return await Promise.resolve(r())}catch(e){let t=new ue("Error ge\ tting auth token.");throw e instanceof Error&&(t=new ue(`Error getting auth toke\ n: ${e.message}`)),t}}a(Wc,"getAuthToken");var eo=Pe(wt()),se=Pe(Tt());var Cn=class Cn extends Bt.Client{constructor(t){super(t);this.config=t}get neonConfig(){ return this.connection.stream}connect(t){let{neonConfig:n}=this;n.forceDisablePgSSL&& (this.ssl=this.connection.ssl=!1),this.ssl&&n.useSecureWebSocket&&console.warn("\ SSL is enabled for both Postgres (e.g. ?sslmode=require in the connection string\ + forceDisablePgSSL = false) and the WebSocket tunnel (useSecureWebSocket = tru\ e). Double encryption will increase latency and CPU usage. It may be appropriate\ to disable SSL in the Postgres connection parameters or set forceDisablePgSSL =\ true.");let i=this.config?.host!==void 0||this.config?.connectionString!==void 0|| m.env.PGHOST!==void 0,s=m.env.USER??m.env.USERNAME;if(!i&&this.host==="localhost"&& this.user===s&&this.database===s&&this.password===null)throw new Error(`No datab\ ase host or connection string was set, and key parameters have default values (h\ ost: localhost, user: ${s}, db: ${s}, password: null). Is an environment variabl\ e missing? Alternatively, if you intended to connect with these parameters, plea\ se set the host to 'localhost' explicitly.`);let o=super.connect(t),u=n.pipelineTLS&& this.ssl,c=n.pipelineConnect==="password";if(!u&&!n.pipelineConnect)return o;let h=this. connection;if(u&&h.on("connect",()=>h.stream.emit("data","S")),c){h.removeAllListeners( "authenticationCleartextPassword"),h.removeAllListeners("readyForQuery"),h.once( "readyForQuery",()=>h.on("readyForQuery",this._handleReadyForQuery.bind(this))); let l=this.ssl?"sslconnect":"connect";h.on(l,()=>{this._handleAuthCleartextPassword(), this._handleReadyForQuery()})}return o}async _handleAuthSASLContinue(t){let n=this. saslSession,i=this.password,s=t.data;if(n.message!=="SASLInitialResponse"||typeof i!= "string"||typeof s!="string")throw new Error("SASL: protocol error");let o=Object. fromEntries(s.split(",").map(K=>{if(!/^.=/.test(K))throw new Error("SASL: Invali\ d attribute pair entry");let k=K[0],ge=K.substring(2);return[k,ge]})),u=o.r,c=o. s,h=o.i;if(!u||!/^[!-+--~]+$/.test(u))throw new Error("SASL: SCRAM-SERVER-FIRST-\ MESSAGE: nonce missing/unprintable");if(!c||!/^(?:[a-zA-Z0-9+/]{4})*(?:[a-zA-Z0-9+/]{2}==|[a-zA-Z0-9+/]{3}=)?$/. test(c))throw new Error("SASL: SCRAM-SERVER-FIRST-MESSAGE: salt missing/not base\ 64");if(!h||!/^[1-9][0-9]*$/.test(h))throw new Error("SASL: SCRAM-SERVER-FIRST-M\ ESSAGE: missing/invalid iteration count");if(!u.startsWith(n.clientNonce))throw new Error( "SASL: SCRAM-SERVER-FIRST-MESSAGE: server nonce does not start with client nonce"); if(u.length===n.clientNonce.length)throw new Error("SASL: SCRAM-SERVER-FIRST-MES\ SAGE: server nonce is too short");let l=parseInt(h,10),d=y.from(c,"base64"),b=new TextEncoder, C=b.encode(i),B=await g.subtle.importKey("raw",C,{name:"HMAC",hash:{name:"SHA-25\ 6"}},!1,["sign"]),j=new Uint8Array(await g.subtle.sign("HMAC",B,y.concat([d,y.from( [0,0,0,1])]))),X=j;for(var de=0;deX[k]^j[k]));let A=X,w=await g.subtle.importKey( "raw",A,{name:"HMAC",hash:{name:"SHA-256"}},!1,["sign"]),P=new Uint8Array(await g. subtle.sign("HMAC",w,b.encode("Client Key"))),V=await g.subtle.digest("SHA-256", P),O="n=*,r="+n.clientNonce,W="r="+u+",s="+c+",i="+l,ce="c=biws,r="+u,ee=O+","+W+ ","+ce,R=await g.subtle.importKey("raw",V,{name:"HMAC",hash:{name:"SHA-256"}},!1, ["sign"]);var G=new Uint8Array(await g.subtle.sign("HMAC",R,b.encode(ee))),he=y. from(P.map((K,k)=>P[k]^G[k])),ye=he.toString("base64");let ve=await g.subtle.importKey( "raw",A,{name:"HMAC",hash:{name:"SHA-256"}},!1,["sign"]),le=await g.subtle.sign( "HMAC",ve,b.encode("Server Key")),Te=await g.subtle.importKey("raw",le,{name:"HM\ AC",hash:{name:"SHA-256"}},!1,["sign"]);var me=y.from(await g.subtle.sign("HMAC", Te,b.encode(ee)));n.message="SASLResponse",n.serverSignature=me.toString("base64"), n.response=ce+",p="+ye,this.connection.sendSCRAMClientFinalMessage(this.saslSession. response)}};a(Cn,"NeonClient");var Pt=Cn;function Hc(r,e){if(e)return{callback:e, result:void 0};let t,n,i=a(function(o,u){o?t(o):n(u)},"cb"),s=new r(function(o,u){ n=o,t=u});return{callback:i,result:s}}a(Hc,"promisify");var Tn=class Tn extends Bt.Pool{constructor(){ super(...arguments);_(this,"Client",Pt);_(this,"hasFetchUnsupportedListeners",!1)}on(t,n){ return t!=="error"&&(this.hasFetchUnsupportedListeners=!0),super.on(t,n)}query(t,n,i){ if(!Ee.poolQueryViaFetch||this.hasFetchUnsupportedListeners||typeof t=="function") return super.query(t,n,i);typeof n=="function"&&(i=n,n=void 0);let s=Hc(this.Promise, i);i=s.callback;try{let o=new eo.default(this.options),u=encodeURIComponent,c=encodeURI, h=`postgresql://${u(o.user)}:${u(o.password)}@${u(o.host)}/${c(o.database)}`,l=typeof t== "string"?t:t.text,d=n??t.values??[];_n(h,{fullResults:!0,arrayMode:t.rowMode==="\ array"})(l,d,{types:t.types??this.options?.types}).then(C=>i(void 0,C)).catch(C=>i( C))}catch(o){i(o)}return s.result}};a(Tn,"NeonPool");var An=Tn; /*! Bundled license information: ieee754/index.js: (*! ieee754. BSD-3-Clause License. Feross Aboukhadijeh *) buffer/index.js: (*! * The buffer module from node.js, for the browser. * * @author Feross Aboukhadijeh * @license MIT *) */