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

fixes for inactive follows/ empty list postprocessing

Browse Source 
for
This commit is contained in:
Believethehype
2024-01-04 13:46:30 +01:00
parent ec1cc8c913
commit 45c5f60580
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
nostr_dvm/tasks/discovery_inactive_follows.py
View File

@@ -108,14 +108,14 @@ class DiscoverInactiveFollows(DVMTaskInterface):
keys = Keys.from_sk_str(self.dvm_config.PRIVATE_KEY)
opts = Options().wait_for_send(True).send_timeout(
timedelta(seconds=10)).skip_disconnected_relays(False)
timedelta(seconds=5)).skip_disconnected_relays(True)
cli = Client.with_opts(keys, opts)
for relay in self.dvm_config.RELAY_LIST:
cli.add_relay(relay)
cli.connect()
filters = []
for i in range(i + st):
for i in range(i, i + st):
filter1 = Filter().author(PublicKey.from_hex(users[i])).since(notactivesince).limit(1)
filters.append(filter1)
event_from_authors = cli.get_events_of(filters, timedelta(seconds=10))
@@ -131,7 +131,7 @@ class DiscoverInactiveFollows(DVMTaskInterface):
args = [followings, ns, begin, step, not_active_since]
t = Thread(target=scanList, args=args)
threads.append(t)
begin = begin + step
begin = begin + step -1
# last to step size
missing_scans = (len(followings) - begin)
@@ -149,9 +149,6 @@ class DiscoverInactiveFollows(DVMTaskInterface):
result = {k for (k, v) in ns.dic.items() if v == "False"}
if len(result) == 0:
print("Not found")
return "No inactive followers found on relays."
print("Inactive accounts found: " + str(len(result)))
for k in result:
p_tag = Tag.parse(["p", k])

4
nostr_dvm/utils/output_utils.py
View File

@@ -97,6 +97,8 @@ def post_process_result(anno, original_event):
def post_process_list_to_events(result):
result_list = json.loads(result)
result_str = ""
if len(result_list) == 0:
return "No results found"
for tag in result_list:
e_tag = Tag.parse(tag)
result_str = result_str + "nostr:" + EventId.from_hex(
@@ -107,6 +109,8 @@ def post_process_list_to_events(result):
def post_process_list_to_users(result):
result_list = json.loads(result)
result_str = ""
if len(result_list) == 0:
return "No results found"
for tag in result_list:
p_tag = Tag.parse(tag)
result_str = result_str + "nostr:" + PublicKey.from_hex(