mqtt5 0.32.2

Complete MQTT v5.0 platform with high-performance async client and full-featured broker supporting TCP, TLS, WebSocket, authentication, bridging, and resource monitoring
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

#![allow(clippy::large_futures)]

use mqtt5::{ConnectOptions, MqttClient, MqttError};

#[tokio::test]
async fn test_connect_disconnect() {
    // This test requires a running MQTT broker
    // Skip if no broker is available
    let client = MqttClient::new("test-client");

    // Try connecting to localhost broker
    match client.connect("mqtt://127.0.0.1:1883").await {
        Ok(()) => {
            // Successfully connected
            assert!(client.is_connected().await);

            // Test disconnect
            client.disconnect().await.unwrap();
            assert!(!client.is_connected().await);
        }
        Err(e) => {
            // Broker not available, skip test
            eprintln!("Skipping test - no broker available: {e}");
        }
    }
}

#[tokio::test]
async fn test_connect_with_options() {
    let mut options = ConnectOptions::new("custom-client");
    options.clean_start = false;

    let client = MqttClient::with_options(options.clone());

    // Try connecting
    match client
        .connect_with_options("tcp://127.0.0.1:1883", options)
        .await
    {
        Ok(result) => {
            assert!(client.is_connected().await);
            assert_eq!(client.client_id().await, "custom-client");
            println!("Connected with session_present: {}", result.session_present);
            client.disconnect().await.unwrap();
        }
        Err(e) => {
            eprintln!("Skipping test - no broker available: {e}");
        }
    }
}

#[tokio::test]
async fn test_already_connected_error() {
    let client = MqttClient::new("test-client");

    // First connection
    match client.connect("mqtt://127.0.0.1:1883").await {
        Ok(()) => {
            // Try connecting again
            let result = client.connect("mqtt://127.0.0.1:1883").await;
            assert!(matches!(result, Err(MqttError::AlreadyConnected)));

            client.disconnect().await.unwrap();
        }
        Err(e) => {
            eprintln!("Skipping test - no broker available: {e}");
        }
    }
}

#[tokio::test]
async fn test_disconnect_not_connected() {
    let client = MqttClient::new("test-client");
    let result = client.disconnect().await;
    assert!(matches!(result, Err(MqttError::NotConnected)));
}