diff --git a/lnbits/wallets/nwc.py b/lnbits/wallets/nwc.py index 828d5dbf..bbfad1ec 100644 --- a/lnbits/wallets/nwc.py +++ b/lnbits/wallets/nwc.py @@ -440,11 +440,14 @@ class NWCConnection: logger.error("Error closing subscription: " + str(e)) return subscription - async def _wait_for_connection(self): + async def _wait_for_connection(self, timeout: int = 60 * 2): """ Waits until the connection is ready """ + t = time.time() while not self.connected: + if time.time() - t > timeout: + raise Exception("Connection timeout, cannot connect to NWC service") if self._is_shutting_down(): raise Exception("Connection is closing") logger.debug("Waiting for connection...")