- let reference_rows = client.query("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 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();
+ let reference_rows = client.query("
+ 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
+ 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();