]> gerrit.simantics Code Review - simantics/district.git/blob
e3ede04fb970053c87d17962f2fbf398ab140e98
[simantics/district.git] /
1 package org.simantics.district.network.visualisations;
2
3 import java.util.ArrayList;
4 import java.util.Collection;
5 import java.util.HashMap;
6 import java.util.List;
7 import java.util.Map;
8 import java.util.function.Supplier;
9 import java.util.stream.Collectors;
10 import java.util.stream.Stream;
11
12 import org.simantics.NameLabelUtil;
13 import org.simantics.Simantics;
14 import org.simantics.db.ReadGraph;
15 import org.simantics.db.Resource;
16 import org.simantics.db.common.NamedResource;
17 import org.simantics.db.common.request.ObjectsWithSupertype;
18 import org.simantics.db.exception.DatabaseException;
19 import org.simantics.db.layer0.util.Layer0Utils;
20 import org.simantics.district.network.visualisations.model.DynamicArrowContribution;
21 import org.simantics.district.network.visualisations.model.DynamicColorContribution;
22 import org.simantics.district.network.visualisations.model.DynamicColorMap;
23 import org.simantics.district.network.visualisations.model.DynamicSizeContribution;
24 import org.simantics.district.network.visualisations.model.DynamicSizeMap;
25 import org.simantics.layer0.Layer0;
26 import org.simantics.scl.compiler.top.ValueNotFound;
27 import org.simantics.scl.osgi.SCLOsgi;
28 import org.simantics.scl.runtime.SCLContext;
29 import org.simantics.scl.runtime.tuple.Tuple0;
30 import org.simantics.structural.stubs.StructuralResource2;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
33
34 public class DynamicVisualisationsContributions {
35
36     private static final Logger LOGGER = LoggerFactory.getLogger(DynamicVisualisationsContributions.class);
37
38     private static final String COMMON_DYNAMIC_VISUALISATIONS_MODULE = "CommonDynamicVisualisations";
39     private static final String COLOR_MAP_CONTRIBUTION = "colorMapContribution";
40     private static final String SIZE_MAP_CONTRIBUTION = "sizeMapContribution";
41     
42     private static final String DYNAMIC_VISUALISATIONS_CONTRIBUTION_MODULE = "DynamicVisualisationsContribution";
43     private static final String COLOR_CONTRIBUTION = "colorContribution";
44     private static final String SIZE_CONTRIBUTION = "sizeContribution";
45     private static final String ARROW_CONTRIBUTION = "arrowContribution";
46
47     public static Map<String, DynamicColorMap> dynamicColorMaps(ReadGraph graph) throws DatabaseException {
48         List<Resource> sharedOntologies = Simantics.applySCL("Simantics/SharedOntologies", "getSharedOntologies", graph, Tuple0.INSTANCE);
49         
50         Map<String, DynamicColorMap> results = new HashMap<>();
51         Layer0 L0 = Layer0.getInstance(graph);
52         for (Resource sharedOntology : sharedOntologies) {
53             Resource sclModule = Layer0Utils.getPossibleChild(graph, sharedOntology, L0.SCLModule, COMMON_DYNAMIC_VISUALISATIONS_MODULE);
54             if (sclModule != null) {
55                 String moduleURI = graph.getURI(sclModule);
56                 Object oldGraph = SCLContext.getCurrent().get("graph");
57                 try {
58                     // let's put the graph to SCLContext for resolving the color maps
59                     SCLContext.getCurrent().put("graph", graph);
60                     @SuppressWarnings("unchecked")
61                     List<DynamicColorMap> result = (List<DynamicColorMap>) SCLOsgi.MODULE_REPOSITORY.getValue(moduleURI, COLOR_MAP_CONTRIBUTION);
62                     
63                     for (DynamicColorMap colorMap : result) {
64                         results.put(colorMap.getLabel(), colorMap);
65                     }
66                 } catch (ValueNotFound e) {
67                     // ignore
68                     LOGGER.debug("Dynamic color maps not found for {}", sclModule, e);
69                 } finally {
70                     SCLContext.getCurrent().put("graph", oldGraph);
71                 }
72             }
73         }
74         return results;
75     }
76
77     public static Map<String, DynamicSizeMap> dynamicSizeMaps(ReadGraph graph) throws DatabaseException {
78         List<Resource> sharedOntologies = Simantics.applySCL("Simantics/SharedOntologies", "getSharedOntologies", graph, Tuple0.INSTANCE);
79         
80         Map<String, DynamicSizeMap> results = new HashMap<>();
81         Layer0 L0 = Layer0.getInstance(graph);
82         for (Resource sharedOntology : sharedOntologies) {
83             Resource sclModule = Layer0Utils.getPossibleChild(graph, sharedOntology, L0.SCLModule, COMMON_DYNAMIC_VISUALISATIONS_MODULE);
84             if (sclModule != null) {
85                 String moduleURI = graph.getURI(sclModule);
86                 Object oldGraph = SCLContext.getCurrent().get("graph");
87                 try {
88                     // let's put the graph to SCLContext for resolving the color maps
89                     SCLContext.getCurrent().put("graph", graph);
90                     @SuppressWarnings("unchecked")
91                     List<DynamicSizeMap> result = (List<DynamicSizeMap>) SCLOsgi.MODULE_REPOSITORY.getValue(moduleURI, SIZE_MAP_CONTRIBUTION);
92                     
93                     for (DynamicSizeMap sizeMap : result) {
94                         results.put(sizeMap.getLabel(), sizeMap);
95                     }
96                 } catch (ValueNotFound e) {
97                     // ignore
98                     LOGGER.debug("Dynamic size maps not found for {}", sclModule, e);
99                 } finally {
100                     SCLContext.getCurrent().put("graph", oldGraph);
101                 }
102             }
103         }
104         return results;
105     }
106
107     public static Collection<DynamicColoringObject> dynamicColoringObjects(ReadGraph graph) throws DatabaseException {
108         
109         List<Resource> sharedOntologies = Simantics.applySCL("Simantics/SharedOntologies", "getSharedOntologies", graph, Tuple0.INSTANCE);
110         
111         List<DynamicColoringObject> results = new ArrayList<>();
112         
113         for (Resource sharedOntology : sharedOntologies) {
114             Collection<Resource> findByType = graph.syncRequest(new ObjectsWithSupertype(sharedOntology, Layer0.getInstance(graph).ConsistsOf, StructuralResource2.getInstance(graph).Component));
115             //Collection<Resource> findByType = QueryIndexUtils.searchByType(graph, sharedOntology, );
116             for (Resource find : findByType) {
117                 NamedResource moduleType = new NamedResource(NameLabelUtil.modalName(graph, find), find);
118                 DynamicColoringObject dynamicColoringObject = dynamicColoringObject(graph, moduleType);
119                 if (dynamicColoringObject != null)
120                     results.add(dynamicColoringObject);
121             }
122         }
123         return results;
124     }
125     
126     public static Collection<DynamicSizingObject> dynamicSizingObjects(ReadGraph graph) throws DatabaseException {
127         
128         List<Resource> sharedOntologies = Simantics.applySCL("Simantics/SharedOntologies", "getSharedOntologies", graph, Tuple0.INSTANCE);
129         
130         List<DynamicSizingObject> results = new ArrayList<>();
131         
132         for (Resource sharedOntology : sharedOntologies) {
133             Collection<Resource> findByType = graph.syncRequest(new ObjectsWithSupertype(sharedOntology, Layer0.getInstance(graph).ConsistsOf, StructuralResource2.getInstance(graph).Component));
134             //Collection<Resource> findByType = QueryIndexUtils.searchByType(graph, sharedOntology, );
135             for (Resource find : findByType) {
136                 NamedResource moduleType = new NamedResource(NameLabelUtil.modalName(graph, find), find);
137                 DynamicSizingObject dynamicSizingObject = dynamicSizingObject(graph, moduleType);
138                 if (dynamicSizingObject != null)
139                     results.add(dynamicSizingObject);
140             }
141         }
142         return results;
143     }
144     
145     private static DynamicColoringObject dynamicColoringObject(ReadGraph graph, NamedResource moduleType) throws DatabaseException {
146         Layer0 L0 = Layer0.getInstance(graph);
147         Resource sclModule = Layer0Utils.getPossibleChild(graph, moduleType.getResource(), L0.SCLModule, DYNAMIC_VISUALISATIONS_CONTRIBUTION_MODULE);
148         if (sclModule != null) {
149             String moduleURI = graph.getURI(sclModule);
150             return new DynamicColoringObject(moduleType, getContributionSupplier(moduleURI, COLOR_CONTRIBUTION));
151         }
152         return null;
153     }
154
155     private static DynamicSizingObject dynamicSizingObject(ReadGraph graph, NamedResource moduleType) throws DatabaseException {
156         Layer0 L0 = Layer0.getInstance(graph);
157         Resource sclModule = Layer0Utils.getPossibleChild(graph, moduleType.getResource(), L0.SCLModule, DYNAMIC_VISUALISATIONS_CONTRIBUTION_MODULE);
158         if (sclModule != null) {
159             String moduleURI = graph.getURI(sclModule);
160             return new DynamicSizingObject(moduleType, getContributionSupplier(moduleURI, SIZE_CONTRIBUTION));
161         }
162         return null;
163     }
164
165     public static Collection<DynamicArrowObject> dynamicEdgeArrowObjects(ReadGraph graph) throws DatabaseException {
166         
167         List<Resource> sharedOntologies = Simantics.applySCL("Simantics/SharedOntologies", "getSharedOntologies", graph, Tuple0.INSTANCE);
168         
169         List<DynamicArrowObject> results = new ArrayList<>();
170         
171         for (Resource sharedOntology : sharedOntologies) {
172             Collection<Resource> findByType = graph.syncRequest(new ObjectsWithSupertype(sharedOntology, Layer0.getInstance(graph).ConsistsOf, StructuralResource2.getInstance(graph).Component));
173             //Collection<Resource> findByType = QueryIndexUtils.searchByType(graph, sharedOntology, );
174             for (Resource find : findByType) {
175                 NamedResource moduleType = new NamedResource(NameLabelUtil.modalName(graph, find), find);
176                 DynamicArrowObject dynamicarrowObject = dynamicEdgeArrowObject(graph, moduleType);
177                 if (dynamicarrowObject != null)
178                     results.add(dynamicarrowObject);
179             }
180         }
181         return results;
182     }
183     
184     private static DynamicArrowObject dynamicEdgeArrowObject(ReadGraph graph, NamedResource moduleType) throws DatabaseException {
185         Layer0 L0 = Layer0.getInstance(graph);
186         Resource sclModule = Layer0Utils.getPossibleChild(graph, moduleType.getResource(), L0.SCLModule, DYNAMIC_VISUALISATIONS_CONTRIBUTION_MODULE);
187         if (sclModule != null) {
188             String moduleURI = graph.getURI(sclModule);
189             return new DynamicArrowObject(moduleType, getContributionSupplier(moduleURI, ARROW_CONTRIBUTION));
190         }
191         return null;
192     }
193
194     private static <T> Supplier<Stream<T>> getContributionSupplier(String uri, String expressionText) {
195         return () -> {
196             try {
197                 @SuppressWarnings("unchecked")
198                 List<T> result = (List<T>) SCLOsgi.MODULE_REPOSITORY.getValue(uri, expressionText);
199                 return result.stream();//result.stream().map(DynamicColorContribution::fromTuple9);
200             } catch (ValueNotFound e) {
201                 LOGGER.trace("Could not find contributions for module {} and expression {}", uri, expressionText, e);
202                 //throw new RuntimeException(e);
203                 return Stream.empty();
204             }
205         };
206     }
207     
208     public static class DynamicArrowObject {
209
210         private final NamedResource arrowObject;
211         private final Supplier<Stream<DynamicArrowContribution>> arrowContributionSupplier;
212         private Map<String, DynamicArrowContribution> arrowContributions;
213
214         public DynamicArrowObject(NamedResource coloringObject, Supplier<Stream<DynamicArrowContribution>> arrowContributionSupplier) {
215             this.arrowObject = coloringObject;
216             this.arrowContributionSupplier = arrowContributionSupplier;
217         }
218
219         public NamedResource getArrowObject() {
220             return arrowObject;
221         }
222
223         public Map<String, DynamicArrowContribution> getArrowContributions() {
224             if (arrowContributions == null)
225                 arrowContributions = arrowContributionSupplier.get().collect(Collectors.toMap(c -> c.getLabel(), c -> c));
226             return arrowContributions;
227         }
228     }
229     
230     public static class DynamicColoringObject {
231
232         private final NamedResource coloringObject;
233         private final Supplier<Stream<DynamicColorContribution>> colorContributionSupplier;
234         private Map<String, DynamicColorContribution> colorContributions;
235
236         public DynamicColoringObject(NamedResource coloringObject, Supplier<Stream<DynamicColorContribution>> colorContributionSupplier) {
237             this.coloringObject = coloringObject;
238             this.colorContributionSupplier = colorContributionSupplier;
239         }
240
241         public NamedResource getColoringObject() {
242             return coloringObject;
243         }
244
245         public Map<String, DynamicColorContribution> getColorContributions() {
246             if (colorContributions == null)
247                 colorContributions = colorContributionSupplier.get().collect(Collectors.toMap(c -> c.getLabel(), c -> c));
248             return colorContributions;
249         }
250     }
251
252     public static class DynamicColoringMap {
253
254         private final NamedResource coloringObject;
255         private final Supplier<Stream<DynamicColorMap>> colorContributionSupplier;
256         private Map<String, DynamicColorMap> colorContributions;
257
258         public DynamicColoringMap(NamedResource coloringObject, Supplier<Stream<DynamicColorMap>> colorContributionSupplier) {
259             this.coloringObject = coloringObject;
260             this.colorContributionSupplier = colorContributionSupplier;
261         }
262
263         public NamedResource getColoringObject() {
264             return coloringObject;
265         }
266
267         public Map<String, DynamicColorMap> getColorContributions() {
268             if (colorContributions == null)
269                 colorContributions = colorContributionSupplier.get().collect(Collectors.toMap(c -> c.getLabel(), c -> c));
270             return colorContributions;
271         }
272     }
273     
274     public static class DynamicSizingObject {
275
276         private final NamedResource sizingObject;
277         private final Supplier<Stream<DynamicSizeContribution>> sizeContributionSupplier;
278         private Map<String, DynamicSizeContribution> sizeContributions;
279         
280         public DynamicSizingObject(NamedResource coloringObject, Supplier<Stream<DynamicSizeContribution>> sizeContributionSupplier) {
281             this.sizingObject = coloringObject;
282             this.sizeContributionSupplier = sizeContributionSupplier;
283         }
284
285         public NamedResource getSizingObject() {
286             return sizingObject;
287         }
288
289         public Map<String, DynamicSizeContribution> getSizeContributions() {
290             if (sizeContributions == null)
291                 sizeContributions = sizeContributionSupplier.get().collect(Collectors.toMap(c -> c.getLabel(), c -> c));
292             return sizeContributions;
293         }
294     }
295 }