From 1006dd40e2cba1b83f112bd00bc6553cf4a7fdae Mon Sep 17 00:00:00 2001
From: Thomas Farstrike <thomasverstreken@protonmail.com>
Date: Mon, 19 May 2025 23:55:22 +0200
Subject: [PATCH] thread works

---
 .../lib/websocket_nostr_receive.py            | 39 ++++++++++---------
 1 file changed, 20 insertions(+), 19 deletions(-)

diff --git a/internal_filesystem/lib/websocket_nostr_receive.py b/internal_filesystem/lib/websocket_nostr_receive.py
index 81e14a46..49c66f2c 100644
--- a/internal_filesystem/lib/websocket_nostr_receive.py
+++ b/internal_filesystem/lib/websocket_nostr_receive.py
@@ -25,25 +25,25 @@ message = json.dumps(request)
 # ["REQ", "ihopethisworks3", {"kinds": [1], "authors": "04c915daefee38317fa734444acee390a8269fe5810b2241e5e6dd343dfbecc9"}]
 print(f"sending this: {message}")
 
-
-relay_manager = RelayManager()
-#relay_manager.add_relay("wss://nostr-pub.wellorder.net")
-relay_manager.add_relay("wss://relay.damus.io")
-relay_manager.add_subscription(subscription_id, filters)
-time.sleep(2) # allow the connections to open
-
-print("opening connections")
-relay_manager.open_connections({"cert_reqs": ssl.CERT_NONE}) # NOTE: This disables ssl certificate verification
-time.sleep(2) # allow the connections to open
-
-print("publishing:")
-relay_manager.publish_message(message)
-time.sleep(1) # allow the messages to send
-
 def printevents():
+
+    relay_manager = RelayManager()
+    #relay_manager.add_relay("wss://nostr-pub.wellorder.net")
+    relay_manager.add_relay("wss://relay.damus.io")
+    relay_manager.add_subscription(subscription_id, filters)
+    time.sleep(2) # allow the connections to open
+    
+    print("opening connections") # after this, CPU usage goes high and stays there
+    relay_manager.open_connections({"cert_reqs": ssl.CERT_NONE}) # NOTE: This disables ssl certificate verification
+    time.sleep(2) # allow the connections to open
+    
+    print("publishing:")
+    relay_manager.publish_message(message)
+    time.sleep(2) # allow the messages to send
+    
     print("printing events:")
     #while relay_manager.message_pool.has_events():
-    for _ in range(60):
+    for _ in range(10):
         time.sleep(1)
         print(".")
         try:
@@ -54,7 +54,8 @@ def printevents():
     print("60 seconds passed, closing:")
     relay_manager.close_connections()
 
-#_thread.stack_size(32*1024)
-#_thread.start_new_thread(printevents, ())
-printevents()
+# new thread so REPL stays available
+_thread.stack_size(32*1024)
+_thread.start_new_thread(printevents, ())
+#printevents()