Custom serde serializer for datetime (#153)

* feat: custom serde serializer for datetime

* feat: use custom serde serializer for datetime for all DateTime<Utc> fields

* review: rename datetime serializer to datetime_rfc3339

Author: Wolfy7

Cargo.toml

@@ -26,7 +26,7 @@ v2_0_1 = []
 
 [dependencies]
 serde = { version = "1", default-features = false, features = ["derive"] }
-chrono = { version = "0.4.39", default-features = false, features = ["serde"] }
+chrono = { version = "0.4.39", default-features = false, features = ["serde", "alloc"] }
 uuid = { version = "1", default-features = false, features = ["v4"] }
 validator = { version = "0.19.0", default-features = false, features = ["derive"] }
 regex = "1.11.1"

src/v2_0_1/helpers/datetime_rfc3339.rs

@@ -0,0 +1,18 @@
+use chrono::{DateTime, SecondsFormat, Utc};
+use serde::{Deserialize, Deserializer, Serializer};
+pub fn serialize<S>(date: &DateTime<Utc>, serializer: S) -> Result<S::Ok, S::Error>
+where
+    S: Serializer,
+{
+    serializer.serialize_str(&date.to_rfc3339_opts(SecondsFormat::Millis, true))
+}
+
+pub fn deserialize<'de, D>(deserializer: D) -> Result<DateTime<Utc>, D::Error>
+where
+    D: Deserializer<'de>,
+{
+    let s: String = Deserialize::deserialize(deserializer)?;
+    DateTime::parse_from_rfc3339(&s)
+        .map(|dt| dt.with_timezone(&Utc))
+        .map_err(serde::de::Error::custom)
+}

src/v2_0_1/helpers/mod.rs

@@ -1,2 +1,5 @@
 /// validators
 pub mod validator;
+
+/// serializers
+pub mod datetime_rfc3339;

src/v2_0_1/messages/boot_notification.rs

@@ -17,6 +17,7 @@ use crate::v2_0_1::datatypes::charging_station_type::ChargingStationType;
 use crate::v2_0_1::datatypes::status_info_type::StatusInfoType;
 use crate::v2_0_1::enumerations::boot_reason_enum_type::BootReasonEnumType;
 use crate::v2_0_1::enumerations::registration_status_enum_type::RegistrationStatusEnumType;
+use crate::v2_0_1::helpers::datetime_rfc3339;
 
 /// `BootNotificationRequest`, sent by the Charging Station to the CSMS when booting.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
@@ -33,6 +34,7 @@ pub struct BootNotificationRequest {
 #[serde(rename_all = "camelCase")]
 pub struct BootNotificationResponse {
     /// This contains the CSMS’s current time.
+    #[serde(with = "datetime_rfc3339 ")]
     pub current_time: DateTime<Utc>,
     /// When [status](BootNotificationResponse::status) is Accepted, this contains the
     /// heartbeat interval in seconds.

src/v2_0_1/messages/heartbeat.rs

@@ -3,6 +3,8 @@
 use chrono::DateTime;
 use chrono::Utc;
 
+use crate::v2_0_1::helpers::datetime_rfc3339;
+
 /// HeartbeatRequest, sent by the Charging Station to the CSMS. No fields are defined.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
 #[serde(rename_all = "camelCase")]
@@ -15,5 +17,6 @@ pub struct HeartbeatRequest {
 #[serde(rename_all = "camelCase")]
 pub struct HeartbeatResponse {
     /// Contains the current time of the CSMS.
+    #[serde(with = "datetime_rfc3339 ")]
     pub current_time: DateTime<Utc>,
 }

src/v2_0_1/messages/notify_customer_information.rs

@@ -1,6 +1,8 @@
 use chrono::DateTime;
 use chrono::Utc;
 
+use crate::v2_0_1::helpers::datetime_rfc3339;
+
 /// This contains the field definition of the NotifyCustomerInformationRequest PDU sent by the Charging Station to the CSMS.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
 #[serde(rename_all = "camelCase")]
@@ -9,6 +11,7 @@ pub struct NotifyCustomerInformationRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tbc: Option<bool>,
     pub seq_no: i32,
+    #[serde(with = "datetime_rfc3339 ")]
     pub generated_at: DateTime<Utc>,
     pub request_id: i32,
 }

src/v2_0_1/messages/notify_ev_charging_schedule.rs

@@ -4,11 +4,13 @@ use chrono::Utc;
 use crate::v2_0_1::datatypes::charging_schedule_type::ChargingScheduleType;
 use crate::v2_0_1::datatypes::status_info_type::StatusInfoType;
 use crate::v2_0_1::enumerations::generic_status_enum_type::GenericStatusEnumType;
+use crate::v2_0_1::helpers::datetime_rfc3339;
 
 /// The Charging Station uses this message to communicate the charging needs as calculated by the EV to the CSMS.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
 #[serde(rename_all = "camelCase")]
 pub struct NotifyEVChargingScheduleRequest {
+    #[serde(with = "datetime_rfc3339 ")]
     pub time_base: DateTime<Utc>,
     pub evse_id: i32,
     pub charging_schedule: ChargingScheduleType,

src/v2_0_1/messages/notify_event.rs

@@ -2,11 +2,13 @@ use chrono::DateTime;
 use chrono::Utc;
 
 use crate::v2_0_1::datatypes::event_data_type::EventDataType;
+use crate::v2_0_1::helpers::datetime_rfc3339;
 
 /// This contains the field definition of the NotifyEventRequest PDU sent by the Charging Station to the CSMS.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
 #[serde(rename_all = "camelCase")]
 pub struct NotifyEventRequest {
+    #[serde(with = "datetime_rfc3339 ")]
     pub generated_at: DateTime<Utc>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tbc: Option<bool>,

src/v2_0_1/messages/notify_monitoring_report.rs

@@ -2,6 +2,7 @@ use chrono::DateTime;
 use chrono::Utc;
 
 use crate::v2_0_1::datatypes::monitoring_data_type::MonitoringDataType;
+use crate::v2_0_1::helpers::datetime_rfc3339;
 
 /// This contains the field definition of the NotifyMonitoringRequest PDU sent by the Charging Station to the CSMS.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
@@ -11,6 +12,7 @@ pub struct NotifyMonitoringReportRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tbc: Option<bool>,
     pub seq_no: i32,
+    #[serde(with = "datetime_rfc3339 ")]
     pub generated_at: DateTime<Utc>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub monitor: Option<Vec<MonitoringDataType>>,

src/v2_0_1/messages/notify_report.rs

@@ -2,6 +2,7 @@ use chrono::DateTime;
 use chrono::Utc;
 
 use crate::v2_0_1::datatypes::report_data_type::ReportDataType;
+use crate::v2_0_1::helpers::datetime_rfc3339;
 
 /// This contains the field definition of the NotifyReportRequest PDU sent by the Charging Station to the CSMS.
 #[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Default)]
@@ -11,6 +12,7 @@ pub struct NotifyReportRequest {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tbc: Option<bool>,
     pub seq_no: i32,
+    #[serde(with = "datetime_rfc3339 ")]
     pub generated_at: DateTime<Utc>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub report_data: Option<Vec<ReportDataType>>,