feat/advanced-weather-mesh

Cargo.toml

@@ -32,6 +32,7 @@ members = [
     "examples/remote-access-demo",
     "examples/weather-mesh-demo/weather-mesh-common",
     "examples/weather-mesh-demo/weather-hub",
+    "examples/weather-mesh-demo/weather-station",
     "examples/weather-mesh-demo/weather-station-alpha",
     "examples/weather-mesh-demo/weather-station-beta",
     "examples/weather-mesh-demo/weather-station-gamma",

Makefile

@@ -178,7 +178,7 @@ test:
 
 fmt:
 	@printf "$(GREEN)Formatting code (workspace members only)...$(NC)\n"
-	@for pkg in aimdb-derive aimdb-data-contracts aimdb-core aimdb-client aimdb-embassy-adapter aimdb-tokio-adapter aimdb-wasm-adapter aimdb-sync aimdb-persistence aimdb-persistence-sqlite aimdb-mqtt-connector aimdb-knx-connector aimdb-ws-protocol aimdb-websocket-connector aimdb-uds-connector aimdb-serial-connector aimdb-tcp-connector aimdb-codegen aimdb-cli aimdb-mcp sync-api-demo tokio-mqtt-connector-demo embassy-mqtt-connector-demo tokio-knx-connector-demo embassy-knx-connector-demo embassy-serial-connector-demo embassy-bench-stm32h5 weather-mesh-common weather-hub weather-station-alpha weather-station-beta hello-mailbox hello-mailbox-async hello-single-latest-async aimdb-bench; do \
+	@for pkg in aimdb-derive aimdb-data-contracts aimdb-core aimdb-client aimdb-embassy-adapter aimdb-tokio-adapter aimdb-wasm-adapter aimdb-sync aimdb-persistence aimdb-persistence-sqlite aimdb-mqtt-connector aimdb-knx-connector aimdb-ws-protocol aimdb-websocket-connector aimdb-uds-connector aimdb-serial-connector aimdb-tcp-connector aimdb-codegen aimdb-cli aimdb-mcp sync-api-demo tokio-mqtt-connector-demo embassy-mqtt-connector-demo tokio-knx-connector-demo embassy-knx-connector-demo embassy-serial-connector-demo embassy-bench-stm32h5 weather-mesh-common weather-hub weather-station weather-station-alpha weather-station-beta hello-mailbox hello-mailbox-async hello-single-latest-async aimdb-bench; do \
 		printf "$(YELLOW)  → Formatting $$pkg$(NC)\n"; \
 		cargo fmt -p $$pkg 2>/dev/null || true; \
 	done
@@ -187,7 +187,7 @@ fmt:
 fmt-check:
 	@printf "$(GREEN)Checking code formatting (workspace members only)...$(NC)\n"
 	@FAILED=0; \
-	for pkg in aimdb-derive aimdb-data-contracts aimdb-core aimdb-client aimdb-embassy-adapter aimdb-tokio-adapter aimdb-wasm-adapter aimdb-sync aimdb-persistence aimdb-persistence-sqlite aimdb-mqtt-connector aimdb-knx-connector aimdb-ws-protocol aimdb-websocket-connector aimdb-uds-connector aimdb-serial-connector aimdb-tcp-connector aimdb-codegen aimdb-cli aimdb-mcp sync-api-demo tokio-mqtt-connector-demo embassy-mqtt-connector-demo tokio-knx-connector-demo embassy-knx-connector-demo embassy-serial-connector-demo embassy-bench-stm32h5 weather-mesh-common weather-hub weather-station-alpha weather-station-beta hello-mailbox hello-mailbox-async hello-single-latest-async aimdb-bench; do \
+	for pkg in aimdb-derive aimdb-data-contracts aimdb-core aimdb-client aimdb-embassy-adapter aimdb-tokio-adapter aimdb-wasm-adapter aimdb-sync aimdb-persistence aimdb-persistence-sqlite aimdb-mqtt-connector aimdb-knx-connector aimdb-ws-protocol aimdb-websocket-connector aimdb-uds-connector aimdb-serial-connector aimdb-tcp-connector aimdb-codegen aimdb-cli aimdb-mcp sync-api-demo tokio-mqtt-connector-demo embassy-mqtt-connector-demo tokio-knx-connector-demo embassy-knx-connector-demo embassy-serial-connector-demo embassy-bench-stm32h5 weather-mesh-common weather-hub weather-station weather-station-alpha weather-station-beta hello-mailbox hello-mailbox-async hello-single-latest-async aimdb-bench; do \
 		printf "$(YELLOW)  → Checking $$pkg$(NC)\n"; \
 		if ! cargo fmt -p $$pkg -- --check 2>&1; then \
 			printf "$(RED)❌ Formatting check failed for $$pkg$(NC)\n"; \
@@ -398,6 +398,8 @@ examples:
 	cargo build --package weather-station-alpha
 	@printf "$(YELLOW)  → Building weather-mesh-demo: weather-station-beta (edge, synthetic)$(NC)\n"
 	cargo build --package weather-station-beta
+	@printf "$(YELLOW)  → Building weather-mesh-demo: weather-station (public mesh, profile-driven)$(NC)\n"
+	cargo build --package weather-station
 	@printf "$(YELLOW)  → Building weather-station-gamma (embedded, embassy runtime)$(NC)\n"
 	cargo build --package weather-station-gamma --target thumbv7em-none-eabihf
 	@printf "$(YELLOW)  → Building remote-access-demo (AimX server + client)$(NC)\n"

README.md

@@ -239,6 +239,8 @@ See the [MCP server docs](tools/aimdb-mcp/) for Claude Desktop and other editors
 | **MQTT** — `aimdb-mqtt-connector` | ✅ Ready | std, no_std |
 | **KNX** — `aimdb-knx-connector` | ✅ Ready | std, no_std |
 | **WebSocket** — `aimdb-websocket-connector` | ✅ Ready | std, wasm |
+| **Serial (COBS/UART)** — `aimdb-serial-connector` | ✅ Ready | std, no_std |
+| **Unix domain socket** — `aimdb-uds-connector` | ✅ Ready | std |
 | **TCP** — `aimdb-tcp-connector` | ✅ Ready | std, no_std |
 | **Kafka** | 📋 Planned | std |
 | **Modbus** | 📋 Planned | std, no_std |

aimdb-mqtt-connector/src/tokio_client.rs

@@ -177,6 +177,12 @@ impl MqttConnectorImpl {
             mqtt_opts.set_credentials(username, password);
         }
 
+        // mqtts:// selects the TLS transport (system trust roots via
+        // native-tls); rumqttc otherwise speaks plain TCP regardless of port.
+        if connector_url.scheme == "mqtts" {
+            mqtt_opts.set_transport(rumqttc::Transport::Tls(rumqttc::TlsConfiguration::Native));
+        }
+
         // Wrap router early so we can count topics for capacity calculation
         let router_arc = Arc::new(router);
         let topic_count = router_arc.resource_ids().len();
@@ -364,4 +370,18 @@ mod tests {
         let connector = MqttConnectorImpl::build_internal("not-a-valid-url", None, router).await;
         assert!(connector.is_err());
     }
+
+    #[tokio::test]
+    async fn test_connector_mqtts_url_with_credentials() {
+        // mqtts:// with URL-embedded credentials must parse and build; the TLS
+        // handshake itself only happens once the event loop is polled.
+        let router = RouterBuilder::new().build();
+        let connector = MqttConnectorImpl::build_internal(
+            "mqtts://hub-sub:secret@broker.example.com:8883",
+            None,
+            router,
+        )
+        .await;
+        assert!(connector.is_ok());
+    }
 }