diff --git a/src/router.ts b/src/router.ts index 60a0893..0eae8d4 100644 --- a/src/router.ts +++ b/src/router.ts @@ -55,12 +55,6 @@ async function init(): Promise { await services.restoreProcesses(); await services.restoreMessages(); - const amount = await services.getAmount(); - - if (amount === 0n) { - const faucetMsg = await services.createFaucetMessage(); - await services.sendFaucetMessage(faucetMsg); - } if (services.isPaired()) { isPaired = true; console.log("🚀 ~ setTimeout ~ isPaired:", isPaired) diff --git a/src/websockets.ts b/src/websockets.ts index 83236ed..57a0a09 100644 --- a/src/websockets.ts +++ b/src/websockets.ts @@ -13,6 +13,12 @@ class WebSocketClient { this.ws.onopen = async (event) => { console.log('WebSocket connection established'); + const amount = await services.getAmount(); + + if (amount === 0n) { + const faucetMsg = await services.createFaucetMessage(); + await services.sendFaucetMessage(faucetMsg); + } while (this.messageQueue.length > 0) { const message = this.messageQueue.shift(); if (message) {