sep2_common 0.2.0

A Rust library for building IEEE 2030.5 Clients & Servers
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
103
104

use sep2_common::packages::metering::Reading;
use sep2_common::packages::pubsub::NotificationList;
use sep2_common::packages::types::DateTimeInterval;
use sep2_common::traits::SEList;
use sep2_common::{deserialize, serialize};
use sep2_common::{
    examples::NTF_16_06_04,
    packages::{
        primitives::{Int48, Int64, Uint32, Uint8},
        pubsub::{get_notif_type, Notification},
    },
};

/// resources/Examples/16_06_04_Notification.xml
pub(crate) fn create_notif_example() -> Notification<Reading> {
    let inner: Reading = Reading {
        local_id: None,
        subscribable: None,
        consumption_block: None,
        quality_flags: None,
        time_period: Some(DateTimeInterval {
            duration: Uint32(0),
            start: Int64(12987364),
        }),
        tou_tier: None,
        value: Some(Int48(1001)),
        href: None,
    };
    Notification {
        new_resource_uri: None,
        resource: Some(inner),
        status: Uint8(0),
        subscription_uri: "/edev/8/sub/5".to_owned(),
        subscribed_resource: "/upt/0/mr/4/r".to_owned(),
        href: None,
    }
}

#[test]
fn notification_example() {
    let orig = create_notif_example();
    let out = serialize(&orig).unwrap();
    let expected = r#"<Notification xmlns="urn:ieee:std:2030.5:ns" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <subscribedResource>/upt/0/mr/4/r</subscribedResource>
  <Resource xsi:type="Reading">
    <timePeriod>
      <duration>0</duration>
      <start>12987364</start>
    </timePeriod>
    <value>1001</value>
  </Resource>
  <status>0</status>
  <subscriptionURI>/edev/8/sub/5</subscriptionURI>
</Notification>"#;
    assert_eq!(expected, out);
    let new: Notification<Reading> = deserialize(expected).unwrap();
    assert_eq!(orig, new);
    let example: Notification<Reading> = deserialize(NTF_16_06_04).unwrap();
    assert_eq!(example, new);
}

#[test]
fn notification_list_default() {
    let expected = r#"<NotificationList xmlns="urn:ieee:std:2030.5:ns" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" all="2" results="0">
  <Notification>
    <subscribedResource>/upt/0/mr/4/r</subscribedResource>
    <Resource xsi:type="Reading">
      <timePeriod>
        <duration>0</duration>
        <start>12987364</start>
      </timePeriod>
      <value>1001</value>
    </Resource>
    <status>0</status>
    <subscriptionURI>/edev/8/sub/5</subscriptionURI>
  </Notification>
  <Notification>
    <subscribedResource>/upt/0/mr/4/r</subscribedResource>
    <Resource xsi:type="Reading">
      <timePeriod>
        <duration>0</duration>
        <start>12987364</start>
      </timePeriod>
      <value>1001</value>
    </Resource>
    <status>0</status>
    <subscriptionURI>/edev/8/sub/5</subscriptionURI>
  </Notification>
</NotificationList>"#;
    let res: Notification<Reading> = create_notif_example();
    let mut list: NotificationList<Reading> = Default::default();
    list.add(res.clone());
    list.add(res);
    let out = serialize(&list).unwrap();
    assert_eq!(expected, out);
}

#[test]
fn peek_notif_example() {
    let orig = create_notif_example();
    let orig = serialize(&orig).unwrap();
    let name = get_notif_type(&orig).unwrap();
    assert_eq!(name, "Reading");
}