feat: Phase 3E plugin marketplace (v1 CLI)

packages/cli/pyproject.toml

@@ -18,6 +18,8 @@ dependencies = [
     "orjson>=3.10.0",
     "sqlalchemy>=2.0.30",
     "aiosqlite>=0.21",
+    "opentools-plugin-core>=0.1.0",
+    "filelock>=3.16",
 ]
 
 [project.optional-dependencies]

packages/cli/src/opentools/cli.py

@@ -35,6 +35,7 @@
 
 from opentools.chain.cli import app as chain_app  # noqa: E402
 from opentools.scanner.scan_cli import app as scan_app  # noqa: E402
+from opentools.plugin_cli import plugin_app  # noqa: E402
 
 app.add_typer(engagement_app)
 app.add_typer(findings_app)
@@ -47,6 +48,7 @@
 app.add_typer(config_app)
 app.add_typer(chain_app)
 app.add_typer(scan_app)
+app.add_typer(plugin_app)
 
 
 # ---------------------------------------------------------------------------

packages/cli/src/opentools/containers.py

@@ -143,3 +143,49 @@ def _get_profiles(self, container_name: str) -> list[str]:
         if tool:
             return tool.profiles
         return []
+
+
+def get_plugin_container_statuses() -> list[ContainerStatus]:
+    """Get status of all plugin containers across installed plugins."""
+    from opentools.plugin import _marketplace_plugin_dirs
+
+    statuses: list[ContainerStatus] = []
+    for version_dir in _marketplace_plugin_dirs():
+        compose_dir = version_dir / "compose"
+        if not compose_dir.is_dir():
+            continue
+
+        compose_file = compose_dir / "docker-compose.yaml"
+        if not compose_file.exists():
+            compose_file = compose_dir / "docker-compose.yml"
+        if not compose_file.exists():
+            continue
+
+        try:
+            result = subprocess.run(
+                ["docker", "compose", "-f", str(compose_file), "ps", "--format", "json"],
+                capture_output=True, timeout=10,
+                cwd=str(compose_dir),
+            )
+            if result.returncode != 0:
+                continue
+
+            stdout = result.stdout.decode(errors="replace").strip()
+            for line in stdout.splitlines():
+                line = line.strip()
+                if not line:
+                    continue
+                try:
+                    data = json.loads(line)
+                    statuses.append(ContainerStatus(
+                        name=data.get("Name", data.get("Service", "")),
+                        state=data.get("State", "unknown"),
+                        health=data.get("Health"),
+                        profile=["plugin"],
+                    ))
+                except json.JSONDecodeError:
+                    continue
+        except (subprocess.TimeoutExpired, FileNotFoundError):
+            continue
+
+    return statuses

packages/cli/src/opentools/plugin.py

@@ -31,3 +31,66 @@ def discover_plugin_dir(cli_package_root: Path | None = None) -> Path:
     raise FileNotFoundError(
         "Plugin directory not found. Set OPENTOOLS_PLUGIN_DIR or run from the OpenTools repo."
     )
+
+
+def _marketplace_plugin_dirs() -> list[Path]:
+    """Scan ~/.opentools/plugins/ for active plugin version directories."""
+    marketplace = Path.home() / ".opentools" / "plugins"
+    if not marketplace.is_dir():
+        return []
+
+    dirs: list[Path] = []
+    for plugin_dir in marketplace.iterdir():
+        if not plugin_dir.is_dir():
+            continue
+        active_file = plugin_dir / ".active"
+        if active_file.exists():
+            version = active_file.read_text(encoding="utf-8").strip()
+            version_dir = plugin_dir / version
+            if version_dir.is_dir():
+                dirs.append(version_dir)
+    return dirs
+
+
+def skill_search_paths() -> list[Path]:
+    """Return search paths for skills: built-in + marketplace."""
+    paths: list[Path] = []
+
+    try:
+        plugin_dir = discover_plugin_dir()
+        paths.append(plugin_dir / "skills")
+    except FileNotFoundError:
+        pass
+
+    for version_dir in _marketplace_plugin_dirs():
+        skills_dir = version_dir / "skills"
+        if skills_dir.is_dir():
+            paths.append(skills_dir)
+
+    marketplace = Path.home() / ".opentools" / "plugins"
+    if marketplace.is_dir():
+        paths.append(marketplace)
+
+    return paths
+
+
+def recipe_search_paths() -> list[Path]:
+    """Return search paths for recipes: built-in + marketplace."""
+    paths: list[Path] = []
+
+    try:
+        plugin_dir = discover_plugin_dir()
+        paths.append(plugin_dir)
+    except FileNotFoundError:
+        pass
+
+    for version_dir in _marketplace_plugin_dirs():
+        recipes_dir = version_dir / "recipes"
+        if recipes_dir.is_dir():
+            paths.append(recipes_dir)
+
+    marketplace = Path.home() / ".opentools" / "plugins"
+    if marketplace.is_dir():
+        paths.append(marketplace)
+
+    return paths