From 34b00ee852e83c4d7c3dc9b5c66a4f0d47230f41 Mon Sep 17 00:00:00 2001
From: David Boyne <boyneyy123@gmail.com>
Date: Mon, 30 Sep 2024 17:59:11 +0100
Subject: [PATCH] fix(winglib): set default value for dynamodb winglib starting
 position on stream

---
 dynamodb/dynamodb.tf-aws.w | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/dynamodb/dynamodb.tf-aws.w b/dynamodb/dynamodb.tf-aws.w
index 4c622b8c..468c09a5 100644
--- a/dynamodb/dynamodb.tf-aws.w
+++ b/dynamodb/dynamodb.tf-aws.w
@@ -76,6 +76,9 @@ pub class Table_tfaws impl dynamodb_types.ITable {
   }
 
   pub setStreamConsumer(handler: inflight (dynamodb_types.StreamRecord): void, options: dynamodb_types.StreamConsumerOptions?) {
+
+    let startingPosition = options?.startingPosition ?? "LATEST";
+
     let consumer = new cloud.Function(inflight (eventStr) => {
       let event: DynamoDBStreamEvent = unsafeCast(eventStr);
       for record in event.Records {
@@ -120,7 +123,7 @@ pub class Table_tfaws impl dynamodb_types.ITable {
           eventSourceArn: this.table.streamArn,
           functionName: lambda.functionName,
           batchSize: options?.batchSize,
-          startingPosition: options?.startingPosition,
+          startingPosition,
           // filterCriteria: unsafeCast(options?.filterCriteria),
         },
       );