fix: checkpoint query

Signed-off-by: Clément Salaün <[email protected]>
formancehq · Feb 5, 2024 · b37dff6 · b37dff6
1 parent b5907d6
commit b37dff6
Showing 1 changed file with 9 additions and 1 deletion.
diff --git 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
 	}