tests: lnpeer/onion_msg: rm dead code
This commit is contained in:
@@ -196,7 +196,6 @@ class MockLNWallet(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
|
|||||||
self.features |= LnFeatures.OPTION_SCID_ALIAS_OPT
|
self.features |= LnFeatures.OPTION_SCID_ALIAS_OPT
|
||||||
self.features |= LnFeatures.OPTION_STATIC_REMOTEKEY_OPT
|
self.features |= LnFeatures.OPTION_STATIC_REMOTEKEY_OPT
|
||||||
self.config.ENABLE_ANCHOR_CHANNELS = has_anchors
|
self.config.ENABLE_ANCHOR_CHANNELS = has_anchors
|
||||||
self.pending_payments = defaultdict(asyncio.Future)
|
|
||||||
for chan in chans:
|
for chan in chans:
|
||||||
chan.lnworker = self
|
chan.lnworker = self
|
||||||
self._peers = {} # bytes -> Peer
|
self._peers = {} # bytes -> Peer
|
||||||
@@ -226,9 +225,6 @@ class MockLNWallet(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
|
|||||||
def clear_invoices_cache(self):
|
def clear_invoices_cache(self):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
def pay_scheduled_invoices(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def get_invoice_status(self, key):
|
def get_invoice_status(self, key):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@@ -314,7 +310,6 @@ class MockLNWallet(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
|
|||||||
pay_invoice = LNWallet.pay_invoice
|
pay_invoice = LNWallet.pay_invoice
|
||||||
force_close_channel = LNWallet.force_close_channel
|
force_close_channel = LNWallet.force_close_channel
|
||||||
schedule_force_closing = LNWallet.schedule_force_closing
|
schedule_force_closing = LNWallet.schedule_force_closing
|
||||||
get_first_timestamp = lambda self: 0
|
|
||||||
on_peer_successfully_established = LNWallet.on_peer_successfully_established
|
on_peer_successfully_established = LNWallet.on_peer_successfully_established
|
||||||
get_channel_by_id = LNWallet.get_channel_by_id
|
get_channel_by_id = LNWallet.get_channel_by_id
|
||||||
channels_for_peer = LNWallet.channels_for_peer
|
channels_for_peer = LNWallet.channels_for_peer
|
||||||
|
|||||||
@@ -24,8 +24,8 @@ from electrum.onion_message import (
|
|||||||
from electrum.util import bfh, read_json_file, OldTaskGroup, get_asyncio_loop
|
from electrum.util import bfh, read_json_file, OldTaskGroup, get_asyncio_loop
|
||||||
from electrum.logging import console_stderr_handler
|
from electrum.logging import console_stderr_handler
|
||||||
|
|
||||||
from . import ElectrumTestCase, test_lnpeer
|
from . import ElectrumTestCase
|
||||||
from .test_lnpeer import PutIntoOthersQueueTransport, PeerInTests, keypair
|
from .test_lnpeer import keypair, MockLNWallet
|
||||||
|
|
||||||
TIME_STEP = 0.01 # run tests 100 x faster
|
TIME_STEP = 0.01 # run tests 100 x faster
|
||||||
OnionMessageManager.SLEEP_DELAY *= TIME_STEP
|
OnionMessageManager.SLEEP_DELAY *= TIME_STEP
|
||||||
@@ -273,21 +273,6 @@ class MockNetwork:
|
|||||||
self.config.EXPERIMENTAL_LN_FORWARD_PAYMENTS = True
|
self.config.EXPERIMENTAL_LN_FORWARD_PAYMENTS = True
|
||||||
|
|
||||||
|
|
||||||
class MockWallet:
|
|
||||||
def __init__(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
class MockLNWallet(test_lnpeer.MockLNWallet):
|
|
||||||
|
|
||||||
async def add_peer(self, connect_str: str):
|
|
||||||
t1 = PutIntoOthersQueueTransport(self.node_keypair, 'test')
|
|
||||||
p1 = PeerInTests(self, keypair().pubkey, t1)
|
|
||||||
self.peers[p1.pubkey] = p1
|
|
||||||
p1.initialized.set_result(True)
|
|
||||||
return p1
|
|
||||||
|
|
||||||
|
|
||||||
class MockPeer:
|
class MockPeer:
|
||||||
their_features = LnFeatures(LnFeatures.OPTION_ONION_MESSAGE_OPT)
|
their_features = LnFeatures(LnFeatures.OPTION_ONION_MESSAGE_OPT)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user