cli/status(refactor[typing]): Add StatusResult TypedDict

why: Make status payload shape explicit and reuse it in sync plan logic/tests.

what:
- Define StatusResult and update status helpers to return it
- Accept StatusResult in sync plan action selection
- Update status/sync plan tests to build typed status inputs

Author: tony

src/vcspull/cli/status.py

@@ -28,6 +28,20 @@
 ANSI_ESCAPE_RE = re.compile(r"\x1b\[[0-9;]*m")
 
 
+class StatusResult(t.TypedDict):
+    """Typed status payload for a single repository."""
+
+    name: str
+    path: str
+    workspace_root: str
+    exists: bool
+    is_git: bool
+    clean: bool | None
+    branch: str | None
+    ahead: int | None
+    behind: int | None
+
+
 @dataclass
 class StatusCheckConfig:
     """Configuration options for status checking."""
@@ -174,7 +188,7 @@ async def _check_repos_status_async(
     *,
     config: StatusCheckConfig,
     progress: StatusProgressPrinter | None,
-) -> list[dict[str, t.Any]]:
+) -> list[StatusResult]:
     """Check repository status concurrently using asyncio.
 
     Parameters
@@ -188,18 +202,18 @@ async def _check_repos_status_async(
 
     Returns
     -------
-    list[dict[str, t.Any]]
+    list[StatusResult]
         List of status dictionaries in completion order
     """
     if not repos:
         return []
 
     semaphore = asyncio.Semaphore(min(config.max_concurrent, len(repos)))
-    results: list[dict[str, t.Any]] = []
+    results: list[StatusResult] = []
     exists_count = 0
     missing_count = 0
 
-    async def check_with_limit(repo: ConfigDict) -> dict[str, t.Any]:
+    async def check_with_limit(repo: ConfigDict) -> StatusResult:
         async with semaphore:
             return await asyncio.to_thread(
                 check_repo_status,
@@ -214,7 +228,7 @@ async def check_with_limit(repo: ConfigDict) -> dict[str, t.Any]:
         results.append(status)
 
         # Update counts for progress
-        if status.get("exists"):
+        if status["exists"]:
             exists_count += 1
         else:
             missing_count += 1
@@ -242,7 +256,7 @@ def _run_git_command(
         return None
 
 
-def check_repo_status(repo: ConfigDict, detailed: bool = False) -> dict[str, t.Any]:
+def check_repo_status(repo: ConfigDict, detailed: bool = False) -> StatusResult:
     """Check the status of a single repository.
 
     Parameters
@@ -261,7 +275,7 @@ def check_repo_status(repo: ConfigDict, detailed: bool = False) -> dict[str, t.A
     repo_name = repo.get("name", "unknown")
     workspace_root = repo.get("workspace_root", "")
 
-    status: dict[str, t.Any] = {
+    status: StatusResult = {
         "name": repo_name,
         "path": str(PrivatePath(repo_path)),
         "workspace_root": workspace_root,
@@ -485,7 +499,7 @@ def status_repos(
 
 
 def _format_status_line(
-    status: dict[str, t.Any],
+    status: StatusResult,
     formatter: OutputFormatter,
     colors: Colors,
     detailed: bool,

src/vcspull/cli/sync.py

@@ -43,7 +43,7 @@
     get_output_mode,
 )
 from ._workspaces import filter_by_workspace
-from .status import check_repo_status
+from .status import StatusResult, check_repo_status
 
 log = logging.getLogger(__name__)
 
@@ -188,7 +188,7 @@ def _maybe_fetch(
 
 
 def _determine_plan_action(
-    status: dict[str, t.Any],
+    status: StatusResult,
     *,
     config: SyncPlanConfig,
 ) -> tuple[PlanAction, str | None]:

tests/cli/test_status.py

@@ -11,6 +11,7 @@
 
 from vcspull.cli.status import (
     StatusCheckConfig,
+    StatusResult,
     _check_repos_status_async,
     check_repo_status,
     status_repos,
@@ -223,7 +224,16 @@ def test_check_repo_status(
         else:
             repo_path.mkdir(parents=True)
 
-    repo_dict: t.Any = {"name": "test-repo", "path": str(repo_path)}
+    repo_dict = t.cast(
+        "ConfigDict",
+        {
+            "vcs": None,
+            "name": "test-repo",
+            "path": repo_path,
+            "url": str(repo_path),
+            "workspace_root": str(tmp_path),
+        },
+    )
 
     status = check_repo_status(repo_dict, detailed=False)
 
@@ -630,21 +640,32 @@ async def test_check_repos_status_async_concurrency_limit(
 ) -> None:
     """Test that semaphore limits concurrent operations."""
     # Create multiple repos
-    repos_list = []
+    repos_list: list[ConfigDict] = []
     for i in range(10):
         repo_path = tmp_path / f"repo{i}"
         init_git_repo(repo_path)
-        repos_list.append({"name": f"repo{i}", "path": str(repo_path)})
+        repos_list.append(
+            t.cast(
+                "ConfigDict",
+                {
+                    "vcs": None,
+                    "name": f"repo{i}",
+                    "path": repo_path,
+                    "url": str(repo_path),
+                    "workspace_root": str(tmp_path),
+                },
+            ),
+        )
 
-    repos = t.cast("list[ConfigDict]", repos_list)
+    repos = repos_list
 
     # Track concurrent calls
     concurrent_calls = []
     max_concurrent_seen = 0
 
     original_check = check_repo_status
 
-    def tracked_check(repo: t.Any, detailed: bool = False) -> dict[str, t.Any]:
+    def tracked_check(repo: ConfigDict, detailed: bool = False) -> StatusResult:
         concurrent_calls.append(1)
         nonlocal max_concurrent_seen
         current = len(concurrent_calls)

tests/cli/test_sync_plan_helpers.py

@@ -13,6 +13,28 @@
 if t.TYPE_CHECKING:
     import pathlib
 
+    from vcspull.cli.status import StatusResult
+
+
+StatusOverride: t.TypeAlias = dict[str, bool | int | None]
+
+
+def _build_status(overrides: StatusOverride) -> StatusResult:
+    """Build a StatusResult with defaults for required keys."""
+    base: dict[str, object] = {
+        "name": "repo",
+        "path": "/tmp/repo",
+        "workspace_root": "/tmp",
+        "exists": False,
+        "is_git": False,
+        "clean": None,
+        "branch": None,
+        "ahead": None,
+        "behind": None,
+    }
+    base.update(overrides)
+    return t.cast("StatusResult", base)
+
 
 class MaybeFetchFixture(t.NamedTuple):
     """Fixture for _maybe_fetch behaviours."""
@@ -147,7 +169,7 @@ class DeterminePlanActionFixture(t.NamedTuple):
     """Fixture for _determine_plan_action outcomes."""
 
     test_id: str
-    status: dict[str, t.Any]
+    status: StatusOverride
     config: SyncPlanConfig
     expected_action: PlanAction
     expected_detail: str
@@ -239,12 +261,15 @@ class DeterminePlanActionFixture(t.NamedTuple):
 )
 def test_determine_plan_action(
     test_id: str,
-    status: dict[str, t.Any],
+    status: StatusOverride,
     config: SyncPlanConfig,
     expected_action: PlanAction,
     expected_detail: str,
 ) -> None:
     """Verify _determine_plan_action handles edge cases."""
-    action, detail = _determine_plan_action(status, config=config)
+    action, detail = _determine_plan_action(
+        _build_status(status),
+        config=config,
+    )
     assert action is expected_action
     assert detail == expected_detail