From 85b081094796e3f2acade5a748cf3dfbca40e103 Mon Sep 17 00:00:00 2001
From: David Boyne <boyneyy123@gmail.com>
Date: Mon, 30 Sep 2024 19:34:39 +0100
Subject: [PATCH] =?UTF-8?q?fix(winglib):=20set=20default=20value=20for=20d?=
 =?UTF-8?q?ynamodb=20winglib=20starting=20positio=E2=80=A6=20(#324)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 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),
         },
       );