Redo indexes for new SELECTs and trivially tweak one old query

[rapid-gossip-sync-server] / src / lookup.rs

diff --git a/src/lookup.rs b/src/lookup.rs
index 6429d5c9371cbc3b988cc57411de585771d8c56e..8018e5ca19d62a5b564b9f40a777f2aad18100b3 100644 (file)
--- a/src/lookup.rs
+++ b/src/lookup.rs
@@ -212,10 +212,9 @@ pub(super) async fn fetch_channel_updates(delta_set: &mut DeltaSet, client: &Cli
                SELECT DISTINCT ON (short_channel_id, direction) id, direction, blob_signed
                FROM channel_updates
                WHERE seen < $1 AND short_channel_id IN (
-                       SELECT short_channel_id
+                       SELECT DISTINCT ON (short_channel_id) short_channel_id
                        FROM channel_updates
                        WHERE seen >= $1
-                       GROUP BY short_channel_id
                )
                ORDER BY short_channel_id ASC, direction ASC, seen DESC
                ", &[&last_sync_timestamp_object]).await.unwrap();