nstreams 0.2.2

Embeddable versioned event stream handler for existing services
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

use nstreams::transport::{delivered_event_json, registered_event_json};
use nstreams_core::event::DeliveredEvent;
use nstreams_core::new_request_id;

#[test]
fn registered_event_json_shape() {
    let request_id = new_request_id();
    let json = registered_event_json(&request_id);
    assert_eq!(json["request_id"], request_id);
    assert!(json.get("namespace").is_none());
}

#[test]
fn delivered_event_json_shape() {
    let event = DeliveredEvent {
        request_id: new_request_id(),
        version: 3,
        payload: br#"{"tick":1}"#.to_vec(),
    };

    let json = delivered_event_json(&event).unwrap();
    assert_eq!(json["request_id"], event.request_id);
    assert_eq!(json["version"], 3);
    assert_eq!(json["payload"]["tick"], 1);
    assert!(json.get("namespace").is_none());
}