1643 lines
139 KiB
JavaScript
1643 lines
139 KiB
JavaScript
"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;Ae<Pn;++Ae)
|
|
oe[Ae]=Rt[Ae],re[Rt.charCodeAt(Ae)]=Ae;var Ae,Pn;re[45]=62;re[95]=63;function Bn(r){
|
|
var e=r.length;if(e%4>0)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<u;c+=
|
|
4)e=re[r.charCodeAt(c)]<<18|re[r.charCodeAt(c+1)]<<12|re[r.charCodeAt(c+2)]<<6|re[r.
|
|
charCodeAt(c+3)],s[o++]=e>>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;s<t;s+=
|
|
3)n=(r[s]<<16&16711680)+(r[s+1]<<8&65280)+(r[s+2]&255),i.push(po(n));return i.join(
|
|
"")}a(yo,"encodeChunk");function mo(r){for(var e,t=r.length,n=t%3,i=[],s=16383,o=0,
|
|
u=t-n;o<u;o+=s)i.push(yo(r,o,o+s>u?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<<u)-1,h=c>>
|
|
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<<i|u,h+=i;h>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<e;n+=1)t[n]=r[n]&255;return t}
|
|
a(Dt,"fromArrayLike");function So(r){if(ae(r,Uint8Array)){let e=new Uint8Array(r);
|
|
return kt(e.buffer,e.byteOffset,e.byteLength)}return Dt(r)}a(So,"fromArrayView");
|
|
function kt(r,e,t){if(e<0||r.byteLength<e)throw new RangeError('"offset" is outs\
|
|
ide of buffer bounds');if(r.byteLength<e+(t||0))throw new RangeError('"length" i\
|
|
s outside of buffer bounds');let n;return e===void 0&&t===void 0?n=new Uint8Array(
|
|
r):t===void 0?n=new Uint8Array(r,e):n=new Uint8Array(r,e,t),Object.setPrototypeOf(
|
|
n,f.prototype),n}a(kt,"fromArrayBuffer");function Eo(r){if(f.isBuffer(r)){let e=Nt(
|
|
r.length)|0,t=fe(e);return t.length===0||r.copy(t,0,0,e),t}if(r.length!==void 0)
|
|
return typeof r.length!="number"||Qt(r.length)?fe(0):Dt(r);if(r.type==="Buffer"&&
|
|
Array.isArray(r.data))return Dt(r.data)}a(Eo,"fromObject");function Nt(r){if(r>=
|
|
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);s<o;++s)if(e[s]!==t[s]){n=e[s],i=t[s];break}return n<
|
|
i?-1:i<n?1:0},"compare");f.isEncoding=a(function(e){switch(String(e).toLowerCase()){case"\
|
|
hex":case"utf8":case"utf-8":case"ascii":case"latin1":case"binary":case"base64":case"\
|
|
ucs2":case"ucs-2":case"utf16le":case"utf-16le":return!0;default:return!1}},"isEn\
|
|
coding");f.concat=a(function(e,t){if(!Array.isArray(e))throw new TypeError('"lis\
|
|
t" argument must be an Array of Buffers');if(e.length===0)return f.alloc(0);let n;
|
|
if(t===void 0)for(t=0,n=0;n<e.length;++n)t+=e[n].length;let i=f.allocUnsafe(t),s=0;
|
|
for(n=0;n<e.length;++n){let o=e[n];if(ae(o,Uint8Array))s+o.length>i.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;t<e;t+=4)Ce(this,t,t+3),Ce(this,t+1,t+2);return this},"swap32");
|
|
f.prototype.swap64=a(function(){let e=this.length;if(e%8!==0)throw new RangeError(
|
|
"Buffer size must be a multiple of 64-bits");for(let t=0;t<e;t+=8)Ce(this,t,t+7),
|
|
Ce(this,t+1,t+6),Ce(this,t+2,t+5),Ce(this,t+3,t+4);return this},"swap64");f.prototype.
|
|
toString=a(function(){let e=this.length;return e===0?"":arguments.length===0?Qn(
|
|
this,0,e):vo.apply(this,arguments)},"toString");f.prototype.toLocaleString=f.prototype.
|
|
toString;f.prototype.equals=a(function(e){if(!f.isBuffer(e))throw new TypeError(
|
|
"Argument must be a Buffer");return this===e?!0:f.compare(this,e)===0},"equals");
|
|
f.prototype.inspect=a(function(){let e="",t=Fe.INSPECT_MAX_BYTES;return e=this.toString(
|
|
"hex",0,t).replace(/(.{2})/g,"$1 ").trim(),this.length>t&&(e+=" ... "),"<Buffer "+
|
|
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;d<c;++d)
|
|
if(h[d]!==l[d]){o=h[d],u=l[d];break}return o<u?-1:u<o?1:0},"compare");function qn(r,e,t,n,i){
|
|
if(r.length===0)return-1;if(typeof t=="string"?(n=t,t=0):t>2147483647?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;d<u;d++)
|
|
if(c(r,h+d)!==c(e,d)){l=!1;break}if(l)return h}return-1}a(Mn,"arrayIndexOf");f.prototype.
|
|
includes=a(function(e,t,n){return this.indexOf(e,t,n)!==-1},"includes");f.prototype.
|
|
indexOf=a(function(e,t,n){return qn(this,e,t,n,!0)},"indexOf");f.prototype.lastIndexOf=
|
|
a(function(e,t,n){return qn(this,e,t,n,!1)},"lastIndexOf");function _o(r,e,t,n){
|
|
t=Number(t)||0;let i=r.length-t;n?(n=Number(n),n>i&&(n=i)):n=i;let s=e.length;n>
|
|
s/2&&(n=s/2);let o;for(o=0;o<n;++o){let u=parseInt(e.substr(o*2,2),16);if(Qt(u))
|
|
return o;r[t+o]=u}return o}a(_o,"hexWrite");function Ao(r,e,t,n){return ot(Ot(e,
|
|
r.length-t),r,t,n)}a(Ao,"utf8Write");function Co(r,e,t,n){return ot(Uo(e),r,t,n)}
|
|
a(Co,"asciiWrite");function To(r,e,t,n){return ot(Kn(e),r,t,n)}a(To,"base64Write");
|
|
function Io(r,e,t,n){return ot(No(e,r.length-t),r,t,n)}a(Io,"ucs2Write");f.prototype.
|
|
write=a(function(e,t,n,i){if(t===void 0)i="utf8",n=this.length,t=0;else if(n===void 0&&
|
|
typeof t=="string")i=t,n=this.length,t=0;else if(isFinite(t))t=t>>>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(;i<t;){let s=r[i],o=null,u=s>239?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(;n<e;)t+=String.fromCharCode.apply(String,r.slice(n,n+=Dn));return t}a(Bo,"d\
|
|
ecodeCodePointsArray");function Lo(r,e,t){let n="";t=Math.min(r.length,t);for(let i=e;i<
|
|
t;++i)n+=String.fromCharCode(r[i]&127);return n}a(Lo,"asciiSlice");function Ro(r,e,t){
|
|
let n="";t=Math.min(r.length,t);for(let i=e;i<t;++i)n+=String.fromCharCode(r[i]);
|
|
return n}a(Ro,"latin1Slice");function Fo(r,e,t){let n=r.length;(!e||e<0)&&(e=0),
|
|
(!t||t<0||t>n)&&(t=n);let i="";for(let s=e;s<t;++s)i+=qo[r[s]];return i}a(Fo,"he\
|
|
xSlice");function Mo(r,e,t){let n=r.slice(e,t),i="";for(let s=0;s<n.length-1;s+=
|
|
2)i+=String.fromCharCode(n[s]+n[s+1]*256);return i}a(Mo,"utf16leSlice");f.prototype.
|
|
slice=a(function(e,t){let n=this.length;e=~~e,t=t===void 0?n:~~t,e<0?(e+=n,e<0&&
|
|
(e=0)):e>n&&(e=n),t<0?(t+=n,t<0&&(t=0)):t>n&&(t=n),t<e&&(t=e);let i=this.subarray(
|
|
e,t);return Object.setPrototypeOf(i,f.prototype),i},"slice");function q(r,e,t){if(r%
|
|
1!==0||r<0)throw new RangeError("offset is not uint");if(r+e>t)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<t&&(s*=256);)i+=this[e+o]*s;return i},"readUIntLE");f.prototype.
|
|
readUintBE=f.prototype.readUIntBE=a(function(e,t,n){e=e>>>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)<<BigInt(32))},"readBigUInt64LE"));f.prototype.
|
|
readBigUInt64BE=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*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)<<BigInt(32))+BigInt(s)},"readBigUInt64BE"));f.prototype.readIntLE=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<t&&(s*=256);)
|
|
i+=this[e+o]*s;return s*=128,i>=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)<<BigInt(32))+BigInt(t+this[++e]*2**8+this[++e]*2**16+this[++e]*2**24)},"readB\
|
|
igInt64LE"));f.prototype.readBigInt64BE=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<<
|
|
24)+this[++e]*2**16+this[++e]*2**8+this[++e];return(BigInt(i)<<BigInt(32))+BigInt(
|
|
this[++e]*2**24+this[++e]*2**16+this[++e]*2**8+n)},"readBigInt64BE"));f.prototype.
|
|
readFloatLE=a(function(e,t){return e=e>>>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<n&&(s*=256);)this[t+o]=e/s&255;return t+
|
|
n},"writeUIntLE");f.prototype.writeUintBE=f.prototype.writeUIntBE=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=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<n&&(o*=256);)e<
|
|
0&&u===0&&this[t+s-1]!==0&&(u=1),this[t+s]=(e/o>>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<n&&(i=n),i===n||e.length===
|
|
0||this.length===0)return 0;if(t<0)throw new RangeError("targetStart out of boun\
|
|
ds");if(n<0||n>=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<i-n&&(i=e.length-
|
|
t+n);let s=i-n;return this===e&&typeof Uint8Array.prototype.copyWithin=="functio\
|
|
n"?this.copyWithin(t,n,i):Uint8Array.prototype.set.call(e,this.subarray(n,i),t),
|
|
s},"copy");f.prototype.fill=a(function(e,t,n,i){if(typeof e=="string"){if(typeof t==
|
|
"string"?(i=t,t=0,n=this.length):typeof n=="string"&&(i=n,n=this.length),i!==void 0&&
|
|
typeof i!="string")throw new TypeError("encoding must be a string");if(typeof i==
|
|
"string"&&!f.isEncoding(i))throw new TypeError("Unknown encoding: "+i);if(e.length===
|
|
1){let o=e.charCodeAt(0);(i==="utf8"&&o<128||i==="latin1")&&(e=o)}}else typeof e==
|
|
"number"?e=e&255:typeof e=="boolean"&&(e=Number(e));if(t<0||this.length<t||this.
|
|
length<n)throw new RangeError("Out of range index");if(n<=t)return this;t=t>>>0,
|
|
n=n===void 0?this.length:n>>>0,e||(e=0);let s;if(typeof e=="number")for(s=t;s<n;++s)
|
|
this[s]=e;else{let o=f.isBuffer(e)?e:f.from(e,i),u=o.length;if(u===0)throw new TypeError(
|
|
'The value "'+e+'" is invalid for argument "value"');for(s=0;s<n-t;++s)this[s+t]=
|
|
o[s%u]}return this},"fill");var Be={};function qt(r,e,t){var n;Be[r]=(n=class extends t{constructor(){
|
|
super(),Object.defineProperty(this,"message",{value:e.apply(this,arguments),writable:!0,
|
|
configurable:!0}),this.name=`${this.name} [${r}]`,this.stack,delete this.name}get code(){
|
|
return r}set code(s){Object.defineProperty(this,"code",{configurable:!0,enumerable:!0,
|
|
value:s,writable:!0})}toString(){return`${this.name} [${r}]: ${this.message}`}},
|
|
a(n,"NodeError"),n)}a(qt,"E");qt("ERR_BUFFER_OUT_OF_BOUNDS",function(r){return r?
|
|
`${r} is outside of buffer bounds`:"Attempt to access memory outside buffer boun\
|
|
ds"},RangeError);qt("ERR_INVALID_ARG_TYPE",function(r,e){return`The "${r}" argum\
|
|
ent must be of type number. Received type ${typeof e}`},TypeError);qt("ERR_OUT_O\
|
|
F_RANGE",function(r,e,t){let n=`The value of "${r}" is out of range.`,i=t;return Number.
|
|
isInteger(t)&&Math.abs(t)>2**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||r<e){let o=typeof e=="bigint"?"n":"",u;throw s>3?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;o<n;++o){if(t=r.charCodeAt(o),t>55295&&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<r.length;++t)e.push(r.charCodeAt(
|
|
t)&255);return e}a(Uo,"asciiToBytes");function No(r,e){let t,n,i,s=[];for(let o=0;o<
|
|
r.length&&!((e-=2)<0);++o)t=r.charCodeAt(o),n=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<n&&!(i+t>=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<arguments.length;n++)t.push(arguments[n]);var i=e==="error",s=this._events;
|
|
if(s!==void 0)i=i&&s.error===void 0;else if(!i)return!1;if(i){var o;if(t.length>
|
|
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;n<h;++n)Yn(l[n],this,
|
|
t);return!0},"emit");function ei(r,e,t,n){var i,s,o;if(ut(t),s=r._events,s===void 0?
|
|
(s=r._events=Object.create(null),r._eventsCount=0):(s.newListener!==void 0&&(r.emit(
|
|
"newListener",e,t.listener?t.listener:t),s=r._events),o=s[e]),o===void 0)o=s[e]=
|
|
t,++r._eventsCount;else if(typeof o=="function"?o=s[e]=n?[t,o]:[o,t]:n?o.unshift(
|
|
t):o.push(t),i=Xn(r),i>0&&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<s.length;++i)o=s[i],
|
|
o!=="removeListener"&&this.removeAllListeners(o);return this.removeAllListeners(
|
|
"removeListener"),this._events=Object.create(null),this._eventsCount=0,this}if(t=
|
|
n[e],typeof t=="function")this.removeListener(e,t);else if(t!==void 0)for(i=t.length-
|
|
1;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;n<e;++n)t[n]=r[n];
|
|
return t}a(ii,"arrayClone");function Ho(r,e){for(;e+1<r.length;e++)r[e]=r[e+1];r.
|
|
pop()}a(Ho,"spliceOne");function Go(r){for(var e=new Array(r.length),t=0;t<e.length;++t)
|
|
e[t]=r[t].listener||r[t];return e}a(Go,"unwrapListeners");function $o(r,e){return new Promise(
|
|
function(t,n){function i(o){r.removeListener(e,s),n(o)}a(i,"errorListener");function s(){
|
|
typeof r.removeListener=="function"&&r.removeListener("error",i),t([].slice.call(
|
|
arguments))}a(s,"resolver"),si(r,e,s,{once:!0}),e!=="error"&&Vo(r,i,{once:!0})})}
|
|
a($o,"once");function Vo(r,e,t){typeof r.on=="function"&&si(r,"error",e,t)}a(Vo,
|
|
"addErrorHandlerIfEventEmitter");function si(r,e,t,n){if(typeof r.on=="function")
|
|
n.once?r.once(e,t):r.on(e,t);else if(typeof r.addEventListener=="function")r.addEventListener(
|
|
e,a(function i(s){n.once&&r.removeEventListener(e,i),t(s)},"wrapListener"));else
|
|
throw new TypeError('The "emitter" argument must be of type EventEmitter. Receiv\
|
|
ed type '+typeof r)}a(si,"eventTargetAgnosticAddListener")});var He={};te(He,{default:()=>Ko});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<A.length;w++)B[l++]=
|
|
A[w],l===64&&j();h+=A.length},"add"),de=a(()=>{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<e.length;o+=1){if(s=e.charCodeAt(o),
|
|
s<128)t[i++]=s;else if(s<2048)t[i++]=(s>>>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<t.length;s+=1)this._buffer8[s]=t.charCodeAt(s)}end(e=!1){
|
|
let t=this._bufferLength,n=this._buffer8,i=this._buffer32,s=(t>>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<arguments.length;e++){var t=arguments[e];for(var n in t)oa.call(t,
|
|
n)&&(r[n]=t[n])}return r}a(aa,"extend")});var gi=I((Ih,mi)=>{"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<e.length;)if(e[n]!=="\\")t+=e[n],++n;else if(/[0-7]{3}/.
|
|
test(e.substr(n+1,3)))t+=String.fromCharCode(parseInt(e.substr(n+1,3),8)),n+=4;else{
|
|
for(var i=1;n+i<e.length&&e[n+i]==="\\";)i++;for(var s=0;s<Math.floor(i/2);++s)t+=
|
|
"\\";n+=Math.floor(i/2)*2}return new y(t,"binary")},"parseBytea")});var Ci=I((Mh,Ai)=>{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<r.length-1;i++){
|
|
if(n||(e+=r[i]),r[i]===")"){n=!0;continue}else if(!n)continue;r[i]!==","&&(t+=r[i])}
|
|
var s=er(e);return s.radius=parseFloat(t),s},"parseCircle"),Ia=a(function(r){r(20,
|
|
_i),r(21,Xt),r(23,Xt),r(26,Xt),r(700,parseFloat),r(701,parseFloat),r(16,vi),r(1082,
|
|
ht),r(1114,ht),r(1184,ht),r(600,er),r(651,ne),r(718,Ta),r(1e3,Ea),r(1001,Ca),r(1005,
|
|
Yt),r(1007,Yt),r(1028,Yt),r(1016,va),r(1017,_a),r(1021,Zt),r(1022,Zt),r(1231,Zt),
|
|
r(1014,ne),r(1015,ne),r(1008,ne),r(1009,ne),r(1040,ne),r(1041,ne),r(1115,Jt),r(1182,
|
|
Jt),r(1185,Jt),r(1186,Ei),r(1187,Aa),r(17,xi),r(114,JSON.parse.bind(JSON)),r(3802,
|
|
JSON.parse.bind(JSON)),r(199,Si),r(3807,Si),r(3907,ne),r(2951,ne),r(791,ne),r(1183,
|
|
ne),r(1270,ne)},"init");Ai.exports={init:Ia}});var Ii=I((Oh,Ti)=>{"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<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<
|
|
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<h;l++)c+="0";i=c+u+i}return s=
|
|
e%Z,o=4294967296*s+t,u=""+o%Z,n+u+i}a(Pa,"readInt8");Ti.exports=Pa});var Fi=I((qh,Ri)=>{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<c&&(u=255<<8-e&255,c=e),t&&(u=u>>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;d<l;d++)h=i(h,o(r[d]),8);var b=(e+t)%8;return b>0&&
|
|
(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<<d-b)>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<s;o++)n+=F(r,16,64+16*o)*t,t/=1e4;var u=Math.pow(10,F(r,16,48));
|
|
return(e===0?1:-1)*Math.round(n*u)/u},"parseNumeric"),Bi=a(function(r,e){var t=F(
|
|
e,1),n=F(e,63,1),i=new Date((t===0?1:-1)*n/1e3+9466848e5);return r||i.setTime(i.
|
|
getTime()+i.getTimezoneOffset()*6e4),i.usec=n%1e3,i.getMicroSeconds=function(){return this.
|
|
usec},i.setMicroSeconds=function(s){this.usec=s},i.getUTCMicroSeconds=function(){
|
|
return this.usec},i},"parseDate"),Ye=a(function(r){for(var e=F(r,32),t=F(r,32,32),
|
|
n=F(r,32,64),i=96,s=[],o=0;o<e;o++)s[o]=F(r,32,i),i+=32,i+=32;var u=a(function(h){
|
|
var l=F(r,32,i);if(i+=32,l==4294967295)return null;var d;if(h==23||h==20)return d=
|
|
F(r,l*8,i),i+=l*8,d;if(h==25)return d=r.toString(this.encoding,i>>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;b<C;b++)d[b]=c(h,l);h.unshift(
|
|
C)}else for(b=0;b<h[0];b++)d[b]=u(l);return d},"parse");return c(s,n)},"parseArr\
|
|
ay"),Da=a(function(r){return r.toString("utf8")},"parseText"),ka=a(function(r){return r===
|
|
null?null:F(r,8)>0},"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;t<r.length;t++)t>0&&(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<e;)r="0"+r;return r}a(
|
|
H,"pad");function Ya(r){var e=-r.getTimezoneOffset(),t=r.getFullYear(),n=t<1;n&&
|
|
(t=Math.abs(t)+1);var i=H(t,4)+"-"+H(r.getMonth()+1,2)+"-"+H(r.getDate(),2)+"T"+
|
|
H(r.getHours(),2)+":"+H(r.getMinutes(),2)+":"+H(r.getSeconds(),2)+"."+H(r.getMilliseconds(),
|
|
3);return e<0?(i+="-",e*=-1):i+="+",i+=H(Math.floor(e/60),2)+":"+H(e%60,2),n&&(i+=
|
|
" BC"),i}a(Ya,"dateToString");function Za(r){var e=r.getUTCFullYear(),t=e<1;t&&(e=
|
|
Math.abs(e)+1);var n=H(e,4)+"-"+H(r.getUTCMonth()+1,2)+"-"+H(r.getUTCDate(),2)+"\
|
|
T"+H(r.getUTCHours(),2)+":"+H(r.getUTCMinutes(),2)+":"+H(r.getUTCSeconds(),2)+"."+
|
|
H(r.getUTCMilliseconds(),3);return n+="+00:00",t&&(n+=" BC"),n}a(Za,"dateToStrin\
|
|
gUTC");function Ja(r,e,t){return r=typeof r=="string"?{text:r}:r,e&&(typeof e=="\
|
|
function"?r.callback=e:r.values=e),t&&(r.callback=t),r}a(Ja,"normalizeQueryConfi\
|
|
g");var rr=a(function(r){return $a.createHash("md5").update(r,"utf-8").digest("h\
|
|
ex")},"md5"),Xa=a(function(r,e,t){var n=rr(e+r),i=rr(y.concat([y.from(n),t]));return"\
|
|
md5"+i},"postgresMd5PasswordHash");Ui.exports={prepareValue:a(function(e){return ft(
|
|
e)},"prepareValueWrapper"),normalizeQueryConfig:Ja,postgresMd5PasswordHash:Xa,md5:rr}});var Wi=I((Xh,ji)=>{"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;s<t-1;s++)n=Oe(r,n),i=Qi(i,n);return i}
|
|
a(au,"Hi");ji.exports={startSession:eu,continueSession:tu,finalizeSession:ru}});var ir={};te(ir,{join:()=>uu});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;i<n.length;i++)try{Vi(this,this.mapper(n[i]))}catch(s){return t(
|
|
s)}if(this.overflow=this[Se].length>this.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||"\
|
|
<unkn>",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<r.length-1;h+=1){if(e=r.charAt(h+1),t=r.charAt(h),u=n==fr-1,u){c(n,i);break}
|
|
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<Ue.length;t+=1){var n=e[t],i=r[Ue[t]]||
|
|
"",s=n(i);if(!s)return!1}return!0}});var es=I((ml,dr)=>{"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<i;n++){
|
|
var s=e[n];s!==null?t[n]=this._parsers[n](s):t[n]=null}return t}parseRow(e){for(var t={},
|
|
n=0,i=e.length;n<i;n++){var s=e[n],o=this.fields[n].name;s!==null?t[o]=this._parsers[n](
|
|
s):t[o]=null}return t}addRow(e){this.rows.push(e)}addFields(e){this.fields=e,this.
|
|
fields.length&&(this._parsers=new Array(e.length));for(var t=0;t<e.length;t++){var n=e[t];
|
|
this._types?this._parsers[t]=this._types.getTypeParser(n.dataTypeID,n.format||"t\
|
|
ext"):this._parsers[t]=Fu.getTypeParser(n.dataTypeID,n.format||"text")}}};a(xr,"\
|
|
Result");var Er=xr;ls.exports=Er});var ms=I((Fl,ys)=>{"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<e){var n=this.buffer,i=n.length+(n.length>>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<n;s++)i.addInt32(t[s]);return M.
|
|
flush(80)},"parse"),qe=new rn.Writer,Wu=a(function(r,e){for(let t=0;t<r.length;t++){
|
|
let n=e?e(r[t],t):r[t];n==null?(M.addInt16(0),qe.addInt32(-1)):n instanceof y?(M.
|
|
addInt16(1),qe.addInt32(n.length),qe.add(n)):(M.addInt16(0),qe.addInt32(y.byteLength(
|
|
n)),qe.addString(n))}},"writeValues"),Hu=a((r={})=>{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<o;c++)u.columnTypes[c]=
|
|
this.reader.int16();return u}parseNotificationMessage(e,t,n){this.reader.setBuffer(
|
|
e,n);let i=this.reader.int32(),s=this.reader.cstring(),o=this.reader.cstring();return new D.
|
|
NotificationResponseMessage(t,i,s,o)}parseRowDescriptionMessage(e,t,n){this.reader.
|
|
setBuffer(e,n);let i=this.reader.int16(),s=new D.RowDescriptionMessage(t,i);for(let o=0;o<
|
|
i;o++)s.fields[o]=this.parseField();return s}parseField(){let e=this.reader.cstring(),
|
|
t=this.reader.int32(),n=this.reader.int16(),i=this.reader.int32(),s=this.reader.
|
|
int16(),o=this.reader.int32(),u=this.reader.int16()===0?"text":"binary";return new D.
|
|
Field(e,t,n,i,s,o,u)}parseParameterDescriptionMessage(e,t,n){this.reader.setBuffer(
|
|
e,n);let i=this.reader.int16(),s=new D.ParameterDescriptionMessage(t,i);for(let o=0;o<
|
|
i;o++)s.dataTypeIDs[o]=this.reader.int32();return s}parseDataRowMessage(e,t,n){this.
|
|
reader.setBuffer(e,n);let i=this.reader.int16(),s=new Array(i);for(let o=0;o<i;o++){
|
|
let u=this.reader.int32();s[o]=u===-1?null:this.reader.string(u)}return new D.DataRowMessage(
|
|
t,s)}parseParameterStatusMessage(e,t,n){this.reader.setBuffer(e,n);let i=this.reader.
|
|
cstring(),s=this.reader.cstring();return new D.ParameterStatusMessage(t,i,s)}parseBackendKeyData(e,t,n){
|
|
this.reader.setBuffer(e,n);let i=this.reader.int32(),s=this.reader.int32();return new D.
|
|
BackendKeyDataMessage(t,i,s)}parseAuthenticationResponse(e,t,n){this.reader.setBuffer(
|
|
e,n);let i=this.reader.int32(),s={name:"authenticationOk",length:t};switch(i){case 0:
|
|
break;case 3:s.length===8&&(s.name="authenticationCleartextPassword");break;case 5:
|
|
if(s.length===12){s.name="authenticationMD5Password";let u=this.reader.bytes(4);
|
|
return new D.AuthenticationMD5Password(t,u)}break;case 10:s.name="authentication\
|
|
SASL",s.mechanisms=[];let o;do o=this.reader.cstring(),o&&s.mechanisms.push(o);while(o);
|
|
break;case 11:s.name="authenticationSASLContinue",s.data=this.reader.string(t-8);
|
|
break;case 12:s.name="authenticationSASLFinal",s.data=this.reader.string(t-8);break;default:
|
|
throw new Error("Unknown authenticationOk message type "+i)}return s}parseErrorMessage(e,t,n,i){
|
|
this.reader.setBuffer(e,n);let s={},o=this.reader.string(1);for(;o!=="\0";)s[o]=
|
|
this.reader.cstring(),o=this.reader.string(1);let u=s.M,c=i==="notice"?new D.NoticeMessage(
|
|
t,u):new D.DatabaseError(u,t,i);return c.severity=s.S,c.code=s.C,c.detail=s.D,c.
|
|
hint=s.H,c.position=s.P,c.internalPosition=s.p,c.internalQuery=s.q,c.where=s.W,c.
|
|
schema=s.s,c.table=s.t,c.column=s.c,c.dataType=s.d,c.constraint=s.n,c.file=s.F,c.
|
|
line=s.L,c.routine=s.R,c}};a(cn,"Parser");var un=cn;_t.Parser=un});var hn=I(xe=>{"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<e.length;i++){var s=e[i];s===
|
|
"'"?n+=s+s:s==="\\"?(n+=s+s,t=!0):n+=s}return n+="'",t===!0&&(n=" E"+n),n}_pulseQueryQueue(){
|
|
if(this.readyForQuery===!0)if(this.activeQuery=this.queryQueue.shift(),this.activeQuery){
|
|
this.readyForQuery=!1,this.hasExecuted=!0;let e=this.activeQuery.submit(this.connection);
|
|
e&&m.nextTick(()=>{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 <brian.m.carlson@gmail.\
|
|
com>",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<A.length;W++)
|
|
P+=A[W],W<w.length&&(P+="$"+(W+1))}w=w.map(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;de<l-1;de++)j=new Uint8Array(await g.subtle.sign(
|
|
"HMAC",B,j)),X=y.from(X.map((K,k)=>X[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 <https://feross.org/opensource> *)
|
|
|
|
buffer/index.js:
|
|
(*!
|
|
* The buffer module from node.js, for the browser.
|
|
*
|
|
* @author Feross Aboukhadijeh <https://feross.org>
|
|
* @license MIT
|
|
*)
|
|
*/
|