feat: Support multi-thread merging.

Author: CarmJos

README.md

@@ -2,7 +2,7 @@
 
 A simple python script to merge all filtered PRs in a GitHub user/org/repository.
 
-![Example](example.png)
+![Example](doc/example.png)
 
 ## Usage
 

example.png doc/example.png

@@ -4,30 +4,41 @@
 from colorama import init, Fore, Back, Style
 import sys
 
-# 访问秘钥和线程配置
+# Replace with your own GitHub token.
+# See https://docs.github.com/en/github/authenticating-to-github/creating-a-personal-access-token
 ACCESS_TOKEN = "ghp_xxxxxxxxxxxxxxxxxxxx"
-THREAD = 4  # 默认线程数量
+THREAD = 4  # Thread count, default 4.
 
 
 def pr_filter(pr):
-    """优化后的PR过滤器，假设已通过state='open'过滤"""
     if pr.draft:
         return False
     if pr.user.login in ["dependabot[bot]", "renovate[bot]"]:
         return True
     return False
 
 
+def repo_filter(repo):
+    if repo.archived: return False;
+    return True
+
+
+def prefix(color: Fore, status, name):
+    return f"{color}[{status}] {Fore.RESET}<{Fore.LIGHTBLUE_EX}{name}{Fore.RESET}>"
+
 def handle_repo(r: Repository):
+    if not repo_filter(r):
+        tqdm.write(f"{prefix(Fore.MAGENTA, "START", r.name)} Repo filtered, skipped.")
+
     try:
         pull_requests = r.get_pulls(state='open')
         pr_list = list(pull_requests)
         pr_count = len(pr_list)
 
         if pr_count == 0:
-            tqdm.write(f"{Fore.MAGENTA}[START] {Fore.RESET}<{Fore.LIGHTBLUE_EX}{r.name}{Fore.RESET}> No PRs found, skipped.")
+            tqdm.write(f"{prefix(Fore.MAGENTA, "START", r.name)} No PRs found, skipped.")
             return
-        tqdm.write(f"{Fore.MAGENTA}[START] {Fore.RESET}<{Fore.LIGHTBLUE_EX}{r.name}{Fore.RESET}> with {pr_count} PRs.")
+        tqdm.write(f"{prefix(Fore.MAGENTA, "START", r.name)} with {pr_count} PRs, processing.")
 
         stats = {'skipped': 0, 'done': 0, 'errors': 0}
         with tqdm(pr_list, desc=f"{r.name:15}", leave=False) as pbar:
@@ -45,20 +56,17 @@ def handle_repo(r: Repository):
                     stats['done'] += 1
                 except Exception as ex:
                     stats['errors'] += 1
-                    tqdm.write(
-                        f"{Fore.RED}[ERROR] {Fore.RESET}<{Fore.BLUE}{r.name}{Fore.CYAN}#{pr.number}{Fore.RESET}>"
-                        f" Failed to process : {str(ex)}"
-                    )
+                    tqdm.write(f"{prefix(Fore.RED, 'ERROR', r.name)} Failed to process #{pr.id}: {str(ex)}")
                 finally:
                     pbar.set_postfix_str(f"S:{stats['skipped']} D:{stats['done']} E:{stats['errors']}")
         tqdm.write(
-            f"{Fore.GREEN}[DONE] {Fore.RESET}<{Fore.LIGHTBLUE_EX}{r.name}{Fore.RESET}> "
+            f"{prefix(Fore.RED, 'DONE', r.name)} "
             f"MERGED: {stats['done']}  "
             f"SKIPPED: {stats['skipped']}  "
             f"ERRORS: {stats['errors']} "
         )
     except Exception as ex:
-        tqdm.write(f"{Fore.RED}[ERROR] <{Fore.BLUE}{r.name}{Fore.RESET}> Failed to process : {str(ex)}")
+        tqdm.write(f"{prefix(Fore.RED, 'ERROR', r.name)} Failed to process : {str(ex)}")
 
 
 if __name__ == "__main__":
@@ -89,7 +97,7 @@ def handle_repo(r: Repository):
         with ThreadPoolExecutor(max_workers=THREAD) as executor:
             futures = [executor.submit(handle_repo, repo) for repo in repos]
 
-            with tqdm(total=len(repos), unit="repo",desc="Repositories Progress") as main_pbar:
+            with tqdm(total=len(repos), unit="repo", desc="Repositories Progress") as main_pbar:
                 for future in as_completed(futures):
                     try:
                         future.result()