diff --git a/jal/db/operations.py b/jal/db/operations.py index 0c4c2cb9..f23eb7a5 100644 --- a/jal/db/operations.py +++ b/jal/db/operations.py @@ -1209,16 +1209,8 @@ def processLedger(self, ledger): ledger.appendTransaction(self, BookAccount.Incomes, -qty, category=PredefinedCategory.Interest, peer=self._broker) else: for trade in closed_trades: - if self._asset.id() == asset.id(): - if self._subtype == CorporateAction.Split: - adj_coef = (self._qty / qty, qty / self._qty) # Price and quantity 1:N adjustment for split - elif self._subtype == CorporateAction.SpinOff or self._subtype == CorporateAction.Merger: - adj_coef = (share, Decimal('1')) # Cost basis adjustment according to corporate action data - else: - assert False, f"Unexpected corporate action type {self._subtype}" - else: - adj_coef = (share * self._qty / qty, qty / self._qty) - self._account.open_trade(trade, asset, modified_by=self, adjustment=adj_coef) + cost_size_adjustment = (share * self._qty / qty, qty / self._qty) + self._account.open_trade(trade, asset, modified_by=self, adjustment=cost_size_adjustment) ledger.appendTransaction(self, BookAccount.Assets, qty, asset_id=asset.id(), value=value) # ----------------------------------------------------------------------------------------------------------------------