|
|
@@ -588,8 +588,9 @@ export class OrderService {
|
|
|
let updatedOrderLines = [orderLine];
|
|
|
if (correctedQuantity === 0) {
|
|
|
order.lines = order.lines.filter(l => !idsAreEqual(l.id, orderLine.id));
|
|
|
+ const deletedOrderLine = new OrderLine(orderLine);
|
|
|
await this.connection.getRepository(ctx, OrderLine).remove(orderLine);
|
|
|
- this.eventBus.publish(new OrderLineEvent(ctx, order, orderLine, 'deleted'));
|
|
|
+ this.eventBus.publish(new OrderLineEvent(ctx, order, deletedOrderLine, 'deleted'));
|
|
|
updatedOrderLines = [];
|
|
|
} else {
|
|
|
await this.orderModifier.updateOrderLineQuantity(ctx, orderLine, correctedQuantity, order);
|
|
|
@@ -620,8 +621,9 @@ export class OrderService {
|
|
|
const orderLine = this.getOrderLineOrThrow(order, orderLineId);
|
|
|
order.lines = order.lines.filter(line => !idsAreEqual(line.id, orderLineId));
|
|
|
const updatedOrder = await this.applyPriceAdjustments(ctx, order);
|
|
|
+ const deletedOrderLine = new OrderLine(orderLine);
|
|
|
await this.connection.getRepository(ctx, OrderLine).remove(orderLine);
|
|
|
- this.eventBus.publish(new OrderLineEvent(ctx, order, orderLine, 'deleted'));
|
|
|
+ this.eventBus.publish(new OrderLineEvent(ctx, order, deletedOrderLine, 'deleted'));
|
|
|
return updatedOrder;
|
|
|
}
|
|
|
|