Include old updates when necessary.

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

diff --git a/src/serialization.rs b/src/serialization.rs
index 93bd381d39e4b2291b54061c0f9913cc7ae39eb8..7e58b02e5d587a8a2e63a3e41712ac67feb17770 100644 (file)
--- a/src/serialization.rs
+++ b/src/serialization.rs
@@ -187,6 +187,10 @@ pub(super) fn serialize_delta_set(delta_set: DeltaSet, last_sync_timestamp: u32)
                                                record_full_update_in_histograms(&latest_update);
                                                serialization_set.updates.push(UpdateSerialization::Full(latest_update));
                                        }
+                               } else if is_newly_included_announcement {
+                                       if let Some(unannounced_update) = updates.last_update_before_seen {
+                                               serialization_set.updates.push(UpdateSerialization::Full(unannounced_update.update));
+                                       }
                                } else if let Some(flags) = updates.serialization_update_flags {
                                        serialization_set.updates.push(UpdateSerialization::Reminder(scid, flags));
                                }