Continued:

- added warning if get_peers() fails
- added sys.exit() if this happens for provided instance from command-line

diff --git a/fetch_instances.py b/fetch_instances.py
index e983924879333c5193e574b1f066750e7a3f3e33..20df590b761c1def4fdfc84e9b1b7586cfe352bd 100644 (file)
--- a/fetch_instances.py
+++ b/fetch_instances.py
@@ -21,20 +21,23 @@ headers = {
     "user-agent": config["useragent"]
 }
 
-
 def get_hash(domain: str) -> str:
     return sha256(domain.encode("utf-8")).hexdigest()
 
-
 def get_peers(domain: str) -> str:
     try:
         res = get(f"https://{domain}/api/v1/instance/peers", headers=headers, timeout=5)
         return res.json()
     except:
+        print("WARNING: Cannot fetch peers:", domain)
         return None
 
 peerlist = get_peers(domain)
 
+if (peerlist is None):
+    print("FATAL: CANNOT FETCH PEERS:", domain)
+    sys.exit(255)
+
 def get_type(instdomain: str) -> str:
     try:
         res = get(f"https://{instdomain}/nodeinfo/2.1.json", headers=headers, timeout=5)
@@ -65,7 +68,7 @@ conn = sqlite3.connect("blocks.db")
 c = conn.cursor()
 
 c.execute(
-    "SELECT domain FROM  instances WHERE 1"
+    "SELECT domain FROM instances WHERE 1"
 )
 
 for instance in peerlist:
@@ -82,7 +85,7 @@ for instance in peerlist:
     print(instance)
     try:
         c.execute(
-            "SELECT domain FROM  instances WHERE domain = ?", (instance,)
+            "SELECT domain FROM instances WHERE domain = ?", (instance,)
         )
         if c.fetchone() == None:
             c.execute(