Fix: Add node_id routing to commands/execute + update UI to use it

src/nacc_orchestrator/server.py

@@ -21,6 +21,7 @@ class ListFilesPayload(BaseModel):
 class CommandPayload(BaseModel):
     description: str = Field(..., description="Human-readable summary of the command")
     command: list[str] | str
+    node_id: str | None = None  # NEW: Specific node to execute on
     preferred_tags: list[str] | None = None
     parallelism: int = Field(default=1, ge=1, le=8)
     timeout: float | None = Field(default=None, gt=0.0, le=600.0)
@@ -83,15 +84,28 @@ def create_app(service: OrchestratorService) -> FastAPI:
 
     @app.post("/commands/execute")
     def execute_command(payload: CommandPayload) -> dict[str, object]:
-        return service.execute_command(
-            description=payload.description,
-            command=payload.command,
-            preferred_tags=payload.preferred_tags,
-            parallelism=payload.parallelism,
-            timeout=payload.timeout,
-            cwd=payload.cwd,
-            env=payload.env,
-        )
+        # If node_id is specified, use it directly; otherwise use tags
+        if payload.node_id:
+            # Execute on specific node
+            return service.execute_command_on_node(
+                node_id=payload.node_id,
+                description=payload.description,
+                command=payload.command,
+                timeout=payload.timeout,
+                cwd=payload.cwd,
+                env=payload.env,
+            )
+        else:
+            # Use legacy tag-based routing
+            return service.execute_command(
+                description=payload.description,
+                command=payload.command,
+                preferred_tags=payload.preferred_tags,
+                parallelism=payload.parallelism,
+                timeout=payload.timeout,
+                cwd=payload.cwd,
+                env=payload.env,
+            )
 
     @app.post("/sync")
     def sync(payload: SyncPayload) -> dict[str, object]:

src/nacc_ui/professional_ui_v2.py

@@ -163,8 +163,6 @@ class ModernNACCUI(NACCConversationUI):
         # No fallback to avoid breaking context switching
         
         try:
-            # Determine preferred tags based on node
-            preferred_tags = ["mac", "local"] if node == "macbook-local" else ["kali", "vm"]
             # Get node display name dynamically
             try:
                 node_info = requests.get(f"{ORCHESTRATOR_URL}/nodes/{node}", timeout=5).json()
@@ -172,16 +170,16 @@ class ModernNACCUI(NACCConversationUI):
             except:
                 node_label = node
             
-            # Use orchestrator's execute command endpoint
+            # Use orchestrator's execute command endpoint WITH node_id
             response = requests.post(
                 f"{ORCHESTRATOR_URL}/commands/execute",
                 json={
                     "description": f"List files in {path} on {node}",
                     "command": ["ls", "-lah", path],
-                    "preferred_tags": preferred_tags,
-                    "timeout": 30
+                    "node_id": node,  # Direct node routing!
+                    "timeout": 10.0
                 },
-                timeout=60  # Increased from 15s to 60s
+                timeout=12
             )
             
             if response.status_code == 200: