reorganzizing

harbor-user-offboarding/sanitize_harbor_user.py

+#!/usr/bin/python3
+import argparse
+import sys
+import requests
+import json
+import os
+import logging
+from requests.auth import HTTPBasicAuth
+
+def _cache_rpm_repo(sync_type, group, src_repo, dest_repo, proxies):
+    _create_repo(sync_type, group, dest_repo, src_repo, proxies)
+    package_repo = repomd.load(src_repo)
+
+    logs.info(package_repo)
+    for package in package_repo:
+        logs.info(f"getting package {dest_repo}{package.location}")
+        r = requests.head(f"{dest_repo}{package.location}", proxies=proxies)
+
+def main():
+    parser = argparse.ArgumentParser(description='Cache RPM and Debian packages in Nexus')
+
+    parser.add_argument('repo_file', help="Run on a single repo", default="repo_file.json")
+    parser.add_argument('--proxy', help="Add proxy for staging", default={})
+    args = parser.parse_args()
+
+    proxies = args.proxy
+
+    if args.proxy:
+        proxies = {
+            'http': f'{args.proxy}',
+            'https': f'{args.proxy}',
+        }
+
+if __name__ == "__main__":
+    logs = logging.getLogger("mirror")
+    # Get logging level, set manually when running pipeline
+    loglevel = os.environ.get("LOGLEVEL", "INFO").upper()
+    if loglevel == "DEBUG":
+        logging.basicConfig(
+            level=loglevel,
+            filename="mirror_log.out",
+            format="%(levelname)s [%(filename)s:%(lineno)d]: %(message)s",
+        )
+        logging.debug("Log level set to debug")
+    else:
+        logging.basicConfig(level=loglevel, format="%(levelname)s: %(message)s")
+        logging.info("Log level set to info")
+    sys.exit(main())