mirrors/core-lightning
1
0
Fork 0
mirror of https://github.com/ElementsProject/lightning.git synced 2025-03-03 18:57:06 +01:00
Code Issues Projects Releases Wiki Activity

pytest: add filters arg to query_gossip()

Browse source 
Code changes mean we're going to get gossip_timestamp_filter messages from
peers.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
This commit is contained in:
Rusty Russell 2019-10-08 11:37:24 +10:30 • committed by neil saitug
parent 9d336763ff
commit a3f6ce1f8f
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tests/utils.py
View file

@ -809,7 +809,7 @@ class LightningNode(object):
wait_for(lambda: txid in self.bitcoin.rpc.getrawmempool()) wait_for(lambda: txid in self.bitcoin.rpc.getrawmempool())
def query_gossip(self, querytype, *args): def query_gossip(self, querytype, *args, filters=[]):
"""Generate a gossip query, feed it into this node and get responses """Generate a gossip query, feed it into this node and get responses
in hex""" in hex"""
query = subprocess.run(['devtools/mkquery', query = subprocess.run(['devtools/mkquery',
@ -825,10 +825,18 @@ class LightningNode(object):
check=True, check=True,
timeout=TIMEOUT, stdout=subprocess.PIPE).stdout timeout=TIMEOUT, stdout=subprocess.PIPE).stdout
def passes_filters(hmsg, filters):
for f in filters:
if hmsg.startswith(f):
return False
return True
msgs = [] msgs = []
while len(out): while len(out):
length = struct.unpack('>H', out[0:2])[0] length = struct.unpack('>H', out[0:2])[0]
msgs.append(out[2:2 + length].hex()) hmsg = out[2:2 + length].hex()
if passes_filters(hmsg, filters):
msgs.append(out[2:2 + length].hex())
out = out[2 + length:] out = out[2 + length:]
return msgs return msgs