--- /dev/null
+package org.simantics.document.server;\r
+\r
+import java.util.ArrayList;\r
+import java.util.Collection;\r
+import java.util.Collections;\r
+import java.util.Set;\r
+import java.util.SortedMap;\r
+import java.util.TreeMap;\r
+\r
+import org.simantics.databoard.Bindings;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.common.request.UnaryRead;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.layer0.request.VariableRead;\r
+import org.simantics.db.layer0.variable.ProxyChildVariable;\r
+import org.simantics.db.layer0.variable.Variable;\r
+import org.simantics.db.layer0.variable.Variables;\r
+import org.simantics.document.base.ontology.DocumentationResource;\r
+import org.simantics.document.server.Functions.RootVariable;\r
+import org.simantics.structural2.variables.Connection;\r
+import org.simantics.structural2.variables.VariableConnectionPointDescriptor;\r
+import org.simantics.utils.datastructures.Pair;\r
+import org.simantics.utils.strings.AlphanumComparator;\r
+\r
+public class DocumentServerUtils {\r
+\r
+ public static Collection<Variable> getChildren(ReadGraph graph, Variable variable) throws DatabaseException {\r
+\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ \r
+ ArrayList<Variable> result = new ArrayList<Variable>();\r
+ for(Variable property : variable.getProperties(graph)) {\r
+ Collection<String> classifications = property.getPossiblePropertyValue(graph, Variables.CLASSIFICATIONS);\r
+ if(classifications != null) {\r
+ if(classifications.contains(DocumentationResource.URIs.Document_ChildRelation)) {\r
+ Connection conn = property.getValue(graph);\r
+ Variable childConnectionPoint = DocumentServerUtils.getPossibleOtherConnectionPoint(graph, property, conn);\r
+ if(childConnectionPoint != null) {\r
+ result.add(childConnectionPoint.getParent(graph));\r
+ }\r
+ } else if (DOC.Relations_partN.equals(property.getPossiblePredicateResource(graph))) {\r
+ Connection conn = property.getValue(graph);\r
+ for (Variable childConnectionPoint : DocumentServerUtils.getOtherConnectionPoints(graph, property, conn)) {\r
+ result.add(childConnectionPoint.getParent(graph));\r
+ }\r
+ }\r
+ }\r
+ }\r
+ return result;\r
+\r
+ }\r
+ \r
+ public static String findManualOrdinal(ReadGraph graph, Variable v) throws DatabaseException {\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ Integer j = null;\r
+ while (j == null && v != null) {\r
+ j = v.getPossiblePropertyValue(graph, DOC.Components_Component_manualOrdinal);\r
+ v = v.getParent(graph);\r
+ }\r
+ if (j != null) {\r
+ return Integer.toString(j);\r
+ } else {\r
+ return null;\r
+ }\r
+ }\r
+ \r
+ public static Collection<Variable> getChildrenInOrdinalOrder(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ \r
+ SortedMap<String, Variable> childMap = new TreeMap<String, Variable>(AlphanumComparator.COMPARATOR);\r
+ \r
+ for(Variable property : variable.getProperties(graph)) {\r
+ Collection<String> classifications = property.getPossiblePropertyValue(graph, Variables.CLASSIFICATIONS);\r
+ if(classifications != null) {\r
+ if(classifications.contains(DocumentationResource.URIs.Document_ChildRelation)) {\r
+ Resource cp = property.getPossiblePredicateResource(graph);\r
+ String i = graph.getRelatedValue(cp, DOC.Document_ChildRelation_ordinal, Bindings.STRING);\r
+ \r
+ Connection conn = property.getValue(graph);\r
+ Variable childConnectionPoint = DocumentServerUtils.getPossibleOtherConnectionPoint(graph, property, conn);\r
+ if(childConnectionPoint != null) {\r
+ childMap.put(i, childConnectionPoint.getParent(graph));\r
+ }\r
+ } else if (DOC.Relations_partN.equals(property.getPossiblePredicateResource(graph))) {\r
+ Connection conn = property.getValue(graph);\r
+\r
+ for (Variable childConnectionPoint : DocumentServerUtils.getOtherConnectionPoints(graph, property, conn)) {\r
+ Variable child = childConnectionPoint.getParent(graph);\r
+ String i = findManualOrdinal(graph, child);\r
+ if (i == null) {\r
+ i = "0";\r
+ }\r
+ childMap.put(i, child);\r
+ }\r
+ }\r
+ }\r
+ }\r
+ return childMap.values();\r
+\r
+ } \r
+\r
+ public static Collection<Variable> collectNodes(ReadGraph graph, Variable variable, Collection<Variable> nodes) throws DatabaseException {\r
+\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+\r
+ Resource type = variable.getPossibleType(graph);\r
+ if(type == null) return nodes;\r
+ \r
+ if(!graph.isInheritedFrom(type, DOC.Components_Component)) return nodes;\r
+\r
+ Boolean enabled = variable.getPossiblePropertyValue(graph, DOC.Properties_exists, Bindings.BOOLEAN);\r
+ if(enabled != null && !enabled) return nodes;\r
+\r
+ if(graph.isInheritedFrom(type, DOC.Components_PrimitiveComponent)) {\r
+ nodes.add(variable);\r
+ } else {\r
+ for(Variable child : variable.getChildren(graph)) {\r
+ collectNodes(graph, child, nodes);\r
+ }\r
+ }\r
+\r
+ return nodes;\r
+\r
+ }\r
+\r
+ public static Variable getPossibleOtherConnectionPoint(ReadGraph graph, Variable connectionPoint, Connection conn) throws DatabaseException {\r
+\r
+ Collection<VariableConnectionPointDescriptor> descs = conn.getConnectionPointDescriptors(graph, null);\r
+ if(descs.size() != 2) return null;\r
+\r
+ for(VariableConnectionPointDescriptor desc : descs) {\r
+ if(desc.isFlattenedFrom(graph, connectionPoint)) continue;\r
+ return desc.getVariable(graph);\r
+ }\r
+ \r
+ return null;\r
+\r
+ }\r
+ \r
+ public static Collection<Variable> getOtherConnectionPoints(ReadGraph graph, Variable connectionPoint, Connection conn) throws DatabaseException {\r
+\r
+ ArrayList<Variable> connectionPoints = new ArrayList<Variable>();\r
+ \r
+ Collection<VariableConnectionPointDescriptor> descs = conn.getConnectionPointDescriptors(graph, null);\r
+\r
+ for(VariableConnectionPointDescriptor desc : descs) {\r
+ if(desc.isFlattenedFrom(graph, connectionPoint)) continue;\r
+ connectionPoints.add(desc.getVariable(graph));\r
+ }\r
+ \r
+ return connectionPoints;\r
+\r
+ }\r
+\r
+ public static Variable getPossibleCommandTriggerConnectionPoint(ReadGraph graph, Variable connectionPoint, Connection conn) throws DatabaseException {\r
+\r
+ Collection<Variable> cpts = conn.getConnectionPoints(graph, null);\r
+\r
+ Variable result = null;\r
+ \r
+ for(Variable cpt : cpts) {\r
+ Set<String> classifications = cpt.getClassifications(graph);\r
+ if(classifications.contains(DocumentationResource.URIs.Relations_commandExecutorRelation)) {\r
+ if(result != null) throw new DatabaseException("Multiple executor connection points in command connection");\r
+ result = cpt;\r
+ }\r
+ }\r
+ \r
+ return result;\r
+\r
+ }\r
+\r
+ public static Collection<Variable> getPossibleOtherConnectionPoints(ReadGraph graph, Variable connectionPoint, Connection conn) throws DatabaseException {\r
+\r
+ Collection<Variable> cpts = conn.getConnectionPoints(graph, null);\r
+ if(cpts.size() < 2) \r
+ return Collections.emptyList();\r
+\r
+ ArrayList<Variable> result = new ArrayList<Variable>();\r
+ for(Variable cpt : cpts) {\r
+ if(!cpt.equals(connectionPoint)) \r
+ result.add(cpt);\r
+ }\r
+ return result;\r
+ }\r
+\r
+ public static String getId(ReadGraph graph, Variable node) throws DatabaseException {\r
+\r
+ if(node == null) return "root";\r
+ else {\r
+ String uri = node.getURI(graph); \r
+ int l = uri.lastIndexOf(ProxyChildVariable.CONTEXT_END);\r
+ return uri.substring(l+4);\r
+ }\r
+\r
+ }\r
+\r
+ public static class DocumentValue extends VariableRead<Object> {\r
+\r
+ public DocumentValue(Variable variable) {\r
+ super(variable);\r
+ }\r
+\r
+ @Override\r
+ public Object perform(ReadGraph graph) throws DatabaseException {\r
+ return variable.getValue(graph);\r
+ }\r
+ \r
+ @Override\r
+ public String toString() {\r
+ return "DocumentValue[" + variable + "]";\r
+ }\r
+ \r
+ }\r
+ \r
+ public static Object getValue(ReadGraph graph, Variable attrib) throws DatabaseException {\r
+ return graph.syncRequest(new DocumentValue(attrib));\r
+ }\r
+\r
+ public static Variable getParentConnectionPoint(ReadGraph graph, Variable component) throws DatabaseException {\r
+\r
+ Variable connectionPoint = component.getPossibleProperty(graph, "parent");\r
+ if(connectionPoint == null) {\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ Collection<Variable> cps = component.getProperties(graph, DOC.Relations_parentRelation);\r
+ if(cps.size() == 1) {\r
+ connectionPoint = cps.iterator().next();\r
+ } else {\r
+ return null;\r
+ }\r
+ }\r
+ \r
+ Connection conn = connectionPoint.getValue(graph);\r
+ Variable otherCp = DocumentServerUtils.getPossibleOtherConnectionPoint(graph, connectionPoint, conn);\r
+ if (otherCp != null) {\r
+ return otherCp;\r
+ } else {\r
+ Variable parentCp = graph.sync(new UnaryRead<Connection, Variable>(conn) {\r
+ @Override\r
+ public Variable perform(ReadGraph graph) throws DatabaseException {\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ Collection<VariableConnectionPointDescriptor> descs = parameter.getConnectionPointDescriptors(graph, null);\r
+\r
+ for(VariableConnectionPointDescriptor desc : descs) {\r
+ if (DOC.Relations_partN.equals(desc.getConnectionPointResource(graph))) {\r
+ return desc.getVariable(graph);\r
+ }\r
+ }\r
+ return null;\r
+ }\r
+ });\r
+ if (parentCp != null) {\r
+ return parentCp;\r
+ }\r
+ }\r
+ return null;\r
+\r
+ }\r
+ \r
+ /* Children */\r
+ public static Collection<Variable> getChildConnections(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ return variable.getProperties(graph, DocumentationResource.getInstance(graph).Document_ChildRelation);\r
+ }\r
+\r
+ /* Command sequence */\r
+ public static Collection<Variable> getTriggerCommands(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ ArrayList<Variable> result = new ArrayList<Variable>();\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ for(Variable var : variable.getProperties(graph, DOC.Document_CommandRelation)) {\r
+ if(DOC.Relations_broadcasted.equals(var.getPredicateResource(graph))) continue;\r
+ result.add(var);\r
+ }\r
+ return result;\r
+ }\r
+\r
+ public static Collection<Variable> getCommands(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ return variable.getProperties(graph, DocumentationResource.getInstance(graph).Document_CommandRelation);\r
+ }\r
+\r
+ /* Data definition */\r
+ public static Collection<Variable> getDataDefinitions(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ return variable.getProperties(graph, DocumentationResource.getInstance(graph).Document_DataDefinitionRelation);\r
+ }\r
+\r
+ /* Data relation */\r
+ public static Collection<Variable> getDataRelations(ReadGraph graph, Variable variable) throws DatabaseException {\r
+ return variable.getProperties(graph, DocumentationResource.getInstance(graph).Document_DataRelation);\r
+ }\r
+\r
+ /* Attributes */\r
+ public static Collection<Variable> getAttributes(ReadGraph graph, DocumentationResource DOC, Variable variable) throws DatabaseException {\r
+ return variable.getProperties(graph, DOC.Document_AttributeRelation);\r
+ }\r
+ \r
+ static class AttributesRequest extends VariableRead<Pair<Collection<Variable>, Collection<Variable>>> {\r
+\r
+ public AttributesRequest(Variable variable) {\r
+ super(variable);\r
+ }\r
+\r
+ @Override\r
+ public Pair<Collection<Variable>,Collection<Variable>> perform(ReadGraph graph) throws DatabaseException {\r
+ ArrayList<Variable> statics = new ArrayList<Variable>();\r
+ ArrayList<Variable> dynamics = new ArrayList<Variable>();\r
+ DocumentationResource DOC = DocumentationResource.getInstance(graph);\r
+ for(Variable property : getAttributes(graph, DOC, variable)) {\r
+ Boolean defaultProperty = property.getPossiblePropertyValue(graph, "default");\r
+ if(defaultProperty != null && defaultProperty) {\r
+// System.err.println("" + property.getURI(graph) + " is default");\r
+ continue;\r
+ } \r
+// else {\r
+// System.err.println("" + property.getURI(graph) + " is not default");\r
+// }\r
+ Boolean dynamicProperty = property.getPossiblePropertyValue(graph, DOC.Document_AttributeRelation_dynamic);\r
+ if(dynamicProperty != null && dynamicProperty) dynamics.add(property);\r
+ else statics.add(property);\r
+ }\r
+ return new Pair<Collection<Variable>, Collection<Variable>>(statics, dynamics);\r
+ }\r
+ \r
+ }\r
+ \r
+ public static Collection<Variable> getStaticAttributes(ReadGraph graph, DocumentationResource DOC, Variable variable) throws DatabaseException {\r
+ Pair<Collection<Variable>, Collection<Variable>> attribs = graph.syncRequest(new AttributesRequest(variable));\r
+ return attribs.first;\r
+ }\r
+\r
+ public static Collection<Variable> getDynamicAttributes(ReadGraph graph, final DocumentationResource DOC, Variable variable) throws DatabaseException {\r
+ Pair<Collection<Variable>, Collection<Variable>> attribs = graph.syncRequest(new AttributesRequest(variable));\r
+ return attribs.second;\r
+ }\r
+ \r
+ public static Variable getPossibleDocumentRootVariable(ReadGraph graph, Variable documentPart) throws DatabaseException {\r
+ if(documentPart instanceof RootVariable) return documentPart;\r
+ Variable parent = documentPart.getParent(graph);\r
+ if(parent == null) return null;\r
+ return getPossibleDocumentRootVariable(graph, parent);\r
+ }\r
+\r
+}\r
Code Review / simantics / platform.git / blobdiff