https://near.com/_next/static/chunks/0_1biwujg-~7x.js?dpl=dpl_5wHu7Ry2rMHZYKhSyS3Y6LPfrcXz

2);else for(var a=e.length-1;a>=0;a--)(n=e[a])&&(o=(s<3?n(o):s>3?n(t,r,o):n(t,r))||o);return s>3&&o&&Object.defineProperty(t,r,o),o},a=e.e&&e.e.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var r in e)"default"!==r&&Object.hasOwnProperty.call(e,r)&&n(t,e,r);return s(t,e),t},c=e.e&&e.e.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(r,"__esModule",{value:!0}),r.deserializeUnchecked=r.deserialize=r.serialize=r.BinaryReader=r.BinaryWriter=r.BorshError=r.baseDecode=r.baseEncode=void 0;let u=c(e.r(93340)),l=c(e.r(55463)),d=a(e.r(479582)),h=new("function"!=typeof TextDecoder?d.TextDecoder:TextDecoder)("utf-8",{fatal:!0});r.baseEncode=function(e){return"string"==typeof e&&(e=i.Buffer.from(e,"utf8")),l.default.encode(i.Buffer.from(e))},r.baseDecode=function(e){return i.Buffer.from(l.default.decode(e))};class f extends Error{constructor(e){super(e),this.fieldPath=[],this.originalMessage=e}addToFieldPath(e){this.fieldPath.splice(0,0,e),this.message=this.originalMessage+": "+this.fieldPath.join(".")}}r.BorshError=f;class p{constructor(){this.buf=i.Buffer.alloc(1024),this.length=0}maybeResize(){this.buf.length<16+this.length&&(this.buf=i.Buffer.concat([this.buf,i.Buffer.alloc(1024)]))}writeU8(e){this.maybeResize(),this.buf.writeUInt8(e,this.length),this.length+=1}writeU16(e){this.maybeResize(),this.buf.writeUInt16LE(e,this.length),this.length+=2}writeU32(e){this.maybeResize(),this.buf.writeUInt32LE(e,this.length),this.length+=4}writeU64(e){this.maybeResize(),this.writeBuffer(i.Buffer.from(new u.default(e).toArray("le",8)))}writeU128(e){this.maybeResize(),this.writeBuffer(i.Buffer.from(new u.default(e).toArray("le",16)))}writeU256(e){this.maybeResize(),this.writeBuffer(i.Buffer.from(new u.default(e).toArray("le",32)))}writeU512(e){this.maybeResize(),this.writeBuffer(i.Buffer.from(new u.default(e).toArray("le",64)))}writeBuffer(e){this.buf=i.Buffer.concat([i.Buffer.from(this.buf.subarray(0,this.length)),e,i.Buffer.alloc(1024)]),this.length+=e.length}writeString(e){this.maybeResize();let t=i.Buffer.from(e,"utf8");this.writeU32(t.length),this.writeBuffer(t)}writeFixedArray(e){this.writeBuffer(i.Buffer.from(e))}writeArray(e,t){for(let r of(this.maybeResize(),this.writeU32(e.length),e))this.maybeResize(),t(r)}toArray(){return this.buf.subarray(0,this.length)}}function g(e,t,r){let i=r.value;r.value=function(...e){try{return i.apply(this,e)}catch(e){if(e instanceof RangeError&&["ERR_BUFFER_OUT_OF_BOUNDS","ERR_OUT_OF_RANGE"].indexOf(e.code)>=0)throw new f("Reached the end of buffer when deserializing");throw e}}}r.BinaryWriter=p;class y{constructor(e){this.buf=e,this.offset=0}readU8(){let e=this.buf.readUInt8(this.offset);return this.offset+=1,e}readU16(){let e=this.buf.readUInt16LE(this.offset);return this.offset+=2,e}readU32(){let e=this.buf.readUInt32LE(this.offset);return this.offset+=4,e}readU64(){let e=this.readBuffer(8);return new u.default(e,"le")}readU128(){let e=this.readBuffer(16);return new u.default(e,"le")}readU256(){let e=this.readBuffer(32);return new u.default(e,"le")}readU512(){let e=this.readBuffer(64);return new u.default(e,"le")}readBuffer(e){if(this.offset+e>this.buf.length)throw new f(`Expected buffer length ${e} isn't within bounds`);let t=this.buf.slice(this.offset,this.offset+e);return this.offset+=e,t}readString(){let e=this.readU32(),t=this.readBuffer(e);try{return h.decode(t)}catch(e){throw new f(`Error decoding UTF-8 string: ${e}`)}}readFixedArray(e){return new Uint8Array(this.readBuffer(e))}readArray(e){let t=this.readU32(),r=[];for(let i=0;i<t;++i)r.push(e());return r}}function m(e){return e.charAt(0).toUpperCase()+e.slice(1)}function b(e,t,r,i,n){try{if("string"==typeof i)n[`write${m(i)}`](r);else if(i instanceof Array)if("number"==typeof i[0]){if(r.length!==i[0])throw new f(`Expecting byte array of length ${i[0]}, but got ${r.length} bytes`);n.writeFixedArray(r)}else if(2===i.length&&"number"==typeof i[1]){if(r.length!==i[1])throw new f(`Expecting byte array of length ${i[1]}, but got ${r.length} bytes`);for(let t=0;t<i[1];t++)b(e,null,r[t],i[0],n)}else n.writeArray(r,r=>{b(e,t,r,i[0],n)});else if(void 0!==i.kind)switch(i.kind){case"option":null==r?n.writeU8(0):(n.writeU8(1),b(e,t,r,i.type,n));break;case"map":n.writeU32(r.size),r.forEach((r,s)=>{b(e,t,s,i.key,n),b(e,t,r,i.value,n)});break;default:throw new f(`FieldType ${i} unrecognized`)}else k(e,r,n)}catch(e){throw e instanceof f&&e.addToFieldPath(t),e}}function k(e,t,r){if("function"==typeof t.borshSerialize)return void t.borshSerialize(r);let i=e.get(t.constructor);if(!i)throw new f(`Class ${t.constructor.name} is missing in schema`);if("struct"===i.kind)i.fields.map(([i,n])=>{b(e,i,t[i],n,r)});else if("enum"===i.kind){let n=t[i.field];for(let s=0;s<i.values.length;++s){let[o,a]=i.values[s];if(o===n){r.writeU8(s),b(e,o,t[o],a,r);break}}}else throw new f(`Unexpected schema kind: ${i.kind} for ${t.constructor.name}`)}function w(e,t,r,i){try{if("string"==typeof r)return i[`read${m(r)}`]();if(r instanceof Array)if("number"==typeof r[0])return i.readFixedArray(r[0]);else{if("number"!=typeof r[1])return i.readArray(()=>w(e,t,r[0],i));let n=[];for(let t=0;t<r[1];t++)n.push(w(e,null,r[0],i));return n}if("option"===r.kind){if(i.readU8())return w(e,t,r.type,i);return}if("map"===r.kind){let n=new Map,s=i.readU32();for(let o=0;o<s;o++){let s=w(e,t,r.key,i),o=w(e,t,r.value,i);n.set(s,o)}return n}

2if(d!==f)throw Error("invZ was invalid");return{x:u,y:l}}),A=(0,l.memoized)(t=>{let r,i,n,s,o,a,c,u,l,d,h,f,{a:p,d:g}=e;if(t.is0())throw Error("bad point: ZERO");let{ex:m,ey:b,ez:k,et:w}=t,S=(r=m*m,y.create(r)),v=(i=b*b,y.create(i)),I=(n=k*k,y.create(n)),_=(s=I*I,y.create(s));if(c=I*(o=S*p,a=y.create(o)+v,y.create(a)),y.create(c)!==(d=_+(l=g*(u=S*v,y.create(u)),y.create(l)),y.create(d)))throw Error("bad point: equation left != right (1)");if(h=m*b,y.create(h)!==(f=k*w,y.create(f)))throw Error("bad point: equation left != right (2)");return!0});class E{constructor(e,t,r,i){this.ex=v("x",e),this.ey=v("y",t),this.ez=v("z",r,!0),this.et=v("t",i),Object.freeze(this)}get x(){return this.toAffine().x}get y(){return this.toAffine().y}static fromAffine(e){let t;if(e instanceof E)throw Error("extended point not allowed");let{x:r,y:i}=e||{};return v("x",r),v("y",i),new E(r,i,f,(t=r*i,y.create(t)))}static normalizeZ(e){return(0,u.normalizeZ)(E,"ez",e)}static msm(e,t){return(0,u.pippenger)(E,m,e,t)}_setWindowSize(e){this.precompute(e)}precompute(e=8,t=!0){return x.setWindowSize(this,e),t||this.multiply(p),this}assertValidity(){A(this)}equals(e){let t,r,i,n;I(e);let{ex:s,ey:o,ez:a}=this,{ex:c,ey:u,ez:l}=e,d=(t=s*l,y.create(t)),h=(r=c*a,y.create(r)),f=(i=o*l,y.create(i)),p=(n=u*a,y.create(n));return d===h&&f===p}is0(){return this.equals(E.ZERO)}negate(){let e,t;return new E((e=-this.ex,y.create(e)),this.ey,this.ez,(t=-this.et,y.create(t)))}double(){let t,r,i,n,s,o,a,c,u,l,d,{a:h}=e,{ex:f,ey:g,ez:m}=this,b=(t=f*f,y.create(t)),k=(r=g*g,y.create(r)),w=(n=p*(i=m*m,y.create(i)),y.create(n)),S=(s=h*b,y.create(s)),v=f+g,I=(o=v*v,a=y.create(o)-b-k,y.create(a)),_=S+k,A=_-w,x=S-k,B=(c=I*A,y.create(c)),P=(u=_*x,y.create(u)),T=(l=I*x,y.create(l));return new E(B,P,(d=A*_,y.create(d)),T)}add(t){let r,i,n,s,o,a,c,u,l,d;I(t);let{a:h,d:f}=e,{ex:p,ey:g,ez:m,et:b}=this,{ex:k,ey:w,ez:S,et:v}=t,_=(r=p*k,y.create(r)),A=(i=g*w,y.create(i)),x=(n=b*f*v,y.create(n)),B=(s=m*S,y.create(s)),P=(o=(p+g)*(k+w)-_-A,y.create(o)),T=B-x,R=B+x,C=(a=A-h*_,y.create(a)),L=(c=P*T,y.create(c)),O=(u=R*C,y.create(u)),z=(l

2G(i(e,t),t,this,e):this.validator=()=>[],n?this.refiner=(e,t)=>G(n(e,t),t,this,e):this.refiner=()=>[]}assert(e,t){return Z(e,this,t)}create(e,t){return X(e,this,t)}is(e){var t,r;return t=e,r=this,!Q(t,r)[0]}mask(e,t){var r=e,i=this,n=t;let s=Q(r,i,{coerce:!0,mask:!0,message:n});if(!s[0])return s[1];throw s[0]}validate(e,t={}){return Q(e,this,t)}}function Z(e,t,r){let i=Q(e,t,{message:r});if(i[0])throw i[0]}function X(e,t,r){let i=Q(e,t,{coerce:!0,message:r});if(!i[0])return i[1];throw i[0]}function Q(e,t,r={}){let i=J(e,t,r),n=function(e){let{done:t,value:r}=e.next();return t?void 0:r}(i);return n[0]?[new V(n[0],function*(){for(let e of i)e[0]&&(yield e[0])}),void 0]:[void 0,n[1]]}function ee(e,t){return new Y({type:e,schema:null,validator:t})}function et(){return ee("any",()=>!0)}function er(e){return new Y({type:"array",schema:e,*entries(t){if(e&&Array.isArray(t))for(let[r,i]of t.entries())yield[r,i,e]},coercer:e=>Array.isArray(e)?e.slice():e,validator:e=>Array.isArray(e)||`Expected an array value, but received: ${H(e)}`})}function ei(){return ee("boolean",e=>"boolean"==typeof e)}function en(e){return ee("instance",t=>t instanceof e||`Expected a \`${e.name}\` instance, but received: ${H(t)}`)}function es(e){let t=H(e),r=typeof e;return new Y({type:"literal",schema:"string"===r||"number"===r||"boolean"===r?e:null,validator:r=>r===e||`Expected the literal \`${t}\`, but received: ${H(r)}`})}function eo(e){return new Y({...e,validator:(t,r)=>null===t||e.validator(t,r),refiner:(t,r)=>null===t||e.refiner(t,r)})}function ea(){return ee("number",e=>"number"==typeof e&&!isNaN(e)||`Expected a number, but received: ${H(e)}`)}function ec(e){return new Y({...e,validator:(t,r)=>void 0===t||e.validator(t,r),refiner:(t,r)=>void 0===t||e.refiner(t,r)})}function eu(e,t){return new Y({type:"record",schema:null,*entries(r){if($(r))for(let i in r){let n=r[i];yield[i,i,e],yield[i,n,t]}},validator:e=>j(e)||`Expected an object, but received: ${H(e)}`,coercer:e=>j(e)?{...e}:e})}function el(){return ee("string",e=>"string"==typeof e||`Expected a string, but received: ${H(e)}`)}function ed(e){let t=ee("never",()=>!1);return new Y({type:"tuple",schema:null,*entries(r){if(Array.isArray(r)){let i=Math.max(e.length,r.length);for(let n=0;n<i;n++)yield[n,r[n],e[n]||t]}},validator:e=>Array.isArray(e)||`Expected an array, but received: ${H(e)}`,coercer:e=>Array.isArray(e)?e.slice():e})}function eh(e){let t=Object.keys(e);return new Y({type:"type",schema:e,*entries(r){if($(r))for(let i of t)yield[i,r[i],e[i]]},validator:e=>j(e)||`Expected an object, but received: ${H(e)}`,coercer:e=>j(e)?{...e}:e})}function ef(e){let t=e.map(e=>e.type).join(" | ");return new Y({type:"union",schema:null,coercer(t,r){for(let i of e){let[e,n]=i.validate(t,{coerce:!0,mask:r.mask});if(!e)return n}return t},validator(r,i){let n=[];for(let t of e){let[...e]=J(r,t,i),[s]=e;if(!s[0])return[];for(let[t]of e)t&&n.push(t)}return[`Expected the value to satisfy a union of \`${t}\`, but received: ${H(r)}`,...n]}})}function ep(){return ee("unknown",()=>!0)}function eg(e,t,r){return new Y({...e,coercer:(i,n)=>Q(i,t)[0]?e.coercer(i,n):e.coercer(r(i,n),n)})}e.s(["any",0,et,"array",0,er,"assert",0,Z,"boolean",0,ei,"coerce",0,eg,"create",0,X,"instance",0,en,"literal",0,es,"nullable",0,eo,"number",0,ea,"optional",0,ec,"record",0,eu,"string",0,el,"tuple",0,ed,"type",0,eh,"union",0,ef,"unknown",0,ep],649162);var ey=e.i(544033);e.i(948053);var em=e.i(757784),em=em,eb=class extends em.default{socket;constructor(e,t){super(),this.socket=new window.WebSocket(e,t.protocols),this.socket.onopen=()=>this.emit("open"),this.socket.onmessage=e=>this.emit("message",e.data),this.socket.onerror=e=>this.emit("error",e),this.socket.onclose=e=>{this.emit("close",e.code,e.reason)}}send(e,t,r){let i=r||t;try{this.socket.send(e),i()}catch(e){i(e)}}close(e,t){this.socket.close(e,t)}addEventListener(e,t,r){this.socket.addEventListener(e,t,r)}};function ek(e,t){return new eb(e,t)}var ew=class{encode(e){return JSON.stringify(e)}decode(e){return JSON.parse(e)}},eS=class extends em.default{address;rpc_id;queue;options;autoconnect;ready;reconnect;reconnect_timer_id;reconnect_interval;max_reconnects;rest_options;current_reconnects;generate_request_id;socket;webSocketFactory;dataPack;constructor(e,t="ws://localhost:8080",{autoconnect:r=!0,reconnect:i=!0,reconnect_interval:n=1e3,max_reconnects:s=5,...o}={},a,c){super(),this.webSocketFactory=e,this.queue={},this.rpc_id=0,this.address=t,this.autoconnect=r,this.ready=!1,this.reconnect=i,this.reconnect_timer_id=void 0,this.reconnect_interval=n,this.max_reconnects=s,this.rest_options=o,this.current_reconnects=0,this.generate_request_id=a||(()=>"number"==typeof this.rpc_id?++this.rpc_id:Number(this.rpc_id)+1),c?this.dataPack=c:this.dataPack=new ew,this.autoconnect&&this._connect(this.address,{autoconnect:this.autoconnect,reconnect:this.reconnect,reconnect_interval:this.reconnect_interval,max_reconnects:this.max_reconnects,...this.rest_options})}connect(){this.socket||this._connect(this.address,{autoconnect:this.autoconnect,reconnect:this.reconnect,reconnect_interval:this.reconnect_interval,max_reconnects:this.max_reconnects,...this.rest_options})}call(e,t,r,i){return i||"object"!=typeof r||(i=r,r=null),new Promise((n,s)=>{if(!this.ready)return s(Error("socket not ready"));let o=this.generate_request_id(e,t);this.socket.send(this.dataPack.encode({jsonrpc:"2.0",method:e,params:t||void 0,id:o}),i,e=>{if(e)return s(e);this.queue[o]={promise:[n,s]},r&&(this.queue[o].timeout=setTimeout(()=>{delete this.queue[o],s(Error("reply timeout"))},r))})})}async login(e){let t=await this.call("rpc.login",e);if(!t)throw Error("authentication failed");return t}async listMethods(){return await this.call("__listMethods")}notify(e,t){return new Promise((r,i)=>{if(!this.ready)return i(Error("socket not ready"));this.socket.send(this.dataPack.encode({jsonrpc:"2.0",method:e,params:t}),e=>{if(e)return i(e);r()})})}async subscribe(e){"string"==typeof e&&(e=[e]);let t=await this.call("rpc.on",e);if("string"==typeof e&&"ok"!==t[e])throw Error("Failed subscribing to an event '"+e+"' with: "+t[e]);return t}async unsubscribe(e){"string"==typeof e&&(e=[e]);let t=await this.call("rpc.off",e);if("string"==typeof e&&"ok"!==t[e])throw Error("Failed unsubscribing from an event with: "+t);return t}close(e,t){this.socket&&this.socket.close(e||1e3,t)}setAutoReconnect(e){this.reconnect=e}setReconnectInterval(e){this.reconnect_interval=e}setMaxReconnects(e){this.max_reconnects=e}getCurrentReconnects(){return this.current_reconnects}getMaxReconnects(){return this.max_reconnects}isReconnecting(){return void 0!==this.reconnect_timer_id}willReconnect(){return this.reconnect&&(0===this.max_reconnects||this.current_reconnects<this.max_reconnects)}_connect(e,t){clearTimeout(this.reconnect_timer_id),this.socket=this.webSocketFactory(e,t),this.socket.addEventListener("open",()=>{this.ready=!0,this.emit("open"),this.current_reconnects=0}),this.socket.addEventListener("message",({data:e})=>{e instanceof ArrayBuffer&&(e=o.Buffer.from(e).toString());try{e=this.dataPack.decode(e)}catch(e){return}if(e.notification&&this.listeners(e.notification).length){if(!Object.keys(e.params).length)return this.emit(e.notification);let t=[e.notification];if(e.params.constructor===Object)t.push(e.params);else for(let r=0;r<e.params.length;r++)t.push(e.params[r]);return Promise.resolve().then(()=>{this.emit.apply(this,t)})}if(!this.queue[e.id])return e.method?Promise.resolve().then(()=>{this.emit(e.method,e?.params)}):void 0;"error"in e=="result"in e&&this.queue[e.id].promise[1](Error('Server response malformed. Response must include either "result" or "error", but not both.')),this.queue[e.id].timeout&&clearTimeout(this.queue[e.id].timeout),e.error?this.queue[e.id].promise[1](e.error):this.queue[e.id].promise[0](e.result),delete this.queue[e.id]}),this.socket.addEventListener("error",e=>this.emit("error",e)),this.socket.addEventListener("close",({code:r,reason:i})=>{this.ready&&setTimeout(()=>

2this.keySegments().flat().forEach((e,r)=>{t.set(e.toBase58(),r)});let r=e=>{let r=t.get(e.toBase58());if(void 0===r)throw Error("Encountered an unknown instruction account key during compilation");return r};return e.map(e=>({programIdIndex:r(e.programId),accountKeyIndexes:e.keys.map(e=>r(e.pubkey)),data:e.data}))}}let eq=(e="publicKey")=>U.blob(32,e),eM=(e="string")=>{let t=U.struct([U.u32("length"),U.u32("lengthPadding"),U.blob(U.offset(U.u32(),-8),"chars")],e),r=t.decode.bind(t),i=t.encode.bind(t);return t.decode=(e,t)=>r(e,t).chars.toString(),t.encode=(e,t,r)=>i({chars:o.Buffer.from(e,"utf8")},t,r),t.alloc=e=>U.u32().span+U.u32().span+o.Buffer.from(e,"utf8").length,t};function eD(e){let t=0,r=0;for(;;){let i=e.shift();if(t|=(127&i)<<7*r,r+=1,(128&i)==0)break}return t}function eF(e,t){let r=t;for(;;){let t=127&r;if(0==(r>>=7)){e.push(t);break}t|=128,e.push(t)}}function eV(e,t){if(!e)throw Error(t||"Assertion failed")}class e${constructor(e,t){this.payer=void 0,this.keyMetaMap=void 0,this.payer=e,this.keyMetaMap=t}static compile(e,t){let r=new Map,i=e=>{let t=e.toBase58(),i=r.get(t);return void 0===i&&(i={isSigner:!1,isWritable:!1,isInvoked:!1},r.set(t,i)),i},n=i(t);for(let t of(n.isSigner=!0,n.isWritable=!0,e))for(let e of(i(t.programId).isInvoked=!0,t.keys)){let t=i(e.pubkey);t.isSigner||=e.isSigner,t.isWritable||=e.isWritable}return new e$(t,r)}getMessageComponents(){let e=[...this.keyMetaMap.entries()];eV(e.length<=256,"Max static account keys length exceeded");let t=e.filter(([,e])=>e.isSigner&&e.isWritable),r=e.filter(([,e])=>e.isSigner&&!e.isWritable),i=e.filter(([,e])=>!e.isSigner&&e.isWritable),n=e.filter(([,e])=>!e.isSigner&&!e.isWritable),s={numRequiredSignatures:t.length+r.length,numReadonlySignedAccounts:r.length,numReadonlyUnsignedAccounts:n.length};{eV(t.length>0,"Expected at least one writable signer key");let[e]=t[0];eV(e===this.payer.toBase58(),"Expected first writable signer key to be the fee payer")}return[s,[...t.map(([e])=>new eO(e)),...r.map(([e])=>new eO(e)),...i.map(([e])=>new eO(e)),...n.map(([e])=>new eO(e))]]}extractTableLookup(e){let[t,r]=this.drainKeysFoundInLookupTable(e.state.addresses,e=>!e.isSigner&&!e.isInvoked&&e.isWritable),[i,n]=this.drainKeysFoundInLookupTable(e.state.addresses,e=>!e.isSigner&&!e.isInvoked&&!e.isWritable);if(0!==t.length||0!==i.length)return[{accountKey:e.key,writableIndexes:t,readonlyIndexes:i},{writable:r,readonly:n}]}drainKeysFoundInLookupTable(e,t){let r=[],i=[];for(let[n,s]of this.keyMetaMap.entries())if(t(s)){let t=new eO(n),s=e.findIndex(e=>e.equals(t));s>=0&&(eV(s<256,"Max lookup table index exceeded"),r.push(s),i.push(t),this.keyMetaMap.delete(n))}return[r,i]}}let ej="Reached end of buffer unexpectedly";function eH(e){if(0===e.length)throw Error(ej);return e.shift()}function eG(e,...t){let[r]=t;if(2===t.length?r+(t[1]??0)>e.length:r>=e.length)throw Error(ej);return e.splice(...t)}class eJ{constructor(e){this.header=void 0,this.accountKeys=void 0,this.recentBlockhash=void 0,this.instructions=void 0,this.indexToProgramIds=new Map,this.header=e.header,this.accountKeys=e.accountKeys.map(e=>new eO(e)),this.recentBlockhash=e.recentBlockhash,this.instructions=e.instructions,this.instructions.forEach(e=>this.indexToProgramIds.set(e.programIdIndex,this.accountKeys[e.programIdIndex]))}get version(){return"legacy"}get staticAccountKeys(){return this.accountKeys}get compiledInstructions(){return this.instructions.map(e=>({programIdIndex:e.programIdIndex,accountKeyIndexes:e.accounts,data:O.default.decode(e.data)}))}get addressTableLookups(){return[]}getAccountKeys(){return new eK(this.staticAccountKeys)}static compile(e){let[t,r]=e$.compile(e.instructions,e.payerKey).getMessageComponents(),i=new eK(r).compileInstructions(e.instructions).map(e=>({programIdIndex:e.programIdIndex,accounts:e.accountKeyIndexes,data:O.default.encode(e.data)}));return new eJ({header:t,accountKeys:r,recentBlockhash:e.recentBlockhash,instructions:i})}isAccountSigner(e){return e<this.header.numRequiredSignatures}isAccountWritable(e){let t=this.header.numRequiredSignatures;if(!(e>=this.header.numRequiredSignatures))return e<t-this.header.numReadonlySignedAccounts;{let r=this.accountKeys.length-t-this.header.numReadonlyUnsignedAccounts;return e-t<r}}isProgramId(e){return this.indexToProgramIds.has(e)}programIds(){return[...this.indexToProgramIds.values()]}nonProgramIds(){return this.accountKeys.filter((e,t)=>!this.isProgramId(t))}serialize(){let e=this.accountKeys.length,t=[];eF(t,e);let r=this.instructions.map(e=>{let{accounts:t,programIdIndex:r}=e,i=Array.from(O.default.decode(e.data)),n=[];eF(n,t.length);let s=[];return eF(s,i.length),{programIdIndex:r,keyIndicesCount:o.Buffer.from(n),keyIndices:t,dataLength:o.Buffer.from(s),data:i}}),i=[];eF(i,r.length);let n=o.Buffer.alloc(1232);o.Buffer.from(i).copy(n);let s=i.length;r.forEach(e=>{let t=U.struct([U.u8("programIdIndex"),U.blob(e.keyIndicesCount.length,"keyIndicesCount"),U.seq(U.u8("keyIndex"),e.keyIndices.length,"keyIndices"),U.blob(e.dataLength.length,"dataLength"),U.seq(U.u8("userdatum"),e.data.length,"data")]).encode(e,n,s);s+=t}),n=n.slice(0,s);let a=U.struct([U.blob(1,"numRequiredSignatures"),U.blob(1,"numReadonlySignedAccounts"),U.blob(1,"numReadonlyUnsignedAccounts"),U.blob(t.length,"keyCount"),U.seq(eq("key"),e,"keys"),eq("recentBlockhash")]),c={numRequiredSignatures:o.Buffer.from([this.header.numRequiredSignatures]),numReadonlySignedAccounts:o.Buffer.from([this.header.numReadonlySignedAccounts]),numReadonlyUnsignedAccounts:o.Buffer.from([this.header.numReadonlyUnsignedAccounts]),keyCount:o.Buffer.from(t),keys:this.accountKeys.map(e=>eT(e.toBytes())),recentBlockhash:O.default.decode(this.recentBlockhash)},u=o.Buffer.alloc(2048),l=a.encode(c,u);return n.copy(u,l),u.slice(0,l+n.length)}static from(e){let t=[...e],r=eH(t);if(r!==(127&r))throw Error("Versioned messages must be deserialized with VersionedMessage.deserialize()");let i=eH(t),n=eH(t),s=eD(t),a=[];for(let e=0;e<s;e++){let e=eG(t,0,32);a.push(new eO(o.Buffer.from(e)))}let c=eG(t,0,32),u=eD(t),l=[];for(let e=0;e<u;e++){let e=eH(t),r=eD(t),i=eG(t,0,r),n=eD(t),s=eG(t,0,n),a=O.default.encode(o.Buffer.from(s));l.push({programIdIndex:e,accounts:i,data:a})}return new eJ({header:{numRequiredSignatures:r,numReadonlySignedAccounts:i,numReadonlyUnsignedAccounts:n},recentBlockhash:O.default.encode(o.Buffer.from(c)),accountKeys:a,instructions:l})}}class eY{constructor(e){this.header=void 0,this.staticAccountKeys=void 0,this.recentBlockhash=void 0,this.compiledInstructions=void 0,this.addressTableLookups=void 0,this.header=e.header,this.staticAccountKeys=e.staticAccountKeys,this.recentBlockhash=e.recentBlockhash,this.compiledInstructions=e.compiledInstructions,this.addressTableLookups=e.addressTableLookups}get version(){return 0}get numAccountKeysFromLookups(){let e=0;for(let t of this.addressTableLookups)e+=t.readonlyIndexes.length+t.writableIndexes.length;return e}getAccountKeys(e){let t;if(e&&"accountKeysFromLookups"in e&&e.accountKeysFromLookups){if(this.numAccountKeysFromLookups!=e.accountKeysFromLookups.writable.length+e.accountKeysFromLookups.readonly.length)throw Error("Failed to get account keys because of a mismatch in the number of account keys from lookups");t=e.accountKeysFromLookups}else if(e&&"addressLookupTableAccounts"in e&&e.addressLookupTableAccounts)t=this.resolveAddressTableLookups(e.addressLookupTableAccounts);else if(this.addressTableLookups.length>0)throw Error("Failed to get account keys because address table lookups were not resolved");return new eK(this.staticAccountKeys,t)}isAccountSigner(e){return e<this.header.numRequiredSignatures}isAccountWritable(e){let t=this.header.numRequiredSignatures,r=this.staticAccountKeys.length;if(e>=r)return e-r<this.addressTableLookups.reduce((e,t)=>e+t.writableIndexes.length,0);if(!(e>=this.header.numRequiredSignatures))return e<t-this.header.numReadonlySignedAccounts;{let i=r-t-this.header.numReadonlyUnsignedAccounts;return e-t<i}}resolveAddressTableLookups(e){let t={writable:[],readonly:[]};for(let r of this.addressTableLookups){let i=e.find(e=>e.key.equals(r.accountKey));if(!i)throw Error(`Failed to find address lookup table account for table key ${r.accountKey.toBase58()}`);for(let e of r.writableIndexes)if(e<i.state.addresses.length)t.writable.push(i.state.addresses[e]);else throw Error(`Failed to find address for index ${e} in address lookup table ${r.accountKey.toBase58()}`);for(let e of r.readonlyIndexes)if(e<i.state.addresses.length)t.readonly.push(i.state.addresses[e]);else throw Error(`Failed to find address for index ${e} in address lookup table ${r.accountKey.toBase58()}`)}return t}static compile(e){let t=e$.compile(e.instructions,e.payerKey),r=[],i={writable:[],readonly:[]};for(let n of e.addressLookupTableAccounts||[]){let e=t.extractTableLookup(n);if(void 0!==e){let[t,{writable:n,readonly:s}]=e;r.push(t),i.writable.push(...n),i.readonly.push(...s)}}let[n,s]=t.getMessageComponents(),o=new eK(s,i).compileInstructions(e.instructions);return new eY({header:n,staticAccountKeys:s,recentBlockhash:e.recentBlockhash,compiledInstructions:o,addressTableLookups:r})}serialize(){let e=[];eF(e,this.staticAccountKeys.length);let t=this.serializeInstructions(),r=[];eF(r,this.compiledInstructions.length);let i=this.serializeAddressTableLookups(),n=[];eF(n,this.addressTableLookups.length);let s=U.struct([U.u8("prefix"),U.struct([U.u8("numRequiredSignatures"),U.u8("numReadonlySignedAccounts"),U.u8("numReadonlyUnsignedAccounts")],"header"),U.blob(e.length,"staticAccountKeysLength"),U.seq(eq(),this.staticAccountKeys.length,"staticAccountKeys"),eq("recentBlockhash"),U.blob(r.length,"instructionsLength"),U.blob(t.length,"serializedInstructions"),U.blob(n.length,"addressTableLookupsLength"),U.blob(i.length,"serializedAddressTableLookups")]),o=new Uint8Array(1232),a=s.encode({prefix:128,header:this.header,staticAccountKeysLength:new Uint8Array(e),staticAccountKeys:this.staticAccountKeys.map(e=>e.toBytes()),recentBlockhash:O.default.decode(this.recentBlockhash),instructionsLength:new Uint8Array(r),serializedInstructions:t,addressTableLookupsLength:new Uint8Array(n),serializedAddressTableLookups:i},o);return o.slice(0,a)}serializeInstructions(){let e=0,t=new Uint8Array(1232);for(let r of this.compiledInstructions){let i=[];eF(i,r.accountKeyIndexes.length);let n=[];eF(n,r.data.length);let s=U.struct([U.u8("programIdIndex"),U.blob(i.length,"encodedAccountKeyIndexesLength"),U.seq(U.u8(),r.accountKeyIndexes.length,"accountKeyIndexes"),U.blob(n.length,"encodedDataLength"),U.blob(r.data.length,"data")]);e+=s.encode({programIdIndex:r.programIdIndex,encodedAccountKeyIndexesLength:new Uint8Array(i),accountKeyIndexes:r.accountKeyIndexes,encodedDataLength:new Uint8Array(n),data:r.data},t,e)}return t.slice(0,e)}serializeAddressTableLookups(){let e=0,t=new Uint8Array(1232);for(let r of this.addressTableLookups){let i=[];eF(i,r.writableIndexes.length);let n=[];eF(n,r.readonlyIndexes.length);let s=U.struct([eq("accountKey"),U.blob(i.length,"encodedWritableIndexesLength"),U.seq(U.u8(),r.writableIndexes.length,"writableIndexes"),U.blob(n.length,"encodedReadonlyIndexesLength"),U.seq(U.u8(),r.readonlyIndexes.length,"readonlyIndexes")]);e+=s.encode({accountKey:r.accountKey.toBytes(),encodedWritableIndexesLength:new Uint8Array(i),writableIndexes:r.writableIndexes,encodedReadonlyIndexesLength:new Uint8Array(n),readonlyIndexes:r.readonlyIndexes},t,e)}return t.slice(0,e)}static deserialize(e){let t=[...e],r=eH(t),i=127&r;eV(r!==i,"Expected versioned message but received legacy message"),eV(0===i,`Expected versioned message with version 0 but found version ${i}`);let n={numRequiredSignatures:eH(t),numReadonlySignedAccounts:eH(t),numReadonlyUnsignedAccounts:eH(t)},s=[],o=eD(t);for(let e=0;e<o;e++)s.push(new eO(eG(t,0,32)));let a=O.default.encode(eG(t,0,32)),c=eD(t),u=[];for(let e=0;e<c;e++){let e=eH(t),r=eD(t),i=eG(t,0,r),n=eD(t),s=new Uint8Array(eG(t,0,n));u.push({programIdIndex:e,accountKeyIndexes:i,data:s})}let l=eD(t),d=[];for(let e=0;e<l;e++){let e=new eO(eG(t,0,32)),r=eD(t),i=eG(t,0,r),n=eD(t),s=eG(t,0,n);d.push({accountKey:e,writableIndexes:i,readonlyIndexes:s})}return new eY({header:n,staticAccountKeys:s,recentBlockhash:a,compiledInstructions:u,addressTableLookups:d})}}let eZ={deserializeMessageVersion(e){let t=e[0],r=127&t;return r===t?"legacy":r},deserialize:e=>{let t=eZ.deserializeMessageVersion(e);if("legacy"===t)return eJ.from(e);if(0===t)return eY.deserialize(e);throw Error(`Transaction message version ${t} deserialization is not supported`)}},eX=((r={})[r.BLOCKHEIGHT_EXCEEDED=0]="BLOCKHEIGHT_EXCEEDED",r[r.PROCESSED=1]="PROCESSED",r[r.TIMED_OUT=2]="TIMED_OUT",r[r.NONCE_INVALID=3]="NONCE_INVALID",r),eQ=o.Buffer.alloc(64).fill(0);class e0{constructor(e){this.keys=void 0,this.programId=void 0,this.data=o.Buffer.alloc(0),this.programId=e.programId,this.keys=e.keys,e.data&&(this.data=e.data)}toJSON(){return{keys:this.keys.map(({pubkey:e,isSigner:t,isWritable:r})=>({pubkey:e.toJSON(),isSigner:t,isWritable:r})),programId:this.programId.toJSON(),data:[...this.data]}}}class e1{get signature(){return this.signatures.length>0?this.signatures[0].signature:null}constructor(e){if(this.signatures=[],this.feePayer=void 0,this.instructions=[],this.recentBlockhash=void 0,this.lastValidBlockHeight=void 0,this.nonceInfo=void 0,this.minNonceContextSlot=void 0,this._message=void 0,this._json=void 0,!e)return;if(e.feePayer&&(this.feePayer=e.feePayer),e.signatures&&(this.signatures=e.signatures),Object.prototype.hasOwnProperty.call(e,"nonceInfo")){const{minContextSlot:t,nonceInfo:r}=e;this.minNonceContextSlot=t,this.nonceInfo=r}else if(Object.prototype.hasOwnProperty.call(e,"lastValidBlockHeight")){const{blockhash:t,lastValidBlockHeight:r}=e;this.recentBlockhash=t,this.lastValidBlockHeight=r}else{const{recentBlockhash:t,nonceInfo:r}=e;r&&(this.nonceInfo=r),this.recentBlockhash=t}}toJSON(){return{recentBlockhash:this.recentBlockhash||null,feePayer:this.feePayer?this.feePayer.toJSON():null,nonceInfo:this.nonceInfo?{nonce:this.nonceInfo.nonce,nonceInstruction:this.nonceInfo.nonceInstruction.toJSON()}:null,instructions:this.instructions.map(e=>e.toJSON()),signers:this.signatures.map(({publicKey:e})=>e.toJSON())}}add(...e){if(0===e.length)throw Error("No instructions");return e.forEach(e=>{"instructions"in e?this.instructions=this.instructions.concat(e.instructions):"data"in e&&"programId"in e&&"keys"in e?this.instructions.push(e):this.instructions.push(new e0(e))}),this}compileMessage(){let e,t,r;if(this._message&&JSON.stringify(this.toJSON())===JSON.stringify(this._json))return this._message;if(this.nonceInfo?(e=this.nonceInfo.nonce,t=this.instructions[0]!=this.nonceInfo.nonceInstruction?[this.nonceInfo.nonceInstruction,...this.instructions]:this.instructions):(e=this.recentBlockhash,t=this.instructions),!e)throw Error("Transaction recentBlockhash required");if(t.length<1&&console.warn("No instructions provided"),this.feePayer)r=this.feePayer;else if(this.signatures.length>0&&this.signatures[0].publicKey)r=this.signatures[0].publicKey;else throw Error("Transaction fee payer required");for(let e=0;e<t.length;e++)if(void 0===t[e].programId)throw Error(`Transaction instruction index ${e} has undefined program id`);let i=[],n=[];t.forEach(e=>{e.keys.forEach(e=>{n.push({...e})});let t=e.programId.toString();i.includes(t)||i.push(t)}),i.forEach(e=>{n.push({pubkey:new eO(e),isSigner:!1,isWritable:!1})});let s=[];n.forEach(e=>{let t=e.pubkey.toString(),r=s.findIndex(e=>e.pubkey.toString()===t);r>-1?(s[r].isWritable=s[r].isWritable||e.isWritable,s[r].isSigner=s[r].isSigner||e.isSigner):s.push(e)}),s.sort(function(e,t){return e.isSigner!==t.isSigner?e.isSigner?-1:1:e.isWritable!==t.isWritable?e.isWritable?-1:1:e.pubkey.toBase58().localeCompare(t.pubkey.toBase58(),"en",{localeMatcher:"best fit",usage:"sort",sensitivity:"variant",ignorePunctuation:!1,numeric:!1,caseFirst:"lower"})});let o=s.findIndex(e=>e.pubkey.equals(r));if(o>-1){let[e]=s.splice(o,1);e.isSigner=!0,e.isWritable=!0,s.unshift(e)}else s.unshift({pubkey:r,isSigner:!0,isWritable:!0});for(let e of this.signatures){let t=s.findIndex(t=>t.pubkey.equals(e.publicKey));if(t>-1)s[t].isSigner||(s[t].isSigner=!0,console.warn("Transaction references a signature that is unnecessary, only the fee payer and instruction signer accounts should sign a transaction. This behavior is deprecated and will throw an error in the next major version release."));else throw Error(`unknown signer: ${e.publicKey.toString()}`)}let a=0,c=0,u=0,l=[],d=[];s.forEach(({pubkey:e,isSigner:t,isWritable:r})=>{t?(l.push(e.toString()),a+=1,r||(c+=1)):(d.push(e.toString()),r||(u+=1))});let h=l.concat(d),f=t.map(e=>{let{data:t,programId:r}=e;return{programIdIndex:h.indexOf(r.toString()),accounts:e.keys.map(e=>h.indexOf(e.pubkey.toString())),data:O.default.encode(t)}});return f.forEach(e=>{eV(e.programIdIndex>=0),e.accounts.forEach(e=>eV(e>=0))}),new eJ({header:{numRequiredSignatures:a,numReadonlySignedAccounts:c,numReadonlyUnsignedAccounts:u},accountKeys:h,recentBlockhash:e,instructions:f})}_compile(){let e=this.compileMessage(),t=e.accountKeys.slice(0,e.header.numRequiredSignatures);return this.signatures.length===t.length&&this.signatures.every((e,r)=>t[r].equals(e.publicKey))?e:(this.signatures=t.map(e=>({signature:null,publicKey:e})),e)}serializeMessage(){return this._compile().serialize()}async getEstimatedFee(e){return(await e.getFeeForMessage(this.compileMessage())).value}setSigners(...e){if(0===e.length)throw Error("No signers");let t=new Set;this.signatures=e.filter(e=>{let r=e.toString();return!t.has(r)&&(t.add(r),!0)}).map(e=>({signature:null,publicKey:e}))}sign(...e){if(0===e.length)throw Error("No signers");let t=new Set,r=[];for(let i of e){let e=i.publicKey.toString();t.has(e)||(t.add(e),r.push(i))}this.signatures=r.map(e=>({signature:null,publicKey:e.publicKey}));let i=this._compile();this._partialSign(i,...r)}partialSign(...e){if(0===e.length)throw Error("No signers");let t=new Set,r=[];for(let i of e){let e=i.publicKey.toString();t.has(e)||(t.add(e),r.push(i))}let i=this._compile();this._partialSign(i,...r)}_partialSign(e,...t){let r=e.serialize();

4w eO("SysvarRewards111111111111111111111111111111"),te=new eO("SysvarS1otHashes111111111111111111111111111"),tt=new eO("SysvarS1otHistory11111111111111111111111111"),tr=new eO("SysvarStakeHistory1111111111111111111111111");class ti extends Error{constructor({action:e,signature:t,transactionMessage:r,logs:i}){let n;const s=i?`Logs: 
5${JSON.stringify(i.slice(-10),null,2)}. `:"",o="\nCatch the `SendTransactionError` and call `getLogs()` on it for full details.";switch(e){case"send":n=`Transaction ${t} resulted in an error. 
6${r}. `+s+o;break;case"simulate":n=`Simulation failed. 
7Message: ${r}. 
8`+s+o;break;default:n=`Unknown action '${(e=>e)(e)}'`}super(n),this.signature=void 0,this.transactionMessage=void 0,this.transactionLogs=void 0,this.signature=t,this.transactionMessage=r,this.transactionLogs=i||void 0}get transactionError(){return{message:this.transactionMessage,logs:Array.isArray(this.transactionLogs)?this.transactionLogs:void 0}}get logs(){let e=this.transactionLogs;if(null==e||"object"!=typeof e||!("then"in e))return e}async getLogs(e){return Array.isArray(this.transactionLogs)||(this.transactionLogs=new Promise((t,r)=>{e.getTransaction(this.signature).then(e=>{if(e&&e.meta&&e.meta.logMessages){let r=e.meta.logMessages;this.transactionLogs=r,t(r)}else r(Error("Log messages not found"))}).catch(r)})),await this.transactionLogs}}class tn extends Error{constructor({code:e,message:t,data:r},i){super(null!=i?`${i}: ${t}`:t),this.code=void 0,this.data=void 0,this.code=e,this.data=r,this.name="SolanaJSONRPCError"}}async function ts(e,t,r,i){let n,s=i&&{skipPreflight:i.skipPreflight,preflightCommitment:i.preflightCommitment||i.commitment,maxRetries:i.maxRetries,minContextSlot:i.minContextSlot},o=await e.sendTransaction(t,r,s);if(null!=t.recentBlockhash&&null!=t.lastValidBlockHeight)n=(await e.confirmTransaction({abortSignal:i?.abortSignal,signature:o,blockhash:t.recentBlockhash,lastValidBlockHeight:t.lastValidBlockHeight},i&&i.commitment)).value;else if(null!=t.minNonceContextSlot&&null!=t.nonceInfo){let{nonceInstruction:r}=t.nonceInfo,s=r.keys[0].pubkey;n=(await e.confirmTransaction({abortSignal:i?.abortSignal,minContextSlot:t.minNonceContextSlot,nonceAccountPubkey:s,nonceValue:t.nonceInfo.nonce,signature:o},i&&i.commitment)).value}else i?.abortSignal!=null&&console.warn("sendAndConfirmTransaction(): A transaction with a deprecated confirmation strategy was supplied along with an `abortSignal`. Only transactions having `lastValidBlockHeight` or a combination of `nonceInfo` and `minNonceContextSlot` are abortable."),n=(await e.confirmTransaction(o,i&&i.commitment)).value;if(n.err){if(null!=o)throw new ti({action:"send",signature:o,transactionMessage:`Status: (${JSON.stringify(n)})`});throw Error(`Transaction ${o} failed (${JSON.stringify(n)})`)}return o}function to(e){return new Promise(t=>setTimeout(t,e))}function ta(e,t){let r=e.layout.span>=0?e.layout.span:function e(t,r){let i=t=>{if(t.span>=0)return t.span;if("function"==typeof t.alloc)return t.alloc(r[t.property]);if("count"in t&&"elementLayout"in t){let e=r[t.property];if(Array.isArray(e))return e.length*i(t.elementLayout)}else if("fields"in t)return e({layout:t},r[t.property]);return 0},n=0;return t.layout.fields.forEach(e=>{n+=i(e)}),n}(e,t),i=o.Buffer.alloc(r),n=Object.assign({instruction:e.index},t);return e.layout.encode(n,i),i}function tc(e,t){let r;try{r=e.layout.decode(t)}catch(e){throw Error("invalid instruction; "+e)}if(r.instruction!==e.index)throw Error(`invalid instruction; instruction index mismatch ${r.instruction} != ${e.index}`);return r}let tu=U.nu64("lamportsPerSignature"),tl=U.struct([U.u32("version"),U.u32("state"),eq("authorizedPubkey"),eq("nonce"),U.struct([tu],"feeCalculator")]),td=tl.span;class th{constructor(e){this.authorizedPubkey=void 0,this.nonce=void 0,this.feeCalculator=void 0,this.authorizedPubkey=e.authorizedPubkey,this.nonce=e.nonce,this.feeCalculator=e.feeCalculator}static fromAccountData(e){let t=tl.decode(eT(e),0);return new th({authorizedPubkey:new eO(t.authorizedPubkey),nonce:new eO(t.nonce).toString(),feeCalculator:t.feeCalculator})}}function tf(e){let t=(0,U.blob)(8,e),r=t.decode.bind(t),i=t.encode.bind(t),n=((e={})=>(function(e,t){if(q(e)!==q(t))throw new K(8078004);if(q(e)&&q(t)&&e.fixedSize!==t.fixedSize)throw new K(8078005,{decoderFixedSize:t.fixedSize,encoderFixedSize:e.fixedSize});if(!q(e)&&!q(t)&&e.maxSize!==t.maxSize)throw new K(8078006,{decoderMaxSize:t.maxSize,encoderMaxSize:e.maxSize});return{...t,...e,decode:t.decode,encode:e.encode,read:t.read,write:e.write}})(F(e),((e={})=>{var t,r;return Object.freeze({...r={fixedSize:(t={config:e,get:(e,t)=>e.getBigUint64(0,t),name:"u64",size:8}).size,read(e,r=0){var i,n,s;let o,a;!function(e,t,r=0){if(t.length-r<=0)throw new K(8078e3,{codecDescription:e})}(t.name,e,r),function(e,t,r,i=0){let n=r.length-i;if(n<t)throw new K(8078001,{bytesLength:n,codecDescription:e,expected:t})}(t.name,t.size,e,r);let c=new DataView((i=e,n=r,s=t.size,o=i.byteOffset+(n??0),a=s??i.byteLength,i.buffer.slice(o,o+a)));return[t.get(c,D(t.config)),r+t.size]}},decode:(e,t=0)=>r.read(e,t)[0]})})(e)))();return t.decode=(e,t)=>{let i=r(e,t);return n.decode(i)},t.encode=(e,t,r)=>i(n.encode(e),t,r),t}let tp=Object.freeze({Create:{index:0,layout:U.struct([U.u32("instruction"),U.ns64("lamports"),U.ns64("space"),eq("programId")])},Assign:{index:1,layout:U.struct([U.u32("instruction"),eq("programId")])},Transfer:{index:2,layout:U.struct([U.u32("instruction"),tf("lamports")])},CreateWithSeed:{index:3,layout:U.struct([U.u32("instruction"),eq("base"),eM("seed"),U.ns64("lamports"),U.ns64("space"),eq("programId")])},AdvanceNonceAccount:{index:4,layout:U.struct([U.u32("instruction")])},WithdrawNonceAccount:{index:5,layout:U.struct([U.u32("instruction"),U.ns64("lamports")])},InitializeNonceAccount:{index:6,layout:U.struct([U.u32("instruction"),eq("authorized")])},AuthorizeNonceAccount:{index:7,layout:U.struct([U.u32("instruction"),eq("authorized")])},Allocate:{index:8,layout:U.struct([U.u32("instruction"),U.ns64("space")])},AllocateWithSeed:{index:9,layout:U.struct([U.u32("instruction"),eq("base"),eM("seed"),U.ns64("space"),eq("programId")])},AssignWithSeed:{index:10,layout:U.struct([U.u32("instruction"),eq("base"),eM("seed"),eq("programId")])},TransferWithSeed:{index:11,layout:U.struct([U.u32("instruction"),tf("lamports"),eM("seed"),eq("programId")])},UpgradeNonceAccount:{index:12,layout:U.struct([U.u32("instruction")])}});class tg{static createAccount(e){let t=ta(tp.Create,{lamports:e.lamports,space:e.space,programId:eT(e.programId.toBuffer())});return new e0({keys:[{pubkey:e.fromPubkey,isSigner:!0,isWritable:!0},{pubkey:e.newAccountPubkey,isSigner:!0,isWritable:!0}],programId:this.programId,data:t})}static transfer(e){let t,r;return"basePubkey"in e?(t=ta(tp.TransferWithSeed,{lamports:BigInt(e.lamports),seed:e.seed,programId:eT(e.programId.toBuffer())}),r=[{pubkey:e.fromPubkey,isSigner:!1,isWritable:!0},{pubkey:e.basePubkey,isSigner:!0,isWritable:!1},{pubkey:e.toPubkey,isSigner:!1,isWritable:!0}]):(t=ta(tp.Transfer,{lamports:BigInt(e.lamports)}),r=[{pubkey:e.fromPubkey,isSigner:!0,isWritable:!0},{pubkey:e.toPubkey,isSigner:!1,isWritable:!0}]),new e0({keys:r,programId:this.programId,data:t})}static assign(e){let t,r;return"basePubkey"in e?(t=ta(tp.AssignWithSeed,{base:eT(e.basePubkey.toBuffer()),seed:e.seed,programId:eT(e.programId.toBuffer())}),r=[{pubkey:e.accountPubkey,isSigner:!1,isWritable:!0},{pubkey:e.basePubkey,isSigner:!0,isWritable:!1}]):(t=ta(tp.Assign,{programId:eT(e.programId.toBuffer())}),r=[{pubkey:e.accountPubkey,isSigner:!0,isWritable:!0}]),new e0({keys:r,programId:this.programId,data:t})}static createAccountWithSeed(e){let t=ta(tp.CreateWithSeed,{base:eT(e.basePubkey.toBuffer()),seed:e.seed,lamports:e.lamports,space:e.space,programId:eT(e.programId.toBuffer())}),r=[{pubkey:e.fromPubkey,isSigner:!0,isWritable:!0},{pubkey:e.newAccountPubkey,isSigner:!1,isWritable:!0}];return e.basePubkey.equals(e.fromPubkey)||r.push({pubkey:e.basePubkey,isSigner:!0,isWritable:!1}),new e0({keys:r,programId:this.programId,data:t})}static createNonceAccount(e){let t=new e1;"basePubkey"in e&&"seed"in e?t.add(tg.createAccountWithSeed({fromPubkey:e.fromPubkey,newAccountPubkey:e.noncePubkey,basePubkey:e.basePubkey,seed:e.seed,lamports:e.lamports,space:td,programId:this.programId})):t.add(tg.createAccount({fromPubkey:e.fromPubkey,newAccountPubkey:e.noncePubkey,lamports:e.lamports,space:td,programId:this.programId}));let r={noncePubkey:e.noncePubkey,authorizedPubkey:e.authorizedPubkey};return t.add(this.nonceInitialize(r)),t}static nonceInitialize(e){let t=ta(tp.InitializeNonceAccount,{authorized:eT(e.authorizedPubkey.toBuffer())});return new e0({keys:[{pubkey:e.noncePubkey,isSigner:!1,isWritable:!0},{pubkey:e4,isSigner:!1,isWritable:!1},{pubkey:e7,isSigner:!1,isWritable:!1}],programId:this.programId,data:t})}static nonceAdvance(e){let t=ta(tp.AdvanceNonceAccount);return new e0({keys:[{pubkey:e.noncePubkey,isSigner:!1,isWritable:!0},{pubkey:e4,isSigner:!1,isWritable:!1},{pubkey:e.authorizedPubkey,isSigner:!0,isWritable:!1}],programId:this.programId,data:t})}static nonceWithdraw(e){let t=ta(tp.WithdrawNonceAccount,{lamports:e.lamports});return new e0({keys:[{pubkey:e.noncePubkey,isSigner:!1,isWritable:!0},{pubkey:e.toPubkey,isSigner:!1,isWritable:!0},{pubkey:e4,isSigner:!1,isWritable:!1},{pubkey:e7,isSigner:!1,isWritable:!1},{pubkey:e.authorizedPubkey,isSigner:!0,isWritable:!1}],programId:this.programId,data:t})}static nonceAuthorize(e){let t=ta(tp.AuthorizeNonceAccount,{authorized:eT(e.newAuthorizedPubkey.toBuffer())});return new e0({keys:[{pubkey:e.noncePubkey,isSigner:!1,isWritable:!0},{pubkey:e.authorizedPubkey,isSigner:!0,isWritable:!1}],programId:this.programId,data:t})}static allocate(e){let t,r;return"basePubkey"in e?(t=ta(tp.AllocateWithSeed,{base:eT(e.basePubkey.toBuffer()),seed:e.seed,space:e.space,programId:eT(e.programId.toBuffer())}),r=[{pubkey:e.accountPubkey,isSigner:!1,isWritable:!0},{pubkey:e.basePubkey,isSigner:!0,isWritable:!1}]):(t=ta(tp.Allocate,{space:e.space}),r=[{pubkey:e.accountPubkey,isSigner:!0,isWritable:!0}]),new e0({keys:r,programId:this.programId,data:t})}}tg.programId=new eO("11111111111111111111111111111111");class ty{static getMinNumSignatures(e){return 2*(Math.ceil(e/ty.chunkSize)+1+1)}static async load(e,t,r,i,n){{let s=await e.getMinimumBalanceForRentExemption(n.length),o=await e.getAccountInfo(r.publicKey,"confirmed"),a=null;if(null!==o){if(o.executable)return console.error("Program load failed, account is already executable"),!1;o.data.length!==n.length&&(a=a||new e1).add(tg.allocate({accountPubkey:r.publicKey,space:n.length})),o.owner.equals(i)||(a=a||new e1).add(tg.assign({accountPubkey:r.publicKey,programId:i})),o.lamports<s&&(a=a||new e1).add(tg.transfer({fromPubkey:t.publicKey,toPubkey:r.publicKey,lamports:s-o.lamports}))}else a=new e1().add(tg.createAccount({fromPubkey:t.publicKey,newAccountPubkey:r.publicKey,lamports:s>0?s:1,space:n.length,programId:i}));null!==a&&await ts(e,a,[t,r],{commitment:"confirmed"})}let s=U.struct([U.u32("instruction"),U.u32("offset"),U.u32("bytesLength"),U.u32("bytesLengthPadding"),U.seq(U.u8("byte"),U.offset(U.u32(),-8),"bytes")]),a=ty.chunkSize,c=0,u=n,l=[];for(;u.length>0;){let n=u.slice(0,a),d=o.Buffer.alloc(a+16);s.encode({instruction:0,offset:c,bytes:n,bytesLength:0,bytesLengthPadding:0},d);let h=new e1().add({keys:[{pubkey:r.publicKey,isSigner:!0,isWritable:!0}],programId:i,data:d});l.push(ts(e,h,[t,r],{commitment:"confirmed"})),e._rpcEndpoint.includes("solana.com")&&await to(250),c+=a,u=u.slice(a)}await Promise.all(l);{let n=U.struct([U.u32("instruction")]),s=o.Buffer.alloc(n.span);n.encode({instruction:1},s);let a=new e1().add({keys:[{pubkey:r.publicKey,isSigner:!0,isWritable:!0},{pubkey:e7,isSigner:!1,isWritable:!1}],programId:i,data:s}),c="processed",u=await e.sendTransaction(a,[t,r],{preflightCommitment:c}),{context:l,value:d}=await e.confirmTransaction({signature:u,lastValidBlockHeight:a.lastValidBlockHeight,blockhash:a.recentBlockhash},c);if(d.err)throw Error(`Transaction ${u} failed (${JSON.stringify(d)})`);for(;;){try{if(await e.getSlot({commitment:c})>l.slot)break}catch{}await new Promise(e=>setTimeout(e,Math.round(200)))}}return!0}}ty.chunkSize=932;let tm=new eO("BPFLoader2111111111111111111111111111111111");var tb=(i=function(){if(s)return n;s=1;var e=Object.prototype.toString,t=Object.keys||function(e){var t=[];for(var r in e)t.push(r);return t};return n=function(r){var i=function r(i,n){var s,o,a,c,u,l,d;if(!0===i)return"true";if(!1===i)return"false";switch(typeof i){case"object":if(null===i)return null;if(i.toJSON&&"function"==typeof i.toJSON)return r(i.toJSON(),n);if("[object Array]"===(d=e.call(i))){for(s=0,a="[",o=i.length-1;s<o;s++)a+=r(i[s],!0)+",";return o>-1&&(a+=r(i[s],!0)),a+"]"}if("[object Object]"!==d)return JSON.stringify(i);for(o=(c=t(i).sort()).length,a="",s=0;s<o;)void 0!==(l=r(i[u=c[s]],!1))&&(a&&(a+=","),a+=JSON.stringify(u)+":"+l),s++;return"{"+a+"}";case"function":case"undefined":return n?null:void 0;case"string":return JSON.stringify(i);default:return isFinite(i)?i:null}}(r,!1);if(void 0!==i)return""+i}}())&&i.__esModule&&Object.prototype.hasOwnProperty.call(i,"default")?i.default:i;function tk(e){let t=0;for(;e>1;)e/=2,t++;return t}class tw{constructor(e,t,r,i,n){this.slotsPerEpoch=void 0,this.leaderScheduleSlotOffset=void 0,this.warmup=void 0,this.firstNormalEpoch=void 0,this.firstNormalSlot=void 0,this.slotsPerEpoch=e,this.leaderScheduleSlotOffset=t,this.warmup=r,this.firstNormalEpoch=i,this.firstNormalSlot=n}getEpoch(e){return this.getEpochAndSlotIndex(e)[0]}getEpochAndSlotIndex(e){if(e<this.firstNormalSlot){var t;let r=tk(0===(t=e+32+1)?1:(t--,t|=t>>1,t|=t>>2,t|=t>>4,t|=t>>8,t|=t>>16,(t|=t>>32)+1))-tk(32)-1,i=this.getSlotsInEpoch(r);return[r,e-(i-32)]}{let t=e-this.firstNormalSlot,r=Math.floor(t/this.slotsPerEpoch);return[this.firstNormalEpoch+r,t%this.slotsPerEpoch]}}getFirstSlotInEpoch(e){return e<=this.firstNormalEpoch?(Math.pow(2,e)-1)*32:(e-this.firstNormalEpoch)*this.slotsPerEpoch+this.firstNormalSlot}getLastSlotInEpoch(e){return this.getFirstSlotInEpoch(e)+this.getSlotsInEpoch(e)-1}getSlotsInEpoch(e){return e<this.firstNormalEpoch?Math.pow(2,e+tk(32)):this.slotsPerEpoch}}var tS=globalThis.fetch;class tv extends eS{constructor(e,t,r){super(e=>{let r=ek(e,{autoconnect:!0,max_reconnects:5,reconnect:!0,reconnect_interval:1e3,...t});return"socket"in r?this.underlyingSocket=r.socket:this.underlyingSocket=r,r},e,t,r),this.underlyingSocket=void 0}call(...e){let t=this.underlyingSocket?.readyState;return 1===t?super.call(...e):Promise.reject(Error("Tried to call a JSON-RPC method `"+e[0]+"` but the socket was not `CONNECTING` or `OPEN` (`readyState` was "+t+")"))}notify(...e){let t=this.underlyingSocket?.readyState;return 1===t?super.notify(...e):Promise.reject(Error("Tried to send a JSON-RPC notification `"+e[0]+"` but the socket was not `CONNECTING` or `OPEN` (`readyState` was "+t+")"))}}class tI{constructor(e){this.key=void 0,this.state=void 0,this.key=e.key,this.state=e.state}isActive(){let e=BigInt("0xffffffffffffffff");return this.state.deactivationSlot===e}static deserialize(e){let t=function(e,t){let r;try{r=e.layout.decode(t)}catch(e){throw Error("invalid instruction; "+e)}if(r.typeIndex!==e.index)throw Error(`invalid account data; account type mismatch ${r.typeIndex} != ${e.index}`);return r}(t_,e),r=e.length-56;eV(r>=0,"lookup table is invalid"),eV(r%32==0,"lookup table is invalid");let{addresses:i}=U.struct([U.seq(eq(),r/32,"addresses")]).decode(e.slice(56));return{deactivationSlot:t.deactivationSlot,lastExtendedSlot:t.lastExtendedSlot,lastExtendedSlotStartIndex:t.lastExtendedStartIndex,authority:0!==t.authority.length?new eO(t.authority[0]):void 0,addresses:i.map(e=>new eO(e))}}}let t_={index:1,layout:U.struct([U.u32("typeIndex"),tf("deactivationSlot"),U.nu64("lastExtendedSlot"),U.u8("lastExtendedStartIndex"),U.u8(),U.seq(eq(),U.offset(U.u8(),-1),"authority")])},tA=/^[^:]+:\/\/([^:[]+|\[[^\]]+\])(:\d+)?(.*)/i,tE=eg(en(eO),el(),e=>new eO(e)),tx=ed([el(),es("base64")]),tB=eg(en(o.Buffer),tx,e=>o.Buffer.from(e[0],"base64"));function tP(e){let t,r;if("string"==typeof e)t=e;else if(e){let{commitment:i,...n}=e;t=i,r=n}return{commitment:t,config:r}}function tT(e){return e.map(e=>"memcmp"in e?{...e,memcmp:{...e.memcmp,encoding:e.memcmp.encoding??"base58"}}:e)}function tR(e){return ef([eh({jsonrpc:es("2.0"),id:el(),result:e}),eh({jsonrpc:es("2.0"),id:el(),error:eh({code:ep(),message:el(),data:ec(et())})})])}let tC=tR(ep());function tL(e){return eg(tR(e),tC,t=>"error"in t?t:{...t,result:X(t.result,e)})}function tO(e){return tL(eh({context:eh({slot:ea()}),value:e}))}function tz(e){return eh({context:eh({slot:ea()}),value:e})}function tN(e,t){return 0===e?new eY({header:t.header,staticAccountKeys:t.accountKeys.map(e=>new eO(e)),recentBlockhash:t.recentBlockhash,compiledInstructions:t.instructions.map(e=>({programIdIndex:e.programIdIndex,accountKeyIndexes:e.accounts,data:O.default.decode(e.data)})),addressTableLookups:t.addressTableLookups}):new eJ(t)}let tU=eh({foundation:ea(),foundationTerm:ea(),initial:ea(),taper:ea(),terminal:ea()}),tW=tL(er(eo(eh({epoch:ea(),effectiveSlot:ea(),amount:ea(),postBalance:ea(),commission:ec(eo(ea()))})))),tK=er(eh({slot:ea(),prioritizationFee:ea()})),tq=eh({total:ea(),validator:ea(),foundation:ea(),epoch:ea()}),tM=eh({epoch:ea(),slotIndex:ea(),slotsInEpoch:ea(),absoluteSlot:ea(),blockHeight:ec(ea()),transactionCount:ec(ea())}),tD=eh({slotsPerEpoch:ea(),leaderScheduleSlotOffset:ea(),warmup:ei(),firstNormalEpoch:ea(),firstNormalSlot:ea()}),tF=eu(el(),er(ea())),tV=eo(ef([eh({}),el()])),t$=eh({err:tV}),tj=es("receivedSignature"),tH=eh({"solana-core":el(),"feature-set":ec(ea())}),tG=eh({program:el(),programId:tE,parsed:ep()}),tJ=eh({programId:tE,accounts:er(tE),data:el()}),tY=tO(eh({err:eo(ef([eh({}),el()])),logs:eo(er(el())),accounts:ec(eo(er(eo(eh({executable:ei(),owner:el(),lamports:ea(),data:er(el()),rentEpoch:ec(ea())}))))),unitsConsumed:ec(ea()),returnData:ec(eo(eh({programId:el(),data:ed([el(),es("base64")])}))),innerInstructions:ec(eo(er(eh({index:ea(),instructions:er(ef([tG,tJ]))}))))})),tZ=tO(eh({byIdentity:eu(el(),er(ea())),range:eh({firstSlot:ea(),lastSlot:ea()})})),tX=tL(tU),tQ=tL(tq),t0=tL(tK),t1=tL(tM),t2=tL(tD),t6=tL(tF),t5=tL(ea()),t3=tO(eh({total:ea(),circulating:ea(),nonCirculating:ea(),nonCirculatingAccounts:er(tE)})),t8=eh({amount:el(),uiAmount:eo(ea()),decimals:ea(),uiAmountString:ec(el())}),t4=tO(er(eh({address:tE,amount:el(),uiAmount:eo(ea()),decimals:ea(),uiAmountString:ec(el())}))),t7=tO(er(eh({pubkey:tE,account:eh({executable:ei(),owner:tE,lamports:ea(),data:tB,rentEpoch:ea()})}))),t9=eh({program:el(),parsed:ep(),space:ea()}),re=tO(er(eh({pubkey:tE,account:eh({executable:ei(),owner:tE,lamports:ea(),data:t9,rentEpoch:ea()})}))),rt=tO(er(eh({lamports:ea(),address:tE}))),rr=eh({executable:ei(),owner:tE,lamports:ea(),data:tB,rentEpoch:ea()}),ri=eh({pubkey:tE,account:rr}),rn=eg(ef([en(o.Buffer),t9]),ef([tx,t9]),e=>Array.isArray(e)?X(e,tB):e),rs=eh({executable:ei(),owner:tE,lamports:ea(),data:rn,rentEpoch:ea()}),ro=eh({pubkey:tE,account:rs}),ra=eh({state:ef([es("active"),es("inactive"),es("activating"),es("deactivating")]),active:ea(),inactive:ea()}),rc=tL(er(eh({signature:el(),slot:ea(),err:tV,memo:eo(el()),blockTime:ec(eo(ea()))}))),ru=tL(er(eh({signature:el(),slot:ea(),err:tV,memo:eo(el()),blockTime:ec(eo(ea()))}))),rl=eh({subscription:ea(),result:tz(rr)}),rd=eh({pubkey:tE,account:rr}),rh=eh({subscription:ea(),result:tz(rd)}),rf=eh({parent:ea(),slot:ea(),root:ea()}),rp=eh({subscription:ea(),result:rf}),rg=ef([eh({type:ef([es("firstShredReceived"),es("completed"),es("optimisticConfirmation"),es("root")]),slot:ea(),timestamp:ea()}),eh({type:es("createdBank"),parent:ea(),slot:ea(),timestamp:ea()}),eh({type:es("frozen"),slot:ea(),timestamp:ea(),stats:eh({numTransactionEntries:ea(),numSuccessfulTransactions:ea(),numFailedTransactions:ea(),maxTransactionsPerEntry:ea()})}),eh({type:es("dead"),slot:ea(),timestamp:ea(),err:el()})]),ry=eh({subscription:ea(),result:rg}),rm=eh({subscription:ea(),result:tz(ef([t$,tj]))}),rb=eh({subscription:ea(),result:ea()}),rk=eh({pubkey:el(),gossip:eo(el()),tpu:eo(el()),rpc:eo(el()),version:eo(el())}),rw=eh({votePubkey:el(),nodePubkey:el(),activatedStake:ea(),epochVoteAccount:ei(),epochCredits:er(ed([ea(),ea(),ea()])),commission:ea(),lastVote:ea(),rootSlot:eo(ea())}),rS=tL(eh({current:er(rw),delinquent:er(rw)})),rv=ef([es("processed"),es("confirmed"),es("finalized")]),rI=eh({slot:ea(),confirmations:eo(ea()),err:tV,confirmationStatus:ec(rv)}),r_=tO(er(eo(rI))),rA=tL(ea()),rE=eh({accountKey:tE,writableIndexes:er(ea()),readonlyIndexes:er(ea())}),rx=eh({signatures:er(el()),message:eh({accountKeys:er(el()),header:eh({numRequiredSignatures:ea(),numReadonlySignedAccounts:ea(),numReadonlyUnsignedAccounts:ea()}),instructions:er(eh({accounts:er(ea()),data:el(),programIdIndex:ea()})),recentBlockhash:el(),addressTableLookups:ec(er(rE))})}),rB=eh({pubkey:tE,signer:ei(),writable:ei(),source:ec(ef([es("transaction"),es("lookupTable")]))}),rP=eh({accountKeys:er(rB),signatures:er(el())}),rT=eh({parsed:ep(),program:el(),programId:tE}),rR=eh({accounts:er(tE),data:el(),programId:tE}),rC=eg(ef([rR,rT]),ef([eh({parsed:ep(),program:el(),programId:el()}),eh({accounts:er(el()),data:el(),programId:el()})]),e=>"accounts"in e?X(e,rR):X(e,rT)),rL=eh({signatures:er(el()),message:eh({accountKeys:er(rB),instructions:er(rC),recentBlockhash:el(),addressTableLookups:ec(eo(er(rE)))})}),rO=eh({accountIndex:ea(),mint:el(),owner:ec(el()),programId:ec(el()),uiTokenAmount:t8}),rz=eh({writable:er(tE),readonly:er(tE)}),rN=eh({err:tV,fee:ea(),innerInstructions:ec(eo(er(eh({index:ea(),instructions:er(eh({accounts:er(ea()),data:el(),programIdIndex:ea()}))})))),preBalances:er(ea()),postBalances:er(ea()),logMessages:ec(eo(er(el()))),preTokenBalances:ec(eo(er(rO))),postTokenBalances:ec(eo(er(rO))),loadedAddresses:ec(rz),computeUnitsConsumed:ec(ea())}),rU=eh({err:tV,fee:ea(),innerInstructions:ec(eo(er(eh({index:ea(),instructions:er(rC)})))),preBalances:er(ea()),postBalances:er(ea()),logMessages:ec(eo(er(el()))),preTokenBalances:ec(eo(er(rO))),postTokenBalances:ec(eo(er(rO))),loadedAddresses:ec(rz),computeUnitsConsumed:ec(ea())}),rW=ef([es(0),es("legacy")]),rK=eh({pubkey:el(),lamports:ea(),postBalance:eo(ea()),rewardType:eo(el()),commission:ec(eo(ea()))}),rq=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),transactions:er(eh({transaction:rx,meta:eo(rN),version:ec(rW)})),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),rM=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),rD=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),transactions:er(eh({transaction:rP,meta:eo(rN),version:ec(rW)})),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),rF=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),transactions:er(eh({transaction:rL,meta:eo(rU),version:ec(rW)})),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),rV=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),transactions:er(eh({transaction:rP,meta:eo(rU),version:ec(rW)})),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),r$=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),rewards:ec(er(rK)),blockTime:eo(ea()),blockHeight:eo(ea())}))),rj=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),transactions:er(eh({transaction:rx,meta:eo(rN)})),rewards:ec(er(rK)),blockTime:eo(ea())}))),rH=tL(eo(eh({blockhash:el(),previousBlockhash:el(),parentSlot:ea(),signatures:er(el()),blockTime:eo(ea())}))),rG=tL(eo(eh({slot:ea(),meta:eo(rN),blockTime:ec(eo(ea())),transaction:rx,version:ec(rW)}))),rJ=tL(eo(eh({slot:ea(),transaction:rL,meta:eo(rU),blockTime:ec(eo(ea())),version:ec(rW)}))),rY=tO(eh({blockhash:el(),lastValidBlockHeight:ea()})),rZ=tO(ei()),rX=tL(er(eh({slot:ea(),numTransactions:ea(),numSlots:ea(),samplePeriodSecs:ea()}))),rQ=tO(eo(eh({feeCalculator:eh({lamportsPerSignature:ea()})}))),r0=tL(el()),r1=tL(el()),r2=eh({err:tV,logs:er(el()),signature:el()}),r6=eh({result:tz(r2),subscription:ea()}),r5={"solana-client":"js/1.0.0-maintenance"};class r3{constructor(e){this._keypair=void 0,this._keypair=e??eA()}static generate(){return new r3(eA())}static fromSecretKey(e,t){if(64!==e.byteLength)throw Error("bad secret key size");let r=e.slice(32,64);if(!t||!t.skipValidation){let t=eE(e.slice(0,32));for(let e=0;e<32;

8catch(e){throw Error(`Error constructing Ethereum address: ${e}`)}}static createInstructionWithPublicKey(e){let{publicKey:t,message:r,signature:i,recoveryId:n,instructionIndex:s}=e;return is.createInstructionWithEthAddress({ethAddress:is.publicKeyToEthAddress(t),message:r,signature:i,recoveryId:n,instructionIndex:s})}static createInstructionWithEthAddress(e){let t,{ethAddress:r,message:i,signature:n,recoveryId:s,instructionIndex:a=0}=e;eV(20===(t="string"==typeof r?r.startsWith("0x")?o.Buffer.from(r.substr(2),"hex"):o.Buffer.from(r,"hex"):r).length,`Address must be 20 bytes but received ${t.length} bytes`);let c=12+t.length,u=c+n.length+1,l=o.Buffer.alloc(ii.span+i.length);return ii.encode({numSignatures:1,signatureOffset:c,signatureInstructionIndex:a,ethAddressOffset:12,ethAddressInstructionIndex:a,messageDataOffset:u,messageDataSize:i.length,messageInstructionIndex:a,signature:eT(n),ethAddress:eT(t),recoveryId:s},l),l.fill(eT(i),ii.span),new e0({keys:[],programId:is.programId,data:l})}static createInstructionWithPrivateKey(e){let{privateKey:t,message:r,instructionIndex:i}=e;eV(32===t.length,`Private key must be 32 bytes but received ${t.length} bytes`);try{var n;let e,s=eT(t),a=ir(s,!1).slice(1),[c,u]=(n=o.Buffer.from((0,ev.keccak_256)(eT(r))),[(e=eI.secp256k1.sign(n,s)).toCompactRawBytes(),e.recovery]);return this.createInstructionWithPublicKey({publicKey:a,message:r,signature:c,recoveryId:u,instructionIndex:i})}catch(e){throw Error(`Error creating instruction; ${e}`)}}}is.programId=new eO("KeccakSecp256k11111111111111111111111111111");let io=new eO("StakeConfig11111111111111111111111111111111");class ia{constructor(e,t){this.staker=void 0,this.withdrawer=void 0,this.staker=e,this.withdrawer=t}}class ic{constructor(e,t,r){this.unixTimestamp=void 0,this.epoch=void 0,this.custodian=void 0,this.unixTimestamp=e,this.epoch=t,this.custodian=r}}ic.default=new ic(0,0,eO.default);let iu=Object.freeze({Initialize:{index:0,layout:U.struct([U.u32("instruction"),((e="authorized")=>U.struct([eq("staker"),eq("withdrawer")],e))(),((e="lockup")=>U.struct([U.ns64("unixTimestamp"),U.ns64("epoch"),eq("custodian")],e))()])},Authorize:{index:1,layout:U.struct([U.u32("instruction"),eq("newAuthorized"),U.u32("stakeAuthorizationType")])},Delegate:{index:2,layout:U.struct([U.u32("instruction")])},Split:{index:3,layout:U.struct([U.u32("instruction"),U.ns64("lamports")])},Withdraw:{index:4,layout:U.struct([U.u32("instruction"),U.ns64("lamports")])},Deactivate:{index:5,layout:U.struct([U.u32("instruction")])},Merge:{index:7,layout:U.struct([U.u32("instruction")])},AuthorizeWithSeed:{index:8,layout:U.struct([U.u32("instruction"),eq("newAuthorized"),U.u32("stakeAuthorizationType"),eM("authoritySeed"),eq("authorityOwner")])}}),il=Object.freeze({Staker:{index:0},Withdrawer:{index:1}});class id{static initialize(e){let{stakePubkey:t,authorized:r,lockup:i}=e,n=i||ic.default,s=ta(iu.Initialize,{authorized:{staker:eT(r.staker.toBuffer()),withdrawer:eT(r.withdrawer.toBuffer())},lockup:{unixTimestamp:n.unixTimestamp,epoch:n.epoch,custodian:eT(n.custodian.toBuffer())}});return new e0({keys:[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:e7,isSigner:!1,isWritable:!1}],programId:this.programId,data:s})}static createAccountWithSeed(e){let t=new e1;t.add(tg.createAccountWithSeed({fromPubkey:e.fromPubkey,newAccountPubkey:e.stakePubkey,basePubkey:e.basePubkey,seed:e.seed,lamports:e.lamports,space:this.space,programId:this.programId}));let{stakePubkey:r,authorized:i,lockup:n}=e;return t.add(this.initialize({stakePubkey:r,authorized:i,lockup:n}))}static createAccount(e){let t=new e1;t.add(tg.createAccount({fromPubkey:e.fromPubkey,newAccountPubkey:e.stakePubkey,lamports:e.lamports,space:this.space,programId:this.programId}));let{stakePubkey:r,authorized:i,lockup:n}=e;return t.add(this.initialize({stakePubkey:r,authorized:i,lockup:n}))}static delegate(e){let{stakePubkey:t,authorizedPubkey:r,votePubkey:i}=e,n=ta(iu.Delegate);return new e1().add({keys:[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:i,isSigner:!1,isWritable:!1},{pubkey:e5,isSigner:!1,isWritable:!1},{pubkey:tr,isSigner:!1,isWritable:!1},{pubkey:io,isSigner:!1,isWritable:!1},{pubkey:r,isSigner:!0,isWritable:!1}],programId:this.programId,data:n})}static authorize(e){let{stakePubkey:t,authorizedPubkey:r,newAuthorizedPubkey:i,stakeAuthorizationType:n,custodianPubkey:s}=e,o=ta(iu.Authorize,{newAuthorized:eT(i.toBuffer()),stakeAuthorizationType:n.index}),a=[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:e5,isSigner:!1,isWritable:!0},{pubkey:r,isSigner:!0,isWritable:!1}];return s&&a.push({pubkey:s,isSigner:!0,isWritable:!1}),new e1().add({keys:a,programId:this.programId,data:o})}static authorizeWithSeed(e){let{stakePubkey:t,authorityBase:r,authoritySeed:i,authorityOwner:n,newAuthorizedPubkey:s,stakeAuthorizationType:o,custodianPubkey:a}=e,c=ta(iu.AuthorizeWithSeed,{newAuthorized:eT(s.toBuffer()),stakeAuthorizationType:o.index,authoritySeed:i,authorityOwner:eT(n.toBuffer())}),u=[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:r,isSigner:!0,isWritable:!1},{pubkey:e5,isSigner:!1,isWritable:!1}];return a&&u.push({pubkey:a,isSigner:!0,isWritable:!1}),new e1().add({keys:u,programId:this.programId,data:c})}static splitInstruction(e){let{stakePubkey:t,authorizedPubkey:r,splitStakePubkey:i,lamports:n}=e,s=ta(iu.Split,{lamports:n});return new e0({keys:[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:i,isSigner:!1,isWritable:!0},{pubkey:r,isSigner:!0,isWritable:!1}],programId:this.programId,data:s})}static split(e,t){let r=new e1;return r.add(tg.createAccount({fromPubkey:e.authorizedPubkey,newAccountPubkey:e.splitStakePubkey,lamports:t,space:this.space,programId:this.programId})),r.add(this.splitInstruction(e))}static splitWithSeed(e,t){let{stakePubkey:r,authorizedPubkey:i,splitStakePubkey:n,basePubkey:s,seed:o,lamports:a}=e,c=new e1;return c.add(tg.allocate({accountPubkey:n,basePubkey:s,seed:o,space:this.space,programId:this.programId})),t&&t>0&&c.add(tg.transfer({fromPubkey:e.authorizedPubkey,toPubkey:n,lamports:t})),c.add(this.splitInstruction({stakePubkey:r,authorizedPubkey:i,splitStakePubkey:n,lamports:a}))}static merge(e){let{stakePubkey:t,sourceStakePubKey:r,authorizedPubkey:i}=e,n=ta(iu.Merge);return new e1().add({keys:[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:r,isSigner:!1,isWritable:!0},{pubkey:e5,isSigner:!1,isWritable:!1},{pubkey:tr,isSigner:!1,isWritable:!1},{pubkey:i,isSigner:!0,isWritable:!1}],programId:this.programId,data:n})}static withdraw(e){let{stakePubkey:t,authorizedPubkey:r,toPubkey:i,lamports:n,custodianPubkey:s}=e,o=ta(iu.Withdraw,{lamports:n}),a=[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:i,isSigner:!1,isWritable:!0},{pubkey:e5,isSigner:!1,isWritable:!1},{pubkey:tr,isSigner:!1,isWritable:!1},{pubkey:r,isSigner:!0,isWritable:!1}];return s&&a.push({pubkey:s,isSigner:!0,isWritable:!1}),new e1().add({keys:a,programId:this.programId,data:o})}static deactivate(e){let{stakePubkey:t,authorizedPubkey:r}=e,i=ta(iu.Deactivate);return new e1().add({keys:[{pubkey:t,isSigner:!1,isWritable:!0},{pubkey:e5,isSigner:!1,isWritable:!1},{pubkey:r,isSigner:!0,isWritable:!1}],programId:this.programId,data:i})}}id.programId=new eO("Stake11111111111111111111111111111111111111"),id.space=200;

