Struct MqttEnergyAdapter 

pub struct MqttEnergyAdapter { /* private fields */ }

Adapter MQTT: subscribe aux topics Home Assistant → dispatch vers IoTRepository.

Flux: Mosquitto broker → rumqttc EventLoop (tokio::spawn) → parse topic (copropriete_id + unit_id) + deserialize JSON payload → IoTReading::new() (validation domaine) → iot_repo.create_reading()

Implementations

impl MqttEnergyAdapter

pub fn new(config: MqttConfig, iot_repo: Arc<dyn IoTRepository>) -> Self

pub fn parse_topic(topic: &str) -> Result<(Uuid, Uuid), MqttError>

Parse le topic MQTT pour extraire copropriete_id et unit_id.

Format attendu: koprogo/{copropriete_id}/energy/{unit_id}/{metric} Exemple: koprogo/550e8400-…/energy/aaaa-bbbb-…/electricity

Trait Implementations

impl MqttEnergyPort for MqttEnergyAdapter

fn start_listening<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), MqttError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Démarre l’écoute MQTT (connect + subscribe). Non-bloquant : lance un tokio::spawn en interne.

fn stop_listening<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), MqttError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Arrête proprement l’écoute MQTT.

fn publish_alert<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _copropriete_id: Uuid, alert_type: &'life1 str, _payload: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), MqttError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Publie un message sortant (ex: alerte anomalie → Home Assistant). Topic: koprogo/{copropriete_id}/alerts/{alert_type}

fn is_running<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Vérifie si le listener est actif.