Add an execute button and endpoint.

lynxkite-app/src/lynxkite_app/main.py

@@ -151,6 +151,14 @@ async def upload(req: fastapi.Request):
     return {"status": "ok"}
 
 
+@app.post("/api/execute_workspace")
+async def execute_workspace(name: str):
+    """Trigger and await the execution of a workspace."""
+    room = await crdt.ws_websocket_server.get_room(name)
+    ws_pyd = workspace.Workspace.model_validate(room.ws.to_py())
+    await crdt.execute(name, room.ws, ws_pyd)
+
+
 class SPAStaticFiles(StaticFiles):
     """Route everything to index.html. https://stackoverflow.com/a/73552966/3318517"""
 

lynxkite-app/web/src/index.css

@@ -54,7 +54,7 @@ body {
       display: flex;
       align-items: center;
 
-      a {
+      .btn {
         color: oklch(75% 0.13 230);
         font-size: 1.5em;
         padding: 0 10px;

lynxkite-app/web/src/workspace/Workspace.tsx

@@ -26,6 +26,8 @@ import Atom from "~icons/tabler/atom.jsx";
 // @ts-ignore
 import Backspace from "~icons/tabler/backspace.jsx";
 // @ts-ignore
+import Restart from "~icons/tabler/rotate-clockwise.jsx";
+// @ts-ignore
 import Close from "~icons/tabler/x.jsx";
 import type { Workspace, WorkspaceNode } from "../apiTypes.ts";
 import favicon from "../assets/favicon.ico";
@@ -181,12 +183,16 @@ function LynxKiteFlow() {
   useEffect(() => {
     const handleKeyDown = (event: KeyboardEvent) => {
       // Show the node search dialog on "/".
-      if (event.key === "/" && !nodeSearchSettings && !isTypingInFormElement()) {
+      if (nodeSearchSettings || isTypingInFormElement()) return;
+      if (event.key === "/") {
         event.preventDefault();
         setNodeSearchSettings({
           pos: { x: 100, y: 100 },
           boxes: catalog.data![state.workspace.env!],
         });
+      } else if (event.key === "r") {
+        event.preventDefault();
+        executeWorkspace();
       }
     };
     // TODO: Switch to keydown once https://github.com/xyflow/xyflow/pull/5055 is merged.
@@ -318,6 +324,12 @@ function LynxKiteFlow() {
       setMessage("File upload failed.");
     }
   }
+  async function executeWorkspace() {
+    const response = await axios.post(`/api/execute_workspace?name=${path}`);
+    if (response.status !== 200) {
+      setMessage("Workspace execution failed.");
+    }
+  }
   return (
     <div className="workspace">
       <div className="top-bar bg-neutral">
@@ -334,13 +346,16 @@ function LynxKiteFlow() {
           }}
         />
         <div className="tools text-secondary">
-          <a href="">
+          <button className="btn btn-link">
             <Atom />
-          </a>
-          <a href="">
+          </button>
+          <button className="btn btn-link">
             <Backspace />
-          </a>
-          <a href={`/dir/${parentDir}`}>
+          </button>
+          <button className="btn btn-link" onClick={executeWorkspace}>
+            <Restart />
+          </button>
+          <a className="btn btn-link" href={`/dir/${parentDir}`}>
             <Close />
           </a>
         </div>

lynxkite-core/src/lynxkite/core/ops.py

@@ -361,12 +361,10 @@ def load_user_scripts(workspace: str):
 
 def install_requirements(req: pathlib.Path):
     cmd = ["uv", "pip", "install", "-r", str(req)]
-    print(f"Running {' '.join(cmd)}")
     subprocess.check_call(cmd)
 
 
 def run_user_script(script_path: pathlib.Path):
-    print(f"Running {script_path}...")
     spec = importlib.util.spec_from_file_location(script_path.stem, str(script_path))
     module = importlib.util.module_from_spec(spec)
     spec.loader.exec_module(module)