Merge branch '3194-redis-idempotency-doc' of github.com:arnabrahman/aws-lambda-powertools-typescript into 3194-redis-idempotency-doc

Author: dreamorosi

.github/workflows/ossf_scorecard.yml

@@ -43,6 +43,6 @@ jobs:
 
       # Upload the results to GitHub's code scanning dashboard.
       - name: "Upload to code-scanning"
-        uses: github/codeql-action/upload-sarif@60168efe1c415ce0f5521ea06d5c2062adbeed1b # v3.28.17
+        uses: github/codeql-action/upload-sarif@ff0a06e83cb2de871e5a09832bc6a81e7276941f # v3.28.18
         with:
           sarif_file: results.sarif

examples/app/package.json

@@ -30,7 +30,7 @@
   "devDependencies": {
     "@types/aws-lambda": "^8.10.149",
     "@types/node": "22.15.18",
-    "aws-cdk-lib": "^2.195.0",
+    "aws-cdk-lib": "^2.196.0",
     "constructs": "^10.4.2",
     "source-map-support": "^0.5.21",
     "tsx": "^4.19.4",
@@ -49,7 +49,7 @@
     "@middy/core": "^4.7.0",
     "@types/aws-lambda": "^8.10.149",
     "@types/node": "22.15.18",
-    "aws-cdk": "^2.1015.0",
+    "aws-cdk": "^2.1016.0",
     "constructs": "^10.4.2",
     "esbuild": "^0.25.4",
     "typescript": "^5.8.3"

layers/package.json

@@ -40,8 +40,8 @@
     "source-map-support": "^0.5.21"
   },
   "dependencies": {
-    "aws-cdk": "^2.1015.0",
-    "aws-cdk-lib": "^2.195.0",
+    "aws-cdk": "^2.1016.0",
+    "aws-cdk-lib": "^2.196.0",
     "esbuild": "^0.25.4",
     "tsx": "^4.19.4"
   }

package-lock.json

@@ -151,69 +151,103 @@ const DynamoDBStreamToKinesisRecord = DynamoDBStreamRecord.extend({
  * @example
  * ```json
  * {
- *   "Records": [
- *     {
- *       "eventID": "1",
- *       "eventVersion": "1.0",
- *       "dynamodb": {
- *         "ApproximateCreationDateTime": 1693997155.0,
- *         "Keys": {
- *           "Id": {
- *             "N": "101"
- *           }
- *         },
- *         "NewImage": {
- *           "Message": {
- *             "S": "New item!"
- *           },
- *           "Id": {
- *             "N": "101"
- *           }
+ *   "Records":[{
+ *     "eventID":"1",
+ *     "eventName":"INSERT",
+ *     "eventVersion":"1.0",
+ *     "eventSource":"aws:dynamodb",
+ *     "awsRegion":"us-east-1",
+ *     "dynamodb":{
+ *       "Keys":{
+ *         "Id":{
+ *           "N":"101"
+ *         }
+ *       },
+ *       "NewImage":{
+ *         "Message":{
+ *           "S":"New item!"
  *         },
- *         "StreamViewType": "NEW_AND_OLD_IMAGES",
- *         "SequenceNumber": "111",
- *         "SizeBytes": 26
+ *         "Id":{
+ *           "N":"101"
+ *         }
  *       },
- *       "awsRegion": "us-west-2",
- *       "eventName": "INSERT",
- *       "eventSourceARN": "eventsource_arn",
- *       "eventSource": "aws:dynamodb"
+ *       "SequenceNumber":"111",
+ *       "SizeBytes":26,
+ *       "StreamViewType":"NEW_AND_OLD_IMAGES"
  *     },
- *     {
- *       "eventID": "2",
- *       "eventVersion": "1.0",
- *       "dynamodb": {
- *         "OldImage": {
- *           "Message": {
- *             "S": "New item!"
- *           },
- *           "Id": {
- *             "N": "101"
- *           }
+ *     "eventSourceARN":"stream-ARN"
+ *   },
+ *   {
+ *     "eventID":"2",
+ *     "eventName":"MODIFY",
+ *     "eventVersion":"1.0",
+ *     "eventSource":"aws:dynamodb",
+ *     "awsRegion":"us-east-1",
+ *     "dynamodb":{
+ *       "Keys":{
+ *         "Id":{
+ *           "N":"101"
+ *         }
+ *       },
+ *       "NewImage":{
+ *         "Message":{
+ *           "S":"This item has changed"
  *         },
- *         "SequenceNumber": "222",
- *         "Keys": {
- *           "Id": {
- *             "N": "101"
- *           }
+ *         "Id":{
+ *           "N":"101"
+ *         }
+ *       },
+ *       "OldImage":{
+ *         "Message":{
+ *           "S":"New item!"
  *         },
- *         "SizeBytes": 59,
- *         "NewImage": {
- *           "Message": {
- *             "S": "This item has changed"
- *           },
- *           "Id": {
- *             "N": "101"
- *           }
+ *         "Id":{
+ *           "N":"101"
+ *         }
+ *       },
+ *       "SequenceNumber":"222",
+ *       "SizeBytes":59,
+ *       "StreamViewType":"NEW_AND_OLD_IMAGES"
+ *     },
+ *     "eventSourceARN":"stream-ARN"
+ *   },
+ *   {
+ *     "eventID":"3",
+ *     "eventName":"REMOVE",
+ *     "eventVersion":"1.0",
+ *     "eventSource":"aws:dynamodb",
+ *     "awsRegion":"us-east-1",
+ *     "dynamodb":{
+ *       "Keys":{
+ *         "Id":{
+ *           "N":"101"
+ *         }
+ *       },
+ *       "OldImage":{
+ *         "Message":{
+ *           "S":"This item has changed"
  *         },
- *         "StreamViewType": "NEW_AND_OLD_IMAGES"
+ *         "Id":{
+ *           "N":"101"
+ *         }
  *       },
- *       "awsRegion": "us-west-2",
- *       "eventName": "MODIFY",
- *       "eventSourceARN": "source_arn",
- *       "eventSource": "aws:dynamodb"
- *     }
- *   ]
+ *       "SequenceNumber":"333",
+ *       "SizeBytes":38,
+ *       "StreamViewType":"NEW_AND_OLD_IMAGES"
+ *     },
+ *     "eventSourceARN":"stream-ARN"
+ *   }],
+ *   "window": {
+ *     "start": "2020-07-30T17:00:00Z",
+ *     "end": "2020-07-30T17:05:00Z"
+ *   },
+ *   "state": {
+ *     "1": "state1"
+ *   },
+ *   "shardId": "shard123456789",
+ *   "eventSourceARN": "stream-ARN",
+ *   "isFinalInvokeForWindow": false,
+ *   "isWindowTerminatedEarly": false
  * }
  * ```
  *
@@ -222,6 +256,17 @@ const DynamoDBStreamToKinesisRecord = DynamoDBStreamRecord.extend({
  */
 const DynamoDBStreamSchema = z.object({
   Records: z.array(DynamoDBStreamRecord).min(1),
+  window: z
+    .object({
+      start: z.string().datetime(),
+      end: z.string().datetime(),
+    })
+    .optional(),
+  state: z.record(z.string(), z.string()).optional(),
+  shardId: z.string().optional(),
+  eventSourceARN: z.string().optional(),
+  isFinalInvokeForWindow: z.boolean().optional(),
+  isWindowTerminatedEarly: z.boolean().optional(),
 });
 
 export {