8async getBalanceAndContext(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgs([e.toBase58()],r,void 0,i),s=X(await this._rpcRequest("getBalance",n),tO(ea()));if("error"in s)throw new tn(s.error,`failed to get balance for ${e.toBase58()}`);return s.result}async getBalance(e,t){return await this.getBalanceAndContext(e,t).then(e=>e.value).catch(t=>{throw Error("failed to get balance of account "+e.toBase58()+": "+t)})}async getBlockTime(e){let t=X(await this._rpcRequest("getBlockTime",[e]),tL(eo(ea())));if("error"in t)throw new tn(t.error,`failed to get block time for slot ${e}`);return t.result}async getMinimumLedgerSlot(){let e=X(await this._rpcRequest("minimumLedgerSlot",[]),tL(ea()));if("error"in e)throw new tn(e.error,"failed to get minimum ledger slot");return e.result}async getFirstAvailableBlock(){let e=X(await this._rpcRequest("getFirstAvailableBlock",[]),t5);if("error"in e)throw new tn(e.error,"failed to get first available block");return e.result}async getSupply(e){let t={};t="string"==typeof e?{commitment:e}:e?{...e,commitment:e&&e.commitment||this.commitment}:{commitment:this.commitment};let r=X(await this._rpcRequest("getSupply",[t]),t3);if("error"in r)throw new tn(r.error,"failed to get supply");return r.result}async getTokenSupply(e,t){let r=this._buildArgs([e.toBase58()],t),i=X(await this._rpcRequest("getTokenSupply",r),tO(t8));if("error"in i)throw new tn(i.error,"failed to get token supply");return i.result}async getTokenAccountBalance(e,t){let r=this._buildArgs([e.toBase58()],t),i=X(await this._rpcRequest("getTokenAccountBalance",r),tO(t8));if("error"in i)throw new tn(i.error,"failed to get token account balance");return i.result}async getTokenAccountsByOwner(e,t,r){let{commitment:i,config:n}=tP(r),s=[e.toBase58()];"mint"in t?s.push({mint:t.mint.toBase58()}):s.push({programId:t.programId.toBase58()});let o=this._buildArgs(s,i,"base64",n),a=X(await this._rpcRequest("getTokenAccountsByOwner",o),t7);if("error"in a)throw new tn(a.error,`failed to get token accounts owned by account ${e.toBase58()}`);return a.result}async getParsedTokenAccountsByOwner(e,t,r){let i=[e.toBase58()];"mint"in t?i.push({mint:t.mint.toBase58()}):i.push({programId:t.programId.toBase58()});let n=this._buildArgs(i,r,"jsonParsed"),s=X(await this._rpcRequest("getTokenAccountsByOwner",n),re);if("error"in s)throw new tn(s.error,`failed to get token accounts owned by account ${e.toBase58()}`);return s.result}async getLargestAccounts(e){let t={...e,commitment:e&&e.commitment||this.commitment},r=t.filter||t.commitment?[t]:[],i=X(await this._rpcRequest("getLargestAccounts",r),rt);if("error"in i)throw new tn(i.error,"failed to get largest accounts");return i.result}async getTokenLargestAccounts(e,t){let r=this._buildArgs([e.toBase58()],t),i=X(await this._rpcRequest("getTokenLargestAccounts",r),t4);if("error"in i)throw new tn(i.error,"failed to get token largest accounts");return i.result}async getAccountInfoAndContext(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgs([e.toBase58()],r,"base64",i),s=X(await this._rpcRequest("getAccountInfo",n),tO(eo(rr)));if("error"in s)throw new tn(s.error,`failed to get info about account ${e.toBase58()}`);return s.result}async getParsedAccountInfo(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgs([e.toBase58()],r,"jsonParsed",i),s=X(await this._rpcRequest("getAccountInfo",n),tO(eo(rs)));if("error"in s)throw new tn(s.error,`failed to get info about account ${e.toBase58()}`);return s.result}async getAccountInfo(e,t){try{return(await this.getAccountInfoAndContext(e,t)).value}catch(t){throw Error("failed to get info about account "+e.toBase58()+": "+t)}}async getMultipleParsedAccounts(e,t){let{commitment:r,config:i}=tP(t),n=e.map(e=>e.toBase58()),s=this._buildArgs([n],r,"jsonParsed",i),o=X(await this._rpcRequest("getMultipleAccounts",s),tO(er(eo(rs))));if("error"in o)throw new tn(o.error,`failed to get info for accounts ${n}`);return o.result}async getMultipleAccountsInfoAndContext(e,t){let{commitment:r,config:i}=tP(t),n=e.map(e=>e.toBase58()),s=this._buildArgs([n],r,"base64",i),o=X(await this._rpcRequest("getMultipleAccounts",s),tO(er(eo(rr))));if("error"in o)throw new tn(o.error,`failed to get info for accounts ${n}`);return o.result}async getMultipleAccountsInfo(e,t){return(await this.getMultipleAccountsInfoAndContext(e,t)).value}async getStakeActivation(e,t,r){let{commitment:i,config:n}=tP(t),s=this._buildArgs([e.toBase58()],i,void 0,{...n,epoch:null!=r?r:n?.epoch}),o=X(await this._rpcRequest("getStakeActivation",s),tL(ra));if("error"in o)throw new tn(o.error,`failed to get Stake Activation ${e.toBase58()}`);return o.result}async getProgramAccounts(e,t){let{commitment:r,config:i}=tP(t),{encoding:n,...s}=i||{},o=this._buildArgs([e.toBase58()],r,n||"base64",{...s,...s.filters?{filters:tT(s.filters)}:null}),a=await this._rpcRequest("getProgramAccounts",o),c=er(ri),u=!0===s.withContext?X(a,tO(c)):X(a,tL(c));if("error"in u)throw new tn(u.error,`failed to get accounts owned by program ${e.toBase58()}`);return u.result}async getParsedProgramAccounts(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgs([e.toBase58()],r,"jsonParsed",i),s=X(await this._rpcRequest("getProgramAccounts",n),tL(er(ro)));if("error"in s)throw new tn(s.error,`failed to get accounts owned by program ${e.toBase58()}`);return s.result}async confirmTransaction(e,t){let r,i;if("string"==typeof e)r=e;else{if(e.abortSignal?.aborted)return Promise.reject(e.abortSignal.reason);r=e.signature}try{i=O.default.decode(r)}catch(e){throw Error("signature must be base58 encoded: "+r)}return(eV(64===i.length,"signature has invalid length"),"string"==typeof e)?await this.confirmTransactionUsingLegacyTimeoutStrategy({commitment:t||this.commitment,signature:r}):"lastValidBlockHeight"in e?await this.confirmTransactionUsingBlockHeightExceedanceStrategy({commitment:t||this.commitment,strategy:e}):await this.confirmTransactionUsingDurableNonceStrategy({commitment:t||this.commitment,strategy:e})}getCancellationPromise(e){return new Promise((t,r)=>{null!=e&&(e.aborted?r(e.reason):e.addEventListener("abort",()=>{r(e.reason)}))})}getTransactionConfirmationPromise({commitment:e,signature:t}){let r,i,n=!1;return{abortConfirmation:()=>{i&&(i(),i=void 0),null!=r&&(this.removeSignatureListener(r),r=void 0)},confirmationPromise:new Promise((s,o)=>{try{r=this.onSignature(t,(e,t)=>{r=void 0,s({__type:eX.PROCESSED,response:{context:t,value:e}})},e);let a=new Promise(e=>{null==r?e():i=this._onSubscriptionStateChange(r,t=>{"subscribed"===t&&e()})});(async()=>{if(await a,n)return;let r=await this.getSignatureStatus(t);if(n||null==r)return;let{context:i,value:c}=r;if(null!=c)if(c?.err)o(c.err);else{switch(e){case"confirmed":case"single":case"singleGossip":if("processed"===c.confirmationStatus)return;break;case"finalized":case"max":case"root":if("processed"===c.confirmationStatus||"confirmed"===c.confirmationStatus)return}n=!0,s({__type:eX.PROCESSED,response:{context:i,value:c}})}})()}catch(e){o(e)}})}}async confirmTransactionUsingBlockHeightExceedanceStrategy({commitment:e,strategy:{abortSignal:t,lastValidBlockHeight:r,signature:i}}){let n,s=!1,o=new Promise(t=>{let i=async()=>{try{return await this.getBlockHeight(e)}catch(e){return -1}};(async()=>{let e=await i();if(!s){for(;e<=r;)if(await to(1e3),s||(e=await i(),s))return;t({__type:eX.BLOCKHEIGHT_EXCEEDED})}})()}),{abortConfirmation:a,confirmationPromise:c}=this.getTransactionConfirmationPromise({commitment:e,signature:i}),u=this.getCancellationPromise(t);try{let e=await Promise.race([u,c,o]);if(e.__type===eX.PROCESSED)n=e.response;else throw new eN(i)}finally{s=!0,a()}return n}async confirmTransactionUsingDurableNonceStrategy({commitment:e,strategy:{abortSignal:t,minContextSlot:r,nonceAccountPubkey:i,nonceValue:n,signature:s}}){let o,a=!1,c=new Promise(t=>{let s=n,o=null,c=async()=>{try{let{context:t,value:n}=await this.getNonceAndContext(i,{commitment:e,minContextSlot:r});return o=t.slot,n?.nonce}catch(e){return s}};(async()=>{if(s=await c(),!a)for(;;){if(n!==s)return void t({__type:eX.NONCE_INVALID,slotInWhichNonceDidAdvance:o});if(await to(2e3),a||(s=await c(),a))return}})()}),{abortConfirmation:u,confirmationPromise:l}=this.getTransactionConfirmationPromise({commitment:e,signature:s}),d=this.getCancellationPromise(t);try{let t=await Promise.race([d,l,c]);if(t.__type===eX.PROCESSED)o=t.response;else{let i;for(;;){let e=await this.getSignatureStatus(s);if(null==e)break;if(e.context.slot<(t.slotInWhichNonceDidAdvance??r)){await to(400);continue}i=e;break}if(i?.value){let t=e||"finalized",{confirmationStatus:r}=i.value;switch(t){case"processed":case"recent":if("processed"!==r&&"confirmed"!==r&&"finalized"!==r)throw new eW(s);break;case"confirmed":case"single":case"singleGossip":if("confirmed"!==r&&"finalized"!==r)throw new eW(s);break;case"finalized":case"max":case"root":if("finalized"!==r)throw new eW(s)}o={context:i.context,value:{err:i.value.err}}}else throw new eW(s)}}finally{a=!0,u()}return o}async confirmTransactionUsingLegacyTimeoutStrategy({commitment:e,signature:t}){let r,i,n=new Promise(t=>{let i=this._confirmTransactionInitialTimeout||6e4;switch(e){case"processed":case"recent":case"single":case"confirmed":case"singleGossip":i=this._confirmTransactionInitialTimeout||3e4}r=setTimeout(()=>t({__type:eX.TIMED_OUT,timeoutMs:i}),i)}),{abortConfirmation:s,confirmationPromise:o}=this.getTransactionConfirmationPromise({commitment:e,signature:t});try{let e=await Promise.race([o,n]);if(e.__type===eX.PROCESSED)i=e.response;else throw new eU(t,e.timeoutMs/1e3)}finally{clearTimeout(r),s()}return i}async getClusterNodes(){let e=X(await this._rpcRequest("getClusterNodes",[]),tL(er(rk)));if("error"in e)throw new tn(e.error,"failed to get cluster nodes");return e.result}async getVoteAccounts(e){let t=this._buildArgs([],e),r=X(await this._rpcRequest("getVoteAccounts",t),rS);if("error"in r)throw new tn(r.error,"failed to get vote accounts");return r.result}async getSlot(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,void 0,r),n=X(await this._rpcRequest("getSlot",i),tL(ea()));if("error"in n)throw new tn(n.error,"failed to get slot");return n.result}async getSlotLeader(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,void 0,r),n=X(await this._rpcRequest("getSlotLeader",i),tL(el()));if("error"in n)throw new tn(n.error,"failed to get slot leader");return n.result}async getSlotLeaders(e,t){let r=X(await this._rpcRequest("getSlotLeaders",[e,t]),tL(er(tE)));if("error"in r)throw new tn(r.error,"failed to get slot leaders");return r.result}async getSignatureStatus(e,t){let{context:r,value:i}=await this.getSignatureStatuses([e],t);return eV(1===i.length),{context:r,value:i[0]}}async getSignatureStatuses(e,t){let r=[e];t&&r.push(t);let i=X(await this._rpcRequest("getSignatureStatuses",r),r_);if("error"in i)throw new tn(i.error,"failed to get signature status");return i.result}async getTransactionCount(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,void 0,r),n=X(await this._rpcRequest("getTransactionCount",i),tL(ea()));if("error"in n)throw new tn(n.error,"failed to get transaction count");return n.result}async getTotalSupply(e){return(await this.getSupply({commitment:e,excludeNonCirculatingAccountsList:!0})).value.total}async getInflationGovernor(e){let t=this._buildArgs([],e),r=X(await this._rpcRequest("getInflationGovernor",t),tX);if("error"in r)throw new tn(r.error,"failed to get inflation");return r.result}async getInflationReward(e,t,r){let{commitment:i,config:n}=tP(r),s=this._buildArgs([e.map(e=>e.toBase58())],i,void 0,{...n,epoch:null!=t?t:n?.epoch}),o=X(await this._rpcRequest("getInflationReward",s),tW);if("error"in o)throw new tn(o.error,"failed to get inflation reward");return o.result}async getInflationRate(){let e=X(await this._rpcRequest("getInflationRate",[]),tQ);if("error"in e)throw new tn(e.error,"failed to get inflation rate");return e.result}async getEpochInfo(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,void 0,r),n=X(await this._rpcRequest("getEpochInfo",i),t1);if("error"in n)throw new tn(n.error,"failed to get epoch info");return n.result}async getEpochSchedule(){let e=X(await this._rpcRequest("getEpochSchedule",[]),t2);if("error"in e)throw new tn(e.error,"failed to get epoch schedule");let t=e.result;return new tw(t.slotsPerEpoch,t.leaderScheduleSlotOffset,t.warmup,t.firstNormalEpoch,t.firstNormalSlot)}async getLeaderSchedule(){let e=X(await this._rpcRequest("getLeaderSchedule",[]),t6);if("error"in e)throw new tn(e.error,"failed to get leader schedule");return e.result}async getMinimumBalanceForRentExemption(e,t){let r=this._buildArgs([e],t),i=X(await this._rpcRequest("getMinimumBalanceForRentExemption",r),rA);return"error"in i?(console.warn("Unable to fetch minimum balance for rent exemption"),0):i.result}async getRecentBlockhashAndContext(e){let{context:t,value:{blockhash:r}}=await this.getLatestBlockhashAndContext(e);return{context:t,value:{blockhash:r,feeCalculator:{get lamportsPerSignature(){throw Error("The capability to fetch `lamportsPerSignature` using the `getRecentBlockhash` API is no longer offered by the network. Use the `getFeeForMessage` API to obtain the fee for a given message.")},toJSON:()=>({})}}}}async getRecentPerformanceSamples(e){let t=X(await this._rpcRequest("getRecentPerformanceSamples",e?[e]:[]),rX);if("error"in t)throw new tn(t.error,"failed to get recent performance samples");return t.result}async getFeeCalculatorForBlockhash(e,t){let r=this._buildArgs([e],t),i=X(await this._rpcRequest("getFeeCalculatorForBlockhash",r),rQ);if("error"in i)throw new tn(i.error,"failed to get fee calculator");let{context:n,value:s}=i.result;return{context:n,value:null!==s?s.feeCalculator:null}}async getFeeForMessage(e,t){let r=eT(e.serialize()).toString("base64"),i=this._buildArgs([r],t),n=X(await this._rpcRequest("getFeeForMessage",i),tO(eo(ea())));if("error"in n)throw new tn(n.error,"failed to get fee for message");if(null===n.result)throw Error("invalid blockhash");return n.result}async getRecentPrioritizationFees(e){let t=e?.lockedWritableAccounts?.map(e=>e.toBase58()),r=t?.length?[t]:[],i=X(await this._rpcRequest("getRecentPrioritizationFees",r),t0);if("error"in i)throw new tn(i.error,"failed to get recent prioritization fees");return i.result}async getRecentBlockhash(e){try{return(await this.getRecentBlockhashAndContext(e)).value}catch(e){throw Error("failed to get recent blockhash: "+e)}}async getLatestBlockhash(e){try{return(await this.getLatestBlockhashAndContext(e)).value}catch(e){throw Error("failed to get recent blockhash: "+e)}}async getLatestBlockhashAndContext(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,void 0,r),n=X(await this._rpcRequest("getLatestBlockhash",i),rY);if("error"in n)throw new tn(n.error,"failed to get latest blockhash");return n.result}async isBlockhashValid(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgs([e],r,void 0,i),s=X(await this._rpcRequest("isBlockhashValid",n),rZ);if("error"in s)throw new tn(s.error,"failed to determine if the blockhash `"+e+"`is valid");return s.result}async getVersion(){let e=X(await this._rpcRequest("getVersion",[]),tL(tH));if("error"in e)throw new tn(e.error,"failed to get version");return e.result}async getGenesisHash(){let e=X(await this._rpcRequest("getGenesisHash",[]),tL(el()));if("error"in e)throw new tn(e.error,"failed to get genesis hash");return e.result}async getBlock(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgsAtLeastConfirmed([e],r,void 0,i),s=await this._rpcRequest("getBlock",n);try{switch(i?.transactionDetails){case"accounts":{let e=X(s,rD);if("error"in e)throw e.error;return e.result}case"none":{let e=X(s,rM);if("error"in e)throw e.error;return e.result}default:{let e=X(s,rq);if("error"in e)throw e.error;let{result:t}=e;return t?{...t,transactions:t.transactions.map(({transaction:e,meta:t,version:r})=>({meta:t,transaction:{...e,message:tN(r,e.message)},version:r}))}:null}}}catch(e){throw new tn(e,"failed to get confirmed block")}}async getParsedBlock(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgsAtLeastConfirmed([e],r,"jsonParsed",i),s=await this._rpcRequest("getBlock",n);try{switch(i?.transactionDetails){case"accounts":{let e=X(s,rV);if("error"in e)throw e.error;return e.result}case"none":{let e=X(s,r$);if("error"in e)throw e.error;return e.result}default:{let e=X(s,rF);if("error"in e)throw e.error;return e.result}}}catch(e){throw new tn(e,"failed to get block")}}async getBlockProduction(e){let t,r;if("string"==typeof e)r=e;else if(e){let{commitment:i,...n}=e;r=i,t=n}let i=this._buildArgs([],r,"base64",t),n=X(await this._rpcRequest("getBlockProduction",i),tZ);if("error"in n)throw new tn(n.error,"failed to get block production information");return n.result}async getTransaction(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgsAtLeastConfirmed([e],r,void 0,i),s=X(await this._rpcRequest("getTransaction",n),rG);if("error"in s)throw new tn(s.error,"failed to get transaction");let o=s.result;return o?{...o,transaction:{...o.transaction,message:tN(o.version,o.transaction.message)}}:o}async getParsedTransaction(e,t){let{commitment:r,config:i}=tP(t),n=this._buildArgsAtLeastConfirmed([e],r,"jsonParsed",i),s=X(await this._rpcRequest("getTransaction",n),rJ);if("error"in s)throw new tn(s.error,"failed to get transaction");return s.result}async getParsedTransactions(e,t){let{commitment:r,config:i}=tP(t),n=e.map(e=>({methodName:"getTransaction",args:this._buildArgsAtLeastConfirmed([e],r,"jsonParsed",i)}));return(await this._rpcBatchRequest(n)).map(e=>{let t=X(e,rJ);if("error"in t)throw new tn(t.error,"failed to get transactions");return t.result})}async getTransactions(e,t){let{commitment:r,config:i}=tP(t),n=e.map(e=>({methodName:"getTransaction",args:this._buildArgsAtLeastConfirmed([e],r,void 0,i)}));return(await this._rpcBatchRequest(n)).map(e=>{let t=X(e,rG);if("error"in t)throw new tn(t.error,"failed to get transactions");let r=t.result;return r?{...r,transaction:{...r.transaction,message:tN(r.version,r.transaction.message)}}:r})}async getConfirmedBlock(e,t){let r=this._buildArgsAtLeastConfirmed([e],t),i=X(await this._rpcRequest("getBlock",r),rj);if("error"in i)throw new tn(i.error,"failed to get confirmed block");let n=i.result;if(!n)throw Error("Confirmed block "+e+" not found");let s={...n,transactions:n.transactions.map(({transaction:e,meta:t})=>{let r=new eJ(e.message);return{meta:t,transaction:{...e,message:r}}})};return{...s,transactions:s.transactions.map(({transaction:e,meta:t})=>({meta:t,transaction:e1.populate(e.message,e.signatures)}))}}async getBlocks(e,t,r){let i=this._buildArgsAtLeastConfirmed(void 0!==t?[e,t]:[e],r),n=X(await this._rpcRequest("getBlocks",i),tL(er(ea())));if("error"in n)throw new tn(n.error,"failed to get blocks");return n.result}async getBlockSignatures(e,t){let r=this._buildArgsAtLeastConfirmed([e],t,void 0,{transactionDetails:"signatures",rewards:!1}),i=X(await this._rpcRequest("getBlock",r),rH);if("error"in i)throw new tn(i.error,"failed to get block");let n=i.result;if(!n)throw Error("Block "+e+" not found");return n}async getConfirmedBlockSignatures(e,t){let r=this._buildArgsAtLeastConfirmed([e],t,void 0,{transactionDetails:"signatures",rewards:!1}),i=X(await this._rpcRequest("getBlock",r),rH);if("error"in i)throw new tn(i.error,"failed to get confirmed block");let n=i.result;if(!n)throw Error("Confirmed block "+e+" not found");return n}async getConfirmedTransaction(e,t){let r=this._buildArgsAtLeastConfirmed([e],t),i=X(await this._rpcRequest("getTransaction",r),rG);if("error"in i)throw new tn(i.error,"failed to get transaction");let n=i.result;if(!n)return n;let s=new eJ(n.transaction.message),o=n.transaction.signatures;return{...n,transaction:e1.populate(s,o)}}async getParsedConfirmedTransaction(e,t){let r=this._buildArgsAtLeastConfirmed([e],t,"jsonParsed"),i=X(await this._rpcRequest("getTransaction",r),rJ);if("error"in i)throw new tn(i.error,"failed to get confirmed transaction");return i.result}async getParsedConfirmedTransactions(e,t){let r=e.map(e=>({methodName:"getTransaction",args:this._buildArgsAtLeastConfirmed([e],t,"jsonParsed")}));return(await this._rpcBatchRequest(r)).map(e=>{let t=X(e,rJ);if("error"in t)throw new tn(t.error,"failed to get confirmed transactions");return t.result})}async getConfirmedSignaturesForAddress(e,t,r){let i={},n=await this.getFirstAvailableBlock();for(;!("until"in i)&&!(--t<=0)&&!(t<n);)try{let e=await this.getConfirmedBlockSignatures(t,"finalized");e.signatures.length>0&&(i.until=e.signatures[e.signatures.length-1].toString())}catch(e){if(e instanceof Error&&e.message.includes("skipped"))continue;throw e}let s=await this.getSlot("finalized");for(;!("before"in i)&&!(++r>s);)try{let e=await this.getConfirmedBlockSignatures(r);e.signatures.length>0&&(i.before=e.signatures[e.signatures.length-1].toString())}catch(e){if(e instanceof Error&&e.message.includes("skipped"))continue;throw e}return(await this.getConfirmedSignaturesForAddress2(e,i)).map(e=>e.signature)}async getConfirmedSignaturesForAddress2(e,t,r){let i=this._buildArgsAtLeastConfirmed([e.toBase58()],r,void 0,t),n=X(await this._rpcRequest("getConfirmedSignaturesForAddress2",i),rc);if("error"in n)throw new tn(n.error,"failed to get confirmed signatures for address");return n.result}async getSignaturesForAddress(e,t,r){let i=this._buildArgsAtLeastConfirmed([e.toBase58()],r,void 0,t),n=X(await this._rpcRequest("getSignaturesForAddress",i),ru);if("error"in n)throw new tn(n.error,"failed to get signatures for address");return n.result}async getAddressLookupTable(e,t){let{context:r,value:i}=await this.getAccountInfoAndContext(e,t),n=null;return null!==i&&(n=new tI({key:e,state:tI.deserialize(i.data)})),{context:r,value:n}}async getNonceAndContext(e,t){let{context:r,value:i}=await this.getAccountInfoAndContext(e,t),n=null;return null!==i&&(n=th.fromAccountData(i.data)),{context:r,value:n}}async getNonce(e,t){return await this.getNonceAndContext(e,t).then(e=>e.value).catch(t=>{throw Error("failed to get nonce for account "+e.toBase58()+": "+t)})}async requestAirdrop(e,t){let r=X(await this._rpcRequest("requestAirdrop",[e.toBase58(),t]),r0);if("error"in r)throw new tn(r.error,`airdrop to ${e.toBase58()} failed`);return r.result}async _blockhashWithExpiryBlockHeight(e){if(!e){for(;this._pollingBlockhash;)await to(100);let e=Date.now()-this._blockhashInfo.lastFetch;if(null!==this._blockhashInfo.latestBlockhash&&!(e>=3e4))return this._blockhashInfo.latestBlockhash}return await this._pollNewBlockhash()}async _pollNewBlockhash(){this._pollingBlockhash=!0;try{let e=Date.now(),t=this._blockhashInfo.latestBlockhash,r=t?t.blockhash:null;for(let e=0;e<50;e++){let e=await this.getLatestBlockhash("finalized");if(r!==e.blockhash)return this._blockhashInfo={latestBlockhash:e,lastFetch:Date.now(),transactionSignatures:[],simulatedSignatures:[]},e;await to(200)}throw Error(`Unable to obtain a new blockhash after ${Date.now()-e}ms`)}finally{this._pollingBlockhash=!1}}async getStakeMinimumDelegation(e){let{commitment:t,config:r}=tP(e),i=this._buildArgs([],t,"base64",r),n=X(await this._rpcRequest("getStakeMinimumDelegation",i),tO(ea()));if("error"in n)throw new tn(n.error,"failed to get stake minimum delegation");return n.result}async simulateTransaction(e,t,r){let i;if("message"in e){let i=e.serialize(),n=o.Buffer.from(i).toString("base64");if(Array.isArray(t)||void 0!==r)throw Error("Invalid arguments");let s=t||{};s.encoding="base64","commitment"in s||(s.commitment=this.commitment),t&&"object"==typeof t&&"innerInstructions"in t&&(s.innerInstructions=t.innerInstructions);let a=[n,s],c=X(await this._rpcRequest("simulateTransaction",a),tY);if("error"in c)throw Error("failed to simulate transaction: "+c.error.message);return c.result}if(e instanceof e1?((i=new e1).feePayer=e.feePayer,i.instructions=e.instructions,i.nonceInfo=e.nonceInfo,i.signatures=e.signatures):(i=e1.populate(e))._message=i._json=void 0,void 0!==t&&!Array.isArray(t))throw Error("Invalid arguments");if(i.nonceInfo&&t)i.sign(...t);else{let e=this._disableBlockhashCaching;for(;;){let r=await this._blockhashWithExpiryBlockHeight(e);if(i.lastValidBlockHeight=r.lastValidBlockHeight,i.recentBlockhash=r.blockhash,!t)break;if(i.sign(...t),!i.signature)throw Error("!signature");let n=i.signature.toString("base64");if(this._blockhashInfo.simulatedSignatures.includes(n)||this._blockhashInfo.transactionSignatures.includes(n))e=!0;else{this._blockhashInfo.simulatedSignatures.push(n);break}}}let n=i._compile(),s=n.serialize(),a=i._serialize(s).toString("base64"),c={encoding:"base64",commitment:this.commitment};r&&(c.accounts={encoding:"base64",addresses:(Array.isArray(r)?r:n.nonProgramIds()).map(e=>e.toBase58())}),t&&(c.sigVerify=!0),t&&"object"==typeof t&&"innerInstructions"in t&&(c.innerInstructions=t.innerInstructions);let u=[a,c],l=X(await this._rpcRequest("simulateTransaction",u),tY);if("error"in l){let e;if("data"in l.error&&(e=l.error.data.logs)&&Array.isArray(e)){let t="\n    ",r=t+e.join(t);console.error(l.error.message,r)}throw new ti({action:"simulate",signature:"",transactionMessage:l.error.message,logs:e})}return l.result}async sendTransaction(e,t,r){if("version"in e){if(t&&Array.isArray(t))throw Error("Invalid arguments");let r=e.serialize();return await this.sendRawTransaction(r,t)}if(void 0===t||!Array.isArray(t))throw Error("Invalid arguments");if(e.nonceInfo)e.sign(...t);else{let r=this._disableBlockhashCaching;for(;;){let i=await this._blockhashWithExpiryBlockHeight(r);if(e.lastValidBlockHeight=i.lastValidBlockHeight,e.recentBlockhash=i.blockhash,e.sign(...t),!e.signature)throw Error("!signature");let n=e.signature.toString("base64");if(this._blockhashInfo.transactionSignatures.includes(n))r=!0;else{this._blockhashInfo.transactionSignatures.push(n);break}}}let i=e.serialize();return await this.sendRawTransaction(i,r)}async sendRawTransaction(e,t){let r=eT(e).toString("base64");return await this.sendEncodedTransaction(r,t)}async sendEncodedTransaction(e,t){let r={encoding:"base64"},i=t&&t.skipPreflight,n=!0===i?"processed":t&&t.preflightCommitment||this.commitment;t&&null!=t.maxRetries&&(r.maxRetries=t.maxRetries),t&&null!=t.minContextSlot&&(r.minContextSlot=t.minContextSlot),i&&(r.skipPreflight=i),n&&(r.preflightCommitment=n);let s=[e,r],o=X(await this._rpcRequest("sendTransaction",s),r1);if("error"in o){let e;throw"data"in o.error&&(e=o.error.data.logs),new ti({action:i?"send":"simulate",signature:"",transactionMessage:o.error.message,logs:e})}return o.result}_wsOnOpen(){this._rpcWebSocketConnected=!0,this._rpcWebSocketHeartbeat=setInterval(()=>{(async()=>{try{await this._rpcWebSocket.notify("ping")}catch{}})()},5e3),this._updateSubscriptions()}_wsOnError(e){this._rpcWebSocketConnected=!1,console.error("ws error:",e.message)}_wsOnClose(e){(this._rpcWebSocketConnected=!1,this._rpcWebSocketGeneration=(this._rpcWebSocketGeneration+1)%Number.MAX_SAFE_INTEGER,this._rpcWebSocketIdleTimeout&&(clearTimeout(this._rpcWebSocketIdleTimeout),this._rpcWebSocketIdleTimeout=null),this._rpcWebSocketHeartbeat&&(clearInterval(this._rpcWebSocketHeartbeat),this._rpcWebSocketHeartbeat=null),1e3===e)?this._updateSubscriptions():(this._subscriptionCallbacksByServerSubscriptionId={},Object.entries(this._subscriptionsByHash).forEach(([e,t])=>{this._setSubscription(e,{...t,state:"pending"})}))}_setSubscription(e,t){let r=this._subscriptionsByHash[e]?.state;if(this._subscriptionsByHash[e]=t,r!==t.state){let r=this._subscriptionStateChangeCallbacksByHash[e];r&&r.forEach(e=>{try{e(t.state)}catch{}})}}_onSubscriptionStateChange(e,t){let r=this._subscriptionHashByClientSubscriptionId[e];if(null==r)return()=>{};let i=this._subscriptionStateChangeCallbacksByHash[r]||=new Set;return i.add(t),()=>{i.delete(t),0===i.size&&delete this._subscriptionStateChangeCallbacksByHash[r]}}async _updateSubscriptions(){if(0===Object.keys(this._subscriptionsByHash).length){this._rpcWebSocketConnected&&(this._rpcWebSocketConnected=!1,this._rpcWebSocketIdleTimeout=setTimeout(()=>{this._rpcWebSocketIdleTimeout=null;try{this._rpcWebSocket.close()}catch(e){e instanceof Error&&console.log(`Error when closing socket connection: ${e.message}`)}},500));return}if(null!==this._rpcWebSocketIdleTimeout&&(clearTimeout(this._rpcWebSocketIdleTimeout),this._rpcWebSocketIdleTimeout=null,this._rpcWebSocketConnected=!0),!this._rpcWebSocketConnected)return void this._rpcWebSocket.connect();let e=this._rpcWebSocketGeneration,t=()=>e===this._rpcWebSocketGeneration;await Promise.all(Object.keys(this._subscriptionsByHash).map(async e=>{let r=this._subscriptionsByHash[e];if(void 0!==r)switch(r.state){case"pending":case"unsubscribed":if(0===r.callbacks.size){delete this._subscriptionsByHash[e],"unsubscribed"===r.state&&delete this._subscriptionCallbacksByServerSubscriptionId[r.serverSubscriptionId],await this._updateSubscriptions();return}await (async()=>{let{args:i,method:n}=r;try{this._setSubscription(e,{...r,state:"subscribing"});let t=await this._rpcWebSocket.call(n,i);this._setSubscription(e,{...r,serverSubscriptionId:t,state:"subscribed"}),this._subscriptionCallbacksByServerSubscriptionId[t]=r.callbacks,await this._updateSubscriptions()}catch(s){if(console.error(`Received ${s instanceof Error?"":"JSON-RPC "}error calling \`${n}\``,{args:i,error:s}),!t())return;this._setSubscription(e,{...r,state:"pending"}),await this._updateSubscriptions()}})();break;case"subscribed":0===r.callbacks.size&&await (async()=>{let{serverSubscriptionId:i,unsubscribeMethod:n}=r;if(this._subscriptionsAutoDisposedByRpc.has(i))this._subscriptionsAutoDisposedByRpc.delete(i);else{this._setSubscription(e,{...r,state:"unsubscribing"}),this._setSubscription(e,{...r,state:"unsubscribing"});try{await this._rpcWebSocket.call(n,[i])}catch(i){if(i instanceof Error&&console.error(`${n} error:`,i.message),!t())return;this._setSubscription(e,{...r,state:"subscribed"}),await this._updateSubscriptions();return}}this._setSubscription(e,{...r,state:"unsubscribed"}),await this._updateSubscriptions()})()}}))}_handleServerNotification(e,t){let r=this._subscriptionCallbacksByServerSubscriptionId[e];void 0!==r&&r.forEach(e=>{try{e(...t)}catch(e){console.error(e)}})}_wsOnAccountNotification(e){let{result:t,subscription:r}=X(e,rl);this._handleServerNotification(r,[t.value,t.context])}_makeSubscription(e,t){let r=this._nextClientSubscriptionId++,i=tb([e.method,t]),n=this._subscriptionsByHash[i];return void 0===n?this._subscriptionsByHash[i]={...e,args:t,callbacks:new Set([e.callback]),state:"pending"}:n.callbacks.add(e.callback),this._subscriptionHashByClientSubscriptionId[r]=i,this._subscriptionDisposeFunctionsByClientSubscriptionId[r]=async()=>{delete this._subscriptionDisposeFunctionsByClientSubscriptionId[r],delete this._subscriptionHashByClientSubscriptionId[r];let t=this._subscriptionsByHash[i];eV(void 0!==t,`Could not find a \`Subscription\` when tearing down client subscription #${r}`),t.callbacks.delete(e.callback),await this._updateSubscriptions()},this._updateSubscriptions(),r}onAccountChange(e,t,r){let{commitment:i,config:n}=tP(r),s=this._buildArgs([e.toBase58()],i||this._commitment||"finalized","base64",n);return this._makeSubscription({callback:t,method:"accountSubscribe",unsubscribeMethod:"accountUnsubscribe"},s)}async removeAccountChangeListener(e){await this._unsubscribeClientSubscription(e,"account change")}_wsOnProgramAccountNotification(e){let{result:t,subscription:r}=X(e,rh);this._handleServerNotification(r,[{accountId:t.value.pubkey,accountInfo:t.value.account},t.context])}onProgramAccountChange(e,t,r,i){let{commitment:n,config:s}=tP(r),o=this._buildArgs([e.toBase58()],n||this._commitment||"finalized","base64",s||(i?{filters:tT(i)}:void 0));return this._makeSubscription({callback:t,method:"programSubscribe",unsubscribeMethod:"programUnsubscribe"},o)}async removeProgramAccountChangeListener(e){await this._unsubscribeClientSubscription(e,"program account change")}onLogs(e,t,r){let i=this._buildArgs(["object"==typeof e?{mentions:[e.toString()]}:e],r||this._commitment||"finalized");return this._makeSubscription({callback:t,method:"logsSubscribe",unsubscribeMethod:"logsUnsubscribe"},i)}async removeOnLogsListener(e){await this._unsubscribeClientSubscription(e,"logs")}_wsOnLogsNotification(e){let{result:t,subscription:r}=X(e,r6);this._handleServerNotification(r,[t.value,t.context])}_wsOnSlotNotification(e){let{result:t,subscription:r}=X(e,rp);this._handleServerNotification(r,[t])}onSlotChange(e){return this._makeSubscription({callback:e,method:"slotSubscribe",unsubscribeMethod:"slotUnsubscribe"},[])}async removeSlotChangeListener(e){await this._unsubscribeClientSubscription(e,"slot change")}_wsOnSlotUpdatesNotification(e){let{result:t,subscription:r}=X(e,ry);this._handleServerNotification(r,[t])}onSlotUpdate(e){return this._makeSubscription({callback:e,method:"slotsUpdatesSubscribe",unsubscribeMethod:"slotsUpdatesUnsubscribe"},[])}async removeSlotUpdateListener(e){await this._unsubscribeClientSubscription(e,"slot update")}async _unsubscribeClientSubscription(e,t){let r=this._subscriptionDisposeFunctionsByClientSubscriptionId[e];r?await r():console.warn(`Ignored unsubscribe request because an active subscription with id \`${e}\` for '${t}' events could not be found.`)}_buildArgs(e,t,r,i){let n=t||this._commitment;if(n||r||i){let t={};r&&(t.encoding=r),n&&(t.commitment=n),i&&(t=Object.assign(t,i)),e.push(t)}return e}_buildArgsAtLeastConfirmed(e,t,r,i){let n=t||this._commitment;if(n&&!["confirmed","finalized"].includes(n))throw Error("Using Connection with default commitment: `"+this._commitment+"`, but method requires at least `confirmed`");return this._buildArgs(e,t,r,i)}_wsOnSignatureNotification(e){let{result:t,subscription:r}=X(e,rm);"receivedSignature"!==t.value&&this._subscriptionsAutoDisposedByRpc.add(r),this._handleServerNotification(r,"receivedSignature"===t.value?[{type:"received"},t.context]:[{type:"status",result:t.value},t.context])}onSignature(e,t,r){let i=this._buildArgs([e],r||this._commitment||"finalized"),n=this._makeSubscription({callback:(e,r)=>{if("status"===e.type){t(e.result,r);try{this.removeSignatureListener(n)}catch(e){}}},method:"signatureSubscribe",unsubscribeMethod:"signatureUnsubscribe"},i);return n}