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

write to own relays, too.

Browse Source
This commit is contained in:
dbth
2025-02-06 20:35:11 +01:00
parent 1cc969119c
commit c95b0836be
3 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -200,3 +200,4 @@ tests/gifs/data.mdb
tests/gifs/lock.mdb tests/gifs/lock.mdb
tests/gif_library.py tests/gif_library.py
/.idea /.idea
/.idea

3
nostr_dvm/tasks/discovery_inactive_follows.py
View File

@@ -23,6 +23,9 @@ Params: None
""" """
# TODO: This is currently broken after SDK update.
class DiscoverInactiveFollows(DVMTaskInterface): class DiscoverInactiveFollows(DVMTaskInterface):
KIND: Kind = EventDefinitions.KIND_NIP90_PEOPLE_DISCOVERY KIND: Kind = EventDefinitions.KIND_NIP90_PEOPLE_DISCOVERY
TASK: str = "inactive-followings" TASK: str = "inactive-followings"

11
nostr_dvm/utils/nostr_utils.py
View File

@@ -178,7 +178,7 @@ async def get_main_relays(event_to_send: Event, client: Client, dvm_config):
async def send_event_outbox(event: Event, client, dvm_config) -> SendEventOutput | None: async def send_event_outbox(event: Event, client, dvm_config) -> SendEventOutput | None:
# 1. OK, Let's overcomplicate things. # 1. OK, Let's overcomplicate things.
# 2. If our event has a relays tag, we just send the event to these relay in the classical way. # 2. If our event has a relays tag, we just send the event to these relay in the classical way.
relays = [] relays = dvm_config.RELAY_LIST
for tag in event.tags().to_vec(): for tag in event.tags().to_vec():
if tag.as_vec()[0] == 'relays': if tag.as_vec()[0] == 'relays':
for index, param in enumerate(tag.as_vec()): for index, param in enumerate(tag.as_vec()):
@@ -192,20 +192,15 @@ async def send_event_outbox(event: Event, client, dvm_config) -> SendEventOutput
break break
# 3. If we couldn't find relays, we look in the receivers inbox # 3. If we couldn't find relays, we look in the receivers inbox
if len(relays) == 0: if len(relays) == len(dvm_config.RELAY_LIST):
relays = await get_inbox_relays(event, client, dvm_config) relays = await get_inbox_relays(event, client, dvm_config)
# 4. If we don't find inbox relays (e.g. because the user didn't announce them, we just send to our default relays # 4. If we don't find inbox relays (e.g. because the user didn't announce them, we just send to our default relays
if len(relays) == 0: if len(relays) == len(dvm_config.RELAY_LIST):
print("[" + dvm_config.NIP89.NAME + "] No Inbox found, replying to generic relays") print("[" + dvm_config.NIP89.NAME + "] No Inbox found, replying to generic relays")
relays = await get_main_relays(event, client, dvm_config) relays = await get_main_relays(event, client, dvm_config)
if len(relays) == 0:
return
# eventid = await send_event(event, client, dvm_config)
# return eventid
# 5. Otherwise, we create a new Outbox client with the inbox relays and send the event there # 5. Otherwise, we create a new Outbox client with the inbox relays and send the event there
relaylimits = RelayLimits.disable() relaylimits = RelayLimits.disable()
connection = Connection().addr("127.0.0.1:9050").target(ConnectionTarget.ONION) connection = Connection().addr("127.0.0.1:9050").target(ConnectionTarget.ONION)