1644 lines
139 KiB
JavaScript
1644 lines
139 KiB
JavaScript
var no=Object.create;var Te=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?Te(r,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):
|
|
r[e]=t;var a=(r,e)=>Te(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),ie=(r,e)=>{for(var t in e)
|
|
Te(r,t,{get:e[t],enumerable:!0})},Cn=(r,e,t,n)=>{if(e&&typeof e=="object"||typeof e==
|
|
"function")for(let i of so(e))!ao.call(r,i)&&i!==t&&Te(r,i,{get:()=>e[i],enumerable:!(n=
|
|
io(e,i))||n.enumerable});return r};var Ie=(r,e,t)=>(t=r!=null?no(oo(r)):{},Cn(e||!r||!r.__esModule?Te(t,"default",{
|
|
value:r,enumerable:!0}):t,r)),N=r=>Cn(Te({},"__esModule",{value:!0}),r);var _=(r,e,t)=>uo(r,typeof e!="symbol"?e+"":e,t);var Pn=I(it=>{"use strict";p();it.byteLength=ho;it.toByteArray=fo;it.fromByteArray=
|
|
mo;var se=[],te=[],co=typeof Uint8Array<"u"?Uint8Array:Array,Lt="ABCDEFGHIJKLMNO\
|
|
PQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";for(ve=0,Tn=Lt.length;ve<Tn;++ve)
|
|
se[ve]=Lt[ve],te[Lt.charCodeAt(ve)]=ve;var ve,Tn;te[45]=62;te[95]=63;function In(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(In,
|
|
"getLens");function ho(r){var e=In(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=In(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=te[r.charCodeAt(c)]<<18|te[r.charCodeAt(c+1)]<<12|te[r.charCodeAt(c+2)]<<6|te[r.
|
|
charCodeAt(c+3)],s[o++]=e>>16&255,s[o++]=e>>8&255,s[o++]=e&255;return i===2&&(e=
|
|
te[r.charCodeAt(c)]<<2|te[r.charCodeAt(c+1)]>>4,s[o++]=e&255),i===1&&(e=te[r.charCodeAt(
|
|
c)]<<10|te[r.charCodeAt(c+1)]<<4|te[r.charCodeAt(c+2)]>>2,s[o++]=e>>8&255,s[o++]=
|
|
e&255),s}a(fo,"toByteArray");function po(r){return se[r>>18&63]+se[r>>12&63]+se[r>>
|
|
6&63]+se[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(se[e>>2]+
|
|
se[e<<4&63]+"==")):n===2&&(e=(r[t-2]<<8)+r[t-1],i.push(se[e>>10]+se[e>>4&63]+se[e<<
|
|
2&63]+"=")),i.join("")}a(mo,"fromByteArray")});var Bn=I(Rt=>{p();Rt.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)};Rt.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 Vn=I(Re=>{"use strict";p();var Ft=Pn(),Be=Bn(),Ln=typeof Symbol=="function"&&
|
|
typeof Symbol.for=="function"?Symbol.for("nodejs.util.inspect.custom"):null;Re.Buffer=
|
|
f;Re.SlowBuffer=xo;Re.INSPECT_MAX_BYTES=50;var st=2147483647;Re.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 he(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(he,"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 Ot(r)}return Dn(r,
|
|
e,t)}a(f,"Buffer");f.poolSize=8192;function Dn(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(oe(r,ArrayBuffer)||r&&oe(r.buffer,ArrayBuffer)||
|
|
typeof SharedArrayBuffer<"u"&&(oe(r,SharedArrayBuffer)||r&&oe(r.buffer,SharedArrayBuffer)))
|
|
return Dt(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(Dn,"from");f.from=function(r,e,t){return Dn(r,e,t)};
|
|
Object.setPrototypeOf(f.prototype,Uint8Array.prototype);Object.setPrototypeOf(f,
|
|
Uint8Array);function kn(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(kn,"assertSize");function wo(r,e,t){return kn(r),
|
|
r<=0?he(r):e!==void 0?typeof t=="string"?he(r).fill(e,t):he(r).fill(e):he(r)}a(wo,
|
|
"alloc");f.alloc=function(r,e,t){return wo(r,e,t)};function Ot(r){return kn(r),he(
|
|
r<0?0:Ut(r)|0)}a(Ot,"allocUnsafe");f.allocUnsafe=function(r){return Ot(r)};f.allocUnsafeSlow=
|
|
function(r){return Ot(r)};function bo(r,e){if((typeof e!="string"||e==="")&&(e="\
|
|
utf8"),!f.isEncoding(e))throw new TypeError("Unknown encoding: "+e);let t=On(r,e)|
|
|
0,n=he(t),i=n.write(r,e);return i!==t&&(n=n.slice(0,i)),n}a(bo,"fromString");function Mt(r){
|
|
let e=r.length<0?0:Ut(r.length)|0,t=he(e);for(let n=0;n<e;n+=1)t[n]=r[n]&255;return t}
|
|
a(Mt,"fromArrayLike");function So(r){if(oe(r,Uint8Array)){let e=new Uint8Array(r);
|
|
return Dt(e.buffer,e.byteOffset,e.byteLength)}return Mt(r)}a(So,"fromArrayView");
|
|
function Dt(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(Dt,"fromArrayBuffer");function Eo(r){if(f.isBuffer(r)){let e=Ut(
|
|
r.length)|0,t=he(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)?he(0):Mt(r);if(r.type==="Buffer"&&
|
|
Array.isArray(r.data))return Mt(r.data)}a(Eo,"fromObject");function Ut(r){if(r>=
|
|
st)throw new RangeError("Attempt to allocate Buffer larger than maximum size: 0x"+
|
|
st.toString(16)+" bytes");return r|0}a(Ut,"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(oe(e,Uint8Array)&&
|
|
(e=f.from(e,e.offset,e.byteLength)),oe(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(oe(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 On(r,e){if(f.isBuffer(r))return r.
|
|
length;if(ArrayBuffer.isView(r)||oe(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 kt(r).length;case"uc\
|
|
s2":case"ucs-2":case"utf16le":case"utf-16le":return t*2;case"hex":return t>>>1;case"\
|
|
base64":return $n(r).length;default:if(i)return n?-1:kt(r).length;e=(""+e).toLowerCase(),
|
|
i=!0}}a(On,"byteLength");f.byteLength=On;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 Nn(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 _e(r,e,t){let n=r[e];r[e]=r[t],
|
|
r[t]=n}a(_e,"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)_e(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)_e(this,t,t+3),_e(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)_e(this,t,t+7),
|
|
_e(this,t+1,t+6),_e(this,t+2,t+5),_e(this,t+3,t+4);return this},"swap64");f.prototype.
|
|
toString=a(function(){let e=this.length;return e===0?"":arguments.length===0?Nn(
|
|
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=Re.INSPECT_MAX_BYTES;return e=this.toString(
|
|
"hex",0,t).replace(/(.{2})/g,"$1 ").trim(),this.length>t&&(e+=" ... "),"<Buffer "+
|
|
e+">"},"inspect");Ln&&(f.prototype[Ln]=f.prototype.inspect);f.prototype.compare=
|
|
a(function(e,t,n,i,s){if(oe(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 Un(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:Rn(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):Rn(r,
|
|
[e],t,n,i);throw new TypeError("val must be string, number or Buffer")}a(Un,"bid\
|
|
irectionalIndexOf");function Rn(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(Rn,"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 Un(this,e,t,n,!0)},"indexOf");f.prototype.lastIndexOf=
|
|
a(function(e,t,n){return Un(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(kt(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($n(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?Ft.fromByteArray(r):Ft.fromByteArray(r.slice(e,t))}a(Po,"base64Slice");function Nn(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(Nn,"utf8Slice");var Fn=4096;function Bo(r){
|
|
let e=r.length;if(e<=Fn)return String.fromCharCode.apply(String,r);let t="",n=0;
|
|
for(;n<e;)t+=String.fromCharCode.apply(String,r.slice(n,n+=Fn));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=ge(a(function(e){e=e>>>0,Le(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=ge(a(function(e){e=e>>>0,Le(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=ge(a(function(e){
|
|
e=e>>>0,Le(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=ge(a(function(e){e=e>>>0,Le(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),Be.read(this,e,
|
|
!0,23,4)},"readFloatLE");f.prototype.readFloatBE=a(function(e,t){return e=e>>>0,
|
|
t||q(e,4,this.length),Be.read(this,e,!1,23,4)},"readFloatBE");f.prototype.readDoubleLE=
|
|
a(function(e,t){return e=e>>>0,t||q(e,8,this.length),Be.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),Be.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 qn(r,e,t,n,i){Gn(
|
|
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(qn,"wrtBigUInt64LE");function Qn(r,e,t,n,i){
|
|
Gn(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(Qn,"wrtBigUInt64BE");f.
|
|
prototype.writeBigUInt64LE=ge(a(function(e,t=0){return qn(this,e,t,BigInt(0),BigInt(
|
|
"0xffffffffffffffff"))},"writeBigUInt64LE"));f.prototype.writeBigUInt64BE=ge(a(function(e,t=0){
|
|
return Qn(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=ge(a(function(e,t=0){return qn(this,e,t,-BigInt(
|
|
"0x8000000000000000"),BigInt("0x7fffffffffffffff"))},"writeBigInt64LE"));f.prototype.
|
|
writeBigInt64BE=ge(a(function(e,t=0){return Qn(this,e,t,-BigInt("0x8000000000000\
|
|
000"),BigInt("0x7fffffffffffffff"))},"writeBigInt64BE"));function jn(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(jn,"checkIEEE754");function Wn(r,e,t,n,i){return e=+e,t=
|
|
t>>>0,i||jn(r,e,t,4,34028234663852886e22,-34028234663852886e22),Be.write(r,e,t,n,
|
|
23,4),t+4}a(Wn,"writeFloat");f.prototype.writeFloatLE=a(function(e,t,n){return Wn(
|
|
this,e,t,!0,n)},"writeFloatLE");f.prototype.writeFloatBE=a(function(e,t,n){return Wn(
|
|
this,e,t,!1,n)},"writeFloatBE");function Hn(r,e,t,n,i){return e=+e,t=t>>>0,i||jn(
|
|
r,e,t,8,17976931348623157e292,-17976931348623157e292),Be.write(r,e,t,n,52,8),t+8}
|
|
a(Hn,"writeDouble");f.prototype.writeDoubleLE=a(function(e,t,n){return Hn(this,e,
|
|
t,!0,n)},"writeDoubleLE");f.prototype.writeDoubleBE=a(function(e,t,n){return Hn(
|
|
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 Pe={};function Nt(r,e,t){var n;Pe[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(Nt,"E");Nt("ERR_BUFFER_OUT_OF_BOUNDS",function(r){return r?
|
|
`${r} is outside of buffer bounds`:"Attempt to access memory outside buffer boun\
|
|
ds"},RangeError);Nt("ERR_INVALID_ARG_TYPE",function(r,e){return`The "${r}" argum\
|
|
ent must be of type number. Received type ${typeof e}`},TypeError);Nt("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=Mn(String(t)):typeof t=="bigint"&&(i=String(t),
|
|
(t>BigInt(2)**BigInt(32)||t<-(BigInt(2)**BigInt(32)))&&(i=Mn(i)),i+="n"),n+=` It\
|
|
must be ${e}. Received ${i}`,n},RangeError);function Mn(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(Mn,"addNumericalSeparator");function Do(r,e,t){Le(e,"offset"),(r[e]===
|
|
void 0||r[e+t]===void 0)&&We(e,r.length-(t+1))}a(Do,"checkBounds");function Gn(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 Pe.ERR_OUT_OF_RANGE(
|
|
"value",u,r)}Do(n,i,s)}a(Gn,"checkIntBI");function Le(r,e){if(typeof r!="number")
|
|
throw new Pe.ERR_INVALID_ARG_TYPE(e,"number",r)}a(Le,"validateNumber");function We(r,e,t){
|
|
throw Math.floor(r)!==r?(Le(r,t),new Pe.ERR_OUT_OF_RANGE(t||"offset","an integer",
|
|
r)):e<0?new Pe.ERR_BUFFER_OUT_OF_BOUNDS:new Pe.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 kt(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(
|
|
kt,"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 $n(r){return Ft.toByteArray(Oo(r))}a($n,"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 oe(r,e){return r instanceof e||
|
|
r!=null&&r.constructor!=null&&r.constructor.name!=null&&r.constructor.name===e.name}
|
|
a(oe,"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 ge(r){return typeof BigInt>"u"?Qo:r}
|
|
a(ge,"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:Vn().Buffer,m=globalThis.process??
|
|
{};m.env??(m.env={});try{m.nextTick(()=>{})}catch{let e=Promise.resolve();m.nextTick=
|
|
e.then.bind(e)}});var we=I((th,Qt)=>{"use strict";p();var Fe=typeof Reflect=="object"?Reflect:null,
|
|
Kn=Fe&&typeof Fe.apply=="function"?Fe.apply:a(function(e,t,n){return Function.prototype.
|
|
apply.call(e,t,n)},"ReflectApply"),at;Fe&&typeof Fe.ownKeys=="function"?at=Fe.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 Yn=Number.isNaN||a(function(e){return e!==
|
|
e},"NumberIsNaN");function L(){L.init.call(this)}a(L,"EventEmitter");Qt.exports=
|
|
L;Qt.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||Yn(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||Yn(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 Zn(r){return r._maxListeners===void 0?L.defaultMaxListeners:
|
|
r._maxListeners}a(Zn,"_getMaxListeners");L.prototype.getMaxListeners=a(function(){
|
|
return Zn(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")Kn(c,this,t);else for(var h=c.length,l=ri(c,h),n=0;n<h;++n)Kn(l[n],this,
|
|
t);return!0},"emit");function Jn(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=Zn(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(Jn,"_addList\
|
|
ener");L.prototype.addListener=a(function(e,t){return Jn(this,e,t,!1)},"addListe\
|
|
ner");L.prototype.on=L.prototype.addListener;L.prototype.prependListener=a(function(e,t){
|
|
return Jn(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 Xn(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(Xn,"_onceWrap");L.prototype.
|
|
once=a(function(e,t){return ut(t),this.on(e,Xn(this,e,t)),this},"once");L.prototype.
|
|
prependOnceListener=a(function(e,t){return ut(t),this.prependListener(e,Xn(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 ei(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):ri(i,i.length)}a(ei,"_listeners");L.prototype.
|
|
listeners=a(function(e){return ei(this,e,!0)},"listeners");L.prototype.rawListeners=
|
|
a(function(e){return ei(this,e,!1)},"rawListeners");L.listenerCount=function(r,e){
|
|
return typeof r.listenerCount=="function"?r.listenerCount(e):ti.call(r,e)};L.prototype.
|
|
listenerCount=ti;function ti(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(ti,"listenerCount");
|
|
L.prototype.eventNames=a(function(){return this._eventsCount>0?at(this._events):
|
|
[]},"eventNames");function ri(r,e){for(var t=new Array(e),n=0;n<e;++n)t[n]=r[n];
|
|
return t}a(ri,"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"),ni(r,e,s,{once:!0}),e!=="error"&&Vo(r,i,{once:!0})})}
|
|
a($o,"once");function Vo(r,e,t){typeof r.on=="function"&&ni(r,"error",e,t)}a(Vo,
|
|
"addErrorHandlerIfEventEmitter");function ni(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(ni,"eventTargetAgnosticAddListener")});var He={};ie(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,ue=b(C[R-2],17)^b(C[R-2],19)^C[R-2]>>>10;C[R]=C[R-
|
|
16]+G+C[R-7]+ue|0}let A=e,w=t,P=n,V=i,O=s,W=o,ae=u,ee=c;for(let R=0;R<64;R++){let G=b(
|
|
O,6)^b(O,11)^b(O,25),ue=O&W^~O&ae,de=ee+G+ue+d[R]+C[R]|0,Ee=b(A,2)^b(A,13)^b(A,22),
|
|
ce=A&w^A&P^w&P,Ce=Ee+ce|0;ee=ae,ae=W,W=O,O=V+de|0,V=P,P=w,w=A,A=de+Ce|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+ae|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"),pe=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:pe}:(X(r),pe())}var ii=z(
|
|
()=>{"use strict";p();a($e,"sha256")});var U,Ve,si=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 jt={};ie(jt,{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 Wt=z(()=>{"use strict";p();ii();si();
|
|
a(zo,"randomBytes");a(Yo,"createHash");a(Zo,"createHmac")});var Gt=I(oi=>{"use strict";p();oi.parse=function(r,e){return new Ht(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 Ht=ct;function Jo(r){return r}a(Jo,"identity")});var $t=I((wh,ai)=>{p();var Xo=Gt();ai.exports={create:a(function(r,e){return{parse:a(
|
|
function(){return Xo.parse(r,e)},"parse")}},"create")}});var hi=I((Eh,ci)=>{"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$/;
|
|
ci.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=ui(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)),Vt(i)&&d.setUTCFullYear(i),b!==0&&d.setTime(d.getTime()-b)):(d=new Date(
|
|
i,s,o,u,c,h,l),Vt(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=ui(t));var i=parseInt(e[2],
|
|
10)-1,s=e[3],o=new Date(t,i,s);return Vt(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 ui(r){
|
|
return-(r-1)}a(ui,"bcYearToNegativeYear");function Vt(r){return r>=0&&r<100}a(Vt,
|
|
"is0To99")});var fi=I((_h,li)=>{p();li.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 yi=I((Th,di)=>{"use strict";p();var ua=fi();di.exports=Me;function Me(r){if(!(this instanceof
|
|
Me))return new Me(r);ua(this,Sa(r))}a(Me,"PostgresInterval");var ca=["seconds","\
|
|
minutes","hours","days","months","years"];Me.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"];Me.
|
|
prototype.toISOString=Me.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 Kt="([+-]?\\d+)",pa=Kt+"\\s+years?",da=Kt+"\\s+mons?",ya=Kt+"\
|
|
\\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*")),pi={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(pi).reduce(function(n,i){var s=pi[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 gi=I((Bh,mi)=>{"use strict";p();mi.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 _i=I((Fh,vi)=>{p();var Ke=Gt(),ze=$t(),ht=hi(),bi=yi(),Si=gi();function lt(r){
|
|
return a(function(t){return t===null?t:r(t)},"nullAllowed")}a(lt,"allowNull");function Ei(r){
|
|
return r===null?r:r==="TRUE"||r==="t"||r==="true"||r==="y"||r==="yes"||r==="on"||
|
|
r==="1"}a(Ei,"parseBool");function Ea(r){return r?Ke.parse(r,Ei):null}a(Ea,"pars\
|
|
eBoolArray");function xa(r){return parseInt(r,10)}a(xa,"parseBaseTenInt");function zt(r){
|
|
return r?Ke.parse(r,lt(xa)):null}a(zt,"parseIntegerArray");function va(r){return r?
|
|
Ke.parse(r,lt(function(e){return xi(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=Xt(t)),t});return e.parse()},"parsePointArray"),Yt=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"),re=a(function(r){if(!r)return null;var e=ze.
|
|
create(r);return e.parse()},"parseStringArray"),Zt=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=bi(t)),t});return e.parse()},"parseIntervalArray"),Ca=a(function(r){
|
|
return r?Ke.parse(r,lt(Si)):null},"parseByteAArray"),Jt=a(function(r){return parseInt(
|
|
r,10)},"parseInteger"),xi=a(function(r){var e=String(r);return/^\d+$/.test(e)?e:
|
|
r},"parseBigInteger"),wi=a(function(r){return r?Ke.parse(r,lt(JSON.parse)):null},
|
|
"parseJsonArray"),Xt=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=Xt(e);return s.radius=parseFloat(t),s},"parseCircle"),Ia=a(function(r){r(20,
|
|
xi),r(21,Jt),r(23,Jt),r(26,Jt),r(700,parseFloat),r(701,parseFloat),r(16,Ei),r(1082,
|
|
ht),r(1114,ht),r(1184,ht),r(600,Xt),r(651,re),r(718,Ta),r(1e3,Ea),r(1001,Ca),r(1005,
|
|
zt),r(1007,zt),r(1028,zt),r(1016,va),r(1017,_a),r(1021,Yt),r(1022,Yt),r(1231,Yt),
|
|
r(1014,re),r(1015,re),r(1008,re),r(1009,re),r(1040,re),r(1041,re),r(1115,Zt),r(1182,
|
|
Zt),r(1185,Zt),r(1186,bi),r(1187,Aa),r(17,Si),r(114,JSON.parse.bind(JSON)),r(3802,
|
|
JSON.parse.bind(JSON)),r(199,wi),r(3807,wi),r(3907,re),r(2951,re),r(791,re),r(1183,
|
|
re),r(1270,re)},"init");vi.exports={init:Ia}});var Ci=I((kh,Ai)=>{"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");Ai.exports=Pa});var Li=I((Nh,Bi)=>{p();var Ba=Ci(),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"),Pi=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"),Ti=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 Pi(r,23,8)},"pars\
|
|
eFloat32"),Fa=a(function(r){return Pi(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"),Ii=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,Ti),r(26,
|
|
Ti),r(1700,Ma),r(700,Ra),r(701,Fa),r(16,ka),r(1114,Ii.bind(null,!1)),r(1184,Ii.bind(
|
|
null,!0)),r(1e3,Ye),r(1007,Ye),r(1016,Ye),r(1008,Ye),r(1009,Ye),r(25,Da)},"init");
|
|
Bi.exports={init:Oa}});var Fi=I((jh,Ri)=>{p();Ri.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=_i(),Na=Li(),qa=$t(),Qa=Fi();Je.getTypeParser=ja;Je.setTypeParser=
|
|
Wa;Je.arrayParser=qa;Je.builtins=Qa;var Ze={text:{},binary:{}};function Mi(r){return String(
|
|
r)}a(Mi,"noParse");function ja(r,e){return e=e||"text",Ze[e]&&Ze[e][r]||Mi}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((Vh,er)=>{"use strict";p();er.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 De=Xe(),Ha=De.getTypeParser(
|
|
20,"text"),Ga=De.getTypeParser(1016,"text");er.exports.__defineSetter__("parseIn\
|
|
t8",function(r){De.setTypeParser(20,"text",r?De.getTypeParser(23,"text"):Ha),De.
|
|
setTypeParser(1016,"text",r?De.getTypeParser(1007,"text"):Ga)})});var tt=I((zh,ki)=>{"use strict";p();var $a=(Wt(),N(jt)),Va=et();function Ka(r){var e=r.
|
|
replace(/\\/g,"\\\\").replace(/"/g,'\\"');return'"'+e+'"'}a(Ka,"escapeElement");
|
|
function Di(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+Di(r[t]):r[t]instanceof y?e+="\\\\x"+r[t].
|
|
toString("hex"):e+=Ka(ft(r[t]));return e=e+"}",e}a(Di,"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)?Di(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 tr=a(function(r){return $a.createHash("md5").update(r,"utf-8").digest("h\
|
|
ex")},"md5"),Xa=a(function(r,e,t){var n=tr(e+r),i=tr(y.concat([y.from(n),t]));return"\
|
|
md5"+i},"postgresMd5PasswordHash");ki.exports={prepareValue:a(function(e){return ft(
|
|
e)},"prepareValueWrapper"),normalizeQueryConfig:Ja,postgresMd5PasswordHash:Xa,md5:tr}});var Qi=I((Jh,qi)=>{"use strict";p();var rr=(Wt(),N(jt));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=rr.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=ke(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=ke(u,d),C=Ni(
|
|
o,b),B=C.toString("base64"),j=ke(s,"Server Key"),X=ke(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 Oi(r){return/^(?:[a-zA-Z0-9+/]{4})*(?:[a-zA-Z0-9+/]{2}==|[a-zA-Z0-9+/]{3}=)?$/.
|
|
test(r)}a(Oi,"isBase64");function Ui(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(Ui,"parseAttributePairs");function iu(r){let e=Ui(
|
|
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(!Oi(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=Ui(r).get("v");if(t){if(!Oi(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 Ni(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(Ni,"xorBuffers");function ou(r){return rr.createHash(
|
|
"sha256").update(r).digest()}a(ou,"sha256");function ke(r,e){return rr.createHmac(
|
|
"sha256",r).update(e).digest()}a(ke,"hmacSha256");function au(r,e,t){for(var n=ke(
|
|
r,y.concat([e,y.from([0,0,0,1])])),i=n,s=0;s<t-1;s++)n=ke(r,n),i=Ni(i,n);return i}
|
|
a(au,"Hi");qi.exports={startSession:eu,continueSession:tu,finalizeSession:ru}});var nr={};ie(nr,{join:()=>uu});function uu(...r){return r.join("/")}var ir=z(()=>{
|
|
"use strict";p();a(uu,"join")});var sr={};ie(sr,{stat:()=>cu});function cu(r,e){e(new Error("No filesystem"))}var or=z(
|
|
()=>{"use strict";p();a(cu,"stat")});var ar={};ie(ar,{default:()=>hu});var hu,ur=z(()=>{"use strict";p();hu={}});var ji={};ie(ji,{StringDecoder:()=>cr});var hr,cr,Wi=z(()=>{"use strict";p();hr=
|
|
class hr{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(hr,"StringDecoder");
|
|
cr=hr});var Vi=I((ul,$i)=>{"use strict";p();var{Transform:lu}=(ur(),N(ar)),{StringDecoder:fu}=(Wi(),N(ji)),
|
|
be=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[be]+=this[pt].write(r),n=this[be].split(this.matcher);this[be]=
|
|
n.pop();for(let i=0;i<n.length;i++)try{Gi(this,this.mapper(n[i]))}catch(s){return t(
|
|
s)}if(this.overflow=this[be].length>this.maxLength,this.overflow&&!this.skipOverflow){
|
|
t(new Error("maximum buffer reached"));return}t()}a(pu,"transform");function du(r){
|
|
if(this[be]+=this[pt].end(),this[be])try{Gi(this,this.mapper(this[be]))}catch(e){
|
|
return r(e)}r()}a(du,"flush");function Gi(r,e){e!==void 0&&r.push(e)}a(Gi,"push");
|
|
function Hi(r){return r}a(Hi,"noop");function yu(r,e,t){switch(r=r||/\r?\n/,e=e||
|
|
Hi,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=Hi)}t=Object.
|
|
assign({},t),t.autoDestroy=!0,t.transform=pu,t.flush=du,t.readableObjectMode=!0;
|
|
let n=new lu(t);return n[be]="",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");$i.exports=yu});var Yi=I((ll,le)=>{"use strict";p();var Ki=(ir(),N(nr)),mu=(ur(),N(ar)).Stream,gu=Vi(),
|
|
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 Oe=["host","port",
|
|
"database","user","password"],lr=Oe.length,_u=Oe[lr-1];function fr(){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(fr,"warn");Object.defineProperty(le.exports,
|
|
"isWin",{get:a(function(){return dt},"get"),set:a(function(r){dt=r},"set")});le.
|
|
exports.warnTo=function(r){var e=rt;return rt=r,e};le.exports.getFileName=function(r){
|
|
var e=r||m.env,t=e.PGPASSFILE||(dt?Ki.join(e.APPDATA||"./","postgresql","pgpass.\
|
|
conf"):Ki.join(e.HOME||"./",".pgpass"));return t};le.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)?(fr('WARNING: password file "%s" has group or \
|
|
world access; permissions should be u=rw (0600) or less',e),!1):!0:(fr('WARNING:\
|
|
password file "%s" is not a plain file',e),!1))};var Au=le.exports.match=function(r,e){
|
|
return Oe.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)};le.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(),
|
|
fr("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=le.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[Oe[l]]=C},"addToObj"),
|
|
h=0;h<r.length-1;h+=1){if(e=r.charAt(h+1),t=r.charAt(h),u=n==lr-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===
|
|
lr?o:null,o},Tu=le.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<Oe.length;t+=1){var n=e[t],i=r[Oe[t]]||
|
|
"",s=n(i);if(!s)return!1}return!0}});var Ji=I((yl,pr)=>{"use strict";p();var dl=(ir(),N(nr)),Zi=(or(),N(sr)),yt=Yi();
|
|
pr.exports=function(r,e){var t=yt.getFileName();Zi.stat(t,function(n,i){if(n||!yt.
|
|
usePgPass(i,t))return e(void 0);var s=Zi.createReadStream(t);yt.getPassword(r,s,
|
|
e)})};pr.exports.warnTo=yt.warnTo});var gt=I((gl,Xi)=>{"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)};Xi.exports=mt});var es={};ie(es,{default:()=>Pu});var Pu,ts=z(()=>{"use strict";p();Pu={}});var rs={};ie(rs,{parse:()=>dr});function dr(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 yr=z(()=>{"use strict";p();a(dr,"parse")});var is=I((vl,ns)=>{"use strict";p();var Bu=(yr(),N(rs)),mr=(or(),N(sr));function gr(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=mr.readFileSync(t.sslcert).toString()),t.sslkey&&(t.ssl.key=mr.readFileSync(
|
|
t.sslkey).toString()),t.sslrootcert&&(t.ssl.ca=mr.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(gr,"parse");ns.exports=gr;gr.parse=gr});var wt=I((Cl,as)=>{"use strict";p();var Lu=(ts(),N(es)),os=et(),ss=is().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||os[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 os.ssl},"readSSLConfigFromEnvironment"),Ue=a(
|
|
function(r){return"'"+(""+r).replace(/\\/g,"\\\\").replace(/'/g,"\\'")+"'"},"quo\
|
|
teParamValue"),ne=a(function(r,e,t){var n=e[t];n!=null&&r.push(t+"="+Ue(n))},"ad\
|
|
d"),br=class br{constructor(e){e=typeof e=="string"?ss(e):e||{},e.connectionString&&
|
|
(e=Object.assign({},e,ss(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=[];
|
|
ne(t,this,"user"),ne(t,this,"password"),ne(t,this,"port"),ne(t,this,"application\
|
|
_name"),ne(t,this,"fallback_application_name"),ne(t,this,"connect_timeout"),ne(t,
|
|
this,"options");var n=typeof this.ssl=="object"?this.ssl:this.ssl?{sslmode:this.
|
|
ssl}:{};if(ne(t,n,"sslmode"),ne(t,n,"sslca"),ne(t,n,"sslkey"),ne(t,n,"sslcert"),
|
|
ne(t,n,"sslrootcert"),this.database&&t.push("dbname="+Ue(this.database)),this.replication&&
|
|
t.push("replication="+Ue(this.replication)),this.host&&t.push("host="+Ue(this.host)),
|
|
this.isDomainSocket)return e(null,t.join(" "));this.client_encoding&&t.push("cli\
|
|
ent_encoding="+Ue(this.client_encoding)),Lu.lookup(this.host,function(i,s){return i?
|
|
e(i,null):(t.push("hostaddr="+Ue(s)),e(null,t.join(" ")))})}};a(br,"ConnectionPa\
|
|
rameters");var wr=br;as.exports=wr});var hs=I((Pl,cs)=>{"use strict";p();var Fu=Xe(),us=/^([A-Za-z]+)(?: (\d+))?(?: (\d+))?/,
|
|
Er=class Er{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=us.exec(e.text):t=us.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(Er,"\
|
|
Result");var Sr=Er;cs.exports=Sr});var ds=I((Rl,ps)=>{"use strict";p();var{EventEmitter:Mu}=we(),ls=hs(),fs=tt(),vr=class vr extends Mu{constructor(e,t,n){
|
|
super(),e=fs.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 ls(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 ls(
|
|
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:fs.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(vr,"Query");
|
|
var xr=vr;ps.exports=xr});var gs={};ie(gs,{Socket:()=>Ae,isIP:()=>Du});function Du(r){return 0}var ms,ys,v,
|
|
Ae,bt=z(()=>{"use strict";p();ms=Ie(we(),1);a(Du,"isIP");ys=/^[^.]+\./,v=class v extends ms.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(ys,"apiauth."):s=t.replace(ys,"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",{});Ae=v});var Jr=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 Ur=class Ur extends Error{constructor(e,t,n){super(
|
|
e),this.length=t,this.name=n}};a(Ur,"DatabaseError");var _r=Ur;T.DatabaseError=_r;
|
|
var Nr=class Nr{constructor(e,t){this.length=e,this.chunk=t,this.name="copyData"}};
|
|
a(Nr,"CopyDataMessage");var Ar=Nr;T.CopyDataMessage=Ar;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 Cr=qr;T.CopyResponse=Cr;var Qr=class Qr{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(Qr,"Field");var Tr=Qr;T.Field=Tr;var jr=class jr{constructor(e,t){
|
|
this.length=e,this.fieldCount=t,this.name="rowDescription",this.fields=new Array(
|
|
this.fieldCount)}};a(jr,"RowDescriptionMessage");var Ir=jr;T.RowDescriptionMessage=
|
|
Ir;var Wr=class Wr{constructor(e,t){this.length=e,this.parameterCount=t,this.name=
|
|
"parameterDescription",this.dataTypeIDs=new Array(this.parameterCount)}};a(Wr,"P\
|
|
arameterDescriptionMessage");var Pr=Wr;T.ParameterDescriptionMessage=Pr;var Hr=class Hr{constructor(e,t,n){
|
|
this.length=e,this.parameterName=t,this.parameterValue=n,this.name="parameterSta\
|
|
tus"}};a(Hr,"ParameterStatusMessage");var Br=Hr;T.ParameterStatusMessage=Br;var Gr=class Gr{constructor(e,t){
|
|
this.length=e,this.salt=t,this.name="authenticationMD5Password"}};a(Gr,"Authenti\
|
|
cationMD5Password");var Lr=Gr;T.AuthenticationMD5Password=Lr;var $r=class $r{constructor(e,t,n){
|
|
this.length=e,this.processID=t,this.secretKey=n,this.name="backendKeyData"}};a($r,
|
|
"BackendKeyDataMessage");var Rr=$r;T.BackendKeyDataMessage=Rr;var Vr=class Vr{constructor(e,t,n,i){
|
|
this.length=e,this.processId=t,this.channel=n,this.payload=i,this.name="notifica\
|
|
tion"}};a(Vr,"NotificationResponseMessage");var Fr=Vr;T.NotificationResponseMessage=
|
|
Fr;var Kr=class Kr{constructor(e,t){this.length=e,this.status=t,this.name="ready\
|
|
ForQuery"}};a(Kr,"ReadyForQueryMessage");var Mr=Kr;T.ReadyForQueryMessage=Mr;var zr=class zr{constructor(e,t){
|
|
this.length=e,this.text=t,this.name="commandComplete"}};a(zr,"CommandCompleteMes\
|
|
sage");var Dr=zr;T.CommandCompleteMessage=Dr;var Yr=class Yr{constructor(e,t){this.
|
|
length=e,this.fields=t,this.name="dataRow",this.fieldCount=t.length}};a(Yr,"Data\
|
|
RowMessage");var kr=Yr;T.DataRowMessage=kr;var Zr=class Zr{constructor(e,t){this.
|
|
length=e,this.message=t,this.name="notice"}};a(Zr,"NoticeMessage");var Or=Zr;T.NoticeMessage=
|
|
Or});var ws=I(St=>{"use strict";p();Object.defineProperty(St,"__esModule",{value:!0});
|
|
St.Writer=void 0;var en=class en{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(en,"Wr\
|
|
iter");var Xr=en;St.Writer=Xr});var Ss=I(xt=>{"use strict";p();Object.defineProperty(xt,"__esModule",{value:!0});
|
|
xt.serialize=void 0;var tn=ws(),M=new tn.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 tn.
|
|
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"),bs=[],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||bs;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"),Ne=new tn.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),Ne.addInt32(-1)):n instanceof y?(M.
|
|
addInt16(1),Ne.addInt32(n.length),Ne.add(n)):(M.addInt16(0),Ne.addInt32(y.byteLength(
|
|
n)),Ne.addString(n))}},"writeValues"),Hu=a((r={})=>{let e=r.portal||"",t=r.statement||
|
|
"",n=r.binary||!1,i=r.values||bs,s=i.length;return M.addCString(e).addCString(t),
|
|
M.addInt16(s),Wu(i,r.valueMapper),M.addInt16(s),M.add(Ne.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"),rn=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?rn(68,`${r.type}${r.name||""}`):r.type==="P"?Ku:zu,"describe"),Zu=a(
|
|
r=>{let e=`${r.type}${r.name||""}`;return rn(67,e)},"close"),Ju=a(r=>M.add(r).flush(
|
|
100),"copyData"),Xu=a(r=>rn(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 Es=I(vt=>{"use strict";p();Object.defineProperty(vt,"__esModule",{value:!0});
|
|
vt.BufferReader=void 0;var sc=y.allocUnsafe(0),sn=class sn{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(sn,"BufferReader");var nn=sn;vt.BufferReader=
|
|
nn});var _s=I(_t=>{"use strict";p();Object.defineProperty(_t,"__esModule",{value:!0});
|
|
_t.Parser=void 0;var D=Jr(),oc=Es(),on=1,ac=4,xs=on+ac,vs=y.allocUnsafe(0),un=class un{constructor(e){
|
|
if(this.buffer=vs,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+xs<=n;){let s=this.buffer[i],o=this.buffer.readUInt32BE(
|
|
i+on),u=on+o;if(u+i<=n){let c=this.handlePacket(i+xs,s,o,this.buffer);t(c),i+=u}else
|
|
break}i===n?(this.buffer=vs,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(un,"Parser");var an=un;_t.Parser=an});var cn=I(Se=>{"use strict";p();Object.defineProperty(Se,"__esModule",{value:!0});
|
|
Se.DatabaseError=Se.serialize=Se.parse=void 0;var uc=Jr();Object.defineProperty(
|
|
Se,"DatabaseError",{enumerable:!0,get:a(function(){return uc.DatabaseError},"get")});
|
|
var cc=Ss();Object.defineProperty(Se,"serialize",{enumerable:!0,get:a(function(){
|
|
return cc.serialize},"get")});var hc=_s();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");Se.
|
|
parse=lc});var As={};ie(As,{connect:()=>fc});function fc({socket:r,servername:e}){return r.
|
|
startTls(e),r}var Cs=z(()=>{"use strict";p();a(fc,"connect")});var fn=I((nf,Ps)=>{"use strict";p();var Ts=(bt(),N(gs)),pc=we().EventEmitter,{parse:dc,
|
|
serialize:Q}=cn(),Is=Q.flush(),yc=Q.sync(),mc=Q.end(),ln=class ln extends pc{constructor(e){
|
|
super(),e=e||{},this.stream=e.stream||new Ts.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=(Cs(),N(As));let c={socket:n.stream};n.ssl!==!0&&(Object.assign(
|
|
c,n.ssl),"key"in n.ssl&&(c.key=n.ssl.key)),Ts.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(Is)}sync(){this.
|
|
_ending=!0,this._send(Is),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(ln,"Connection");var hn=ln;Ps.exports=hn});var Rs=I((uf,Ls)=>{"use strict";p();var gc=we().EventEmitter,af=(Ge(),N(He)),wc=tt(),
|
|
pn=Qi(),bc=Ji(),Sc=gt(),Ec=wt(),Bs=ds(),xc=et(),vc=fn(),dn=class dn 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=pn.startSession(e.mechanisms),this.connection.sendSASLInitialResponseMessage(
|
|
this.saslSession.mechanism,this.saslSession.response)})}_handleAuthSASLContinue(e){
|
|
pn.continueSession(this.saslSession,this.password,e.data),this.connection.sendSCRAMClientFinalMessage(
|
|
this.saslSession.response)}_handleAuthSASLFinal(e){pn.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 Bs(
|
|
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(dn,"Client");var At=dn;At.Query=
|
|
Bs;Ls.exports=At});var ks=I((lf,Ds)=>{"use strict";p();var _c=we().EventEmitter,Fs=a(function(){},"\
|
|
NOOP"),Ms=a((r,e)=>{let t=r.findIndex(e);return t===-1?void 0:r.splice(t,1)[0]},
|
|
"removeWhere"),gn=class gn{constructor(e,t,n){this.client=e,this.idleListener=t,
|
|
this.timeoutId=n}};a(gn,"IdleItem");var yn=gn,wn=class wn{constructor(e){this.callback=
|
|
e}};a(wn,"PendingItem");var qe=wn;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 bn=class bn 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=Ms(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(()=>{Ms(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,Fs);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,Fs);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 yn(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(bn,"Pool");var mn=bn;Ds.exports=mn});var Os={};ie(Os,{default:()=>Tc});var Tc,Us=z(()=>{"use strict";p();Tc={}});var Ns=I((yf,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 js=I((mf,Qs)=>{"use strict";p();var qs=we().EventEmitter,Pc=(Ge(),N(He)),Sn=tt(),
|
|
Qe=Qs.exports=function(r,e,t){qs.call(this),r=Sn.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(
|
|
Qe,qs);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"};Qe.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"};Qe.prototype.then=function(r,e){return this.
|
|
_getPromise().then(r,e)};Qe.prototype.catch=function(r){return this._getPromise().
|
|
catch(r)};Qe.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)};Qe.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(Sn.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(Sn.prepareValue);r.native.query(this.text,i,t)}else r.native.query(this.
|
|
text,t)}});var $s=I((Sf,Gs)=>{"use strict";p();var Lc=(Us(),N(Os)),Rc=gt(),bf=Ns(),Ws=we().
|
|
EventEmitter,Fc=(Ge(),N(He)),Mc=wt(),Hs=js(),J=Gs.exports=function(r){Ws.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=Hs;Fc.inherits(J,Ws);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 Hs(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 En=I((vf,Vs)=>{"use strict";p();Vs.exports=$s()});var Tt=I((Af,nt)=>{"use strict";p();var Dc=Rs(),kc=et(),Oc=fn(),Uc=ks(),{DatabaseError:Nc}=cn(),
|
|
qc=a(r=>{var e;return e=class extends Uc{constructor(n){super(n,r)}},a(e,"BoundP\
|
|
ool"),e},"poolFactory"),xn=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 xn(En()):(nt.exports=new xn(Dc),Object.defineProperty(nt.exports,"na\
|
|
tive",{configurable:!0,enumerable:!1,get(){var r=null;try{r=new xn(En())}catch(e){
|
|
if(e.code!=="MODULE_NOT_FOUND")throw e}return Object.defineProperty(nt.exports,"\
|
|
native",{value:r}),r}}))});p();var Pt=Ie(Tt());bt();p();bt();yr();var Ys=Ie(tt()),Zs=Ie(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 fe=It,Ks="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 Js(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=dr(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,Ys.prepareValue)(W));let O={query:P,
|
|
params:w};return u&&u(O),jc(pe,O,V)}a(X,"resolve"),X.transaction=async(A,w)=>{if(typeof A==
|
|
"function"&&(A=A(X)),!Array.isArray(A))throw new Error(Ks);A.forEach(O=>{if(O[Symbol.
|
|
toStringTag]!=="NeonQueryPromise")throw new Error(Ks)});let P=A.map(O=>O.parameterizedQuery),
|
|
V=A.map(O=>O.opts??{});return pe(P,V,w)};async function pe(A,w,P){let{fetchEndpoint:V,
|
|
fetchFunction:O}=Ae,W=typeof V=="function"?V(C,B,{jwtAuth:h!==void 0}):V,ae=Array.
|
|
isArray(A)?{queries:A}:A,ee=n??{},R=e??!1,G=t??!1,ue=i,de=s,Ee=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&&
|
|
(ue=P.isolationLevel),P.readOnly!==void 0&&(de=P.readOnly),P.deferrable!==void 0&&
|
|
(Ee=P.deferrable)),w!==void 0&&!Array.isArray(w)&&w.fetchOptions!==void 0&&(ee={
|
|
...ee,...w.fetchOptions});let ce={"Neon-Connection-String":r,"Neon-Raw-Text-Outp\
|
|
ut":"true","Neon-Array-Mode":"true"},Ce=await Wc(h);Ce&&(ce.Authorization=`Beare\
|
|
r ${Ce}`),Array.isArray(A)&&(ue!==void 0&&(ce["Neon-Batch-Isolation-Level"]=ue),
|
|
de!==void 0&&(ce["Neon-Batch-Read-Only"]=String(de)),Ee!==void 0&&(ce["Neon-Batc\
|
|
h-Deferrable"]=String(Ee)));let ye;try{ye=await(O??fetch)(W,{method:"POST",body:JSON.
|
|
stringify(ae),headers:ce,...ee})}catch(K){let k=new fe(`Error connecting to data\
|
|
base: ${K.message}`);throw k.sourceError=K,k}if(ye.ok){let K=await ye.json();if(Array.
|
|
isArray(A)){let k=K.results;if(!Array.isArray(k))throw new fe("Neon internal err\
|
|
or: unexpected result format");return k.map((me,xe)=>{let Bt=w[xe]??{},to=Bt.arrayMode??
|
|
R,ro=Bt.fullResults??G;return zs(me,{arrayMode:to,fullResults:ro,parameterizedQuery:A[xe],
|
|
resultCallback:c,types:Bt.types})})}else{let k=w??{},me=k.arrayMode??R,xe=k.fullResults??
|
|
G;return zs(K,{arrayMode:me,fullResults:xe,parameterizedQuery:A,resultCallback:c,
|
|
types:k.types})}}else{let{status:K}=ye;if(K===400){let k=await ye.json(),me=new fe(
|
|
k.message);for(let xe of Qc)me[xe]=k[xe]??void 0;throw me}else{let k=await ye.text();
|
|
throw new fe(`Server error (HTTP status ${K}): ${k}`)}}}return a(pe,"execute"),X}
|
|
a(Js,"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 Zs.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 fe("Error ge\
|
|
tting auth token.");throw e instanceof Error&&(t=new fe(`Error getting auth toke\
|
|
n: ${e.message}`)),t}}a(Wc,"getAuthToken");var eo=Ie(wt()),je=Ie(Tt());var _n=class _n extends Pt.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],me=K.substring(2);return[k,me]})),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 pe=0;pe<l-1;pe++)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,ae="c=biws,r="+u,ee=O+","+W+
|
|
","+ae,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))),ue=y.
|
|
from(P.map((K,k)=>P[k]^G[k])),de=ue.toString("base64");let Ee=await g.subtle.importKey(
|
|
"raw",A,{name:"HMAC",hash:{name:"SHA-256"}},!1,["sign"]),ce=await g.subtle.sign(
|
|
"HMAC",Ee,b.encode("Server Key")),Ce=await g.subtle.importKey("raw",ce,{name:"HM\
|
|
AC",hash:{name:"SHA-256"}},!1,["sign"]);var ye=y.from(await g.subtle.sign("HMAC",
|
|
Ce,b.encode(ee)));n.message="SASLResponse",n.serverSignature=ye.toString("base64"),
|
|
n.response=ae+",p="+de,this.connection.sendSCRAMClientFinalMessage(this.saslSession.
|
|
response)}};a(_n,"NeonClient");var vn=_n;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 An=class An extends Pt.Pool{constructor(){
|
|
super(...arguments);_(this,"Client",vn);_(this,"hasFetchUnsupportedListeners",!1)}on(t,n){
|
|
return t!=="error"&&(this.hasFetchUnsupportedListeners=!0),super.on(t,n)}query(t,n,i){
|
|
if(!Ae.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??[];Js(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(An,"NeonPool");var Xs=An;var export_ClientBase=je.ClientBase;var export_Connection=je.Connection;var export_DatabaseError=je.DatabaseError;
|
|
var export_Query=je.Query;var export_defaults=je.defaults;var export_types=je.types;
|
|
export{vn as Client,export_ClientBase as ClientBase,export_Connection as Connection,
|
|
export_DatabaseError as DatabaseError,fe as NeonDbError,Xs as Pool,export_Query as Query,
|
|
export_defaults as defaults,Js as neon,Ae as neonConfig,export_types as types};
|
|
/*! 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
|
|
*)
|
|
*/
|