Merge #202: Kyoto: Remove connection requirement to send tx

3b60b7b fix(kyoto): remove conn requirement to send tx (rustaceanrob)

Pull request description:

  Kyoto now holds on to a transaction internally until it is successfully broadcast, so we can broadcast the transaction immediately once the node starts up, and wait for a confirmation or 30 second timeout

  Successful test on Signet. Note that `Testnet4` still has the difficulty adjustment bug when loading block headers from storage.

  ### Checklists

  #### All Submissions:

  * [x] I've signed all my commits
  * [x] I followed the [contribution guidelines](https://github.com/bitcoindevkit/bdk-cli/blob/master/CONTRIBUTING.md)
  * [x] I ran `cargo fmt` and `cargo clippy` before committing

  #### New Features:

  * [ ] I've added tests for the new feature
  * [ ] I've added docs for the new feature
  * [ ] I've updated `CHANGELOG.md`

  #### Bugfixes:

  * [ ] This pull request breaks the existing API
  * [ ] I've added tests to reproduce the issue which are now passing
  * [ ] I'm linking the issue being fixed by this PR

Top commit has no ACKs.

Tree-SHA512: e1ad420440bad12b42847f09cc564e9fcc292c5acf12ac173560652c85a3fcf802052d20206bef7a8615d6beb93519c83c519dc086d8604656f088e78ef424b4

Author: tvpeter

src/handlers.rs

@@ -576,19 +576,10 @@ pub(crate) async fn handle_online_wallet_subcommand(
                         }
                     });
                     let txid = tx.compute_txid();
-                    tracing::info!("Waiting for connections to broadcast...");
-                    while let Some(info) = info_subscriber.recv().await {
-                        match info {
-                            Info::ConnectionsMet => {
-                                requester
-                                    .broadcast_random(tx.clone())
-                                    .map_err(|e| Error::Generic(format!("{}", e)))?;
-                                break;
-                            }
-                            _ => tracing::info!("{info}"),
-                        }
-                    }
-                    tokio::time::timeout(tokio::time::Duration::from_secs(15), async move {
+                    requester
+                        .broadcast_random(tx.clone())
+                        .map_err(|e| Error::Generic(format!("{}", e)))?;
+                    tokio::time::timeout(tokio::time::Duration::from_secs(30), async move {
                         while let Some(info) = info_subscriber.recv().await {
                             match info {
                                 Info::TxGossiped(wtxid) => {
@@ -606,7 +597,7 @@ pub(crate) async fn handle_online_wallet_subcommand(
                     .await
                     .map_err(|_| {
                         tracing::warn!("Broadcast was unsuccessful");
-                        Error::Generic("Transaction broadcast timed out after 15 seconds".into())
+                        Error::Generic("Transaction broadcast timed out after 30 seconds".into())
                     })?;
                     txid
                 }