Allow empty ConnectQueue

aws_lambda_events/src/connect/mod.rs

@@ -59,8 +59,8 @@ pub struct ConnectContactData {
     #[serde(default)]
     #[serde(rename = "PreviousContactId")]
     pub previous_contact_id: Option<String>,
-    #[serde(rename = "Queue")]
-    pub queue: ConnectQueue,
+    #[serde(rename = "Queue", default)]
+    pub queue: Option<ConnectQueue>,
     #[serde(rename = "SystemEndpoint")]
     pub system_endpoint: ConnectEndpoint,
     #[serde(deserialize_with = "deserialize_lambda_string")]
@@ -114,4 +114,14 @@ mod test {
         let reparsed: ConnectEvent = serde_json::from_slice(output.as_bytes()).unwrap();
         assert_eq!(parsed, reparsed);
     }
+
+    #[test]
+    #[cfg(feature = "connect")]
+    fn example_connect_event_without_queue() {
+        let data = include_bytes!("../fixtures/example-connect-event-without-queue.json");
+        let parsed: ConnectEvent = serde_json::from_slice(data).unwrap();
+        let output: String = serde_json::to_string(&parsed).unwrap();
+        let reparsed: ConnectEvent = serde_json::from_slice(output.as_bytes()).unwrap();
+        assert_eq!(parsed, reparsed);
+    }
 }

aws_lambda_events/src/fixtures/example-connect-event-without-queue.json

@@ -0,0 +1,29 @@
+{
+   "Name": "ContactFlowExecution",
+   "Details": {
+      "Parameters": {
+         "key1": "value1",
+         "key2": "value2"
+      },
+      "ContactData": {
+         "ContactId": "ASDAcxcasDFSSDFs",
+         "InitialContactId": "Acxsada-asdasdaxA",
+         "PreviousContactId": "Acxsada-asdasdaxA",
+         "Channel": "Voice",
+         "InstanceARN": "",
+         "InitiationMethod": "INBOUND/OUTBOUND/TRANSFER/CALLBACK",
+         "SystemEndpoint": {
+            "Type": "TELEPHONE_NUMBER",
+            "Address": "01234567"
+         },
+         "CustomerEndpoint": {
+            "Type": "TELEPHONE_NUMBER",
+            "Address": "+14802021091"
+         },
+         "Attributes": {
+            "key1": "value",
+            "key2": "value"
+         }
+      }
+   }
+}

aws_lambda_events/src/fixtures/example-connect-event.json

@@ -1,35 +1,33 @@
-{  
-   "Name":"ContactFlowExecution",
-   "Details":{  
-      "Parameters":{  
-         "key1":"value1",
-         "key2":"value2"
+{
+   "Name": "ContactFlowExecution",
+   "Details": {
+      "Parameters": {
+         "key1": "value1",
+         "key2": "value2"
       },
-      "ContactData":{  
-         "ContactId":"ASDAcxcasDFSSDFs",
-         "InitialContactId":"Acxsada-asdasdaxA", 
-         "PreviousContactId":"Acxsada-asdasdaxA", 
-         "Channel":"Voice",
+      "ContactData": {
+         "ContactId": "ASDAcxcasDFSSDFs",
+         "InitialContactId": "Acxsada-asdasdaxA",
+         "PreviousContactId": "Acxsada-asdasdaxA",
+         "Channel": "Voice",
          "InstanceARN": "",
-         "InitiationMethod":"INBOUND/OUTBOUND/TRANSFER/CALLBACK",
-         "SystemEndpoint":{   
-            "Type":"TELEPHONE_NUMBER",
-            "Address":"01234567"
+         "InitiationMethod": "INBOUND/OUTBOUND/TRANSFER/CALLBACK",
+         "SystemEndpoint": {
+            "Type": "TELEPHONE_NUMBER",
+            "Address": "01234567"
          },
-         "CustomerEndpoint":{  
-            "Type":"TELEPHONE_NUMBER",
-            "Address":"+14802021091" 
-         }, 
-         "Queue" : {  
-             "Name":"PrimaryPhoneQueue", 
-              "ARN" : ""
+         "CustomerEndpoint": {
+            "Type": "TELEPHONE_NUMBER",
+            "Address": "+14802021091"
          },
-
-         "Attributes":{   
-            "key1":"value",
-            "key2":"value"
+         "Queue": {
+            "Name": "PrimaryPhoneQueue",
+            "ARN": ""
+         },
+         "Attributes": {
+            "key1": "value",
+            "key2": "value"
          }
       }
    }
-}
-
+}