@@ -321,6 +321,7 @@ class ChannelDB(SqlDB):
|
|||||||
self.lock = threading.RLock()
|
self.lock = threading.RLock()
|
||||||
self.num_nodes = 0
|
self.num_nodes = 0
|
||||||
self.num_channels = 0
|
self.num_channels = 0
|
||||||
|
self.num_policies = 0
|
||||||
self._channel_updates_for_private_channels = {} # type: Dict[Tuple[bytes, bytes], Tuple[dict, int]]
|
self._channel_updates_for_private_channels = {} # type: Dict[Tuple[bytes, bytes], Tuple[dict, int]]
|
||||||
# note: ^ we could maybe move this cache into PaySession instead of being global.
|
# note: ^ we could maybe move this cache into PaySession instead of being global.
|
||||||
# That would only make sense though if PaySessions were never too short
|
# That would only make sense though if PaySessions were never too short
|
||||||
|
|||||||
@@ -67,6 +67,7 @@ class MockNetwork:
|
|||||||
self.channel_db = ChannelDB(self)
|
self.channel_db = ChannelDB(self)
|
||||||
self.channel_db.data_loaded.set()
|
self.channel_db.data_loaded.set()
|
||||||
self.path_finder = LNPathFinder(self.channel_db)
|
self.path_finder = LNPathFinder(self.channel_db)
|
||||||
|
self.lngossip = MockLNGossip()
|
||||||
self.tx_queue = tx_queue
|
self.tx_queue = tx_queue
|
||||||
self._blockchain = MockBlockchain()
|
self._blockchain = MockBlockchain()
|
||||||
|
|
||||||
@@ -129,6 +130,11 @@ class MockWallet:
|
|||||||
return ''
|
return ''
|
||||||
|
|
||||||
|
|
||||||
|
class MockLNGossip:
|
||||||
|
def get_sync_progress_estimate(self):
|
||||||
|
return None, None, None
|
||||||
|
|
||||||
|
|
||||||
class MockLNWallet(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
|
class MockLNWallet(Logger, EventListener, NetworkRetryManager[LNPeerAddr]):
|
||||||
MPP_EXPIRY = 2 # HTLC timestamps are cast to int, so this cannot be 1
|
MPP_EXPIRY = 2 # HTLC timestamps are cast to int, so this cannot be 1
|
||||||
PAYMENT_TIMEOUT = 120
|
PAYMENT_TIMEOUT = 120
|
||||||
|
|||||||
Reference in New Issue
Block a user