[cueweb] Add Monitor Cue page (CueCommander parity)

cueweb/.env.example

@@ -1,5 +1,11 @@
 NEXT_PUBLIC_OPENCUE_ENDPOINT=http://your-rest-gateway-url.com
 
+# Optional allow-list for the frame preview route (/api/frame/preview), as a
+# colon-separated list of absolute path prefixes. When set, the server only
+# serves preview images located under one of these roots. When unset, preview
+# reads are not restricted to a root (set this to harden the deployment).
+# CUEWEB_PREVIEW_ROOTS=/mnt/render:/shows
+
 # Sentry values
 SENTRY_ENVIRONMENT='development'
 SENTRY_DSN = sentrydsn

cueweb/Dockerfile

@@ -94,6 +94,29 @@ ENV NEXT_PUBLIC_OPENCUE_ENDPOINT=${NEXT_PUBLIC_OPENCUE_ENDPOINT}
 ARG NEXT_PUBLIC_LOG_EDITOR_URL=
 ENV NEXT_PUBLIC_LOG_EDITOR_URL=${NEXT_PUBLIC_LOG_EDITOR_URL}
 
+# CueProgBar launcher (Monitor Jobs "Show Progress Bar"). CueProgBar is a
+# desktop tool (python -m cuegui.cueguiplugin.cueprogbar <job>); a browser
+# can only reach it via a registered URL scheme. {job} is replaced with the
+# job name. Leave empty to fall back to the in-table Progress column.
+ARG NEXT_PUBLIC_CUEPROGBAR_URL=
+ENV NEXT_PUBLIC_CUEPROGBAR_URL=${NEXT_PUBLIC_CUEPROGBAR_URL}
+
+# The CueProgBar command shown in the "Show Progress Bar" dialog. {job} is
+# replaced with the job name. Sites override this with their own launcher,
+# e.g. "spawn launch cueprogbar {job}".
+ARG NEXT_PUBLIC_CUEPROGBAR_COMMAND=python -m cuegui.cueguiplugin.cueprogbar {job}
+ENV NEXT_PUBLIC_CUEPROGBAR_COMMAND=${NEXT_PUBLIC_CUEPROGBAR_COMMAND}
+
+# "Preview All" (Frames menu) opens rendered output in an external image
+# viewer. PREVIEW_COMMAND is the command shown/copied; PREVIEW_URL is an
+# optional registered URL scheme the Launch button hands off to a local
+# handler. Placeholders {paths} (output paths), {job}, {layer}, {frame} are
+# substituted. Override per site, e.g. a viewer scheme "openrv://{paths}".
+ARG NEXT_PUBLIC_PREVIEW_COMMAND=rv {paths}
+ENV NEXT_PUBLIC_PREVIEW_COMMAND=${NEXT_PUBLIC_PREVIEW_COMMAND}
+ARG NEXT_PUBLIC_PREVIEW_URL=
+ENV NEXT_PUBLIC_PREVIEW_URL=${NEXT_PUBLIC_PREVIEW_URL}
+
 # Authentication providers - use ARG to allow override at build time
 # Set to empty string to disable authentication (sandbox mode)
 # Set to comma-separated list for production (e.g., "google,okta,github,ldap")

cueweb/app/api/department/getdepartmentnames/route.ts

