spawn-lnd 0.2.0

use spawn_lnd::{DEFAULT_CHANNEL_CAPACITY_SAT, SpawnLnd};

#[tokio::test]
async fn channel_smoke_opens_confirms_and_activates_channel()
-> Result<(), Box<dyn std::error::Error>> {
    if std::env::var("RUN_DOCKER_TESTS").as_deref() != Ok("1") {
        eprintln!("skipping channel smoke test; set RUN_DOCKER_TESTS=1 to run it");
        return Ok(());
    }

    eprintln!("channel smoke: spawning alice/bob cluster");
    let mut cluster = SpawnLnd::builder().nodes(["alice", "bob"]).spawn().await?;
    eprintln!("channel smoke: cluster_id={}", cluster.cluster_id());

    let result = async {
        eprintln!("channel smoke: funding alice");
        let funding = cluster.fund_node("alice").await?;
        eprintln!(
            "channel smoke: funded alice txid={} spendable_utxo_total_sat={}",
            funding.txid, funding.spendable_utxo_total_sat
        );

        eprintln!(
            "channel smoke: opening alice -> bob channel capacity_sat={DEFAULT_CHANNEL_CAPACITY_SAT}"
        );
        let channel = cluster.open_channel("alice", "bob").await?;
        eprintln!(
            "channel smoke: channel open point={} active_from={} active_to={} blocks={:?}",
            channel.channel_point,
            channel.from_channel.active,
            channel.to_channel.active,
            channel.confirmation_blocks
        );

        Ok::<_, Box<dyn std::error::Error>>((funding, channel))
    }
    .await;
    eprintln!(
        "channel smoke: shutting down cluster_id={}",
        cluster.cluster_id()
    );
    let cleanup = cluster.shutdown().await;

    let (funding, channel) = result?;
    let cleanup = cleanup?;
    eprintln!(
        "channel smoke: cleanup matched={} removed={} failures={}",
        cleanup.matched,
        cleanup.removed,
        cleanup.failures.len()
    );
    assert!(
        cleanup.removed >= 4,
        "expected bitcoind, two LND containers, and network to be removed"
    );

    assert_eq!(funding.alias, "alice");
    assert!(funding.spendable_utxo_total_sat >= DEFAULT_CHANNEL_CAPACITY_SAT);

    assert_eq!(channel.from_alias, "alice");
    assert_eq!(channel.to_alias, "bob");
    assert_eq!(
        channel.local_funding_amount_sat,
        DEFAULT_CHANNEL_CAPACITY_SAT
    );
    assert!(!channel.channel_point.is_empty());
    assert!(!channel.confirmation_blocks.is_empty());
    assert!(channel.from_channel.active);
    assert!(channel.to_channel.active);
    assert_eq!(channel.from_channel.capacity, DEFAULT_CHANNEL_CAPACITY_SAT);
    assert_eq!(channel.to_channel.capacity, DEFAULT_CHANNEL_CAPACITY_SAT);

    Ok(())
}