Improve behavior of okx rebuys when using stop on exchange
closes #8755
This commit is contained in:
@@ -125,6 +125,20 @@ class Okx(Exchange):
|
|||||||
params['posSide'] = self._get_posSide(side, reduceOnly)
|
params['posSide'] = self._get_posSide(side, reduceOnly)
|
||||||
return params
|
return params
|
||||||
|
|
||||||
|
def __fetch_leverage_already_set(self, pair: str, leverage: float, side: BuySell) -> bool:
|
||||||
|
try:
|
||||||
|
res_lev = self._api.fetch_leverage(symbol=pair, params={
|
||||||
|
"mgnMode": self.margin_mode.value,
|
||||||
|
"posSide": self._get_posSide(side, False),
|
||||||
|
})
|
||||||
|
self._log_exchange_response('get_leverage', res_lev)
|
||||||
|
already_set = all(float(x['lever']) == leverage for x in res_lev['data'])
|
||||||
|
return already_set
|
||||||
|
|
||||||
|
except ccxt.BaseError:
|
||||||
|
# Assume all errors as "not set yet"
|
||||||
|
return False
|
||||||
|
|
||||||
@retrier
|
@retrier
|
||||||
def _lev_prep(self, pair: str, leverage: float, side: BuySell, accept_fail: bool = False):
|
def _lev_prep(self, pair: str, leverage: float, side: BuySell, accept_fail: bool = False):
|
||||||
if self.trading_mode != TradingMode.SPOT and self.margin_mode is not None:
|
if self.trading_mode != TradingMode.SPOT and self.margin_mode is not None:
|
||||||
@@ -141,8 +155,11 @@ class Okx(Exchange):
|
|||||||
except ccxt.DDoSProtection as e:
|
except ccxt.DDoSProtection as e:
|
||||||
raise DDosProtection(e) from e
|
raise DDosProtection(e) from e
|
||||||
except (ccxt.NetworkError, ccxt.ExchangeError) as e:
|
except (ccxt.NetworkError, ccxt.ExchangeError) as e:
|
||||||
|
already_set = self.__fetch_leverage_already_set(pair, leverage, side)
|
||||||
|
if not already_set:
|
||||||
raise TemporaryError(
|
raise TemporaryError(
|
||||||
f'Could not set leverage due to {e.__class__.__name__}. Message: {e}') from e
|
f'Could not set leverage due to {e.__class__.__name__}. Message: {e}'
|
||||||
|
) from e
|
||||||
except ccxt.BaseError as e:
|
except ccxt.BaseError as e:
|
||||||
raise OperationalException(e) from e
|
raise OperationalException(e) from e
|
||||||
|
|
||||||
|
|||||||
@@ -499,7 +499,11 @@ def test__set_leverage_okx(mocker, default_conf):
|
|||||||
assert api_mock.set_leverage.call_args_list[0][1]['params'] == {
|
assert api_mock.set_leverage.call_args_list[0][1]['params'] == {
|
||||||
'mgnMode': 'isolated',
|
'mgnMode': 'isolated',
|
||||||
'posSide': 'net'}
|
'posSide': 'net'}
|
||||||
|
api_mock.set_leverage = MagicMock(side_effect=ccxt.NetworkError())
|
||||||
|
exchange._lev_prep('BTC/USDT:USDT', 3.2, 'buy')
|
||||||
|
api_mock.fetch_leverage.call_count == 1
|
||||||
|
|
||||||
|
api_mock.fetch_leverage = MagicMock(side_effect=ccxt.NetworkError())
|
||||||
ccxt_exceptionhandlers(
|
ccxt_exceptionhandlers(
|
||||||
mocker,
|
mocker,
|
||||||
default_conf,
|
default_conf,
|
||||||
|
|||||||
Reference in New Issue
Block a user