2018-10-10 00:39:05 +02:00
from collections import namedtuple
2018-08-03 17:29:38 +02:00
from fixtures import * # noqa: F401,F403
from lightning import RpcError
2018-12-10 04:10:16 +01:00
from utils import DEVELOPER , only_one , wait_for , sync_blockheight , VALGRIND , EXPERIMENTAL_FEATURES
2018-08-03 17:29:38 +02:00
2018-08-10 08:19:06 +02:00
import os
2018-08-03 17:29:38 +02:00
import pytest
import time
2018-08-10 08:19:06 +02:00
import random
import shutil
2018-08-03 17:29:38 +02:00
import unittest
def test_connect ( node_factory ) :
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = False )
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
# These should be in openingd.
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ]
assert l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' connected ' ]
assert len ( l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' channels ' ] ) == 0
assert len ( l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' channels ' ] ) == 0
2018-08-03 17:29:38 +02:00
# Reconnect should be a noop
ret = l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , port = l2 . port )
assert ret [ ' id ' ] == l2 . info [ ' id ' ]
ret = l2 . rpc . connect ( l1 . info [ ' id ' ] , host = ' localhost ' , port = l1 . port )
assert ret [ ' id ' ] == l1 . info [ ' id ' ]
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l2 . rpc . listpeers ( ) ) == 1
# Should get reasonable error if unknown addr for peer.
with pytest . raises ( RpcError , match = r ' No address known ' ) :
l1 . rpc . connect ( ' 032cf15d1ad9c4a08d26eab1918f732d8ef8fdc6abb9640bf3db174372c491304e ' )
# Should get reasonable error if connection refuse.
with pytest . raises ( RpcError , match = r ' Connection establishment: Connection refused ' ) :
l1 . rpc . connect ( ' 032cf15d1ad9c4a08d26eab1918f732d8ef8fdc6abb9640bf3db174372c491304e ' , ' localhost ' , 1 )
# Should get reasonable error if wrong key for peer.
2018-10-18 02:52:43 +02:00
with pytest . raises ( RpcError , match = r ' Cryptographic handshake: peer closed connection \ (wrong key \ ? \ ) ' ) :
2018-08-03 17:29:38 +02:00
l1 . rpc . connect ( ' 032cf15d1ad9c4a08d26eab1918f732d8ef8fdc6abb9640bf3db174372c491304e ' , ' localhost ' , l2 . port )
def test_connect_standard_addr ( node_factory ) :
""" Test standard node@host:port address
"""
l1 , l2 , l3 = node_factory . get_nodes ( 3 )
# node@host
ret = l1 . rpc . connect ( " {} @ {} " . format ( l2 . info [ ' id ' ] , ' localhost ' ) , port = l2 . port )
assert ret [ ' id ' ] == l2 . info [ ' id ' ]
# node@host:port
ret = l1 . rpc . connect ( " {} @localhost: {} " . format ( l3 . info [ ' id ' ] , l3 . port ) )
assert ret [ ' id ' ] == l3 . info [ ' id ' ]
# node@[ipv6]:port --- not supported by our CI
# ret = l1.rpc.connect("{}@[::1]:{}".format(l3.info['id'], l3.port))
# assert ret['id'] == l3.info['id']
def test_reconnect_channel_peers ( node_factory , executor ) :
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
l2 . restart ( )
# Should reconnect.
wait_for ( lambda : only_one ( l1 . rpc . listpeers ( l2 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' connected ' ] )
wait_for ( lambda : only_one ( l2 . rpc . listpeers ( l1 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' connected ' ] )
# Connect command should succeed.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Stop l2 and wait for l1 to notice.
l2 . stop ( )
wait_for ( lambda : not only_one ( l1 . rpc . listpeers ( l2 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' connected ' ] )
# Now should fail.
with pytest . raises ( RpcError , match = r ' Connection refused ' ) :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Wait for exponential backoff to give us a 2 second window.
2018-08-09 02:25:29 +02:00
l1 . daemon . wait_for_log ( ' Will try reconnect in 2 seconds ' )
2018-08-03 17:29:38 +02:00
# It should now succeed when it restarts.
l2 . start ( )
# Multiples should be fine!
fut1 = executor . submit ( l1 . rpc . connect , l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
fut2 = executor . submit ( l1 . rpc . connect , l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
fut3 = executor . submit ( l1 . rpc . connect , l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
fut1 . result ( 10 )
fut2 . result ( 10 )
fut3 . result ( 10 )
def test_balance ( node_factory ) :
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = True )
p1 = only_one ( l1 . rpc . getpeer ( peer_id = l2 . info [ ' id ' ] , level = ' info ' ) [ ' channels ' ] )
p2 = only_one ( l2 . rpc . getpeer ( l1 . info [ ' id ' ] , ' info ' ) [ ' channels ' ] )
assert p1 [ ' msatoshi_to_us ' ] == 10 * * 6 * 1000
assert p1 [ ' msatoshi_total ' ] == 10 * * 6 * 1000
assert p2 [ ' msatoshi_to_us ' ] == 0
assert p2 [ ' msatoshi_total ' ] == 10 * * 6 * 1000
def test_bad_opening ( node_factory ) :
# l1 asks for a too-long locktime
l1 = node_factory . get_node ( options = { ' watchtime-blocks ' : 100 } )
l2 = node_factory . get_node ( options = { ' max-locktime-blocks ' : 99 } )
ret = l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
assert ret [ ' id ' ] == l2 . info [ ' id ' ]
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
l1 . daemon . wait_for_log ( ' openingd-.*: Handed peer, entering loop ' )
l2 . daemon . wait_for_log ( ' openingd-.*: Handed peer, entering loop ' )
2018-08-03 17:29:38 +02:00
l1 . fundwallet ( 10 * * 6 + 1000000 )
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 )
l2 . daemon . wait_for_log ( ' to_self_delay 100 larger than 99 ' )
def test_second_channel ( node_factory ) :
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( )
l3 = node_factory . get_node ( )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l3 . info [ ' id ' ] , ' localhost ' , l3 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
l1 . fund_channel ( l3 , 10 * * 6 )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_disconnect ( node_factory ) :
# These should all make us fail
disconnects = [ ' -WIRE_INIT ' ,
' @WIRE_INIT ' ,
' +WIRE_INIT ' ]
l1 = node_factory . get_node ( disconnect = disconnects )
l2 = node_factory . get_node ( )
with pytest . raises ( RpcError ) :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Should have 3 connect fails.
for d in disconnects :
l1 . daemon . wait_for_log ( ' Failed connected out for {} '
. format ( l2 . info [ ' id ' ] ) )
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l2 . rpc . listpeers ( ) ) == 1
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_disconnect_funder ( node_factory ) :
# Now error on funder side duringchannel open.
disconnects = [ ' -WIRE_OPEN_CHANNEL ' ,
' @WIRE_OPEN_CHANNEL ' ,
' +WIRE_OPEN_CHANNEL ' ,
' -WIRE_FUNDING_CREATED ' ,
' @WIRE_FUNDING_CREATED ' ]
l1 = node_factory . get_node ( disconnect = disconnects )
l2 = node_factory . get_node ( )
l1 . fundwallet ( 2000000 )
for d in disconnects :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# This one will succeed.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l2 . rpc . listpeers ( ) ) == 1
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_disconnect_fundee ( node_factory ) :
# Now error on fundee side during channel open.
disconnects = [ ' -WIRE_ACCEPT_CHANNEL ' ,
' @WIRE_ACCEPT_CHANNEL ' ,
' +WIRE_ACCEPT_CHANNEL ' ]
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( disconnect = disconnects )
l1 . fundwallet ( 2000000 )
for d in disconnects :
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# This one will succeed.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
# Should still only have one peer!
assert len ( l1 . rpc . listpeers ( ) ) == 1
assert len ( l2 . rpc . listpeers ( ) ) == 1
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_disconnect_half_signed ( node_factory ) :
# Now, these are the corner cases. Fundee sends funding_signed,
# but funder doesn't receive it.
disconnects = [ ' @WIRE_FUNDING_SIGNED ' ]
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( disconnect = disconnects )
l1 . fundwallet ( 2000000 )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
# Fundee remembers, funder doesn't.
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
assert l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' id ' ] == l1 . info [ ' id ' ]
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_signed ( node_factory ) :
# This will fail *after* both sides consider channel opening.
disconnects = [ ' +WIRE_FUNDING_SIGNED ' ]
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l1 . fundwallet ( 2000000 )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
# They haven't forgotten each other.
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' id ' ] == l2 . info [ ' id ' ]
assert l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' id ' ] == l1 . info [ ' id ' ]
# Technically, this is async to fundchannel (and could reconnect first)
l1 . daemon . wait_for_logs ( [ ' sendrawtx exit 0 ' ,
' Peer has reconnected, state CHANNELD_AWAITING_LOCKIN ' ] )
l1 . bitcoin . generate_block ( 6 )
l1 . daemon . wait_for_log ( ' to CHANNELD_NORMAL ' )
l2 . daemon . wait_for_log ( ' to CHANNELD_NORMAL ' )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_openingd ( node_factory ) :
# Openingd thinks we're still opening; funder reconnects..
disconnects = [ ' 0WIRE_ACCEPT_CHANNEL ' ]
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fundwallet ( 2000000 )
# l2 closes on l1, l1 forgets.
with pytest . raises ( RpcError ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
# Reconnect.
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
2018-08-09 02:25:29 +02:00
# We should get a message about reconnecting.
l2 . daemon . wait_for_log ( ' Killing openingd: Reconnected ' )
l2 . daemon . wait_for_log ( ' lightning_openingd.*Handed peer, entering loop ' )
2018-08-03 17:29:38 +02:00
# Should work fine.
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 20000 )
l1 . daemon . wait_for_log ( ' sendrawtx exit 0 ' )
# Just to be sure, second openingd hand over to channeld.
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
l2 . daemon . wait_for_log ( ' lightning_openingd.*UPDATE WIRE_OPENING_FUNDEE ' )
2018-08-03 17:29:38 +02:00
2018-08-10 08:18:33 +02:00
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_gossiping ( node_factory ) :
# connectd thinks we're still gossiping; peer reconnects.
disconnects = [ ' 0WIRE_PING ' ]
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
2018-08-10 13:41:32 +02:00
l2 . rpc . ping ( l1 . info [ ' id ' ] , 1 , 65532 )
2018-09-28 05:24:14 +02:00
wait_for ( lambda : l1 . rpc . listpeers ( l2 . info [ ' id ' ] ) [ ' peers ' ] == [ ] )
2018-08-10 08:18:33 +02:00
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l2 . daemon . wait_for_log ( ' processing now old peer gone ' )
2018-08-10 08:19:06 +02:00
def test_connect_stresstest ( node_factory , executor ) :
# This test is unreliable, but it's better than nothing.
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( may_reconnect = True )
l3 = node_factory . get_node ( may_reconnect = True )
# Hack l3 into a clone of l2, to stress reconnect code.
l3 . stop ( )
shutil . copyfile ( os . path . join ( l2 . daemon . lightning_dir , ' hsm_secret ' ) ,
os . path . join ( l3 . daemon . lightning_dir , ' hsm_secret ' ) )
l3 . start ( )
l3 . info = l3 . rpc . getinfo ( )
assert l3 . info [ ' id ' ] == l2 . info [ ' id ' ]
# We fire off random connect/disconnect commands.
actions = [
( l2 . rpc . connect , l1 . info [ ' id ' ] , ' localhost ' , l1 . port ) ,
( l3 . rpc . connect , l1 . info [ ' id ' ] , ' localhost ' , l3 . port ) ,
( l1 . rpc . connect , l2 . info [ ' id ' ] , ' localhost ' , l2 . port ) ,
( l1 . rpc . connect , l3 . info [ ' id ' ] , ' localhost ' , l3 . port ) ,
( l1 . rpc . disconnect , l2 . info [ ' id ' ] )
]
args = [ random . choice ( actions ) for _ in range ( 1000 ) ]
# We get them all to connect to each other.
futs = [ ]
for a in args :
futs . append ( executor . submit ( * a ) )
# We don't actually care if they fail, since some will.
successes = 0
failures = 0
for f in futs :
if f . exception ( ) :
failures + = 1
else :
f . result ( )
successes + = 1
assert successes > failures
2018-08-03 17:29:38 +02:00
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_normal ( node_factory ) :
# Should reconnect fine even if locked message gets lost.
disconnects = [ ' -WIRE_FUNDING_LOCKED ' ,
' @WIRE_FUNDING_LOCKED ' ,
' +WIRE_FUNDING_LOCKED ' ]
l1 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_sender_add1 ( node_factory ) :
# Fail after add is OK, will cause payment failure though.
disconnects = [ ' -WIRE_UPDATE_ADD_HTLC-nocommit ' ,
' +WIRE_UPDATE_ADD_HTLC-nocommit ' ,
' @WIRE_UPDATE_ADD_HTLC-nocommit ' ]
2018-08-23 01:27:17 +02:00
# Feerates identical so we don't get gratuitous commit to update them
2018-08-03 17:29:38 +02:00
l1 = node_factory . get_node ( disconnect = disconnects ,
2018-08-23 01:27:17 +02:00
may_reconnect = True ,
feerates = ( 7500 , 7500 , 7500 ) )
2018-08-03 17:29:38 +02:00
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
amt = 200000000
rhash = l2 . rpc . invoice ( amt , ' test_reconnect_sender_add1 ' , ' desc ' ) [ ' payment_hash ' ]
assert only_one ( l2 . rpc . listinvoices ( ' test_reconnect_sender_add1 ' ) [ ' invoices ' ] ) [ ' status ' ] == ' unpaid '
2019-01-10 22:42:18 +01:00
route = [ { ' msatoshi ' : amt , ' id ' : l2 . info [ ' id ' ] , ' delay ' : 5 , ' channel ' : ' 1x1x1 ' } ]
2018-08-03 17:29:38 +02:00
for i in range ( 0 , len ( disconnects ) ) :
l1 . rpc . sendpay ( route , rhash )
with pytest . raises ( RpcError ) :
l1 . rpc . waitsendpay ( rhash )
# Wait for reconnection.
l1 . daemon . wait_for_log ( ' Already have funding locked in ' )
# This will send commit, so will reconnect as required.
l1 . rpc . sendpay ( route , rhash )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_sender_add ( node_factory ) :
disconnects = [ ' -WIRE_COMMITMENT_SIGNED ' ,
' @WIRE_COMMITMENT_SIGNED ' ,
' +WIRE_COMMITMENT_SIGNED ' ,
' -WIRE_REVOKE_AND_ACK ' ,
' @WIRE_REVOKE_AND_ACK ' ,
' +WIRE_REVOKE_AND_ACK ' ]
2018-08-23 01:27:17 +02:00
# Feerates identical so we don't get gratuitous commit to update them
2018-08-03 17:29:38 +02:00
l1 = node_factory . get_node ( disconnect = disconnects ,
2018-08-23 01:27:17 +02:00
may_reconnect = True ,
feerates = ( 7500 , 7500 , 7500 ) )
2018-08-03 17:29:38 +02:00
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
amt = 200000000
rhash = l2 . rpc . invoice ( amt , ' testpayment ' , ' desc ' ) [ ' payment_hash ' ]
assert only_one ( l2 . rpc . listinvoices ( ' testpayment ' ) [ ' invoices ' ] ) [ ' status ' ] == ' unpaid '
2019-01-10 22:42:18 +01:00
route = [ { ' msatoshi ' : amt , ' id ' : l2 . info [ ' id ' ] , ' delay ' : 5 , ' channel ' : ' 1x1x1 ' } ]
2018-08-03 17:29:38 +02:00
# This will send commit, so will reconnect as required.
l1 . rpc . sendpay ( route , rhash )
# Should have printed this for every reconnect.
for i in range ( 0 , len ( disconnects ) ) :
l1 . daemon . wait_for_log ( ' Already have funding locked in ' )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_receiver_add ( node_factory ) :
disconnects = [ ' -WIRE_COMMITMENT_SIGNED ' ,
' @WIRE_COMMITMENT_SIGNED ' ,
' +WIRE_COMMITMENT_SIGNED ' ,
' -WIRE_REVOKE_AND_ACK ' ,
' @WIRE_REVOKE_AND_ACK ' ,
' +WIRE_REVOKE_AND_ACK ' ]
2018-08-23 01:27:17 +02:00
# Feerates identical so we don't get gratuitous commit to update them
l1 = node_factory . get_node ( may_reconnect = True , feerates = ( 7500 , 7500 , 7500 ) )
2018-08-03 17:29:38 +02:00
l2 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
amt = 200000000
rhash = l2 . rpc . invoice ( amt , ' testpayment2 ' , ' desc ' ) [ ' payment_hash ' ]
assert only_one ( l2 . rpc . listinvoices ( ' testpayment2 ' ) [ ' invoices ' ] ) [ ' status ' ] == ' unpaid '
2019-01-10 22:42:18 +01:00
route = [ { ' msatoshi ' : amt , ' id ' : l2 . info [ ' id ' ] , ' delay ' : 5 , ' channel ' : ' 1x1x1 ' } ]
2018-08-03 17:29:38 +02:00
l1 . rpc . sendpay ( route , rhash )
for i in range ( len ( disconnects ) ) :
l1 . daemon . wait_for_log ( ' Already have funding locked in ' )
assert only_one ( l2 . rpc . listinvoices ( ' testpayment2 ' ) [ ' invoices ' ] ) [ ' status ' ] == ' paid '
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_reconnect_receiver_fulfill ( node_factory ) :
# Ordering matters: after +WIRE_UPDATE_FULFILL_HTLC, channeld
# will continue and try to send WIRE_COMMITMENT_SIGNED: if
# that's the next failure, it will do two in one run.
disconnects = [ ' @WIRE_UPDATE_FULFILL_HTLC ' ,
' +WIRE_UPDATE_FULFILL_HTLC ' ,
' -WIRE_UPDATE_FULFILL_HTLC ' ,
' -WIRE_COMMITMENT_SIGNED ' ,
' @WIRE_COMMITMENT_SIGNED ' ,
' +WIRE_COMMITMENT_SIGNED ' ,
' -WIRE_REVOKE_AND_ACK ' ,
' @WIRE_REVOKE_AND_ACK ' ,
' +WIRE_REVOKE_AND_ACK ' ]
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
amt = 200000000
rhash = l2 . rpc . invoice ( amt , ' testpayment2 ' , ' desc ' ) [ ' payment_hash ' ]
assert only_one ( l2 . rpc . listinvoices ( ' testpayment2 ' ) [ ' invoices ' ] ) [ ' status ' ] == ' unpaid '
2019-01-10 22:42:18 +01:00
route = [ { ' msatoshi ' : amt , ' id ' : l2 . info [ ' id ' ] , ' delay ' : 5 , ' channel ' : ' 1x1x1 ' } ]
2018-08-03 17:29:38 +02:00
l1 . rpc . sendpay ( route , rhash )
for i in range ( len ( disconnects ) ) :
l1 . daemon . wait_for_log ( ' Already have funding locked in ' )
assert only_one ( l2 . rpc . listinvoices ( ' testpayment2 ' ) [ ' invoices ' ] ) [ ' status ' ] == ' paid '
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_shutdown_reconnect ( node_factory ) :
disconnects = [ ' -WIRE_SHUTDOWN ' ,
' @WIRE_SHUTDOWN ' ,
' +WIRE_SHUTDOWN ' ]
l1 = node_factory . get_node ( disconnect = disconnects ,
may_reconnect = True )
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
chan = l1 . fund_channel ( l2 , 10 * * 6 )
l1 . pay ( l2 , 200000000 )
assert l1 . bitcoin . rpc . getmempoolinfo ( ) [ ' size ' ] == 0
# This should return with an error, then close.
with pytest . raises ( RpcError , match = r ' Channel close negotiation not finished ' ) :
l1 . rpc . close ( chan , False , 0 )
l1 . daemon . wait_for_log ( ' to CHANNELD_SHUTTING_DOWN ' )
l2 . daemon . wait_for_log ( ' to CHANNELD_SHUTTING_DOWN ' )
l1 . daemon . wait_for_log ( ' to CLOSINGD_SIGEXCHANGE ' )
l2 . daemon . wait_for_log ( ' to CLOSINGD_SIGEXCHANGE ' )
# And should put closing into mempool (happens async, so
# CLOSINGD_COMPLETE may come first).
l1 . daemon . wait_for_logs ( [ ' sendrawtx exit 0 ' , ' to CLOSINGD_COMPLETE ' ] )
l2 . daemon . wait_for_logs ( [ ' sendrawtx exit 0 ' , ' to CLOSINGD_COMPLETE ' ] )
assert l1 . bitcoin . rpc . getmempoolinfo ( ) [ ' size ' ] == 1
def test_shutdown_awaiting_lockin ( node_factory , bitcoind ) :
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( options = { ' funding-confirms ' : 3 } )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fundwallet ( 10 * * 6 + 1000000 )
chanid = l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 ) [ ' channel_id ' ]
# Technically, this is async to fundchannel.
l1 . daemon . wait_for_log ( ' sendrawtx exit 0 ' )
bitcoind . generate_block ( 1 )
# This should return with an error, then close.
with pytest . raises ( RpcError , match = r ' Channel close negotiation not finished ' ) :
l1 . rpc . close ( chanid , False , 0 )
l1 . daemon . wait_for_log ( ' CHANNELD_AWAITING_LOCKIN to CHANNELD_SHUTTING_DOWN ' )
l2 . daemon . wait_for_log ( ' CHANNELD_AWAITING_LOCKIN to CHANNELD_SHUTTING_DOWN ' )
l1 . daemon . wait_for_log ( ' CHANNELD_SHUTTING_DOWN to CLOSINGD_SIGEXCHANGE ' )
l2 . daemon . wait_for_log ( ' CHANNELD_SHUTTING_DOWN to CLOSINGD_SIGEXCHANGE ' )
# And should put closing into mempool (happens async, so
# CLOSINGD_COMPLETE may come first).
l1 . daemon . wait_for_logs ( [ ' sendrawtx exit 0 ' , ' to CLOSINGD_COMPLETE ' ] )
l2 . daemon . wait_for_logs ( [ ' sendrawtx exit 0 ' , ' to CLOSINGD_COMPLETE ' ] )
assert bitcoind . rpc . getmempoolinfo ( ) [ ' size ' ] == 1
bitcoind . generate_block ( 1 )
l1 . daemon . wait_for_log ( ' to ONCHAIN ' )
l2 . daemon . wait_for_log ( ' to ONCHAIN ' )
bitcoind . generate_block ( 100 )
wait_for ( lambda : l1 . rpc . listpeers ( ) [ ' peers ' ] == [ ] )
wait_for ( lambda : l2 . rpc . listpeers ( ) [ ' peers ' ] == [ ] )
def test_funding_change ( node_factory , bitcoind ) :
""" Add some funds, fund a channel, and make sure we remember the change
"""
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = False )
l1 . fundwallet ( 10000000 )
bitcoind . generate_block ( 1 )
sync_blockheight ( bitcoind , [ l1 ] )
outputs = l1 . db_query ( ' SELECT value FROM outputs WHERE status=0; ' )
assert only_one ( outputs ) [ ' value ' ] == 10000000
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 1000000 )
outputs = { r [ ' status ' ] : r [ ' value ' ] for r in l1 . db_query (
' SELECT status, SUM(value) AS value FROM outputs GROUP BY status; ' ) }
# The 10m out is spent and we have a change output of 9m-fee
assert outputs [ 0 ] > 8990000
assert outputs [ 2 ] == 10000000
def test_funding_all ( node_factory , bitcoind ) :
""" Add some funds, fund a channel using all funds, make sure no funds remain
"""
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = False )
l1 . fundwallet ( 0.1 * 10 * * 8 )
bitcoind . generate_block ( 1 )
sync_blockheight ( bitcoind , [ l1 ] )
outputs = l1 . db_query ( ' SELECT value FROM outputs WHERE status=0; ' )
assert only_one ( outputs ) [ ' value ' ] == 10000000
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , " all " )
outputs = l1 . db_query ( ' SELECT value FROM outputs WHERE status=0; ' )
assert len ( outputs ) == 0
def test_funding_all_too_much ( node_factory ) :
""" Add more than max possible funds, fund a channel using all funds we can.
"""
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = False )
l1 . fundwallet ( 2 * * 24 + 10000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , " all " )
assert only_one ( l1 . rpc . listfunds ( ) [ ' outputs ' ] ) [ ' status ' ] == ' unconfirmed '
assert only_one ( l1 . rpc . listfunds ( ) [ ' channels ' ] ) [ ' channel_total_sat ' ] == 2 * * 24 - 1
def test_funding_fail ( node_factory , bitcoind ) :
""" Add some funds, fund a channel without enough funds """
# Previous runs with same bitcoind can leave funds!
max_locktime = 5 * 6 * 24
l1 = node_factory . get_node ( random_hsm = True , options = { ' max-locktime-blocks ' : max_locktime } )
l2 = node_factory . get_node ( options = { ' watchtime-blocks ' : max_locktime + 1 } )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
funds = 1000000
addr = l1 . rpc . newaddr ( ) [ ' address ' ]
l1 . bitcoin . rpc . sendtoaddress ( addr , funds / 10 * * 8 )
bitcoind . generate_block ( 1 )
# Wait for it to arrive.
wait_for ( lambda : len ( l1 . rpc . listfunds ( ) [ ' outputs ' ] ) > 0 )
# Fail because l1 dislikes l2's huge locktime.
with pytest . raises ( RpcError , match = r ' to_self_delay \ d+ larger than \ d+ ' ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , int ( funds / 10 ) )
assert only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) [ ' connected ' ]
assert only_one ( l2 . rpc . listpeers ( ) [ ' peers ' ] ) [ ' connected ' ]
# Restart l2 without ridiculous locktime.
del l2 . daemon . opts [ ' watchtime-blocks ' ]
l2 . restart ( )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# We don't have enough left to cover fees if we try to spend it all.
with pytest . raises ( RpcError , match = r ' Cannot afford transaction ' ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , funds )
# Should still be connected.
assert only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) [ ' connected ' ]
2018-08-09 02:25:29 +02:00
l2 . daemon . wait_for_log ( ' lightning_openingd-.*: Handed peer, entering loop ' )
2018-08-03 17:29:38 +02:00
assert only_one ( l2 . rpc . listpeers ( ) [ ' peers ' ] ) [ ' connected ' ]
# This works.
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , int ( funds / 10 ) )
def test_funding_toolarge ( node_factory , bitcoind ) :
""" Try to create a giant channel """
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Send funds.
amount = 2 * * 24
bitcoind . rpc . sendtoaddress ( l1 . rpc . newaddr ( ) [ ' address ' ] , amount / 10 * * 8 + 0.01 )
bitcoind . generate_block ( 1 )
# Wait for it to arrive.
wait_for ( lambda : len ( l1 . rpc . listfunds ( ) [ ' outputs ' ] ) > 0 )
# Fail to open (too large)
with pytest . raises ( RpcError , match = r ' Amount exceeded 16777215 ' ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , amount )
# This should work.
amount = amount - 1
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , amount )
def test_lockin_between_restart ( node_factory , bitcoind ) :
l1 = node_factory . get_node ( may_reconnect = True )
l2 = node_factory . get_node ( options = { ' funding-confirms ' : 3 } ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fundwallet ( 10 * * 6 + 1000000 )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 ) [ ' tx ' ]
# l1 goes down.
l1 . stop ( )
# Now 120 blocks go by...
bitcoind . generate_block ( 120 )
# Restart
l1 . start ( )
# All should be good.
l1 . daemon . wait_for_log ( ' to CHANNELD_NORMAL ' )
l2 . daemon . wait_for_log ( ' to CHANNELD_NORMAL ' )
def test_funding_while_offline ( node_factory , bitcoind ) :
l1 = node_factory . get_node ( )
addr = l1 . rpc . newaddr ( ) [ ' address ' ]
sync_blockheight ( bitcoind , [ l1 ] )
# l1 goes down.
l1 . stop ( )
# We send funds
bitcoind . rpc . sendtoaddress ( addr , ( 10 * * 6 + 1000000 ) / 10 * * 8 )
# Now 120 blocks go by...
bitcoind . generate_block ( 120 )
# Restart
l1 . start ( )
sync_blockheight ( bitcoind , [ l1 ] )
assert len ( l1 . rpc . listfunds ( ) [ ' outputs ' ] ) == 1
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_channel_persistence ( node_factory , bitcoind , executor ) :
# Start two nodes and open a channel (to remember). l2 will
# mysteriously die while committing the first HTLC so we can
# check that HTLCs reloaded from the DB work.
2018-08-23 01:27:17 +02:00
# Feerates identical so we don't get gratuitous commit to update them
l1 = node_factory . get_node ( may_reconnect = True , feerates = ( 7500 , 7500 , 7500 ) )
2018-08-03 17:29:38 +02:00
l2 = node_factory . get_node ( disconnect = [ ' =WIRE_COMMITMENT_SIGNED-nocommit ' ] ,
may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Neither node should have a channel open, they are just connected
for n in ( l1 , l2 ) :
assert ( n . db_query ( ' SELECT COUNT(id) as count FROM channels; ' ) [ 0 ] [ ' count ' ] == 0 )
l1 . fund_channel ( l2 , 100000 )
peers = l1 . rpc . listpeers ( ) [ ' peers ' ]
assert ( only_one ( peers [ 0 ] [ ' channels ' ] ) [ ' state ' ] == ' CHANNELD_NORMAL ' )
# Both nodes should now have exactly one channel in the database
for n in ( l1 , l2 ) :
assert ( n . db_query ( ' SELECT COUNT(id) as count FROM channels; ' ) [ 0 ] [ ' count ' ] == 1 )
# Fire off a sendpay request, it'll get interrupted by a restart
executor . submit ( l1 . pay , l2 , 10000 )
# Wait for it to be committed to, i.e., stored in the DB
l1 . daemon . wait_for_log ( ' peer_in WIRE_COMMITMENT_SIGNED ' )
# Stop l2, l1 will reattempt to connect
print ( " Killing l2 in mid HTLC " )
l2 . daemon . kill ( )
# Clear the disconnect and timer stop so we can proceed normally
del l2 . daemon . opts [ ' dev-disconnect ' ]
# Wait for l1 to notice
wait_for ( lambda : ' connected ' not in only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] [ 0 ] [ ' channels ' ] ) )
# Now restart l2 and it should reload peers/channels from the DB
l2 . start ( )
wait_for ( lambda : len ( l2 . rpc . listpeers ( ) [ ' peers ' ] ) == 1 )
# Wait for the restored HTLC to finish
2018-10-10 01:11:55 +02:00
wait_for ( lambda : only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] [ 0 ] [ ' channels ' ] ) [ ' msatoshi_to_us ' ] == 99990000 )
2018-08-03 17:29:38 +02:00
2018-10-10 01:11:55 +02:00
wait_for ( lambda : len ( [ p for p in l1 . rpc . listpeers ( ) [ ' peers ' ] if p [ ' connected ' ] ] ) )
wait_for ( lambda : len ( [ p for p in l2 . rpc . listpeers ( ) [ ' peers ' ] if p [ ' connected ' ] ] ) )
2018-08-03 17:29:38 +02:00
# Now make sure this is really functional by sending a payment
l1 . pay ( l2 , 10000 )
# L1 doesn't actually update msatoshi_to_us until it receives
# revoke_and_ack from L2, which can take a little bit.
wait_for ( lambda : only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] [ 0 ] [ ' channels ' ] ) [ ' msatoshi_to_us ' ] == 99980000 )
assert only_one ( l2 . rpc . listpeers ( ) [ ' peers ' ] [ 0 ] [ ' channels ' ] ) [ ' msatoshi_to_us ' ] == 20000
# Finally restart l1, and make sure it remembers
l1 . restart ( )
assert only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] [ 0 ] [ ' channels ' ] ) [ ' msatoshi_to_us ' ] == 99980000
# Now make sure l1 is watching for unilateral closes
l2 . rpc . dev_fail ( l1 . info [ ' id ' ] )
l2 . daemon . wait_for_log ( ' Failing due to dev-fail command ' )
2018-09-19 06:06:07 +02:00
l2 . wait_for_channel_onchain ( l1 . info [ ' id ' ] )
2018-08-03 17:29:38 +02:00
bitcoind . generate_block ( 1 )
# L1 must notice.
l1 . daemon . wait_for_log ( ' to ONCHAIN ' )
2018-12-08 00:38:41 +01:00
def test_private_channel ( node_factory ) :
l1 , l2 = node_factory . line_graph ( 2 , announce_channels = False , wait_for_announce = False )
l3 , l4 = node_factory . line_graph ( 2 , announce_channels = True , wait_for_announce = True )
assert l1 . daemon . is_in_log ( ' Will open private channel with node {} ' . format ( l2 . info [ ' id ' ] ) )
assert not l2 . daemon . is_in_log ( ' Will open private channel with node {} ' . format ( l1 . info [ ' id ' ] ) )
assert not l3 . daemon . is_in_log ( ' Will open private channel with node {} ' . format ( l4 . info [ ' id ' ] ) )
l3 . daemon . wait_for_log ( ' Received node_announcement for node {} ' . format ( l4 . info [ ' id ' ] ) )
l4 . daemon . wait_for_log ( ' Received node_announcement for node {} ' . format ( l3 . info [ ' id ' ] ) )
assert not l1 . daemon . is_in_log ( ' Received node_announcement for node {} ' . format ( l2 . info [ ' id ' ] ) )
assert not l2 . daemon . is_in_log ( ' Received node_announcement for node {} ' . format ( l1 . info [ ' id ' ] ) )
2019-01-08 00:47:39 +01:00
# test for 'private' flag in rpc output
assert only_one ( only_one ( l1 . rpc . listpeers ( l2 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' channels ' ] ) [ ' private ' ]
# check non-private channel
assert not only_one ( only_one ( l4 . rpc . listpeers ( l3 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' channels ' ] ) [ ' private ' ]
2018-12-08 00:38:41 +01:00
2018-08-03 17:29:38 +02:00
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 for --dev-broadcast-interval " )
def test_channel_reenable ( node_factory ) :
2018-12-08 00:27:14 +01:00
l1 , l2 = node_factory . line_graph ( 2 , opts = { ' may_reconnect ' : True } , fundchannel = True , wait_for_announce = True )
2018-08-03 17:29:38 +02:00
l1 . daemon . wait_for_log ( ' Received node_announcement for node {} ' . format ( l2 . info [ ' id ' ] ) )
l2 . daemon . wait_for_log ( ' Received node_announcement for node {} ' . format ( l1 . info [ ' id ' ] ) )
# Both directions should be active before the restart
wait_for ( lambda : [ c [ ' active ' ] for c in l1 . rpc . listchannels ( ) [ ' channels ' ] ] == [ True , True ] )
# Restart l2, will cause l1 to reconnect
2018-08-14 02:26:03 +02:00
l2 . stop ( )
wait_for ( lambda : [ c [ ' active ' ] for c in l1 . rpc . listchannels ( ) [ ' channels ' ] ] == [ False , False ] )
l2 . start ( )
2018-08-03 17:29:38 +02:00
2018-08-14 02:26:03 +02:00
# Updates may be suppressed if redundant; just test results.
2018-08-03 17:29:38 +02:00
wait_for ( lambda : [ c [ ' active ' ] for c in l1 . rpc . listchannels ( ) [ ' channels ' ] ] == [ True , True ] )
2018-08-14 02:26:03 +02:00
wait_for ( lambda : [ c [ ' active ' ] for c in l2 . rpc . listchannels ( ) [ ' channels ' ] ] == [ True , True ] )
2018-08-03 17:29:38 +02:00
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_update_fee ( node_factory , bitcoind ) :
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = True )
chanid = l1 . get_channel_scid ( l2 )
# Make l1 send out feechange.
2018-08-23 01:27:24 +02:00
l1 . set_feerates ( ( 14000 , 7500 , 3750 ) )
2018-08-03 17:29:38 +02:00
l2 . daemon . wait_for_log ( ' peer updated fee to 14000 ' )
# Now make sure an HTLC works.
# (First wait for route propagation.)
l1 . wait_channel_active ( chanid )
sync_blockheight ( bitcoind , [ l1 , l2 ] )
# Make payments.
l1 . pay ( l2 , 200000000 )
l2 . pay ( l1 , 100000000 )
# Now shutdown cleanly.
with pytest . raises ( RpcError , match = r ' Channel close negotiation not finished ' ) :
l1 . rpc . close ( chanid , False , 0 )
l1 . daemon . wait_for_log ( ' to CLOSINGD_COMPLETE ' )
l2 . daemon . wait_for_log ( ' to CLOSINGD_COMPLETE ' )
# And should put closing into mempool.
2018-09-19 06:06:07 +02:00
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
l2 . wait_for_channel_onchain ( l1 . info [ ' id ' ] )
2018-08-03 17:29:38 +02:00
bitcoind . generate_block ( 1 )
l1 . daemon . wait_for_log ( ' to ONCHAIN ' )
l2 . daemon . wait_for_log ( ' to ONCHAIN ' )
bitcoind . generate_block ( 99 )
l1 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
l2 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_fee_limits ( node_factory ) :
# FIXME: Test case where opening denied.
2018-08-23 01:27:24 +02:00
l1 , l2 = node_factory . line_graph ( 2 , opts = { ' dev-max-fee-multiplier ' : 5 , ' may_reconnect ' : True } , fundchannel = True )
2018-08-03 17:29:38 +02:00
2018-08-23 01:27:24 +02:00
# L1 asks for stupid low fee (will actually hit the floor of 253)
l1 . stop ( )
l1 . set_feerates ( ( 15 , 15 , 15 ) , False )
l1 . start ( )
2018-08-03 17:29:38 +02:00
2018-08-23 01:27:24 +02:00
l1 . daemon . wait_for_log ( ' Peer permanent failure in CHANNELD_NORMAL: lightning_channeld: received ERROR channel .*: update_fee 253 outside range 1875-75000 ' )
2018-08-03 17:29:38 +02:00
# Make sure the resolution of this one doesn't interfere with the next!
# Note: may succeed, may fail with insufficient fee, depending on how
# bitcoind feels!
l1 . daemon . wait_for_log ( ' sendrawtx exit ' )
# Restore to normal.
2018-08-23 01:27:24 +02:00
l1 . stop ( )
l1 . set_feerates ( ( 15000 , 7500 , 3750 ) , False )
l1 . start ( )
2018-08-03 17:29:38 +02:00
# Try with node which sets --ignore-fee-limits
2018-08-23 01:27:24 +02:00
l3 = node_factory . get_node ( options = { ' ignore-fee-limits ' : ' true ' } , may_reconnect = True )
2018-08-03 17:29:38 +02:00
l1 . rpc . connect ( l3 . info [ ' id ' ] , ' localhost ' , l3 . port )
chan = l1 . fund_channel ( l3 , 10 * * 6 )
# Try stupid high fees
2018-08-23 01:27:24 +02:00
l1 . stop ( )
l1 . set_feerates ( ( 15000 * 10 , 7500 , 3750 ) , False )
l1 . start ( )
2018-08-03 17:29:38 +02:00
l3 . daemon . wait_for_log ( ' peer_in WIRE_UPDATE_FEE ' )
l3 . daemon . wait_for_log ( ' peer_in WIRE_COMMITMENT_SIGNED ' )
# We need to wait until both have committed and revoked the
# old state, otherwise we'll still try to commit with the old
# 15sat/byte fee
l1 . daemon . wait_for_log ( ' peer_out WIRE_REVOKE_AND_ACK ' )
# This should wait for close to complete
l1 . rpc . close ( chan )
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_update_fee_reconnect ( node_factory , bitcoind ) :
# Disconnect after first commitsig.
disconnects = [ ' +WIRE_COMMITMENT_SIGNED ' ]
2018-08-23 01:27:17 +02:00
# Feerates identical so we don't get gratuitous commit to update them
l1 = node_factory . get_node ( disconnect = disconnects , may_reconnect = True ,
2018-08-23 01:27:24 +02:00
feerates = ( 15000 , 15000 , 3750 ) )
# We match l2's later feerate, so we agree on same closing tx for simplicity.
l2 = node_factory . get_node ( may_reconnect = True ,
feerates = ( 14000 , 14000 , 3750 ) )
2018-08-03 17:29:38 +02:00
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
chan = l1 . fund_channel ( l2 , 10 * * 6 )
# Make l1 send out feechange; triggers disconnect/reconnect.
2018-08-23 01:27:24 +02:00
# (Note: < 10% change, so no smoothing here!)
l1 . set_feerates ( ( 14000 , 14000 , 3750 ) )
2018-08-03 17:29:38 +02:00
l1 . daemon . wait_for_log ( ' Setting REMOTE feerate to 14000 ' )
l2 . daemon . wait_for_log ( ' Setting LOCAL feerate to 14000 ' )
2018-10-26 07:49:53 +02:00
l1 . daemon . wait_for_log ( r ' dev_disconnect: \ +WIRE_COMMITMENT_SIGNED ' )
2018-08-03 17:29:38 +02:00
# Wait for reconnect....
l1 . daemon . wait_for_log ( ' Applying feerate 14000 to LOCAL ' )
l1 . pay ( l2 , 200000000 )
l2 . pay ( l1 , 100000000 )
# They should both have gotten commits with correct feerate.
assert l1 . daemon . is_in_log ( ' got commitsig [0-9]*: feerate 14000 ' )
assert l2 . daemon . is_in_log ( ' got commitsig [0-9]*: feerate 14000 ' )
# Now shutdown cleanly.
l1 . rpc . close ( chan )
# And should put closing into mempool.
2018-09-19 06:06:07 +02:00
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
l2 . wait_for_channel_onchain ( l1 . info [ ' id ' ] )
2018-08-03 17:29:38 +02:00
bitcoind . generate_block ( 1 )
l1 . daemon . wait_for_log ( ' to ONCHAIN ' )
l2 . daemon . wait_for_log ( ' to ONCHAIN ' )
bitcoind . generate_block ( 99 )
l1 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
l2 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
@unittest.skipIf ( not DEVELOPER , " Too slow without --dev-bitcoind-poll " )
def test_multiple_channels ( node_factory ) :
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( )
for i in range ( 3 ) :
# FIXME: we shouldn't disconnect on close?
ret = l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
assert ret [ ' id ' ] == l2 . info [ ' id ' ]
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
l1 . daemon . wait_for_log ( ' openingd-.*: Handed peer, entering loop ' )
l2 . daemon . wait_for_log ( ' openingd-.*: Handed peer, entering loop ' )
2018-08-03 17:29:38 +02:00
chan = l1 . fund_channel ( l2 , 10 * * 6 )
l1 . rpc . close ( chan )
channels = only_one ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) [ ' channels ' ]
assert len ( channels ) == 3
# Most in state ONCHAIN, last is CLOSINGD_COMPLETE
for i in range ( len ( channels ) - 1 ) :
assert channels [ i ] [ ' state ' ] == ' ONCHAIN '
assert channels [ - 1 ] [ ' state ' ] == ' CLOSINGD_COMPLETE '
@unittest.skipIf ( not DEVELOPER , " needs DEVELOPER=1 " )
def test_forget_channel ( node_factory ) :
l1 = node_factory . get_node ( )
l2 = node_factory . get_node ( )
l1 . fundwallet ( 10 * * 6 )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 5 )
assert len ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) == 1
# This should fail, the funding tx is in the mempool and may confirm
with pytest . raises ( RpcError , match = r ' Cowardly refusing to forget channel ' ) :
l1 . rpc . dev_forget_channel ( l2 . info [ ' id ' ] )
assert len ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) == 1
# Forcing should work
l1 . rpc . dev_forget_channel ( l2 . info [ ' id ' ] , True )
assert len ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) == 0
# And restarting should keep that peer forgotten
l1 . restart ( )
assert len ( l1 . rpc . listpeers ( ) [ ' peers ' ] ) == 0
def test_peerinfo ( node_factory , bitcoind ) :
2018-08-17 06:14:39 +02:00
l1 , l2 = node_factory . line_graph ( 2 , fundchannel = False , opts = { ' may_reconnect ' : True } )
2018-12-10 04:10:16 +01:00
if EXPERIMENTAL_FEATURES :
lfeatures = ' 8a '
else :
lfeatures = ' 88 '
2018-08-03 17:29:38 +02:00
# Gossiping but no node announcement yet
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ]
assert len ( l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' channels ' ] ) == 0
2018-12-10 04:10:16 +01:00
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' localfeatures ' ] == lfeatures
2018-08-03 17:29:38 +02:00
# Fund a channel to force a node announcement
chan = l1 . fund_channel ( l2 , 10 * * 6 )
# Now proceed to funding-depth and do a full gossip round
bitcoind . generate_block ( 5 )
l1 . daemon . wait_for_logs ( [ ' Received node_announcement for node ' + l2 . info [ ' id ' ] ] )
l2 . daemon . wait_for_logs ( [ ' Received node_announcement for node ' + l1 . info [ ' id ' ] ] )
# Should have announced the same global features as told to peer.
nodes1 = l1 . rpc . listnodes ( l2 . info [ ' id ' ] ) [ ' nodes ' ]
nodes2 = l2 . rpc . listnodes ( l2 . info [ ' id ' ] ) [ ' nodes ' ]
peer1 = l1 . rpc . getpeer ( l2 . info [ ' id ' ] )
peer2 = l2 . rpc . getpeer ( l1 . info [ ' id ' ] )
2018-09-28 05:24:25 +02:00
assert only_one ( nodes1 ) [ ' globalfeatures ' ] == peer1 [ ' globalfeatures ' ]
assert only_one ( nodes2 ) [ ' globalfeatures ' ] == peer2 [ ' globalfeatures ' ]
2018-08-03 17:29:38 +02:00
2018-12-10 04:10:16 +01:00
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' localfeatures ' ] == lfeatures
assert l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' localfeatures ' ] == lfeatures
2018-08-17 06:14:39 +02:00
# If it reconnects after db load, it should know features.
l1 . restart ( )
wait_for ( lambda : l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ] )
wait_for ( lambda : l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' connected ' ] )
2018-12-10 04:10:16 +01:00
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' localfeatures ' ] == lfeatures
assert l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' localfeatures ' ] == lfeatures
2018-08-17 06:14:39 +02:00
2018-08-03 17:29:38 +02:00
# Close the channel to forget the peer
with pytest . raises ( RpcError , match = r ' Channel close negotiation not finished ' ) :
l1 . rpc . close ( chan , False , 0 )
2018-09-28 05:24:14 +02:00
wait_for ( lambda : not only_one ( l1 . rpc . listpeers ( l2 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' connected ' ] )
wait_for ( lambda : not only_one ( l2 . rpc . listpeers ( l1 . info [ ' id ' ] ) [ ' peers ' ] ) [ ' connected ' ] )
2018-08-03 17:29:38 +02:00
bitcoind . generate_block ( 100 )
l1 . daemon . wait_for_log ( ' WIRE_ONCHAIN_ALL_IRREVOCABLY_RESOLVED ' )
l2 . daemon . wait_for_log ( ' WIRE_ONCHAIN_ALL_IRREVOCABLY_RESOLVED ' )
# The only channel was closed, everybody should have forgotten the nodes
assert l1 . rpc . listnodes ( ) [ ' nodes ' ] == [ ]
assert l2 . rpc . listnodes ( ) [ ' nodes ' ] == [ ]
def test_disconnectpeer ( node_factory , bitcoind ) :
l1 , l2 , l3 = node_factory . get_nodes ( 3 , opts = { ' may_reconnect ' : False } )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . rpc . connect ( l3 . info [ ' id ' ] , ' localhost ' , l3 . port )
# Gossiping
openingd: take peer before we're opening, wait for explicit funding msg.
Prior to this, lightningd would hand uninteresting peers back to connectd,
which would then return it to lightningd if it sent a non-gossip msg,
or if lightningd asked it to release the peer.
Now connectd hands the peer to lightningd once we've done the init
handshake, which hands it off to openingd.
This is a deep structural change, so we do the minimum here and cleanup
in the following patches.
Lightningd:
1. Remove peer_nongossip handling from connect_control and peer_control.
2. Remove list of outstanding fundchannel command; it was only needed to
find the race between us asking connectd to release the peer and it
reconnecting.
3. We can no longer tell if the remote end has started trying to fund a
channel (until it has succeeded): it's very transitory anyway so not
worth fixing.
4. We now always have a struct peer, and allocate an uncommitted_channel
for it, though it may never be used if neither end funds a channel.
5. We start funding on messages for openingd: we can get a funder_reply
or a fundee, or an error in response to our request to fund a channel.
so we handle all of them.
6. A new peer_start_openingd() is called after connectd hands us a peer.
7. json_fund_channel just looks through local peers; there are none
hidden in connectd any more.
8. We sometimes start a new openingd just to send an error message.
Openingd:
1. We always have information we need to accept them funding a channel (in
the init message).
2. We have to listen for three fds: peer, gossip and master, so we opencode
the poll.
3. We have an explicit message to start trying to fund a channel.
4. We can be told to send a message in our init message.
Testing:
1. We don't handle some things gracefully yet, so two tests are disabled.
2. 'hand_back_peer .*: now local again' from connectd is no longer a message,
openingd says 'Handed peer, entering loop' once its managing it.
3. peer['state'] used to be set to 'GOSSIPING' (otherwise this field doesn't
exist; 'state' is now per-channel. It doesn't exist at all now.
4. Some tests now need to turn on IO logging in openingd, not connectd.
5. There's a gap between connecting on one node and having connectd on
the peer hand over the connection to openingd. Our tests sometimes
checked getpeers() on the peer, and didn't see anything, so line_graph
needed updating.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
2018-08-08 16:10:58 +02:00
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ]
assert len ( l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' channels ' ] ) == 0
assert l1 . rpc . getpeer ( l3 . info [ ' id ' ] ) [ ' connected ' ]
assert len ( l1 . rpc . getpeer ( l3 . info [ ' id ' ] ) [ ' channels ' ] ) == 0
2018-08-09 02:25:19 +02:00
wait_for ( lambda : l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) is not None )
2018-08-03 17:29:38 +02:00
# Disconnect l2 from l1
l1 . rpc . disconnect ( l2 . info [ ' id ' ] )
# Make sure listpeers no longer returns the disconnected node
assert l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) is None
2018-08-09 02:25:19 +02:00
wait_for ( lambda : l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) is None )
2018-08-03 17:29:38 +02:00
# Make sure you cannot disconnect after disconnecting
with pytest . raises ( RpcError , match = r ' Peer not connected ' ) :
l1 . rpc . disconnect ( l2 . info [ ' id ' ] )
with pytest . raises ( RpcError , match = r ' Peer not connected ' ) :
l2 . rpc . disconnect ( l1 . info [ ' id ' ] )
# Fund channel l1 -> l3
l1 . fund_channel ( l3 , 10 * * 6 )
bitcoind . generate_block ( 5 )
# disconnecting a non gossiping peer results in error
2018-08-09 02:25:29 +02:00
with pytest . raises ( RpcError , match = r ' Peer is in state CHANNELD_NORMAL ' ) :
2018-08-03 17:29:38 +02:00
l1 . rpc . disconnect ( l3 . info [ ' id ' ] )
@unittest.skipIf ( not DEVELOPER , " needs --dev-max-funding-unconfirmed-blocks " )
def test_fundee_forget_funding_tx_unconfirmed ( node_factory , bitcoind ) :
""" Test that fundee will forget the channel if
the funding tx has been unconfirmed for too long .
"""
# Keep this low (default is 2016), since everything
# is much slower in VALGRIND mode and wait_for_log
# could time out before lightningd processes all the
# blocks.
blocks = 200
# funder
2018-08-22 02:13:57 +02:00
l1 = node_factory . get_node ( )
2018-08-03 17:29:38 +02:00
# fundee
l2 = node_factory . get_node ( options = { " dev-max-funding-unconfirmed-blocks " : blocks } )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Give funder some funds.
l1 . fundwallet ( 10 * * 7 )
# Let blocks settle.
time . sleep ( 1 )
2018-09-05 10:43:32 +02:00
def mock_sendrawtransaction ( r ) :
return { ' error ' : ' sendrawtransaction disabled ' }
# Prevent funder from broadcasting funding tx (any tx really).
l1 . daemon . rpcproxy . mock_rpc ( ' sendrawtransaction ' , mock_sendrawtransaction )
2018-08-03 17:29:38 +02:00
# Fund the channel.
# The process will complete, but funder will be unable
# to broadcast and confirm funding tx.
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 )
2018-09-05 10:43:32 +02:00
2018-08-03 17:29:38 +02:00
# Generate blocks until unconfirmed.
bitcoind . generate_block ( blocks )
# fundee will forget channel!
l2 . daemon . wait_for_log ( ' Forgetting channel: It has been {} blocks ' . format ( blocks ) )
2018-09-05 10:43:32 +02:00
2018-08-03 17:29:38 +02:00
# fundee will also forget and disconnect from peer.
assert len ( l2 . rpc . listpeers ( l1 . info [ ' id ' ] ) [ ' peers ' ] ) == 0
2018-08-22 02:09:56 +02:00
2018-08-23 01:27:25 +02:00
@unittest.skipIf ( not DEVELOPER , " needs dev_fail " )
def test_no_fee_estimate ( node_factory , bitcoind , executor ) :
l1 = node_factory . get_node ( start = False )
2018-09-05 01:01:50 +02:00
# Fail any fee estimation requests until we allow them further down
l1 . daemon . rpcproxy . mock_rpc ( ' estimatesmartfee ' , {
' error ' : { " errors " : [ " Insufficient data or no feerate found " ] , " blocks " : 0 }
} )
2018-08-23 01:27:25 +02:00
l1 . start ( )
l2 = node_factory . get_node ( )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# Can't fund a channel.
l1 . fundwallet ( 10 * * 7 )
with pytest . raises ( RpcError , match = r ' Cannot estimate fees ' ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 )
# Can't withdraw either.
with pytest . raises ( RpcError , match = r ' Cannot estimate fees ' ) :
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , ' all ' )
2018-08-28 22:46:34 +02:00
# Can't use feerate names, either.
with pytest . raises ( RpcError , match = r ' Cannot estimate fees ' ) :
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , ' all ' , ' urgent ' )
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , ' all ' , ' normal ' )
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , ' all ' , ' slow ' )
with pytest . raises ( RpcError , match = r ' Cannot estimate fees ' ) :
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 , ' urgent ' )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 , ' normal ' )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 , ' slow ' )
2018-08-27 07:13:57 +02:00
# Can with manual feerate.
2018-08-28 22:46:32 +02:00
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , 10000 , ' 1500perkb ' )
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 , ' 2000perkw ' )
2018-08-27 07:13:57 +02:00
# Make sure we clean up cahnnel for later attempt.
l1 . daemon . wait_for_log ( ' sendrawtx exit 0 ' )
l1 . rpc . dev_fail ( l2 . info [ ' id ' ] )
2018-08-29 03:29:50 +02:00
l1 . daemon . wait_for_log ( ' Failing due to dev-fail command ' )
2018-09-19 06:06:07 +02:00
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
2018-08-27 07:13:57 +02:00
bitcoind . generate_block ( 6 )
wait_for ( lambda : only_one ( l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' channels ' ] ) [ ' state ' ] == ' ONCHAIN ' )
wait_for ( lambda : only_one ( l2 . rpc . getpeer ( l1 . info [ ' id ' ] ) [ ' channels ' ] ) [ ' state ' ] == ' ONCHAIN ' )
2018-08-23 01:27:25 +02:00
# But can accept incoming connections.
2018-08-27 07:13:57 +02:00
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
2018-08-23 01:27:25 +02:00
l2 . fund_channel ( l1 , 10 * * 6 )
# Can do HTLCs.
l2 . pay ( l1 , 10 * * 5 )
# Can do mutual close.
l1 . rpc . close ( l2 . info [ ' id ' ] )
bitcoind . generate_block ( 100 )
# Can do unilateral close.
l2 . rpc . connect ( l1 . info [ ' id ' ] , ' localhost ' , l1 . port )
l2 . fund_channel ( l1 , 10 * * 6 )
l2 . pay ( l1 , 10 * * 9 / / 2 )
l1 . rpc . dev_fail ( l2 . info [ ' id ' ] )
2018-08-29 03:29:50 +02:00
l1 . daemon . wait_for_log ( ' Failing due to dev-fail command ' )
2018-09-19 06:06:07 +02:00
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
2018-08-23 01:27:25 +02:00
bitcoind . generate_block ( 5 )
2018-09-19 06:06:07 +02:00
wait_for ( lambda : len ( bitcoind . rpc . getrawmempool ( ) ) > 0 )
2018-08-23 01:27:25 +02:00
bitcoind . generate_block ( 100 )
2018-08-29 03:29:50 +02:00
# Start estimatesmartfee.
2018-08-23 01:27:25 +02:00
l1 . set_feerates ( ( 15000 , 7500 , 3750 ) , True )
2018-08-28 22:46:34 +02:00
# Can now fund a channel (as a test, use slow feerate).
2018-08-23 01:27:25 +02:00
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
2018-08-28 22:46:34 +02:00
l1 . rpc . fundchannel ( l2 . info [ ' id ' ] , 10 * * 6 , ' slow ' )
2018-08-23 01:27:25 +02:00
2018-08-28 22:46:34 +02:00
# Can withdraw (use urgent feerate).
l1 . rpc . withdraw ( l2 . rpc . newaddr ( ) [ ' address ' ] , ' all ' , ' urgent ' )
2018-08-23 01:27:25 +02:00
2018-08-22 02:09:56 +02:00
@unittest.skipIf ( not DEVELOPER , " needs --dev-disconnect " )
def test_funder_feerate_reconnect ( node_factory , bitcoind ) :
# l1 updates fees, then reconnect so l2 retransmits commitment_signed.
disconnects = [ ' -WIRE_COMMITMENT_SIGNED ' ]
2018-08-23 13:45:33 +02:00
l1 = node_factory . get_node ( may_reconnect = True ,
feerates = ( 7500 , 7500 , 7500 ) )
2018-08-22 02:09:56 +02:00
l2 = node_factory . get_node ( disconnect = disconnects , may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
2018-08-23 13:45:33 +02:00
# create fee update, causing disconnect.
l1 . set_feerates ( ( 15000 , 7500 , 3750 ) )
2018-10-26 07:49:53 +02:00
l2 . daemon . wait_for_log ( r ' dev_disconnect: \ -WIRE_COMMITMENT_SIGNED ' )
2018-08-22 02:09:56 +02:00
# Wait until they reconnect.
l1 . daemon . wait_for_log ( ' Peer transient failure in CHANNELD_NORMAL ' )
wait_for ( lambda : l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ] )
# Should work normally.
l1 . pay ( l2 , 200000000 )
2018-08-17 06:16:34 +02:00
2018-12-10 02:03:42 +01:00
def test_funder_simple_reconnect ( node_factory , bitcoind ) :
""" Sanity check that reconnection works with completely unused channels """
# Set fees even so it doesn't send any commitments.
l1 = node_factory . get_node ( may_reconnect = True ,
feerates = ( 7500 , 7500 , 7500 ) )
l2 = node_factory . get_node ( may_reconnect = True )
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
l1 . fund_channel ( l2 , 10 * * 6 )
l1 . rpc . disconnect ( l2 . info [ ' id ' ] , True )
# Wait until they reconnect.
wait_for ( lambda : l1 . rpc . getpeer ( l2 . info [ ' id ' ] ) [ ' connected ' ] )
# Should work normally.
l1 . pay ( l2 , 200000000 )
2018-08-17 06:16:34 +02:00
@unittest.skipIf ( not DEVELOPER , " needs LIGHTNINGD_DEV_LOG_IO " )
2019-01-18 02:21:19 +01:00
@unittest.skipIf ( not EXPERIMENTAL_FEATURES , " needs option_data_loss_protect " )
2018-08-17 07:06:36 +02:00
def test_dataloss_protection ( node_factory , bitcoind ) :
2019-01-18 02:21:19 +01:00
l1 = node_factory . get_node ( may_reconnect = True , log_all_io = True ,
feerates = ( 7500 , 7500 , 7500 ) )
l2 = node_factory . get_node ( may_reconnect = True , log_all_io = True ,
feerates = ( 7500 , 7500 , 7500 ) )
2018-08-17 06:16:34 +02:00
l1 . rpc . connect ( l2 . info [ ' id ' ] , ' localhost ' , l2 . port )
# l1 should send out WIRE_INIT (0010)
2018-10-26 07:49:53 +02:00
l1 . daemon . wait_for_log ( r " \ [OUT \ ] 0010 "
2018-08-17 06:16:34 +02:00
# gflen == 0
" 0000 "
# lflen == 1
" 0001 "
# Local features 1, 3 and 7 (0x8a).
" 8a " )
l1 . fund_channel ( l2 , 10 * * 6 )
2018-08-17 07:06:36 +02:00
l2 . stop ( )
# Save copy of the db.
dbpath = os . path . join ( l2 . daemon . lightning_dir , " lightningd.sqlite3 " )
orig_db = open ( dbpath , " rb " ) . read ( )
l2 . start ( )
2018-08-17 06:16:34 +02:00
# l1 should have sent WIRE_CHANNEL_REESTABLISH with option_data_loss_protect.
2018-10-26 07:49:53 +02:00
l1 . daemon . wait_for_log ( r " \ [OUT \ ] 0088 "
2018-08-17 06:16:34 +02:00
# channel_id
" [0-9a-f] {64} "
# next_local_commitment_number
2019-01-18 02:21:19 +01:00
" 0000000000000001 "
2018-08-17 06:16:34 +02:00
# next_remote_revocation_number
2019-01-18 02:21:19 +01:00
" 0000000000000000 "
2018-08-22 04:33:32 +02:00
# your_last_per_commitment_secret (funding_depth may
# trigger a fee-update and commit, hence this may not
# be zero)
" [0-9a-f] {64} "
2018-08-17 06:16:34 +02:00
# my_current_per_commitment_point
" 0[23][0-9a-f] {64} " )
# After an htlc, we should get different results (two more commits)
l1 . pay ( l2 , 200000000 )
# Make sure both sides consider it completely settled (has received both
# REVOKE_AND_ACK)
2018-10-26 07:49:53 +02:00
l1 . daemon . wait_for_logs ( [ r " \ [IN \ ] 0085 " ] * 2 )
l2 . daemon . wait_for_logs ( [ r " \ [IN \ ] 0085 " ] * 2 )
2018-08-17 06:16:34 +02:00
l2 . restart ( )
# l1 should have sent WIRE_CHANNEL_REESTABLISH with option_data_loss_protect.
2018-10-26 07:49:53 +02:00
l1 . daemon . wait_for_log ( r " \ [OUT \ ] 0088 "
2018-08-17 06:16:34 +02:00
# channel_id
" [0-9a-f] {64} "
# next_local_commitment_number
2018-08-22 04:33:32 +02:00
" 000000000000000[1-9] "
2018-08-17 06:16:34 +02:00
# next_remote_revocation_number
2018-08-22 04:33:32 +02:00
" 000000000000000[1-9] "
2018-08-17 06:16:34 +02:00
# your_last_per_commitment_secret
" [0-9a-f] {64} "
# my_current_per_commitment_point
" 0[23][0-9a-f] {64} " )
2018-08-17 07:06:36 +02:00
# Now, move l2 back in time.
l2 . stop ( )
# Overwrite with OLD db.
open ( dbpath , " wb " ) . write ( orig_db )
l2 . start ( )
# l2 should freak out!
2018-08-23 03:08:48 +02:00
l2 . daemon . wait_for_log ( " Peer permanent failure in CHANNELD_NORMAL: Awaiting unilateral close " )
2018-08-17 07:06:36 +02:00
# l1 should drop to chain.
2018-09-19 06:06:07 +02:00
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
2018-08-17 07:06:36 +02:00
# l2 must NOT drop to chain.
l2 . daemon . wait_for_log ( " Cannot broadcast our commitment tx: they have a future one " )
assert not l2 . daemon . is_in_log ( ' sendrawtx exit 0 ' )
2018-08-17 07:06:36 +02:00
closetxid = only_one ( bitcoind . rpc . getrawmempool ( False ) )
# l2 should still recover something!
bitcoind . generate_block ( 1 )
2018-08-22 04:33:32 +02:00
l2 . daemon . wait_for_log ( " ERROR: Unknown commitment #[0-9], recovering our funds! " )
2018-08-17 07:06:36 +02:00
# Restarting l2, and it should remember from db.
l2 . restart ( )
2018-08-22 04:33:32 +02:00
l2 . daemon . wait_for_log ( " ERROR: Unknown commitment #[0-9], recovering our funds! " )
2018-08-17 07:06:36 +02:00
bitcoind . generate_block ( 100 )
l2 . daemon . wait_for_log ( ' WIRE_ONCHAIN_ALL_IRREVOCABLY_RESOLVED ' )
# l2 should have it in wallet.
assert ( closetxid , " confirmed " ) in set ( [ ( o [ ' txid ' ] , o [ ' status ' ] ) for o in l2 . rpc . listfunds ( ) [ ' outputs ' ] ] )
2018-09-04 07:18:55 +02:00
@unittest.skipIf ( not DEVELOPER , " needs dev_disconnect " )
def test_restart_multi_htlc_rexmit ( node_factory , bitcoind , executor ) :
# l1 disables commit timer once we send first htlc, dies on commit
disconnects = [ ' =WIRE_UPDATE_ADD_HTLC-nocommit ' ,
' -WIRE_COMMITMENT_SIGNED ' ]
l1 , l2 = node_factory . line_graph ( 2 , opts = [ { ' disconnect ' : disconnects ,
' may_reconnect ' : True } ,
{ ' may_reconnect ' : True } ] )
executor . submit ( l1 . pay , l2 , 20000 )
executor . submit ( l1 . pay , l2 , 30000 )
l1 . daemon . wait_for_logs ( [ ' peer_out WIRE_UPDATE_ADD_HTLC ' ] * 2 )
l1 . rpc . dev_reenable_commit ( l2 . info [ ' id ' ] )
l1 . daemon . wait_for_log ( ' dev_disconnect: -WIRE_COMMITMENT_SIGNED ' )
# This will make it reconnect
l1 . stop ( )
# Clear the disconnect so we can proceed normally
del l1 . daemon . opts [ ' dev-disconnect ' ]
l1 . start ( )
# Payments will fail due to restart, but we can see results in listpayments.
print ( l1 . rpc . listpayments ( ) )
wait_for ( lambda : [ p [ ' status ' ] for p in l1 . rpc . listpayments ( ) [ ' payments ' ] ] == [ ' complete ' , ' complete ' ] )
2018-10-09 10:46:52 +02:00
@unittest.skipIf ( not DEVELOPER , " needs dev-disconnect " )
def test_fulfill_incoming_first ( node_factory , bitcoind ) :
""" Test that we handle the case where we completely resolve incoming htlc
before fulfilled outgoing htlc """
# We agree on fee change first, then add HTLC, then remove; stop after remove.
disconnects = [ ' +WIRE_COMMITMENT_SIGNED*3 ' ]
# We manually reconnect l2 & l3, after 100 blocks; hence allowing manual
2018-10-10 00:39:05 +02:00
# reconnect, but disabling auto connect, and massive cltv so 2/3 doesn't
2018-10-09 10:46:52 +02:00
# time out.
l1 , l2 , l3 = node_factory . line_graph ( 3 , opts = [ { } ,
{ ' may_reconnect ' : True ,
' dev-no-reconnect ' : None } ,
{ ' may_reconnect ' : True ,
' dev-no-reconnect ' : None ,
' disconnect ' : disconnects ,
' cltv-final ' : 200 } ] ,
2018-12-08 00:27:14 +01:00
wait_for_announce = True )
2018-10-09 10:46:52 +02:00
# This succeeds.
l1 . rpc . pay ( l3 . rpc . invoice ( 200000000 , ' test_fulfill_incoming_first ' , ' desc ' ) [ ' bolt11 ' ] )
# l1 can shutdown, fine.
l1 . rpc . close ( l2 . info [ ' id ' ] )
l1 . wait_for_channel_onchain ( l2 . info [ ' id ' ] )
bitcoind . generate_block ( 100 )
l2 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
# Now, l2 should restore from DB fine, even though outgoing HTLC no longer
# has an incoming.
l2 . restart ( )
2018-10-09 10:49:52 +02:00
# Manually reconnect l2->l3.
l2 . rpc . connect ( l3 . info [ ' id ' ] , ' localhost ' , l3 . port )
# Fulfill should be retransmitted OK (ignored result).
l2 . rpc . close ( l3 . info [ ' id ' ] )
l2 . wait_for_channel_onchain ( l3 . info [ ' id ' ] )
bitcoind . generate_block ( 100 )
l2 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
l3 . daemon . wait_for_log ( ' onchaind complete, forgetting peer ' )
2018-10-09 10:53:52 +02:00
def test_restart_many_payments ( node_factory ) :
l1 = node_factory . get_node ( may_reconnect = True )
# On my laptop, these take 74 seconds and 44 seconds (with restart commented out)
if VALGRIND :
num = 2
else :
num = 5
# Nodes with channels into the main node
innodes = node_factory . get_nodes ( num , opts = { ' may_reconnect ' : True } )
inchans = [ ]
for n in innodes :
n . rpc . connect ( l1 . info [ ' id ' ] , ' localhost ' , l1 . port )
2018-11-22 03:17:29 +01:00
inchans . append ( n . fund_channel ( l1 , 10 * * 6 , False ) )
2018-10-09 10:53:52 +02:00
# Nodes with channels out of the main node
outnodes = node_factory . get_nodes ( len ( innodes ) , opts = { ' may_reconnect ' : True } )
outchans = [ ]
for n in outnodes :
n . rpc . connect ( l1 . info [ ' id ' ] , ' localhost ' , l1 . port )
2018-11-22 03:17:29 +01:00
outchans . append ( l1 . fund_channel ( n , 10 * * 6 , False ) )
# Now do all the waiting at once: if !DEVELOPER, this can be *very* slow!
l1_logs = [ ]
for i in range ( len ( innodes ) ) :
scid = inchans [ i ]
2019-01-15 05:11:27 +01:00
l1_logs + = [ r ' update for channel {} /0 now ACTIVE ' . format ( scid ) ,
r ' update for channel {} /1 now ACTIVE ' . format ( scid ) ,
2018-11-22 03:17:29 +01:00
' to CHANNELD_NORMAL ' ]
2019-01-15 05:11:27 +01:00
innodes [ i ] . daemon . wait_for_logs ( [ r ' update for channel {} /0 now ACTIVE '
2018-11-22 03:17:29 +01:00
. format ( scid ) ,
2019-01-15 05:11:27 +01:00
r ' update for channel {} /1 now ACTIVE '
2018-11-22 03:17:29 +01:00
. format ( scid ) ,
' to CHANNELD_NORMAL ' ] )
for i in range ( len ( outnodes ) ) :
scid = outchans [ i ]
2019-01-15 05:11:27 +01:00
l1_logs + = [ r ' update for channel {} /0 now ACTIVE ' . format ( scid ) ,
r ' update for channel {} /1 now ACTIVE ' . format ( scid ) ,
2018-11-22 03:17:29 +01:00
' to CHANNELD_NORMAL ' ]
2019-01-15 05:11:27 +01:00
outnodes [ i ] . daemon . wait_for_logs ( [ r ' update for channel {} /0 now ACTIVE '
2018-11-22 03:17:29 +01:00
. format ( scid ) ,
2019-01-15 05:11:27 +01:00
r ' update for channel {} /1 now ACTIVE '
2018-11-22 03:17:29 +01:00
. format ( scid ) ,
' to CHANNELD_NORMAL ' ] )
l1 . daemon . wait_for_logs ( l1_logs )
2018-10-09 10:53:52 +02:00
# Manually create routes, get invoices
2018-10-10 00:39:05 +02:00
Payment = namedtuple ( ' Payment ' , [ ' innode ' , ' route ' , ' payment_hash ' ] )
to_pay = [ ]
2018-10-09 10:53:52 +02:00
for i in range ( len ( innodes ) ) :
# This one will cause WIRE_INCORRECT_CLTV_EXPIRY from l1.
2018-10-10 00:39:05 +02:00
route = [ { ' msatoshi ' : 100001001 ,
' id ' : l1 . info [ ' id ' ] ,
' delay ' : 10 ,
' channel ' : inchans [ i ] } ,
{ ' msatoshi ' : 100000000 ,
' id ' : outnodes [ i ] . info [ ' id ' ] ,
' delay ' : 5 ,
' channel ' : outchans [ i ] } ]
payment_hash = outnodes [ i ] . rpc . invoice ( 100000000 , " invoice " , " invoice " ) [ ' payment_hash ' ]
to_pay . append ( Payment ( innodes [ i ] , route , payment_hash ) )
2018-10-09 10:53:52 +02:00
# This one should be routed through to the outnode.
2018-10-10 00:39:05 +02:00
route = [ { ' msatoshi ' : 100001001 ,
' id ' : l1 . info [ ' id ' ] ,
' delay ' : 11 ,
' channel ' : inchans [ i ] } ,
{ ' msatoshi ' : 100000000 ,
' id ' : outnodes [ i ] . info [ ' id ' ] ,
' delay ' : 5 ,
' channel ' : outchans [ i ] } ]
payment_hash = outnodes [ i ] . rpc . invoice ( 100000000 , " invoice2 " , " invoice2 " ) [ ' payment_hash ' ]
to_pay . append ( Payment ( innodes [ i ] , route , payment_hash ) )
2018-10-09 10:53:52 +02:00
# sendpay is async.
2018-10-10 00:39:05 +02:00
for p in to_pay :
p . innode . rpc . sendpay ( p . route , p . payment_hash )
2018-10-09 10:53:52 +02:00
# Now restart l1 while traffic is flowing...
l1 . restart ( )
# Wait for them to finish.
2018-10-10 00:39:05 +02:00
for n in innodes :
wait_for ( lambda : ' pending ' not in [ p [ ' status ' ] for p in n . rpc . listpayments ( ) [ ' payments ' ] ] )
