src.sysadmin.sysadmin_cli_adapter

  1"""CLI adapter for sysadmin operations."""
  2
  3import sys
  4from dataclasses import asdict
  5from typing import override
  6
  7import msgspec
  8
  9from src.credential_configurations.credential_configurations_service import (
 10    CredentialConfigurationsService,
 11)
 12from src.credential_configurations.models import (
 13    CredentialConfiguration,
 14)
 15
 16from .sysadmin_port import SysadminPort
 17
 18USAGE = """\
 19Usage: ec-issuer <command> [args]
 20
 21Commands:
 22    credential-configuration  - Manage credential configurations
 23"""
 24
 25CREDENTIAL_CONFIG_USAGE = """\
 26Usage: ec-issuer credential-configuration <command> [args]
 27
 28Commands:
 29    create <id> - Create a new config (reads JSON from stdin)
 30    show <id>   - Show a credential configuration by ID
 31    update <id> - Update a config (reads JSON from stdin)
 32    list        - List all credential configurations
 33"""
 34
 35
 36class SysadminCliAdapter(SysadminPort):
 37    """CLI adapter for sysadmin operations."""
 38
 39    _credential_configurations_service: CredentialConfigurationsService
 40
 41    def __init__(
 42        self, credential_configurations_service: CredentialConfigurationsService
 43    ) -> None:
 44        """Initialize the adapter.
 45
 46        Args:
 47            service: The credential configurations service.
 48        """
 49        self._credential_configurations_service = credential_configurations_service
 50
 51    @override
 52    def run(self, command: list[str]) -> None:
 53        """Run a sysadmin command.
 54
 55        Args:
 56            command: The command and its arguments.
 57        """
 58        match command:
 59            case []:
 60                print(USAGE, file=sys.stderr)
 61                sys.exit(1)
 62            case ["credential-configuration"]:
 63                print(CREDENTIAL_CONFIG_USAGE, file=sys.stderr)
 64                sys.exit(1)
 65            case ["credential-configuration", "create", config_id]:
 66                self._handle_create(config_id)
 67            case ["credential-configuration", "show", config_id]:
 68                self._handle_show(config_id)
 69            case ["credential-configuration", "list"]:
 70                self._handle_list()
 71            case ["credential-configuration", "update", config_id]:
 72                self._handle_update(config_id)
 73            case ["credential-configuration", *_]:
 74                print(CREDENTIAL_CONFIG_USAGE, file=sys.stderr)
 75                sys.exit(1)
 76            case _:
 77                print(USAGE, file=sys.stderr)
 78                sys.exit(1)
 79
 80    def _handle_create(self, config_id: str) -> None:
 81        """Handle the create command."""
 82        try:
 83            input_json = sys.stdin.read()
 84            configuration: CredentialConfiguration = msgspec.json.decode(
 85                input_json, type=CredentialConfiguration
 86            )
 87            configuration.credential_configuration_id = config_id
 88            result = self._credential_configurations_service.create(configuration)
 89            print(msgspec.json.encode(asdict(result)).decode())
 90        except Exception as e:
 91            print(f"Error: {e}", file=sys.stderr)
 92            sys.exit(1)
 93
 94    def _handle_show(self, config_id: str) -> None:
 95        """Handle the show command."""
 96        try:
 97            result = self._credential_configurations_service.get(config_id)
 98            print(msgspec.json.encode(asdict(result)).decode())
 99        except Exception as e:
100            print(f"Error: {e}", file=sys.stderr)
101            sys.exit(1)
102
103    def _handle_list(self) -> None:
104        """Handle the list command."""
105        try:
106            results = self._credential_configurations_service.list()
107            # Convert to list of dicts for JSON serialization
108            results_list = [asdict(r) for r in results]
109            print(msgspec.json.encode(results_list).decode())
110        except Exception as e:
111            print(f"Error: {e}", file=sys.stderr)
112            sys.exit(1)
113
114    def _handle_update(self, config_id: str) -> None:
115        """Handle the update command."""
116        self._handle_create(config_id)