-
Notifications
You must be signed in to change notification settings - Fork 129
sauron: Add mutinynet and tests #584
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Changes from all commits
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
.venv/ |
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,2 +1,2 @@ | ||
pyln-client>=23.2 | ||
pyln-client>=23.2,<=24.5 | ||
requests[socks]>=2.23.0 | ||
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,161 @@ | ||
#!/usr/bin/python | ||
|
||
import os | ||
|
||
import pyln | ||
import pytest | ||
from pyln.testing import utils | ||
from pyln.testing.fixtures import * # noqa: F403 | ||
from util import LightningD | ||
|
||
pyln.testing.fixtures.network_daemons["bitcoin"] = utils.BitcoinD | ||
|
||
|
||
class LightningNode(utils.LightningNode): | ||
def __init__(self, *args, **kwargs): | ||
pyln.testing.utils.TEST_NETWORK = "bitcoin" | ||
utils.LightningNode.__init__(self, *args, **kwargs) | ||
lightning_dir = args[1] | ||
self.daemon = LightningD(lightning_dir, None, port=self.daemon.port) # noqa: F405 | ||
options = { | ||
"disable-plugin": "bcli", | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. I don't think you need to override this class at all. Just set the options appropriately when using the There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. Hey @cdecker it looks like we actually do need to override both the We need to override the In addition, we have to override the These options if set, crash On top of this, the So unfortunately we need to leave these classes as they are unless I'm missing something. |
||
"network": "bitcoin", | ||
"plugin": os.path.join(os.path.dirname(__file__), "../sauron.py"), | ||
"sauron-api-endpoint": "https://blockstream.info/api", | ||
} | ||
self.daemon.opts.update(options) | ||
|
||
# Monkey patch | ||
def set_feerates(self, feerates, wait_for_effect=True): | ||
return None | ||
|
||
|
||
@pytest.fixture | ||
def node_cls(monkeypatch): | ||
monkeypatch.setenv("TEST_NETWORK", "bitcoin") | ||
yield LightningNode | ||
|
||
|
||
def test_rpc_getchaininfo(node_factory): | ||
""" | ||
Test getchaininfo | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
response = ln_node.rpc.call("getchaininfo") | ||
|
||
assert ln_node.daemon.is_in_log("Sauron plugin initialized using Esplora API") | ||
|
||
expected_response_keys = ["chain", "blockcount", "headercount", "ibd"] | ||
assert list(response.keys()) == expected_response_keys | ||
assert response["chain"] == "main" | ||
assert not response["ibd"] | ||
|
||
|
||
def test_rpc_getrawblockbyheight(node_factory): | ||
""" | ||
Test getrawblockbyheight | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
response = ln_node.rpc.call("getrawblockbyheight", {"height": 0}) | ||
|
||
expected_response = { | ||
"block": "0100000000000000000000000000000000000000000000000000000000000000000000003ba3edfd7a7b12b27ac72c3e67768f617fc81bc3888a51323a9fb8aa4b1e5e4a29ab5f49ffff001d1dac2b7c0101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff4d04ffff001d0104455468652054696d65732030332f4a616e2f32303039204368616e63656c6c6f72206f6e206272696e6b206f66207365636f6e64206261696c6f757420666f722062616e6b73ffffffff0100f2052a01000000434104678afdb0fe5548271967f1a67130b7105cd6a828e03909a67962e0ea1f61deb649f6bc3f4cef38c4f35504e51ec112de5c384df7ba0b8d578a4c702b6bf11d5fac00000000", | ||
"blockhash": "000000000019d6689c085ae165831e934ff763ae46a2a6c172b3f1b60a8ce26f", | ||
} | ||
assert response == expected_response | ||
|
||
@pytest.mark.skip(reason="testing_theory") | ||
def test_rpc_sendrawtransaction_invalid(node_factory): | ||
""" | ||
Test sendrawtransaction | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
expected_response = { | ||
"errmsg": 'sendrawtransaction RPC error: {"code":-22,"message":"TX decode failed. Make sure the tx has at least one input."}', | ||
"success": False, | ||
} | ||
response = ln_node.rpc.call( | ||
"sendrawtransaction", | ||
{"tx": "invalid-raw-tx"}, | ||
) | ||
|
||
assert response == expected_response | ||
|
||
|
||
def test_rpc_getutxout(node_factory): | ||
""" | ||
Test getutxout | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
expected_response = { | ||
"amount": 1000000000, | ||
"script": "4104b5abd412d4341b45056d3e376cd446eca43fa871b51961330deebd84423e740daa520690e1d9e074654c59ff87b408db903649623e86f1ca5412786f61ade2bfac", | ||
} | ||
response = ln_node.rpc.call( | ||
"getutxout", | ||
{ | ||
# block 181 | ||
"txid": "a16f3ce4dd5deb92d98ef5cf8afeaf0775ebca408f708b2146c4fb42b41e14be", | ||
"vout": 0, | ||
}, | ||
) | ||
assert response == expected_response | ||
|
||
|
||
def test_rpc_estimatefees(node_factory): | ||
""" | ||
Test estimatefees | ||
""" | ||
|
||
ln_node = node_factory.get_node() | ||
|
||
# Sample response | ||
# { | ||
# "opening": 4477, | ||
# "mutual_close": 4477, | ||
# "unilateral_close": 11929, | ||
# "delayed_to_us": 4477, | ||
# "htlc_resolution": 5652, | ||
# "penalty": 5652, | ||
# "min_acceptable": 1060, | ||
# "max_acceptable": 119290, | ||
# "feerate_floor": 1520, | ||
# "feerates": [ | ||
# {"blocks": 2, "feerate": 11929}, | ||
# {"blocks": 6, "feerate": 5652}, | ||
# {"blocks": 12, "feerate": 4477}, | ||
# {"blocks": 144, "feerate": 2120} | ||
# ] | ||
# } | ||
response = ln_node.rpc.call("estimatefees") | ||
|
||
|
||
|
||
expected_response_keys = [ | ||
"opening", | ||
"mutual_close", | ||
"unilateral_close", | ||
"delayed_to_us", | ||
"htlc_resolution", | ||
"penalty", | ||
"min_acceptable", | ||
"max_acceptable", | ||
"feerate_floor", | ||
"feerates", | ||
] | ||
assert list(response.keys()) == expected_response_keys | ||
|
||
expected_feerates_keys = ("blocks", "feerate") | ||
assert ( | ||
list(set([tuple(entry.keys()) for entry in response["feerates"]]))[0] | ||
== expected_feerates_keys | ||
) | ||
|
||
expected_feerates_blocks = [2, 6, 12, 144] | ||
assert [ | ||
entry["blocks"] for entry in response["feerates"] | ||
] == expected_feerates_blocks |
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,157 @@ | ||
#!/usr/bin/python | ||
|
||
import os | ||
|
||
import pyln | ||
import pytest | ||
from pyln.testing import utils | ||
from pyln.testing.fixtures import * # noqa: F403 | ||
from util import LightningD | ||
|
||
pyln.testing.fixtures.network_daemons["signet"] = utils.BitcoinD | ||
|
||
|
||
class LightningNode(utils.LightningNode): | ||
def __init__(self, *args, **kwargs): | ||
pyln.testing.utils.TEST_NETWORK = "signet" | ||
utils.LightningNode.__init__(self, *args, **kwargs) | ||
lightning_dir = args[1] | ||
self.daemon = LightningD(lightning_dir, None, port=self.daemon.port) # noqa: F405 | ||
options = { | ||
"disable-plugin": "bcli", | ||
"network": "signet", | ||
"plugin": os.path.join(os.path.dirname(__file__), "../sauron.py"), | ||
"sauron-api-endpoint": "https://blockstream.info/signet/api", | ||
} | ||
self.daemon.opts.update(options) | ||
|
||
# Monkey patch | ||
def set_feerates(self, feerates, wait_for_effect=True): | ||
return None | ||
|
||
|
||
@pytest.fixture | ||
def node_cls(monkeypatch): | ||
monkeypatch.setenv("TEST_NETWORK", "signet") | ||
yield LightningNode | ||
|
||
|
||
def test_rpc_getchaininfo(node_factory): | ||
""" | ||
Test getchaininfo | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
response = ln_node.rpc.call("getchaininfo") | ||
|
||
assert ln_node.daemon.is_in_log("Sauron plugin initialized using Esplora API") | ||
|
||
expected_response_keys = ["chain", "blockcount", "headercount", "ibd"] | ||
assert list(response.keys()) == expected_response_keys | ||
assert response["chain"] == "signet" | ||
assert not response["ibd"] | ||
|
||
|
||
def test_rpc_getrawblockbyheight(node_factory): | ||
""" | ||
Test getrawblockbyheight | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
response = ln_node.rpc.call("getrawblockbyheight", {"height": 0}) | ||
|
||
expected_response = { | ||
"block": "0100000000000000000000000000000000000000000000000000000000000000000000003ba3edfd7a7b12b27ac72c3e67768f617fc81bc3888a51323a9fb8aa4b1e5e4a008f4d5fae77031e8ad222030101000000010000000000000000000000000000000000000000000000000000000000000000ffffffff4d04ffff001d0104455468652054696d65732030332f4a616e2f32303039204368616e63656c6c6f72206f6e206272696e6b206f66207365636f6e64206261696c6f757420666f722062616e6b73ffffffff0100f2052a01000000434104678afdb0fe5548271967f1a67130b7105cd6a828e03909a67962e0ea1f61deb649f6bc3f4cef38c4f35504e51ec112de5c384df7ba0b8d578a4c702b6bf11d5fac00000000", | ||
"blockhash": "00000008819873e925422c1ff0f99f7cc9bbb232af63a077a480a3633bee1ef6", | ||
} | ||
assert response == expected_response | ||
|
||
@pytest.mark.skip(reason="testing_theory") | ||
def test_rpc_sendrawtransaction_invalid(node_factory): | ||
""" | ||
Test sendrawtransaction | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
expected_error_substring = "RPC error" | ||
|
||
response = ln_node.rpc.call( | ||
"sendrawtransaction", | ||
{"tx": "invalid-raw-tx"}, | ||
) | ||
|
||
assert expected_error_substring in response.get("errmsg", ""), "Expected 'RPC error' in errmsg field" | ||
assert response.get("success") is False, "Expected success to be False" | ||
|
||
|
||
def test_rpc_getutxout(node_factory): | ||
""" | ||
Test getutxout | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
expected_response = { | ||
"amount": 5000000000, | ||
"script": "4104678afdb0fe5548271967f1a67130b7105cd6a828e03909a67962e0ea1f61deb649f6bc3f4cef38c4f35504e51ec112de5c384df7ba0b8d578a4c702b6bf11d5fac", | ||
} | ||
response = ln_node.rpc.call( | ||
"getutxout", | ||
{ | ||
# block 217883 | ||
"txid": "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b", | ||
"vout": 0, | ||
}, | ||
) | ||
assert response == expected_response | ||
|
||
|
||
def test_rpc_estimatefees(node_factory): | ||
""" | ||
Test estimatefees | ||
""" | ||
ln_node = node_factory.get_node() | ||
|
||
# Sample response | ||
# { | ||
# "opening": 4477, | ||
# "mutual_close": 4477, | ||
# "unilateral_close": 11929, | ||
# "delayed_to_us": 4477, | ||
# "htlc_resolution": 5652, | ||
# "penalty": 5652, | ||
# "min_acceptable": 1060, | ||
# "max_acceptable": 119290, | ||
# "feerate_floor": 1520, | ||
# "feerates": [ | ||
# {"blocks": 2, "feerate": 11929}, | ||
# {"blocks": 6, "feerate": 5652}, | ||
# {"blocks": 12, "feerate": 4477}, | ||
# {"blocks": 144, "feerate": 2120} | ||
# ] | ||
# } | ||
response = ln_node.rpc.call("estimatefees") | ||
|
||
expected_response_keys = [ | ||
"opening", | ||
"mutual_close", | ||
"unilateral_close", | ||
"delayed_to_us", | ||
"htlc_resolution", | ||
"penalty", | ||
"min_acceptable", | ||
"max_acceptable", | ||
"feerate_floor", | ||
"feerates", | ||
] | ||
assert list(response.keys()) == expected_response_keys | ||
|
||
expected_feerates_keys = ("blocks", "feerate") | ||
assert ( | ||
list(set([tuple(entry.keys()) for entry in response["feerates"]]))[0] | ||
== expected_feerates_keys | ||
) | ||
|
||
expected_feerates_blocks = [2, 6, 12, 144] | ||
assert [ | ||
entry["blocks"] for entry in response["feerates"] | ||
] == expected_feerates_blocks |
Uh oh!
There was an error while loading. Please reload this page.