From 322679e7c5fe07b1004f6fb910e304dc81947651 Mon Sep 17 00:00:00 2001
From: Vlad Stan <stan.v.vlad@gmail.com>
Date: Wed, 21 Jun 2023 14:40:28 +0300
Subject: [PATCH] fix: do not use lambda in a loop

---
 nostr/pow.py   |  2 ++
 nostr/relay.py | 14 +++++++++++---
 2 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/nostr/pow.py b/nostr/pow.py
index e006288..fece484 100644
--- a/nostr/pow.py
+++ b/nostr/pow.py
@@ -1,7 +1,9 @@
 import time
+
 from .event import Event
 from .key import PrivateKey
 
+
 def zero_bits(b: int) -> int:
     n = 0
 
diff --git a/nostr/relay.py b/nostr/relay.py
index 7fb4baa..246b985 100644
--- a/nostr/relay.py
+++ b/nostr/relay.py
@@ -2,7 +2,9 @@ import json
 import time
 from queue import Queue
 from threading import Lock
+
 from websocket import WebSocketApp
+
 from .event import Event
 from .filter import Filters
 from .message_pool import MessagePool
@@ -45,6 +47,7 @@ class Relay:
         self.queue = Queue()
 
     def connect(self, ssl_options: dict = None, proxy: dict = None):
+        print("### relay.connect", self.url)
         self.ws = WebSocketApp(
             self.url,
             on_open=self._on_open,
@@ -81,24 +84,29 @@ class Relay:
 
     @property
     def ping(self):
+        print("### ping: ", self.url)
         ping_ms = int((self.ws.last_pong_tm - self.ws.last_ping_tm) * 1000)
         return ping_ms if self.connected and ping_ms > 0 else 0
 
     def publish(self, message: str):
         self.queue.put(message)
 
-    def queue_worker(self, shutdown):
+    def queue_worker(self):
+        print("#### IN !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!", self.url)
         while True:
             if self.connected:
                 try:
                     message = self.queue.get(timeout=1)
+                    print("#### queue_worker", message)
                     self.num_sent_events += 1
                     self.ws.send(message)
-                except:
-                    if shutdown():
+                except Exception as e:
+                    if self.shutdown:
+                        print("#### !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! e [", e, self.url, self.shutdown," ]###")
                         break
             else:
                 time.sleep(0.1)
+        print("#### OUT !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!", self.url)
 
     def add_subscription(self, id, filters: Filters):
         with self.lock: