fix: restore start/stop time for reconcileMessagesForFid (#2351)

farcasterxyz · Oct 2, 2024 · 8dfe984 · 8dfe984
1 parent 071ea25
commit 8dfe984
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/.changeset/unlucky-pots-retire.md b/.changeset/unlucky-pots-retire.md
@@ -0,0 +1,5 @@
+---
+"@farcaster/shuttle": patch
+---
+
+fix: restore start/stop times for reconcileMessagesForFid
diff --git a/packages/shuttle/src/shuttle/messageReconciliation.ts b/packages/shuttle/src/shuttle/messageReconciliation.ts
@@ -90,7 +90,7 @@ export class MessageReconciliation {
 
     const hubMessagesByHash: Record<string, Message> = {};
     // First, reconcile messages that are in the hub but not in the database
-    for await (const messages of this.allHubMessagesOfTypeForFid(fid, type)) {
+    for await (const messages of this.allHubMessagesOfTypeForFid(fid, type, startTimestamp, stopTimestamp)) {
       const messageHashes = messages.map((msg) => msg.hash);
 
       if (messageHashes.length === 0) {