refactor(cli): convert CLI commands to use context manager pattern

Convert all CLI commands from module-level client import to the new
get_client() context manager pattern, removing manual auth header management.

Changes to command_utils.py:
- Import get_client() instead of client from async_client module
- Remove get_authenticated_headers() import
- Wrap run_sync() in async with get_client() context manager
- Wrap get_project_info() in async with get_client() context manager
- Remove all manual auth header handling

Changes to status.py:
- Import get_client() instead of client from async_client module
- Remove get_authenticated_headers() import
- Wrap run_status() in async with get_client() context manager
- Remove all manual auth header handling

Changes to project.py:
- Import get_client() instead of client from async_client module
- Remove get_authenticated_headers() import
- Update all project commands to use context manager pattern:
  - list_projects()
  - add_project_cloud() (cloud mode)
  - add_project() (local mode)
  - remove_project()
  - set_default_project()
  - synchronize_projects()
  - move_project()
- Remove all manual auth header handling

Pattern Applied:
Each CLI command now uses a nested async function with context manager:
```python
async def _operation():
    async with get_client() as client:
        response = await call_*(client, "/path")
        return result

result = asyncio.run(_operation())
```

Benefits:
- Auth now happens at client creation, not per-request
- Cloud app can inject custom transport via factory
- Cleaner code without manual header management
- Proper client lifecycle management
- Tests can mock client behavior

Testing:
- Typecheck passed (0 errors, 0 warnings)
- All CLI commands properly scoped

✅ Phase 0.4 Complete: All CLI commands converted to context manager pattern
Related to SPEC-16 MCP Cloud Service Consolidation.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: phernandez

specs/SPEC-16 MCP Cloud Service Consolidation.md