@@ -0,0 +1,36 @@
+/*
+ * 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";
+
+// List the known department names (for the Group dialog's Department dropdown).
+// Request: {} (empty). RPC: /department.DepartmentInterface/GetDepartmentNames.
+export async function POST(request: NextRequest) {
+  const endpoint = "/department.DepartmentInterface/GetDepartmentNames";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify({}));
+  const responseData = await response.json();
+
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? "Failed to fetch department names" }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data?.names ?? [] }, { status: response.status });
+}

cueweb/app/api/department/gettasks/route.ts

@@ -0,0 +1,39 @@
+/*
+ * 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";
+
+// List a department's tasks. Request: { department }.
+// RPC: /department.DepartmentInterface/GetTasks (nested under tasks.tasks).
+export async function POST(request: NextRequest) {
+  const endpoint = "/department.DepartmentInterface/GetTasks";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  const body = JSON.stringify(await request.json());
+  const jsonBody = JSON.parse(body);
+  if (!jsonBody || typeof jsonBody !== 'object' || !jsonBody.department?.id) {
+    return NextResponse.json({ error: 'Invalid request body: department is required' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, body);
+  const responseData = await response.json();
+  if (!response.ok) return NextResponse.json({ error: responseData.error }, { status: response.status });
+  return NextResponse.json({ data: responseData.data?.tasks?.tasks ?? [] }, { status: response.status });
+}

cueweb/app/api/filter/getactions/route.ts

@@ -0,0 +1,39 @@
+/*
+ * 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";
+
+// List a filter's actions. Request: { filter }.
+// RPC: /filter.FilterInterface/GetActions (nested under actions.actions).
+export async function POST(request: NextRequest) {
+  const endpoint = "/filter.FilterInterface/GetActions";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  const body = JSON.stringify(await request.json());
+  const jsonBody = JSON.parse(body);
+  if (!jsonBody || typeof jsonBody !== 'object' || !jsonBody.filter?.id) {
+    return NextResponse.json({ error: 'Invalid request body: filter is required' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, body);
+  const responseData = await response.json();
+  if (!response.ok) return NextResponse.json({ error: responseData.error }, { status: response.status });
+  return NextResponse.json({ data: responseData.data?.actions?.actions ?? [] }, { status: response.status });
+}

cueweb/app/api/filter/getmatchers/route.ts

@@ -0,0 +1,39 @@
+/*
+ * 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";
+
+// List a filter's matchers. Request: { filter }.
+// RPC: /filter.FilterInterface/GetMatchers (nested under matchers.matchers).
+export async function POST(request: NextRequest) {
+  const endpoint = "/filter.FilterInterface/GetMatchers";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  const body = JSON.stringify(await request.json());
+  const jsonBody = JSON.parse(body);
+  if (!jsonBody || typeof jsonBody !== 'object' || !jsonBody.filter?.id) {
+    return NextResponse.json({ error: 'Invalid request body: filter is required' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, body);
+  const responseData = await response.json();
+  if (!response.ok) return NextResponse.json({ error: responseData.error }, { status: response.status });
+  return NextResponse.json({ data: responseData.data?.matchers?.matchers ?? [] }, { status: response.status });
+}

cueweb/app/api/filter/mutate/route.ts

@@ -0,0 +1,71 @@
+/*
+ * 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";
+
+// Consolidated proxy for the View Filters dialog mutations. The body is
+// { op, ...payload }; `op` selects one of the allowlisted Filter / Matcher /
+// Action RPCs and the rest of the body is forwarded verbatim. Returns the
+// gateway response data (the created object for create ops).
+const ENDPOINTS: Record<string, string> = {
+  // ShowInterface
+  "show.createfilter": "/show.ShowInterface/CreateFilter",
+  // FilterInterface
+  "filter.setname": "/filter.FilterInterface/SetName",
+  "filter.settype": "/filter.FilterInterface/SetType",
+  "filter.setenabled": "/filter.FilterInterface/SetEnabled",
+  "filter.setorder": "/filter.FilterInterface/SetOrder",
+  "filter.raiseorder": "/filter.FilterInterface/RaiseOrder",
+  "filter.lowerorder": "/filter.FilterInterface/LowerOrder",
+  "filter.orderfirst": "/filter.FilterInterface/OrderFirst",
+  "filter.orderlast": "/filter.FilterInterface/OrderLast",
+  "filter.delete": "/filter.FilterInterface/Delete",
+  "filter.creatematcher": "/filter.FilterInterface/CreateMatcher",
+  "filter.createaction": "/filter.FilterInterface/CreateAction",
+  // MatcherInterface
+  "matcher.commit": "/filter.MatcherInterface/Commit",
+  "matcher.delete": "/filter.MatcherInterface/Delete",
+  // ActionInterface
+  "action.commit": "/filter.ActionInterface/Commit",
+  "action.delete": "/filter.ActionInterface/Delete",
+};
+
+export async function POST(request: NextRequest) {
+  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 in request body' }, { status: 400 });
+  }
+  const { op, ...payload } = jsonBody ?? {};
+  const endpoint = typeof op === 'string' ? ENDPOINTS[op] : undefined;
+  if (!endpoint) {
+    return NextResponse.json({ error: `Unknown filter op: ${op}` }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, JSON.stringify(payload), true);
+  const responseData = await response.json();
+  if (!response.ok) {
+    return NextResponse.json({ error: responseData?.error ?? `Failed: ${op}` }, { status: response.status });
+  }
+  return NextResponse.json({ data: responseData.data ?? { success: true } }, { status: response.status });
+}

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

@@ -22,7 +22,7 @@ import { NextRequest, NextResponse } from "next/server";
 // 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 endpoint = "/job.FrameInterface/CreateDependencyOnFrame";
   const method = request.method;
   if (method !== 'POST') {
     return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });

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

@@ -21,7 +21,7 @@ import { NextRequest, NextResponse } from "next/server";
 // FrameInterface.CreateDependencyOnJob. Used by the Frame On Job
 // dependency wizard flow.
 export async function POST(request: NextRequest) {
-  const endpoint = "/frame.FrameInterface/CreateDependencyOnJob";
+  const endpoint = "/job.FrameInterface/CreateDependencyOnJob";
   const method = request.method;
   if (method !== 'POST') {
     return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });

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

@@ -21,7 +21,7 @@ import { NextRequest, NextResponse } from "next/server";
 // FrameInterface.CreateDependencyOnLayer. Used by the Frame On Layer
 // dependency wizard flow.
 export async function POST(request: NextRequest) {
-  const endpoint = "/frame.FrameInterface/CreateDependencyOnLayer";
+  const endpoint = "/job.FrameInterface/CreateDependencyOnLayer";
   const method = request.method;
   if (method !== 'POST') {
     return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });

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

@@ -0,0 +1,42 @@
+/*
+ * 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";
+
+// Drop all dependencies on a frame (CueGUI FrameActions.dropDepends).
+// RPC: /job.FrameInterface/DropDepends. Request: { frame, target } where
+// target is a depend.DependTarget name (default "ANY_TARGET" = drop all).
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.FrameInterface/DropDepends";
+  if (request.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?.frame) {
+    return NextResponse.json({ error: 'Invalid request body (need {frame})' }, { status: 400 });
+  }
+  if (!jsonBody.target) jsonBody.target = "ANY_TARGET";
+  const response = await handleRoute(request.method, endpoint, JSON.stringify(jsonBody), true);
+  const responseData = await response.json();
+  if (!response.ok) return NextResponse.json({ error: responseData.error }, { status: response.status });
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}

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

@@ -0,0 +1,41 @@
+/*
+ * 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";
+
+// Return the dependencies a frame depends on (CueGUI DependDialog ->
+// getWhatThisDependsOn). RPC: /job.FrameInterface/GetWhatThisDependsOn.
+// Request: { frame }. Response wraps a depend.DependSeq.
+export async function POST(request: NextRequest) {
+  const endpoint = "/job.FrameInterface/GetWhatThisDependsOn";
+  const method = request.method;
+  if (method !== 'POST') {
+    return NextResponse.json({ error: 'Invalid method. Only POST is allowed.' }, { status: 405 });
+  }
+
+  const body = JSON.stringify(await request.json());
+  const jsonBody = JSON.parse(body);
+  if (!jsonBody || typeof jsonBody !== 'object' || !jsonBody.frame) {
+    return NextResponse.json({ error: 'Invalid request body' }, { status: 400 });
+  }
+
+  const response = await handleRoute(method, endpoint, body, true);
+  const responseData = await response.json();
+
+  if (!response.ok) return NextResponse.json({ error: responseData.error }, { status: response.status });
+  return NextResponse.json({ data: responseData.data }, { status: response.status });
+}