After installing signClient connection Node.js app is crashing with walletConnect Core error.

[Gostai]

A Minimal Reproducible Example

It is a simple telegram bot with node-telegram-bot-api. I'm using this files:

package.json

{
  "name": "min",
  "version": "1.0.0",
  "scripts": {
    "compile": "npx rimraf dist && tsc",
    "start": "node ./dist/main.js"
  },
  "dependencies": {    
    "dotenv": "^16.0.3",
    "node-telegram-bot-api": "^0.61.0",
    "@walletconnect/sign-client": "^2.17.3",
    "lokijs": "^1.5.12",
    "qrcode": "^1.5.1"
  },
  "devDependencies": {
    "@types/node-telegram-bot-api": "^0.61.4",
    "@types/qrcode": "^1.5.0",
    "rimraf": "^3.0.2",
    "typescript": "^4.9.5"
  }
} 

tsconfig.json

{
  "compilerOptions": {
    "declaration": true,
    "lib": ["ESNext", "dom"],
    "resolveJsonModule": true,
    "experimentalDecorators": false,
    "esModuleInterop": true,
    "allowSyntheticDefaultImports": true,
    "target": "es6",
    "strict": true,
    "noImplicitAny": true,
    "strictNullChecks": true,
    "strictFunctionTypes": true,
    "strictPropertyInitialization": true,
    "noImplicitThis": true,
    "alwaysStrict": true,
    "noUnusedLocals": false,
    "noUnusedParameters": true,
    "noImplicitReturns": true,
    "noFallthroughCasesInSwitch": true,
    "module": "commonjs",
    "moduleResolution": "node",
    "sourceMap": true,
    "useUnknownInCatchVariables": false,
    "noUncheckedIndexedAccess": true,
    "emitDecoratorMetadata": false,
    "importHelpers": false,
    "skipLibCheck": true,
    "skipDefaultLibCheck": true,
    "allowJs": true,
    "outDir": "./dist"
  },
  "include": ["src"],
  "exclude": [
    "./tests","node_modules", "lib", "types"]
} 

.env

TELEGRAM_BOT_TOKEN="Token"
ETH_PROJECT_ID="ID"

and /src folder with two files:

first for bot implemetation

bot.ts

import TelegramBot from 'node-telegram-bot-api';
import * as process from 'process';

const token = process.env.TELEGRAM_BOT_TOKEN!;

export const bot = new TelegramBot(token, { polling: true });

and second for signClient usage with Node.js

main.ts

import dotenv from 'dotenv';
dotenv.config();

import { bot } from './bot';
import QRCode from 'qrcode';
import SignClient from '@walletconnect/sign-client';


bot.on('message', async msg => {
  const chatId = msg.chat.id;
  const projectId = process.env.ETH_PROJECT_ID!;

  const signClient = await SignClient.init({
    projectId,    
    metadata: {
      name: 'Example Dapp',
      description: 'Example Dapp',
      url: '#',
      icons: ['https://walletconnect.com/walletconnect-logo.png']
    }
  });

  try {
    const { uri, approval } = await signClient.connect({
      requiredNamespaces: {
        eip155: {
          methods: [
            'eth_sendTransaction',
            'eth_signTransaction',
            'eth_sign',
            'eth_getTransactionReceipt'
          ],
          chains: ['eip155:84532'],
          events: ['chainChanged', 'accountsChanged']
        }
      }
    });

    if (uri) {
      const image = await QRCode.toBuffer(uri);
      const botMessage = await bot.sendPhoto(chatId, image);

      const session = await approval();

      const [account] = session.namespaces.eip155!.accounts;
      if (account === undefined) {
        bot.deleteMessage(chatId, botMessage.message_id);
        console.log("no account in walletConnect session");
        await bot.sendMessage(chatId, `No account in walletConnect session `);
        return;
      }

      console.log("account: ", account);
    }
  } catch (e) {
    console.error(e)
  }
}); 

I use

npm i
npm run compile
npm run start

Everything is compiling and starting well. I send a message to the bot and it is replying me with the QRcode that I am using with Metamask to connect to BASE Sepolia network. Console is logging my Metamask address and even more, if I send some requests with the connection, they all working well, but not for a long time. Even on this MRE Bot crashes after about 2 minutes of working fine
with ./node_modules/@walletconnect/core/dist/index.cjs.js:1

TypeError: i.terminate is not a function
    at Timeout._onTimeout (/home/gorub/Documents/TONProjects/Novikov/MintBot/min/node_modules/@walletconnect/core/dist/index.cjs.js:1:41151)
    at listOnTimeout (node:internal/timers:594:17)
    at process.processTimers (node:internal/timers:529:7)

Here I provide all the console output

> [email protected] start
> node ./dist/main.js

