Trigger full sync on old GossipTimestampFilter

Author: arik-so

lightning/src/ln/peer_handler.rs

@@ -509,9 +509,18 @@ impl fmt::Display for PeerHandleError {
 	}
 }
 
+/// Internal struct for keeping track of the gossip syncing progress with a given peer
 enum InitSyncTracker{
+	/// Only sync ad-hoc gossip as it comes in, do not send historical gossip.
+	/// Upon receipt of a GossipTimestampFilter message, this is the default initial state if the
+	/// contained timestamp is less than 6 hours old.
 	NoSyncRequested,
+	/// Send historical gossip starting at the given channel id, which gets incremented as the
+	/// gossiping progresses.
+	/// Upon receipt of a GossipTimestampFilter message, this is the default initial state if the
+	/// contained timestamp is at least 6 hours old, and the initial channel id is set to 0.
 	ChannelsSyncing(u64),
+	/// Once the channel announcements and updates finish syncing, the node announcements are synced.
 	NodesSyncing(NodeId),
 }
 
@@ -1721,13 +1730,26 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
 			return Err(PeerHandleError { }.into());
 		}
 
-		if let wire::Message::GossipTimestampFilter(_msg) = message {
+		if let wire::Message::GossipTimestampFilter(msg) = message {
 			// When supporting gossip messages, start initial gossip sync only after we receive
 			// a GossipTimestampFilter
+
 			if peer_lock.their_features.as_ref().unwrap().supports_gossip_queries() &&
 				!peer_lock.sent_gossip_timestamp_filter {
 				peer_lock.sent_gossip_timestamp_filter = true;
-				peer_lock.sync_status = InitSyncTracker::ChannelsSyncing(0);
+
+				#[allow(unused_mut, unused_assignments)]
+				let mut full_sync_threshold = 0;
+				#[cfg(feature = "std")]
+				{
+					// if the timestamp range starts more than six hours ago, do a full sync
+					// otherwise, start at the current time
+					use std::time::{SystemTime, UNIX_EPOCH};
+					full_sync_threshold = SystemTime::now().duration_since(UNIX_EPOCH).expect("Time must be > 1970").as_secs() - 6 * 3600;
+				}
+				if (msg.first_timestamp as u64) <= full_sync_threshold {
+					peer_lock.sync_status = InitSyncTracker::ChannelsSyncing(0);
+				}
 			}
 			return Ok(None);
 		}