use std::io::BufReader;
use std::ops::Deref;
use std::sync::Arc;
+use bitcoin::blockdata::constants::ChainHash;
use lightning::log_info;
use lightning::routing::gossip::{NetworkGraph, NodeId};
use lightning::util::ser::{ReadableArgs, Writeable};
use tokio::sync::mpsc;
use tokio_postgres::{Client, NoTls};
+use crate::config::SYMLINK_GRANULARITY_INTERVAL;
use crate::lookup::DeltaSet;
use crate::persistence::GossipPersister;
pub mod types;
+#[cfg(test)]
+mod tests;
+
/// The purpose of this prefix is to identify the serialization format, should other rapid gossip
/// sync formats arise in the future.
///
}
pub async fn start_sync(&self) {
+ log_info!(self.logger, "Starting Rapid Gossip Sync Server");
+ log_info!(self.logger, "Snapshot interval: {} seconds", config::snapshot_generation_interval());
+
// means to indicate sync completion status within this module
let (sync_completion_sender, mut sync_completion_receiver) = mpsc::channel::<()>(1);
}
});
+ #[cfg(test)]
+ {
+ let schema_name = tests::db_test_schema();
+ let schema_creation_command = format!("CREATE SCHEMA IF NOT EXISTS {}", schema_name);
+ client.execute(&schema_creation_command, &[]).await.unwrap();
+ client.execute(&format!("SET search_path TO {}", schema_name), &[]).await.unwrap();
+ }
+
client.execute("set time zone UTC", &[]).await.unwrap();
client
}
let mut blob = GOSSIP_PREFIX.to_vec();
let network = config::network();
- let calc_interval = config::calculate_interval();
- let genesis_block = bitcoin::blockdata::constants::genesis_block(network);
- let chain_hash = genesis_block.block_hash();
+ let chain_hash = ChainHash::using_genesis_block(network);
chain_hash.write(&mut blob).unwrap();
- let blob_timestamp = Snapshotter::<Arc<RGSSLogger>>::round_down_to_nearest_multiple(current_timestamp, calc_interval as u64) as u32;
+ let blob_timestamp = Snapshotter::<Arc<RGSSLogger>>::round_down_to_nearest_multiple(current_timestamp, SYMLINK_GRANULARITY_INTERVAL as u64) as u32;
blob_timestamp.write(&mut blob).unwrap();
0u32.write(&mut blob).unwrap(); // node count
network_graph.remove_stale_channels_and_tracking();
let mut output: Vec<u8> = vec![];
- let calc_interval = config::calculate_interval();
+ let snapshot_interval = config::snapshot_generation_interval();
// set a flag if the chain hash is prepended
// chain hash only necessary if either channel announcements or non-incremental updates are present
serialization_details.chain_hash.write(&mut prefixed_output).unwrap();
// always write the latest seen timestamp
let latest_seen_timestamp = serialization_details.latest_seen;
- let overflow_seconds = latest_seen_timestamp % calc_interval;
+ let overflow_seconds = latest_seen_timestamp % snapshot_interval;
let serialized_seen_timestamp = latest_seen_timestamp.saturating_sub(overflow_seconds);
serialized_seen_timestamp.write(&mut prefixed_output).unwrap();