Eventbridge Event Processor

lambda-events/Cargo.toml

@@ -30,7 +30,10 @@ chrono = { version = "0.4.23", default-features = false, features = [
   "serde",
   "std",
 ], optional = true }
-query_map = { version = "^0.7", features = ["serde", "url-query"], optional = true }
+query_map = { version = "^0.7", features = [
+  "serde",
+  "url-query",
+], optional = true }
 flate2 = { version = "1.0.24", optional = true }
 
 [features]
@@ -72,6 +75,7 @@ default = [
   "sns",
   "sqs",
   "streams",
+  "eventbridge",
 ]
 
 activemq = []
@@ -112,3 +116,4 @@ ses = ["chrono"]
 sns = ["chrono", "serde_with"]
 sqs = ["serde_with"]
 streams = []
+eventbridge = ["chrono", "serde_with"]

lambda-events/src/event/eventbridge/mod.rs

@@ -0,0 +1,87 @@
+use chrono::{DateTime, Utc};
+use serde::de::DeserializeOwned;
+use serde::{Deserialize, Serialize};
+use serde_with::serde_as;
+
+#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
+#[serde(rename_all = "kebab-case")]
+pub struct EventBridgeEvent {
+    #[serde(default)]
+    pub version: Option<String>,
+    #[serde(default)]
+    pub id: Option<String>,
+    pub detail_type: String,
+    pub source: String,
+    #[serde(default)]
+    pub account: Option<String>,
+    #[serde(default)]
+    pub time: Option<DateTime<Utc>>,
+    #[serde(default)]
+    pub region: Option<String>,
+    #[serde(default)]
+    pub resources: Option<Vec<String>>,
+    #[serde(default)]
+    pub detail: Option<String>,
+}
+
+#[serde_with::serde_as]
+#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
+#[serde(bound(deserialize = "T: DeserializeOwned"))]
+#[serde(rename_all = "kebab-case")]
+pub struct EventBridgeEventObj<T: Serialize> {
+    #[serde(default)]
+    pub version: Option<String>,
+    #[serde(default)]
+    pub id: Option<String>,
+    pub detail_type: String,
+    pub source: String,
+    #[serde(default)]
+    pub account: Option<String>,
+    #[serde(default)]
+    pub time: Option<DateTime<Utc>>,
+    #[serde(default)]
+    pub region: Option<String>,
+    #[serde(default)]
+    pub resources: Option<Vec<String>>,
+    #[serde_as(as = "serde_with::json::JsonString")]
+    #[serde(bound(deserialize = "T: DeserializeOwned"))]
+    pub detail: T,
+}
+
+#[cfg(test)]
+#[cfg(feature = "eventbridge")]
+mod test {
+    use super::*;
+
+    use serde_json;
+
+    #[test]
+    fn example_eventbridge_obj_event() {
+        #[derive(Serialize, Deserialize, Debug, Eq, PartialEq)]
+        struct CustomStruct {
+            a: String,
+            b: String,
+        }
+
+        let data = include_bytes!("../../fixtures/example-eventbridge-event-obj.json");
+        let parsed: EventBridgeEventObj<CustomStruct> = serde_json::from_slice(data).unwrap();
+
+        assert_eq!(parsed.detail.a, "123");
+        assert_eq!(parsed.detail.b, "456");
+
+        let output: String = serde_json::to_string(&parsed).unwrap();
+        let reparsed: EventBridgeEventObj<CustomStruct> = serde_json::from_slice(output.as_bytes()).unwrap();
+        assert_eq!(parsed, reparsed);
+    }
+
+    #[test]
+    fn example_eventbridge_event() {
+        let data = include_bytes!("../../fixtures/example-eventbridge-event.json");
+        let parsed: EventBridgeEvent = serde_json::from_slice(data).unwrap();
+        assert_eq!(parsed.detail, Some(String::from("String Message")));
+
+        let output: String = serde_json::to_string(&parsed).unwrap();
+        let reparsed: EventBridgeEvent = serde_json::from_slice(output.as_bytes()).unwrap();
+        assert_eq!(parsed, reparsed);
+    }
+}

lambda-events/src/event/mod.rs

@@ -136,3 +136,7 @@ pub mod sqs;
 /// AWS Lambda event definitions for streams.
 #[cfg(feature = "streams")]
 pub mod streams;
+
+/// AWS Lambda event definitions for EventBridge.
+#[cfg(feature = "eventbridge")]
+pub mod eventbridge;

lambda-events/src/fixtures/example-eventbridge-event-obj.json

@@ -0,0 +1,13 @@
+{
+  "version": "0",
+  "id": "6a7e8feb-b491-4cf7-a9f1-bf3703467718",
+  "detail-type": "EC2 Instance State-change Notification",
+  "source": "aws.ec2",
+  "account": "111122223333",
+  "time": "2017-12-22T18:43:48Z",
+  "region": "us-west-1",
+  "resources": [
+    "arn:aws:ec2:us-west-1:123456789012:instance/i-1234567890abcdef0"
+  ],
+  "detail": "{\"a\":\"123\",\"b\":\"456\"}"
+}

lambda-events/src/fixtures/example-eventbridge-event.json

@@ -0,0 +1,13 @@
+{
+  "version": "0",
+  "id": "6a7e8feb-b491-4cf7-a9f1-bf3703467718",
+  "detail-type": "EC2 Instance State-change Notification",
+  "source": "aws.ec2",
+  "account": "111122223333",
+  "time": "2017-12-22T18:43:48Z",
+  "region": "us-west-1",
+  "resources": [
+    "arn:aws:ec2:us-west-1:123456789012:instance/i-1234567890abcdef0"
+  ],
+  "detail": "String Message"
+}

lambda-events/src/lib.rs

@@ -159,3 +159,7 @@ pub use event::sqs;
 /// AWS Lambda event definitions for streams.
 #[cfg(feature = "streams")]
 pub use event::streams;
+
+/// AWS Lambda event definitions for EventBridge.
+#[cfg(feature = "eventbridge")]
+pub use event::eventbridge;