(node, channel_id, exp_events)
| 377 | l2.daemon.wait_for_log('Snapshot balances updated') |
| 378 | |
| 379 | def _check_events(node, channel_id, exp_events): |
| 380 | chan_events = [ev for ev in node.rpc.bkpr_listaccountevents()['events'] if ev['account'] == channel_id] |
| 381 | assert len(chan_events) == len(exp_events) |
| 382 | for ev, exp in zip(chan_events, exp_events): |
| 383 | assert ev['tag'] == exp[0] |
| 384 | assert ev['credit_msat'] == Millisatoshi(exp[1]) |
| 385 | assert ev['debit_msat'] == Millisatoshi(exp[2]) |
| 386 | |
| 387 | # l1 events |
| 388 | exp_events = [('channel_open', open_amt * 1000 + lease_fee, 0), |
no test coverage detected