sim1222/fedi-block-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use domain from mastodon instances if not censored

Browse Source
This commit is contained in:
Enju Aihara 2022-03-05 00:15:08 +01:00
parent 00a1a766bb
commit 807d114ea1
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
fetch_blocks.py
View File

@ -8,15 +8,15 @@ c = conn.cursor()
with open("pleroma_instances.txt", "r") as f: with open("pleroma_instances.txt", "r") as f:
while blocker := f.readline().strip(): while blocker := f.readline().strip():
print(blocker) print(blocker)
c.execute(f"delete from blocks where blocker = '{blocker}'") c.execute("delete from blocks where blocker = ?", (blocker,))
conn.commit() conn.commit()
try: try:
json = loads(get(f"https://{blocker}/nodeinfo/2.1.json").text) json = loads(get(f"https://{blocker}/nodeinfo/2.1.json").text)
for mrf in json["metadata"]["federation"]["mrf_simple"]: for mrf in json["metadata"]["federation"]["mrf_simple"]:
for blocked in json["metadata"]["federation"]["mrf_simple"][mrf]: for blocked in json["metadata"]["federation"]["mrf_simple"][mrf]:
c.execute(f"insert into blocks select '{blocker}', '{blocked}', '', '{mrf}'") c.execute("insert into blocks select ?, ?, '', ?", (blocker, blocked, mrf))
for blocked in json["metadata"]["federation"]["quarantined_instances"]: for blocked in json["metadata"]["federation"]["quarantined_instances"]:
c.execute(f"insert into blocks select '{blocker}', '{blocked}', '', 'quarantined_instances'") c.execute("insert into blocks select ?, ?, '', 'quarantined_instances'", (blocker, blocked))
conn.commit() conn.commit()
except: except:
pass pass
@ -24,16 +24,25 @@ with open("pleroma_instances.txt", "r") as f:
with open("mastodon_instances.txt", "r") as f: with open("mastodon_instances.txt", "r") as f:
while blocker := f.readline().strip(): while blocker := f.readline().strip():
print(blocker) print(blocker)
c.execute(f"delete from blocks where blocker = '{blocker}'") c.execute("delete from blocks where blocker = ?", (blocker,))
conn.commit() conn.commit()
try: try:
json = loads(get(f"http://127.0.0.1:8069/{blocker}").text) json = loads(get(f"http://127.0.0.1:8069/{blocker}").text)
for blocked in json["reject"]: for blocked in json["reject"]:
c.execute(f"insert into blocks select '{blocker}', ifnull((select domain from instances where hash = '{blocked['hash']}'), '{blocked['hash']}'), '{blocked['reason']}', 'reject'") if blocked["domain"].count("*") > 1:
c.execute("insert into blocks select ?, ifnull((select domain from instances where hash = ?), ?), ?, 'reject'", (blocker, blocked["hash"], blocked["hash"], blocked['reason']))
else:
c.execute("insert into blocks select ?, ?, ?, 'reject'", (blocker, blocked["domain"], blocked["reason"]))
for blocked in json["media_removal"]: for blocked in json["media_removal"]:
c.execute(f"insert into blocks select '{blocker}', ifnull((select domain from instances where hash = '{blocked['hash']}'), '{blocked['hash']}'), '{blocked['reason']}', 'media_removal'") if blocked["domain"].count("*") > 1:
c.execute("insert into blocks select ?, ifnull((select domain from instances where hash = ?), ?), ?, 'media_removal'", (blocker, blocked["hash"], blocked["hash"], blocked['reason']))
else:
c.execute("insert into blocks select ?, ?, ?, 'media_removal'", (blocker, blocked["domain"], blocked["reason"]))
for blocked in json["federated_timeline_removal"]: for blocked in json["federated_timeline_removal"]:
c.execute(f"insert into blocks select '{blocker}', ifnull((select domain from instances where hash = '{blocked['hash']}'), '{blocked['hash']}'), '{blocked['reason']}', 'federated_timeline_removal'") if blocked["domain"].count("*") > 1:
c.execute("insert into blocks select ?, ifnull((select domain from instances where hash = ?), ?), ?, 'federated_timeline_removal'", (blocker, blocked["hash"], blocked["hash"], blocked['reason']))
else:
c.execute("insert into blocks select ?, ?, ?, 'federated_timeline_removal'", (blocker, blocked["domain"], blocked["reason"]))
conn.commit() conn.commit()
except: except:
pass pass