feat: live-refresh public data sources; make gallery a CQL engine

comfy_cli/command/generate/app.py

@@ -507,6 +507,21 @@ def _refresh() -> None:
         with httpx.Client(timeout=30.0, follow_redirects=True) as cli:
             r = cli.get(url, headers={"Comfy-Env": "comfy-cli", "User-Agent": "comfy-cli/api"})
             r.raise_for_status()
+    except httpx.HTTPStatusError as e:
+        # The partner-proxy OpenAPI spec is not published at a public URL, so a
+        # 404 here is expected, not a transient failure. Explain that the model
+        # catalog ships bundled with the CLI and updates via `pip install -U`,
+        # rather than dumping a raw HTTP error.
+        if e.response.status_code == 404:
+            rprint(
+                "[bold yellow]The partner model catalog is not available for live refresh.[/bold yellow]\n"
+                f"[dim]No public catalog is published at {url}.[/dim]\n"
+                f"The CLI uses its bundled catalog at [dim]{spec.active_spec_path()}[/dim].\n"
+                "To get newer models, update the CLI: [bold]pip install -U comfy-cli[/bold]."
+            )
+            raise typer.Exit(code=0)
+        rprint(f"[bold red]Failed to fetch {url}: {e}[/bold red]")
+        raise typer.Exit(code=1)
     except httpx.HTTPError as e:
         rprint(f"[bold red]Failed to fetch {url}: {e}[/bold red]")
         raise typer.Exit(code=1)

comfy_cli/command/nodes.py

@@ -864,16 +864,32 @@ def categories_cmd(
 
 @app.command(
     "refresh",
-    help="object_info is fetched live from the server on each command — nothing to refresh.",
+    help="Re-fetch node annotation data (pack/labels/cloud_disabled) from Comfy-Org/comfy-complete.",
 )
 @tracking.track_command("nodes")
-def refresh_cmd(
-    where: Annotated[
-        str | None,
-        typer.Option("--where", show_default=False, help="Override the resolved routing mode."),
-    ] = None,
-):
-    """Explain that object_info is fetched live and exit."""
+def refresh_cmd():
+    """Force-refresh the node annotation cache from the public comfy-complete repo.
+
+    ``object_info`` itself is fetched live from the server on every command, so
+    there is nothing to refresh there. The *annotations* (which custom-node pack
+    a node belongs to, its behavioral labels, and whether it's disabled on
+    cloud) come from Comfy-Org/comfy-complete and are cached locally with a TTL;
+    this command pulls the latest copy immediately.
+    """
     renderer = get_renderer()
-    rprint("[dim]object_info is fetched live from the server on each command — nothing to refresh.[/dim]")
-    renderer.emit({"refreshed": False, "reason": "live_fetch"}, command="nodes refresh")
+    from comfy_cli.cql import annotations_source
+
+    results = annotations_source.refresh_annotations()
+    ok = all(r["source"] == "remote" for r in results)
+    if renderer.is_pretty():
+        for r in results:
+            if r["source"] == "remote":
+                rprint(f"[green]✓[/green] {r['name']} ({r['bytes']:,} bytes) → {r['path']}")
+            elif r["source"] == "bundled":
+                rprint(
+                    f"[yellow]![/yellow] {r['name']}: remote fetch failed, using bundled snapshot "
+                    f"([dim]{r.get('error', '')}[/dim])"
+                )
+            else:
+                rprint(f"[red]✗[/red] {r['name']}: unavailable ([dim]{r.get('error', '')}[/dim])")
+    renderer.emit({"refreshed": ok, "files": results}, command="nodes refresh")

comfy_cli/command/run_cli.py

@@ -429,26 +429,15 @@ def _build_steps(state: _DemoState) -> list[Step]:
             ],
         ),
         Step(
-            title="query — CQL against the live node graph",
+            title="nodes — introspect the live node graph (CQL engine, flag-based)",
             invocations=[
                 Invocation(
-                    argv=[
-                        *comfy,
-                        "query",
-                        "-q",
-                        "from nodes where name in ('EmptyImage','ImageInvert','SaveImage') select name, category",
-                    ],
-                    label="comfy query",
+                    argv=[*comfy, "nodes", "search", "SaveImage"],
+                    label="comfy nodes search SaveImage",
                 ),
                 Invocation(
-                    argv=[
-                        *comfy,
-                        "--json",
-                        "query",
-                        "-q",
-                        "from nodes where name in ('EmptyImage','ImageInvert','SaveImage') select name, category",
-                    ],
-                    label="comfy --json query",
+                    argv=[*comfy, "--json", "nodes", "ls", "--produces", "IMAGE", "--limit", "5"],
+                    label="comfy --json nodes ls --produces IMAGE --limit 5",
                 ),
             ],
         ),