lightning-cluster 0.1.4

Lightning Node Load Balancer & Cache
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

mod tests {
    use lightning_cluster::{
        cluster::{Cluster, ClusterAddInvoice, Node, NodeClient, NodeLightningImpl, NodeNetwork},
        lnd::LndClient,
    };

    #[tokio::test]
    async fn test_lightning_cluster() {
        let node1 = Node {
            pubkey: dotenvy::var("NODE1_PUBKEY").unwrap(),
            ip: dotenvy::var("NODE1_IP").unwrap(),
            port: dotenvy::var("NODE1_PORT").unwrap(),
            network: NodeNetwork::Testnet,
            lightning_impl: NodeLightningImpl::Lnd,
            client: NodeClient::Lnd(LndClient::new(
                dotenvy::var("NODE1_HOST").unwrap(),
                dotenvy::var("NODE1_CERT_PATH").unwrap(),
                dotenvy::var("NODE1_MACAROON_PATH").unwrap(),
            )),
        };

        let client = redis::Client::open("redis://127.0.0.1/").unwrap();
        let con = client.get_async_connection().await.unwrap();

        let nodes = vec![node1];
        let mut cluster = Cluster::new(nodes, con, 1, 3600, 3600);

        let req = ClusterAddInvoice {
            pubkey: None,
            memo: String::from("test"),
            value: 1000,
            expiry: 1000,
        };

        let invoice = cluster.add_invoice(req, None).await.unwrap();
        let get_invoice = cluster.lookup_invoice(&invoice.r_hash, None).await.unwrap();

        println!("first get: {:?}", get_invoice);

        let get_invoice = cluster.lookup_invoice(&invoice.r_hash, None).await.unwrap();

        println!("2nd get from cache: {:?}", get_invoice); // from cache

        let next_addr = cluster.next_address(None).await.unwrap();

        println!("{:?}", next_addr);

        let utxos = cluster.list_utxos(None).await.unwrap();

        for utxo in utxos.utxos {
            println!("{:?}", utxo);
        }

        let payment_request = String::from("lntb10u1pjva6sepp5lqz5lysxd7vu7h3nqzj3lem544uqmvec5k53cp2msm2lvnw0s9zqdqqcqzzsxqr23ssp5dysff7u8n2w7f0x5gysmlze7zw3fg05f2e2q24tzh8vanfnt5nss9qyyssqtcashms9q6dmt4ywja8jrtkztzr5kr5k24wa8mdxs00fgxq76d9zvs6styvhuxc5pvdcrs4m89r4rmvkp6lvc7tr959cds7na7k63vcplqfzxx");

        let _ = cluster
            .pay_invoice(1000, payment_request, 100, None)
            .await
            .unwrap();

        //println!("{:?}", pay_ln_invoice);
    }
}