From cd629209823371eae38cd1c164fc1e580151469a Mon Sep 17 00:00:00 2001
From: Andrew Chuang <andrewjschuang@gmail.com>
Date: Fri, 21 Mar 2025 18:07:59 -0300
Subject: [PATCH 1/3] recover if shard iterator becomes null

---
 .../new-dynamodb-stream-event.mjs              | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

diff --git a/components/aws/sources/new-dynamodb-stream-event/new-dynamodb-stream-event.mjs b/components/aws/sources/new-dynamodb-stream-event/new-dynamodb-stream-event.mjs
index bf66e08e447d7..8c23bf865a629 100644
--- a/components/aws/sources/new-dynamodb-stream-event/new-dynamodb-stream-event.mjs
+++ b/components/aws/sources/new-dynamodb-stream-event/new-dynamodb-stream-event.mjs
@@ -6,7 +6,7 @@ export default {
   name: "New DynamoDB Stream Event",
   description: "Emit new event when a DynamoDB stream receives new events. [See the docs here](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_streams_GetRecords.html)",
   type: "source",
-  version: "0.0.2",
+  version: "0.0.3",
   dedupe: "unique",
   props: {
     ...common.props,
@@ -36,6 +36,12 @@ export default {
   },
   hooks: {
     async deploy() {
+      await this._getNewShardIterator();
+    },
+  },
+  methods: {
+    ...common.methods,
+    async _getNewShardIterator() {
       const { StreamDescription: streamDescription } = await this.listShards({
         StreamArn: this.stream,
       });
@@ -46,10 +52,8 @@ export default {
         ShardIteratorType: "LATEST",
       });
       this._setShardIterator(shardIterator);
+      return shardIterator;
     },
-  },
-  methods: {
-    ...common.methods,
     _getShardIterator() {
       return this.db.get("shardIterator");
     },
@@ -71,7 +75,7 @@ export default {
       throw new Error("Stream is no longer enabled.");
     }
 
-    const shardIterator = this._getShardIterator();
+    const shardIterator = this._getShardIterator() ?? (await this._getNewShardIterator());
 
     const {
       Records: records, NextShardIterator: nextShardIterator,
@@ -84,6 +88,8 @@ export default {
       this.$emit(record, meta);
     }
 
-    this._setShardIterator(nextShardIterator);
+    if (nextShardIterator) {
+      this._setShardIterator(nextShardIterator);
+    }
   },
 };

From 7299f60150c8b044490ab498e265a391d6f725ed Mon Sep 17 00:00:00 2001
From: Andrew Chuang <andrewjschuang@gmail.com>
Date: Fri, 21 Mar 2025 18:08:15 -0300
Subject: [PATCH 2/3] bump package.json

---
 components/aws/package.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/aws/package.json b/components/aws/package.json
index 2dee0cc912151..11e2480be6f66 100644
--- a/components/aws/package.json
+++ b/components/aws/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/aws",
-  "version": "0.7.5",
+  "version": "0.7.6",
   "description": "Pipedream Aws Components",
   "main": "aws.app.mjs",
   "keywords": [

From 9607f48229108f7f46b56dab99690a850cca9da0 Mon Sep 17 00:00:00 2001
From: Andrew Chuang <andrewjschuang@gmail.com>
Date: Fri, 21 Mar 2025 18:09:34 -0300
Subject: [PATCH 3/3] pnpm

---
 pnpm-lock.yaml | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index e39376605af3e..ab58933ab74c2 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -34336,6 +34336,8 @@ snapshots:
       '@putout/operator-filesystem': 5.0.0(putout@36.13.1(eslint@8.57.1)(typescript@5.6.3))
       '@putout/operator-json': 2.2.0
       putout: 36.13.1(eslint@8.57.1)(typescript@5.6.3)
+    transitivePeerDependencies:
+      - supports-color
 
   '@putout/operator-regexp@1.0.0(putout@36.13.1(eslint@8.57.1)(typescript@5.6.3))':
     dependencies: