adds infrahubctl repository list command

Author: wvandeun

infrahub_sdk/ctl/repository.py

@@ -5,13 +5,14 @@
 import yaml
 from pydantic import ValidationError
 from rich.console import Console
+from rich.table import Table
 
 from infrahub_sdk.ctl.client import initialize_client
 
 from ..async_typer import AsyncTyper
 from ..ctl.exceptions import FileNotValidError
 from ..ctl.utils import init_logging
-from ..graphql import Mutation
+from ..graphql import Mutation, Query
 from ..schema import InfrahubRepositoryConfig
 from ._file import read_file
 from .parameters import CONFIG_PARAM
@@ -101,3 +102,63 @@ async def add(
     )
 
     await client.execute_graphql(query=query.render(), branch_name=branch, tracker="mutation-repository-create")
+
+
+@app.command()
+async def list(
+    debug: bool = False,
+    _: str = CONFIG_PARAM,
+) -> None:
+
+    init_logging(debug=debug)
+
+    client = initialize_client()
+
+    repo_status_query = {
+        "CoreGenericRepository": {
+            "edges": {
+                "node": {
+                    "__typename": None,
+                    "name": {
+                        "value": None
+                    },
+                    "operational_status": {
+                        "value": None
+                    },
+                    "sync_status": {
+                        "value": None
+                    },
+                    "internal_status": {
+                        "value": None
+                    }
+                }
+            }
+        },
+    }
+
+    BRANCH_DATA_FILTER = {"@filters": {"name": "$branch_name"}}
+    query = Query(name="GetRepositoryStatus", query=repo_status_query)
+    resp = await client.execute_graphql(query=query.render(), branch_name="main", tracker="query-repository-list")
+
+    table = Table(title="List of all Repositories")
+
+    table.add_column("Name", justify="right", style="cyan", no_wrap=True)
+    table.add_column("Type")
+    table.add_column("Operational status")
+    table.add_column("Sync status")
+    table.add_column("Internal status")
+
+
+    for repository_node in resp["CoreGenericRepository"]["edges"]:
+
+        repository = repository_node["node"]
+
+        table.add_row(
+            repository["name"]["value"],
+            repository["__typename"],
+            repository["operational_status"]["value"],
+            repository["sync_status"]["value"],
+            repository["internal_status"]["value"]
+        )
+
+    console.print(table)