feat: add standalone Discord webhooks and remove legacy per-printer config keys

Author: GhostTypes

CHANGELOG.md

@@ -7,6 +7,25 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+
+- Discord webhook notifications for the standalone WebUI with:
+  - Global config keys in `config.json`: `DiscordSync`, `WebhookUrl`, `DiscordUpdateIntervalMinutes`
+  - Multi-printer periodic status updates using a single shared timer
+  - Event-driven notifications for print completion, printer cooled, and idle transitions
+  - Status embeds using precise elapsed seconds and firmware ETA when available
+- Focused Discord notification service tests covering timer behavior, multi-context sends, and payload formatting
+
+### Changed
+
+- Legacy per-printer settings in `config.json` are now treated as stale keys only and stripped on save
+- Printer connection and backend selection now use per-printer `forceLegacyMode` instead of the removed global `ForceLegacyAPI`
+- Camera configuration resolution now uses only per-printer settings from saved printer details
+
+### Removed
+
+- Legacy global config ownership for `CustomCamera`, `CustomCameraUrl`, `CustomLeds`, `ForceLegacyAPI`, and `CameraProxyPort`
+
 ## [1.0.2] - 2026-01-31
 
 ### Added

CLAUDE.md

@@ -271,7 +271,7 @@ class Service extends EventEmitter<EventMap> {
 
 1. **Dual Build System**: Backend and frontend have separate `tsconfig.json` files with different module systems (CommonJS vs ES modules)
 2. **Data Directory**: Not in git but can be manually accessed for debugging. Default location is `<project>/data/`
-3. **Port Allocation**: Camera proxies dynamically allocate ports starting from config value (`CameraProxyPort`)
+3. **Camera Streams**: go2rtc manages camera streams per context; there is no user-facing global `CameraProxyPort` setting anymore
 4. **Polling Frequency**: All contexts poll at 3 seconds (changed from 30s for inactive contexts to prevent TCP keep-alive failures)
 5. **Context IDs**: UUID-based, generated during connection. Not tied to IP or serial number
 6. **Backend Lifecycle**: Backends are created per context, not shared. Each context has its own TCP connection

src/index.ts

@@ -23,6 +23,7 @@ import { getMultiContextPollingCoordinator } from './services/MultiContextPollin
 import { getMultiContextPrintStateMonitor } from './services/MultiContextPrintStateMonitor';
 import { getMultiContextTemperatureMonitor } from './services/MultiContextTemperatureMonitor';
 import { getMultiContextSpoolmanTracker } from './services/MultiContextSpoolmanTracker';
+import { getDiscordNotificationService } from './services/discord';
 import { getGo2rtcService } from './services/Go2rtcService';
 import { initializeSpoolmanIntegrationService } from './services/SpoolmanIntegrationService';
 import { getSavedPrinterService } from './services/SavedPrinterService';
@@ -43,6 +44,7 @@ const pollingCoordinator = getMultiContextPollingCoordinator();
 const savedPrinterService = getSavedPrinterService();
 const webUIManager = getWebUIManager();
 const go2rtcService = getGo2rtcService();
+const discordService = getDiscordNotificationService();
 
 let connectedContexts: string[] = [];
 let isInitialized = false;
@@ -230,6 +232,10 @@ function setupEventForwarding(): void {
   // For WebUI (single-printer or multi-printer), forward all context data
   // The WebUI/WebSocket layer will handle filtering if needed
   pollingCoordinator.on('polling-data', (contextId: string, data: any) => {
+    if (data?.printerStatus) {
+      discordService.updatePrinterStatus(contextId, data.printerStatus);
+    }
+
     // Forward all polling data regardless of active context
     // This ensures data reaches the WebUI even if active context isn't set yet
     webUIManager.handlePollingUpdate(data);
@@ -372,12 +378,17 @@ async function shutdown(): Promise<void> {
 
   try {
     // Step 1: Stop polling (immediate)
-    console.log('[Shutdown] Step 1/4: Stopping polling...');
+    console.log('[Shutdown] Step 1/5: Stopping polling...');
     pollingCoordinator.stopAllPolling();
     console.log('[Shutdown] Polling stopped');
 
-    // Step 2: Parallel disconnects (all printers disconnect concurrently)
-    console.log(`[Shutdown] Step 2/4: Disconnecting ${connectedContexts.length} context(s)...`);
+    // Step 2: Stop Discord notifications
+    console.log('[Shutdown] Step 2/5: Stopping Discord notifications...');
+    discordService.dispose();
+    console.log('[Shutdown] Discord notifications stopped');
+
+    // Step 3: Parallel disconnects (all printers disconnect concurrently)
+    console.log(`[Shutdown] Step 3/5: Disconnecting ${connectedContexts.length} context(s)...`);
     if (connectedContexts.length > 0) {
       const results = await Promise.allSettled(connectedContexts.map((contextId) => connectionManager.disconnectContext(contextId)));
 
@@ -396,13 +407,13 @@ async function shutdown(): Promise<void> {
       console.log('[Shutdown] No contexts to disconnect');
     }
 
-    // Step 3: Stop go2rtc camera streaming service
-    console.log('[Shutdown] Step 3/4: Stopping camera streaming...');
+    // Step 4: Stop go2rtc camera streaming service
+    console.log('[Shutdown] Step 4/5: Stopping camera streaming...');
     await go2rtcService.shutdown();
     console.log('[Shutdown] Camera streaming stopped');
 
-    // Step 4: Stop WebUI (with timeout and force-close fallback)
-    console.log('[Shutdown] Step 4/4: Stopping WebUI...');
+    // Step 5: Stop WebUI (with timeout and force-close fallback)
+    console.log('[Shutdown] Step 5/5: Stopping WebUI...');
     await webUIManager.stop(SHUTDOWN_CONFIG.WEBUI_STOP_TIMEOUT_MS);
     console.log('[Shutdown] WebUI stopped');
 
@@ -473,6 +484,9 @@ async function main(): Promise<void> {
     getMultiContextPrintStateMonitor();
     console.log('[Init] Print state monitor initialized');
 
+    discordService.initialize();
+    console.log('[Init] Discord notification service initialized');
+
     // 9. Initialize Spoolman usage tracking
     const multiContextSpoolmanTracker = getMultiContextSpoolmanTracker();
     multiContextSpoolmanTracker.initialize();
@@ -524,11 +538,26 @@ async function main(): Promise<void> {
 
         console.log(`[Events] Created PrintStateMonitor for context ${contextId}`);
 
-        // STEP 4: Create SpoolmanTracker for this context (depends on PrintStateMonitor)
+        // STEP 4: Create TemperatureMonitor for this context
+        const temperatureMonitor = getMultiContextTemperatureMonitor();
+        temperatureMonitor.createMonitorForContext(contextId, pollingService, stateMonitor);
+        const contextTemperatureMonitor = temperatureMonitor.getMonitor(contextId);
+
+        if (!contextTemperatureMonitor) {
+          console.error('[Events] Failed to create temperature monitor');
+          return;
+        }
+
+        console.log(`[Events] Created TemperatureMonitor for context ${contextId}`);
+
+        // STEP 5: Create SpoolmanTracker for this context (depends on PrintStateMonitor)
         const spoolmanTracker = getMultiContextSpoolmanTracker();
         spoolmanTracker.createTrackerForContext(contextId, stateMonitor);
 
         console.log(`[Events] Created SpoolmanTracker for context ${contextId}`);
+        discordService.registerContext(contextId);
+        discordService.attachContextMonitors(contextId, stateMonitor, contextTemperatureMonitor);
+        console.log(`[Events] Registered Discord notifications for context ${contextId}`);
         void reconcileCameraStream(contextId);
         console.log(`[Events] All services initialized for context ${contextId}`);
       } catch (error) {

src/managers/ConfigManager.test.ts

@@ -27,7 +27,9 @@ describe('ConfigManager', () => {
       WebUIPort: 3000,
       WebUIPassword: 'testpass',
       WebUIPasswordRequired: true,
-      CameraProxyPort: 8181,
+      DiscordSync: false,
+      WebhookUrl: '',
+      DiscordUpdateIntervalMinutes: 5,
       SpoolmanEnabled: false,
       SpoolmanServerUrl: ''
     }));
@@ -75,7 +77,9 @@ describe('ConfigManager', () => {
       expect(config).toHaveProperty('WebUIPort');
       expect(config).toHaveProperty('WebUIPassword');
       expect(config).toHaveProperty('WebUIPasswordRequired');
-      expect(config).toHaveProperty('CameraProxyPort');
+      expect(config).toHaveProperty('DiscordSync');
+      expect(config).toHaveProperty('WebhookUrl');
+      expect(config).toHaveProperty('DiscordUpdateIntervalMinutes');
       expect(config).toHaveProperty('SpoolmanEnabled');
       expect(config).toHaveProperty('SpoolmanServerUrl');
     });
@@ -87,7 +91,9 @@ describe('ConfigManager', () => {
       expect(typeof config.WebUIPort).toBe('number');
       expect(typeof config.WebUIPassword).toBe('string');
       expect(typeof config.WebUIPasswordRequired).toBe('boolean');
-      expect(typeof config.CameraProxyPort).toBe('number');
+      expect(typeof config.DiscordSync).toBe('boolean');
+      expect(typeof config.WebhookUrl).toBe('string');
+      expect(typeof config.DiscordUpdateIntervalMinutes).toBe('number');
       expect(typeof config.SpoolmanEnabled).toBe('boolean');
       expect(typeof config.SpoolmanServerUrl).toBe('string');
     });
@@ -163,8 +169,7 @@ describe('ConfigManager', () => {
 
       expect(config.WebUIPort).toBeGreaterThanOrEqual(1);
       expect(config.WebUIPort).toBeLessThanOrEqual(65535);
-      expect(config.CameraProxyPort).toBeGreaterThanOrEqual(1);
-      expect(config.CameraProxyPort).toBeLessThanOrEqual(65535);
+      expect(config.DiscordUpdateIntervalMinutes).toBeGreaterThanOrEqual(0);
     });
 
     it('should have valid URL format for SpoolmanServerUrl', () => {

src/managers/ConnectionFlowManager.ts

@@ -52,7 +52,6 @@ import {
 } from '../utils/PrinterUtils';
 import { TimeoutError, withTimeout } from '../utils/ShutdownTimeout';
 import { IPAddressSchema } from '../utils/validation.utils';
-import { getConfigManager } from './ConfigManager';
 import { getLoadingManager } from './LoadingManager';
 import { getPrinterBackendManager } from './PrinterBackendManager';
 import { getPrinterContextManager } from './PrinterContextManager';
@@ -80,7 +79,6 @@ interface ConnectionFlowState {
 }
 
 export class ConnectionFlowManager extends EventEmitter {
-  private readonly configManager = getConfigManager();
   private readonly loadingManager = getLoadingManager();
   private readonly backendManager = getPrinterBackendManager();
   private readonly contextManager = getPrinterContextManager();
@@ -107,11 +105,6 @@ export class ConnectionFlowManager extends EventEmitter {
 
   /** Setup internal event handlers and service event forwarding */
   private setupEventHandlers(): void {
-    // Forward configuration changes
-    this.configManager.on('config:ForceLegacyAPI', (newValue: boolean) => {
-      this.emit('force-legacy-changed', newValue);
-    });
-
     // Forward backend manager events
     this.forwardEvents(this.backendManager, [
       'backend-initialized',
@@ -585,7 +578,6 @@ export class ConnectionFlowManager extends EventEmitter {
       // Step 2: Detect printer family and requirements
       const familyInfo = detectPrinterFamily(tempResult.typeName);
       const clientType = determineClientType(familyInfo.is5MFamily);
-      const ForceLegacyAPI = this.configManager.get('ForceLegacyAPI') || false;
 
       this.emit('printer-type-detected', {
         typeName: tempResult.typeName,
@@ -599,34 +591,7 @@ export class ConnectionFlowManager extends EventEmitter {
           ? tempResult.printerInfo.Name
           : discoveredPrinter.name;
 
-      // Step 3: Handle check code requirements
-      let checkCode = getDefaultCheckCode();
-
-      // Check if this printer has a saved check code
-      const savedCheckCode = this.savedPrinterService.getSavedCheckCode(
-        discoveredPrinter.serialNumber
-      );
-
-      if (savedCheckCode) {
-        console.log('Using saved check code for known printer:', realPrinterName);
-        checkCode = savedCheckCode;
-      } else if (shouldPromptForCheckCode(familyInfo.is5MFamily, undefined, ForceLegacyAPI)) {
-        this.loadingManager.hide();
-
-        const promptedCheckCode = await this.promptForCheckCode(realPrinterName);
-        if (!promptedCheckCode) {
-          this.loadingManager.showError('Printer pairing cancelled', 2000);
-          return { success: false, error: 'Connection cancelled by user' };
-        }
-        checkCode = promptedCheckCode;
-
-        this.loadingManager.show({
-          message: 'Establishing connection with pairing code...',
-          canCancel: false,
-        });
-      }
-
-      // Step 4: Extract and validate printer information
+      // Step 3: Extract and validate printer information
       this.loadingManager.updateMessage('Processing printer details...');
       const modelType = detectPrinterModelType(tempResult.typeName);
 
@@ -649,6 +614,32 @@ export class ConnectionFlowManager extends EventEmitter {
         serialNumber = `Unknown-${Date.now()}`;
       }
 
+      const existingPrinter = this.savedPrinterService.getSavedPrinter(serialNumber);
+      const forceLegacyMode = existingPrinter?.forceLegacyMode ?? false;
+
+      // Step 4: Handle check code requirements
+      let checkCode = getDefaultCheckCode();
+      const savedCheckCode = existingPrinter?.CheckCode;
+
+      if (savedCheckCode) {
+        console.log('Using saved check code for known printer:', realPrinterName);
+        checkCode = savedCheckCode;
+      } else if (shouldPromptForCheckCode(familyInfo.is5MFamily, undefined, forceLegacyMode)) {
+        this.loadingManager.hide();
+
+        const promptedCheckCode = await this.promptForCheckCode(realPrinterName);
+        if (!promptedCheckCode) {
+          this.loadingManager.showError('Printer pairing cancelled', 2000);
+          return { success: false, error: 'Connection cancelled by user' };
+        }
+        checkCode = promptedCheckCode;
+
+        this.loadingManager.show({
+          message: 'Establishing connection with pairing code...',
+          canCancel: false,
+        });
+      }
+
       // Update the discoveredPrinter object with the correct information for connection establishment
       const updatedDiscoveredPrinter: DiscoveredPrinter = {
         ...discoveredPrinter,
@@ -671,7 +662,7 @@ export class ConnectionFlowManager extends EventEmitter {
         tempResult.typeName,
         familyInfo.is5MFamily,
         checkCode,
-        ForceLegacyAPI
+        forceLegacyMode
       );
 
       if (!connectionResult) {
@@ -683,7 +674,6 @@ export class ConnectionFlowManager extends EventEmitter {
       this.loadingManager.updateMessage('Saving printer details...');
 
       // Check if printer already exists to preserve per-printer settings
-      const existingPrinter = this.savedPrinterService.getSavedPrinter(serialNumber);
       console.log(
         '[ConnectionFlow] Existing printer check for',
         serialNumber,
@@ -702,14 +692,14 @@ export class ConnectionFlowManager extends EventEmitter {
         IPAddress: discoveredPrinter.ipAddress,
         SerialNumber: serialNumber,
         CheckCode: checkCode,
-        ClientType: ForceLegacyAPI ? 'legacy' : clientType,
+        ClientType: forceLegacyMode ? 'legacy' : clientType,
         printerModel: tempResult.typeName,
         modelType,
         // Preserve existing per-printer settings or use defaults for new printers
         customCameraEnabled: existingPrinter?.customCameraEnabled ?? false,
         customCameraUrl: existingPrinter?.customCameraUrl ?? '',
         customLedsEnabled: existingPrinter?.customLedsEnabled ?? false,
-        forceLegacyMode: existingPrinter?.forceLegacyMode ?? false,
+        forceLegacyMode,
         activeSpoolData: existingPrinter?.activeSpoolData ?? null,
       };
 
@@ -945,7 +935,6 @@ export class ConnectionFlowManager extends EventEmitter {
         console.log(`Initialized default per-printer settings for ${detailsWithDefaults.Name}`);
       }
 
-      const ForceLegacyAPI = this.configManager.get('ForceLegacyAPI') || false;
       const familyInfo = detectPrinterFamily(detailsWithDefaults.printerModel);
 
       // Create a mock discovered printer for connection establishment
@@ -962,7 +951,7 @@ export class ConnectionFlowManager extends EventEmitter {
         detailsWithDefaults.printerModel,
         familyInfo.is5MFamily,
         detailsWithDefaults.CheckCode,
-        ForceLegacyAPI
+        detailsWithDefaults.forceLegacyMode ?? false
       );
 
       if (!connectionResult) {
@@ -1251,14 +1240,15 @@ export class ConnectionFlowManager extends EventEmitter {
           model: tempResult.typeName,
         };
 
+        const forceLegacyMode = existingPrinter?.forceLegacyMode ?? false;
+
         // Establish final connection
-        const ForceLegacyAPI = this.configManager.get('ForceLegacyAPI') || false;
         const connectionResult = await this.connectionService.establishFinalConnection(
           updatedDiscoveredPrinter,
           tempResult.typeName,
           is5MFamily,
           checkCode,
-          ForceLegacyAPI
+          forceLegacyMode
         );
 
         if (!connectionResult) {
@@ -1273,14 +1263,14 @@ export class ConnectionFlowManager extends EventEmitter {
           IPAddress: spec.ip,
           SerialNumber: serialNumber,
           CheckCode: checkCode,
-          ClientType: spec.type,
+          ClientType: forceLegacyMode ? 'legacy' : spec.type,
           printerModel: tempResult.typeName,
           modelType,
           // Preserve previously configured per-printer overrides when present
           customCameraEnabled: existingPrinter?.customCameraEnabled ?? false,
           customCameraUrl: existingPrinter?.customCameraUrl ?? '',
           customLedsEnabled: existingPrinter?.customLedsEnabled ?? false,
-          forceLegacyMode: existingPrinter?.forceLegacyMode ?? false,
+          forceLegacyMode,
         };
 
         await this.savedPrinterService.savePrinter(printerDetails);