(node:13755) [DEP0040] DeprecationWarning: The `punycode` module is deprecated. Please use a userland alternative instead.
(Use `node --trace-deprecation ...` to show where the warning was created)
(node:13755) [node-telegram-bot-api] DeprecationWarning: Buffers will have their filenames default to "filename" instead of "data". See https://github.com/yagop/node-telegram-bot-api/blob/master/doc/usage.md#sending-files for more information on how sending files has been improved and on how to disable this deprecation message altogether.
(node:13755) [DEP0044] DeprecationWarning: The `util.isArray` API is deprecated. Please use `Array.isArray()` instead.
account:  eip155:84532:0xcd5acea374cd26ee5ccde225c1446d72036e21a3
/home/../min/node_modules/@walletconnect/core/dist/index.cjs.js:1
"use strict";Object.defineProperty(exports,"__esModule",{value:!0});var $=require("events"),k=require("@walletconnect/heartbeat"),$t=require("@walletconnect/keyvaluestorage"),y=require("@walletconnect/logger"),N=require("@walletconnect/types"),u=require("@walletconnect/time"),te=require("@walletconnect/safe-json"),ie=require("@walletconnect/relay-auth"),c=require("@walletconnect/utils"),Vt=require("uint8arrays"),kt=require("@walletconnect/jsonrpc-provider"),I=require("@walletconnect/jsonrpc-utils"),Bt=require("@walletconnect/jsonrpc-ws-connection"),Kt=require("lodash.isequal"),jt=require("@walletconnect/window-getters");function X(o){return o&&typeof o=="object"&&"default"in o?o:{default:o}}function qt(o){if(o&&o.__esModule)return o;var e=Object.create(null);return o&&Object.keys(o).forEach(function(t){if(t!=="default"){var s=Object.getOwnPropertyDescriptor(o,t);Object.defineProperty(e,t,s.get?s:{enumerable:!0,get:function(){return o[t]}})}}),e.default=o,Object.freeze(e)}var Yt=X($),Gt=X($t),W=qt(ie),Ht=X(Bt),Jt=X(Kt);const se="wc",re=2,j="core",x=`${se}@2:${j}:`,ge={name:j,logger:"error"},pe={database:":memory:"},ye="crypto",ne="client_ed25519_seed",Ee=u.ONE_DAY,De="keychain",_e="0.3",me="messages",be="0.3",oe=u.SIX_HOURS,ve="publisher",fe="irn",we="error",ae="wss://relay.walletconnect.org",Te="relayer",f={message:"relayer_message",message_ack:"relayer_message_ack",connect:"relayer_connect",disconnect:"relayer_disconnect",error:"relayer_error",connection_stalled:"relayer_connection_stalled",transport_closed:"relayer_transport_closed",publish:"relayer_publish"},Ie="_subscription",C={payload:"payload",connect:"connect",disconnect:"disconnect",error:"error"},Re=.1,Xt={database:":memory:"},Z="2.17.3",Wt=1e4,V={link_mode:"link_mode",relay:"relay"},Ce="0.3",Se="WALLETCONNECT_CLIENT_ID",ce="WALLETCONNECT_LINK_MODE_APPS",R={created:"subscription_created",deleted:"subscription_deleted",expired:"subscription_expired",disabled:"subscription_disabled",sync:"subscription_sync",resubscribed:"subscription_resubscribed"},Zt=u.THIRTY_DAYS,Pe="subscription",Oe="0.3",Ae=u.FIVE_SECONDS*1e3,Ne="pairing",xe="0.3",Qt=u.THIRTY_DAYS,B={wc_pairingDelete:{req:{ttl:u.ONE_DAY,prompt:!1,tag:1e3},res:{ttl:u.ONE_DAY,prompt:!1,tag:1001}},wc_pairingPing:{req:{ttl:u.THIRTY_SECONDS,prompt:!1,tag:1002},res:{ttl:u.THIRTY_SECONDS,prompt:!1,tag:1003}},unregistered_method:{req:{ttl:u.ONE_DAY,prompt:!1,tag:0},res:{ttl:u.ONE_DAY,prompt:!1,tag:0}}},K={create:"pairing_create",expire:"pairing_expire",delete:"pairing_delete",ping:"pairing_ping"},P={created:"history_created",updated:"history_updated",deleted:"history_deleted",sync:"history_sync"},Le="history",Ue="0.3",ze="expirer",O={created:"expirer_created",deleted:"expirer_deleted",expired:"expirer_expired",sync:"expirer_sync"},Me="0.3",ei=u.ONE_DAY,Fe="verify-api",ti="https://verify.walletconnect.com",$e="https://verify.walletconnect.org",q=$e,Ve=`${q}/v3`,ke=[ti,$e],Be="echo",Ke="https://echo.walletconnect.com",ii="event-client",U={pairing_started:"pairing_started",pairing_uri_validation_success:"pairing_uri_validation_success",pairing_uri_not_expired:"pairing_uri_not_expired",store_new_pairing:"store_new_pairing",subscribing_pairing_topic:"subscribing_pairing_topic",subscribe_pairing_topic_success:"subscribe_pairing_topic_success",existing_pairing:"existing_pairing",pairing_not_expired:"pairing_not_expired",emit_inactive_pairing:"emit_inactive_pairing",emit_session_proposal:"emit_session_proposal",subscribing_to_pairing_topic:"subscribing_to_pairing_topic"},M={no_wss_connection:"no_wss_connection",no_internet_connection:"no_internet_connection",malformed_pairing_uri:"malformed_pairing_uri",active_pairing_already_exists:"active_pairing_already_exists",subscribe_pairing_topic_failure:"subscribe_pairing_topic_failure",pairing_expired:"pairing_expired",proposal_expired:"proposal_expired",proposal_listener_not_found:"proposal_listener_not_found"},si={session_approve_started:"session_approve_started",proposal_not_expired:"proposal_not_expired",session_namespaces_validation_success:"session_namespaces_validation_success",create_session_topic:"create_session_topic",subscribing_session_topic:"subscribing_session_topic",subscribe_session_topic_success:"subscribe_session_topic_success",publishing_session_approve:"publishing_session_approve",session_approve_publish_success:"session_approve_publish_success",store_session:"store_session",publishing_session_settle:"publishing_session_settle",session_settle_publish_success:"session_settle_publish_success"},ri={no_internet_connection:"no_internet_connection",no_wss_connection:"no_wss_connection",proposal_expired:"proposal_expired",subscribe_session_topic_failure:"subscribe_session_topic_failure",session_approve_publish_failure:"session_approve_publish_failure",session_settle_publish_failure:"session_settle_publish_failure",session_approve_namespace_validation_failure:"session_approve_namespace_validation_failure",proposal_not_found:"proposal_not_found"},ni={authenticated_session_approve_started:"authenticated_session_approve_started",authenticated_session_not_expired:"authenticated_session_not_expired",chains_caip2_compliant:"chains_caip2_compliant",chains_evm_compliant:"chains_evm_compliant",create_authenticated_session_topic:"create_authenticated_session_topic",cacaos_verified:"cacaos_verified",store_authenticated_session:"store_authenticated_session",subscribing_authenticated_session_topic:"subscribing_authenticated_session_topic",subscribe_authenticated_session_topic_success:"subscribe_authenticated_session_topic_success",publishing_authenticated_session_approve:"publishing_authenticated_session_approve",authenticated_session_approve_publish_success:"authenticated_session_approve_publish_success"},oi={no_internet_connection:"no_internet_connection",no_wss_connection:"no_wss_connection",missing_session_authenticate_request:"missing_session_authenticate_request",session_authenticate_request_expired:"session_authenticate_request_expired",chains_caip2_compliant_failure:"chains_caip2_compliant_failure",chains_evm_compliant_failure:"chains_evm_compliant_failure",invalid_cacao:"invalid_cacao",subscribe_authenticated_session_topic_failure:"subscribe_authenticated_session_topic_failure",authenticated_session_approve_publish_failure:"authenticated_session_approve_publish_failure",authenticated_session_pending_request_not_found:"authenticated_session_pending_request_not_found"},je=.1,qe="event-client",Ye=86400,Ge="https://pulse.walletconnect.org/batch";function ai(o,e){if(o.length>=255)throw new TypeError("Alphabet too long");for(var t=new Uint8Array(256),s=0;s<t.length;s++)t[s]=255;for(var i=0;i<o.length;i++){var r=o.charAt(i),n=r.charCodeAt(0);if(t[n]!==255)throw new TypeError(r+" is ambiguous");t[n]=i}var a=o.length,h=o.charAt(0),l=Math.log(a)/Math.log(256),g=Math.log(256)/Math.log(a);function p(d){if(d instanceof Uint8Array||(ArrayBuffer.isView(d)?d=new Uint8Array(d.buffer,d.byteOffset,d.byteLength):Array.isArray(d)&&(d=Uint8Array.from(d))),!(d instanceof Uint8Array))throw new TypeError("Expected Uint8Array");if(d.length===0)return"";for(var E=0,T=0,b=0,_=d.length;b!==_&&d[b]===0;)b++,E++;for(var S=(_-b)*g+1>>>0,v=new Uint8Array(S);b!==_;){for(var L=d[b],F=0,A=S-1;(L!==0||F<T)&&A!==-1;A--,F++)L+=256*v[A]>>>0,v[A]=L%a>>>0,L=L/a>>>0;if(L!==0)throw new Error("Non-zero carry");T=F,b++}for(var z=S-T;z!==S&&v[z]===0;)z++;for(var J=h.repeat(E);z<S;++z)J+=o.charAt(v[z]);return J}function D(d){if(typeof d!="string")throw new TypeError("Expected String");if(d.length===0)return new Uint8Array;var E=0;if(d[E]!==" "){for(var T=0,b=0;d[E]===h;)T++,E++;for(var _=(d.length-E)*l+1>>>0,S=new Uint8Array(_);d[E];){var v=t[d.charCodeAt(E)];if(v===255)return;for(var L=0,F=_-1;(v!==0||L<b)&&F!==-1;F--,L++)v+=a*S[F]>>>0,S[F]=v%256>>>0,v=v/256>>>0;if(v!==0)throw new Error("Non-zero carry");b=L,E++}if(d[E]!==" "){for(var A=_-b;A!==_&&S[A]===0;)A++;for(var z=new Uint8Array(T+(_-A)),J=T;A!==_;)z[J++]=S[A++];return z}}}function m(d){var E=D(d);if(E)return E;throw new Error(`Non-${e} character`)}return{encode:p,decodeUnsafe:D,decode:m}}var ci=ai,hi=ci;const He=o=>{if(o instanceof Uint8Array&&o.constructor.name==="Uint8Array")return o;if(o instanceof ArrayBuffer)return new Uint8Array(o);if(ArrayBuffer.isView(o))return new Uint8Array(o.buffer,o.byteOffset,o.byteLength);throw new Error("Unknown type, must be binary type")},li=o=>new TextEncoder().encode(o),ui=o=>new TextDecoder().decode(o);class di{constructor(e,t,s){this.name=e,this.prefix=t,this.baseEncode=s}encode(e){if(e instanceof Uint8Array)return`${this.prefix}${this.baseEncode(e)}`;throw Error("Unknown type, must be binary type")}}class gi{constructor(e,t,s){if(this.name=e,this.prefix=t,t.codePointAt(0)===void 0)throw new Error("Invalid prefix character");this.prefixCodePoint=t.codePointAt(0),this.baseDecode=s}decode(e){if(typeof e=="string"){if(e.codePointAt(0)!==this.prefixCodePoint)throw Error(`Unable to decode multibase string ${JSON.stringify(e)}, ${this.name} decoder only supports inputs prefixed with ${this.prefix}`);return this.baseDecode(e.slice(this.prefix.length))}else throw Error("Can only multibase decode strings")}or(e){return Je(this,e)}}class pi{constructor(e){this.decoders=e}or(e){return Je(this,e)}decode(e){const t=e[0],s=this.decoders[t];if(s)return s.decode(e);throw RangeError(`Unable to decode multibase string ${JSON.stringify(e)}, only inputs prefixed with ${Object.keys(this.decoders)} are supported`)}}const Je=(o,e)=>new pi({...o.decoders||{[o.prefix]:o},...e.decoders||{[e.prefix]:e}});class yi{constructor(e,t,s,i){this.name=e,this.prefix=t,this.baseEncode=s,this.baseDecode=i,this.encoder=new di(e,t,s),this.decoder=new gi(e,t,i)}encode(e){return this.encoder.encode(e)}decode(e){return this.decoder.decode(e)}}const Q=({name:o,prefix:e,encode:t,decode:s})=>new yi(o,e,t,s),Y=({prefix:o,name:e,alphabet:t})=>{const{encode:s,decode:i}=hi(t,e);return Q({prefix:o,name:e,encode:s,decode:r=>He(i(r))})},Ei=(o,e,t,s)=>{const i={};for(let g=0;g<e.length;++g)i[e[g]]=g;let r=o.length;for(;o[r-1]==="=";)--r;const n=new Uint8Array(r*t/8|0);let a=0,h=0,l=0;for(let g=0;g<r;++g){const p=i[o[g]];if(p===void 0)throw new SyntaxError(`Non-${s} character`);h=h<<t|p,a+=t,a>=8&&(a-=8,n[l++]=255&h>>a)}if(a>=t||255&h<<8-a)throw new SyntaxError("Unexpected end of data");return n},Di=(o,e,t)=>{const s=e[e.length-1]==="=",i=(1<<t)-1;let r="",n=0,a=0;for(let h=0;h<o.length;++h)for(a=a<<8|o[h],n+=8;n>t;)n-=t,r+=e[i&a>>n];if(n&&(r+=e[i&a<<t-n]),s)for(;r.length*t&7;)r+="=";return r},w=({name:o,prefix:e,bitsPerChar:t,alphabet:s})=>Q({prefix:e,name:o,encode(i){return Di(i,s,t)},decode(i){return Ei(i,s,t,o)}}),_i=Q({prefix:"\0",name:"identity",encode:o=>ui(o),decode:o=>li(o)});var mi=Object.freeze({__proto__:null,identity:_i});const bi=w({prefix:"0",name:"base2",alphabet:"01",bitsPerChar:1});var vi=Object.freeze({__proto__:null,base2:bi});const fi=w({prefix:"7",name:"base8",alphabet:"01234567",bitsPerChar:3});var wi=Object.freeze({__proto__:null,base8:fi});const Ti=Y({prefix:"9",name:"base10",alphabet:"0123456789"});var Ii=Object.freeze({__proto__:null,base10:Ti});const Ri=w({prefix:"f",name:"base16",alphabet:"0123456789abcdef",bitsPerChar:4}),Ci=w({prefix:"F",name:"base16upper",alphabet:"0123456789ABCDEF",bitsPerChar:4});var Si=Object.freeze({__proto__:null,base16:Ri,base16upper:Ci});const Pi=w({prefix:"b",name:"base32",alphabet:"abcdefghijklmnopqrstuvwxyz234567",bitsPerChar:5}),Oi=w({prefix:"B",name:"base32upper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567",bitsPerChar:5}),Ai=w({prefix:"c",name:"base32pad",alphabet:"abcdefghijklmnopqrstuvwxyz234567=",bitsPerChar:5}),Ni=w({prefix:"C",name:"base32padupper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567=",bitsPerChar:5}),xi=w({prefix:"v",name:"base32hex",alphabet:"0123456789abcdefghijklmnopqrstuv",bitsPerChar:5}),Li=w({prefix:"V",name:"base32hexupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV",bitsPerChar:5}),Ui=w({prefix:"t",name:"base32hexpad",alphabet:"0123456789abcdefghijklmnopqrstuv=",bitsPerChar:5}),zi=w({prefix:"T",name:"base32hexpadupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV=",bitsPerChar:5}),Mi=w({prefix:"h",name:"base32z",alphabet:"ybndrfg8ejkmcpqxot1uwisza345h769",bitsPerChar:5});var Fi=Object.freeze({__proto__:null,base32:Pi,base32upper:Oi,base32pad:Ai,base32padupper:Ni,base32hex:xi,base32hexupper:Li,base32hexpad:Ui,base32hexpadupper:zi,base32z:Mi});const $i=Y({prefix:"k",name:"base36",alphabet:"0123456789abcdefghijklmnopqrstuvwxyz"}),Vi=Y({prefix:"K",name:"base36upper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ"});var ki=Object.freeze({__proto__:null,base36:$i,base36upper:Vi});const Bi=Y({name:"base58btc",prefix:"z",alphabet:"123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz"}),Ki=Y({name:"base58flickr",prefix:"Z",alphabet:"123456789abcdefghijkmnopqrstuvwxyzABCDEFGHJKLMNPQRSTUVWXYZ"});var ji=Object.freeze({__proto__:null,base58btc:Bi,base58flickr:Ki});const qi=w({prefix:"m",name:"base64",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",bitsPerChar:6}),Yi=w({prefix:"M",name:"base64pad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",bitsPerChar:6}),Gi=w({prefix:"u",name:"base64url",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_",bitsPerChar:6}),Hi=w({prefix:"U",name:"base64urlpad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_=",bitsPerChar:6});var Ji=Object.freeze({__proto__:null,base64:qi,base64pad:Yi,base64url:Gi,base64urlpad:Hi});const Xe=Array.from("\u{1F680}\u{1FA90}\u2604\u{1F6F0}\u{1F30C}\u{1F311}\u{1F312}\u{1F313}\u{1F314}\u{1F315}\u{1F316}\u{1F317}\u{1F318}\u{1F30D}\u{1F30F}\u{1F30E}\u{1F409}\u2600\u{1F4BB}\u{1F5A5}\u{1F4BE}\u{1F4BF}\u{1F602}\u2764\u{1F60D}\u{1F923}\u{1F60A}\u{1F64F}\u{1F495}\u{1F62D}\u{1F618}\u{1F44D}\u{1F605}\u{1F44F}\u{1F601}\u{1F525}\u{1F970}\u{1F494}\u{1F496}\u{1F499}\u{1F622}\u{1F914}\u{1F606}\u{1F644}\u{1F4AA}\u{1F609}\u263A\u{1F44C}\u{1F917}\u{1F49C}\u{1F614}\u{1F60E}\u{1F607}\u{1F339}\u{1F926}\u{1F389}\u{1F49E}\u270C\u2728\u{1F937}\u{1F631}\u{1F60C}\u{1F338}\u{1F64C}\u{1F60B}\u{1F497}\u{1F49A}\u{1F60F}\u{1F49B}\u{1F642}\u{1F493}\u{1F929}\u{1F604}\u{1F600}\u{1F5A4}\u{1F603}\u{1F4AF}\u{1F648}\u{1F447}\u{1F3B6}\u{1F612}\u{1F92D}\u2763\u{1F61C}\u{1F48B}\u{1F440}\u{1F62A}\u{1F611}\u{1F4A5}\u{1F64B}\u{1F61E}\u{1F629}\u{1F621}\u{1F92A}\u{1F44A}\u{1F973}\u{1F625}\u{1F924}\u{1F449}\u{1F483}\u{1F633}\u270B\u{1F61A}\u{1F61D}\u{1F634}\u{1F31F}\u{1F62C}\u{1F643}\u{1F340}\u{1F337}\u{1F63B}\u{1F613}\u2B50\u2705\u{1F97A}\u{1F308}\u{1F608}\u{1F918}\u{1F4A6}\u2714\u{1F623}\u{1F3C3}\u{1F490}\u2639\u{1F38A}\u{1F498}\u{1F620}\u261D\u{1F615}\u{1F33A}\u{1F382}\u{1F33B}\u{1F610}\u{1F595}\u{1F49D}\u{1F64A}\u{1F639}\u{1F5E3}\u{1F4AB}\u{1F480}\u{1F451}\u{1F3B5}\u{1F91E}\u{1F61B}\u{1F534}\u{1F624}\u{1F33C}\u{1F62B}\u26BD\u{1F919}\u2615\u{1F3C6}\u{1F92B}\u{1F448}\u{1F62E}\u{1F646}\u{1F37B}\u{1F343}\u{1F436}\u{1F481}\u{1F632}\u{1F33F}\u{1F9E1}\u{1F381}\u26A1\u{1F31E}\u{1F388}\u274C\u270A\u{1F44B}\u{1F630}\u{1F928}\u{1F636}\u{1F91D}\u{1F6B6}\u{1F4B0}\u{1F353}\u{1F4A2}\u{1F91F}\u{1F641}\u{1F6A8}\u{1F4A8}\u{1F92C}\u2708\u{1F380}\u{1F37A}\u{1F913}\u{1F619}\u{1F49F}\u{1F331}\u{1F616}\u{1F476}\u{1F974}\u25B6\u27A1\u2753\u{1F48E}\u{1F4B8}\u2B07\u{1F628}\u{1F31A}\u{1F98B}\u{1F637}\u{1F57A}\u26A0\u{1F645}\u{1F61F}\u{1F635}\u{1F44E}\u{1F932}\u{1F920}\u{1F927}\u{1F4CC}\u{1F535}\u{1F485}\u{1F9D0}\u{1F43E}\u{1F352}\u{1F617}\u{1F911}\u{1F30A}\u{1F92F}\u{1F437}\u260E\u{1F4A7}\u{1F62F}\u{1F486}\u{1F446}\u{1F3A4}\u{1F647}\u{1F351}\u2744\u{1F334}\u{1F4A3}\u{1F438}\u{1F48C}\u{1F4CD}\u{1F940}\u{1F922}\u{1F445}\u{1F4A1}\u{1F4A9}\u{1F450}\u{1F4F8}\u{1F47B}\u{1F910}\u{1F92E}\u{1F3BC}\u{1F975}\u{1F6A9}\u{1F34E}\u{1F34A}\u{1F47C}\u{1F48D}\u{1F4E3}\u{1F942}"),Xi=Xe.reduce((o,e,t)=>(o[t]=e,o),[]),Wi=Xe.reduce((o,e,t)=>(o[e.codePointAt(0)]=t,o),[]);function Zi(o){return o.reduce((e,t)=>(e+=Xi[t],e),"")}function Qi(o){const e=[];for(const t of o){const s=Wi[t.codePointAt(0)];if(s===void 0)throw new Error(`Non-base256emoji character: ${t}`);e.push(s)}return new Uint8Array(e)}const es=Q({prefix:"\u{1F680}",name:"base256emoji",encode:Zi,decode:Qi});var ts=Object.freeze({__proto__:null,base256emoji:es}),is=Ze,We=128,ss=127,rs=~ss,ns=Math.pow(2,31);function Ze(o,e,t){e=e||[],t=t||0;for(var s=t;o>=ns;)e[t++]=o&255|We,o/=128;for(;o&rs;)e[t++]=o&255|We,o>>>=7;return e[t]=o|0,Ze.bytes=t-s+1,e}var os=he,as=128,Qe=127;function he(o,s){var t=0,s=s||0,i=0,r=s,n,a=o.length;do{if(r>=a)throw he.bytes=0,new RangeError("Could not decode varint");n=o[r++],t+=i<28?(n&Qe)<<i:(n&Qe)*Math.pow(2,i),i+=7}while(n>=as);return he.bytes=r-s,t}var cs=Math.pow(2,7),hs=Math.pow(2,14),ls=Math.pow(2,21),us=Math.pow(2,28),ds=Math.pow(2,35),gs=Math.pow(2,42),ps=Math.pow(2,49),ys=Math.pow(2,56),Es=Math.pow(2,63),Ds=function(o){return o<cs?1:o<hs?2:o<ls?3:o<us?4:o<ds?5:o<gs?6:o<ps?7:o<ys?8:o<Es?9:10},_s={encode:is,decode:os,encodingLength:Ds},et=_s;const tt=(o,e,t=0)=>(et.encode(o,e,t),e),it=o=>et.encodingLength(o),le=(o,e)=>{const t=e.byteLength,s=it(o),i=s+it(t),r=new Uint8Array(i+t);return tt(o,r,0),tt(t,r,s),r.set(e,i),new ms(o,t,e,r)};class ms{constructor(e,t,s,i){this.code=e,this.size=t,this.digest=s,this.bytes=i}}const st=({name:o,code:e,encode:t})=>new bs(o,e,t);class bs{constructor(e,t,s){this.name=e,this.code=t,this.encode=s}digest(e){if(e instanceof Uint8Array){const t=this.encode(e);return t instanceof Uint8Array?le(this.code,t):t.then(s=>le(this.code,s))}else throw Error("Unknown type, must be binary type")}}const rt=o=>async e=>new Uint8Array(await crypto.subtle.digest(o,e)),vs=st({name:"sha2-256",code:18,encode:rt("SHA-256")}),fs=st({name:"sha2-512",code:19,encode:rt("SHA-512")});var ws=Object.freeze({__proto__:null,sha256:vs,sha512:fs});const nt=0,Ts="identity",ot=He,Is=o=>le(nt,ot(o)),Rs={code:nt,name:Ts,encode:ot,digest:Is};var Cs=Object.freeze({__proto__:null,identity:Rs});new TextEncoder,new TextDecoder;const at={...mi,...vi,...wi,...Ii,...Si,...Fi,...ki,...ji,...Ji,...ts};({...ws,...Cs});function Ss(o=0){return globalThis.Buffer!=null&&globalThis.Buffer.allocUnsafe!=null?globalThis.Buffer.allocUnsafe(o):new Uint8Array(o)}function ct(o,e,t,s){return{name:o,prefix:e,encoder:{name:o,prefix:e,encode:t},decoder:{decode:s}}}const ht=ct("utf8","u",o=>"u"+new TextDecoder("utf8").decode(o),o=>new TextEncoder().encode(o.substring(1))),ue=ct("ascii","a",o=>{let e="a";for(let t=0;t<o.length;t++)e+=String.fromCharCode(o[t]);return e},o=>{o=o.substring(1);const e=Ss(o.length);for(let t=0;t<o.length;t++)e[t]=o.charCodeAt(t);return e}),Ps={utf8:ht,"utf-8":ht,hex:at.base16,latin1:ue,ascii:ue,binary:ue,...at};function Os(o,e="utf8"){const t=Ps[e];if(!t)throw new Error(`Unsupported encoding "${e}"`);return(e==="utf8"||e==="utf-8")&&globalThis.Buffer!=null&&globalThis.Buffer.from!=null?globalThis.Buffer.from(o,"utf8"):t.decoder.decode(`${t.prefix}${o}`)}class lt{constructor(e,t){this.core=e,this.logger=t,this.keychain=new Map,this.name=De,this.version=_e,this.initialized=!1,this.storagePrefix=x,this.init=async()=>{if(!this.initialized){const s=await this.getKeyChain();typeof s<"u"&&(this.keychain=s),this.initialized=!0}},this.has=s=>(this.isInitialized(),this.keychain.has(s)),this.set=async(s,i)=>{this.isInitialized(),this.keychain.set(s,i),await this.persist()},this.get=s=>{this.isInitialized();const i=this.keychain.get(s);if(typeof i>"u"){const{message:r}=c.getInternalError("NO_MATCHING_KEY",`${this.name}: ${s}`);throw new Error(r)}return i},this.del=async s=>{this.isInitialized(),this.keychain.delete(s),await this.persist()},this.core=e,this.logger=y.generateChildLogger(t,this.name)}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//"+this.name}async setKeyChain(e){await this.core.storage.setItem(this.storageKey,c.mapToObj(e))}async getKeyChain(){const e=await this.core.storage.getItem(this.storageKey);return typeof e<"u"?c.objToMap(e):void 0}async persist(){await this.setKeyChain(this.keychain)}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}class ut{constructor(e,t,s){this.core=e,this.logger=t,this.name=ye,this.randomSessionIdentifier=c.generateRandomBytes32(),this.initialized=!1,this.init=async()=>{this.initialized||(await this.keychain.init(),this.initialized=!0)},this.hasKeys=i=>(this.isInitialized(),this.keychain.has(i)),this.getClientId=async()=>{this.isInitialized();const i=await this.getClientSeed(),r=W.generateKeyPair(i);return W.encodeIss(r.publicKey)},this.generateKeyPair=()=>{this.isInitialized();const i=c.generateKeyPair();return this.setPrivateKey(i.publicKey,i.privateKey)},this.signJWT=async i=>{this.isInitialized();const r=await this.getClientSeed(),n=W.generateKeyPair(r),a=this.randomSessionIdentifier,h=Ee;return await W.signJWT(a,i,h,n)},this.generateSharedKey=(i,r,n)=>{this.isInitialized();const a=this.getPrivateKey(i),h=c.deriveSymKey(a,r);return this.setSymKey(h,n)},this.setSymKey=async(i,r)=>{this.isInitialized();const n=r||c.hashKey(i);return await this.keychain.set(n,i),n},this.deleteKeyPair=async i=>{this.isInitialized(),await this.keychain.del(i)},this.deleteSymKey=async i=>{this.isInitialized(),await this.keychain.del(i)},this.encode=async(i,r,n)=>{this.isInitialized();const a=c.validateEncoding(n),h=te.safeJsonStringify(r);if(c.isTypeTwoEnvelope(a))return c.encodeTypeTwoEnvelope(h,n?.encoding);if(c.isTypeOneEnvelope(a)){const D=a.senderPublicKey,m=a.receiverPublicKey;i=await this.generateSharedKey(D,m)}const l=this.getSymKey(i),{type:g,senderPublicKey:p}=a;return c.encrypt({type:g,symKey:l,message:h,senderPublicKey:p,encoding:n?.encoding})},this.decode=async(i,r,n)=>{this.isInitialized();const a=c.validateDecoding(r,n);if(c.isTypeTwoEnvelope(a)){const h=c.decodeTypeTwoEnvelope(r,n?.encoding);return te.safeJsonParse(h)}if(c.isTypeOneEnvelope(a)){const h=a.receiverPublicKey,l=a.senderPublicKey;i=await this.generateSharedKey(h,l)}try{const h=this.getSymKey(i),l=c.decrypt({symKey:h,encoded:r,encoding:n?.encoding});return te.safeJsonParse(l)}catch(h){this.logger.error(`Failed to decode message from topic: '${i}', clientId: '${await this.getClientId()}'`),this.logger.error(h)}},this.getPayloadType=(i,r=c.BASE64)=>{const n=c.deserialize({encoded:i,encoding:r});return c.decodeTypeByte(n.type)},this.getPayloadSenderPublicKey=(i,r=c.BASE64)=>{const n=c.deserialize({encoded:i,encoding:r});return n.senderPublicKey?Vt.toString(n.senderPublicKey,c.BASE16):void 0},this.core=e,this.logger=y.generateChildLogger(t,this.name),this.keychain=s||new lt(this.core,this.logger)}get context(){return y.getLoggerContext(this.logger)}async setPrivateKey(e,t){return await this.keychain.set(e,t),e}getPrivateKey(e){return this.keychain.get(e)}async getClientSeed(){let e="";try{e=this.keychain.get(ne)}catch{e=c.generateRandomBytes32(),await this.keychain.set(ne,e)}return Os(e,"base16")}getSymKey(e){return this.keychain.get(e)}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}class dt extends N.IMessageTracker{constructor(e,t){super(e,t),this.logger=e,this.core=t,this.messages=new Map,this.name=me,this.version=be,this.initialized=!1,this.storagePrefix=x,this.init=async()=>{if(!this.initialized){this.logger.trace("Initialized");try{const s=await this.getRelayerMessages();typeof s<"u"&&(this.messages=s),this.logger.debug(`Successfully Restored records for ${this.name}`),this.logger.trace({type:"method",method:"restore",size:this.messages.size})}catch(s){this.logger.debug(`Failed to Restore records for ${this.name}`),this.logger.error(s)}finally{this.initialized=!0}}},this.set=async(s,i)=>{this.isInitialized();const r=c.hashMessage(i);let n=this.messages.get(s);return typeof n>"u"&&(n={}),typeof n[r]<"u"||(n[r]=i,this.messages.set(s,n),await this.persist()),r},this.get=s=>{this.isInitialized();let i=this.messages.get(s);return typeof i>"u"&&(i={}),i},this.has=(s,i)=>{this.isInitialized();const r=this.get(s),n=c.hashMessage(i);return typeof r[n]<"u"},this.del=async s=>{this.isInitialized(),this.messages.delete(s),await this.persist()},this.logger=y.generateChildLogger(e,this.name),this.core=t}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//"+this.name}async setRelayerMessages(e){await this.core.storage.setItem(this.storageKey,c.mapToObj(e))}async getRelayerMessages(){const e=await this.core.storage.getItem(this.storageKey);return typeof e<"u"?c.objToMap(e):void 0}async persist(){await this.setRelayerMessages(this.messages)}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}var As=Object.defineProperty,Ns=Object.defineProperties,xs=Object.getOwnPropertyDescriptors,gt=Object.getOwnPropertySymbols,Ls=Object.prototype.hasOwnProperty,Us=Object.prototype.propertyIsEnumerable,pt=(o,e,t)=>e in o?As(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,yt=(o,e)=>{for(var t in e||(e={}))Ls.call(e,t)&&pt(o,t,e[t]);if(gt)for(var t of gt(e))Us.call(e,t)&&pt(o,t,e[t]);return o},Et=(o,e)=>Ns(o,xs(e));class zs extends N.IPublisher{constructor(e,t){super(e,t),this.relayer=e,this.logger=t,this.events=new $.EventEmitter,this.name=ve,this.queue=new Map,this.publishTimeout=u.toMiliseconds(u.ONE_MINUTE),this.initialPublishTimeout=u.toMiliseconds(u.ONE_SECOND*15),this.needsTransportRestart=!1,this.publish=async(s,i,r)=>{var n;this.logger.debug("Publishing Payload"),this.logger.trace({type:"method",method:"publish",params:{topic:s,message:i,opts:r}});const a=r?.ttl||oe,h=c.getRelayProtocolName(r),l=r?.prompt||!1,g=r?.tag||0,p=r?.id||I.getBigIntRpcId().toString(),D={topic:s,message:i,opts:{ttl:a,relay:h,prompt:l,tag:g,id:p,attestation:r?.attestation}},m=`Failed to publish payload, please try again. id:${p} tag:${g}`;try{const d=new Promise(async E=>{const T=({id:_})=>{D.opts.id===_&&(this.removeRequestFromQueue(_),this.relayer.events.removeListener(f.publish,T),E(D))};this.relayer.events.on(f.publish,T);const b=c.createExpiringPromise(new Promise((_,S)=>{this.rpcPublish({topic:s,message:i,ttl:a,prompt:l,tag:g,id:p,attestation:r?.attestation}).then(_).catch(v=>{this.logger.warn(v,v?.message),S(v)})}),this.initialPublishTimeout,`Failed initial publish, retrying.... id:${p} tag:${g}`);try{await b,this.events.removeListener(f.publish,T)}catch(_){this.queue.set(p,Et(yt({},D),{attempt:1})),this.logger.warn(_,_?.message)}});this.logger.trace({type:"method",method:"publish",params:{id:p,topic:s,message:i,opts:r}}),await c.createExpiringPromise(d,this.publishTimeout,m)}catch(d){if(this.logger.debug("Failed to Publish Payload"),this.logger.error(d),(n=r?.internal)!=null&&n.throwOnFailedPublish)throw d}finally{this.queue.delete(p)}},this.on=(s,i)=>{this.events.on(s,i)},this.once=(s,i)=>{this.events.once(s,i)},this.off=(s,i)=>{this.events.off(s,i)},this.removeListener=(s,i)=>{this.events.removeListener(s,i)},this.relayer=e,this.logger=y.generateChildLogger(t,this.name),this.registerEventListeners()}get context(){return y.getLoggerContext(this.logger)}async rpcPublish(e){var t,s,i,r;const{topic:n,message:a,ttl:h=oe,prompt:l,tag:g,id:p,attestation:D}=e,m={method:c.getRelayProtocolApi(c.getRelayProtocolName().protocol).publish,params:{topic:n,message:a,ttl:h,prompt:l,tag:g,attestation:D},id:p};c.isUndefined((t=m.params)==null?void 0:t.prompt)&&((s=m.params)==null||delete s.prompt),c.isUndefined((i=m.params)==null?void 0:i.tag)&&((r=m.params)==null||delete r.tag),this.logger.debug("Outgoing Relay Payload"),this.logger.trace({type:"message",direction:"outgoing",request:m});const d=await this.relayer.request(m);return this.relayer.events.emit(f.publish,e),this.logger.debug("Successfully Published Payload"),d}removeRequestFromQueue(e){this.queue.delete(e)}checkQueue(){this.queue.forEach(async(e,t)=>{const s=e.attempt+1;this.queue.set(t,Et(yt({},e),{attempt:s}));const{topic:i,message:r,opts:n,attestation:a}=e;this.logger.warn({},`Publisher: queue->publishing: ${e.opts.id}, tag: ${e.opts.tag}, attempt: ${s}`),await this.rpcPublish({topic:i,message:r,ttl:n.ttl,prompt:n.prompt,tag:n.tag,id:n.id,attestation:a}),this.logger.warn({},`Publisher: queue->published: ${e.opts.id}`)})}registerEventListeners(){this.relayer.core.heartbeat.on(k.HEARTBEAT_EVENTS.pulse,()=>{if(this.needsTransportRestart){this.needsTransportRestart=!1,this.relayer.events.emit(f.connection_stalled);return}this.checkQueue()}),this.relayer.on(f.message_ack,e=>{this.removeRequestFromQueue(e.id.toString())})}}class Ms{constructor(){this.map=new Map,this.set=(e,t)=>{const s=this.get(e);this.exists(e,t)||this.map.set(e,[...s,t])},this.get=e=>this.map.get(e)||[],this.exists=(e,t)=>this.get(e).includes(t),this.delete=(e,t)=>{if(typeof t>"u"){this.map.delete(e);return}if(!this.map.has(e))return;const s=this.get(e);if(!this.exists(e,t))return;const i=s.filter(r=>r!==t);if(!i.length){this.map.delete(e);return}this.map.set(e,i)},this.clear=()=>{this.map.clear()}}get topics(){return Array.from(this.map.keys())}}var Fs=Object.defineProperty,$s=Object.defineProperties,Vs=Object.getOwnPropertyDescriptors,Dt=Object.getOwnPropertySymbols,ks=Object.prototype.hasOwnProperty,Bs=Object.prototype.propertyIsEnumerable,_t=(o,e,t)=>e in o?Fs(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,G=(o,e)=>{for(var t in e||(e={}))ks.call(e,t)&&_t(o,t,e[t]);if(Dt)for(var t of Dt(e))Bs.call(e,t)&&_t(o,t,e[t]);return o},de=(o,e)=>$s(o,Vs(e));class mt extends N.ISubscriber{constructor(e,t){super(e,t),this.relayer=e,this.logger=t,this.subscriptions=new Map,this.topicMap=new Ms,this.events=new $.EventEmitter,this.name=Pe,this.version=Oe,this.pending=new Map,this.cached=[],this.initialized=!1,this.pendingSubscriptionWatchLabel="pending_sub_watch_label",this.pollingInterval=20,this.storagePrefix=x,this.subscribeTimeout=u.toMiliseconds(u.ONE_MINUTE),this.initialSubscribeTimeout=u.toMiliseconds(u.ONE_SECOND*15),this.batchSubscribeTopicsLimit=500,this.init=async()=>{this.initialized||(this.logger.trace("Initialized"),this.registerEventListeners(),this.clientId=await this.relayer.core.crypto.getClientId(),await this.restore()),this.initialized=!0},this.subscribe=async(s,i)=>{this.isInitialized(),this.logger.debug("Subscribing Topic"),this.logger.trace({type:"method",method:"subscribe",params:{topic:s,opts:i}});try{const r=c.getRelayProtocolName(i),n={topic:s,relay:r,transportType:i?.transportType};this.pending.set(s,n);const a=await this.rpcSubscribe(s,r,i);return typeof a=="string"&&(this.onSubscribe(a,n),this.logger.debug("Successfully Subscribed Topic"),this.logger.trace({type:"method",method:"subscribe",params:{topic:s,opts:i}})),a}catch(r){throw this.logger.debug("Failed to Subscribe Topic"),this.logger.error(r),r}},this.unsubscribe=async(s,i)=>{await this.restartToComplete(),this.isInitialized(),typeof i?.id<"u"?await this.unsubscribeById(s,i.id,i):await this.unsubscribeByTopic(s,i)},this.isSubscribed=async s=>{if(this.topics.includes(s))return!0;const i=`${this.pendingSubscriptionWatchLabel}_${s}`;return await new Promise((r,n)=>{const a=new u.Watch;a.start(i);const h=setInterval(()=>{(!this.pending.has(s)&&this.topics.includes(s)||this.cached.some(l=>l.topic===s))&&(clearInterval(h),a.stop(i),r(!0)),a.elapsed(i)>=Ae&&(clearInterval(h),a.stop(i),n(new Error("Subscription resolution timeout")))},this.pollingInterval)}).catch(()=>!1)},this.on=(s,i)=>{this.events.on(s,i)},this.once=(s,i)=>{this.events.once(s,i)},this.off=(s,i)=>{this.events.off(s,i)},this.removeListener=(s,i)=>{this.events.removeListener(s,i)},this.start=async()=>{await this.onConnect()},this.stop=async()=>{await this.onDisconnect()},this.restart=async()=>{await this.restore(),await this.onRestart()},this.checkPending=async()=>{if(this.pending.size===0&&(!this.initialized||!this.relayer.connected))return;const s=[];this.pending.forEach(i=>{s.push(i)}),await this.batchSubscribe(s)},this.registerEventListeners=()=>{this.relayer.core.heartbeat.on(k.HEARTBEAT_EVENTS.pulse,async()=>{await this.checkPending()}),this.events.on(R.created,async s=>{const i=R.created;this.logger.info(`Emitting ${i}`),this.logger.debug({type:"event",event:i,data:s}),await this.persist()}),this.events.on(R.deleted,async s=>{const i=R.deleted;this.logger.info(`Emitting ${i}`),this.logger.debug({type:"event",event:i,data:s}),await this.persist()})},this.relayer=e,this.logger=y.generateChildLogger(t,this.name),this.clientId=""}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.relayer.core.customStoragePrefix+"//"+this.name}get length(){return this.subscriptions.size}get ids(){return Array.from(this.subscriptions.keys())}get values(){return Array.from(this.subscriptions.values())}get topics(){return this.topicMap.topics}hasSubscription(e,t){let s=!1;try{s=this.getSubscription(e).topic===t}catch{}return s}reset(){this.cached=[],this.initialized=!0}onDisable(){this.cached=this.values,this.subscriptions.clear(),this.topicMap.clear()}async unsubscribeByTopic(e,t){const s=this.topicMap.get(e);await Promise.all(s.map(async i=>await this.unsubscribeById(e,i,t)))}async unsubscribeById(e,t,s){this.logger.debug("Unsubscribing Topic"),this.logger.trace({type:"method",method:"unsubscribe",params:{topic:e,id:t,opts:s}});try{const i=c.getRelayProtocolName(s);await this.rpcUnsubscribe(e,t,i);const r=c.getSdkError("USER_DISCONNECTED",`${this.name}, ${e}`);await this.onUnsubscribe(e,t,r),this.logger.debug("Successfully Unsubscribed Topic"),this.logger.trace({type:"method",method:"unsubscribe",params:{topic:e,id:t,opts:s}})}catch(i){throw this.logger.debug("Failed to Unsubscribe Topic"),this.logger.error(i),i}}async rpcSubscribe(e,t,s){var i;s?.transportType===V.relay&&await this.restartToComplete();const r={method:c.getRelayProtocolApi(t.protocol).subscribe,params:{topic:e}};this.logger.debug("Outgoing Relay Payload"),this.logger.trace({type:"payload",direction:"outgoing",request:r});const n=(i=s?.internal)==null?void 0:i.throwOnFailedPublish;try{const a=this.getSubscriptionId(e);if(s?.transportType===V.link_mode)return setTimeout(()=>{(this.relayer.connected||this.relayer.connecting)&&this.relayer.request(r).catch(g=>this.logger.warn(g))},u.toMiliseconds(u.ONE_SECOND)),a;const h=new Promise(async g=>{const p=D=>{D.topic===e&&(this.events.removeListener(R.created,p),g(D.id))};this.events.on(R.created,p);try{const D=await c.createExpiringPromise(new Promise((m,d)=>{this.relayer.request(r).catch(E=>{this.logger.warn(E,E?.message),d(E)}).then(m)}),this.initialSubscribeTimeout,`Subscribing to ${e} failed, please try again`);this.events.removeListener(R.created,p),g(D)}catch{}}),l=await c.createExpiringPromise(h,this.subscribeTimeout,`Subscribing to ${e} failed, please try again`);if(!l&&n)throw new Error(`Subscribing to ${e} failed, please try again`);return l?a:null}catch(a){if(this.logger.debug("Outgoing Relay Subscribe Payload stalled"),this.relayer.events.emit(f.connection_stalled),n)throw a}return null}async rpcBatchSubscribe(e){if(!e.length)return;const t=e[0].relay,s={method:c.getRelayProtocolApi(t.protocol).batchSubscribe,params:{topics:e.map(i=>i.topic)}};this.logger.debug("Outgoing Relay Payload"),this.logger.trace({type:"payload",direction:"outgoing",request:s});try{await await c.createExpiringPromise(new Promise(i=>{this.relayer.request(s).catch(r=>this.logger.warn(r)).then(i)}),this.subscribeTimeout,"rpcBatchSubscribe failed, please try again")}catch{this.relayer.events.emit(f.connection_stalled)}}async rpcBatchFetchMessages(e){if(!e.length)return;const t=e[0].relay,s={method:c.getRelayProtocolApi(t.protocol).batchFetchMessages,params:{topics:e.map(r=>r.topic)}};this.logger.debug("Outgoing Relay Payload"),this.logger.trace({type:"payload",direction:"outgoing",request:s});let i;try{i=await await c.createExpiringPromise(new Promise((r,n)=>{this.relayer.request(s).catch(a=>{this.logger.warn(a),n(a)}).then(r)}),this.subscribeTimeout,"rpcBatchFetchMessages failed, please try again")}catch{this.relayer.events.emit(f.connection_stalled)}return i}rpcUnsubscribe(e,t,s){const i={method:c.getRelayProtocolApi(s.protocol).unsubscribe,params:{topic:e,id:t}};return this.logger.debug("Outgoing Relay Payload"),this.logger.trace({type:"payload",direction:"outgoing",request:i}),this.relayer.request(i)}onSubscribe(e,t){this.setSubscription(e,de(G({},t),{id:e})),this.pending.delete(t.topic)}onBatchSubscribe(e){e.length&&e.forEach(t=>{this.setSubscription(t.id,G({},t)),this.pending.delete(t.topic)})}async onUnsubscribe(e,t,s){this.events.removeAllListeners(t),this.hasSubscription(t,e)&&this.deleteSubscription(t,s),await this.relayer.messages.del(e)}async setRelayerSubscriptions(e){await this.relayer.core.storage.setItem(this.storageKey,e)}async getRelayerSubscriptions(){return await this.relayer.core.storage.getItem(this.storageKey)}setSubscription(e,t){this.logger.debug("Setting subscription"),this.logger.trace({type:"method",method:"setSubscription",id:e,subscription:t}),this.addSubscription(e,t)}addSubscription(e,t){this.subscriptions.set(e,G({},t)),this.topicMap.set(t.topic,e),this.events.emit(R.created,t)}getSubscription(e){this.logger.debug("Getting subscription"),this.logger.trace({type:"method",method:"getSubscription",id:e});const t=this.subscriptions.get(e);if(!t){const{message:s}=c.getInternalError("NO_MATCHING_KEY",`${this.name}: ${e}`);throw new Error(s)}return t}deleteSubscription(e,t){this.logger.debug("Deleting subscription"),this.logger.trace({type:"method",method:"deleteSubscription",id:e,reason:t});const s=this.getSubscription(e);this.subscriptions.delete(e),this.topicMap.delete(s.topic,e),this.events.emit(R.deleted,de(G({},s),{reason:t}))}async persist(){await this.setRelayerSubscriptions(this.values),this.events.emit(R.sync)}async onRestart(){if(this.cached.length){const e=[...this.cached],t=Math.ceil(this.cached.length/this.batchSubscribeTopicsLimit);for(let s=0;s<t;s++){const i=e.splice(0,this.batchSubscribeTopicsLimit);await this.batchSubscribe(i)}}this.events.emit(R.resubscribed)}async restore(){try{const e=await this.getRelayerSubscriptions();if(typeof e>"u"||!e.length)return;if(this.subscriptions.size){const{message:t}=c.getInternalError("RESTORE_WILL_OVERRIDE",this.name);throw this.logger.error(t),this.logger.error(`${this.name}: ${JSON.stringify(this.values)}`),new Error(t)}this.cached=e,this.logger.debug(`Successfully Restored subscriptions for ${this.name}`),this.logger.trace({type:"method",method:"restore",subscriptions:this.values})}catch(e){this.logger.debug(`Failed to Restore subscriptions for ${this.name}`),this.logger.error(e)}}async batchSubscribe(e){e.length&&(await this.rpcBatchSubscribe(e),this.onBatchSubscribe(e.map(t=>de(G({},t),{id:this.getSubscriptionId(t.topic)}))))}async batchFetchMessages(e){if(!e.length)return;this.logger.trace(`Fetching batch messages for ${e.length} subscriptions`);const t=await this.rpcBatchFetchMessages(e);t&&t.messages&&(await c.sleep(u.toMiliseconds(u.ONE_SECOND)),await this.relayer.handleBatchMessageEvents(t.messages))}async onConnect(){await this.restart(),this.reset()}onDisconnect(){this.onDisable()}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}async restartToComplete(){!this.relayer.connected&&!this.relayer.connecting&&await this.relayer.transportOpen()}getSubscriptionId(e){return c.hashMessage(e+this.clientId)}}var Ks=Object.defineProperty,bt=Object.getOwnPropertySymbols,js=Object.prototype.hasOwnProperty,qs=Object.prototype.propertyIsEnumerable,vt=(o,e,t)=>e in o?Ks(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,ft=(o,e)=>{for(var t in e||(e={}))js.call(e,t)&&vt(o,t,e[t]);if(bt)for(var t of bt(e))qs.call(e,t)&&vt(o,t,e[t]);return o};class wt extends N.IRelayer{constructor(e){super(e),this.protocol="wc",this.version=2,this.events=new $.EventEmitter,this.name=Te,this.transportExplicitlyClosed=!1,this.initialized=!1,this.connectionAttemptInProgress=!1,this.hasExperiencedNetworkDisruption=!1,this.heartBeatTimeout=u.toMiliseconds(u.THIRTY_SECONDS+u.FIVE_SECONDS),this.requestsInFlight=[],this.connectTimeout=u.toMiliseconds(u.ONE_SECOND*15),this.request=async t=>{var s,i;this.logger.debug("Publishing Request Payload");const r=t.id||I.getBigIntRpcId().toString();await this.toEstablishConnection();try{this.logger.trace({id:r,method:t.method,topic:(s=t.params)==null?void 0:s.topic},"relayer.request - publishing...");const n=`${r}:${((i=t.params)==null?void 0:i.tag)||""}`;this.requestsInFlight.push(n);const a=await this.provider.request(t);return this.requestsInFlight=this.requestsInFlight.filter(h=>h!==n),a}catch(n){throw this.logger.debug(`Failed to Publish Request: ${r}`),n}},this.resetPingTimeout=()=>{if(c.isNode())try{clearTimeout(this.pingTimeout),this.pingTimeout=setTimeout(()=>{var t,s,i;this.logger.debug({},"pingTimeout: Connection stalled, terminating..."),(i=(s=(t=this.provider)==null?void 0:t.connection)==null?void 0:s.socket)==null||i.terminate()},this.heartBeatTimeout)}catch(t){this.logger.warn(t,t?.message)}},this.onPayloadHandler=t=>{this.onProviderPayload(t),this.resetPingTimeout()},this.onConnectHandler=()=>{this.logger.warn({},"Relayer connected \u{1F6DC}"),this.startPingTimeout(),this.events.emit(f.connect)},this.onDisconnectHandler=()=>{this.logger.warn({},"Relayer disconnected \u{1F6D1}"),this.requestsInFlight=[],this.onProviderDisconnect()},this.onProviderErrorHandler=t=>{this.logger.fatal(t,`Fatal socket error: ${t?.message}`),this.events.emit(f.error,t),this.logger.fatal("Fatal socket error received, closing transport"),this.transportClose()},this.registerProviderListeners=()=>{this.provider.on(C.payload,this.onPayloadHandler),this.provider.on(C.connect,this.onConnectHandler),this.provider.on(C.disconnect,this.onDisconnectHandler),this.provider.on(C.error,this.onProviderErrorHandler)},this.core=e.core,this.logger=typeof e.logger<"u"&&typeof e.logger!="string"?y.generateChildLogger(e.logger,this.name):y.pino(y.getDefaultLoggerOptions({level:e.logger||we})),this.messages=new dt(this.logger,e.core),this.subscriber=new mt(this,this.logger),this.publisher=new zs(this,this.logger),this.relayUrl=e?.relayUrl||ae,this.projectId=e.projectId,c.isAndroid()?this.packageName=c.getAppId():c.isIos()&&(this.bundleId=c.getAppId()),this.provider={}}async init(){if(this.logger.trace("Initialized"),this.registerEventListeners(),await Promise.all([this.messages.init(),this.subscriber.init()]),this.initialized=!0,this.subscriber.cached.length>0)try{await this.transportOpen()}catch(e){this.logger.warn(e,e?.message)}}get context(){return y.getLoggerContext(this.logger)}get connected(){var e,t,s;return((s=(t=(e=this.provider)==null?void 0:e.connection)==null?void 0:t.socket)==null?void 0:s.readyState)===1}get connecting(){var e,t,s;return((s=(t=(e=this.provider)==null?void 0:e.connection)==null?void 0:t.socket)==null?void 0:s.readyState)===0}async publish(e,t,s){this.isInitialized(),await this.publisher.publish(e,t,s),await this.recordMessageEvent({topic:e,message:t,publishedAt:Date.now(),transportType:V.relay})}async subscribe(e,t){var s,i,r;this.isInitialized(),(!(t!=null&&t.transportType)||t?.transportType==="relay")&&await this.toEstablishConnection();const n=typeof((s=t?.internal)==null?void 0:s.throwOnFailedPublish)>"u"?!0:(i=t?.internal)==null?void 0:i.throwOnFailedPublish;let a=((r=this.subscriber.topicMap.get(e))==null?void 0:r[0])||"",h;const l=g=>{g.topic===e&&(this.subscriber.off(R.created,l),h())};return await Promise.all([new Promise(g=>{h=g,this.subscriber.on(R.created,l)}),new Promise(async(g,p)=>{a=await this.subscriber.subscribe(e,ft({internal:{throwOnFailedPublish:n}},t)).catch(D=>{n&&p(D)})||a,g()})]),a}async unsubscribe(e,t){this.isInitialized(),await this.subscriber.unsubscribe(e,t)}on(e,t){this.events.on(e,t)}once(e,t){this.events.once(e,t)}off(e,t){this.events.off(e,t)}removeListener(e,t){this.events.removeListener(e,t)}async transportDisconnect(){this.provider.disconnect&&(this.hasExperiencedNetworkDisruption||this.connected)?await c.createExpiringPromise(this.provider.disconnect(),2e3,"provider.disconnect()").catch(()=>this.onProviderDisconnect()):this.onProviderDisconnect()}async transportClose(){this.transportExplicitlyClosed=!0,await this.transportDisconnect()}async transportOpen(e){if(this.connectPromise?(this.logger.debug({},"Waiting for existing connection attempt to resolve..."),await this.connectPromise,this.logger.debug({},"Existing connection attempt resolved")):(this.connectPromise=new Promise(async(t,s)=>{await this.connect(e).then(t).catch(s).finally(()=>{this.connectPromise=void 0})}),await this.connectPromise),!this.connected)throw new Error(`Couldn't establish socket connection to the relay server: ${this.relayUrl}`)}async restartTransport(e){this.logger.debug({},"Restarting transport..."),!this.connectionAttemptInProgress&&(this.relayUrl=e||this.relayUrl,await this.confirmOnlineStateOrThrow(),await this.transportClose(),await this.transportOpen())}async confirmOnlineStateOrThrow(){if(!await c.isOnline())throw new Error("No internet connection detected. Please restart your network and try again.")}async handleBatchMessageEvents(e){if(e?.length===0){this.logger.trace("Batch message events is empty. Ignoring...");return}const t=e.sort((s,i)=>s.publishedAt-i.publishedAt);this.logger.debug(`Batch of ${t.length} message events sorted`);for(const s of t)try{await this.onMessageEvent(s)}catch(i){this.logger.warn(i,"Error while processing batch message event: "+i?.message)}this.logger.trace(`Batch of ${t.length} message events processed`)}async onLinkMessageEvent(e,t){const{topic:s}=e;if(!t.sessionExists){const i=c.calcExpiry(u.FIVE_MINUTES),r={topic:s,expiry:i,relay:{protocol:"irn"},active:!1};await this.core.pairing.pairings.set(s,r)}this.events.emit(f.message,e),await this.recordMessageEvent(e)}async connect(e){await this.confirmOnlineStateOrThrow(),e&&e!==this.relayUrl&&(this.relayUrl=e,await this.transportDisconnect()),this.connectionAttemptInProgress=!0,this.transportExplicitlyClosed=!1;let t=1;for(;t<6;){try{this.logger.debug({},`Connecting to ${this.relayUrl}, attempt: ${t}...`),await this.createProvider(),await new Promise(async(s,i)=>{const r=()=>{i(new Error("Connection interrupted while trying to subscribe"))};this.provider.once(C.disconnect,r),await c.createExpiringPromise(new Promise((n,a)=>{this.provider.connect().then(n).catch(a)}),this.connectTimeout,`Socket stalled when trying to connect to ${this.relayUrl}`).catch(n=>{i(n)}).finally(()=>{this.provider.off(C.disconnect,r),clearTimeout(this.reconnectTimeout),this.reconnectTimeout=void 0}),await new Promise(async(n,a)=>{const h=()=>{a(new Error("Connection interrupted while trying to subscribe"))};this.provider.once(C.disconnect,h),await this.subscriber.start().then(n).catch(a).finally(()=>{this.provider.off(C.disconnect,h)})}),this.hasExperiencedNetworkDisruption=!1,s()})}catch(s){await this.subscriber.stop();const i=s;this.logger.warn({},i.message),this.hasExperiencedNetworkDisruption=!0}finally{this.connectionAttemptInProgress=!1}if(this.connected){this.logger.debug({},`Connected to ${this.relayUrl} successfully on attempt: ${t}`);break}await new Promise(s=>setTimeout(s,u.toMiliseconds(t*1))),t++}}startPingTimeout(){var e,t,s,i,r;if(c.isNode())try{(t=(e=this.provider)==null?void 0:e.connection)!=null&&t.socket&&((r=(i=(s=this.provider)==null?void 0:s.connection)==null?void 0:i.socket)==null||r.on("ping",()=>{this.resetPingTimeout()})),this.resetPingTimeout()}catch(n){this.logger.warn(n,n?.message)}}async createProvider(){this.provider.connection&&this.unregisterProviderListeners();const e=await this.core.crypto.signJWT(this.relayUrl);this.provider=new kt.JsonRpcProvider(new Ht.default(c.formatRelayRpcUrl({sdkVersion:Z,protocol:this.protocol,version:this.version,relayUrl:this.relayUrl,projectId:this.projectId,auth:e,useOnCloseEvent:!0,bundleId:this.bundleId,packageName:this.packageName}))),this.registerProviderListeners()}async recordMessageEvent(e){const{topic:t,message:s}=e;await this.messages.set(t,s)}async shouldIgnoreMessageEvent(e){const{topic:t,message:s}=e;if(!s||s.length===0)return this.logger.warn(`Ignoring invalid/empty message: ${s}`),!0;if(!await this.subscriber.isSubscribed(t))return this.logger.warn(`Ignoring message for non-subscribed topic ${t}`),!0;const i=this.messages.has(t,s);return i&&this.logger.warn(`Ignoring duplicate message: ${s}`),i}async onProviderPayload(e){if(this.logger.debug("Incoming Relay Payload"),this.logger.trace({type:"payload",direction:"incoming",payload:e}),I.isJsonRpcRequest(e)){if(!e.method.endsWith(Ie))return;const t=e.params,{topic:s,message:i,publishedAt:r,attestation:n}=t.data,a={topic:s,message:i,publishedAt:r,transportType:V.relay,attestation:n};this.logger.debug("Emitting Relayer Payload"),this.logger.trace(ft({type:"event",event:t.id},a)),this.events.emit(t.id,a),await this.acknowledgePayload(e),await this.onMessageEvent(a)}else I.isJsonRpcResponse(e)&&this.events.emit(f.message_ack,e)}async onMessageEvent(e){await this.shouldIgnoreMessageEvent(e)||(this.events.emit(f.message,e),await this.recordMessageEvent(e))}async acknowledgePayload(e){const t=I.formatJsonRpcResult(e.id,!0);await this.provider.connection.send(t)}unregisterProviderListeners(){this.provider.off(C.payload,this.onPayloadHandler),this.provider.off(C.connect,this.onConnectHandler),this.provider.off(C.disconnect,this.onDisconnectHandler),this.provider.off(C.error,this.onProviderErrorHandler),clearTimeout(this.pingTimeout)}async registerEventListeners(){let e=await c.isOnline();c.subscribeToNetworkChange(async t=>{e!==t&&(e=t,t?await this.transportOpen().catch(s=>this.logger.error(s,s?.message)):(this.hasExperiencedNetworkDisruption=!0,await this.transportDisconnect(),this.transportExplicitlyClosed=!1))})}async onProviderDisconnect(){await this.subscriber.stop(),clearTimeout(this.pingTimeout),this.events.emit(f.disconnect),this.connectionAttemptInProgress=!1,!this.transportExplicitlyClosed&&(this.reconnectTimeout||this.connectPromise||(this.reconnectTimeout=setTimeout(async()=>{clearTimeout(this.reconnectTimeout),await this.transportOpen().catch(e=>this.logger.error(e,e?.message))},u.toMiliseconds(Re))))}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}async toEstablishConnection(){await this.confirmOnlineStateOrThrow(),!this.connected&&await this.transportOpen()}}var Ys=Object.defineProperty,Tt=Object.getOwnPropertySymbols,Gs=Object.prototype.hasOwnProperty,Hs=Object.prototype.propertyIsEnumerable,It=(o,e,t)=>e in o?Ys(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,Rt=(o,e)=>{for(var t in e||(e={}))Gs.call(e,t)&&It(o,t,e[t]);if(Tt)for(var t of Tt(e))Hs.call(e,t)&&It(o,t,e[t]);return o};class Ct extends N.IStore{constructor(e,t,s,i=x,r=void 0){super(e,t,s,i),this.core=e,this.logger=t,this.name=s,this.map=new Map,this.version=Ce,this.cached=[],this.initialized=!1,this.storagePrefix=x,this.recentlyDeleted=[],this.recentlyDeletedLimit=200,this.init=async()=>{this.initialized||(this.logger.trace("Initialized"),await this.restore(),this.cached.forEach(n=>{this.getKey&&n!==null&&!c.isUndefined(n)?this.map.set(this.getKey(n),n):c.isProposalStruct(n)?this.map.set(n.id,n):c.isSessionStruct(n)&&this.map.set(n.topic,n)}),this.cached=[],this.initialized=!0)},this.set=async(n,a)=>{this.isInitialized(),this.map.has(n)?await this.update(n,a):(this.logger.debug("Setting value"),this.logger.trace({type:"method",method:"set",key:n,value:a}),this.map.set(n,a),await this.persist())},this.get=n=>(this.isInitialized(),this.logger.debug("Getting value"),this.logger.trace({type:"method",method:"get",key:n}),this.getData(n)),this.getAll=n=>(this.isInitialized(),n?this.values.filter(a=>Object.keys(n).every(h=>Jt.default(a[h],n[h]))):this.values),this.update=async(n,a)=>{this.isInitialized(),this.logger.debug("Updating value"),this.logger.trace({type:"method",method:"update",key:n,update:a});const h=Rt(Rt({},this.getData(n)),a);this.map.set(n,h),await this.persist()},this.delete=async(n,a)=>{this.isInitialized(),this.map.has(n)&&(this.logger.debug("Deleting value"),this.logger.trace({type:"method",method:"delete",key:n,reason:a}),this.map.delete(n),this.addToRecentlyDeleted(n),await this.persist())},this.logger=y.generateChildLogger(t,this.name),this.storagePrefix=i,this.getKey=r}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//"+this.name}get length(){return this.map.size}get keys(){return Array.from(this.map.keys())}get values(){return Array.from(this.map.values())}addToRecentlyDeleted(e){this.recentlyDeleted.push(e),this.recentlyDeleted.length>=this.recentlyDeletedLimit&&this.recentlyDeleted.splice(0,this.recentlyDeletedLimit/2)}async setDataStore(e){await this.core.storage.setItem(this.storageKey,e)}async getDataStore(){return await this.core.storage.getItem(this.storageKey)}getData(e){const t=this.map.get(e);if(!t){if(this.recentlyDeleted.includes(e)){const{message:i}=c.getInternalError("MISSING_OR_INVALID",`Record was recently deleted - ${this.name}: ${e}`);throw this.logger.error(i),new Error(i)}const{message:s}=c.getInternalError("NO_MATCHING_KEY",`${this.name}: ${e}`);throw this.logger.error(s),new Error(s)}return t}async persist(){await this.setDataStore(this.values)}async restore(){try{const e=await this.getDataStore();if(typeof e>"u"||!e.length)return;if(this.map.size){const{message:t}=c.getInternalError("RESTORE_WILL_OVERRIDE",this.name);throw this.logger.error(t),new Error(t)}this.cached=e,this.logger.debug(`Successfully Restored value for ${this.name}`),this.logger.trace({type:"method",method:"restore",value:this.values})}catch(e){this.logger.debug(`Failed to Restore value for ${this.name}`),this.logger.error(e)}}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}class St{constructor(e,t){this.core=e,this.logger=t,this.name=Ne,this.version=xe,this.events=new Yt.default,this.initialized=!1,this.storagePrefix=x,this.ignoredPayloadTypes=[c.TYPE_1],this.registeredMethods=[],this.init=async()=>{this.initialized||(await this.pairings.init(),await this.cleanup(),this.registerRelayerEvents(),this.registerExpirerEvents(),this.initialized=!0,this.logger.trace("Initialized"))},this.register=({methods:s})=>{this.isInitialized(),this.registeredMethods=[...new Set([...this.registeredMethods,...s])]},this.create=async s=>{this.isInitialized();const i=c.generateRandomBytes32(),r=await this.core.crypto.setSymKey(i),n=c.calcExpiry(u.FIVE_MINUTES),a={protocol:fe},h={topic:r,expiry:n,relay:a,active:!1,methods:s?.methods},l=c.formatUri({protocol:this.core.protocol,version:this.core.version,topic:r,symKey:i,relay:a,expiryTimestamp:n,methods:s?.methods});return this.events.emit(K.create,h),this.core.expirer.set(r,n),await this.pairings.set(r,h),await this.core.relayer.subscribe(r,{transportType:s?.transportType}),{topic:r,uri:l}},this.pair=async s=>{this.isInitialized();const i=this.core.eventClient.createEvent({properties:{topic:s?.uri,trace:[U.pairing_started]}});this.isValidPair(s,i);const{topic:r,symKey:n,relay:a,expiryTimestamp:h,methods:l}=c.parseUri(s.uri);i.props.properties.topic=r,i.addTrace(U.pairing_uri_validation_success),i.addTrace(U.pairing_uri_not_expired);let g;if(this.pairings.keys.includes(r)){if(g=this.pairings.get(r),i.addTrace(U.existing_pairing),g.active)throw i.setError(M.active_pairing_already_exists),new Error(`Pairing already exists: ${r}. Please try again with a new connection URI.`);i.addTrace(U.pairing_not_expired)}const p=h||c.calcExpiry(u.FIVE_MINUTES),D={topic:r,relay:a,expiry:p,active:!1,methods:l};this.core.expirer.set(r,p),await this.pairings.set(r,D),i.addTrace(U.store_new_pairing),s.activatePairing&&await this.activate({topic:r}),this.events.emit(K.create,D),i.addTrace(U.emit_inactive_pairing),this.core.crypto.keychain.has(r)||await this.core.crypto.setSymKey(n,r),i.addTrace(U.subscribing_pairing_topic);try{await this.core.relayer.confirmOnlineStateOrThrow()}catch{i.setError(M.no_internet_connection)}try{await this.core.relayer.subscribe(r,{relay:a})}catch(m){throw i.setError(M.subscribe_pairing_topic_failure),m}return i.addTrace(U.subscribe_pairing_topic_success),D},this.activate=async({topic:s})=>{this.isInitialized();const i=c.calcExpiry(u.THIRTY_DAYS);this.core.expirer.set(s,i),await this.pairings.update(s,{active:!0,expiry:i})},this.ping=async s=>{this.isInitialized(),await this.isValidPing(s);const{topic:i}=s;if(this.pairings.keys.includes(i)){const r=await this.sendRequest(i,"wc_pairingPing",{}),{done:n,resolve:a,reject:h}=c.createDelayedPromise();this.events.once(c.engineEvent("pairing_ping",r),({error:l})=>{l?h(l):a()}),await n()}},this.updateExpiry=async({topic:s,expiry:i})=>{this.isInitialized(),await this.pairings.update(s,{expiry:i})},this.updateMetadata=async({topic:s,metadata:i})=>{this.isInitialized(),await this.pairings.update(s,{peerMetadata:i})},this.getPairings=()=>(this.isInitialized(),this.pairings.values),this.disconnect=async s=>{this.isInitialized(),await this.isValidDisconnect(s);const{topic:i}=s;this.pairings.keys.includes(i)&&(await this.sendRequest(i,"wc_pairingDelete",c.getSdkError("USER_DISCONNECTED")),await this.deletePairing(i))},this.formatUriFromPairing=s=>{this.isInitialized();const{topic:i,relay:r,expiry:n,methods:a}=s,h=this.core.crypto.keychain.get(i);return c.formatUri({protocol:this.core.protocol,version:this.core.version,topic:i,symKey:h,relay:r,expiryTimestamp:n,methods:a})},this.sendRequest=async(s,i,r)=>{const n=I.formatJsonRpcRequest(i,r),a=await this.core.crypto.encode(s,n),h=B[i].req;return this.core.history.set(s,n),this.core.relayer.publish(s,a,h),n.id},this.sendResult=async(s,i,r)=>{const n=I.formatJsonRpcResult(s,r),a=await this.core.crypto.encode(i,n),h=await this.core.history.get(i,s),l=B[h.request.method].res;await this.core.relayer.publish(i,a,l),await this.core.history.resolve(n)},this.sendError=async(s,i,r)=>{const n=I.formatJsonRpcError(s,r),a=await this.core.crypto.encode(i,n),h=await this.core.history.get(i,s),l=B[h.request.method]?B[h.request.method].res:B.unregistered_method.res;await this.core.relayer.publish(i,a,l),await this.core.history.resolve(n)},this.deletePairing=async(s,i)=>{await this.core.relayer.unsubscribe(s),await Promise.all([this.pairings.delete(s,c.getSdkError("USER_DISCONNECTED")),this.core.crypto.deleteSymKey(s),i?Promise.resolve():this.core.expirer.del(s)])},this.cleanup=async()=>{const s=this.pairings.getAll().filter(i=>c.isExpired(i.expiry));await Promise.all(s.map(i=>this.deletePairing(i.topic)))},this.onRelayEventRequest=s=>{const{topic:i,payload:r}=s;switch(r.method){case"wc_pairingPing":return this.onPairingPingRequest(i,r);case"wc_pairingDelete":return this.onPairingDeleteRequest(i,r);default:return this.onUnknownRpcMethodRequest(i,r)}},this.onRelayEventResponse=async s=>{const{topic:i,payload:r}=s,n=(await this.core.history.get(i,r.id)).request.method;switch(n){case"wc_pairingPing":return this.onPairingPingResponse(i,r);default:return this.onUnknownRpcMethodResponse(n)}},this.onPairingPingRequest=async(s,i)=>{const{id:r}=i;try{this.isValidPing({topic:s}),await this.sendResult(r,s,!0),this.events.emit(K.ping,{id:r,topic:s})}catch(n){await this.sendError(r,s,n),this.logger.error(n)}},this.onPairingPingResponse=(s,i)=>{const{id:r}=i;setTimeout(()=>{I.isJsonRpcResult(i)?this.events.emit(c.engineEvent("pairing_ping",r),{}):I.isJsonRpcError(i)&&this.events.emit(c.engineEvent("pairing_ping",r),{error:i.error})},500)},this.onPairingDeleteRequest=async(s,i)=>{const{id:r}=i;try{this.isValidDisconnect({topic:s}),await this.deletePairing(s),this.events.emit(K.delete,{id:r,topic:s})}catch(n){await this.sendError(r,s,n),this.logger.error(n)}},this.onUnknownRpcMethodRequest=async(s,i)=>{const{id:r,method:n}=i;try{if(this.registeredMethods.includes(n))return;const a=c.getSdkError("WC_METHOD_UNSUPPORTED",n);await this.sendError(r,s,a),this.logger.error(a)}catch(a){await this.sendError(r,s,a),this.logger.error(a)}},this.onUnknownRpcMethodResponse=s=>{this.registeredMethods.includes(s)||this.logger.error(c.getSdkError("WC_METHOD_UNSUPPORTED",s))},this.isValidPair=(s,i)=>{var r;if(!c.isValidParams(s)){const{message:a}=c.getInternalError("MISSING_OR_INVALID",`pair() params: ${s}`);throw i.setError(M.malformed_pairing_uri),new Error(a)}if(!c.isValidUrl(s.uri)){const{message:a}=c.getInternalError("MISSING_OR_INVALID",`pair() uri: ${s.uri}`);throw i.setError(M.malformed_pairing_uri),new Error(a)}const n=c.parseUri(s?.uri);if(!((r=n?.relay)!=null&&r.protocol)){const{message:a}=c.getInternalError("MISSING_OR_INVALID","pair() uri#relay-protocol");throw i.setError(M.malformed_pairing_uri),new Error(a)}if(!(n!=null&&n.symKey)){const{message:a}=c.getInternalError("MISSING_OR_INVALID","pair() uri#symKey");throw i.setError(M.malformed_pairing_uri),new Error(a)}if(n!=null&&n.expiryTimestamp&&u.toMiliseconds(n?.expiryTimestamp)<Date.now()){i.setError(M.pairing_expired);const{message:a}=c.getInternalError("EXPIRED","pair() URI has expired. Please try again with a new connection URI.");throw new Error(a)}},this.isValidPing=async s=>{if(!c.isValidParams(s)){const{message:r}=c.getInternalError("MISSING_OR_INVALID",`ping() params: ${s}`);throw new Error(r)}const{topic:i}=s;await this.isValidPairingTopic(i)},this.isValidDisconnect=async s=>{if(!c.isValidParams(s)){const{message:r}=c.getInternalError("MISSING_OR_INVALID",`disconnect() params: ${s}`);throw new Error(r)}const{topic:i}=s;await this.isValidPairingTopic(i)},this.isValidPairingTopic=async s=>{if(!c.isValidString(s,!1)){const{message:i}=c.getInternalError("MISSING_OR_INVALID",`pairing topic should be a string: ${s}`);throw new Error(i)}if(!this.pairings.keys.includes(s)){const{message:i}=c.getInternalError("NO_MATCHING_KEY",`pairing topic doesn't exist: ${s}`);throw new Error(i)}if(c.isExpired(this.pairings.get(s).expiry)){await this.deletePairing(s);const{message:i}=c.getInternalError("EXPIRED",`pairing topic: ${s}`);throw new Error(i)}},this.core=e,this.logger=y.generateChildLogger(t,this.name),this.pairings=new Ct(this.core,this.logger,this.name,this.storagePrefix)}get context(){return y.getLoggerContext(this.logger)}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}registerRelayerEvents(){this.core.relayer.on(f.message,async e=>{const{topic:t,message:s,transportType:i}=e;if(!this.pairings.keys.includes(t)||i===V.link_mode||this.ignoredPayloadTypes.includes(this.core.crypto.getPayloadType(s)))return;const r=await this.core.crypto.decode(t,s);try{I.isJsonRpcRequest(r)?(this.core.history.set(t,r),this.onRelayEventRequest({topic:t,payload:r})):I.isJsonRpcResponse(r)&&(await this.core.history.resolve(r),await this.onRelayEventResponse({topic:t,payload:r}),this.core.history.delete(t,r.id))}catch(n){this.logger.error(n)}})}registerExpirerEvents(){this.core.expirer.on(O.expired,async e=>{const{topic:t}=c.parseExpirerTarget(e.target);t&&this.pairings.keys.includes(t)&&(await this.deletePairing(t,!0),this.events.emit(K.expire,{topic:t}))})}}class Pt extends N.IJsonRpcHistory{constructor(e,t){super(e,t),this.core=e,this.logger=t,this.records=new Map,this.events=new $.EventEmitter,this.name=Le,this.version=Ue,this.cached=[],this.initialized=!1,this.storagePrefix=x,this.init=async()=>{this.initialized||(this.logger.trace("Initialized"),await this.restore(),this.cached.forEach(s=>this.records.set(s.id,s)),this.cached=[],this.registerEventListeners(),this.initialized=!0)},this.set=(s,i,r)=>{if(this.isInitialized(),this.logger.debug("Setting JSON-RPC request history record"),this.logger.trace({type:"method",method:"set",topic:s,request:i,chainId:r}),this.records.has(i.id))return;const n={id:i.id,topic:s,request:{method:i.method,params:i.params||null},chainId:r,expiry:c.calcExpiry(u.THIRTY_DAYS)};this.records.set(n.id,n),this.persist(),this.events.emit(P.created,n)},this.resolve=async s=>{if(this.isInitialized(),this.logger.debug("Updating JSON-RPC response history record"),this.logger.trace({type:"method",method:"update",response:s}),!this.records.has(s.id))return;const i=await this.getRecord(s.id);typeof i.response>"u"&&(i.response=I.isJsonRpcError(s)?{error:s.error}:{result:s.result},this.records.set(i.id,i),this.persist(),this.events.emit(P.updated,i))},this.get=async(s,i)=>(this.isInitialized(),this.logger.debug("Getting record"),this.logger.trace({type:"method",method:"get",topic:s,id:i}),await this.getRecord(i)),this.delete=(s,i)=>{this.isInitialized(),this.logger.debug("Deleting record"),this.logger.trace({type:"method",method:"delete",id:i}),this.values.forEach(r=>{if(r.topic===s){if(typeof i<"u"&&r.id!==i)return;this.records.delete(r.id),this.events.emit(P.deleted,r)}}),this.persist()},this.exists=async(s,i)=>(this.isInitialized(),this.records.has(i)?(await this.getRecord(i)).topic===s:!1),this.on=(s,i)=>{this.events.on(s,i)},this.once=(s,i)=>{this.events.once(s,i)},this.off=(s,i)=>{this.events.off(s,i)},this.removeListener=(s,i)=>{this.events.removeListener(s,i)},this.logger=y.generateChildLogger(t,this.name)}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//"+this.name}get size(){return this.records.size}get keys(){return Array.from(this.records.keys())}get values(){return Array.from(this.records.values())}get pending(){const e=[];return this.values.forEach(t=>{if(typeof t.response<"u")return;const s={topic:t.topic,request:I.formatJsonRpcRequest(t.request.method,t.request.params,t.id),chainId:t.chainId};return e.push(s)}),e}async setJsonRpcRecords(e){await this.core.storage.setItem(this.storageKey,e)}async getJsonRpcRecords(){return await this.core.storage.getItem(this.storageKey)}getRecord(e){this.isInitialized();const t=this.records.get(e);if(!t){const{message:s}=c.getInternalError("NO_MATCHING_KEY",`${this.name}: ${e}`);throw new Error(s)}return t}async persist(){await this.setJsonRpcRecords(this.values),this.events.emit(P.sync)}async restore(){try{const e=await this.getJsonRpcRecords();if(typeof e>"u"||!e.length)return;if(this.records.size){const{message:t}=c.getInternalError("RESTORE_WILL_OVERRIDE",this.name);throw this.logger.error(t),new Error(t)}this.cached=e,this.logger.debug(`Successfully Restored records for ${this.name}`),this.logger.trace({type:"method",method:"restore",records:this.values})}catch(e){this.logger.debug(`Failed to Restore records for ${this.name}`),this.logger.error(e)}}registerEventListeners(){this.events.on(P.created,e=>{const t=P.created;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,record:e})}),this.events.on(P.updated,e=>{const t=P.updated;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,record:e})}),this.events.on(P.deleted,e=>{const t=P.deleted;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,record:e})}),this.core.heartbeat.on(k.HEARTBEAT_EVENTS.pulse,()=>{this.cleanup()})}cleanup(){try{this.isInitialized();let e=!1;this.records.forEach(t=>{u.toMiliseconds(t.expiry||0)-Date.now()<=0&&(this.logger.info(`Deleting expired history log: ${t.id}`),this.records.delete(t.id),this.events.emit(P.deleted,t,!1),e=!0)}),e&&this.persist()}catch(e){this.logger.warn(e)}}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}class Ot extends N.IExpirer{constructor(e,t){super(e,t),this.core=e,this.logger=t,this.expirations=new Map,this.events=new $.EventEmitter,this.name=ze,this.version=Me,this.cached=[],this.initialized=!1,this.storagePrefix=x,this.init=async()=>{this.initialized||(this.logger.trace("Initialized"),await this.restore(),this.cached.forEach(s=>this.expirations.set(s.target,s)),this.cached=[],this.registerEventListeners(),this.initialized=!0)},this.has=s=>{try{const i=this.formatTarget(s);return typeof this.getExpiration(i)<"u"}catch{return!1}},this.set=(s,i)=>{this.isInitialized();const r=this.formatTarget(s),n={target:r,expiry:i};this.expirations.set(r,n),this.checkExpiry(r,n),this.events.emit(O.created,{target:r,expiration:n})},this.get=s=>{this.isInitialized();const i=this.formatTarget(s);return this.getExpiration(i)},this.del=s=>{if(this.isInitialized(),this.has(s)){const i=this.formatTarget(s),r=this.getExpiration(i);this.expirations.delete(i),this.events.emit(O.deleted,{target:i,expiration:r})}},this.on=(s,i)=>{this.events.on(s,i)},this.once=(s,i)=>{this.events.once(s,i)},this.off=(s,i)=>{this.events.off(s,i)},this.removeListener=(s,i)=>{this.events.removeListener(s,i)},this.logger=y.generateChildLogger(t,this.name)}get context(){return y.getLoggerContext(this.logger)}get storageKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//"+this.name}get length(){return this.expirations.size}get keys(){return Array.from(this.expirations.keys())}get values(){return Array.from(this.expirations.values())}formatTarget(e){if(typeof e=="string")return c.formatTopicTarget(e);if(typeof e=="number")return c.formatIdTarget(e);const{message:t}=c.getInternalError("UNKNOWN_TYPE",`Target type: ${typeof e}`);throw new Error(t)}async setExpirations(e){await this.core.storage.setItem(this.storageKey,e)}async getExpirations(){return await this.core.storage.getItem(this.storageKey)}async persist(){await this.setExpirations(this.values),this.events.emit(O.sync)}async restore(){try{const e=await this.getExpirations();if(typeof e>"u"||!e.length)return;if(this.expirations.size){const{message:t}=c.getInternalError("RESTORE_WILL_OVERRIDE",this.name);throw this.logger.error(t),new Error(t)}this.cached=e,this.logger.debug(`Successfully Restored expirations for ${this.name}`),this.logger.trace({type:"method",method:"restore",expirations:this.values})}catch(e){this.logger.debug(`Failed to Restore expirations for ${this.name}`),this.logger.error(e)}}getExpiration(e){const t=this.expirations.get(e);if(!t){const{message:s}=c.getInternalError("NO_MATCHING_KEY",`${this.name}: ${e}`);throw this.logger.warn(s),new Error(s)}return t}checkExpiry(e,t){const{expiry:s}=t;u.toMiliseconds(s)-Date.now()<=0&&this.expire(e,t)}expire(e,t){this.expirations.delete(e),this.events.emit(O.expired,{target:e,expiration:t})}checkExpirations(){this.core.relayer.connected&&this.expirations.forEach((e,t)=>this.checkExpiry(t,e))}registerEventListeners(){this.core.heartbeat.on(k.HEARTBEAT_EVENTS.pulse,()=>this.checkExpirations()),this.events.on(O.created,e=>{const t=O.created;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,data:e}),this.persist()}),this.events.on(O.expired,e=>{const t=O.expired;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,data:e}),this.persist()}),this.events.on(O.deleted,e=>{const t=O.deleted;this.logger.info(`Emitting ${t}`),this.logger.debug({type:"event",event:t,data:e}),this.persist()})}isInitialized(){if(!this.initialized){const{message:e}=c.getInternalError("NOT_INITIALIZED",this.name);throw new Error(e)}}}class At extends N.IVerify{constructor(e,t,s){super(e,t,s),this.core=e,this.logger=t,this.store=s,this.name=Fe,this.verifyUrlV3=Ve,this.storagePrefix=x,this.version=re,this.init=async()=>{var i;this.isDevEnv||(this.publicKey=await this.store.getItem(this.storeKey),this.publicKey&&u.toMiliseconds((i=this.publicKey)==null?void 0:i.expiresAt)<Date.now()&&(this.logger.debug("verify v2 public key expired"),await this.removePublicKey()))},this.register=async i=>{if(!c.isBrowser()||this.isDevEnv)return;const r=window.location.origin,{id:n,decryptedId:a}=i,h=`${this.verifyUrlV3}/attestation?projectId=${this.core.projectId}&origin=${r}&id=${n}&decryptedId=${a}`;try{const l=jt.getDocument(),g=this.startAbortTimer(u.ONE_SECOND*5),p=await new Promise((D,m)=>{const d=()=>{window.removeEventListener("message",T),l.body.removeChild(E),m("attestation aborted")};this.abortController.signal.addEventListener("abort",d);const E=l.createElement("iframe");E.src=h,E.style.display="none",E.addEventListener("error",d,{signal:this.abortController.signal});const T=b=>{if(b.data&&typeof b.data=="string")try{const _=JSON.parse(b.data);if(_.type==="verify_attestation"){if(ie.decodeJWT(_.attestation).payload.id!==n)return;clearInterval(g),l.body.removeChild(E),this.abortController.signal.removeEventListener("abort",d),window.removeEventListener("message",T),D(_.attestation===null?"":_.attestation)}}catch(_){this.logger.warn(_)}};l.body.appendChild(E),window.addEventListener("message",T,{signal:this.abortController.signal})});return this.logger.debug("jwt attestation",p),p}catch(l){this.logger.warn(l)}return""},this.resolve=async i=>{if(this.isDevEnv)return"";const{attestationId:r,hash:n,encryptedId:a}=i;if(r===""){this.logger.debug("resolve: attestationId is empty, skipping");return}if(r){if(ie.decodeJWT(r).payload.id!==a)return;const l=await this.isValidJwtAttestation(r);if(l){if(!l.isVerified){this.logger.warn("resolve: jwt attestation: origin url not verified");return}return l}}if(!n)return;const h=this.getVerifyUrl(i?.verifyUrl);return this.fetchAttestation(n,h)},this.fetchAttestation=async(i,r)=>{this.logger.debug(`resolving attestation: ${i} from url: ${r}`);const n=this.startAbortTimer(u.ONE_SECOND*5),a=await fetch(`${r}/attestation/${i}?v2Supported=true`,{signal:this.abortController.signal});return clearTimeout(n),a.status===200?await a.json():void 0},this.getVerifyUrl=i=>{let r=i||q;return ke.includes(r)||(this.logger.info(`verify url: ${r}, not included in trusted list, assigning default: ${q}`),r=q),r},this.fetchPublicKey=async()=>{try{this.logger.debug(`fetching public key from: ${this.verifyUrlV3}`);const i=this.startAbortTimer(u.FIVE_SECONDS),r=await fetch(`${this.verifyUrlV3}/public-key`,{signal:this.abortController.signal});return clearTimeout(i),await r.json()}catch(i){this.logger.warn(i)}},this.persistPublicKey=async i=>{this.logger.debug("persisting public key to local storage",i),await this.store.setItem(this.storeKey,i),this.publicKey=i},this.removePublicKey=async()=>{this.logger.debug("removing verify v2 public key from storage"),await this.store.removeItem(this.storeKey),this.publicKey=void 0},this.isValidJwtAttestation=async i=>{const r=await this.getPublicKey();try{if(r)return this.validateAttestation(i,r)}catch(a){this.logger.error(a),this.logger.warn("error validating attestation")}const n=await this.fetchAndPersistPublicKey();try{if(n)return this.validateAttestation(i,n)}catch(a){this.logger.error(a),this.logger.warn("error validating attestation")}},this.getPublicKey=async()=>this.publicKey?this.publicKey:await this.fetchAndPersistPublicKey(),this.fetchAndPersistPublicKey=async()=>{if(this.fetchPromise)return await this.fetchPromise,this.publicKey;this.fetchPromise=new Promise(async r=>{const n=await this.fetchPublicKey();n&&(await this.persistPublicKey(n),r(n))});const i=await this.fetchPromise;return this.fetchPromise=void 0,i},this.validateAttestation=(i,r)=>{const n=c.verifyP256Jwt(i,r.publicKey),a={hasExpired:u.toMiliseconds(n.exp)<Date.now(),payload:n};if(a.hasExpired)throw this.logger.warn("resolve: jwt attestation expired"),new Error("JWT attestation expired");return{origin:a.payload.origin,isScam:a.payload.isScam,isVerified:a.payload.isVerified}},this.logger=y.generateChildLogger(t,this.name),this.abortController=new AbortController,this.isDevEnv=c.isTestRun(),this.init()}get storeKey(){return this.storagePrefix+this.version+this.core.customStoragePrefix+"//verify:public:key"}get context(){return y.getLoggerContext(this.logger)}startAbortTimer(e){return this.abortController=new AbortController,setTimeout(()=>this.abortController.abort(),u.toMiliseconds(e))}}class Nt extends N.IEchoClient{constructor(e,t){super(e,t),this.projectId=e,this.logger=t,this.context=Be,this.registerDeviceToken=async s=>{const{clientId:i,token:r,notificationType:n,enableEncrypted:a=!1}=s,h=`${Ke}/${this.projectId}/clients`;await fetch(h,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify({client_id:i,type:n,token:r,always_raw:a})})},this.logger=y.generateChildLogger(t,this.context)}}var Js=Object.defineProperty,xt=Object.getOwnPropertySymbols,Xs=Object.prototype.hasOwnProperty,Ws=Object.prototype.propertyIsEnumerable,Lt=(o,e,t)=>e in o?Js(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,H=(o,e)=>{for(var t in e||(e={}))Xs.call(e,t)&&Lt(o,t,e[t]);if(xt)for(var t of xt(e))Ws.call(e,t)&&Lt(o,t,e[t]);return o};class Ut extends N.IEventClient{constructor(e,t,s=!0){super(e,t,s),this.core=e,this.logger=t,this.context=qe,this.storagePrefix=x,this.storageVersion=je,this.events=new Map,this.shouldPersist=!1,this.init=async()=>{if(!c.isTestRun())try{const i={eventId:c.uuidv4(),timestamp:Date.now(),domain:this.getAppDomain(),props:{event:"INIT",type:"",properties:{client_id:await this.core.crypto.getClientId(),user_agent:c.formatUA(this.core.relayer.protocol,this.core.relayer.version,Z)}}};await this.sendEvent([i])}catch(i){this.logger.warn(i)}},this.createEvent=i=>{const{event:r="ERROR",type:n="",properties:{topic:a,trace:h}}=i,l=c.uuidv4(),g=this.core.projectId||"",p=Date.now(),D=H({eventId:l,timestamp:p,props:{event:r,type:n,properties:{topic:a,trace:h}},bundleId:g,domain:this.getAppDomain()},this.setMethods(l));return this.telemetryEnabled&&(this.events.set(l,D),this.shouldPersist=!0),D},this.getEvent=i=>{const{eventId:r,topic:n}=i;if(r)return this.events.get(r);const a=Array.from(this.events.values()).find(h=>h.props.properties.topic===n);if(a)return H(H({},a),this.setMethods(a.eventId))},this.deleteEvent=i=>{const{eventId:r}=i;this.events.delete(r),this.shouldPersist=!0},this.setEventListeners=()=>{this.core.heartbeat.on(k.HEARTBEAT_EVENTS.pulse,async()=>{this.shouldPersist&&await this.persist(),this.events.forEach(i=>{u.fromMiliseconds(Date.now())-u.fromMiliseconds(i.timestamp)>Ye&&(this.events.delete(i.eventId),this.shouldPersist=!0)})})},this.setMethods=i=>({addTrace:r=>this.addTrace(i,r),setError:r=>this.setError(i,r)}),this.addTrace=(i,r)=>{const n=this.events.get(i);n&&(n.props.properties.trace.push(r),this.events.set(i,n),this.shouldPersist=!0)},this.setError=(i,r)=>{const n=this.events.get(i);n&&(n.props.type=r,n.timestamp=Date.now(),this.events.set(i,n),this.shouldPersist=!0)},this.persist=async()=>{await this.core.storage.setItem(this.storageKey,Array.from(this.events.values())),this.shouldPersist=!1},this.restore=async()=>{try{const i=await this.core.storage.getItem(this.storageKey)||[];if(!i.length)return;i.forEach(r=>{this.events.set(r.eventId,H(H({},r),this.setMethods(r.eventId)))})}catch(i){this.logger.warn(i)}},this.submit=async()=>{if(!this.telemetryEnabled||this.events.size===0)return;const i=[];for(const[r,n]of this.events)n.props.type&&i.push(n);if(i.length!==0)try{if((await this.sendEvent(i)).ok)for(const r of i)this.events.delete(r.eventId),this.shouldPersist=!0}catch(r){this.logger.warn(r)}},this.sendEvent=async i=>{const r=this.getAppDomain()?"":"&sp=desktop";return await fetch(`${Ge}?projectId=${this.core.projectId}&st=events_sdk&sv=js-${Z}${r}`,{method:"POST",body:JSON.stringify(i)})},this.getAppDomain=()=>c.getAppMetadata().url,this.logger=y.generateChildLogger(t,this.context),this.telemetryEnabled=s,s?this.restore().then(async()=>{await this.submit(),this.setEventListeners()}):this.persist()}get storageKey(){return this.storagePrefix+this.storageVersion+this.core.customStoragePrefix+"//"+this.context}}var Zs=Object.defineProperty,zt=Object.getOwnPropertySymbols,Qs=Object.prototype.hasOwnProperty,er=Object.prototype.propertyIsEnumerable,Mt=(o,e,t)=>e in o?Zs(o,e,{enumerable:!0,configurable:!0,writable:!0,value:t}):o[e]=t,Ft=(o,e)=>{for(var t in e||(e={}))Qs.call(e,t)&&Mt(o,t,e[t]);if(zt)for(var t of zt(e))er.call(e,t)&&Mt(o,t,e[t]);return o};class ee extends N.ICore{constructor(e){var t;super(e),this.protocol=se,this.version=re,this.name=j,this.events=new $.EventEmitter,this.initialized=!1,this.on=(n,a)=>this.events.on(n,a),this.once=(n,a)=>this.events.once(n,a),this.off=(n,a)=>this.events.off(n,a),this.removeListener=(n,a)=>this.events.removeListener(n,a),this.dispatchEnvelope=({topic:n,message:a,sessionExists:h})=>{if(!n||!a)return;const l={topic:n,message:a,publishedAt:Date.now(),transportType:V.link_mode};this.relayer.onLinkMessageEvent(l,{sessionExists:h})},this.projectId=e?.projectId,this.relayUrl=e?.relayUrl||ae,this.customStoragePrefix=e!=null&&e.customStoragePrefix?`:${e.customStoragePrefix}`:"";const s=y.getDefaultLoggerOptions({level:typeof e?.logger=="string"&&e.logger?e.logger:ge.logger,name:j}),{logger:i,chunkLoggerController:r}=y.generatePlatformLogger({opts:s,maxSizeInBytes:e?.maxLogBlobSizeInBytes,loggerOverride:e?.logger});this.logChunkController=r,(t=this.logChunkController)!=null&&t.downloadLogsBlobInBrowser&&(window.downloadLogsBlobInBrowser=async()=>{var n,a;(n=this.logChunkController)!=null&&n.downloadLogsBlobInBrowser&&((a=this.logChunkController)==null||a.downloadLogsBlobInBrowser({clientId:await this.crypto.getClientId()}))}),this.logger=y.generateChildLogger(i,this.name),this.heartbeat=new k.HeartBeat,this.crypto=new ut(this,this.logger,e?.keychain),this.history=new Pt(this,this.logger),this.expirer=new Ot(this,this.logger),this.storage=e!=null&&e.storage?e.storage:new Gt.default(Ft(Ft({},pe),e?.storageOptions)),this.relayer=new wt({core:this,logger:this.logger,relayUrl:this.relayUrl,projectId:this.projectId}),this.pairing=new St(this,this.logger),this.verify=new At(this,this.logger,this.storage),this.echoClient=new Nt(this.projectId||"",this.logger),this.linkModeSupportedApps=[],this.eventClient=new Ut(this,this.logger,e?.telemetryEnabled)}static async init(e){const t=new ee(e);await t.initialize();const s=await t.crypto.getClientId();return await t.storage.setItem(Se,s),t}get context(){return y.getLoggerContext(this.logger)}async start(){this.initialized||await this.initialize()}async getLogsBlob(){var e;return(e=this.logChunkController)==null?void 0:e.logsToBlob({clientId:await this.crypto.getClientId()})}async addLinkModeSupportedApp(e){this.linkModeSupportedApps.includes(e)||(this.linkModeSupportedApps.push(e),await this.storage.setItem(ce,this.linkModeSupportedApps))}async initialize(){this.logger.trace("Initialized");try{await this.crypto.init(),await this.history.init(),await this.expirer.init(),await this.relayer.init(),await this.heartbeat.init(),await this.pairing.init(),this.eventClient.init(),this.linkModeSupportedApps=await this.storage.getItem(ce)||[],this.initialized=!0,this.logger.info("Core Initialization Success")}catch(e){throw this.logger.warn(`Core Initialization Failure at epoch ${Date.now()}`,e),this.logger.error(e.message),e}}}const tr=ee;exports.CORE_CONTEXT=j,exports.CORE_DEFAULT=ge,exports.CORE_PROTOCOL=se,exports.CORE_STORAGE_OPTIONS=pe,exports.CORE_STORAGE_PREFIX=x,exports.CORE_VERSION=re,exports.CRYPTO_CLIENT_SEED=ne,exports.CRYPTO_CONTEXT=ye,exports.CRYPTO_JWT_TTL=Ee,exports.Core=tr,exports.Crypto=ut,exports.ECHO_CONTEXT=Be,exports.ECHO_URL=Ke,exports.EVENTS_CLIENT_API_URL=Ge,exports.EVENTS_STORAGE_CLEANUP_INTERVAL=Ye,exports.EVENTS_STORAGE_CONTEXT=qe,exports.EVENTS_STORAGE_VERSION=je,exports.EVENT_CLIENT_AUTHENTICATE_ERRORS=oi,exports.EVENT_CLIENT_AUTHENTICATE_TRACES=ni,exports.EVENT_CLIENT_CONTEXT=ii,exports.EVENT_CLIENT_PAIRING_ERRORS=M,exports.EVENT_CLIENT_PAIRING_TRACES=U,exports.EVENT_CLIENT_SESSION_ERRORS=ri,exports.EVENT_CLIENT_SESSION_TRACES=si,exports.EXPIRER_CONTEXT=ze,exports.EXPIRER_DEFAULT_TTL=ei,exports.EXPIRER_EVENTS=O,exports.EXPIRER_STORAGE_VERSION=Me,exports.EchoClient=Nt,exports.EventClient=Ut,exports.Expirer=Ot,exports.HISTORY_CONTEXT=Le,exports.HISTORY_EVENTS=P,exports.HISTORY_STORAGE_VERSION=Ue,exports.JsonRpcHistory=Pt,exports.KEYCHAIN_CONTEXT=De,exports.KEYCHAIN_STORAGE_VERSION=_e,exports.KeyChain=lt,exports.MESSAGES_CONTEXT=me,exports.MESSAGES_STORAGE_VERSION=be,exports.MessageTracker=dt,exports.PAIRING_CONTEXT=Ne,exports.PAIRING_DEFAULT_TTL=Qt,exports.PAIRING_EVENTS=K,exports.PAIRING_RPC_OPTS=B,exports.PAIRING_STORAGE_VERSION=xe,exports.PENDING_SUB_RESOLUTION_TIMEOUT=Ae,exports.PUBLISHER_CONTEXT=ve,exports.PUBLISHER_DEFAULT_TTL=oe,exports.Pairing=St,exports.RELAYER_CONTEXT=Te,exports.RELAYER_DEFAULT_LOGGER=we,exports.RELAYER_DEFAULT_PROTOCOL=fe,exports.RELAYER_DEFAULT_RELAY_URL=ae,exports.RELAYER_EVENTS=f,exports.RELAYER_PROVIDER_EVENTS=C,exports.RELAYER_RECONNECT_TIMEOUT=Re,exports.RELAYER_SDK_VERSION=Z,exports.RELAYER_STORAGE_OPTIONS=Xt,exports.RELAYER_SUBSCRIBER_SUFFIX=Ie,exports.RELAYER_TRANSPORT_CUTOFF=Wt,exports.Relayer=wt,exports.STORE_STORAGE_VERSION=Ce,exports.SUBSCRIBER_CONTEXT=Pe,exports.SUBSCRIBER_DEFAULT_TTL=Zt,exports.SUBSCRIBER_EVENTS=R,exports.SUBSCRIBER_STORAGE_VERSION=Oe,exports.Store=Ct,exports.Subscriber=mt,exports.TRANSPORT_TYPES=V,exports.TRUSTED_VERIFY_URLS=ke,exports.VERIFY_CONTEXT=Fe,exports.VERIFY_SERVER=q,exports.VERIFY_SERVER_V3=Ve,exports.Verify=At,exports.WALLETCONNECT_CLIENT_ID=Se,exports.WALLETCONNECT_LINK_MODE_APPS=ce,exports.default=ee;
                                                                                                                                                                                                                                                                          
TypeError: i.terminate is not a function
    at Timeout._onTimeout (/home/gorub/Documents/TONProjects/Novikov/MintBot/min/node_modules/@walletconnect/core/dist/index.cjs.js:1:41151)
    at listOnTimeout (node:internal/timers:594:17)
    at process.processTimers (node:internal/timers:529:7)

Node.js v22.11.0

The problem is in @walletconnect/core/dist/index.cjs.js in wt/constructor/resetPingTimeout/setTimeout callback()

I am working on Ubuntu, Node.js 22.11.0, not using walletConnectModal.openModal({ uri }) because of using Telegram Bot frontend Opening QRcodes with MetaMask

Expected behavior

Connection must be successfull and must not result the breaking of the all Bot App.