Add cloud servers

Author: jtcorbett

src/mcp_agent/cli/cloud/commands/logger/tail/main.py

@@ -18,7 +18,7 @@
 from mcp_agent.cli.exceptions import CLIError
 from mcp_agent.cli.auth import load_credentials, UserCredentials
 from mcp_agent.cli.core.constants import DEFAULT_API_BASE_URL
-from mcp_agent.cli.cloud.commands.logger.utils import parse_app_identifier, resolve_server_url
+from mcp_agent.cli.core.utils import parse_app_identifier, resolve_server_url
 
 console = Console()
 

src/mcp_agent/cli/cloud/commands/logger/utils.py

@@ -0,0 +1,15 @@
+"""Server management commands for MCP Agent Cloud."""
+
+from .list.main import list_servers
+from .describe.main import describe_server
+from .stats.main import get_server_stats
+from .delete.main import delete_server
+from .workflows.main import list_server_workflows
+
+__all__ = [
+    "list_servers",
+    "describe_server", 
+    "get_server_stats",
+    "delete_server",
+    "list_server_workflows",
+]

src/mcp_agent/cli/cloud/commands/servers/__init__.py

@@ -0,0 +1,78 @@
+
+import typer
+from rich.panel import Panel
+
+from mcp_agent.cli.core.utils import run_async
+from mcp_agent.cli.exceptions import CLIError
+from mcp_agent.cli.mcp_app.api_client import MCPApp
+from ..utils import (
+    setup_authenticated_client,
+    resolve_server,
+    handle_server_api_errors,
+    get_server_name,
+    get_server_id,
+)
+from mcp_agent.cli.utils.ux import console, print_info
+
+
+@handle_server_api_errors
+def delete_server(
+    id_or_url: str = typer.Argument(..., help="Server ID or URL to delete"),
+    force: bool = typer.Option(False, "--force", "-f", help="Force deletion without confirmation prompt"),
+) -> None:
+    """Delete a specific MCP Server."""
+    client = setup_authenticated_client()
+    server = resolve_server(client, id_or_url)
+    
+    # Determine server type and delete function
+    if isinstance(server, MCPApp):
+        server_type = "Deployed Server"
+        delete_function = client.delete_app
+    else:
+        server_type = "Configured Server" 
+        delete_function = client.delete_app_configuration
+        
+    server_name = get_server_name(server)
+    server_id = get_server_id(server)
+
+    if not force:
+        console.print(
+            Panel(
+                f"Name: [cyan]{server_name}[/cyan]\n"
+                f"Type: [cyan]{server_type}[/cyan]\n"
+                f"ID: [cyan]{server_id}[/cyan]\n\n"
+                f"[bold red]⚠️  This action cannot be undone![/bold red]",
+                title="Server to Delete",
+                border_style="red",
+                expand=False,
+            )
+        )
+        
+        confirm = typer.confirm(f"\nAre you sure you want to delete this {server_type.lower()}?")
+        if not confirm:
+            print_info("Deletion cancelled.")
+            return
+
+    if isinstance(server, MCPApp):
+        can_delete = run_async(client.can_delete_app(server_id))
+    else:
+        can_delete = run_async(client.can_delete_app_configuration(server_id))
+        
+    if not can_delete:
+        raise CLIError(
+            f"You do not have permission to delete this {server_type.lower()}. "
+            f"You can only delete servers that you created."
+        )
+    deleted_id = run_async(delete_function(server_id))
+    
+    console.print(
+        Panel(
+            f"[green]✅ Successfully deleted {server_type.lower()}[/green]\n\n"
+            f"Name: [cyan]{server_name}[/cyan]\n"
+            f"ID: [cyan]{deleted_id}[/cyan]",
+            title="Deletion Complete",
+            border_style="green",
+            expand=False,
+        )
+    )
+

src/mcp_agent/cli/cloud/commands/servers/delete/__init__.py

