Started sketching the Event data structure

Implemented 1.0 Attributes

Fixed data read/write methods
Added extensions creators

Signed-off-by: Francesco Guardiani <[email protected]>

Author: slinkydeveloper

Cargo.lock

@@ -7,3 +7,7 @@ edition = "2018"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+serde = { version = "^1.0", features = ["derive"] }
+serde_json = "^1.0"
+chrono = { version = "^0.4", features = ["serde"] }
+delegate = "^0.4"

Cargo.toml

@@ -0,0 +1,170 @@
+use super::SpecVersion;
+use crate::event::{AttributesV10, ExtensionValue};
+use chrono::{DateTime, FixedOffset};
+
+pub trait AttributesReader {
+    fn get_id(&self) -> &str;
+    fn get_source(&self) -> &str;
+    fn get_specversion(&self) -> SpecVersion;
+    fn get_type(&self) -> &str;
+    fn get_datacontenttype(&self) -> Option<&str>;
+    fn get_dataschema(&self) -> Option<&str>;
+    fn get_subject(&self) -> Option<&str>;
+    fn get_time(&self) -> Option<&DateTime<FixedOffset>>;
+    fn get_extension(&self, extension_name: &str) -> Option<&ExtensionValue>;
+    fn get_extensions(&self) -> Vec<(&str, &ExtensionValue)>;
+}
+
+pub trait AttributesWriter {
+    fn set_id<'event>(&'event mut self, id: impl Into<&'event str>);
+    fn set_source<'event>(&'event mut self, source: impl Into<&'event str>);
+    fn set_type<'event>(&'event mut self, ty: impl Into<&'event str>);
+    fn set_datacontenttype<'event>(
+        &'event mut self,
+        datacontenttype: Option<impl Into<&'event str>>,
+    );
+    fn set_dataschema<'event>(&'event mut self, dataschema: Option<impl Into<&'event str>>);
+    fn set_subject<'event>(&'event mut self, subject: Option<impl Into<&'event str>>);
+    fn set_time<'event>(&'event mut self, time: Option<impl Into<DateTime<FixedOffset>>>);
+    fn set_extension<'event>(
+        &'event mut self,
+        extension_name: &'event str,
+        extension_value: impl Into<ExtensionValue>,
+    );
+    fn remove_extension<'event>(
+        &'event mut self,
+        extension_name: &'event str,
+    ) -> Option<ExtensionValue>;
+}
+
+pub enum Attributes {
+    V10(AttributesV10),
+}
+
+impl AttributesReader for Attributes {
+    fn get_id(&self) -> &str {
+        match self {
+            Attributes::V10(a) => a.get_id(),
+        }
+    }
+
+    fn get_type(&self) -> &str {
+        match self {
+            Attributes::V10(a) => a.get_type(),
+        }
+    }
+
+    fn get_source(&self) -> &str {
+        match self {
+            Attributes::V10(a) => a.get_source(),
+        }
+    }
+
+    fn get_specversion(&self) -> SpecVersion {
+        match self {
+            Attributes::V10(a) => a.get_specversion(),
+        }
+    }
+
+    fn get_datacontenttype(&self) -> Option<&str> {
+        match self {
+            Attributes::V10(a) => a.get_datacontenttype(),
+        }
+    }
+
+    fn get_dataschema(&self) -> Option<&str> {
+        match self {
+            Attributes::V10(a) => a.get_dataschema(),
+        }
+    }
+
+    fn get_subject(&self) -> Option<&str> {
+        match self {
+            Attributes::V10(a) => a.get_subject(),
+        }
+    }
+
+    fn get_time(&self) -> Option<&DateTime<FixedOffset>> {
+        match self {
+            Attributes::V10(a) => a.get_time(),
+        }
+    }
+
+    fn get_extension(&self, extension_name: &str) -> Option<&ExtensionValue> {
+        match self {
+            Attributes::V10(a) => a.get_extension(extension_name),
+        }
+    }
+
+    fn get_extensions(&self) -> Vec<(&str, &ExtensionValue)> {
+        match self {
+            Attributes::V10(a) => a.get_extensions(),
+        }
+    }
+}
+
+impl AttributesWriter for Attributes {
+    fn set_id<'event>(&'event mut self, id: impl Into<&'event str>) {
+        match self {
+            Attributes::V10(a) => a.set_id(id),
+        }
+    }
+
+    fn set_type<'event>(&'event mut self, ty: impl Into<&'event str>) {
+        match self {
+            Attributes::V10(a) => a.set_type(ty),
+        }
+    }
+
+    fn set_source<'event>(&'event mut self, source: impl Into<&'event str>) {
+        match self {
+            Attributes::V10(a) => a.set_source(source),
+        }
+    }
+
+    fn set_datacontenttype<'event>(
+        &'event mut self,
+        datacontenttype: Option<impl Into<&'event str>>,
+    ) {
+        match self {
+            Attributes::V10(a) => a.set_datacontenttype(datacontenttype),
+        }
+    }
+
+    fn set_extension<'event>(
+        &'event mut self,
+        extension_name: &'event str,
+        extension_value: impl Into<ExtensionValue>,
+    ) {
+        match self {
+            Attributes::V10(a) => a.set_extension(extension_name, extension_value),
+        }
+    }
+
+    fn remove_extension<'event>(
+        &'event mut self,
+        extension_name: &'event str,
+    ) -> Option<ExtensionValue> {
+        match self {
+            Attributes::V10(a) => a.remove_extension(extension_name),
+        }
+    }
+
+    fn set_dataschema<'event>(&'event mut self, dataschema: Option<impl Into<&'event str>>) {
+        match self {
+            Attributes::V10(a) => a.set_dataschema(dataschema),
+        }
+    }
+
+    fn set_subject<'event>(&'event mut self, subject: Option<impl Into<&'event str>>) {
+        match self {
+            Attributes::V10(a) => a.set_subject(subject),
+        }
+    }
+
+    fn set_time<'event>(&'event mut self, time: Option<impl Into<DateTime<FixedOffset>>>) {
+        match self {
+            Attributes::V10(a) => a.set_time(time),
+        }
+    }
+}