subscribe

This commit is contained in:
callebtc
2023-02-09 11:55:12 +01:00
parent 56fff73af4
commit be948b6ca3
2 changed files with 8 additions and 2 deletions

View File

@@ -28,6 +28,11 @@ async def dm():
) )
client = NostrClient(privatekey_hex=pk) client = NostrClient(privatekey_hex=pk)
if not pk:
print(f"Your private key: {client.private_key.hex()}")
print(f"Your public key: {client.public_key.hex()}")
# await asyncio.sleep(1) # await asyncio.sleep(1)
t = threading.Thread( t = threading.Thread(
target=client.get_dm, target=client.get_dm,

View File

@@ -129,9 +129,10 @@ class NostrClient:
break break
time.sleep(0.1) time.sleep(0.1)
async def subscribe(self): async def subscribe(self, callback_func=None):
while True: while True:
while self.relay_manager.message_pool.has_events(): while self.relay_manager.message_pool.has_events():
event_msg = self.relay_manager.message_pool.get_event() event_msg = self.relay_manager.message_pool.get_event()
break if callback_func:
callback_func(event_msg.event)
time.sleep(0.1) time.sleep(0.1)