Add test testing the different ways exchanges may return data
This commit is contained in:
parent
f040c20688
commit
b4aeb93a18
@ -877,6 +877,99 @@ def limit_buy_order_old_partial_canceled(limit_buy_order_old_partial):
|
|||||||
return res
|
return res
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.fixture(scope='function')
|
||||||
|
def limit_buy_order_canceled_empty(request):
|
||||||
|
# Indirect fixture
|
||||||
|
# Documentation:
|
||||||
|
# https://docs.pytest.org/en/latest/example/parametrize.html#apply-indirect-on-particular-arguments
|
||||||
|
|
||||||
|
exchange_name = request.param
|
||||||
|
if exchange_name == 'ftx':
|
||||||
|
return {
|
||||||
|
'info': {},
|
||||||
|
'id': '1234512345',
|
||||||
|
'clientOrderId': None,
|
||||||
|
'timestamp': arrow.utcnow().shift(minutes=-601).timestamp,
|
||||||
|
'datetime': arrow.utcnow().shift(minutes=-601).isoformat(),
|
||||||
|
'lastTradeTimestamp': None,
|
||||||
|
'symbol': 'LTC/USDT',
|
||||||
|
'type': 'limit',
|
||||||
|
'side': 'buy',
|
||||||
|
'price': 34.3225,
|
||||||
|
'amount': 0.55,
|
||||||
|
'cost': 0.0,
|
||||||
|
'average': None,
|
||||||
|
'filled': 0.0,
|
||||||
|
'remaining': 0.0,
|
||||||
|
'status': 'closed',
|
||||||
|
'fee': None,
|
||||||
|
'trades': None
|
||||||
|
}
|
||||||
|
elif exchange_name == 'kraken':
|
||||||
|
return {
|
||||||
|
'info': {},
|
||||||
|
'id': 'AZNPFF-4AC4N-7MKTAT',
|
||||||
|
'clientOrderId': None,
|
||||||
|
'timestamp': arrow.utcnow().shift(minutes=-601).timestamp,
|
||||||
|
'datetime': arrow.utcnow().shift(minutes=-601).isoformat(),
|
||||||
|
'lastTradeTimestamp': None,
|
||||||
|
'status': 'canceled',
|
||||||
|
'symbol': 'LTC/USDT',
|
||||||
|
'type': 'limit',
|
||||||
|
'side': 'buy',
|
||||||
|
'price': 34.3225,
|
||||||
|
'cost': 0.0,
|
||||||
|
'amount': 0.55,
|
||||||
|
'filled': 0.0,
|
||||||
|
'average': 0.0,
|
||||||
|
'remaining': 0.55,
|
||||||
|
'fee': {'cost': 0.0, 'rate': None, 'currency': 'USDT'},
|
||||||
|
'trades': []
|
||||||
|
}
|
||||||
|
elif exchange_name == 'binance':
|
||||||
|
return {
|
||||||
|
'info': {},
|
||||||
|
'id': '1234512345',
|
||||||
|
'clientOrderId': 'alb1234123',
|
||||||
|
'timestamp': arrow.utcnow().shift(minutes=-601).timestamp,
|
||||||
|
'datetime': arrow.utcnow().shift(minutes=-601).isoformat(),
|
||||||
|
'lastTradeTimestamp': None,
|
||||||
|
'symbol': 'LTC/USDT',
|
||||||
|
'type': 'limit',
|
||||||
|
'side': 'buy',
|
||||||
|
'price': 0.016804,
|
||||||
|
'amount': 0.55,
|
||||||
|
'cost': 0.0,
|
||||||
|
'average': None,
|
||||||
|
'filled': 0.0,
|
||||||
|
'remaining': 0.55,
|
||||||
|
'status': 'canceled',
|
||||||
|
'fee': None,
|
||||||
|
'trades': None
|
||||||
|
}
|
||||||
|
else:
|
||||||
|
return {
|
||||||
|
'info': {},
|
||||||
|
'id': '1234512345',
|
||||||
|
'clientOrderId': 'alb1234123',
|
||||||
|
'timestamp': arrow.utcnow().shift(minutes=-601).timestamp,
|
||||||
|
'datetime': arrow.utcnow().shift(minutes=-601).isoformat(),
|
||||||
|
'lastTradeTimestamp': None,
|
||||||
|
'symbol': 'LTC/USDT',
|
||||||
|
'type': 'limit',
|
||||||
|
'side': 'buy',
|
||||||
|
'price': 0.016804,
|
||||||
|
'amount': 0.55,
|
||||||
|
'cost': 0.0,
|
||||||
|
'average': None,
|
||||||
|
'filled': 0.0,
|
||||||
|
'remaining': 0.55,
|
||||||
|
'status': 'canceled',
|
||||||
|
'fee': None,
|
||||||
|
'trades': None
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
@pytest.fixture
|
||||||
def limit_sell_order():
|
def limit_sell_order():
|
||||||
return {
|
return {
|
||||||
|
@ -2313,12 +2313,12 @@ def test_handle_timedout_limit_buy(mocker, caplog, default_conf, limit_buy_order
|
|||||||
Trade.session = MagicMock()
|
Trade.session = MagicMock()
|
||||||
trade = MagicMock()
|
trade = MagicMock()
|
||||||
trade.pair = 'LTC/ETH'
|
trade.pair = 'LTC/ETH'
|
||||||
limit_buy_order['remaining'] = limit_buy_order['amount']
|
limit_buy_order['filled'] = 0
|
||||||
assert freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
assert freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
||||||
assert cancel_order_mock.call_count == 1
|
assert cancel_order_mock.call_count == 1
|
||||||
|
|
||||||
cancel_order_mock.reset_mock()
|
cancel_order_mock.reset_mock()
|
||||||
limit_buy_order['amount'] = 2
|
limit_buy_order['filled'] = 2
|
||||||
assert not freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
assert not freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
||||||
assert cancel_order_mock.call_count == 1
|
assert cancel_order_mock.call_count == 1
|
||||||
|
|
||||||
@ -2326,6 +2326,27 @@ def test_handle_timedout_limit_buy(mocker, caplog, default_conf, limit_buy_order
|
|||||||
assert not freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
assert not freqtrade.handle_timedout_limit_buy(trade, limit_buy_order)
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.parametrize("limit_buy_order_canceled_empty", ['binance', 'ftx', 'kraken', 'bittrex'],
|
||||||
|
indirect=['limit_buy_order_canceled_empty'])
|
||||||
|
def test_handle_timedout_limit_buy_exchanges(mocker, caplog, default_conf,
|
||||||
|
limit_buy_order_canceled_empty) -> None:
|
||||||
|
patch_RPCManager(mocker)
|
||||||
|
patch_exchange(mocker)
|
||||||
|
cancel_order_mock = mocker.patch(
|
||||||
|
'freqtrade.exchange.Exchange.cancel_order_with_result',
|
||||||
|
return_value=limit_buy_order_canceled_empty)
|
||||||
|
|
||||||
|
freqtrade = FreqtradeBot(default_conf)
|
||||||
|
|
||||||
|
Trade.session = MagicMock()
|
||||||
|
trade = MagicMock()
|
||||||
|
trade.pair = 'LTC/ETH'
|
||||||
|
assert freqtrade.handle_timedout_limit_buy(trade, limit_buy_order_canceled_empty)
|
||||||
|
assert cancel_order_mock.call_count == 0
|
||||||
|
assert log_has_re(r'Buy order fully cancelled. Removing .* from database\.', caplog)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('cancelorder', [
|
@pytest.mark.parametrize('cancelorder', [
|
||||||
{},
|
{},
|
||||||
{'remaining': None},
|
{'remaining': None},
|
||||||
|
Loading…
Reference in New Issue
Block a user