@@ -64,16 +64,16 @@ def wait_for_txs(self, count):
64
64
def manual_open_channels (self ):
65
65
# 1 -> 4
66
66
pk1 = self .warnet ("ln pubkey tank-0004-lnd" ) # prefer -> self.node("tank-0004-lnd").uri()
67
- cln1_lnd4_channel = self .node ("tank-0001-cln" ).channel (pk1 , 444444 , 200000 , 5000 )
68
- assert "txid" in cln1_lnd4_channel , "Failed to create channel between CLN and LND"
69
- print ( cln1_lnd4_channel ["txid" ])
67
+ channel = self .node ("tank-0001-cln" ).channel (pk1 , 444444 , 200000 , 5000 )
68
+ assert "txid" in channel , "Failed to create channel between CLN and LND"
69
+ self . log . info ( f'Channel txid { channel ["txid" ]} ' )
70
70
71
71
# 4 -> 2
72
- # lnd4_cln2_channel = self.node("tank-0004-lnd").channel(
72
+ # channel = self.node("tank-0004-lnd").channel(
73
73
# self.lns[1].uri(), 333333, 150000, 5000
74
74
# )
75
- # assert "txid" in lnd4_cln2_channel , "Failed to create channel between LND and CLN"
76
- # print(lnd4_cln2_channel ["txid"])
75
+ # assert "txid" in channel , "Failed to create channel between LND and CLN"
76
+ # self.log.info(f'Channel txid {channel ["txid"]}' )
77
77
78
78
self .wait_for_txs (1 )
79
79
@@ -84,18 +84,18 @@ def wait_for_gossip_sync(self, nodes, expected):
84
84
for node in nodes :
85
85
chs = node .graph ()["edges" ]
86
86
if len (chs ) >= expected :
87
- print (f"Too many edges for { node } " )
87
+ self . log . info (f"Too many edges for { node } " )
88
88
sleep (1 )
89
89
90
90
def pay_invoice_rpc (self , sender : str , recipient : str ):
91
- print ("pay invoice using ln rpc" )
91
+ self . log . info ("pay invoice using ln rpc" )
92
92
init_balance = self .node (recipient ).channelbalance ()
93
- print ( "initial balance" , init_balance )
93
+ self . log . info ( f "initial balance { init_balance } " )
94
94
# create cln invoice
95
95
inv = json .loads (self .warnet (f"ln rpc { recipient } invoice 1000000 label description" ))
96
- print (inv )
96
+ self . log . info (inv )
97
97
# pay from lightning
98
- print (self .warnet (f"ln rpc { sender } payinvoice -f { inv ['bolt11' ]} " ))
98
+ self . log . info (self .warnet (f"ln rpc { sender } payinvoice -f { inv ['bolt11' ]} " ))
99
99
100
100
def wait_for_success ():
101
101
return self .node (recipient ).channelbalance () == init_balance + 1000
0 commit comments