publisher_example.rs

/********************************************************************************
 * Copyright (c) 2023 Contributors to the Eclipse Foundation
 *
 * See the NOTICE file(s) distributed with this work for additional
 * information regarding copyright ownership.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Apache License Version 2.0 which is available at
 * https://www.apache.org/licenses/LICENSE-2.0
 *
 * SPDX-License-Identifier: Apache-2.0
 ********************************************************************************/

use std::{str::FromStr, time::SystemTime};

use env_logger::{Builder, Target};
use log::LevelFilter;
use up_client_mqtt5_rust::{MqttConfig, MqttProtocol, UPClientMqtt, UPClientMqttType};
use up_rust::{UMessageBuilder, UPayloadFormat, UStatus, UTransport, UUri, UUID};

#[tokio::main]
async fn main() -> Result<(), UStatus> {
    Builder::new()
        .target(Target::Stdout) // Logs to stdout
        .filter(None, LevelFilter::Trace) // Default level
        .init();

    // Set the protocol type ("mqtt" for unencrypted mqtt)
    let protocol = MqttProtocol::Mqtt;

    // no need to build ssl options since we are using unencrypted mqtt, username is arbitrary
    let ssl_options = None;
    let user_name = "eclipse_testuser".to_string();

    let config = MqttConfig {
        mqtt_protocol: protocol,
        mqtt_hostname: "localhost".to_string(),
        mqtt_port: 1883,
        max_buffered_messages: 100,
        max_subscriptions: 100,
        session_expiry_interval: 3600,
        ssl_options,
        username: user_name,
    };

    let client = UPClientMqtt::new(
        config,
        UUID::build(),
        "Vehicle_B".to_string(),
        UPClientMqttType::Device,
    )
    .await?;

    let source =
        UUri::from_str("//Vehicle_B/A8000/2/8A50").expect("Failed to create source filter");

    loop {
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
        let current_time = SystemTime::now()
            .duration_since(SystemTime::UNIX_EPOCH)
            .unwrap()
            .as_secs();
        let message = UMessageBuilder::publish(source.clone())
            .build_with_payload(
                current_time.to_string(),
                UPayloadFormat::UPAYLOAD_FORMAT_TEXT,
            )
            .expect("Failed to build message");

        println!(
            "Sending message: {} to source: {}",
            current_time,
            source.to_uri(false)
        );
        client.send(message).await?;
    }
}