Hotfix/documentdb (#742)

* Fix field types:

- ls_nd must be an AnyDocument
- cluster_time must be optional, because it's new at version 4.0

* Fields bug fix

Author: nichmorgan

lambda-events/src/event/documentdb/events/drop_database_event.rs

@@ -7,7 +7,9 @@ use super::commom_types::{AnyDocument, DatabaseCollection, DocumentId, Timestamp
 pub struct ChangeDropDatabaseEvent {
     #[serde(rename = "_id")]
     id: DocumentId,
-    cluster_time: Timestamp,
+    #[serde(default)]
+    cluster_time: Option<Timestamp>,
+    #[serde(default)]
     #[serde(rename = "lsid")]
     ls_id: Option<AnyDocument>,
     ns: DatabaseCollection,

lambda-events/src/event/documentdb/events/drop_event.rs

@@ -6,7 +6,8 @@ use serde::{Deserialize, Serialize};
 pub struct ChangeDropEvent {
     #[serde(rename = "_id")]
     id: DocumentId,
-    cluster_time: Timestamp,
+    #[serde(default)]
+    cluster_time: Option<Timestamp>,
     #[serde(default)]
     #[serde(rename = "lsid")]
     ls_id: Option<AnyDocument>,

lambda-events/src/event/documentdb/events/insert_event.rs

@@ -13,7 +13,7 @@ pub struct ChangeInsertEvent {
     document_key: DocumentKeyId,
     #[serde(default)]
     #[serde(rename = "lsid")]
-    ls_id: Option<String>,
+    ls_id: Option<AnyDocument>,
     ns: DatabaseCollection,
     //operation_type: String,
     #[serde(default)]

lambda-events/src/event/documentdb/events/replace_event.rs

@@ -12,7 +12,7 @@ pub struct ChangeReplaceEvent {
     document_key: DocumentKeyId,
     #[serde(default)]
     #[serde(rename = "lsid")]
-    ls_id: Option<String>,
+    ls_id: Option<AnyDocument>,
     ns: DatabaseCollection,
     // operation_type: String,
     #[serde(default)]

lambda-events/src/event/documentdb/events/update_event.rs

@@ -2,6 +2,21 @@ use serde::{Deserialize, Serialize};
 
 use super::commom_types::{AnyDocument, DatabaseCollection, DocumentId, DocumentKeyId, Timestamp};
 
+#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
+#[serde(rename_all = "camelCase")]
+pub struct UpdateTruncate {
+    field: String,
+    new_size: usize,
+}
+
+#[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
+#[serde(rename_all = "camelCase")]
+pub struct UpdateDescription {
+    removed_fields: Vec<String>,
+    truncated_arrays: Vec<UpdateTruncate>,
+    updated_fields: AnyDocument,
+}
+
 #[derive(Clone, Debug, Default, Deserialize, Eq, PartialEq, Serialize)]
 #[serde(rename_all = "camelCase")]
 pub struct ChangeUpdateEvent {
@@ -10,10 +25,12 @@ pub struct ChangeUpdateEvent {
     #[serde(default)]
     cluster_time: Option<Timestamp>,
     document_key: DocumentKeyId,
+    #[serde(default)]
     #[serde(rename = "lsid")]
-    ls_id: Option<String>,
+    ls_id: Option<AnyDocument>,
     ns: DatabaseCollection,
     // operation_type: String,
+    update_description: UpdateDescription,
     #[serde(default)]
     txn_number: Option<AnyDocument>,
 }

lambda-events/src/fixtures/example-documentdb-update-event.json

@@ -1,29 +1,43 @@
 {
-    "eventSourceArn": "arn:aws:rds:us-east-1:123456789012:cluster:canaryclusterb2a659a2-qo5tcmqkcl03",
-    "events": [
-      {
-        "event": {
+  "eventSourceArn": "arn:aws:rds:us-east-1:123456789012:cluster:canaryclusterb2a659a2-qo5tcmqkcl03",
+  "events": [
+    {
+      "event": {
+        "_id": {
+          "_data": "0163eeb6e7000000090100000009000041e1"
+        },
+        "operationType": "update",
+        "clusterTime": {
+          "$timestamp": {
+            "t": 1676588775,
+            "i": 9
+          }
+        },
+        "ns": {
+          "db": "test_database",
+          "coll": "test_collection"
+        },
+        "documentKey": {
           "_id": {
-            "_data": "0163eeb6e7000000090100000009000041e1"
+            "$oid": "63eeb6e7d418cd98afb1c1d7"
+          }
+        },
+        "updateDescription": {
+          "updatedFields": {
+            "email": "alice@10gen.com"
           },
-          "clusterTime": {
-            "$timestamp": {
-              "t": 1676588775,
-              "i": 9
+          "removedFields": [
+            "phoneNumber"
+          ],
+          "truncatedArrays": [
+            {
+              "field": "vacation_time",
+              "newSize": 36
             }
-          },
-          "documentKey": {
-            "_id": {
-              "$oid": "63eeb6e7d418cd98afb1c1d7"
-            }
-          },
-          "ns": {
-            "db": "test_database",
-            "coll": "test_collection"
-          },
-          "operationType": "update"
+          ]
         }
       }
-    ],
-    "eventSource": "aws:docdb"
-  }
+    }
+  ],
+  "eventSource": "aws:docdb"
+}