@@ -0,0 +1,171 @@
+import json
+from typing import Optional, Union
+
+import typer
+import yaml
+from rich.panel import Panel
+
+from mcp_agent.cli.exceptions import CLIError
+from mcp_agent.cli.mcp_app.api_client import MCPApp, MCPAppConfiguration
+from ..utils import (
+    setup_authenticated_client,
+    validate_output_format, 
+    resolve_server,
+    handle_server_api_errors,
+    clean_server_status,
+)
+from mcp_agent.cli.utils.ux import console
+
+
+@handle_server_api_errors 
+def describe_server(
+    id_or_url: str = typer.Argument(..., help="Server ID or URL to describe"),
+    format: Optional[str] = typer.Option("text", "--format", help="Output format (text|json|yaml)"),
+) -> None:
+    """Describe a specific MCP Server."""
+    validate_output_format(format)
+    client = setup_authenticated_client()
+    server = resolve_server(client, id_or_url)
+    print_server_description(server, format)
+
+
+def print_server_description(server: Union[MCPApp, MCPAppConfiguration], output_format: str = "text") -> None:
+    """Print detailed description information for a server."""
+    
+    valid_formats = ["text", "json", "yaml"]
+    if output_format not in valid_formats:
+        raise CLIError(f"Invalid format '{output_format}'. Valid options are: {', '.join(valid_formats)}")
+    
+    if output_format == "json":
+        _print_server_json(server)
+    elif output_format == "yaml":
+        _print_server_yaml(server)
+    else:
+        _print_server_text(server)
+
+
+def _print_server_json(server: Union[MCPApp, MCPAppConfiguration]) -> None:
+    """Print server in JSON format."""
+    server_data = _server_to_dict(server)
+    print(json.dumps(server_data, indent=2, default=str))
+
+
+def _print_server_yaml(server: Union[MCPApp, MCPAppConfiguration]) -> None:
+    """Print server in YAML format."""
+    server_data = _server_to_dict(server)
+    print(yaml.dump(server_data, default_flow_style=False))
+
+
+def _server_to_dict(server: Union[MCPApp, MCPAppConfiguration]) -> dict:
+    """Convert server to dictionary."""
+    if isinstance(server, MCPApp):
+        server_type = "deployed"
+        server_id = server.appId
+        server_name = server.name
+        server_description = server.description
+        created_at = server.createdAt
+        server_info = server.appServerInfo
+        creator_id = server.creatorId
+        underlying_app = None
+    else:
+        server_type = "configured"
+        server_id = server.appConfigurationId
+        server_name = server.app.name if server.app else "Unnamed"
+        server_description = server.app.description if server.app else None
+        created_at = server.createdAt
+        server_info = server.appServerInfo
+        creator_id = server.creatorId
+        underlying_app = {
+            "app_id": server.app.appId,
+            "name": server.app.name
+        } if server.app else None
+
+    status_raw = server_info.status if server_info else "APP_SERVER_STATUS_OFFLINE"
+    server_url = server_info.serverUrl if server_info else None
+    
+    data = {
+        "id": server_id,
+        "name": server_name,
+        "type": server_type,
+        "status": clean_server_status(status_raw),
+        "server_url": server_url,
+        "description": server_description,
+        "creator_id": creator_id,
+        "created_at": created_at.isoformat() if created_at else None
+    }
+    
+    if underlying_app:
+        data["underlying_app"] = underlying_app
+        
+    return data
+
+
+
+
+def _print_server_text(server: Union[MCPApp, MCPAppConfiguration]) -> None:
+    """Print server in text format."""
+    if isinstance(server, MCPApp):
+        server_type = "Deployed Server"
+        server_id = server.appId
+        server_name = server.name
+        server_description = server.description
+        created_at = server.createdAt
+        server_info = server.appServerInfo
+        creator_id = server.creatorId
+    else:
+        server_type = "Configured Server"
+        server_id = server.appConfigurationId
+        server_name = server.app.name if server.app else "Unnamed"
+        server_description = server.app.description if server.app else None
+        created_at = server.createdAt
+        server_info = server.appServerInfo
+        creator_id = server.creatorId
+
+    status_text = "❓ Unknown"
+    server_url = "N/A"
+    
+    if server_info:
+        status_text = _server_status_text(server_info.status)
+        server_url = server_info.serverUrl
+    content_lines = [
+        f"Name: [cyan]{server_name}[/cyan]",
+        f"Type: [cyan]{server_type}[/cyan]",
+        f"ID: [cyan]{server_id}[/cyan]",
+        f"Status: {status_text}",
+        f"Server URL: [cyan]{server_url}[/cyan]",
+    ]
+    
+    if server_description:
+        content_lines.append(f"Description: [cyan]{server_description}[/cyan]")
+    
+    content_lines.append(f"Creator: [cyan]{creator_id}[/cyan]")
+    
+    if created_at:
+        content_lines.append(f"Created: [cyan]{created_at.strftime('%Y-%m-%d %H:%M:%S')}[/cyan]")
+
+    if isinstance(server, MCPAppConfiguration) and server.app:
+        content_lines.extend([
+            "",
+            "[bold]Underlying App:[/bold]",
+            f"  App ID: [cyan]{server.app.appId}[/cyan]",
+            f"  App Name: [cyan]{server.app.name}[/cyan]",
+        ])
+
+    console.print(
+        Panel(
+            "\n".join(content_lines),
+            title="Server Description",
+            border_style="blue",
+            expand=False,
+        )
+    )
+
+
+def _server_status_text(status: str) -> str:
+    """Convert server status code to emoji and text."""
+    if status == "APP_SERVER_STATUS_ONLINE":
+        return "[green]🟢 Active[/green]"
+    elif status == "APP_SERVER_STATUS_OFFLINE":
+        return "[red]🔴 Offline[/red]"
+    else:
+        return "❓ Unknown"