-
Most important detection
+
+ Priority Case
{overview.importantDetection ? (
<>
{overview.importantDetection.summary}
-
-
-
-
+
+
+
Severity
+
+
+
+
+
Status
+
+
+
+
+
Confidence
+ {Math.round(overview.importantDetection.confidence * 100)}%
+
+
+
Work order
+ {overview.context.workOrderId}
+
+
+
+
) : (
<>
-
No active detections
-
- Start Demo-Factory, then start the FIP Docker Compose stack
- and refresh this page after Process Sentinel stores runtime
- detections.
-
+
No active cases
+
No active Process Sentinel cases are available in the current operational state.
+
+ Open Process Sentinel
+
)}
-
-
+
+
+
+ Operational Context
+ {overview.context.areaName}
+
+
+
Line
+ {overview.context.lineDescription}
+
+
+
Asset
+ {overview.context.assetName}
+
+
+
Signal
+ {overview.context.signalName}
+
+
+
Product
+ {overview.context.productName}
+
+
+
+
+
+ Integration & Governance
+
+
+
Data source
+ {productCopy.dataSourceLabel}
+
+
+
Status
+ {productCopy.integrationStatusLabel}
+
+
+
Writeback policy
+ {productCopy.writebackPolicyLabel}
+
+
+
External submission
+ Not configured
+
+
+
+
+
) : null}
-
+
+ );
+}
+
+function FactoryContextGraph({ context }: { context: OverviewContext }) {
+ const nodes = [
+ { className: "site", label: context.siteName, type: "Site" },
+ { className: "area", label: context.areaName, type: "Area" },
+ { className: "asset", label: context.assetName, type: "Asset" },
+ { className: "signal", label: context.signalName, type: "Signal" },
+ { className: "case", label: "Priority case", type: "Process Sentinel" },
+ { className: "work-order", label: context.workOrderId, type: "Work order" },
+ { className: "recommendation", label: "Recommendation", type: "Governed review" },
+ { className: "historian", label: "Historian", type: "Connection" },
+ { className: "qms", label: "QMS / LIMS", type: "Quality" },
+ { className: "mes", label: "MES", type: "Production" },
+ ];
+
+ return (
+
+
+
+ {nodes.map((node) => (
+
+ {node.label}
+ {node.type}
+
+ ))}
+
);
}
+type OverviewContext = {
+ areaName: string;
+ assetName: string;
+ lastUpdated: string;
+ lineDescription: string;
+ productName: string;
+ signalName: string;
+ siteDescription: string;
+ siteName: string;
+ workOrderId: string;
+};
+
async function loadOverview() {
try {
- const [health, sites, areas, equipment, batches, detections, recommendations] =
- await Promise.all([
- workbenchApi.getHealth(),
- workbenchApi.listSites(),
- workbenchApi.listAreas(),
- workbenchApi.listEquipment(),
- workbenchApi.listBatches(),
- workbenchApi.listDetections(),
- workbenchApi.listRecommendations(),
- ]);
+ const [
+ health,
+ sites,
+ areas,
+ equipment,
+ processSignals,
+ batches,
+ detections,
+ recommendations,
+ ] = await Promise.all([
+ workbenchApi.getHealth(),
+ workbenchApi.listSites(),
+ workbenchApi.listAreas(),
+ workbenchApi.listEquipment(),
+ workbenchApi.listProcessSignals(),
+ workbenchApi.listBatches(),
+ workbenchApi.listDetections(),
+ workbenchApi.listRecommendations(),
+ ]);
const activeDetections = detections.filter((detection) =>
activeDetectionStatuses.has(detection.status),
);
@@ -193,8 +286,15 @@ async function loadOverview() {
return {
activeDetections,
- context: buildOverviewContext({ areas, batches, equipment, importantDetection, sites }),
- health,
+ context: buildOverviewContext({
+ areas,
+ batches,
+ equipment,
+ importantDetection,
+ processSignals,
+ sites,
+ }),
+ dataHealthLabel: health.status === "ok" ? productCopy.dataHealthLabel : health.status,
importantDetection,
ok: true as const,
pendingRecommendations,
@@ -207,8 +307,8 @@ async function loadOverview() {
function selectImportantDetection(detections: Detection[]): Detection | null {
const severityRank: Record
= {
high: 3,
- medium: 2,
low: 1,
+ medium: 2,
};
return (
@@ -227,19 +327,24 @@ function buildOverviewContext({
batches,
equipment,
importantDetection,
+ processSignals,
sites,
}: {
areas: Area[];
batches: Batch[];
equipment: Equipment[];
importantDetection: Detection | null;
+ processSignals: ProcessSignal[];
sites: Site[];
-}) {
+}): OverviewContext {
const currentBatch =
batches.find((batch) => batch.status === "running" || batch.status === "held") ?? batches[0];
const relatedAsset = importantDetection?.related_asset_ids[0];
const currentEquipment =
equipment.find((asset) => asset.equipment_id === relatedAsset) ?? equipment[0];
+ const currentSignal =
+ processSignals.find((signal) => signal.equipment_id === currentEquipment?.equipment_id) ??
+ processSignals[0];
const currentArea =
areas.find((area) => area.area_id === currentEquipment?.area_id) ??
areas.find((area) => area.area_id === currentBatch?.area_id) ??
@@ -250,18 +355,24 @@ function buildOverviewContext({
sites[0];
return {
- areaName: currentArea?.name ?? "Demo production area",
- assetName: currentEquipment?.name ?? "Demo asset unavailable",
- lineDescription: currentArea?.description ?? "Demo line context unavailable",
- productName: currentBatch?.product_name ?? "Demo product unavailable",
- siteDescription:
- currentSite?.description ??
- "External-source site context will appear when the local FIP API is available.",
- siteName: currentSite?.name ?? "Factory Intelligence Platform demo",
- workOrderId: importantDetection?.related_work_order_id ?? "Demo work order unavailable",
+ areaName: currentArea?.name ?? "Production area unavailable",
+ assetName: currentEquipment?.name ?? "Asset unavailable",
+ lastUpdated: importantDetection?.created_at
+ ? formatTimestamp(importantDetection.created_at)
+ : "Current session",
+ lineDescription: currentArea?.description ?? "Line context unavailable",
+ productName: currentBatch?.product_name ?? "Product unavailable",
+ signalName: currentSignal?.name ?? "Signal unavailable",
+ siteDescription: currentSite?.description ?? productCopy.siteSubtitle,
+ siteName: currentSite?.name ?? productCopy.siteName,
+ workOrderId: importantDetection?.related_work_order_id ?? "Work order unavailable",
};
}
+function formatTimestamp(value: string): string {
+ return value.replace("T", " ").replace("Z", " UTC");
+}
+
function severityTone(severity: Detection["severity"]) {
if (severity === "high") {
return "danger";
diff --git a/apps/web/app/process-sentinel/page.tsx b/apps/web/app/process-sentinel/page.tsx
new file mode 100644
index 0000000..5f65f4b
--- /dev/null
+++ b/apps/web/app/process-sentinel/page.tsx
@@ -0,0 +1,396 @@
+import Link from "next/link";
+
+import {
+ ApiErrorPanel,
+ EmptyState,
+ StatusBadge,
+} from "../components/demo-state";
+import {
+ type Detection,
+ type Equipment,
+ type EvidenceItem,
+ type Recommendation,
+ formatApiError,
+ workbenchApi,
+} from "../../lib/api-client";
+
+export const dynamic = "force-dynamic";
+
+export default async function ProcessSentinelPage() {
+ const result = await loadProcessSentinelWorkbench();
+
+ return (
+
+
+
+
+
+ Ask about current factory context
+
+
+
+
+
+ 1
+ Detect
+ {result.ok ? `${result.newCount} new` : "Unavailable"}
+
+
+ 2
+ Explain
+ {result.ok ? `${result.explainCount} explained` : "Unavailable"}
+
+
+ 3
+ Review
+ {result.ok ? `${result.reviewCount} pending` : "Unavailable"}
+
+
+ 4
+ Draft
+ {result.ok ? `${result.draftCount} in progress` : "Unavailable"}
+
+
+
+ {!result.ok ?
+
+
+
Detection Queue ({result.detections.length})
+
+ View
+
+ All Open
+ Review
+ Explain
+
+
+
+
+
+
+
+ Severity
+ Detection Title
+ Unit
+ Detected At
+ Status
+
+
+
+ {result.detections.map((detection) => {
+ const isSelected =
+ detection.detection_id === result.selectedDetection?.detection_id;
+
+ return (
+
+
+
+
+
+ {formatAssetLabel(detection, result.equipmentById)}
+ {formatClock(detection.created_at)}
+
+
+
+ );
+ })}
+
+
+
+ 1-{result.detections.length} of {result.detections.length}
+ Rows per page 10
+
+
+
+
+
+
+
+ Selected Finding
+
{result.selectedDetection.summary}
+
+
+
+
+
Unit
+ {formatAssetLabel(result.selectedDetection, result.equipmentById)}
+
+
+
Detected At
+ {formatDateTime(result.selectedDetection.created_at)}
+
+
+
Duration
+ {formatDuration(result.selectedDetection)}
+
+
+
Status
+ {formatStatus(result.selectedDetection.status)}
+
+
+
Owner
+ Unassigned
+
+
+
+ {result.selectedDetection.summary} Confidence is{" "}
+ {Math.round(result.selectedDetection.confidence * 100)}% for the
+ current operating window.
+
+
+ Evidence
+ Signals
+ KPIs
+ Context
+ Notes (0)
+ Linked Items ({result.selectedRecommendation ? 1 : 0})
+
+
+
+
Evidence Timeline
+
+
+
+ Time
+ Evidence
+ Score
+ Severity
+
+
+
+ {result.evidence.map((item) => (
+
+ {formatClock(item.timestamp)}
+
+ {item.title}
+ {item.description}
+
+ {Math.round(item.score * 100)}%
+
+
+
+ ))}
+
+
+ ) : (
+ No evidence items are linked to this finding yet.
+ )}
+
+
+
+
+
+
+ Governed Recommendation
+
{result.selectedRecommendation ? "Recommendation Draft" : "No recommendation linked"}
+
+
+
+
+ Recommendation
+ {result.selectedRecommendation.recommended_action}
+ Expected Outcome
+
+ Reduce quality risk while the affected work order is under
+ human review.
+
+
+
+ Rationale
+ {result.selectedRecommendation.rationale}
+ Reference Evidence
+ {result.selectedRecommendation.evidence_ids.join(", ")}
+
+
No governed recommendation has been generated for this case yet.
+ )}
+
+
+
+
+
+ );
+}
+
+async function loadProcessSentinelWorkbench() {
+ try {
+ const [detections, recommendations, equipment] = await Promise.all([
+ workbenchApi.listDetections(),
+ workbenchApi.listRecommendations(),
+ workbenchApi.listEquipment(),
+ ]);
+ const selectedDetection = selectDetection(detections);
+ const evidence = selectedDetection
+ ? await workbenchApi.listDetectionEvidence(selectedDetection.detection_id)
+ : [];
+ const selectedRecommendation = selectedDetection
+ ? recommendations.find(
+ (recommendation) =>
+ recommendation.detection_id === selectedDetection.detection_id,
+ ) ?? null
+ : null;
+
+ return {
+ detections,
+ draftCount: recommendations.filter((item) => item.status === "draft").length,
+ equipmentById: new Map(equipment.map((item) => [item.equipment_id, item])),
+ evidence,
+ explainCount: detections.filter((item) => item.status === "investigating").length,
+ newCount: detections.filter((item) => item.status === "new").length,
+ ok: true as const,
+ reviewCount: recommendations.filter((item) => item.status === "needs_review").length,
+ selectedDetection,
+ selectedRecommendation,
+ };
+ } catch (error) {
+ return { message: formatApiError(error), ok: false as const };
+ }
+}
+
+function selectDetection(detections: Detection[]): Detection | null {
+ return [...detections].sort((left, right) => {
+ const severityDelta = severityRank(right.severity) - severityRank(left.severity);
+ if (severityDelta !== 0) {
+ return severityDelta;
+ }
+ return Date.parse(right.created_at) - Date.parse(left.created_at);
+ })[0] ?? null;
+}
+
+function severityRank(severity: Detection["severity"] | EvidenceItem["severity"]) {
+ if (severity === "high") {
+ return 3;
+ }
+ if (severity === "medium") {
+ return 2;
+ }
+ return 1;
+}
+
+function severityTone(severity: Detection["severity"] | EvidenceItem["severity"]) {
+ if (severity === "high") {
+ return "danger";
+ }
+ if (severity === "medium") {
+ return "warning";
+ }
+ return "info";
+}
+
+function formatAssetLabel(
+ detection: Detection,
+ equipmentById: Map,
+): string {
+ const assetId = detection.related_asset_ids[0];
+ return assetId ? equipmentById.get(assetId)?.name ?? assetId : "Unassigned";
+}
+
+function formatStatus(status: Detection["status"]): string {
+ if (status === "recommendation_created") {
+ return "Review";
+ }
+ if (status === "investigating") {
+ return "Explain";
+ }
+ return status.replaceAll("_", " ");
+}
+
+function formatClock(value: string): string {
+ return new Intl.DateTimeFormat("en-US", {
+ hour: "2-digit",
+ hour12: false,
+ minute: "2-digit",
+ timeZone: "UTC",
+ }).format(new Date(value));
+}
+
+function formatDateTime(value: string): string {
+ return new Intl.DateTimeFormat("en-US", {
+ dateStyle: "medium",
+ timeStyle: "short",
+ timeZone: "UTC",
+ }).format(new Date(value));
+}
+
+function formatDuration(detection: Detection): string {
+ const start = Date.parse(detection.time_window_start);
+ const end = Date.parse(detection.time_window_end);
+ if (Number.isNaN(start) || Number.isNaN(end) || end <= start) {
+ return "Current window";
+ }
+ return `${Math.round((end - start) / 60_000)} min`;
+}
diff --git a/apps/web/app/rca-capa-draft/draft-copy-button.tsx b/apps/web/app/rca-capa-draft/draft-copy-button.tsx
index 68f3682..28b9143 100644
--- a/apps/web/app/rca-capa-draft/draft-copy-button.tsx
+++ b/apps/web/app/rca-capa-draft/draft-copy-button.tsx
@@ -21,7 +21,7 @@ export function DraftCopyButton({ draftText }: DraftCopyButtonProps) {
return (
- Copy draft text
+ Copy draft
{copyState === "copied" ? "Copied" : null}
diff --git a/apps/web/app/rca-capa-draft/page.tsx b/apps/web/app/rca-capa-draft/page.tsx
index 3b1cce1..c7764e6 100644
--- a/apps/web/app/rca-capa-draft/page.tsx
+++ b/apps/web/app/rca-capa-draft/page.tsx
@@ -10,7 +10,6 @@ import {
ApiClientError,
type RcaCapaDraft,
formatApiError,
- getApiBaseUrl,
workbenchApi,
} from "../../lib/api-client";
import { DraftCopyButton } from "./draft-copy-button";
@@ -31,22 +30,21 @@ export default async function RcaCapaDraftPage({
return (
- Demo-generated draft
+ Investigation draft
RCA/CAPA Draft
- Preview investigation-ready RCA/CAPA draft language for the selected
- external-source Process Sentinel detection. Draft content is
- human-review required and is not automatically submitted to QMS or MES
- systems.
+ Review RCA/CAPA draft language generated from the selected case,
+ linked evidence, and recommendation history. Draft content requires
+ human review before QMS or MES submission.
{!result.ok && result.notFound ? (
- The local FIP API did not return an RCA/CAPA draft for{" "}
+ The manufacturing data service did not return an RCA/CAPA draft for{" "}
{result.detectionId}. Open a current runtime detection
and use its RCA/CAPA draft link.
@@ -57,18 +55,18 @@ export default async function RcaCapaDraftPage({
{!result.ok && !result.notFound ?
- This RCA/CAPA draft is generated from runtime detection, evidence,
- and recommendation state. It is advisory decision support for human
- review only; it is not a validated production record and it does not
- submit anything to QMS or MES.
+ This draft is generated from case evidence and recommendation
+ state. It is advisory content for human review and is not a
+ validated production record until reviewed, approved, and submitted
+ through the appropriate quality workflow.
@@ -95,13 +93,13 @@ export default async function RcaCapaDraftPage({
System submission
-
Source
-
@@ -142,7 +140,7 @@ export default async function RcaCapaDraftPage({
className="secondary-action"
href={`/detections/${result.draft.detection_id}`}
>
- Open detection
+ Review case
@@ -161,11 +159,6 @@ export default async function RcaCapaDraftPage({
-
- Configured API target: {getApiBaseUrl()}
-
-
- External-source governed recommendation
+ Recommendation pending review
Recommendation review
- Review the advisory Process Sentinel recommendation and record a human
- decision. This recommendation is advisory and human-reviewed; no
- industrial writeback is performed.
+ Review the advisory recommendation, supporting evidence, and
+ operational impact before recording a disposition.
{!result.ok ?
Recommendations are advisory decision support. A named human reviewer
- must approve, reject, or defer before any high-impact action is
- considered. The Workbench does not perform industrial writeback,
- product disposition, QMS/MES updates, or production CAPA creation.
+ must approve, reject, or defer the recommendation before any
+ external execution, system submission, or quality action is
+ initiated.
@@ -70,7 +68,7 @@ export default async function RecommendationsPage({
className="secondary-action"
href={`/detections/${result.selected.detection_id}`}
>
- Open detection
+ Review case
@@ -92,11 +90,6 @@ export default async function RecommendationsPage({
) : null}
-
-
- Configured API target: {getApiBaseUrl()}
-
-
);
}
diff --git a/apps/web/app/recommendations/recommendation-review-panel.tsx b/apps/web/app/recommendations/recommendation-review-panel.tsx
index 0535020..00a3c5a 100644
--- a/apps/web/app/recommendations/recommendation-review-panel.tsx
+++ b/apps/web/app/recommendations/recommendation-review-panel.tsx
@@ -104,11 +104,11 @@ export function RecommendationReviewPanel({
onSubmit={handleSubmit}
>
- Enter a reviewer and decision reason before approving, rejecting, or
- deferring this external-source recommendation.
+ Enter a reviewer name and decision reason before recording a
+ disposition.
-
Reviewer name
+
Reviewer Name
submitDecision("approve")}
type="button"
>
- {submittingAction === "approve" ? "Approving..." : "Approve"}
+ {submittingAction === "approve" ? "Approving..." : "Approve recommendation"}
- Demo audit feedback: {formatEnum(decisionResult.decision)}
+ Disposition recorded: {formatEnum(decisionResult.decision)}
Recommendation ID: {decisionResult.recommendation_id}
Reviewer: {decisionResult.reviewer}
@@ -195,8 +195,8 @@ export function RecommendationReviewPanel({
/>
- This is a demo audit trail from the decision response, not a
- validated production audit record or electronic signature.
+ This disposition record is not a validated production audit record
+ or electronic signature.
("/equipment"),
listProcessSignals: () => requestJson("/process-signals"),
listBatches: () => requestJson("/batches"),
+ askContextQuestion: (request: ContextQuestionRequest) =>
+ requestJson("/context/questions", {
+ body: JSON.stringify(request),
+ method: "POST",
+ }),
listDetections: () => requestJson("/sentinel/detections"),
getDetection: (detectionId: string) =>
requestJson(`/sentinel/detections/${encodeURIComponent(detectionId)}`),
@@ -361,7 +385,7 @@ function postDecision(
}
async function requestJson(path: string, init: RequestInit = {}): Promise {
- const response = await fetch(`${apiBaseUrl}${path}`, {
+ const response = await fetch(`${getRequestApiBaseUrl()}${path}`, {
...init,
cache: "no-store",
headers: {
diff --git a/apps/web/lib/api-config.ts b/apps/web/lib/api-config.ts
index 857a090..7c7d737 100644
--- a/apps/web/lib/api-config.ts
+++ b/apps/web/lib/api-config.ts
@@ -1,2 +1,16 @@
+const fallbackApiBaseUrl = "http://127.0.0.1:8000";
+
+function cleanBaseUrl(value: string | undefined): string | undefined {
+ return value?.replace(/\/$/, "");
+}
+
export const apiBaseUrl =
- process.env.NEXT_PUBLIC_API_BASE_URL?.replace(/\/$/, "") ?? "http://127.0.0.1:8000";
+ cleanBaseUrl(process.env.NEXT_PUBLIC_API_BASE_URL) ?? fallbackApiBaseUrl;
+
+export function getRequestApiBaseUrl(): string {
+ if (typeof window !== "undefined") {
+ return apiBaseUrl;
+ }
+
+ return cleanBaseUrl(process.env.FIP_API_URL) ?? apiBaseUrl;
+}
diff --git a/apps/web/lib/product-copy.ts b/apps/web/lib/product-copy.ts
new file mode 100644
index 0000000..4e4c5fc
--- /dev/null
+++ b/apps/web/lib/product-copy.ts
@@ -0,0 +1,12 @@
+export const productCopy = {
+ dataHealthLabel: "Connected",
+ dataSourceLabel: "Manufacturing Data Service",
+ environmentLabel: "Validation",
+ integrationEndpointLabel: "Integration endpoint",
+ integrationStatusLabel: "Connected",
+ siteLocationLabel: "Greenville",
+ siteName: "Greenville Manufacturing Site",
+ siteSubtitle: "Process quality monitoring and recommendation review workspace.",
+ writebackPolicyLabel: "Human approval required",
+ writebackPolicyDetail: "Read-only; external submission not configured",
+} as const;
diff --git a/apps/web/tests/api-client.test.mjs b/apps/web/tests/api-client.test.mjs
index 16e2826..b5ecfff 100644
--- a/apps/web/tests/api-client.test.mjs
+++ b/apps/web/tests/api-client.test.mjs
@@ -19,6 +19,7 @@ const requiredEndpoints = [
"/equipment",
"/process-signals",
"/batches",
+ "/context/questions",
"/sentinel/detections",
"/sentinel/detections/${encodeURIComponent(detectionId)}",
"/sentinel/detections/${encodeURIComponent(detectionId)}/evidence",
@@ -50,6 +51,10 @@ test("typed workbench API client covers demo endpoints", () => {
assert.match(client, /listEquipment/);
assert.match(client, /listProcessSignals/);
assert.match(client, /listBatches/);
+ assert.match(client, /askContextQuestion/);
+ assert.match(client, /export type ContextQuestionResponse/);
+ assert.match(client, /confidence: "supported" \| "partial" \| "unsupported"/);
+ assert.match(client, /sources: ContextQuestionSource\[\]/);
assert.match(client, /listDetections/);
assert.match(client, /getDetection/);
assert.match(client, /listDetectionEvidence/);
diff --git a/apps/web/tests/app-shell.test.mjs b/apps/web/tests/app-shell.test.mjs
index 90465dc..88bb91d 100644
--- a/apps/web/tests/app-shell.test.mjs
+++ b/apps/web/tests/app-shell.test.mjs
@@ -9,6 +9,8 @@ const root = fileURLToPath(new URL("..", import.meta.url));
const requiredRoutes = [
"app/page.tsx",
+ "app/context-question-panel.tsx",
+ "app/process-sentinel/page.tsx",
"app/connections/page.tsx",
"app/connections/connections-workspace.tsx",
"app/protocol-diagnostics/page.tsx",
@@ -27,33 +29,43 @@ test("workbench placeholder routes exist", async () => {
await Promise.all(requiredRoutes.map((route) => access(join(root, route))));
});
-test("navigation includes the required demo routes", () => {
+test("navigation includes the required workbench routes", () => {
const layout = readFileSync(join(root, "app/layout.tsx"), "utf8");
+ const navigation = readFileSync(join(root, "app/components/operator-navigation.tsx"), "utf8");
+ const shell = `${layout}\n${navigation}`;
assert.match(layout, /Skip to main content/);
assert.match(layout, /id="main-content"/);
assert.match(layout, /operator-shell/);
assert.match(layout, /operator-sidebar/);
assert.match(layout, /Workbench navigation/);
- assert.match(layout, /Operator Console/);
- assert.match(layout, /Sentinel workflows/);
- assert.match(layout, /Overview/);
- assert.match(layout, /Detections/);
- assert.match(layout, /Recommendations/);
- assert.match(layout, /RCA\/CAPA Draft/);
- assert.match(layout, /Protocol operations/);
- assert.match(layout, /Connections/);
- assert.match(layout, /href: "\/connections"/);
- assert.match(layout, /Protocol Diagnostics/);
- assert.match(layout, /href: "\/protocol-diagnostics"/);
- assert.match(layout, /Tag\/Source Browser/);
- assert.match(layout, /href: "\/tag-source-browser"/);
- assert.match(layout, /Workbench status strip/);
- assert.doesNotMatch(layout, / {
assert.doesNotMatch(workspace, /connections-actions/);
});
-test("operator shell uses the Demo Factory console palette", () => {
+test("operator shell uses the production operations console palette", () => {
const styles = readFileSync(join(root, "app/globals.css"), "utf8");
- assert.match(styles, /--background: #e8eef3/);
+ assert.match(styles, /--background: #eef2f6/);
assert.match(styles, /--surface: #ffffff/);
assert.match(styles, /--text: #16202a/);
assert.match(styles, /--muted: #526579/);
assert.match(styles, /--border: #d3dee7/);
- assert.match(styles, /--nav: #101820/);
- assert.match(styles, /--nav-2: #1d2b36/);
+ assert.match(styles, /--nav: #07111b/);
+ assert.match(styles, /--nav-2: #101f2b/);
assert.match(styles, /--accent: #0f766e/);
assert.match(styles, /--warning: #b45309/);
assert.match(styles, /--danger: #b91c1c/);
assert.match(styles, /background: var\(--nav\)/);
assert.match(styles, /background: var\(--nav-2\)/);
+ assert.match(styles, /operator-topbar/);
+ assert.match(styles, /sentinel-workbench-grid/);
});
-test("overview page contains manufacturer demo dashboard content", () => {
+test("overview page contains production operations dashboard content", () => {
const overview = readFileSync(join(root, "app/page.tsx"), "utf8");
+ const contextQuestion = readFileSync(join(root, "app/context-question-panel.tsx"), "utf8");
const demoState = readFileSync(join(root, "app/components/demo-state.tsx"), "utf8");
-
- assert.match(overview, /Current demo context/);
- assert.match(overview, /Active detections/);
- assert.match(overview, /Pending recommendations/);
- assert.match(overview, /Most important detection/);
- assert.match(overview, /Open detection/);
+ const productCopy = readFileSync(join(root, "lib/product-copy.ts"), "utf8");
+
+ assert.match(overview, /ContextQuestionPanel/);
+ assert.match(contextQuestion, /Ask about current factory context/);
+ assert.match(contextQuestion, /workbenchApi\.askContextQuestion/);
+ assert.match(contextQuestion, /Context answer sources/);
+ assert.match(contextQuestion, /suggested_questions/);
+ assert.match(contextQuestion, /supported/);
+ assert.match(contextQuestion, /partial/);
+ assert.match(contextQuestion, /unsupported/);
+ assert.match(productCopy, /Greenville Manufacturing Site/);
+ assert.match(productCopy, /Process quality monitoring and recommendation review workspace/);
+ assert.match(overview, /Current operational state/);
+ assert.match(overview, /Active Cases/);
+ assert.match(overview, /Pending Reviews/);
+ assert.match(overview, /Factory Context/);
+ assert.match(overview, /FactoryContextGraph/);
+ assert.match(overview, /Connected operational graph/);
+ assert.match(overview, /Operational Context/);
+ assert.match(overview, /Priority case/);
+ assert.match(overview, /Review case/);
+ assert.match(overview, /Integration & Governance/);
+ assert.match(overview, /listProcessSignals/);
assert.match(overview, /selectImportantDetection/);
- assert.match(overview, /ApiConnectionBanner/);
- assert.match(overview, /API base URL/);
- assert.match(overview, /API health/);
- assert.match(demoState, /Local API connected/);
- assert.match(demoState, /API target/);
- assert.match(demoState, /External source expected/);
- assert.match(demoState, /Read-only runtime expected/);
+ assert.doesNotMatch(overview, /hero/);
+ assert.doesNotMatch(overview, /overview-kpi-strip/);
+ assert.doesNotMatch(overview, /ApiConnectionBanner/);
+ assert.doesNotMatch(overview, /API base URL/);
+ assert.match(demoState, /Integration details/);
+ assert.match(demoState, /Integration endpoint/);
+ assert.match(demoState, /productCopy\.dataSourceLabel/);
+ assert.match(demoState, /validation data source/);
+});
+
+test("process sentinel has an operations workbench route separate from overview", () => {
+ const route = readFileSync(join(root, "app/process-sentinel/page.tsx"), "utf8");
+ const readme = readFileSync(join(root, "README.md"), "utf8");
+ const ia = readFileSync(
+ join(root, "../../docs/demo/OPERATIONS_WORKBENCH_INFORMATION_ARCHITECTURE.md"),
+ "utf8",
+ );
+
+ assert.match(route, /Process Sentinel/);
+ assert.match(route, /Detection Queue/);
+ assert.match(route, /Selected Finding/);
+ assert.match(route, /Evidence Timeline/);
+ assert.match(route, /Governed Recommendation/);
+ assert.match(route, /Configure Connections/);
+ assert.match(route, /listDetectionEvidence/);
+ assert.match(route, /listRecommendations/);
+ assert.match(route, /listEquipment/);
+ assert.match(readme, /\/process-sentinel/);
+ assert.match(ia, /\/process-sentinel/);
+ assert.match(ia, /Overview is global factory context/);
});
test("detections pages contain list and detail content", () => {
@@ -271,10 +326,7 @@ test("detections pages contain list and detail content", () => {
const demoState = readFileSync(join(root, "app/components/demo-state.tsx"), "utf8");
const styles = readFileSync(join(root, "app/globals.css"), "utf8");
- assert.match(
- list,
- /Process Sentinel detections from the current external-source event\s+store/,
- );
+ assert.match(list, /Process Sentinel cases generated from monitored process signals/);
assert.match(list, /detection.summary/);
assert.match(list, /detection.severity/);
assert.match(list, /detection.confidence/);
@@ -285,7 +337,8 @@ test("detections pages contain list and detail content", () => {
assert.match(list, /formatTimeWindow/);
assert.match(list, /related_work_order_id/);
assert.match(list, /related_asset_ids/);
- assert.match(list, /Open detection/);
+ assert.match(list, /Evidence count/);
+ assert.match(list, /Review case/);
assert.match(detail, /Detection detail/);
assert.match(detail, /getDetection/);
assert.match(detail, /Detection not found/);
@@ -318,7 +371,7 @@ test("detections pages contain list and detail content", () => {
assert.match(detail, /RCA\/CAPA draft/);
assert.match(detail, /rca-capa-draft\?detection_id=/);
assert.doesNotMatch(detail, new RegExp("simulator-" + "backed", "i"));
- assert.match(detail, /External-source evidence/);
+ assert.match(detail, /Linked evidence/);
assert.match(demoState, /function StatusBadge/);
assert.match(styles, /status-badge/);
assert.match(styles, /status-badge-danger/);
@@ -340,7 +393,7 @@ test("recommendation page contains governed review panel", () => {
assert.match(page, /RecommendationReviewPanel/);
assert.match(page, /Recommendations are advisory decision support/);
assert.match(page, /rca-capa-draft\?detection_id=/);
- assert.match(panel, /Reviewer name/);
+ assert.match(panel, /Reviewer Name/);
assert.match(panel, /Decision reason/);
assert.match(panel, /Approve/);
assert.match(panel, /Reject/);
@@ -348,7 +401,7 @@ test("recommendation page contains governed review panel", () => {
assert.match(panel, /approveRecommendation/);
assert.match(panel, /rejectRecommendation/);
assert.match(panel, /deferRecommendation/);
- assert.match(panel, /Demo audit feedback/);
+ assert.match(panel, /Disposition recorded/);
assert.match(panel, /Recommendation ID/);
assert.match(panel, /decisionResult\.recommendation_id/);
assert.match(panel, /Reviewer:/);
@@ -380,36 +433,40 @@ test("RCA CAPA page contains selected detection draft preview", () => {
assert.match(page, /Evidence summary/);
assert.match(page, /Recommended containment/);
assert.match(page, /CAPA placeholder/);
- assert.match(page, /human-review/);
- assert.match(page, /not automatically submitted to QMS/);
+ assert.match(page, /Human review/);
+ assert.match(page, /System submission/);
+ assert.match(page, /Not submitted/);
assert.match(page, /DraftCopyButton/);
assert.match(page, /formatDraftForCopy/);
assert.match(page, /StatusBadge/);
assert.match(copyButton, /navigator\.clipboard\.writeText/);
- assert.match(copyButton, /Copy draft text/);
+ assert.match(copyButton, /Copy draft/);
assert.match(styles, /rca-draft-card/);
assert.match(styles, /draft-section/);
assert.match(styles, /draft-copy/);
});
-test("app shell documents configurable API base URL", () => {
+test("app shell keeps integration endpoint details in diagnostics copy", () => {
const config = readFileSync(join(root, "lib/api-config.ts"), "utf8");
const client = readFileSync(join(root, "lib/api-client.ts"), "utf8");
const demoState = readFileSync(join(root, "app/components/demo-state.tsx"), "utf8");
const readme = readFileSync(join(root, "README.md"), "utf8");
assert.match(config, /NEXT_PUBLIC_API_BASE_URL/);
+ assert.match(config, /FIP_API_URL/);
+ assert.match(config, /getRequestApiBaseUrl/);
+ assert.match(config, /typeof window !== "undefined"/);
assert.match(client, /apiBaseUrl/);
+ assert.match(client, /getRequestApiBaseUrl\(\)/);
assert.match(client, /local FIP API/);
assert.match(config, /http:\/\/127\.0\.0\.1:8000/);
- assert.match(demoState, /Start Demo-Factory/);
- assert.match(demoState, /FIP Docker Compose stack/);
- assert.match(demoState, /NEXT_PUBLIC_API_BASE_URL/);
+ assert.match(demoState, /Integration details/);
+ assert.match(demoState, /Integration endpoint/);
assert.doesNotMatch(demoState, /Synthetic local scenario; not real plant data/);
assert.match(readme, /NEXT_PUBLIC_API_BASE_URL/);
});
-test("workbench state panels distinguish local demo data gaps from API failures", () => {
+test("workbench state panels distinguish operational data gaps from API failures", () => {
const demoState = readFileSync(join(root, "app/components/demo-state.tsx"), "utf8");
const overview = readFileSync(join(root, "app/page.tsx"), "utf8");
const detections = readFileSync(join(root, "app/detections/page.tsx"), "utf8");
@@ -423,23 +480,23 @@ test("workbench state panels distinguish local demo data gaps from API failures"
assert.match(demoState, /aria-busy="true"/);
assert.match(demoState, /MissingDataPanel/);
assert.match(demoState, /loading-panel/);
- assert.match(overview, /Start Demo-Factory/);
- assert.match(detections, /No Process Sentinel detections are available for the current external-source event store yet/);
- assert.match(detections, /curl http:\/\/localhost:8000\/health/);
+ assert.match(overview, /current operational state/);
+ assert.match(detections, /No Process Sentinel cases are available for the current operational state yet/);
+ assert.match(detections, /Verify the validation data source and service health/);
assert.match(detail, /Detection not found/);
assert.match(detail, /No evidence available/);
- assert.match(detail, /FIP Docker Compose stack/);
+ assert.match(detail, /manufacturing data service/);
assert.match(recommendations, /No recommendations returned/);
assert.match(recommendations, /No linked recommendation found/);
- assert.match(recommendations, /current external-source event store yet/);
+ assert.match(recommendations, /current operational state yet/);
assert.match(draft, /Draft not found/);
assert.match(draft, /No detection available for draft preview/);
- assert.match(draft, /Start Demo-Factory/);
+ assert.match(draft, /manufacturing data service/);
assert.match(styles, /missing-data-panel/);
assert.match(styles, /min-height: 260px/);
});
-test("workbench runtime copy points to external sources and Docker recovery", () => {
+test("workbench runtime copy points to operational sources and integration recovery", () => {
const files = [
"app/layout.tsx",
"app/page.tsx",
@@ -453,10 +510,11 @@ test("workbench runtime copy points to external sources and Docker recovery", ()
];
const combined = files.map((file) => readFileSync(join(root, file), "utf8")).join("\n");
- assert.match(combined, /Start Demo-Factory/);
- assert.match(combined, /FIP Docker Compose stack/);
- assert.match(combined, /The Workbench could not reach the local FIP API/);
- assert.match(combined, /advisory and human-reviewed/);
+ assert.match(combined, /manufacturing data service/);
+ assert.match(combined, /validation data source/);
+ assert.match(combined, /The Workbench could not reach the configured manufacturing data service/);
+ assert.match(combined, /advisory decision support/);
+ assert.match(combined, /human-reviewed RCA\/CAPA draft/);
assert.doesNotMatch(combined, new RegExp("simulator-" + "backed", "i"));
assert.doesNotMatch(combined, new RegExp("rerun make" + " demo", "i"));
assert.doesNotMatch(combined, new RegExp("make " + "demo-data", "i"));
@@ -465,6 +523,7 @@ test("workbench runtime copy points to external sources and Docker recovery", ()
test("accessibility baseline covers landmarks, focus, forms, badges, and timeline order", () => {
const layout = readFileSync(join(root, "app/layout.tsx"), "utf8");
+ const navigation = readFileSync(join(root, "app/components/operator-navigation.tsx"), "utf8");
const demoState = readFileSync(join(root, "app/components/demo-state.tsx"), "utf8");
const detail = readFileSync(join(root, "app/detections/[detectionId]/page.tsx"), "utf8");
const panel = readFileSync(
@@ -475,9 +534,9 @@ test("accessibility baseline covers landmarks, focus, forms, badges, and timelin
assert.match(layout, /className="skip-link"/);
assert.match(layout, / ContextQuestionRequest:
+ stripped = self.question.strip()
+ if not stripped:
+ msg = "question must not be empty"
+ raise ValueError(msg)
+ self.question = stripped
+ return self
+
+
+class ContextQuestionSource(BaseModel):
+ type: str = Field(min_length=1)
+ id: str = Field(min_length=1)
+ label: str = Field(min_length=1)
+ href: str = Field(min_length=1)
+
+
+class ContextQuestionResponse(BaseModel):
+ question: str
+ answer: str
+ confidence: ContextQuestionConfidence
+ sources: list[ContextQuestionSource]
+ suggested_questions: list[str] = Field(default_factory=list)
+
+
+class RuntimeContext(BaseModel):
+ health: dict[str, str]
+ connection_profiles: list[ProtocolConnectionProfile]
+ domain: DomainData
+ detections: list[Detection]
+ evidence: list[EvidenceItem]
+ recommendations: list[Recommendation]
+
+
+def answer_context_question(
+ request: ContextQuestionRequest,
+ context: RuntimeContext,
+) -> ContextQuestionResponse:
+ question_key = request.question.lower()
+
+ if _asks_about_health(question_key):
+ return _answer_health(request.question, context)
+ if _asks_why_detection_was_flagged(question_key):
+ return _answer_detection_evidence(request.question, context)
+ if _asks_about_recommendations(question_key):
+ return _answer_recommendations(request.question, context)
+ if _asks_about_detections(question_key):
+ return _answer_detections(request.question, context)
+ if _asks_about_current_context(question_key):
+ return _answer_current_context(request.question, context, question_key)
+ return _unsupported(request.question)
+
+
+def _answer_current_context(
+ question: str,
+ context: RuntimeContext,
+ question_key: str,
+) -> ContextQuestionResponse:
+ detection = _select_primary_detection(context.detections)
+ batch = _select_current_batch(context.domain)
+ asset = _select_current_asset(context.domain, detection)
+ area = _select_current_area(context.domain, batch, asset)
+ site = _select_current_site(context.domain, area, batch)
+ work_order_id = detection.related_work_order_id if detection is not None else None
+
+ answer = (
+ f"Current context is {site.name if site else 'an unknown site'}, "
+ f"{area.name if area else 'an unknown area'}, "
+ f"{asset.name if asset else 'an unlinked asset'}, "
+ f"batch {batch.batch_id if batch else 'unavailable'}, "
+ f"work order {work_order_id or 'unavailable'}, and product "
+ f"{batch.product_name if batch else 'unavailable'}."
+ )
+ confidence: ContextQuestionConfidence = "supported"
+ if any(term in question_key for term in ("operator", "supervisor", "shift")):
+ answer += (
+ " Operator, supervisor, and shift assignment are not present in the "
+ "current browser-safe context."
+ )
+ confidence = "partial"
+
+ sources: list[ContextQuestionSource] = []
+ if site is not None:
+ sources.append(
+ ContextQuestionSource(
+ type="site",
+ id=site.site_id,
+ label=site.name,
+ href="/",
+ )
+ )
+ if area is not None:
+ sources.append(
+ ContextQuestionSource(
+ type="area",
+ id=area.area_id,
+ label=area.name,
+ href="/",
+ )
+ )
+ if asset is not None:
+ sources.append(
+ ContextQuestionSource(
+ type="asset",
+ id=asset.equipment_id,
+ label=asset.name,
+ href="/tag-source-browser",
+ )
+ )
+ if batch is not None:
+ sources.append(
+ ContextQuestionSource(
+ type="batch",
+ id=batch.batch_id,
+ label=batch.batch_id,
+ href="/",
+ )
+ )
+ if work_order_id is not None and detection is not None:
+ sources.append(
+ ContextQuestionSource(
+ type="work_order",
+ id=work_order_id,
+ label=work_order_id,
+ href=f"/detections/{detection.detection_id}",
+ )
+ )
+ return ContextQuestionResponse(
+ question=question,
+ answer=answer,
+ confidence=confidence,
+ sources=sources,
+ )
+
+
+def _answer_detections(question: str, context: RuntimeContext) -> ContextQuestionResponse:
+ active_detections = _active_detections(context.detections)
+ primary = _select_primary_detection(context.detections)
+ if primary is None:
+ return ContextQuestionResponse(
+ question=question,
+ answer="There are no active Process Sentinel detections in the current runtime state.",
+ confidence="supported",
+ sources=[
+ ContextQuestionSource(
+ type="detection_list",
+ id="sentinel-detections",
+ label="Process Sentinel detections",
+ href="/detections",
+ )
+ ],
+ )
+
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ f"There are {len(active_detections)} active Process Sentinel detections. "
+ f"The highest-priority finding is {primary.summary} "
+ f"({primary.detection_id}) with {primary.severity} severity, "
+ f"{primary.status} status, and {round(primary.confidence * 100)}% confidence."
+ ),
+ confidence="supported",
+ sources=[_detection_source(primary)],
+ )
+
+
+def _answer_detection_evidence(question: str, context: RuntimeContext) -> ContextQuestionResponse:
+ primary = _select_primary_detection(context.detections)
+ if primary is None:
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ "No primary detection is available, so there is no evidence "
+ "summary to explain yet."
+ ),
+ confidence="partial",
+ sources=[],
+ )
+ evidence_items = [
+ item for item in context.evidence if item.detection_id == primary.detection_id
+ ]
+ if not evidence_items:
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ f"{primary.summary} is the primary detection, but no evidence items are "
+ "available in the current Sentinel state."
+ ),
+ confidence="partial",
+ sources=[_detection_source(primary)],
+ )
+
+ evidence_summary = "; ".join(item.description for item in evidence_items[:3])
+ return ContextQuestionResponse(
+ question=question,
+ answer=f"{primary.summary} was flagged because {evidence_summary}",
+ confidence="supported",
+ sources=[
+ _detection_source(primary),
+ *[
+ ContextQuestionSource(
+ type="evidence",
+ id=item.evidence_id,
+ label=item.title,
+ href=f"/detections/{primary.detection_id}",
+ )
+ for item in evidence_items[:3]
+ ],
+ ],
+ )
+
+
+def _answer_recommendations(question: str, context: RuntimeContext) -> ContextQuestionResponse:
+ pending = [
+ recommendation
+ for recommendation in context.recommendations
+ if recommendation.status in PENDING_RECOMMENDATION_STATUSES
+ ]
+ if not pending:
+ return ContextQuestionResponse(
+ question=question,
+ answer="There are no pending governed recommendations in the current runtime state.",
+ confidence="supported",
+ sources=[
+ ContextQuestionSource(
+ type="recommendation_list",
+ id="recommendations",
+ label="Recommendation review",
+ href="/recommendations",
+ )
+ ],
+ )
+
+ statuses = ", ".join(
+ f"{recommendation.recommendation_id}: {recommendation.status}"
+ for recommendation in pending[:3]
+ )
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ f"There are {len(pending)} pending governed recommendations. Current "
+ f"recommendation status: {statuses}."
+ ),
+ confidence="supported",
+ sources=[
+ ContextQuestionSource(
+ type="recommendation",
+ id=recommendation.recommendation_id,
+ label=recommendation.recommended_action,
+ href=f"/recommendations?detection_id={recommendation.detection_id}",
+ )
+ for recommendation in pending[:3]
+ ],
+ )
+
+
+def _answer_health(question: str, context: RuntimeContext) -> ContextQuestionResponse:
+ enabled_profiles = [
+ profile for profile in context.connection_profiles if profile.enabled
+ ]
+ disabled_profiles = [
+ profile for profile in context.connection_profiles if not profile.enabled
+ ]
+ health = context.health
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ f"The API reports {health.get('status', 'unknown')} health, "
+ f"{health.get('source_mode', 'unknown')} source mode, "
+ f"{health.get('storage_backend', 'unknown')} storage, and "
+ f"{health.get('connector_mode', 'unknown')} connector mode. "
+ f"There are {len(enabled_profiles)} enabled and {len(disabled_profiles)} "
+ "disabled connection profiles visible to the browser."
+ ),
+ confidence="supported",
+ sources=[
+ ContextQuestionSource(
+ type="health",
+ id="api-health",
+ label="API health",
+ href="/protocol-diagnostics",
+ ),
+ ContextQuestionSource(
+ type="connection_profiles",
+ id="connection-profiles",
+ label="Connection profiles",
+ href="/connections",
+ ),
+ ],
+ )
+
+
+def _unsupported(question: str) -> ContextQuestionResponse:
+ return ContextQuestionResponse(
+ question=question,
+ answer=(
+ "I can only answer deterministic questions about current factory context, "
+ "Process Sentinel detections, evidence, recommendations, and browser-safe "
+ "runtime health. Try one of the example questions below."
+ ),
+ confidence="unsupported",
+ sources=[],
+ suggested_questions=EXAMPLE_QUESTIONS,
+ )
+
+
+def _asks_about_current_context(question_key: str) -> bool:
+ return any(
+ term in question_key
+ for term in (
+ "site",
+ "area",
+ "line",
+ "asset",
+ "batch",
+ "work order",
+ "product",
+ "context",
+ "operator",
+ "supervisor",
+ "shift",
+ )
+ )
+
+
+def _asks_about_detections(question_key: str) -> bool:
+ return any(
+ term in question_key
+ for term in ("detection", "finding", "findings", "important", "priority", "count")
+ )
+
+
+def _asks_why_detection_was_flagged(question_key: str) -> bool:
+ return any(term in question_key for term in ("why", "flagged", "evidence"))
+
+
+def _asks_about_recommendations(question_key: str) -> bool:
+ return any(
+ term in question_key
+ for term in ("recommendation", "recommendations", "pending", "status")
+ )
+
+
+def _asks_about_health(question_key: str) -> bool:
+ return any(
+ term in question_key
+ for term in ("health", "api", "source", "connector", "connection", "profile", "storage")
+ )
+
+
+def _active_detections(detections: list[Detection]) -> list[Detection]:
+ return [item for item in detections if item.status in ACTIVE_DETECTION_STATUSES]
+
+
+def _select_primary_detection(detections: list[Detection]) -> Detection | None:
+ active_detections = _active_detections(detections)
+ if not active_detections:
+ return None
+ return sorted(
+ active_detections,
+ key=lambda item: (SEVERITY_RANK[item.severity], item.confidence),
+ reverse=True,
+ )[0]
+
+
+def _select_current_batch(domain: DomainData):
+ return next(
+ (batch for batch in domain.batches if batch.status in {"running", "held"}),
+ domain.batches[0] if domain.batches else None,
+ )
+
+
+def _select_current_asset(domain: DomainData, detection: Detection | None):
+ related_asset_id = (
+ detection.related_asset_ids[0] if detection and detection.related_asset_ids else None
+ )
+ return next(
+ (asset for asset in domain.equipment if asset.equipment_id == related_asset_id),
+ domain.equipment[0] if domain.equipment else None,
+ )
+
+
+def _select_current_area(domain: DomainData, batch, asset):
+ return next(
+ (
+ area
+ for area in domain.areas
+ if area.area_id in {getattr(asset, "area_id", None), getattr(batch, "area_id", None)}
+ ),
+ domain.areas[0] if domain.areas else None,
+ )
+
+
+def _select_current_site(domain: DomainData, area, batch):
+ return next(
+ (
+ site
+ for site in domain.sites
+ if site.site_id in {getattr(area, "site_id", None), getattr(batch, "site_id", None)}
+ ),
+ domain.sites[0] if domain.sites else None,
+ )
+
+
+def _detection_source(detection: Detection) -> ContextQuestionSource:
+ return ContextQuestionSource(
+ type="detection",
+ id=detection.detection_id,
+ label=detection.summary,
+ href=f"/detections/{detection.detection_id}",
+ )
diff --git a/services/api/factory_api/domain.py b/services/api/factory_api/domain.py
index 3557053..e7201cc 100644
--- a/services/api/factory_api/domain.py
+++ b/services/api/factory_api/domain.py
@@ -190,10 +190,10 @@ def build_demo_domain_data() -> DomainData:
sites=[
Site(
site_id="greenville_demo_site",
- name="Greenville Demo Site",
+ name="Greenville Manufacturing Site",
timezone="America/New_York",
description=(
- "External-source Greenville site context used for the manufacturer demo."
+ "Process quality monitoring and recommendation review workspace."
),
)
],
@@ -244,7 +244,7 @@ def build_demo_domain_data() -> DomainData:
batch_id="BATCH-DEMO-1007",
site_id="greenville_demo_site",
area_id="packaging_area",
- product_name="OFI Demo Beverage",
+ product_name="Beverage Line Product",
status="held",
started_at=started_at,
ended_at=None,
diff --git a/services/api/factory_api/main.py b/services/api/factory_api/main.py
index 00e80b7..af0a6d0 100644
--- a/services/api/factory_api/main.py
+++ b/services/api/factory_api/main.py
@@ -24,6 +24,11 @@
serialize_connection_profile_for_browser,
)
from factory_api.connection_tests import test_connection_profile_data
+from factory_api.context_questions import (
+ ContextQuestionRequest,
+ RuntimeContext,
+ answer_context_question,
+)
from factory_api.domain import DomainData, build_demo_domain_data
DEFAULT_CORS_ORIGINS = (
@@ -160,13 +165,18 @@ def connection_profile_store() -> ConnectionProfileStore:
def domain() -> DomainData:
return resolved_domain_data
- @app.get("/health")
- def health() -> dict:
+ def runtime_health() -> dict[str, str]:
return {
"status": "ok",
"source_mode": resolved_source_mode,
"storage_backend": resolved_storage_backend,
"connector_mode": resolved_connector_mode,
+ }
+
+ @app.get("/health")
+ def health() -> dict:
+ return {
+ **runtime_health(),
"simulator_backed": False,
"simulator_backed_migration_note": (
"Deprecated compatibility field. Use source_mode and connector_mode "
@@ -177,6 +187,21 @@ def health() -> dict:
"connection_profiles_store": str(resolved_connection_profiles_store),
}
+ @app.post("/context/questions")
+ def answer_context_question_endpoint(request: ContextQuestionRequest) -> dict:
+ response = answer_context_question(
+ request,
+ RuntimeContext(
+ health=runtime_health(),
+ connection_profiles=connection_profile_store().list_profiles(),
+ domain=domain(),
+ detections=sentinel_store().list_detections(),
+ evidence=sentinel_store().list_evidence(),
+ recommendations=sentinel_store().list_recommendations(),
+ ),
+ )
+ return response.model_dump(mode="json")
+
@app.get("/events")
def list_events(event_type: str | None = None) -> list[dict]:
events = event_store().list_events()
diff --git a/services/api/tests/test_api.py b/services/api/tests/test_api.py
index 60c1154..dd61e02 100644
--- a/services/api/tests/test_api.py
+++ b/services/api/tests/test_api.py
@@ -38,6 +38,156 @@ def test_health_endpoint(tmp_path: Path) -> None:
assert "Deprecated compatibility field" in health["simulator_backed_migration_note"]
+def test_context_question_endpoint_answers_supported_detection_question(
+ tmp_path: Path,
+) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ response = client.post(
+ "/context/questions",
+ json={"question": "What is the most important finding right now?"},
+ )
+
+ body = response.json()
+ assert response.status_code == 200
+ assert body["question"] == "What is the most important finding right now?"
+ assert body["confidence"] == "supported"
+ assert "highest-priority finding" in body["answer"]
+ assert "det_fill_weight_gradual_drift" in body["answer"]
+ assert body["sources"] == [
+ {
+ "type": "detection",
+ "id": "det_fill_weight_gradual_drift",
+ "label": "Fill weight is trending upward toward the upper quality limit.",
+ "href": "/detections/det_fill_weight_gradual_drift",
+ }
+ ]
+
+
+def test_context_question_endpoint_uses_evidence_for_why_question(
+ tmp_path: Path,
+) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ response = client.post(
+ "/context/questions",
+ json={"question": "Why was the primary detection flagged?"},
+ )
+
+ body = response.json()
+ assert response.status_code == 200
+ assert body["confidence"] == "supported"
+ assert "was flagged because" in body["answer"]
+ assert "Baseline average" in body["answer"]
+ assert [source["type"] for source in body["sources"]] == [
+ "detection",
+ "evidence",
+ "evidence",
+ ]
+ assert body["sources"][1]["href"] == "/detections/det_fill_weight_gradual_drift"
+
+
+def test_context_question_endpoint_returns_partial_context_when_field_missing(
+ tmp_path: Path,
+) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ response = client.post(
+ "/context/questions",
+ json={"question": "What is the current batch and shift supervisor?"},
+ )
+
+ body = response.json()
+ assert response.status_code == 200
+ assert body["confidence"] == "partial"
+ assert "BATCH-DEMO-1007" in body["answer"]
+ assert "shift assignment" in body["answer"]
+ assert {source["type"] for source in body["sources"]} >= {
+ "site",
+ "area",
+ "asset",
+ "batch",
+ "work_order",
+ }
+
+
+def test_context_question_endpoint_answers_recommendation_and_health_questions(
+ tmp_path: Path,
+) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ recommendation_response = client.post(
+ "/context/questions",
+ json={"question": "How many recommendations are pending review?"},
+ )
+ health_response = client.post(
+ "/context/questions",
+ json={"question": "What is the API and source health?"},
+ )
+
+ recommendation = recommendation_response.json()
+ health = health_response.json()
+ assert recommendation_response.status_code == 200
+ assert recommendation["confidence"] == "supported"
+ assert "1 pending governed recommendations" in recommendation["answer"]
+ assert recommendation["sources"][0]["type"] == "recommendation"
+ assert recommendation["sources"][0]["href"] == (
+ "/recommendations?detection_id=det_fill_weight_gradual_drift"
+ )
+ assert health_response.status_code == 200
+ assert health["confidence"] == "supported"
+ assert "external_demo_factory source mode" in health["answer"]
+ assert [source["href"] for source in health["sources"]] == [
+ "/protocol-diagnostics",
+ "/connections",
+ ]
+
+
+def test_context_question_endpoint_fails_safely_for_unsupported_question(
+ tmp_path: Path,
+) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ response = client.post(
+ "/context/questions",
+ json={"question": "Write a CAPA and close the deviation automatically."},
+ )
+
+ body = response.json()
+ assert response.status_code == 200
+ assert body["confidence"] == "unsupported"
+ assert "deterministic questions" in body["answer"]
+ assert body["sources"] == []
+ assert "What is the most important finding right now?" in body["suggested_questions"]
+
+
+def test_context_question_endpoint_rejects_empty_question(tmp_path: Path) -> None:
+ events_store_path, state_dir = seed_state(tmp_path)
+ client = TestClient(
+ create_app(events_store_path=events_store_path, sentinel_state_dir=state_dir)
+ )
+
+ response = client.post("/context/questions", json={"question": " "})
+
+ assert response.status_code == 422
+ assert response.json()["error"]["code"] == "request_validation_failed"
+
+
def test_event_and_detection_query_endpoints(tmp_path: Path) -> None:
events_store_path, state_dir = seed_state(tmp_path)
client = TestClient(
@@ -71,8 +221,7 @@ def test_demo_detection_detail_endpoint_exposes_expected_lookup_fields(
]
assert detail_response.json()["detection_id"] == "det_fill_weight_gradual_drift"
assert detail_response.json()["summary"] == (
- "Advisory: fill weight is trending upward, which may move the affected "
- "work order toward the upper quality limit."
+ "Fill weight is trending upward toward the upper quality limit."
)
assert "root cause" not in detail_response.json()["summary"].lower()
assert "caused by" not in detail_response.json()["summary"].lower()
@@ -169,7 +318,7 @@ def test_domain_model_query_endpoints(tmp_path: Path) -> None:
investigation_response = client.get("/investigations/inv_fill_weight_drift_WO_DEMO_1007")
assert site_response.status_code == 200
- assert site_response.json()["name"] == "Greenville Demo Site"
+ assert site_response.json()["name"] == "Greenville Manufacturing Site"
assert signal_response.status_code == 200
assert signal_response.json()["equipment_id"] == "filler_f_201"
assert quality_response.status_code == 200
@@ -234,7 +383,7 @@ def test_demo_recommendation_endpoints_expose_review_fields(tmp_path: Path) -> N
assert recommendation["detection_id"] == "det_fill_weight_gradual_drift"
assert recommendation["status"] == "needs_review"
assert recommendation["recommended_action"] == (
- "Inspect filler calibration and increase quality checks for the affected demo work "
+ "Inspect filler calibration and increase quality checks for the affected work "
"order."
)
assert recommendation["rationale"] == (
diff --git a/services/api/tests/test_domain.py b/services/api/tests/test_domain.py
index 0f5753e..6867112 100644
--- a/services/api/tests/test_domain.py
+++ b/services/api/tests/test_domain.py
@@ -17,7 +17,7 @@ def test_demo_domain_links_process_signals_to_quality_and_investigation() -> Non
investigation = domain.get_investigation_detail("inv_fill_weight_drift_WO_DEMO_1007")
assert site is not None
- assert site.name == "Greenville Demo Site"
+ assert site.name == "Greenville Manufacturing Site"
assert area is not None
assert area.name == "Packaging Area"
assert filler is not None
diff --git a/services/process-sentinel/process_sentinel/rules.py b/services/process-sentinel/process_sentinel/rules.py
index ccc848c..8443d3f 100644
--- a/services/process-sentinel/process_sentinel/rules.py
+++ b/services/process-sentinel/process_sentinel/rules.py
@@ -67,8 +67,7 @@ def _detect_gradual_fill_weight_drift(
time_window_start=baseline[0].timestamp,
time_window_end=recent[-1].timestamp,
summary=(
- "Advisory: fill weight is trending upward, which may move the affected "
- "work order toward the upper quality limit."
+ "Fill weight is trending upward toward the upper quality limit."
),
confidence=min(0.95, 0.55 + delta / 10),
related_work_order_id=recent[-1].context.work_order_id,
@@ -176,11 +175,11 @@ def _recommendation_for_detection(
detection: Detection, evidence_items: Sequence[EvidenceItem]
) -> Recommendation:
if detection.severity == "high":
- action = "Inspect filler operation and hold affected demo work order for quality review."
+ action = "Inspect filler operation and hold the affected work order for quality review."
rationale = "A process excursion can affect product quality and requires human review."
else:
action = (
- "Inspect filler calibration and increase quality checks for the affected demo work "
+ "Inspect filler calibration and increase quality checks for the affected work "
"order."
)
rationale = "The trend is moving toward the quality limit before confirmed broad failure."
diff --git a/services/process-sentinel/tests/test_rules.py b/services/process-sentinel/tests/test_rules.py
index 2ddd14f..62b3228 100644
--- a/services/process-sentinel/tests/test_rules.py
+++ b/services/process-sentinel/tests/test_rules.py
@@ -89,8 +89,7 @@ def test_fill_weight_drift_demo_supports_detection_recommendation_and_rca_draft(
assert [item.detection_type for item in result.detections] == ["quality_drift"]
assert detection.detection_id == "det_fill_weight_gradual_drift"
assert detection.summary == (
- "Advisory: fill weight is trending upward, which may move the affected "
- "work order toward the upper quality limit."
+ "Fill weight is trending upward toward the upper quality limit."
)
assert "root cause" not in detection.summary.lower()
assert "caused by" not in detection.summary.lower()
diff --git a/services/simulator/tests/test_connection_management_epic_readiness.py b/services/simulator/tests/test_connection_management_epic_readiness.py
index 76e1d30..96bbaf9 100644
--- a/services/simulator/tests/test_connection_management_epic_readiness.py
+++ b/services/simulator/tests/test_connection_management_epic_readiness.py
@@ -71,6 +71,8 @@ def test_issue_206_test_connection_results_are_read_only_structured_and_redacted
def test_issue_206_operator_console_includes_protocol_and_sentinel_workflows() -> None:
layout = _content("apps/web/app/layout.tsx")
+ navigation = _content("apps/web/app/components/operator-navigation.tsx")
+ shell = f"{layout}\n{navigation}"
connections = _content("apps/web/app/connections/connections-workspace.tsx")
diagnostics = _content(
"apps/web/app/protocol-diagnostics/protocol-diagnostics-workspace.tsx"
@@ -79,17 +81,25 @@ def test_issue_206_operator_console_includes_protocol_and_sentinel_workflows() -
for expected in [
"operator-sidebar",
- "Workbench status strip",
+ "Global operations toolbar",
+ "Configure Connections",
+ ]:
+ assert expected in layout
+
+ for expected in [
"Sentinel workflows",
"Protocol operations",
'href: "/connections"',
'href: "/protocol-diagnostics"',
'href: "/tag-source-browser"',
- "Read-only diagnostics",
- "Writeback",
- "Disabled",
+ 'href: "/process-sentinel"',
]:
- assert expected in layout
+ assert expected in shell
+
+ assert "Workbench status strip" not in layout
+ assert "Data freshness" not in layout
+ assert "Historian" not in layout
+ assert "sidebar-config-link" not in layout
assert "OPC-UA controls" in connections
assert "MQTT controls" in connections
diff --git a/services/simulator/tests/test_docker_compose_runtime_docs.py b/services/simulator/tests/test_docker_compose_runtime_docs.py
index 5e25667..809e133 100644
--- a/services/simulator/tests/test_docker_compose_runtime_docs.py
+++ b/services/simulator/tests/test_docker_compose_runtime_docs.py
@@ -106,6 +106,8 @@ def test_docker_compose_runtime_defines_fip_services_without_simulator() -> None
"${FIP_WEB_PORT:-3000}:3000",
"FIP_PUBLIC_API_URL",
"FIP_API_URL: http://api:8000",
+ "http://localhost:8000",
+ "http://api:8000",
"FACTORY_CONNECTION_PROFILES_STORE",
"DEMO_FACTORY_HOST",
"DEMO_FACTORY_OPCUA_ENDPOINT",
@@ -134,6 +136,9 @@ def test_docker_compose_runtime_defines_fip_services_without_simulator() -> None
]:
assert service in runtime_doc
assert "It does not start an in-repo simulator service." in runtime_doc
+ assert "server-rendered\nNext.js requests" in runtime_doc
+ assert "`web` container use `FIP_API_URL`" in runtime_doc
+ assert "`http://localhost:8000` points\nback at the `web` container" in runtime_doc
def test_makefile_includes_compose_wrappers() -> None: