Merge branch 'master' into cuegui-fix-preview-bytes-decode

Author: ramonfigueiredo

cueweb/README.md

@@ -376,6 +376,7 @@ The current CueWeb system offers a robust set of features designed to enhance us
 - **LAN access:** the client builds same-origin relative URLs for every API call by default, so the app loads correctly from any host (`http://<lan-ip>:3000` from a phone, `http://localhost:3000` on the dev Mac). Clipboard has an `execCommand("copy")` fallback for plain-HTTP LAN deployments where the modern Clipboard API is unavailable.
 - **Auto-reloading:** Real-time updates for tables.
 - **Job-finished notifications (two channels):** A per-row **Notify bell** subscribes the browser - a background poller fires a toast (and an optional desktop popup when notification permission is granted) when the job reaches `FINISHED`; subscriptions persist in `localStorage`, sync across tabs, and the notify decision is serialized cross-tab via the Web Locks API so only one tab toasts when several poll the same job. The right-click **Subscribe to Job** menu entry opens a CueGUI-parity dialog that registers an *email* subscriber on Cuebot via the `AddSubscriber` RPC, so Cuebot mails the saved address when the job finishes. The two channels are independent.
+- **Job dependencies (CueGUI parity):** the job right-click menu groups four entries together. **View Dependencies...** opens a themed dialog mirroring CueGUI's `DependDialog` - a Type / Target / Active / OnJob / OnLayer / OnFrame table backed by the `GetDepends` RPC, with a **Refresh** button. **Dependency Wizard...** is a multi-step state machine covering every CueGUI `depend.DependType` (Job-On-Job / Layer / Frame, Frame By Frame for all layers / Hard Depend, Layer-On-Job / Layer / Frame, Frame By Frame, Frame-On-Job / Layer / Frame, Layer on Simulation Frame); every picker (source layers / frames, target jobs / layers / frames) is multi-select and Done fires the full source x target cross-product in one bulk batch. The Hard Depend variant pairs source/target layers by `layer.type` and fans out one `CreateFrameByFrameDependency` per matched pair across every picked target job. **Drop External Dependencies** and **Drop Internal Dependencies** call the `DropDepends` RPC with `target = EXTERNAL` / `INTERNAL` respectively; on success they dispatch `cueweb:refresh-now` and `cueweb:depends-changed` so the Jobs table re-polls and the Group-By Dependent tree cache rebuilds immediately.
 - **Logs:** View current and previous logs via dropdown.
 - **Security:** Use JWT-based authorization and secure headers.
 - **Keyboard shortcuts:** Press `?` anywhere in the app to open a cheat-sheet overlay; the same overlay is also reachable from **Other ▸ Show Shortcuts** in the header or the sidebar. An optional **Notify on Shortcut** toggle (also under Other) fires a toast naming the shortcut that just triggered. See [Keyboard shortcuts](#keyboard-shortcuts) below for the full list.

cueweb/__tests__/cuesubmit/builders.test.ts

@@ -341,6 +341,11 @@ describe("buildJobSpecXml", () => {
     // (deplayer) waiting on "preview" (onlayer) to finish.
     expect(xml).toContain("<deplayer>final</deplayer>");
     expect(xml).toContain("<onlayer>preview</onlayer>");
+    // depjob / onjob must carry the job name - cuebot's JobSpec runs both
+    // through conformJobName, which throws on empty strings. See
+    // pyoutline/outline/backend/cue.py:478-487 for the reference shape.
+    expect(xml).toContain("<depjob>test_job</depjob>");
+    expect(xml).toContain("<onjob>test_job</onjob>");
   });
 
   test("omits <depends> body when no layer has dependencyType set", () => {

cueweb/app/api/frame/action/createdependonframe/route.ts

@@ -0,0 +1,47 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Frame.createDependencyOnFrame (pycue) ->
+// FrameInterface.CreateDependencyOnFrame. Used by the Frame On Frame
+// and Layer on Simulation Frame dependency wizard flows. The latter
+// loops this call once per source frame in the source layer.
+export async function POST(request: NextRequest) {
+  const endpoint = "/frame.FrameInterface/CreateDependencyOnFrame";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.frame || !jsonBody.depend_on_frame) {
+    return NextResponse.json({ error: 'Invalid request body (need {frame, depend_on_frame})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/frame/action/createdependonjob/route.ts

@@ -0,0 +1,46 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Frame.createDependencyOnJob (pycue) ->
+// FrameInterface.CreateDependencyOnJob. Used by the Frame On Job
+// dependency wizard flow.
+export async function POST(request: NextRequest) {
+  const endpoint = "/frame.FrameInterface/CreateDependencyOnJob";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.frame || !jsonBody.job) {
+    return NextResponse.json({ error: 'Invalid request body (need {frame, job})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/frame/action/createdependonlayer/route.ts

@@ -0,0 +1,46 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Frame.createDependencyOnLayer (pycue) ->
+// FrameInterface.CreateDependencyOnLayer. Used by the Frame On Layer
+// dependency wizard flow.
+export async function POST(request: NextRequest) {
+  const endpoint = "/frame.FrameInterface/CreateDependencyOnLayer";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.frame || !jsonBody.layer) {
+    return NextResponse.json({ error: 'Invalid request body (need {frame, layer})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/job/action/createdependonframe/route.ts

@@ -0,0 +1,47 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Cuedepend.createJobOnFrameDepend (cuegui/cuegui/Cuedepend.py) ->
+// JobInterface.CreateDependencyOnFrame. Adds a "this job depends on that
+// frame" link so the dependent job stays paused until the target frame
+// completes.
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.JobInterface/CreateDependencyOnFrame";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.job || !jsonBody.frame) {
+    return NextResponse.json({ error: 'Invalid request body (need {job, frame})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/job/action/createdependonjob/route.ts

@@ -0,0 +1,46 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Cuedepend.createJobOnJobDepend (cuegui/cuegui/Cuedepend.py) ->
+// JobInterface.CreateDependencyOnJob. Adds a "this job depends on that
+// job" link; Cuebot pauses the dependent job until the on_job satisfies.
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.JobInterface/CreateDependencyOnJob";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.job || !jsonBody.on_job) {
+    return NextResponse.json({ error: 'Invalid request body (need {job, on_job})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/job/action/createdependonlayer/route.ts

@@ -0,0 +1,47 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { handleRoute } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors Cuedepend.createJobOnLayerDepend (cuegui/cuegui/Cuedepend.py) ->
+// JobInterface.CreateDependencyOnLayer. Adds a "this job depends on that
+// layer" link so the dependent job stays paused until every frame of the
+// target layer completes.
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.JobInterface/CreateDependencyOnLayer";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.job || !jsonBody.layer) {
+    return NextResponse.json({ error: 'Invalid request body (need {job, layer})' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? 'Upstream error' }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

cueweb/app/api/job/action/getdepends/route.ts

@@ -0,0 +1,51 @@
+/*
+ * Copyright Contributors to the OpenCue Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { fetchObjectFromRestGateway } from '@/app/utils/api_utils';
+import { NextRequest, NextResponse } from "next/server";
+
+// Mirrors cuegui.JobActions.viewDepends -> DependDialog
+// (cuegui/cuegui/MenuActions.py, cuegui/cuegui/DependDialog.py). Returns
+// the depend.DependSeq for the job so the View Dependencies dialog can
+// render the Type / Target / Active / OnJob / OnLayer / OnFrame table.
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.JobInterface/GetDepends";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  let jsonBody: any;
+  try {
+    jsonBody = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON body' }, { status: 400 });
+  }
+  if (!jsonBody || typeof jsonBody !== 'object' || Array.isArray(jsonBody) || !jsonBody.job) {
+    return NextResponse.json({ error: 'Invalid request body (need {job})' }, { status: 400 });
+  }
+
+  const response = await fetchObjectFromRestGateway(endpoint, method, JSON.stringify(jsonBody));
+  const responseData = await response.json();
+
+  if (!response.ok) {
+    return NextResponse.json(
+      { error: responseData?.error ?? 'Upstream error' },
+      { status: response.status },
+    );
+  }
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}