1 Commits

Author SHA1 Message Date
8762112e37 feat: Add Markdown export 2023-01-29 15:24:16 +01:00
4 changed files with 65 additions and 124 deletions

View File

@@ -9,11 +9,11 @@ the mastodon server, this is supposed to be automated with Drone CI.
In order to compare the list entries, we can read the whole blocklist In order to compare the list entries, we can read the whole blocklist
using [the get endpoint](https://docs.joinmastodon.org/methods/admin/domain_blocks/#get). At the same time we read the using [the get endpoint](https://docs.joinmastodon.org/methods/admin/domain_blocks/#get). At the same time we read the
whole file in the repository, make a comparison whole file in the repository, make a comparision
and [remove](https://docs.joinmastodon.org/methods/admin/domain_blocks/#delete) unblocked domains from the blocklist and [remove](https://docs.joinmastodon.org/methods/admin/domain_blocks/#delete) unblocked domains from the blocklist
and [add](https://docs.joinmastodon.org/methods/admin/domain_blocks/#create) newly added. and [add](https://docs.joinmastodon.org/methods/admin/domain_blocks/#create) newly added.
Since we have several attributes for a domain block, a simple `.txt` file might not be sufficient. We probably want to Since we have several attributes for a domain blog, a simple `.txt` file might not be sufficient. We probably want to
set the severity, reject_media, reject_reports and comments. This means we need a human-readable, easily python-readable set the severity, reject_media, reject_reports and comments. This means we need a human-readable, easily python-readable
and structured file format. Since Python 3.11 got native support for [toml](https://toml.io/) and it and structured file format. Since Python 3.11 got native support for [toml](https://toml.io/) and it
supports [Array of Tables](https://toml.io/en/v1.0.0#array-of-tables), I'd prefer to use this. supports [Array of Tables](https://toml.io/en/v1.0.0#array-of-tables), I'd prefer to use this.
@@ -25,15 +25,13 @@ supports [Array of Tables](https://toml.io/en/v1.0.0#array-of-tables), I'd prefe
## ##
``` ```
usage: mastodon_blocklist_deploy [-h] [-s SERVER] [-t TOKEN] [-i INPUT_FILE] [-r REMOTE_BLOCKLIST] [-o OUTPUT] [-v] [-n] $ mastodon_blocklist_deploy -h
[--format FORMAT] [--private] usage: mastodon_blocklist_deploy [-h] [-s SERVER] [-t TOKEN] [-i INPUT_FILE] [-r REMOTE_BLOCKLIST] [-o OUTPUT] [-v] [-n] {diff,deploy,export}
{diff,deploy,export}
Deploy blocklist updates to a mastodon server Deploy blocklist updates to a mastodon server
positional arguments: positional arguments:
{diff,deploy,export} Either use 'diff' to check the difference between local blockĺist and the blocklist on the server, 'deploy' {diff,deploy,export} Either use 'diff' to check the difference between local blockĺist and the blocklist on the server, 'deploy' to apply the current local blocklist or 'export' to export the remote blocklist into a local file.
to apply the current local blocklist or 'export' to export the remote blocklist into a local file.
options: options:
-h, --help show this help message and exit -h, --help show this help message and exit
@@ -49,8 +47,6 @@ options:
Filename where to export the blocklist Filename where to export the blocklist
-v, --verbose -v, --verbose
-n, --no-delete Do not delete existing blocks -n, --no-delete Do not delete existing blocks
--format FORMAT Export format: toml|markdown|csv|json
--private When the flag is set, private comment will also be exported.
``` ```
## Obtain a server token ## Obtain a server token
@@ -91,4 +87,4 @@ mastodon_blocklist_deploy diff -s yourserver -t yourtoken -i blocklist.toml
``` ```
mastodon_blocklist_deploy apply -s yourserver -t yourtoken -i blocklist.toml mastodon_blocklist_deploy apply -s yourserver -t yourtoken -i blocklist.toml
``` ```

View File

@@ -7,8 +7,7 @@ import os
import toml import toml
from mastodon_blocklist_deploy.models import Instance from mastodon_blocklist_deploy.models import Instance
from mastodon_blocklist_deploy.helpers import blocklist_to_markdown, blocklist_to_toml, blocklist_to_csv, \ from mastodon_blocklist_deploy.helpers import blocklist_to_markdown
blocklist_to_json
def load_blocklist_file(filename: str) -> [Instance]: def load_blocklist_file(filename: str) -> [Instance]:
@@ -40,61 +39,16 @@ def load_blocklist_from_instance(server: str, token: str) -> [Instance]:
else: else:
raise ConnectionError(f"Could not connect to the server ({response.status_code}: {response.reason})") raise ConnectionError(f"Could not connect to the server ({response.status_code}: {response.reason})")
def remove_key_from_dict(dict, key): def remove_key_from_dict(dict, key):
del dict[key] del dict[key]
return dict return dict
def exporter(blocklist, output=None, format: str = "toml", private: bool = False):
if format == "toml":
exported_text = blocklist_to_toml(blocklist, private)
if format == "csv":
exported_text = blocklist_to_csv(blocklist, private)
if format == "markdown":
exported_text = blocklist_to_markdown(blocklist, private)
if format == "json":
exported_text = blocklist_to_json(blocklist, private)
# Output the text
if output is not None:
with open(output, "w") as f:
f.write(exported_text)
else:
print(exported_text)
def merge(input_file, merge_target, format: str = "toml", private: bool = False, overwrite=False):
input_blocklist = load_blocklist_file(input_file)
merge_target_blocklist = load_blocklist_file(merge_target)
for input_instance in input_blocklist:
# If the block is already there with the same parameters we do nothing
if input_instance in merge_target_blocklist:
continue
# Check if there is a domain in the merge target where the input domain is similar
try:
merge_target_instance = [merge_target_instance for merge_target_instance in merge_target if input_instance.domain == merge_target_instance.domain][0]
if not overwrite:
key_input = ""
while key_input not in ("i", "O"):
print(f"Different settings for {input_instance.domain} detected.")
print(f"In the input blocklist the setting is\n{input_instance} whereas it's {merge_target_instance} in the merge target")
key_input = input("Keep input (i) or original (o) [i/O]")
elif key_input == "i":
merge_target_blocklist.append(merge_target_instance)
else:
merge_target_blocklist.append(input_instance)
except KeyError:
pass
def cli(): def cli():
parser = argparse.ArgumentParser(description='Deploy blocklist updates to a mastodon server') parser = argparse.ArgumentParser(description='Deploy blocklist updates to a mastodon server')
parser.add_argument('action', choices=['diff', 'deploy', 'export', 'merge'], parser.add_argument('action', choices=['diff', 'deploy', 'export'],
help="Either use 'diff' to check the difference between local blockĺist and the blocklist on " help="Either use 'diff' to check the difference between local blockĺist and the blocklist on "
"the server, 'deploy' to apply the current local blocklist or 'export' to export the remote " "the server, 'deploy' to apply the current local blocklist or 'export' to export the remote "
"blocklist into a local file. merge can be used to merge a blocklist (given by -i) into " "blocklist into a local file.")
"another (-o)")
parser.add_argument('-s', '--server', help="The address of the server where you want to deploy (e.g. " parser.add_argument('-s', '--server', help="The address of the server where you want to deploy (e.g. "
"mastodon.social)") "mastodon.social)")
parser.add_argument('-t', '--token', help="Authorization token") parser.add_argument('-t', '--token', help="Authorization token")
@@ -103,9 +57,7 @@ def cli():
parser.add_argument('-o', '--output', help="Filename where to export the blocklist") parser.add_argument('-o', '--output', help="Filename where to export the blocklist")
parser.add_argument('-v', '--verbose', action='store_true') parser.add_argument('-v', '--verbose', action='store_true')
parser.add_argument('-n', '--no-delete', action='store_true', help="Do not delete existing blocks") parser.add_argument('-n', '--no-delete', action='store_true', help="Do not delete existing blocks")
parser.add_argument('--format', help="Export format: toml|markdown|csv|json") parser.add_argument('--markdown', action='store_true', help="Export as markdown table")
parser.add_argument('--private', action='store_true', help="When the flag is set, private comment will also be "
"exported.")
args = parser.parse_args() args = parser.parse_args()
if args.verbose: if args.verbose:
logging.basicConfig(level=logging.DEBUG) logging.basicConfig(level=logging.DEBUG)
@@ -117,6 +69,8 @@ def cli():
else: else:
token = os.getenv('MBD_TOKEN') token = os.getenv('MBD_TOKEN')
"""if there is a remote blocklist provided load this instead of fetching it from a server (for debugging reasons)""" """if there is a remote blocklist provided load this instead of fetching it from a server (for debugging reasons)"""
if args.remote_blocklist: if args.remote_blocklist:
with open(args.remote_blocklist) as f: with open(args.remote_blocklist) as f:
@@ -125,7 +79,7 @@ def cli():
remote_blocklist = load_blocklist_from_instance(server=args.server, token=token) remote_blocklist = load_blocklist_from_instance(server=args.server, token=token)
"""Load local blocklist only when needed""" """Load local blocklist only when needed"""
if args.action in ["diff", "deploy", "merge"]: if args.action in ["diff", "deploy"]:
if args.input_file: if args.input_file:
blocklist_filename = args.input_file blocklist_filename = args.input_file
else: else:
@@ -142,9 +96,17 @@ def cli():
diffs = Instance.list_diffs(local_blocklist, remote_blocklist) diffs = Instance.list_diffs(local_blocklist, remote_blocklist)
Instance.apply_blocks_from_diff(diffs, args.server, token, args.no_delete) Instance.apply_blocks_from_diff(diffs, args.server, token, args.no_delete)
elif args.action == "export": elif args.action == "export":
exporter(remote_blocklist, args.output, args.format, args.private) if not args.output:
elif args.action == "merge": if args.markdown:
merge(args.input_file, args.output, args.format, args.private) print(blocklist_to_markdown(remote_blocklist))
else:
print(toml.dumps({"instances": [remove_key_from_dict(b.__dict__, 'id') for b in remote_blocklist]}))
else:
with open(args.output, "w") as f:
if args.markdown:
f.write(blocklist_to_markdown(remote_blocklist))
else:
toml.dump({"instances": [remove_key_from_dict(b.__dict__, 'id') for b in remote_blocklist]}, f)
if __name__ == "__main__": if __name__ == "__main__":

View File

@@ -1,36 +1,6 @@
from mastodon_blocklist_deploy.models import Instance from mastodon_blocklist_deploy.models import Instance
import toml def blocklist_to_markdown(blocklist:[Instance]):
import io markdown_string = "| Instance | Status | Reason |\n | --- | --- | --- |\n"
import csv
import json
def blocklist_to_markdown(blocklist: [Instance], private: bool = False):
if private:
markdown_string = "| Instance | Status | Reason | Private Comment |\n | --- | --- | --- |\n"
else:
markdown_string = "| Instance | Status | Reason |\n | --- | --- | --- |\n"
for instance in blocklist: for instance in blocklist:
markdown_string += f"| {instance.domain} | {instance.severity} | {instance.public_comment} |\n"
if private: return markdown_string
markdown_string += f"| {instance.domain} | {instance.severity} | {instance.public_comment} | {instance.private_comment} |\n"
else:
markdown_string += f"| {instance.domain} | {instance.severity} | {instance.public_comment} |\n"
return markdown_string
def blocklist_to_toml(blocklist: [Instance], private: bool = False):
toml_string = toml.dumps({"instances": [b.as_dict(private) for b in blocklist]})
return toml_string
def blocklist_to_csv(blocklist: [Instance], private: bool = False):
csv_string = io.StringIO()
blocklist_as_dict = [b.as_dict(private) for b in blocklist]
keys = blocklist_as_dict[0].keys()
w = csv.DictWriter(csv_string, keys)
w.writeheader()
w.writerows(blocklist_as_dict)
return csv_string.getvalue()
def blocklist_to_json(blocklist: [Instance], private: bool = False):
json_string = json.dumps([b.as_dict(private) for b in blocklist])
return json_string

View File

@@ -11,7 +11,12 @@ class Instance:
self.reject_reports = False self.reject_reports = False
self.id = None self.id = None
self.parse_block(instance_dict) """Remote blocks and local blocks are parsed differently"""
try:
instance_dict["id"]
self.parse_remote_block(instance_dict)
except KeyError:
self.parse_local_block(instance_dict)
def __str__(self): def __str__(self):
return f"{self.domain}: {self.severity}" return f"{self.domain}: {self.severity}"
@@ -22,29 +27,37 @@ class Instance:
def status_str(self): def status_str(self):
return f"{self.severity}\nReject reports: {self.reject_reports}\nReject media: {self.reject_media}\nObfuscate: {self.obfuscate}" return f"{self.severity}\nReject reports: {self.reject_reports}\nReject media: {self.reject_media}\nObfuscate: {self.obfuscate}"
def as_dict(self, private=False): def parse_remote_block(self, instance_dict):
keys = ["domain", "severity", "public_comment", "obfuscate", "reject_media", "reject_reports"] self.domain = instance_dict["domain"]
if private: self.id = instance_dict["id"]
keys.append("private_comment") self.severity = instance_dict["severity"]
exportable = {} self.public_comment = instance_dict["public_comment"]
for key in keys: self.private_comment = instance_dict["private_comment"]
exportable[key] = getattr(self, key) self.obfuscate = instance_dict["obfuscate"]
return exportable self.reject_media = instance_dict["reject_media"]
self.reject_reports = instance_dict["reject_reports"]
def parse_block(self, instance_dict): def parse_local_block(self, instance_dict):
# this specifies possible properties and default values if not found on the remote source. If a default is None try:
# the value is required and the parse will fail self.name = instance_dict["name"]
properties_and_defaults = [("domain", None), ("severity", "suspend"), ("public_comment", ""), except KeyError:
("private_comment", ""), ("obfuscate", False), ("reject_media", True), pass
("reject_reports", True)] self.domain = instance_dict["domain"]
for key, default in properties_and_defaults: self.severity = instance_dict["severity"]
try: self.public_comment = instance_dict["public_comment"]
setattr(self, key, instance_dict[key]) self.private_comment = instance_dict["private_comment"]
except KeyError: try:
if default is not None: self.obfuscate = instance_dict["obfuscate"]
setattr(self, key, default) except KeyError:
else: pass
raise KeyError(f"The key {key} was not in the instance_dict response.") try:
self.reject_media = instance_dict["reject_media"]
except KeyError:
pass
try:
self.reject_reports = instance_dict["reject_reports"]
except KeyError:
pass
def apply(self, server, token, block_id=None): def apply(self, server, token, block_id=None):
"""Applies instance block on the remote server""" """Applies instance block on the remote server"""
@@ -65,7 +78,7 @@ class Instance:
response = requests.put(f'https://{server}/api/v1/admin/domain_blocks/{block_id}', data=data, response = requests.put(f'https://{server}/api/v1/admin/domain_blocks/{block_id}', data=data,
headers=headers) headers=headers)
if response.status_code != 200: if response.status_code != 200:
raise ConnectionError(f"Could not apply block for {self.domain} ({response.status_code}: {response.reason})") raise ConnectionError(f"Could not apply block ({response.status_code}: {response.reason})")
def delete(self, server: str, token: str): def delete(self, server: str, token: str):
"""Deletes the instance from the blocklist on the remote server""" """Deletes the instance from the blocklist on the remote server"""