aljaz/python-nostr
1
0
Fork 0
mirror of https://github.com/aljazceru/python-nostr.git synced 2025-12-19 23:34:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

subscribe global

Browse Source
This commit is contained in:
callebtc
2023-02-01 14:37:22 +01:00
parent 76815b77ee
commit 1d6ee33aa4
2 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
main.py
View File

@@ -53,11 +53,16 @@ async def post():
await asyncio.sleep(1) await asyncio.sleep(1)
to_pubk_hex = ( to_pubk_hex = (
input("Enter other pubkey (enter nothing to read your own posts): ") input(
"Enter other pubkey (enter nothing to read your own posts, enter * for all): "
)
or sender_client.public_key.hex() or sender_client.public_key.hex()
) )
print(f"Subscribing to posts by {to_pubk_hex}") if to_pubk_hex == "*":
to_pubk = PublicKey(bytes.fromhex(to_pubk_hex)) to_pubk = None
else:
print(f"Subscribing to posts by {to_pubk_hex}")
to_pubk = PublicKey(bytes.fromhex(to_pubk_hex))
t = threading.Thread( t = threading.Thread(
target=sender_client.get_post, target=sender_client.get_post,
@@ -74,7 +79,7 @@ async def post():
# write a DM and receive DMs # write a DM and receive DMs
asyncio.run(dm()) # asyncio.run(dm())
# make a post and subscribe to posts # make a post and subscribe to posts
# asyncio.run(post()) asyncio.run(post())

8
nostr/client/client.py
View File

@@ -62,10 +62,12 @@ class NostrClient:
# print(message) # print(message)
self.relay_manager.publish_message(message) self.relay_manager.publish_message(message)
def get_post(self, sender_publickey: PublicKey, callback_func=None): def get_post(self, sender_publickey: PublicKey = None, callback_func=None):
filters = Filters( filter = Filter(
[Filter(authors=[sender_publickey.hex()], kinds=[EventKind.TEXT_NOTE])] authors=[sender_publickey.hex()] if sender_publickey else None,
kinds=[EventKind.TEXT_NOTE],
) )
filters = Filters([filter])
subscription_id = os.urandom(4).hex() subscription_id = os.urandom(4).hex()
self.relay_manager.add_subscription(subscription_id, filters) self.relay_manager.add_subscription(subscription_id, filters)