fix state check (#1853)

faros-ai · Dec 11, 2024 · 61bb7f9 · 61bb7f9
1 parent 9aef880
commit 61bb7f9
Showing 1 changed file with 14 additions and 8 deletions.
diff --git a/sources/tromzo-source/src/streams/findings.ts b/sources/tromzo-source/src/streams/findings.ts
@@ -71,14 +71,20 @@ export class Findings extends AirbyteStreamBase {
     const currentState = Utils.toDate(
       currentStreamState?.[streamSlice.tool]?.cutoff
     );
-    const cutoff =
-      latestRecordCutoff > currentState ? latestRecordCutoff : currentState;
-    return {
-      ...currentStreamState,
-      [streamSlice.tool]: {
-        cutoff: cutoff.getTime(),
-      },
-    };
+    if (!latestRecordCutoff) {
+      return currentStreamState;
+    }
+
+    if (currentState && latestRecordCutoff.getTime() > currentState.getTime()) {
+      return {
+        ...currentStreamState,
+        [streamSlice.tool]: {
+          cutoff: latestRecordCutoff.getTime(),
+        },
+      };
+    }
+
+    return currentStreamState;
   }
 
   private getUpdateRange(cutoff?: number): [Date, Date] {