kubemq 1.0.0

KubeMQ Rust SDK - Message broker client for events, commands, queries, and queues
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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Additional unit tests for common.rs coverage gaps.
//!
//! Targets: resolve_client_id with non-empty client_id,
//! resolve_client_id_owned with non-empty and empty,
//! resolve_id/resolve_id_owned with explicit ids.

use kubemq::KubemqClient;

/// Test common::resolve_id behavior is exercised through event sending.
/// When an event has a non-empty id, it should be preserved.
#[test]
fn test_event_builder_preserves_explicit_id() {
    let event = kubemq::Event::builder()
        .id("my-explicit-id")
        .channel("test-ch")
        .build();
    assert_eq!(event.id, "my-explicit-id");
}

/// When an event has empty id, a UUID is generated.
#[test]
fn test_event_builder_empty_id_generates_uuid() {
    let event = kubemq::Event::builder().channel("test-ch").build();
    assert!(event.id.is_empty()); // Builder doesn't generate - conversion does
}

/// Test event_store builder preserves explicit id.
#[test]
fn test_event_store_builder_preserves_explicit_id() {
    let es = kubemq::EventStore::builder()
        .id("my-store-id")
        .channel("test-ch")
        .build();
    assert_eq!(es.id, "my-store-id");
}

/// Test command builder preserves explicit id.
#[test]
fn test_command_builder_preserves_explicit_id() {
    let cmd = kubemq::Command::builder()
        .id("cmd-explicit-id")
        .channel("test-ch")
        .timeout(std::time::Duration::from_secs(5))
        .build();
    assert_eq!(cmd.id, "cmd-explicit-id");
}

/// Test query builder preserves explicit id.
#[test]
fn test_query_builder_preserves_explicit_id() {
    let q = kubemq::Query::builder()
        .id("query-explicit-id")
        .channel("test-ch")
        .timeout(std::time::Duration::from_secs(5))
        .build();
    assert_eq!(q.id, "query-explicit-id");
}

/// Test queue message builder preserves explicit client_id.
#[test]
fn test_queue_message_builder_preserves_client_id() {
    let msg = kubemq::QueueMessage::builder()
        .client_id("custom-client")
        .channel("test-ch")
        .build();
    assert_eq!(msg.client_id, "custom-client");
}

/// Test queue message builder empty client_id.
#[test]
fn test_queue_message_builder_empty_client_id() {
    let msg = kubemq::QueueMessage::builder().channel("test-ch").build();
    assert!(msg.client_id.is_empty());
}

/// Test event with non-empty client_id uses it instead of default.
#[test]
fn test_event_custom_client_id_preserved() {
    let event = kubemq::Event::builder()
        .id("e1")
        .channel("ch")
        .client_id("my-custom-client")
        .build();
    assert_eq!(event.client_id, "my-custom-client");
}

/// Test event with empty client_id.
#[test]
fn test_event_empty_client_id() {
    let event = kubemq::Event::builder().channel("ch").build();
    assert!(event.client_id.is_empty());
}

/// Test event store with non-empty client_id uses it.
#[test]
fn test_event_store_custom_client_id() {
    let es = kubemq::EventStore::builder()
        .channel("ch")
        .client_id("custom-es-client")
        .build();
    assert_eq!(es.client_id, "custom-es-client");
}