highperfocused/nostrdvm
1
0
Fork 0
mirror of https://github.com/believethehype/nostrdvm.git synced 2025-11-19 18:47:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

fixes related to new nostrsdk version

Browse Source
This commit is contained in:
Believethehype
2024-01-19 15:17:34 +01:00
parent 756962ea6f
commit a53fb71cba
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
nostr_dvm/tasks/discovery_inactive_follows.py
View File

@@ -3,7 +3,7 @@ import os
from datetime import timedelta from datetime import timedelta
from threading import Thread from threading import Thread
from nostr_sdk import Client, Timestamp, PublicKey, Tag, Keys, Options, SecretKey from nostr_sdk import Client, Timestamp, PublicKey, Tag, Keys, Options, SecretKey, ClientSigner
from nostr_dvm.interfaces.dvmtaskinterface import DVMTaskInterface, process_venv from nostr_dvm.interfaces.dvmtaskinterface import DVMTaskInterface, process_venv
from nostr_dvm.utils.admin_utils import AdminConfig from nostr_dvm.utils.admin_utils import AdminConfig
@@ -69,7 +69,8 @@ class DiscoverInactiveFollows(DVMTaskInterface):
opts = (Options().wait_for_send(False).send_timeout(timedelta(seconds=self.dvm_config.RELAY_TIMEOUT))) opts = (Options().wait_for_send(False).send_timeout(timedelta(seconds=self.dvm_config.RELAY_TIMEOUT)))
sk = SecretKey.from_hex(self.dvm_config.PRIVATE_KEY) sk = SecretKey.from_hex(self.dvm_config.PRIVATE_KEY)
keys = Keys.from_sk_str(sk.to_hex()) keys = Keys.from_sk_str(sk.to_hex())
cli = Client.with_opts(keys, opts) signer = ClientSigner.keys(keys)
cli = Client.with_opts(signer, opts)
for relay in self.dvm_config.RELAY_LIST: for relay in self.dvm_config.RELAY_LIST:
cli.add_relay(relay) cli.add_relay(relay)
cli.connect() cli.connect()
@@ -109,7 +110,8 @@ class DiscoverInactiveFollows(DVMTaskInterface):
keys = Keys.from_sk_str(self.dvm_config.PRIVATE_KEY) keys = Keys.from_sk_str(self.dvm_config.PRIVATE_KEY)
opts = Options().wait_for_send(True).send_timeout( opts = Options().wait_for_send(True).send_timeout(
timedelta(seconds=5)).skip_disconnected_relays(True) timedelta(seconds=5)).skip_disconnected_relays(True)
cli = Client.with_opts(keys, opts) signer = ClientSigner.keys(keys)
cli = Client.with_opts(signer, opts)
for relay in self.dvm_config.RELAY_LIST: for relay in self.dvm_config.RELAY_LIST:
cli.add_relay(relay) cli.add_relay(relay)
cli.connect() cli.connect()