send base_currency with messages that need it.
This commit is contained in:
parent
cbdd86d777
commit
c0a57d352f
@ -1859,6 +1859,7 @@ class FreqtradeBot(LoggingMixin):
|
|||||||
if prot_trig:
|
if prot_trig:
|
||||||
msg: RPCProtectionMsg = {
|
msg: RPCProtectionMsg = {
|
||||||
'type': RPCMessageType.PROTECTION_TRIGGER,
|
'type': RPCMessageType.PROTECTION_TRIGGER,
|
||||||
|
'base_currency': self.exchange.get_pair_base_currency(prot_trig.pair),
|
||||||
**prot_trig.to_json() # type: ignore
|
**prot_trig.to_json() # type: ignore
|
||||||
}
|
}
|
||||||
self.rpc.send_msg(msg)
|
self.rpc.send_msg(msg)
|
||||||
@ -1867,6 +1868,7 @@ class FreqtradeBot(LoggingMixin):
|
|||||||
if prot_trig_glb:
|
if prot_trig_glb:
|
||||||
msg = {
|
msg = {
|
||||||
'type': RPCMessageType.PROTECTION_TRIGGER_GLOBAL,
|
'type': RPCMessageType.PROTECTION_TRIGGER_GLOBAL,
|
||||||
|
'base_currency': self.exchange.get_pair_base_currency(prot_trig_glb.pair),
|
||||||
**prot_trig_glb.to_json() # type: ignore
|
**prot_trig_glb.to_json() # type: ignore
|
||||||
}
|
}
|
||||||
self.rpc.send_msg(msg)
|
self.rpc.send_msg(msg)
|
||||||
|
@ -70,10 +70,6 @@ class RPCManager:
|
|||||||
"""
|
"""
|
||||||
if msg.get('type') not in NO_ECHO_MESSAGES:
|
if msg.get('type') not in NO_ECHO_MESSAGES:
|
||||||
logger.info('Sending rpc message: %s', msg)
|
logger.info('Sending rpc message: %s', msg)
|
||||||
if 'pair' in msg:
|
|
||||||
msg.update({
|
|
||||||
'base_currency': self._rpc._freqtrade.exchange.get_pair_base_currency(msg['pair'])
|
|
||||||
})
|
|
||||||
for mod in self.registered_modules:
|
for mod in self.registered_modules:
|
||||||
logger.debug('Forwarding message to rpc.%s', mod.name)
|
logger.debug('Forwarding message to rpc.%s', mod.name)
|
||||||
try:
|
try:
|
||||||
|
Loading…
Reference in New Issue
Block a user