diff --git a/TransactionProcessor.BusinessLogic/Services/TransactionDomainService.cs b/TransactionProcessor.BusinessLogic/Services/TransactionDomainService.cs index f0139649..865dc6d9 100644 --- a/TransactionProcessor.BusinessLogic/Services/TransactionDomainService.cs +++ b/TransactionProcessor.BusinessLogic/Services/TransactionDomainService.cs @@ -185,9 +185,12 @@ await this.TransactionAggregateManager.StartTransaction(transactionId, transactionAmount, cancellationToken); - // Add the product details - await this.TransactionAggregateManager.AddProductDetails(estateId, transactionId, contractId, productId, cancellationToken); - + // Add the product details (unless invalid estate) + if (validationResult.responseCode != TransactionResponseCode.InvalidEstateId) + { + await this.TransactionAggregateManager.AddProductDetails(estateId, transactionId, contractId, productId, cancellationToken); + } + if (validationResult.responseCode == TransactionResponseCode.Success) { // Record any additional request metadata