Skip to content

Commit 0ac9345

Browse files
committed
Send full updates whenever the channel announcement is sent.
1 parent 8126ad4 commit 0ac9345

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/serialization.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -140,12 +140,12 @@ pub(super) fn serialize_delta_set(delta_set: DeltaSet, last_sync_timestamp: u32)
140140

141141
let current_announcement_seen = channel_announcement_delta.seen;
142142
let is_new_announcement = current_announcement_seen >= last_sync_timestamp;
143-
let is_newly_updated_announcement = if let Some(first_update_seen) = channel_delta.first_bidirectional_updates_seen {
143+
let is_newly_included_announcement = if let Some(first_update_seen) = channel_delta.first_bidirectional_updates_seen {
144144
first_update_seen >= last_sync_timestamp
145145
} else {
146146
false
147147
};
148-
let send_announcement = is_new_announcement || is_newly_updated_announcement;
148+
let send_announcement = is_new_announcement || is_newly_included_announcement;
149149
if send_announcement {
150150
serialization_set.latest_seen = max(serialization_set.latest_seen, current_announcement_seen);
151151
serialization_set.announcements.push(channel_delta.announcement.unwrap().announcement);
@@ -166,7 +166,7 @@ pub(super) fn serialize_delta_set(delta_set: DeltaSet, last_sync_timestamp: u32)
166166

167167
if updates.last_update_before_seen.is_some() {
168168
let mutated_properties = updates.mutated_properties;
169-
if mutated_properties.len() == 5 {
169+
if mutated_properties.len() == 5 || send_announcement {
170170
// all five values have changed, it makes more sense to just
171171
// serialize the update as a full update instead of as a change
172172
// this way, the default values can be computed more efficiently

0 commit comments

Comments
 (0)