add gitlab_repo_merge_request

Signed-off-by: Feng Huang <fehuang@redhat.com>

Author: BumbleFeng

reconcile/queries.py

@@ -1748,7 +1748,7 @@ def get_repos_gitlab_housekeeping(server: str = "") -> list[dict[str, Any]]:
     """
     code_components = get_code_components()
     return [
-        {"url": c["url"], "housekeeping": c["gitlabHousekeeping"]}
+        {"name": c["name"], "url": c["url"], "housekeeping": c["gitlabHousekeeping"]}
         for c in code_components
         if c["url"].startswith(server)
         and c["gitlabHousekeeping"]

reconcile/utils/gitlab_api.py

@@ -401,8 +401,12 @@ def get_issues(self, state: str) -> list[ProjectIssue]:
     def get_merge_request(self, mr_id: str | int) -> ProjectMergeRequest:
         return self.project.mergerequests.get(mr_id)
 
-    def get_merge_requests(self, state: str) -> list[ProjectMergeRequest]:
-        return self.project.mergerequests.list(state=state, get_all=True)
+    def get_merge_requests(
+        self, state: str, order_by: str = "created_at"
+    ) -> list[ProjectMergeRequest]:
+        return self.project.mergerequests.list(
+            state=state, order_by=order_by, get_all=True
+        )
 
     @staticmethod
     def get_merge_request_label_events(

tools/qontract_cli.py

@@ -2249,6 +2249,109 @@ def sre_checkpoints(ctx: click.Context) -> None:
     print_output(ctx.obj["options"], checkpoints_data, columns)
 
 
+@get.command()
+@click.pass_context
+@click.option(
+    "--repo-name",
+    help="Specifies the gitlab repo name",
+    type=str,
+)
+@click.option(
+    "--ignore-awaiting-approval",
+    help="Ignore MR awaiting approval",
+    default=False,
+    type=bool,
+)
+def gitlab_repo_merge_request(
+    ctx: click.Context,
+    repo_name: str,
+    ignore_awaiting_approval: bool,
+) -> None:
+    import reconcile.gitlab_housekeeping as glhk
+
+    instance = queries.get_gitlab_instance()
+    settings = queries.get_app_interface_settings()
+    repos = [
+        r
+        for r in queries.get_repos_gitlab_housekeeping(server=instance["url"])
+        if r["name"] == repo_name
+    ]
+    if len(repos) != 1:
+        print(f"{repo_name} name error")
+        sys.exit(1)
+
+    repo = repos[0]
+    hk = repo["housekeeping"]
+    must_pass = hk.get("must_pass")
+    rebase = hk.get("rebase")
+    gl = GitLabApi(instance, project_url=repo["url"], settings=settings)
+    state = init_state(integration=glhk.QONTRACT_INTEGRATION)
+    merge_requests = gl.get_merge_requests(state=MRState.OPENED, order_by="updated_at")
+
+    columns = [
+        "id",
+        "title",
+        "author",
+        "labels",
+        "merge_status",
+    ]
+    if must_pass:
+        columns.append("remaining_tests")
+    merge_queue_data = []
+    for mr in merge_requests:
+        pipelines = gl.get_merge_request_pipelines(mr)
+        running_pipelines = [p for p in pipelines if p.status == PipelineStatus.RUNNING]
+        last_pipeline_result = None
+        if pipelines:
+            last_pipeline_result = pipelines[0].status
+        if must_pass:
+            commit = next(mr.commits())
+            state_key = f"{gl.project.path_with_namespace}/{mr.iid}/{commit.id}"
+            remaining_tests = state.get(state_key, must_pass)
+
+        merge_status = ""
+        if mr.merge_status in {
+            MRStatus.CANNOT_BE_MERGED,
+            MRStatus.CANNOT_BE_MERGED_RECHECK,
+        }:
+            # https://docs.gitlab.com/api/merge_requests/#merge-status
+            merge_status = mr.detailed_merge_status
+        elif mr.draft:
+            merge_status = "draft_status"
+        elif len(mr.commits()) == 0:
+            merge_status = "contains_no_changes"
+        elif must_pass and remaining_tests:
+            merge_status = "has_remain_tests"
+        elif any(label in glhk.HOLD_LABELS for label in mr.labels):
+            merge_status = "hold"
+        elif not any(label in glhk.MERGE_LABELS_PRIORITY for label in mr.labels):
+            if ignore_awaiting_approval:
+                continue
+            merge_status = "awaiting_approval"
+        elif rebase and not glhk.is_rebased(mr, gl):
+            merge_status = "needs_rebase"
+        elif not pipelines:
+            merge_status = "no_pipelines"
+        elif running_pipelines:
+            merge_status = "pipeline_running"
+        elif last_pipeline_result != PipelineStatus.SUCCESS:
+            merge_status = "last_pipeline_failed"
+
+        item = {
+            "id": f"[{mr.iid}]({mr.web_url})",
+            "title": mr.title,
+            "author": mr.author["username"],
+            "labels": ", ".join(mr.labels),
+            "merge_status": merge_status,
+        }
+        if must_pass:
+            item["remaining_tests"] = ", ".join(remaining_tests)
+        merge_queue_data.append(item)
+
+    ctx.obj["options"]["sort"] = False  # do not sort
+    print_output(ctx.obj["options"], merge_queue_data, columns)
+
+
 @get.command()
 @click.pass_context
 def app_interface_merge_queue(ctx: click.Context) -> None: