feat: auto-detect OEM cameras from printer-reported stream URLs

Introduce CameraStreamCoordinator to detect and register OEM camera
streams from printer-reported URLs, alongside the broader go2rtc
migration, Discord webhook notifications, and E2E test framework.

- Add CameraStreamCoordinator service for OEM stream URL detection
- Add printerSettingsDefaults utility for consistent per-printer init
- Update all backends to expose printer-reported OEM stream URL
- Refactor camera-utils and camera routes to use coordinator-driven
  stream resolution
- Add test coverage for coordinator, camera-utils, and defaults
- go2rtc-based camera streaming replacing legacy proxy/RTSP stack
- Discord webhook notifications with multi-printer status support
- Playwright E2E testing framework (fixture + emulator-backed)
- Backend bundling via build-backend.ts for pkg-compatible output
- Bump version to 1.1.0

Author: GhostTypes

CHANGELOG.md

@@ -7,8 +7,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [1.1.0] - 2026-03-08
+
 ### Added
 
+- `CameraStreamCoordinator` service to detect and register OEM camera streams from printer-reported stream URLs without manual configuration
+- `printerSettingsDefaults` utility for consistent per-printer settings initialization across backends
+- Test coverage for `camera-utils`, `printerSettingsDefaults`, and OEM stream coordinator behavior
 - Playwright E2E testing framework with dual configuration:
   - Fixture-based E2E tests (`e2e/`) for fast WebUI validation with a stub HTTP+WebSocket server
   - Emulator-backed E2E tests (`e2e-emulator/`) for full lifecycle testing with `flashforge-emulator-v2` printer emulator
@@ -40,6 +45,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
 
+- Camera configuration resolution now uses `CameraStreamCoordinator` for OEM stream URL detection before falling back to per-printer overrides
+- All printer backends updated to expose the printer-reported OEM stream URL for coordinator use
 - `type-check` script now runs both `type-check:app` and `type-check:e2e` for full TypeScript validation
 - Camera streaming migrated from the legacy proxy/RTSP stack to go2rtc-managed per-context streams
 - Frontend camera playback now uses the bundled `video-rtc` player instead of the previous streaming path
@@ -152,7 +159,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Optional password authentication
 - Configuration persistence in `data/config.json`
 
-[Unreleased]: https://github.com/Parallel-7/FlashForgeWebUI/compare/v1.0.2...HEAD
+[Unreleased]: https://github.com/Parallel-7/FlashForgeWebUI/compare/v1.1.0...HEAD
+[1.1.0]: https://github.com/Parallel-7/FlashForgeWebUI/compare/v1.0.2...v1.1.0
 [1.0.2]: https://github.com/Parallel-7/FlashForgeWebUI/compare/v1.0.1...v1.0.2
 [1.0.1]: https://github.com/Parallel-7/FlashForgeWebUI/compare/v1.0.0...v1.0.1
 [1.0.0]: https://github.com/Parallel-7/FlashForgeWebUI/releases/tag/v1.0.0

data/printer_details.json

@@ -9,11 +9,11 @@
       "ClientType": "new",
       "printerModel": "Flashforge AD5X",
       "modelType": "ad5x",
-      "customCameraEnabled": true,
+      "customCameraEnabled": false,
       "customCameraUrl": "",
       "customLedsEnabled": false,
       "forceLegacyMode": false,
       "lastConnected": "2025-11-23T02:52:58.265Z"
     }
   }
-}
+}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "flashforge-webui",
-  "version": "1.0.2",
+  "version": "1.1.0",
   "description": "Standalone WebUI for FlashForge 3D Printers",
   "main": "dist/index.js",
   "bin": "dist/index.js",

src/index.ts

@@ -26,12 +26,14 @@ import { getMultiContextPrintStateMonitor } from './services/MultiContextPrintSt
 import { getMultiContextSpoolmanTracker } from './services/MultiContextSpoolmanTracker';
 import { getMultiContextTemperatureMonitor } from './services/MultiContextTemperatureMonitor';
 import { getSavedPrinterService } from './services/SavedPrinterService';
+import { resolveAndEnsureCameraStream } from './services/CameraStreamCoordinator';
 import { initializeSpoolmanIntegrationService } from './services/SpoolmanIntegrationService';
 import type { PollingData } from './types/polling';
 import type { PrinterClientType, PrinterDetails } from './types/printer';
-import { getCameraUserConfig, resolveCameraConfig } from './utils/camera-utils';
+import { getCameraUserConfig } from './utils/camera-utils';
 import type { HeadlessConfig, PrinterSpec } from './utils/HeadlessArguments';
 import { parseHeadlessArguments, validateHeadlessConfig } from './utils/HeadlessArguments';
+import { applyPerPrinterDefaults } from './utils/printerSettingsDefaults';
 import { createHardDeadline } from './utils/ShutdownTimeout';
 import { initializeDataDirectory } from './utils/setup';
 import { getWebUIManager } from './webui/server/WebUIManager';
@@ -104,7 +106,7 @@ async function connectLastUsed(): Promise<string[]> {
   );
 
   // Convert StoredPrinterDetails to PrinterDetails
-  const printerDetails: PrinterDetails = {
+  const printerDetails: PrinterDetails = applyPerPrinterDefaults({
     Name: lastUsedPrinter.Name,
     IPAddress: lastUsedPrinter.IPAddress,
     SerialNumber: lastUsedPrinter.SerialNumber,
@@ -116,7 +118,7 @@ async function connectLastUsed(): Promise<string[]> {
     customCameraUrl: lastUsedPrinter.customCameraUrl,
     customLedsEnabled: lastUsedPrinter.customLedsEnabled,
     forceLegacyMode: lastUsedPrinter.forceLegacyMode,
-  };
+  });
 
   const results = await connectionManager.connectHeadlessFromSaved([printerDetails]);
 
@@ -137,7 +139,7 @@ async function connectAllSaved(): Promise<string[]> {
   console.log(`[Connection] Connecting to ${savedPrinters.length} saved printer(s)...`);
 
   // Convert StoredPrinterDetails to PrinterDetails
-  const printerDetailsList: PrinterDetails[] = savedPrinters.map((saved) => ({
+  const printerDetailsList: PrinterDetails[] = savedPrinters.map((saved) => applyPerPrinterDefaults({
     Name: saved.Name,
     IPAddress: saved.IPAddress,
     SerialNumber: saved.SerialNumber,
@@ -261,45 +263,24 @@ async function reconcileCameraStream(contextId: string): Promise<void> {
       return;
     }
 
-    const features = backendManager.getFeatures(contextId);
-    if (!features) {
+    const backend = backendManager.getBackendForContext(contextId);
+    if (!backend) {
       await go2rtcService.removeStream(contextId);
       return;
     }
 
-    const cameraConfig = resolveCameraConfig({
+    const ensuredStream = await resolveAndEnsureCameraStream({
+      contextId,
       printerIpAddress: context.printerDetails.IPAddress,
-      printerFeatures: features,
+      printerFeatures: backend.getBackendStatus().features,
       userConfig: getCameraUserConfig(contextId),
+      go2rtcService,
     });
 
-    if (
-      !cameraConfig.isAvailable ||
-      !cameraConfig.streamUrl ||
-      !cameraConfig.streamType ||
-      (cameraConfig.sourceType !== 'builtin' && cameraConfig.sourceType !== 'custom')
-    ) {
-      await go2rtcService.removeStream(contextId);
+    if (!ensuredStream) {
       return;
     }
 
-    if (
-      go2rtcService.hasMatchingStream(
-        contextId,
-        cameraConfig.streamUrl,
-        cameraConfig.sourceType,
-        cameraConfig.streamType
-      )
-    ) {
-      return;
-    }
-
-    await go2rtcService.addStream(
-      contextId,
-      cameraConfig.streamUrl,
-      cameraConfig.sourceType,
-      cameraConfig.streamType
-    );
     console.log(`[Camera] Stream ready for context: ${contextId}`);
   } catch (error) {
     console.error(`[Camera] Failed to reconcile stream for context ${contextId}:`, error);
@@ -581,6 +562,21 @@ async function main(): Promise<void> {
     });
     console.log('[Events] Context-updated hook configured');
 
+    connectionManager.on('feature-updated', (event: { contextId?: string; changedKeys?: readonly string[] }) => {
+      const contextId = event.contextId;
+      if (!contextId) {
+        return;
+      }
+
+      const changedKeys = event.changedKeys || [];
+      if (!changedKeys.includes('oemCameraStreamUrl')) {
+        return;
+      }
+
+      void reconcileCameraStream(contextId);
+    });
+    console.log('[Events] Feature-updated hook configured');
+
     connectionManager.on('pre-disconnect', (contextId: string) => {
       void go2rtcService.removeStream(contextId);
     });

src/managers/ConnectionFlowManager.ts

@@ -50,6 +50,7 @@ import {
   getDefaultCheckCode,
   shouldPromptForCheckCode,
 } from '../utils/PrinterUtils';
+import { applyPerPrinterDefaults } from '../utils/printerSettingsDefaults';
 import { TimeoutError, withTimeout } from '../utils/ShutdownTimeout';
 import { IPAddressSchema } from '../utils/validation.utils';
 import { getLoadingManager } from './LoadingManager';
@@ -687,7 +688,7 @@ export class ConnectionFlowManager extends EventEmitter {
         forceLegacyMode: existingPrinter?.forceLegacyMode,
       });
 
-      const printerDetails: PrinterDetails = {
+      const printerDetails: PrinterDetails = applyPerPrinterDefaults({
         Name: formatPrinterName(printerName, serialNumber),
         IPAddress: discoveredPrinter.ipAddress,
         SerialNumber: serialNumber,
@@ -703,7 +704,7 @@ export class ConnectionFlowManager extends EventEmitter {
         customLedsEnabled: existingPrinter?.customLedsEnabled ?? false,
         forceLegacyMode,
         activeSpoolData: existingPrinter?.activeSpoolData ?? null,
-      };
+      });
 
       console.log('[ConnectionFlow] Final printer details to save:', printerDetails);
 
@@ -918,21 +919,10 @@ export class ConnectionFlowManager extends EventEmitter {
 
     try {
       // Ensure per-printer settings have defaults if not set
-      const detailsWithDefaults: PrinterDetails = {
-        ...details,
-        customCameraEnabled: details.customCameraEnabled ?? false,
-        customCameraUrl: details.customCameraUrl ?? '',
-        customLedsEnabled: details.customLedsEnabled ?? false,
-        forceLegacyMode: details.forceLegacyMode ?? false,
-      };
+      const detailsWithDefaults: PrinterDetails = applyPerPrinterDefaults(details);
 
       // If we added defaults, save them back to printer_details.json
-      if (
-        details.customCameraEnabled === undefined ||
-        details.customCameraUrl === undefined ||
-        details.customLedsEnabled === undefined ||
-        details.forceLegacyMode === undefined
-      ) {
+      if (JSON.stringify(detailsWithDefaults) !== JSON.stringify(details)) {
         await this.savedPrinterService.savePrinter(detailsWithDefaults);
         console.log(`Initialized default per-printer settings for ${detailsWithDefaults.Name}`);
       }
@@ -1293,7 +1283,7 @@ export class ConnectionFlowManager extends EventEmitter {
         }
 
         // Save printer details
-        const printerDetails: PrinterDetails = {
+        const printerDetails: PrinterDetails = applyPerPrinterDefaults({
           Name: formatPrinterName(printerName, serialNumber),
           IPAddress: spec.ip,
           SerialNumber: serialNumber,
@@ -1308,7 +1298,7 @@ export class ConnectionFlowManager extends EventEmitter {
           customCameraUrl: existingPrinter?.customCameraUrl ?? '',
           customLedsEnabled: existingPrinter?.customLedsEnabled ?? false,
           forceLegacyMode,
-        };
+        });
 
         await this.savedPrinterService.savePrinter(printerDetails);
         await this.savedPrinterService.updateLastConnected(serialNumber);

src/managers/PrinterDetailsManager.ts

@@ -25,6 +25,7 @@ import type {
   ValidatedPrinterDetails,
 } from '../types/printer';
 import { detectPrinterModelType } from '../utils/PrinterUtils';
+import { normalizeCustomCameraSettings } from '../utils/printerSettingsDefaults';
 import { getDataPath } from '../utils/setup';
 
 /**
@@ -74,6 +75,11 @@ export class PrinterDetailsManager {
    * Remove unsupported per-printer keys while preserving current behavior.
    */
   private sanitizePrinterDetails(details: PrinterDetails): PrinterDetails {
+    const normalizedCameraSettings = normalizeCustomCameraSettings({
+      customCameraEnabled: details.customCameraEnabled,
+      customCameraUrl: details.customCameraUrl,
+    });
+
     return {
       Name: details.Name,
       IPAddress: details.IPAddress,
@@ -84,11 +90,11 @@ export class PrinterDetailsManager {
       ...(details.modelType ? { modelType: details.modelType } : {}),
       ...(details.commandPort !== undefined ? { commandPort: details.commandPort } : {}),
       ...(details.httpPort !== undefined ? { httpPort: details.httpPort } : {}),
-      ...(details.customCameraEnabled !== undefined
-        ? { customCameraEnabled: details.customCameraEnabled }
+      ...(normalizedCameraSettings.customCameraEnabled !== undefined
+        ? { customCameraEnabled: normalizedCameraSettings.customCameraEnabled }
         : {}),
-      ...(details.customCameraUrl !== undefined
-        ? { customCameraUrl: details.customCameraUrl }
+      ...(normalizedCameraSettings.customCameraUrl !== undefined
+        ? { customCameraUrl: normalizedCameraSettings.customCameraUrl }
         : {}),
       ...(details.customLedsEnabled !== undefined
         ? { customLedsEnabled: details.customLedsEnabled }
@@ -307,8 +313,9 @@ export class PrinterDetailsManager {
     // Ensure modelType is set if missing
     const modelType = oldData.modelType || detectPrinterModelType(oldData.printerModel);
 
+    const normalizedOldData = this.sanitizePrinterDetails(oldData);
     const storedDetails: StoredPrinterDetails = {
-      ...oldData,
+      ...normalizedOldData,
       modelType,
       lastConnected: new Date().toISOString(),
     };

src/printer-backends/AD5XBackend.ts

@@ -7,7 +7,7 @@
  * - Multi-color printing support with material mapping
  * - AD5X-specific job operations (upload 3MF with material mappings)
  * - Material station status monitoring (slot contents, active slot, heating status)
- * - No built-in camera (custom camera URL supported)
+ * - OEM camera auto-detection when the printer reports a stream URL
  * - Custom LED control via G-code (when enabled)
  * - No built-in filtration control
  *
@@ -47,7 +47,7 @@ export class AD5XBackend extends DualAPIBackend {
   protected getChildBaseFeatures(): PrinterFeatureSet {
     return {
       camera: {
-        builtin: false, // AD5X doesn't have built-in camera
+        oemStreamUrl: '',
         customUrl: null,
         customEnabled: false,
       },
@@ -124,6 +124,8 @@ export class AD5XBackend extends DualAPIBackend {
    * Override from DualAPIBackend
    */
   protected async processMachineInfo(_machineInfo: unknown): Promise<void> {
+    await super.processMachineInfo(_machineInfo);
+
     // Store machine info for material station data extraction with type validation
     if (isAD5XMachineInfo(_machineInfo)) {
       this.lastMachineInfo = _machineInfo;

src/printer-backends/Adventurer5MBackend.ts

@@ -3,7 +3,7 @@
  *
  * Provides backend functionality specific to the Adventurer 5M standard model:
  * - Dual API support (FiveMClient + FlashForgeClient)
- * - No built-in camera (custom camera URL supported)
+ * - OEM camera auto-detection when the printer reports a stream URL
  * - LED control via G-code (auto-detected from product endpoint)
  * - No filtration control (5M standard lacks this feature)
  * - Full job management capabilities (local/recent jobs, upload, start/pause/resume/cancel)
@@ -15,7 +15,7 @@
  *
  * This backend extends DualAPIBackend to leverage common dual-API functionality while
  * defining model-specific features. The main difference from the Pro model is the lack
- * of built-in camera and filtration control features.
+ * of factory camera and filtration control features.
  */
 
 import type { MaterialStationStatus, PrinterFeatureSet } from '../types/printer-backend';
@@ -33,7 +33,7 @@ export class Adventurer5MBackend extends DualAPIBackend {
   protected getChildBaseFeatures(): PrinterFeatureSet {
     return {
       camera: {
-        builtin: false,
+        oemStreamUrl: '',
         customUrl: null,
         customEnabled: false,
       },

src/printer-backends/Adventurer5MProBackend.ts

@@ -3,7 +3,7 @@
  *
  * Provides backend functionality specific to the Adventurer 5M Pro model:
  * - Dual API support (FiveMClient + FlashForgeClient)
- * - Built-in RTSP camera support (rtsp://printer-ip:8554/stream)
+ * - OEM camera auto-detection when the printer reports a stream URL
  * - Built-in LED control via new API
  * - Filtration control (off/internal/external modes)
  * - Full job management capabilities (local/recent jobs, upload, start/pause/resume/cancel)
@@ -14,8 +14,8 @@
  * - Adventurer5MProBackend class: Backend for Adventurer 5M Pro printers
  *
  * This backend extends DualAPIBackend to leverage common dual-API functionality while
- * defining Pro-specific features. Key differences from standard 5M include built-in
- * RTSP camera and filtration control capabilities.
+ * defining Pro-specific features. Key differences from standard 5M include factory
+ * camera support and filtration control capabilities.
  */
 
 import type { MaterialStationStatus, PrinterFeatureSet } from '../types/printer-backend';
@@ -33,7 +33,7 @@ export class Adventurer5MProBackend extends DualAPIBackend {
   protected getChildBaseFeatures(): PrinterFeatureSet {
     return {
       camera: {
-        builtin: true,
+        oemStreamUrl: '',
         customUrl: null,
         customEnabled: false,
       },