Event::PendingHTLCsForwardable { time_forwardable } => {
let forwarding_channel_manager = loop_channel_manager.clone();
tokio::spawn(async move {
- let min = time_forwardable.as_secs();
- let seconds_to_sleep = thread_rng().gen_range(min, min * 5);
- tokio::time::sleep(Duration::from_secs(seconds_to_sleep)).await;
+ let min = time_forwardable.as_millis() as u64;
+ let millis_to_sleep = thread_rng().gen_range(min, min * 5) as u64;
+ tokio::time::sleep(Duration::from_millis(millis_to_sleep)).await;
forwarding_channel_manager.process_pending_htlc_forwards();
});
}
)
.unwrap();
bitcoind_client.broadcast_transaction(&spending_tx);
- // XXX maybe need to rescan and blah?
}
}
}
}
}
-#[tokio::main]
-pub async fn main() {
+async fn start_ldk() {
let args = match cli::parse_startup_args() {
Ok(user_args) => user_args,
Err(()) => return,
)
.await;
}
+
+#[tokio::main]
+pub async fn main() {
+ start_ldk().await;
+}