ocpp_rs 0.4.2

no_std + alloc OCPP 1.6 and 2.1 protocol library (OCPP-J parse/serialize, CallResult correlation).
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

//! Datetime serialize feature tests.
//!
//! Parse always accepts RFC3339 (including `%.3fZ`).
//! Serialize defaults to `%Y-%m-%dT%H:%M:%S%.3fZ`; enable `datetime_serialize_rfc3339`
//! for chrono RFC3339 millis emit.

use chrono::{TimeZone, Utc};
use ocpp_rs::datetime::DateTimeWrapper;
use ocpp_rs::v16::call_result::Heartbeat;
use ocpp_rs::v16::parse::{deserialize_to_message, serialize_message};
use ocpp_rs::v16::response_trait::Response;

fn status_call_json(ts: &str) -> String {
    format!(
        r#"[2, "dt", "StatusNotification", {{"connectorId":1,"errorCode":"NoError","status":"Available","timestamp":"{ts}"}}]"#
    )
}

#[test]
fn parses_strict_millis_z() {
    let data = status_call_json("2024-06-01T19:52:45.123Z");
    assert!(deserialize_to_message(&data).is_ok());
}

#[test]
fn parses_rfc3339_offset() {
    let data = status_call_json("2024-06-01T19:52:45.123+00:00");
    assert!(deserialize_to_message(&data).is_ok());
}

#[test]
fn parses_rfc3339_without_fractional_seconds() {
    let data = status_call_json("2024-06-01T19:52:45Z");
    assert!(deserialize_to_message(&data).is_ok());
}

#[test]
fn default_serialize_uses_three_fractional_digits() {
    let req = ocpp_rs::v16::call::Heartbeat {};
    let dt = DateTimeWrapper::new(Utc.with_ymd_and_hms(2024, 1, 1, 0, 0, 0).unwrap());
    let msg = req
        .get_response("1".into(), Heartbeat { current_time: dt })
        .expect("serialize response");
    let wire = serialize_message(&msg).expect("serialize");
    assert!(
        wire.contains("2024-01-01T00:00:00.000Z"),
        "expected %.3fZ in {wire}"
    );
}

#[cfg(feature = "datetime_serialize_rfc3339")]
#[test]
fn serialize_rfc3339_emits_millis_z() {
    let req = ocpp_rs::v16::call::Heartbeat {};
    let dt = DateTimeWrapper::new(Utc.with_ymd_and_hms(2024, 6, 15, 12, 30, 45).unwrap());
    let msg = req
        .get_response("1".into(), Heartbeat { current_time: dt })
        .expect("serialize response");
    let wire = serialize_message(&msg).expect("serialize");
    // For Utc + millis, RFC3339 opts match %.3fZ shape.
    assert!(wire.contains("2024-06-15T12:30:45.000Z"), "{wire}");
}