CMS/mailman-sync
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add dry run argument

Browse Source
This commit is contained in:
Adam Goldsmith 2022-12-25 02:25:24 -05:00
parent fa366e7e63
commit b85005d603
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
mailman_sync.py
View File

@ -11,12 +11,12 @@ import subprocess
import requests
def sync_members(mailman_bin: Path, mailing_list: str, members: list[str]):
def sync_members(mailman_bin: Path, mailing_list: str, members: list[str], dry_run: bool):
members_data = "\n".join(members)
output = subprocess.run(
[
mailman_bin / "sync_members",
"--no-change",
"--no-change" if dry_run else "",
"--welcome-msg=no",
"--goodbye-msg=no",
"--notifyadmin=no",
@ -32,7 +32,7 @@ def sync_members(mailman_bin: Path, mailing_list: str, members: list[str]):
print(output.stdout)
def main(mailman_bin: Path, api: str, token: str, list_suffix: str):
def main(mailman_bin: Path, api: str, token: str, list_suffix: str, dry_run: bool):
r = requests.get(api, headers={"Authorization": "Token " + token})
if not r.ok:
print(f"Failed to get mailing list data from api: {r.status_code} {r.text}")
@ -48,7 +48,7 @@ def main(mailman_bin: Path, api: str, token: str, list_suffix: str):
for name, members in certification_lists.items():
list_name = name + list_suffix
if list_name in existing_lists:
sync_members(mailman_bin, list_name, members)
sync_members(mailman_bin, list_name, members, dry_run)
else:
print(f"Skipping {list_name}, as it does not exist in Mailman")
@ -64,10 +64,11 @@ if __name__ == "__main__":
argp.add_argument("--api", required=True, help="API endpoint to retrieve JSON from")
argp.add_argument("--token", required=True, help="Authorization Token for API")
argp.add_argument("--list-suffix", help="Suffix for mailing lists")
argp.add_argument("-n", "--dry-run", help="Don't make changes, just print what would happen")
args = argp.parse_args()
try:
main(args.bin, args.api, args.token, args.list_suffix)
main(args.bin, args.api, args.token, args.list_suffix, args.dry_run)
except subprocess.CalledProcessError as e:
print(e.stderr)
raise