aws-lambda-stream - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

lib/from/dynamodb.js

@@ -19,3 +19,4 @@ "use strict";
   ignoreTtlExpiredEvents = false,
-  ignoreReplicas = true
+  ignoreReplicas = true,
+  preferApproximateTimestamp = false
 } = {}) =>
@@ -47,3 +48,3 @@ // eslint-disable-line import/prefer-default-export
     partitionKey: record.dynamodb.Keys[pkFn].S,
-    timestamp: deriveTimestamp(record),
+    timestamp: deriveTimestamp(record, preferApproximateTimestamp),
     tags: {
@@ -96,3 +97,9 @@ region: record.awsRegion
 };
-const deriveTimestamp = record => parseInt(record.dynamodb.NewImage?.timestamp?.N, 10) || ddbApproximateCreationTimestamp(record);
+const deriveTimestamp = (record, preferApproximateTimestamp) => {
+  if (preferApproximateTimestamp) {
+    return ddbApproximateCreationTimestamp(record);
+  } else {
+    return parseInt(record.dynamodb.NewImage?.timestamp?.N, 10) || ddbApproximateCreationTimestamp(record);
+  }
+};
 const ddbApproximateCreationTimestamp = record => record.dynamodb.ApproximateCreationDateTime * 1000;
@@ -99,0 +106,0 @@

package.json

 {
   "name": "aws-lambda-stream",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "description": "Create stream processors with AWS Lambda functions.",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

249403

0.09%

Lines of code

6044

0.12%

No dependency changes