@ -251,12 +251,12 @@ def test_disconnect_opener(node_factory):
for d in disconnects :
for d in disconnects :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# This one will succeed.
# This one will succeed.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
# Should still only have one peer!
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l1 . rpc . listpeers ( ) ) == 1
@ -277,12 +277,12 @@ def test_disconnect_fundee(node_factory):
for d in disconnects :
for d in disconnects :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# This one will succeed.
# This one will succeed.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
# Should still only have one peer!
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l1 . rpc . listpeers ( ) ) == 1
@ -301,7 +301,7 @@ def test_disconnect_half_signed(node_factory):
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
# Peer remembers, opener doesn't.
# Peer remembers, opener doesn't.
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
@ -319,7 +319,7 @@ def test_reconnect_signed(node_factory):
l1 . fundwallet ( 2000000 )
l1 . fundwallet ( 2000000 )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
# They haven't forgotten each other.
# They haven't forgotten each other.
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' id ' ] == l2 . info [ ' id ' ]
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' id ' ] == l2 . info [ ' id ' ]
@ -348,7 +348,7 @@ def test_reconnect_openingd(node_factory):
# l2 closes on l1, l1 forgets.
# l2 closes on l1, l1 forgets.
with pytest . raises ( RpcError ) :
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# Reconnect.
# Reconnect.
@ -359,7 +359,7 @@ def test_reconnect_openingd(node_factory):
l2 . daemon . wait_for_log ( ' openingd.*Handed peer, entering loop ' )
l2 . daemon . wait_for_log ( ' openingd.*Handed peer, entering loop ' )
# Should work fine.
# Should work fine.
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20 000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 25 000 )
l1 . daemon . wait_for_log ( ' sendrawtx exit 0 ' )
l1 . daemon . wait_for_log ( ' sendrawtx exit 0 ' )
l1 . bitcoin . generate_block ( 3 )
l1 . bitcoin . generate_block ( 3 )