-
Notifications
You must be signed in to change notification settings - Fork 2
/
RuleRepositoryImpl.java
29 lines (21 loc) · 1020 Bytes
/
RuleRepositoryImpl.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
package com.iot.rule.engine.application.repository.impl;
import com.iot.rule.engine.application.model.RuleRepresentation;
import com.iot.rule.engine.application.repository.RuleRepresentationRepository;
import com.iot.rule.engine.domain.Rule;
import com.iot.rule.engine.infra.RuleRepository;
import java.util.List;
import java.util.stream.Collectors;
public class RuleRepositoryImpl implements RuleRepository {
private final RuleRepresentationRepository ruleRepresentationRepository;
public RuleRepositoryImpl(RuleRepresentationRepository ruleRepresentationRepository) {
this.ruleRepresentationRepository = ruleRepresentationRepository;
}
@Override
public List<Rule> findAllByCustomerIdAndDeviceId(String customerId, String deviceId) {
return this.ruleRepresentationRepository
.findAllByCustomerIdAndDeviceId(customerId, deviceId)
.stream()
.map(RuleRepresentation::toRule)
.collect(Collectors.toList());
}
}