From 51ff465587d7583aab9733c5e12ddd5a23f7f728 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Thu, 8 Aug 2024 15:34:47 -0400 Subject: [PATCH] fix: column typo --- internal/persistence/database.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/persistence/database.go b/internal/persistence/database.go index 5ab613e..6604da8 100644 --- a/internal/persistence/database.go +++ b/internal/persistence/database.go @@ -240,7 +240,7 @@ func (d *DBStore) GetTopicSyncStatus(ctx context.Context, clusterID uint, pubsub } func (d *DBStore) GetMissingMessages(from time.Time, to time.Time, clusterID uint) (map[peer.ID][]pb.MessageHash, error) { - rows, err := d.db.Query("SELECT messageHash, storenode FROM missingMessages WHERE storedAt >= $1 AND storedAt <= $2 AND clusterId = $3 AND msgStatus = 'does_not_exist' AND fundOnRecheck = false", from.UnixNano(), to.UnixNano(), clusterID) + rows, err := d.db.Query("SELECT messageHash, storenode FROM missingMessages WHERE storedAt >= $1 AND storedAt <= $2 AND clusterId = $3 AND msgStatus = 'does_not_exist' AND foundOnRecheck = false", from.UnixNano(), to.UnixNano(), clusterID) if err != nil { return nil, err }