use tokio::sync::mpsc;
use tokio_postgres::NoTls;
-use crate::{config, hex_utils, TestLogger};
+use crate::{config, TestLogger};
use crate::types::GossipMessage;
pub(crate) struct GossipPersister {
let direction = (update.contents.flags & 1) == 1;
let disable = (update.contents.flags & 2) > 0;
- 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 fee_base_msat = update.contents.fee_base_msat as i32;
let result = client
.execute("INSERT INTO channel_updates (\
- composite_index, \
short_channel_id, \
timestamp, \
channel_flags, \
fee_proportional_millionths, \
htlc_maximum_msat, \
blob_signed \
- ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) ON CONFLICT (composite_index) DO NOTHING", &[
- &composite_index,
+ ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11) ON CONFLICT DO NOTHING", &[
&scid,
×tamp,
&(update.contents.flags as i16),