From 81e77a5e04daf2cd7f7a2474f0830d874c04dfd5 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Roland=20H=C3=A4der?= Date: Sun, 23 Jul 2023 19:30:13 +0200 Subject: [PATCH] Continued: - better check if no peers has further been added --- fba/networks/misskey.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/fba/networks/misskey.py b/fba/networks/misskey.py index ec35833..c254111 100644 --- a/fba/networks/misskey.py +++ b/fba/networks/misskey.py @@ -86,7 +86,7 @@ def fetch_peers(domain: str) -> list: rows = fetched["json"] - logger.debug("rows(%d)[]='%s'", len(rows), type(rows)) + logger.debug("rows(%d)[]='%s',step=%d", len(rows), type(rows), step) if len(rows) == 0: logger.debug("Returned zero bytes, domain='%s' - BREAK!", domain) break @@ -97,7 +97,7 @@ def fetch_peers(domain: str) -> list: logger.debug("Raising offset by step=%d", step) offset = offset + step - already = 0 + added = 0 logger.debug("rows(%d))[]='%s'", len(rows), type(rows)) for row in rows: logger.debug("row()=%d", len(row)) @@ -112,14 +112,15 @@ def fetch_peers(domain: str) -> list: continue elif row["host"] in peers: logger.debug("Not adding row[host]='%s', already found - SKIPPED!", row['host']) - already = already + 1 continue logger.debug("Adding peer: row[host]='%s'", row['host']) + added = added + 1 peers.append(row["host"]) - if already == len(rows): - logger.debug("Host returned same set of %d instance(s) - BREAK!", already) + logger.debug("added=%d,rows()=%d", added, len(rows)) + if added == 0: + logger.debug("Host returned already added (%d) peers - BREAK!", len(rows)) break logger.debug("peers()=%d - EXIT!", len(peers)) -- 2.39.5