From 8dfe98437f8a1143d6f8a356a2a94e0c6e9b2062 Mon Sep 17 00:00:00 2001 From: Cassandra Heart <7929478+CassOnMars@users.noreply.github.com> Date: Wed, 2 Oct 2024 15:37:17 -0700 Subject: [PATCH] fix: restore start/stop time for reconcileMessagesForFid (#2351) --- .changeset/unlucky-pots-retire.md | 5 +++++ packages/shuttle/src/shuttle/messageReconciliation.ts | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) create mode 100644 .changeset/unlucky-pots-retire.md diff --git a/.changeset/unlucky-pots-retire.md b/.changeset/unlucky-pots-retire.md new file mode 100644 index 0000000000..2c273ceedc --- /dev/null +++ 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 index ecea29d88f..9c60aabf10 100644 --- a/packages/shuttle/src/shuttle/messageReconciliation.ts +++ b/packages/shuttle/src/shuttle/messageReconciliation.ts @@ -90,7 +90,7 @@ export class MessageReconciliation { const hubMessagesByHash: Record = {}; // 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) {