From b37dff6eb4c99e3bb68c80527607364d56fd2e38 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Sala=C3=BCn?= Date: Mon, 5 Feb 2024 18:54:05 +0100 Subject: [PATCH] fix: checkpoint query MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Clément Salaün --- pkg/storage/sqlstorage/transactions.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/pkg/storage/sqlstorage/transactions.go b/pkg/storage/sqlstorage/transactions.go index 6e4e84380..001e48623 100644 --- a/pkg/storage/sqlstorage/transactions.go +++ b/pkg/storage/sqlstorage/transactions.go @@ -123,7 +123,15 @@ func (s *Store) buildTransactionsQuery(flavor Flavor, p ledger.TransactionsQuery if !endTime.IsZero() { sb.Where(sb.L("timestamp", endTime.UTC())) sub := sqlbuilder.NewSelectBuilder() - sb.Where(sb.In("id", sub.Select("txid").From(s.schema.Table("accounts_checkpoints")).Where(sub.L("last_tx_at", endTime.UTC())))) + sb.Where( + sb.In( + "id", + sub.Select("txid"). + From(s.schema.Table("accounts_checkpoints")). + Where(sub.LE("last_tx_at", endTime.UTC())). + OrderBy("last_tx_at").Desc(), + ), + ) t.EndTime = endTime }