-
Notifications
You must be signed in to change notification settings - Fork 274
/
DemandEventsPropagation.java
42 lines (36 loc) · 1.57 KB
/
DemandEventsPropagation.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package io.dddbyexamples.factory.demand.forecasting;
import io.dddbyexamples.factory.delivery.planning.projection.DeliveryForecastProjection;
import io.dddbyexamples.factory.demand.forecasting.command.RequiredReviewDao;
import io.dddbyexamples.factory.demand.forecasting.command.RequiredReviewEntity;
import io.dddbyexamples.factory.demand.forecasting.projection.CurrentDemandProjection;
import io.dddbyexamples.factory.shortages.prediction.monitoring.ShortagePredictionService;
import lombok.AllArgsConstructor;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Component;
import java.time.Clock;
import java.time.Instant;
import java.util.stream.Collectors;
@Lazy
@Component
@AllArgsConstructor
class DemandEventsPropagation implements DemandEvents {
private final CurrentDemandProjection demandProjection;
private final DeliveryForecastProjection deliveryProjection;
private final ShortagePredictionService shortagePrediction;
private final RequiredReviewDao demandReviews;
private final Clock clock;
@Override
public void emit(DemandedLevelsChanged event) {
demandProjection.applyDemandedLevelsChanged(event);
deliveryProjection.applyDemandedLevelsChanged(event);
shortagePrediction.predictShortages(event);
}
@Override
public void emit(ReviewRequired event) {
Instant timestamp = Instant.now(clock);
demandReviews.saveAll(event.getReviews().stream()
.map(r -> new RequiredReviewEntity(timestamp, r))
.collect(Collectors.toList())
);
}
}