Move startup to separate from `main` for better errors
[ldk-sample] / src / main.rs
index ab9508672d6483ac82384eef39fa49d3492a62d7..5f5dc0af87324ba4bf416829d8ea2fa1446036b0 100644 (file)
@@ -235,9 +235,9 @@ async fn handle_ldk_events(
                                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();
                                        });
                                }
@@ -256,7 +256,6 @@ async fn handle_ldk_events(
                                                )
                                                .unwrap();
                                        bitcoind_client.broadcast_transaction(&spending_tx);
-                                       // XXX maybe need to rescan and blah?
                                }
                        }
                }
@@ -264,8 +263,7 @@ async fn handle_ldk_events(
        }
 }
 
-#[tokio::main]
-pub async fn main() {
+async fn start_ldk() {
        let args = match cli::parse_startup_args() {
                Ok(user_args) => user_args,
                Err(()) => return,
@@ -573,3 +571,8 @@ pub async fn main() {
        )
        .await;
 }
+
+#[tokio::main]
+pub async fn main() {
+       start_ldk().await;
+}