Implement MQTT-over-WebSocket Data Ingestion

[w2naf]

Overview

Support MQTT protocol for data ingestion, enabling integration with message broker infrastructure.

Requirements

• FR-DI-03: The system SHOULD support MQTT-over-WebSocket for data ingestion
• NFR-SEC-03: The system SHOULD support optional authentication for MQTT connections

Tasks

• Integrate MQTT.js library (already vendored in mag-dash)
• Implement MQTT connection handling
• Support configurable broker URL and topic
• Handle MQTT authentication (username/password)
• Parse incoming MQTT messages (same JSONL format)
• Allow switching between WebSocket and MQTT modes

Acceptance Criteria

• Can connect to MQTT broker over WebSocket
• Receives and displays MQTT messages
• Authentication works when required
• Graceful fallback/error handling if broker unavailable