fix(dynamodb)!: stream records format is unmarshalled (#172)

winglang · Apr 1, 2024 · 602972b · 602972b
1 parent 0440bb8
commit 602972b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 16 deletions.
diff --git a/dynamodb/dynamodb.mjs b/dynamodb/dynamodb.mjs
@@ -53,21 +53,9 @@ const processStreamRecords = async (client, StreamArn, handler, options) => {
             dynamodb: {
               ApproximateCreationDateTime:
                 record.dynamodb.ApproximateCreationDateTime,
-              Keys: record.dynamodb.Keys
-                ? unmarshall(record.dynamodb.Keys, {
-                    wrapNumbers: true,
-                  })
-                : undefined,
-              NewImage: record.dynamodb.NewImage
-                ? unmarshall(record.dynamodb.NewImage, {
-                    wrapNumbers: true,
-                  })
-                : undefined,
-              OldImage: record.dynamodb.OldImage
-                ? unmarshall(record.dynamodb.OldImage, {
-                    wrapNumbers: true,
-                  })
-                : undefined,
+              Keys: record.dynamodb.Keys,
+              NewImage: record.dynamodb.NewImage,
+              OldImage: record.dynamodb.OldImage,
               SequenceNumber: record.dynamodb.SequenceNumber,
               SizeBytes: record.dynamodb.SizeBytes,
               StreamViewType: record.dynamodb.StreamViewType,

diff --git a/dynamodb/package.json b/dynamodb/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@winglibs/dynamodb",
-  "version": "0.0.8",
+  "version": "0.1.0",
   "description": "DynamoDB library for Wing",
   "author": {
     "name": "Cristian Pallarés",