From d268b2e403bad139ec479bdb7998bc90a1a2b223 Mon Sep 17 00:00:00 2001 From: harsh-98 Date: Thu, 21 Sep 2023 11:01:36 +0700 Subject: [PATCH] fix: limit can't be negative for postgres --- waku/persistence/store.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/waku/persistence/store.go b/waku/persistence/store.go index 2fc8405e..cb7a0ab6 100644 --- a/waku/persistence/store.go +++ b/waku/persistence/store.go @@ -224,7 +224,7 @@ func (d *DBStore) cleanOlderRecords(ctx context.Context) error { // Limit number of records to a max N if d.maxMessages > 0 { start := time.Now() - sqlStmt := `DELETE FROM message WHERE id IN (SELECT id FROM message ORDER BY receiverTimestamp DESC LIMIT -1 OFFSET $1)` + sqlStmt := `DELETE FROM message WHERE id IN (SELECT id FROM message ORDER BY receiverTimestamp DESC OFFSET $1)` _, err := d.db.Exec(sqlStmt, d.maxMessages) if err != nil { d.metrics.RecordError(retPolicyFailure)