-
{overview.ok ? overview.context.siteName : "Operations Workbench"}
{overview.ok
diff --git a/apps/web/app/protocol-diagnostics/loading.tsx b/apps/web/app/protocol-diagnostics/loading.tsx
new file mode 100644
index 0000000..5388d4a
--- /dev/null
+++ b/apps/web/app/protocol-diagnostics/loading.tsx
@@ -0,0 +1,11 @@
+export default function ProtocolDiagnosticsLoading() {
+ return (
+
+ Protocol Operations
+ Protocol Diagnostics
+
+ Loading read-only protocol diagnostics from the Factory Intelligence API.
+
+
+ );
+}
diff --git a/apps/web/app/protocol-diagnostics/page.tsx b/apps/web/app/protocol-diagnostics/page.tsx
new file mode 100644
index 0000000..272dba3
--- /dev/null
+++ b/apps/web/app/protocol-diagnostics/page.tsx
@@ -0,0 +1,78 @@
+import { ApiErrorPanel } from "../components/demo-state";
+import {
+ type ConnectionTestResult,
+ type ProtocolConnectionProfile,
+ formatApiError,
+ workbenchApi,
+} from "../../lib/api-client";
+import { ProtocolDiagnosticsWorkspace } from "./protocol-diagnostics-workspace";
+
+export const dynamic = "force-dynamic";
+
+type LoadResult =
+ | { data: T; error: null; ok: true }
+ | { data: null; error: string; ok: false };
+
+type ConnectionTestLoadResult =
+ | { connectionId: string; result: ConnectionTestResult; error: null; ok: true }
+ | { connectionId: string; result: null; error: string; ok: false };
+
+export default async function ProtocolDiagnosticsPage() {
+ const [healthResult, profilesResult, signalsResult] = await Promise.all([
+ loadData(() => workbenchApi.getHealth()),
+ loadData(() => workbenchApi.listConnectionProfiles()),
+ loadData(() => workbenchApi.listProcessSignals()),
+ ]);
+
+ const profiles = profilesResult.data ?? [];
+ const testResults = profilesResult.ok
+ ? await Promise.all(
+ profiles.map(async (profile) => loadConnectionTest(profile.id)),
+ )
+ : [];
+ const pageError =
+ healthResult.error ?? profilesResult.error ?? signalsResult.error ?? null;
+
+ return (
+
+ {pageError !== null ? : null}
+
+
+ );
+}
+
+async function loadData(loader: () => Promise): Promise> {
+ try {
+ return { data: await loader(), error: null, ok: true };
+ } catch (error) {
+ return { data: null, error: formatApiError(error), ok: false };
+ }
+}
+
+async function loadConnectionTest(
+ connectionId: string,
+): Promise {
+ try {
+ return {
+ connectionId,
+ error: null,
+ ok: true,
+ result: await workbenchApi.testConnectionProfile(connectionId),
+ };
+ } catch (error) {
+ return {
+ connectionId,
+ error: formatApiError(error),
+ ok: false,
+ result: null,
+ };
+ }
+}
diff --git a/apps/web/app/protocol-diagnostics/protocol-diagnostics-workspace.tsx b/apps/web/app/protocol-diagnostics/protocol-diagnostics-workspace.tsx
new file mode 100644
index 0000000..3bebc16
--- /dev/null
+++ b/apps/web/app/protocol-diagnostics/protocol-diagnostics-workspace.tsx
@@ -0,0 +1,494 @@
+"use client";
+
+import { useMemo, useState } from "react";
+
+import { StatusBadge } from "../components/demo-state";
+import {
+ type ConnectionTestResult,
+ type HealthResponse,
+ type ProcessSignal,
+ type Protocol,
+ type ProtocolConnectionProfile,
+} from "../../lib/api-client";
+
+type ConnectionTestLoadResult =
+ | { connectionId: string; result: ConnectionTestResult; error: null; ok: true }
+ | { connectionId: string; result: null; error: string; ok: false };
+
+type ProtocolDiagnosticsWorkspaceProps = {
+ health: HealthResponse | null;
+ healthError: string | null;
+ processSignals: ProcessSignal[];
+ processSignalsError: string | null;
+ profiles: ProtocolConnectionProfile[];
+ profilesError: string | null;
+ testResults: ConnectionTestLoadResult[];
+};
+
+type DiagnosticsCard = {
+ detail: string;
+ label: string;
+ meta: string;
+ status: string;
+ tone: "danger" | "draft" | "neutral" | "success" | "warning";
+};
+
+type MappingRow = {
+ connectionId: string;
+ connectionName: string;
+ fipSignalName: string;
+ mappingReference: string;
+ protocol: Protocol;
+ sourceReference: string;
+ unit: string;
+};
+
+const protocols: Protocol[] = ["opcua", "mqtt", "bacnet"];
+
+const demoFactoryTroubleshootingCommands = [
+ "cd ~/Documents/Open\\ Factory\\ Initiative/Demo-Factory",
+ "docker compose ps",
+ "python -m pytest tests/test_protocol_services.py",
+ "npm run build",
+];
+
+export function ProtocolDiagnosticsWorkspace({
+ health,
+ healthError,
+ processSignals,
+ processSignalsError,
+ profiles,
+ profilesError,
+ testResults,
+}: ProtocolDiagnosticsWorkspaceProps) {
+ const [query, setQuery] = useState("");
+ const testResultByConnection = useMemo(
+ () => indexConnectionTests(testResults),
+ [testResults],
+ );
+ const mappingRows = useMemo(
+ () => buildMappingRows(profiles, processSignals),
+ [processSignals, profiles],
+ );
+ const visibleRows = useMemo(
+ () => filterMappingRows(mappingRows, query),
+ [mappingRows, query],
+ );
+ const diagnosticsCards = useMemo(
+ () =>
+ buildDiagnosticsCards({
+ health,
+ healthError,
+ processSignals,
+ processSignalsError,
+ profiles,
+ profilesError,
+ testResultByConnection,
+ }),
+ [
+ health,
+ healthError,
+ processSignals,
+ processSignalsError,
+ profiles,
+ profilesError,
+ testResultByConnection,
+ ],
+ );
+
+ return (
+
+
+
+
+ {diagnosticsCards.map((card) => (
+
+
+
{card.label}
+
+
+ {card.detail}
+ {card.meta}
+
+ ))}
+
+
+
+
+
+ Configured connection status
+
Connection Diagnostics
+
+
+
+
+
+ | Connection |
+ Protocol |
+ Configured status |
+ Last test result |
+ Last checked |
+ Error or next step |
+
+
+
+ {profiles.length === 0 ? (
+
+ |
+ No configured connections were returned by the FIP API.
+ |
+
+ ) : (
+ profiles.map((profile) => {
+ const testLoad = testResultByConnection.get(profile.id);
+ const result = testLoad?.result ?? null;
+ return (
+
+ |
+ {profile.name}
+ {profile.endpoint}
+ |
+ {formatProtocol(profile.protocol)} |
+
+
+ |
+
+ {result !== null ? (
+
+ ) : (
+
+ )}
+ |
+ {result ? formatDateTime(result.checked_at) : "Not checked"} |
+ {connectionMessage(testLoad, result)} |
+
+ );
+ })
+ )}
+
+
+
+
+
+
+
+ Protocol/tag mapping
+
Source Mapping Table
+
+
+
+
+
+
+ | Source/tag |
+ Protocol |
+ Connection |
+ Mapping reference |
+ FIP signal |
+ Unit |
+
+
+
+ {visibleRows.length === 0 ? (
+
+ |
+ {mappingRows.length === 0
+ ? "No protocol source mappings are available yet."
+ : "No mappings match the current search."}
+ |
+
+ ) : (
+ visibleRows.map((row) => (
+
+ | {row.sourceReference} |
+ {formatProtocol(row.protocol)} |
+ {row.connectionName} |
+ {row.mappingReference} |
+ {row.fipSignalName} |
+ {row.unit} |
+
+ ))
+ )}
+
+
+
+
+
+ Local Demo-Factory validation next steps
+
+ Use these commands when comparing FIP diagnostics against the local
+ Demo-Factory protocol services. This page reads FIP API data only; it
+ does not inspect Demo-Factory runtime state directly.
+
+
+ {demoFactoryTroubleshootingCommands.map((command) => (
+ -
+
{command}
+
+ ))}
+
+
+