88 lines
2.3 KiB
Python
88 lines
2.3 KiB
Python
import asyncio
|
|
import ssl
|
|
import threading
|
|
|
|
from .nostr.client.client import NostrClient
|
|
from .nostr.event import Event
|
|
from .nostr.key import PublicKey
|
|
from .nostr.relay_manager import RelayManager
|
|
|
|
# relays = [
|
|
# "wss://nostr.mom",
|
|
# "wss://nostr-pub.wellorder.net",
|
|
# "wss://nostr.zebedee.cloud",
|
|
# "wss://relay.damus.io",
|
|
# "wss://relay.nostr.info",
|
|
# "wss://nostr.onsats.org",
|
|
# "wss://nostr-relay.untethr.me",
|
|
# "wss://relay.snort.social",
|
|
# "wss://lnbits.link/nostrrelay/client",
|
|
# ]
|
|
client = NostrClient(
|
|
connect=False,
|
|
)
|
|
|
|
# client = NostrClient(
|
|
# connect=False,
|
|
# privatekey_hex="211aac75a687ad96cca402406f8147a2726e31c5fc838e22ce30640ca1f3a6fe",
|
|
# )
|
|
|
|
received_event_queue: asyncio.Queue[Event] = asyncio.Queue(0)
|
|
|
|
from .crud import get_relays
|
|
|
|
|
|
async def init_relays():
|
|
relays = await get_relays()
|
|
client.relays = set([r.url for r in relays.__root__])
|
|
client.connect()
|
|
return
|
|
|
|
|
|
# async def send_data():
|
|
# while not any([r.connected for r in client.relay_manager.relays.values()]):
|
|
# print("no relays connected yet")
|
|
# await asyncio.sleep(0.5)
|
|
# while True:
|
|
# client.dm("test", PublicKey(bytes.fromhex(client.public_key.hex())))
|
|
# print("sent DM")
|
|
# await asyncio.sleep(5)
|
|
# return
|
|
|
|
|
|
# async def receive_data():
|
|
# while not any([r.connected for r in client.relay_manager.relays.values()]):
|
|
# print("no relays connected yet")
|
|
# await asyncio.sleep(0.5)
|
|
|
|
# def callback(event: Event, decrypted_content=None):
|
|
# print(
|
|
# f"From {event.public_key[:3]}..{event.public_key[-3:]}: {decrypted_content or event.content}"
|
|
# )
|
|
|
|
# t = threading.Thread(
|
|
# target=client.get_dm,
|
|
# args=(
|
|
# client.public_key,
|
|
# callback,
|
|
# ),
|
|
# name="Nostr DM",
|
|
# )
|
|
# t.start()
|
|
|
|
|
|
async def subscribe_events():
|
|
while not any([r.connected for r in client.relay_manager.relays.values()]):
|
|
await asyncio.sleep(2)
|
|
|
|
def callback(event: Event):
|
|
# print(f"From {event.public_key[:3]}..{event.public_key[-3:]}: {event.content}")
|
|
asyncio.run(received_event_queue.put(event))
|
|
|
|
t = threading.Thread(
|
|
target=client.subscribe,
|
|
args=(callback,),
|
|
name="Nostr-event-subscription",
|
|
daemon=True,
|
|
)
|
|
t.start()
|