import logging from freqtrade.constants import Config from freqtrade.enums.tradingmode import TradingMode from freqtrade.persistence.pairlock import PairLock from freqtrade.persistence.trade_model import Trade logger = logging.getLogger(__name__) def migrate_binance_futures_names(config: Config): if ( not (config.get('trading_mode', TradingMode.SPOT) == TradingMode.FUTURES and config['exchange']['name'] == 'binance') ): # only act on new futures return _migrate_binance_futures_db(config) migrate_binance_futures_data(config) def _migrate_binance_futures_db(config: Config): logger.warning('Migrating binance futures pairs in database.') trades = Trade.get_trades([Trade.exchange == 'binance', Trade.trading_mode == 'FUTURES']).all() for trade in trades: if ':' in trade.pair: # already migrated continue new_pair = f"{trade.pair}:{trade.stake_currency}" trade.pair = new_pair for order in trade.orders: order.ft_pair = new_pair # Should symbol be migrated too? # order.symbol = new_pair Trade.commit() pls = PairLock.query.filter(PairLock.pair.notlike('%:%')) for pl in pls: pl.pair = f"{pl.pair}:{config['stake_currency']}" # print(pls) # pls.update({'pair': concat(PairLock.pair,':USDT')}) Trade.commit() logger.warning('Done migrating binance futures pairs in database.') def migrate_binance_futures_data(config: Config): if ( not (config.get('trading_mode', TradingMode.SPOT) == TradingMode.FUTURES and config['exchange']['name'] == 'binance') ): # only act on new futures return from freqtrade.data.history.idatahandler import get_datahandler dhc = get_datahandler(config['datadir'], config.get('dataformat_ohlcv', 'json')) paircombs = dhc.ohlcv_get_available_data( config['datadir'], config.get('trading_mode', TradingMode.SPOT) ) for pair, timeframe, candle_type in paircombs: if ':' in pair: # already migrated continue new_pair = f"{pair}:{config['stake_currency']}" dhc.rename_futures_data(pair, new_pair, timeframe, candle_type)