GlcoinCore/cln-plugins
1
0
Fork 0
mirror of https://github.com/lightningd/plugins.git synced 2026-08-19 13:18:19 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

chore: rewording peer2channel method to peer_from_scid

Browse source
This commit is contained in:
Michael Schmoock 2019-04-29 23:45:08 +02:00 • committed by Christian Decker
parent 187c66a9b1
commit 3d9b3c8a22
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
rebalance/rebalance.py
View file

@ -20,12 +20,12 @@ def setup_routing_fees(plugin, route, msatoshi):
delay += ch['delay']
def peer2channel(plugin, channel_id, my_node_id, payload):
channels = plugin.rpc.listchannels(channel_id).get('channels')
def peer_from_scid(plugin, short_channel_id, my_node_id, payload):
channels = plugin.rpc.listchannels(short_channel_id).get('channels')
for ch in channels:
if ch['source'] == my_node_id:
return ch['destination']
raise RpcError("rebalance", payload, {'message': 'Cannot find peer for channel: ' + channel_id})
raise RpcError("rebalance", payload, {'message': 'Cannot find peer for channel: ' + short_channel_id})
def find_worst_channel(route):
@ -71,8 +71,8 @@ def rebalance(plugin, outgoing_channel_id, incoming_channel_id, msatoshi: Millis
"exemptfee": exemptfee
}
my_node_id = plugin.rpc.getinfo().get('id')
outgoing_node_id = peer2channel(plugin, outgoing_channel_id, my_node_id, payload)
incoming_node_id = peer2channel(plugin, incoming_channel_id, my_node_id, payload)
outgoing_node_id = peer_from_scid(plugin, outgoing_channel_id, my_node_id, payload)
incoming_node_id = peer_from_scid(plugin, incoming_channel_id, my_node_id, payload)
plugin.log("Outgoing node: %s, channel: %s" % (outgoing_node_id, outgoing_channel_id))
plugin.log("Incoming node: %s, channel: %s" % (incoming_node_id, incoming_channel_id))