X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Flookup.rs;h=8018e5ca19d62a5b564b9f40a777f2aad18100b3;hb=7895189f7922cb60bde7627c04e0da840b9735aa;hp=6429d5c9371cbc3b988cc57411de585771d8c56e;hpb=f739c3112576469fe79f77c9777936608b1cfebc;p=rapid-gossip-sync-server

diff --git a/src/lookup.rs b/src/lookup.rs
index 6429d5c..8018e5c 100644
--- 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();