aljaz/plugins
1
0
Fork 0
mirror of https://github.com/aljazceru/plugins.git synced 2025-12-23 16:14:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

autopilot: catch and return initialization errors.

Browse Source
This commit is contained in:
Michael Schmoock
2021-08-31 11:56:14 +02:00
parent aa0efca2bc
commit 5cb1e3e8d8
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
autopilot/autopilot.py
View File

@@ -129,10 +129,14 @@ def init(configuration, options, plugin):
plugin.min_capacity_sat = int(options['autopilot-min-channel-size-msat']) / 1000 plugin.min_capacity_sat = int(options['autopilot-min-channel-size-msat']) / 1000
plugin.initialized = threading.Event() plugin.initialized = threading.Event()
plugin.autopilot = None plugin.autopilot = None
plugin.initerror = None
print('Initialized autopilot function') print('Initialized autopilot function')
def initialize_autopilot(): def initialize_autopilot():
try:
plugin.autopilot = CLightning_autopilot(plugin.rpc) plugin.autopilot = CLightning_autopilot(plugin.rpc)
except Exception as e:
plugin.initerror = e
plugin.initialized.set() plugin.initialized.set()
# Load the autopilot in the background and have it notify # Load the autopilot in the background and have it notify
@@ -178,6 +182,9 @@ def run_once(plugin, dryrun=False):
print("I'd like to open {} new channels with {} satoshis each".format(num_channels, channel_capacity)) print("I'd like to open {} new channels with {} satoshis each".format(num_channels, channel_capacity))
plugin.initialized.wait() plugin.initialized.wait()
if plugin.initerror:
return f"Error: autopilot had initialization errors: {str(plugin.initerror)}"
candidates = plugin.autopilot.find_candidates( candidates = plugin.autopilot.find_candidates(
num_channels, num_channels,
strategy=Strategy.DIVERSE, strategy=Strategy.DIVERSE,