Merge branch 'develop' into 9746

CHANGELOG.md

@@ -298,6 +298,7 @@
 - [9746](https://github.com/vegaprotocol/vega/issues/9746) - Fix handling of LP fees reward 
 - [9747](https://github.com/vegaprotocol/vega/issues/9747) - Return correct destination type
 - [9541](https://github.com/vegaprotocol/vega/issues/9731) - Add filtering for party to the referral fees API.
+- [9751](https://github.com/vegaprotocol/vega/issues/9751) - Make sure that LP fee party accounts exists.
 
 ## 0.72.1
 

core/collateral/engine.go

@@ -938,7 +938,7 @@ func (e *Engine) transferFees(ctx context.Context, marketID string, assetID stri
 	responses := make([]*types.LedgerMovement, 0, len(transfers))
 
 	for _, transfer := range transfers {
-		req, err := e.getFeeTransferRequest(
+		req, err := e.getFeeTransferRequest(ctx,
 			transfer, makerFee, infraFee, liquiFee, marketID, assetID)
 		if err != nil {
 			e.log.Error("Failed to build transfer request for event",
@@ -2001,6 +2001,7 @@ func (e *Engine) MarginUpdateOnOrder(ctx context.Context, marketID string, updat
 }
 
 func (e *Engine) getFeeTransferRequest(
+	ctx context.Context,
 	t *types.Transfer,
 	makerFee, infraFee, liquiFee *types.Account,
 	marketID, assetID string,
@@ -2021,11 +2022,11 @@ func (e *Engine) getFeeTransferRequest(
 	}
 
 	partyLiquidityFeeAccount := func() (*types.Account, error) {
-		return getAccount(marketID, t.Owner, types.AccountTypeLPLiquidityFees)
+		return e.GetOrCreatePartyLiquidityFeeAccount(ctx, t.Owner, marketID, assetID)
 	}
 
 	bonusDistributionAccount := func() (*types.Account, error) {
-		return getAccount(marketID, systemOwner, types.AccountTypeLiquidityFeesBonusDistribution)
+		return e.GetOrCreateLiquidityFeesBonusDistributionAccount(ctx, marketID, assetID)
 	}
 
 	marginAccount := func() (*types.Account, error) {