highperfocused/nostrdvm
1
0
Fork 0
mirror of https://github.com/believethehype/nostrdvm.git synced 2025-06-21 10:41:01 +02:00
Code Issues Packages Projects Releases Wiki Activity

adapting more functions to async

Browse Source
This commit is contained in:
Believethehype 2024-06-09 12:46:44 +02:00
parent f17621e56c
commit 96e0be239f
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/gui/nicegui/nostrAI_search_client.py
View File

@ -13,7 +13,7 @@ from nostr_dvm.utils.definitions import EventDefinitions
@ui.page('/', dark=True) @ui.page('/', dark=True)
def init(): async def init():
keys = Keys.parse(check_and_set_private_key("test_client")) keys = Keys.parse(check_and_set_private_key("test_client"))
opts = (Options().wait_for_send(False).send_timeout(timedelta(seconds=2)) opts = (Options().wait_for_send(False).send_timeout(timedelta(seconds=2))
.skip_disconnected_relays(True)) .skip_disconnected_relays(True))
@ -23,11 +23,11 @@ def init():
relay_list = dvmconfig.DVMConfig.RELAY_LIST relay_list = dvmconfig.DVMConfig.RELAY_LIST
for relay in relay_list: for relay in relay_list:
client.add_relay(relay) await client.add_relay(relay)
client.connect() await client.connect()
data = [] data = []
def nostr_client_test_search(prompt, users=None, since="", until=""): async def nostr_client_test_search(prompt, users=None, since="", until=""):
if users is None: if users is None:
users = [] users = []
@ -53,7 +53,7 @@ def init():
config = DVMConfig config = DVMConfig
config.RELAY_LIST = relay_list config.RELAY_LIST = relay_list
send_event(event, client=client, dvm_config=config) await send_event(event, client=client, dvm_config=config)
return event return event
def handledvm(now, eventid): def handledvm(now, eventid):
@ -135,7 +135,7 @@ def init():
tags.append(pTag.as_vec()) tags.append(pTag.as_vec())
search = str(search).replace("from:", "").replace("to:", "").replace("@", "").lstrip().rstrip() search = str(search).replace("from:", "").replace("to:", "").replace("@", "").lstrip().rstrip()
print(search) print(search)
ev = nostr_client_test_search(search, tags) ev = await nostr_client_test_search(search, tags)
ui.notify('Request sent to DVM, awaiting results..') ui.notify('Request sent to DVM, awaiting results..')
print("Sent: " + ev.as_json()) print("Sent: " + ev.as_json())

2
tests/test_dvm_client.py
View File

@ -148,7 +148,7 @@ async def nostr_client_test_inactive_filter(user):
await client.add_relay_with_opts("wss://nostr.band", ropts) await client.add_relay_with_opts("wss://nostr.band", ropts)
await client.connect() await client.connect()
config = DVMConfig config = DVMConfig
send_event(event, client=client, dvm_config=config) await send_event(event, client=client, dvm_config=config)
return event.as_json() return event.as_json()
async def nostr_client_test_tts(prompt): async def nostr_client_test_tts(prompt):