blob: c844a89f1ebcf9612a34a8b14b5bebb12afb7c13 (
plain) (
blame)
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
43
44
45
46
47
48
49
50
51
52
53
|
/*
* SPDX-FileCopyrightText: 2023 The Refinery Authors <https://refinery.tools/>
*
* SPDX-License-Identifier: EPL-2.0
*/
package tools.refinery.store.dse.propagation.impl;
import tools.refinery.store.adapter.AbstractModelAdapterBuilder;
import tools.refinery.store.dse.propagation.PropagationBuilder;
import tools.refinery.store.dse.propagation.PropagationStoreAdapter;
import tools.refinery.store.dse.propagation.Propagator;
import tools.refinery.store.dse.propagation.impl.rule.RuleBasedPropagator;
import tools.refinery.store.dse.transition.Rule;
import tools.refinery.store.model.ModelStore;
import tools.refinery.store.model.ModelStoreBuilder;
import java.util.*;
public class PropagationBuilderImpl extends AbstractModelAdapterBuilder<PropagationStoreAdapter>
implements PropagationBuilder {
private final Set<Rule> propagationRules = new LinkedHashSet<>();
private final Deque<Propagator> propagators = new ArrayDeque<>();
@Override
public PropagationBuilder rule(Rule propagationRule) {
checkNotConfigured();
propagationRules.add(propagationRule);
return this;
}
@Override
public PropagationBuilder propagator(Propagator propagator) {
checkNotConfigured();
propagators.addFirst(propagator);
return this;
}
@Override
protected void doConfigure(ModelStoreBuilder storeBuilder) {
super.doConfigure(storeBuilder);
if (!propagationRules.isEmpty()) {
propagators.addFirst(new RuleBasedPropagator(List.copyOf(propagationRules)));
}
for (var propagator : propagators) {
propagator.configure(storeBuilder);
}
}
@Override
protected PropagationStoreAdapter doBuild(ModelStore store) {
return new PropagationStoreAdapterImpl(store, List.copyOf(propagators));
}
}
|