Notation applied:

[fba.git] / fba / networks / misskey.py

diff --git a/fba/networks/misskey.py b/fba/networks/misskey.py
index 1320d06f394b974a14a6e79cf8a37e7e82f78e40..e47c7dd9d04548c5d63171fec5dfb7665a83e69a 100644 (file)
--- a/fba/networks/misskey.py
+++ b/fba/networks/misskey.py
@@ -55,7 +55,7 @@ def fetch_peers(domain: str) -> list:
     # instances page-by-page, since that troonware doesn't support
     # sending them all at once
     while True:
-        logger.debug("Fetching offset='%d' from domain='%s' ...", offset, domain)
+        logger.debug("Fetching offset=%d from domain='%s' ...", offset, domain)
         if offset == 0:
             fetched = network.post_json_api(domain, "/api/federation/instances", json.dumps({
                 "sort" : "+pubAt",
@@ -91,7 +91,7 @@ def fetch_peers(domain: str) -> list:
             logger.debug("Fetched %d row(s) but expected: %d", len(rows), config.get('misskey_limit'))
             offset = offset + (config.get("misskey_limit") - len(rows))
         else:
-            logger.debug("Raising offset by step='%d'", step)
+            logger.debug("Raising offset by step=%d", step)
             offset = offset + step
 
         already = 0
@@ -119,9 +119,6 @@ def fetch_peers(domain: str) -> list:
             logger.debug("Host returned same set of %d instance(s) - BREAK!", already)
             break
 
-    logger.debug("Adding %d for domain='%s'", len(peers), domain)
-    instances.set_total_peers(domain, peers)
-
     logger.debug("peers()=%d - EXIT!", len(peers))
     return peers
 
@@ -150,9 +147,9 @@ def fetch_blocks(domain: str) -> list:
     # instances page-by-page since it doesn't support sending them all at once
     while True:
         try:
-            logger.debug("Fetching offset='%d' from domain='%s' ...", offset, domain)
+            logger.debug("Fetching offset=%d from domain='%s' ...", offset, domain)
             if offset == 0:
-                logger.debug("Sending JSON API request to domain='%s',step='%d',offset='%d'", domain, step, offset)
+                logger.debug("Sending JSON API request to domain='%s',step=%d,offset=%d", domain, step, offset)
                 fetched = network.post_json_api(domain, "/api/federation/instances", json.dumps({
                     "sort"     : "+pubAt",
                     "host"     : None,
@@ -160,7 +157,7 @@ def fetch_blocks(domain: str) -> list:
                     "limit"    : step
                 }), headers)
             else:
-                logger.debug("Sending JSON API request to domain='%s',step='%d',offset='%d'", domain, step, offset)
+                logger.debug("Sending JSON API request to domain='%s',step=%d,offset=%d", domain, step, offset)
                 fetched = network.post_json_api(domain, "/api/federation/instances", json.dumps({
                     "sort"     : "+pubAt",
                     "host"     : None,
@@ -189,7 +186,7 @@ def fetch_blocks(domain: str) -> list:
                 logger.debug("Fetched %d row(s) but expected: %d", len(rows), config.get('misskey_limit'))
                 offset = offset + (config.get("misskey_limit") - len(rows))
             else:
-                logger.debug("Raising offset by step='%d'", step)
+                logger.debug("Raising offset by step=%d", step)
                 offset = offset + step
 
             count = 0
@@ -220,7 +217,7 @@ def fetch_blocks(domain: str) -> list:
         # Fetch blocked (full suspended) instances
         try:
             if offset == 0:
-                logger.debug("Sending JSON API request to domain='%s',step='%d',offset='%d'", domain, step, offset)
+                logger.debug("Sending JSON API request to domain='%s',step=%d,offset=%d", domain, step, offset)
                 fetched = network.post_json_api(domain, "/api/federation/instances", json.dumps({
                     "sort"   : "+pubAt",
                     "host"   : None,
@@ -228,7 +225,7 @@ def fetch_blocks(domain: str) -> list:
                     "limit"  : step
                 }), headers)
             else:
-                logger.debug("Sending JSON API request to domain='%s',step='%d',offset='%d'", domain, step, offset)
+                logger.debug("Sending JSON API request to domain='%s',step=%d,offset=%d", domain, step, offset)
                 fetched = network.post_json_api(domain, "/api/federation/instances", json.dumps({
                     "sort"   : "+pubAt",
                     "host"   : None,
@@ -257,7 +254,7 @@ def fetch_blocks(domain: str) -> list:
                 logger.debug("Fetched %d row(s) but expected: %d'", len(rows), config.get('misskey_limit'))
                 offset = offset + (config.get("misskey_limit") - len(rows))
             else:
-                logger.debug("Raising offset by step='%d'", step)
+                logger.debug("Raising offset by step=%d", step)
                 offset = offset + step
 
             count = 0