@@ -469,9 +469,9 @@ Convert from `from async_client import client` to `async with get_client() as cl
 #### 0.4 Update CLI Commands (~3 files)
 Remove manual auth header passing, use context manager:
 
-- [ ] `cli/commands/project.py` - remove get_authenticated_headers() calls
-- [ ] `cli/commands/status.py` - use context manager
-- [ ] `cli/commands/command_utils.py` - use context manager
+- [x] `cli/commands/project.py` - removed get_authenticated_headers() calls, use context manager
+- [x] `cli/commands/status.py` - use context manager
+- [x] `cli/commands/command_utils.py` - use context manager
 
 #### 0.5 Update Config
 - [x] Remove `api_url` field from `BasicMemoryConfig` in config.py

src/basic_memory/cli/commands/command_utils.py

@@ -7,8 +7,7 @@
 
 from rich.console import Console
 
-from basic_memory.cli.commands.cloud import get_authenticated_headers
-from basic_memory.mcp.async_client import client
+from basic_memory.mcp.async_client import get_client
 
 from basic_memory.mcp.tools.utils import call_post, call_get
 from basic_memory.mcp.project_context import get_active_project
@@ -21,40 +20,24 @@ async def run_sync(project: Optional[str] = None):
     """Run sync operation via API endpoint."""
 
     try:
-        from basic_memory.config import ConfigManager
-
-        config = ConfigManager().config
-        auth_headers = {}
-        if config.cloud_mode_enabled:
-            auth_headers = await get_authenticated_headers()
-
-        project_item = await get_active_project(client, project, None, headers=auth_headers)
-        response = await call_post(
-            client, f"{project_item.project_url}/project/sync", headers=auth_headers
-        )
-        data = response.json()
-        console.print(f"[green]✓ {data['message']}[/green]")
+        async with get_client() as client:
+            project_item = await get_active_project(client, project, None)
+            response = await call_post(client, f"{project_item.project_url}/project/sync")
+            data = response.json()
+            console.print(f"[green]✓ {data['message']}[/green]")
     except (ToolError, ValueError) as e:
         console.print(f"[red]✗ Sync failed: {e}[/red]")
         raise typer.Exit(1)
 
 
 async def get_project_info(project: str):
-    """Run sync operation via API endpoint."""
+    """Get project information via API endpoint."""
 
     try:
-        from basic_memory.config import ConfigManager
-
-        config = ConfigManager().config
-        auth_headers = {}
-        if config.cloud_mode_enabled:
-            auth_headers = await get_authenticated_headers()
-
-        project_item = await get_active_project(client, project, None, headers=auth_headers)
-        response = await call_get(
-            client, f"{project_item.project_url}/project/info", headers=auth_headers
-        )
-        return ProjectInfoResponse.model_validate(response.json())
+        async with get_client() as client:
+            project_item = await get_active_project(client, project, None)
+            response = await call_get(client, f"{project_item.project_url}/project/info")
+            return ProjectInfoResponse.model_validate(response.json())
     except (ToolError, ValueError) as e:
         console.print(f"[red]✗ Sync failed: {e}[/red]")
         raise typer.Exit(1)

src/basic_memory/cli/commands/project.py

@@ -9,14 +9,13 @@
 from rich.table import Table
 
 from basic_memory.cli.app import app
-from basic_memory.cli.commands.cloud import get_authenticated_headers
 from basic_memory.cli.commands.command_utils import get_project_info
 from basic_memory.config import ConfigManager
 import json
 from datetime import datetime
 
 from rich.panel import Panel
-from basic_memory.mcp.async_client import client
+from basic_memory.mcp.async_client import get_client
 from basic_memory.mcp.tools.utils import call_get
 from basic_memory.schemas.project_info import ProjectList
 from basic_memory.mcp.tools.utils import call_post
@@ -46,14 +45,14 @@ def format_path(path: str) -> str:
 @project_app.command("list")
 def list_projects() -> None:
     """List all Basic Memory projects."""
-    # Use API to list projects
-    try:
-        auth_headers = {}
-        if config.cloud_mode_enabled:
-            auth_headers = asyncio.run(get_authenticated_headers())
 
-        response = asyncio.run(call_get(client, "/projects/projects", headers=auth_headers))
-        result = ProjectList.model_validate(response.json())
+    async def _list_projects():
+        async with get_client() as client:
+            response = await call_get(client, "/projects/projects")
+            return ProjectList.model_validate(response.json())
+
+    try:
+        result = asyncio.run(_list_projects())
 
         table = Table(title="Basic Memory Projects")
         table.add_column("Name", style="cyan")
@@ -79,16 +78,14 @@ def add_project_cloud(
     ) -> None:
         """Add a new project to Basic Memory Cloud"""
 
-        try:
-            auth_headers = asyncio.run(get_authenticated_headers())
-
-            data = {"name": name, "path": generate_permalink(name), "set_default": set_default}
-
-            response = asyncio.run(
-                call_post(client, "/projects/projects", json=data, headers=auth_headers)
-            )
-            result = ProjectStatusResponse.model_validate(response.json())
+        async def _add_project():
+            async with get_client() as client:
+                data = {"name": name, "path": generate_permalink(name), "set_default": set_default}
+                response = await call_post(client, "/projects/projects", json=data)
+                return ProjectStatusResponse.model_validate(response.json())
 
+        try:
+            result = asyncio.run(_add_project())
             console.print(f"[green]{result.message}[/green]")
         except Exception as e:
             console.print(f"[red]Error adding project: {str(e)}[/red]")
@@ -109,12 +106,14 @@ def add_project(
         # Resolve to absolute path
         resolved_path = Path(os.path.abspath(os.path.expanduser(path))).as_posix()
 
-        try:
-            data = {"name": name, "path": resolved_path, "set_default": set_default}
-
-            response = asyncio.run(call_post(client, "/projects/projects", json=data))
-            result = ProjectStatusResponse.model_validate(response.json())
+        async def _add_project():
+            async with get_client() as client:
+                data = {"name": name, "path": resolved_path, "set_default": set_default}
+                response = await call_post(client, "/projects/projects", json=data)
+                return ProjectStatusResponse.model_validate(response.json())
 
+        try:
+            result = asyncio.run(_add_project())
             console.print(f"[green]{result.message}[/green]")
         except Exception as e:
             console.print(f"[red]Error adding project: {str(e)}[/red]")
@@ -130,17 +129,15 @@ def remove_project(
     name: str = typer.Argument(..., help="Name of the project to remove"),
 ) -> None:
     """Remove a project."""
-    try:
-        auth_headers = {}
-        if config.cloud_mode_enabled:
-            auth_headers = asyncio.run(get_authenticated_headers())
 
-        project_permalink = generate_permalink(name)
-        response = asyncio.run(
-            call_delete(client, f"/projects/{project_permalink}", headers=auth_headers)
-        )
-        result = ProjectStatusResponse.model_validate(response.json())
+    async def _remove_project():
+        async with get_client() as client:
+            project_permalink = generate_permalink(name)
+            response = await call_delete(client, f"/projects/{project_permalink}")
+            return ProjectStatusResponse.model_validate(response.json())
 
+    try:
+        result = asyncio.run(_remove_project())
         console.print(f"[green]{result.message}[/green]")
     except Exception as e:
         console.print(f"[red]Error removing project: {str(e)}[/red]")
@@ -157,11 +154,15 @@ def set_default_project(
         name: str = typer.Argument(..., help="Name of the project to set as CLI default"),
     ) -> None:
         """Set the default project when 'config.default_project_mode' is set."""
-        try:
-            project_permalink = generate_permalink(name)
-            response = asyncio.run(call_put(client, f"/projects/{project_permalink}/default"))
-            result = ProjectStatusResponse.model_validate(response.json())
 
+        async def _set_default():
+            async with get_client() as client:
+                project_permalink = generate_permalink(name)
+                response = await call_put(client, f"/projects/{project_permalink}/default")
+                return ProjectStatusResponse.model_validate(response.json())
+
+        try:
+            result = asyncio.run(_set_default())
             console.print(f"[green]{result.message}[/green]")
         except Exception as e:
             console.print(f"[red]Error setting default project: {str(e)}[/red]")
@@ -170,12 +171,14 @@ def set_default_project(
     @project_app.command("sync-config")
     def synchronize_projects() -> None:
         """Synchronize project config between configuration file and database."""
-        # Call the API to synchronize projects
 
-        try:
-            response = asyncio.run(call_post(client, "/projects/config/sync"))
-            result = ProjectStatusResponse.model_validate(response.json())
+        async def _sync_config():
+            async with get_client() as client:
+                response = await call_post(client, "/projects/config/sync")
+                return ProjectStatusResponse.model_validate(response.json())
 
+        try:
+            result = asyncio.run(_sync_config())
             console.print(f"[green]{result.message}[/green]")
         except Exception as e:  # pragma: no cover
             console.print(f"[red]Error synchronizing projects: {str(e)}[/red]")
@@ -190,17 +193,19 @@ def move_project(
         # Resolve to absolute path
         resolved_path = Path(os.path.abspath(os.path.expanduser(new_path))).as_posix()
 
-        try:
-            data = {"path": resolved_path}
-
-            project_permalink = generate_permalink(name)
+        async def _move_project():
+            async with get_client() as client:
+                data = {"path": resolved_path}
+                project_permalink = generate_permalink(name)
 
-            # TODO fix route to use ProjectPathDep
-            response = asyncio.run(
-                call_patch(client, f"/{name}/project/{project_permalink}", json=data)
-            )
-            result = ProjectStatusResponse.model_validate(response.json())
+                # TODO fix route to use ProjectPathDep
+                response = await call_patch(
+                    client, f"/{name}/project/{project_permalink}", json=data
+                )
+                return ProjectStatusResponse.model_validate(response.json())
 
+        try:
+            result = asyncio.run(_move_project())
             console.print(f"[green]{result.message}[/green]")
 
             # Show important file movement reminder

src/basic_memory/cli/commands/status.py

@@ -12,8 +12,7 @@
 from rich.tree import Tree
 
 from basic_memory.cli.app import app
-from basic_memory.cli.commands.cloud import get_authenticated_headers
-from basic_memory.mcp.async_client import client
+from basic_memory.mcp.async_client import get_client
 from basic_memory.mcp.tools.utils import call_post
 from basic_memory.schemas import SyncReportResponse
 from basic_memory.mcp.project_context import get_active_project
@@ -130,20 +129,12 @@ async def run_status(project: Optional[str] = None, verbose: bool = False):  # p
     """Check sync status of files vs database."""
 
     try:
-        from basic_memory.config import ConfigManager
+        async with get_client() as client:
+            project_item = await get_active_project(client, project, None)
+            response = await call_post(client, f"{project_item.project_url}/project/status")
+            sync_report = SyncReportResponse.model_validate(response.json())
 
-        config = ConfigManager().config
-        auth_headers = {}
-        if config.cloud_mode_enabled:
-            auth_headers = await get_authenticated_headers()
-
-        project_item = await get_active_project(client, project, None)
-        response = await call_post(
-            client, f"{project_item.project_url}/project/status", headers=auth_headers
-        )
-        sync_report = SyncReportResponse.model_validate(response.json())
-
-        display_changes(project_item.name, "Status", sync_report, verbose)
+            display_changes(project_item.name, "Status", sync_report, verbose)
 
     except (ValueError, ToolError) as e:
         console.print(f"[red]✗ Error: {e}[/red]")