self.report.log_stage("follow_orders_end")
def prepare_trades(self, base_currency="BTC", liquidity="medium",
- compute_value="average", repartition=None, only=None):
+ compute_value="average", repartition=None, only=None,
+ available_balance_only=False):
self.report.log_stage("prepare_trades",
base_currency=base_currency, liquidity=liquidity,
compute_value=compute_value, only=only,
- repartition=repartition)
+ repartition=repartition, available_balance_only=available_balance_only)
values_in_base = self.balances.in_currency(base_currency,
compute_value=compute_value)
- total_base_value = sum(values_in_base.values())
+ if available_balance_only:
+ balance = self.balances.all.get(base_currency)
+ if balance is None:
+ total_base_value = portfolio.Amount(base_currency, 0)
+ else:
+ total_base_value = balance.exchange_free + balance.margin_available
+ else:
+ total_base_value = sum(values_in_base.values())
new_repartition = self.balances.dispatch_assets(total_base_value,
liquidity=liquidity, repartition=repartition)
+ if available_balance_only:
+ for currency, amount in values_in_base.items():
+ if currency != base_currency:
+ new_repartition.setdefault(currency, portfolio.Amount(base_currency, 0))
+ new_repartition[currency] += amount
+
self.trades.compute_trades(values_in_base, new_repartition, only=only)
def print_tickers(self, base_currency="BTC"):
"before": False,
"after": True,
"fetch_balances": ["begin", "end"],
- "prepare_trades": { "only": "acquire" },
+ "prepare_trades": { "only": "acquire", "available_balance_only": True },
"prepare_orders": { "only": "acquire", "compute_value": "average" },
"move_balances": {},
"run_orders": {},
"before": False,
"after": True,
"fetch_balances": ["begin", "end"],
- "prepare_trades": {},
+ "prepare_trades": { "available_balance_only": True },
"prepare_orders": { "compute_value": "average" },
"move_balances": {},
"run_orders": {},