aljaz/lightning
1
0
Fork 0
mirror of https://github.com/aljazceru/lightning.git synced 2025-12-24 01:24:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

pytest: gossipd: test resumption of pruned channels

Browse Source
This commit is contained in:
Alex Myers
2022-11-16 13:38:51 -06:00
committed by Rusty Russell
parent a3ca3fb047
commit f2f05117aa
1 changed files with 69 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
tests/test_gossip.py
View File

@@ -2223,3 +2223,72 @@ def test_gossip_private_updates(node_factory, bitcoind):
l1.restart()
wait_for(lambda: l1.daemon.is_in_log(r'gossip_store_compact_offline: 5 deleted, 3 copied'))
@pytest.mark.developer("Needs --dev-fast-gossip, --dev-fast-gossip-prune")
@pytest.mark.xfail(strict=True)
def test_channel_resurrection(node_factory, bitcoind):
"""When a node goes offline long enough to prune a channel, the
channel_announcement should be retained in case the node comes back online.
"""
opts = {'dev-fast-gossip-prune': None,
'may_reconnect': True}
l1, l2 = node_factory.get_nodes(2, opts=opts)
opts.update({'log-level': 'debug'})
l3, = node_factory.get_nodes(1, opts=opts)
l1.rpc.connect(l2.info['id'], 'localhost', l2.port)
l3.rpc.connect(l2.info['id'], 'localhost', l2.port)
scid, _ = l1.fundchannel(l2, 10**6, True, True)
bitcoind.generate_block(6)
sync_blockheight(bitcoind, [l1, l2, l3])
l3.wait_channel_active(scid)
start_time = int(time.time())
# Channel_update should now be refreshed.
refresh_due = start_time + 44
prune_due = start_time + 61
l2.rpc.call('dev-gossip-set-time', [refresh_due])
l3.rpc.call('dev-gossip-set-time', [refresh_due])
# Automatic reconnect is too fast, so shutdown l1 instead of disconnecting
l1.stop()
l2.daemon.wait_for_log('Sending keepalive channel_update')
l3.daemon.wait_for_log('Received channel_update for channel 103x1')
# Wait for the next pruning cycle
l2.rpc.call('dev-gossip-set-time', [prune_due])
l3.rpc.call('dev-gossip-set-time', [prune_due])
# Make sure l1 is recognized as disconnected
wait_for(lambda: only_one(l2.rpc.listpeers(l1.info['id'])['peers'])['connected'] is False)
# Wait for the channel to be pruned.
l3.daemon.wait_for_log("Pruning channel")
assert l3.rpc.listchannels()['channels'] == []
l1.start()
time.sleep(1)
l1.rpc.call('dev-gossip-set-time', [prune_due])
time.sleep(1)
l1.rpc.call('dev-gossip-set-time', [prune_due])
wait_for(lambda: [c['active'] for c in l2.rpc.listchannels()['channels']] == [True, True])
l1.rpc.call('dev-gossip-set-time', [prune_due + 30])
l2.rpc.call('dev-gossip-set-time', [prune_due + 30])
l3.rpc.call('dev-gossip-set-time', [prune_due + 30])
# l2 should recognize its own channel as announceable
wait_for(lambda: [[c['public'], c['active']] for c in l2.rpc.listchannels()['channels']] == [[True, True], [True, True]], timeout=30)
# l3 should be able to recover the zombie channel
wait_for(lambda: [c['active'] for c in l3.rpc.listchannels()['channels']] == [True, True], timeout=30)
# Now test spending the outpoint and removing a zombie channel from the store.
l2.stop()
prune_again = prune_due + 91
l1.rpc.call('dev-gossip-set-time', [prune_again])
l3.rpc.call('dev-gossip-set-time', [prune_again])
l3.daemon.wait_for_log("Pruning channel")
txid = l1.rpc.close(l2.info['id'], 1)['txid']
bitcoind.generate_block(13, txid)
l3.daemon.wait_for_log(f"Deleting channel {scid} due to the funding "
"outpoint being spent", 30)
# gossip_store is cleaned of zombie channels once outpoint is spent.
gs_path = os.path.join(l3.daemon.lightning_dir, TEST_NETWORK, 'gossip_store')
gs = subprocess.run(['devtools/dump-gossipstore', '--print-deleted', gs_path],
check=True, timeout=TIMEOUT, stdout=subprocess.PIPE)
print(gs.stdout.decode())
for l in gs.stdout.decode().splitlines():
if "ZOMBIE" in l:
assert ("DELETED" in l)