+ searchres = fba.c.fetchone()
+ if searchres != None:
+ blocked = searchres[0]
+
+ # NOISY-DEBUG: print("DEBUG: AFTER-blocked:", blocked)
+ fba.c.execute(
+ "SELECT domain FROM instances WHERE domain = ?", (blocked,)
+ )
+
+ if fba.c.fetchone() == None:
+ # NOISY-DEBUG: print("DEBUG: Hash wasn't found, adding:", blocked)
+ fba.add_instance(blocked)
+
+ timestamp = int(time.time())
+ fba.c.execute(
+ "SELECT * FROM blocks WHERE blocker = ? AND blocked = ?",
+ (blocker, blocked),
+ )
+ if fba.c.fetchone() == None:
+ fba.block_instance(blocker, blocked, reason, block_level, timestamp, timestamp)
+
+ if block_level == "reject":
+ blockdict.append(
+ {
+ "blocked": blocked,
+ "reason": reason
+ })
+ else:
+ fba.update_last_seen(timestamp, blocker, blocked, block_level)
+
+ if reason != '':
+ # NOISY-DEBUG: print("DEBUG: Updating block reason:", blocker, blocked, reason)
+ fba.update_block_reason(reason, blocker, blocked, block_level)
+
+ fba.conn.commit()
+ except Exception as e:
+ print("error:", e, blocker, software)
+ elif software == "gotosocial":
+ print("INFO: blocker:", blocker)
+ try:
+ # Blocks
+ federation = reqto.get(f"https://{blocker}/api/v1/instance/peers?filter=suspended", headers=fba.headers, timeout=5).json()
+
+ if (federation == None):
+ print("WARNING: No valid response:", blocker);
+ elif "error" in federation:
+ print("WARNING: API returned error:", federation["error"])
+ else:
+ # NOISY-DEBUG: print("DEBUG: Checking fenderation():", len(federation))
+ for peer in federation:
+ blocked = peer["domain"].lower()
+ # NOISY-DEBUG: print("DEBUG: BEFORE-blocked:", blocked)
+ blocked = fba.tidyup(blocked)
+ # NOISY-DEBUG: print("DEBUG: AFTER-blocked:", blocked)
+
+ if blocked == "":
+ print("WARNING: blocked is empty:", blocker)
+ continue
+ if blocked.count("*") > 0:
+ # GTS does not have hashes for obscured domains, so we have to guess it
+ fba.c.execute(
+ "SELECT domain FROM instances WHERE domain LIKE ? ORDER BY rowid LIMIT 1", (blocked.replace("*", "_"),)
+ )
+ searchres = fba.c.fetchone()
+
+ if searchres != None:
+ blocked = searchres[0]
+
+ fba.c.execute(
+ "SELECT domain FROM instances WHERE domain = ?", (blocked,)
+ )
+
+ if fba.c.fetchone() == None:
+ # NOISY-DEBUG: print("DEBUG: Hash wasn't found, adding:", blocked)
+ fba.add_instance(blocked)
+
+ fba.c.execute(
+ "SELECT * FROM blocks WHERE blocker = ? AND blocked = ? AND block_level = ?",
+ (
+ blocker,
+ blocked,
+ "reject"
+ ),
+ )
+ timestamp = int(time.time())
+
+ if fba.c.fetchone() == None:
+ fba.block_instance(blocker, blocked, "unknown", "reject", timestamp, timestamp)
+
+ blockdict.append(
+ {
+ "blocked": blocked,
+ "reason": None
+ })
+ else:
+ fba.update_last_seen(timestamp, blocker, blocked, "reject")
+
+ if "public_comment" in peer:
+ reason = peer["public_comment"]
+ # NOISY-DEBUG: print("DEBUG: Updating block reason:", blocker, blocked, reason)
+ fba.update_block_reason(reason, blocker, blocked, "reject")
+
+ for entry in blockdict:
+ if entry["blocked"] == blocked:
+ entry["reason"] = reason
+
+ fba.conn.commit()