projects
/
rapid-gossip-sync-server
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Simplify composite index construction somewhat
[rapid-gossip-sync-server]
/
src
/
persistence.rs
diff --git
a/src/persistence.rs
b/src/persistence.rs
index ceeec9ded12d0b86433e2297a09c15849ead06e1..fcc3f300a34f0fe472df9dcc61f3d54228fcb585 100644
(file)
--- a/
src/persistence.rs
+++ b/
src/persistence.rs
@@
-135,15
+135,13
@@
impl GossipPersister {
}
GossipMessage::ChannelUpdate(update) => {
let scid = update.contents.short_channel_id as i64;
}
GossipMessage::ChannelUpdate(update) => {
let scid = update.contents.short_channel_id as i64;
- let scid_hex = hex_utils::hex_str(&scid.to_be_bytes());
let timestamp = update.contents.timestamp as i64;
let timestamp = update.contents.timestamp as i64;
- let channel_flags = update.contents.flags as i32;
- let direction = channel_flags & 1;
- let disable = (channel_flags & 2) > 0;
+ let direction = (update.contents.flags & 1) == 1;
+ let disable = (update.contents.flags & 2) > 0;
- let composite_index =
format!("{}:{}:{}", scid_hex
, timestamp, direction);
+ let composite_index =
hex_utils::to_composite_index(scid
, timestamp, direction);
let cltv_expiry_delta = update.contents.cltv_expiry_delta as i32;
let htlc_minimum_msat = update.contents.htlc_minimum_msat as i64;
let cltv_expiry_delta = update.contents.cltv_expiry_delta as i32;
let htlc_minimum_msat = update.contents.htlc_minimum_msat as i64;
@@
-174,8
+172,8
@@
impl GossipPersister {
&composite_index,
&scid,
×tamp,
&composite_index,
&scid,
×tamp,
- &
channel_flags
,
- &
(direction == 1)
,
+ &
(update.contents.flags as i32)
,
+ &
direction
,
&disable,
&cltv_expiry_delta,
&htlc_minimum_msat,
&disable,
&cltv_expiry_delta,
&htlc_minimum_msat,