-package org.simantics.modeling.ui.diagram.monitor;\r
-\r
-import java.util.HashMap;\r
-import java.util.LinkedList;\r
-import java.util.Map;\r
-import java.util.Stack;\r
-\r
-import org.simantics.basicexpression.analysis.DepthFirstAdapter;\r
-import org.simantics.basicexpression.analysis.EvaluationException;\r
-import org.simantics.basicexpression.node.AAddressValue;\r
-import org.simantics.basicexpression.node.AConstantValue;\r
-import org.simantics.basicexpression.node.AFunctionPrimary;\r
-import org.simantics.basicexpression.node.AMultMultiplicative;\r
-import org.simantics.basicexpression.node.APlusExpression;\r
-import org.simantics.basicexpression.node.ARangeValue;\r
-import org.simantics.basicexpression.node.ARviValue;\r
-import org.simantics.basicexpression.node.ASequenceArgList;\r
-import org.simantics.basicexpression.node.ASingleArgList;\r
-import org.simantics.basicexpression.node.ASingleRange;\r
-import org.simantics.basicexpression.node.AStringValue;\r
-import org.simantics.basicexpression.node.AVariablePrimary;\r
-import org.simantics.basicexpression.node.PArgList;\r
-import org.simantics.common.format.Formatter;\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.common.procedure.adapter.TransientCacheListener;\r
-import org.simantics.db.common.utils.Logger;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.layer0.request.ModelInstances;\r
-import org.simantics.db.layer0.request.VariableIndexRoot;\r
-import org.simantics.db.layer0.variable.Variable;\r
-import org.simantics.layer0.Layer0;\r
-import org.simantics.scl.runtime.function.Function;\r
-\r
-public class MonitorExpressionVisitor extends DepthFirstAdapter {\r
-\r
- public static final boolean DEBUG_APPLICATION = false;\r
- public static final boolean DEBUG = false;\r
- \r
- public static class ApplicationException extends Exception {\r
-\r
- private static final long serialVersionUID = 1L;\r
-\r
- public ApplicationException(String message) {\r
- super(message);\r
- }\r
-\r
- }\r
-\r
- final ReadGraph graph;\r
- final Variable variable;\r
- final Formatter formatter;\r
- \r
- Stack<Object> stack = new Stack<Object>();\r
-\r
- HashMap<String, Function> builtins = new HashMap<String, Function>();\r
-\r
- public MonitorExpressionVisitor(ReadGraph graph, Formatter formatter, Variable variable) {\r
-\r
- this.graph = graph;\r
- this.formatter = formatter;\r
- this.variable = variable;\r
-\r
- }\r
-\r
- public Object getResult() {\r
- if(exception != null) return exception;\r
- return stack.pop();\r
- }\r
-\r
- public void outAConstantValue(AConstantValue node) {\r
- if(DEBUG) System.out.println("outAConstantValue " + node);\r
- stack.push(Double.valueOf(node.toString()));\r
- }\r
-\r
- public void outAStringValue(AStringValue node) {\r
- if(DEBUG) System.out.println("outAStringValue " + node);\r
- String value = node.toString();\r
- stack.push(value.substring(1, value.length() - 2));\r
- }\r
-\r
- public void outAAddressValue(AAddressValue node) {\r
- if(DEBUG) System.out.println("outAAddressValue " + node);\r
- stack.push('&' + node.getRange().toString());\r
- }\r
-\r
- @Override\r
- public void outASingleRange(ASingleRange node) {\r
- \r
- if(DEBUG) System.out.println("outASingleRange " + node);\r
- \r
- }\r
- \r
- @Override\r
- public void outARviValue(ARviValue node) {\r
- \r
- if(DEBUG) System.out.println("outARviValue " + node);\r
- \r
- String rvi = node.toString().trim();\r
- \r
- try {\r
- Variable var = variable.browse(graph, rvi);\r
- stack.push(format(var.getValue(graph)));\r
- } catch (DatabaseException e) {\r
- Logger.defaultLogError(e);\r
- stack.push("<No value for '" + rvi + "'>");\r
- }\r
- \r
- }\r
- \r
- @Override\r
- public void outAVariablePrimary(AVariablePrimary node) {\r
- \r
- if(DEBUG) System.out.println("outAVariablePrimary " + node);\r
- \r
- String identifier = node.toString().trim();\r
- if("value".equals(identifier)) {\r
- try {\r
- stack.push(format(variable.getValue(graph)));\r
- } catch (DatabaseException e) {\r
- stack.push(e);\r
- }\r
- } else {\r
- stack.push(identifier);\r
- }\r
- \r
- }\r
- \r
- public void outARangeValue(ARangeValue node) {\r
-\r
- if(DEBUG) System.out.println("outARangeValue " + node);\r
-\r
- String identifier = node.getRange().toString().trim();\r
- stack.push(identifier);\r
-\r
- }\r
- \r
- private String format(Object o) {\r
- if(formatter != null)\r
- return formatter.format(o);\r
- else return o != null ? o.toString() : "";\r
- }\r
-\r
- private double extractValue(Object o) {\r
- if (o instanceof Number) {\r
- return ((Number) o).doubleValue();\r
- } else if (o instanceof String) {\r
- String s = (String) o;\r
- if (s.isEmpty())\r
- return 0;\r
- return Double.valueOf((String) o);\r
- } else {\r
- return Double.NaN;\r
- }\r
- }\r
- \r
- private Object extractSum(Object o1, Object o2) {\r
- \r
- if(o1 instanceof String) {\r
- return o1.toString() + o2;\r
- } else if (o2 instanceof String) {\r
- return o1.toString() + o2.toString(); \r
- } else if (o1 instanceof Number && o2 instanceof Number) {\r
- return ((Number) o1).doubleValue() + ((Number) o2).doubleValue();\r
- } else {\r
- return o1.toString() + o2.toString();\r
- }\r
- \r
- }\r
-\r
- public void outAPlusExpression(APlusExpression node) {\r
- \r
- if(DEBUG) System.out.println("outAPlusExpression " + node);\r
- \r
- Object o2 = stack.pop();\r
- Object o1 = stack.pop();\r
- \r
- Object out = extractSum(o1, o2);\r
- stack.push(out);\r
- \r
- }\r
-\r
- public void outAMultMultiplicative(AMultMultiplicative node) {\r
- \r
- if(DEBUG) System.out.println("outAMultiplicative " + node);\r
- \r
- Object o1 = stack.pop();\r
- Object o2 = stack.pop();\r
- double d1 = extractValue(o1);\r
- double d2 = extractValue(o2);\r
- stack.push(d1 * d2);\r
- \r
- }\r
-\r
- int countArguments(PArgList args) {\r
- if (args == null)\r
- return 0;\r
- if (args instanceof ASingleArgList)\r
- return 1;\r
- ASequenceArgList seq = (ASequenceArgList) args;\r
- return 1 + countArguments(seq.getArgList());\r
- }\r
-\r
- public void outAFunctionPrimary(AFunctionPrimary node) {\r
-\r
- if(DEBUG) System.out.println("outAFunctionPrimary " + node);\r
-\r
- try {\r
-\r
- String functionName = node.getFunc().getText().replace("(", "");\r
-\r
- if (DEBUG_APPLICATION)\r
- System.out.println("function apply " + functionName);\r
-\r
- Function function = builtins.get(functionName);\r
- if (function != null) {\r
-\r
- LinkedList<Object> args = new LinkedList<Object>();\r
- int argc = countArguments(node.getArgList());\r
- for (int i = 0; i < argc; i++) {\r
- args.addFirst(stack.pop());\r
- }\r
- args.addFirst(formatter);\r
- args.addFirst(variable);\r
- args.addFirst(graph);\r
-\r
- Object result = function.applyArray(args);\r
- stack.push(format(result));\r
-\r
- } else {\r
-\r
- // Instances instances = graph.adapt(L0.Function, Instances.class);\r
- // Collection<Resource> functions = instances.find(graph, Variables.getModel(graph, variable),\r
- // "Name:" + functionName);\r
- // if (DEBUG_APPLICATION)\r
- // System.out.println("Found " + functions.size() + " matches.");\r
- // if (functions != null && functions.size() == 1) {\r
- Layer0 L0 = Layer0.getInstance(graph);\r
- Resource functionResource = null;\r
- Resource indexRoot = graph.sync(new VariableIndexRoot(variable));\r
- if (indexRoot != null) {\r
- Map<String, Resource> functions = graph.syncRequest(\r
- new ModelInstances(indexRoot, L0.Function),\r
- TransientCacheListener.<Map<String, Resource>> instance());\r
- functionResource = functions.get(functionName);\r
- }\r
- if(functionResource != null) {\r
-// Resource functionResource = functions.iterator().next();\r
- function = graph.adapt(functionResource, Function.class);\r
- LinkedList<Object> args = new LinkedList<Object>();\r
- int argc = countArguments(node.getArgList());\r
- for (int i = 0; i < argc; i++) {\r
- args.addFirst(stack.pop());\r
- }\r
- args.addFirst(formatter);\r
- args.addFirst(variable);\r
- args.addFirst(graph);\r
- Object result = function.applyArray(args.toArray());\r
- stack.push(format(result));\r
-\r
- } else {\r
-\r
- //stack.push(null);\r
- throw new EvaluationException("Function not found in dependencies: '" + functionName + "'");\r
-\r
- }\r
-\r
- }\r
-\r
- } catch (DatabaseException e) {\r
-\r
- stack.push(null);\r
-\r
- }\r
-\r
- }\r
-\r
-}\r
+package org.simantics.modeling.ui.diagram.monitor;
+
+import java.util.HashMap;
+import java.util.LinkedList;
+import java.util.Map;
+import java.util.Stack;
+
+import org.simantics.basicexpression.analysis.DepthFirstAdapter;
+import org.simantics.basicexpression.analysis.EvaluationException;
+import org.simantics.basicexpression.node.AAddressValue;
+import org.simantics.basicexpression.node.AConstantValue;
+import org.simantics.basicexpression.node.AFunctionPrimary;
+import org.simantics.basicexpression.node.AMultMultiplicative;
+import org.simantics.basicexpression.node.APlusExpression;
+import org.simantics.basicexpression.node.ARangeValue;
+import org.simantics.basicexpression.node.ARviValue;
+import org.simantics.basicexpression.node.ASequenceArgList;
+import org.simantics.basicexpression.node.ASingleArgList;
+import org.simantics.basicexpression.node.ASingleRange;
+import org.simantics.basicexpression.node.AStringValue;
+import org.simantics.basicexpression.node.AVariablePrimary;
+import org.simantics.basicexpression.node.PArgList;
+import org.simantics.common.format.Formatter;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.common.procedure.adapter.TransientCacheListener;
+import org.simantics.db.common.utils.Logger;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.layer0.request.ModelInstances;
+import org.simantics.db.layer0.request.VariableIndexRoot;
+import org.simantics.db.layer0.variable.Variable;
+import org.simantics.layer0.Layer0;
+import org.simantics.scl.runtime.function.Function;
+
+public class MonitorExpressionVisitor extends DepthFirstAdapter {
+
+ public static final boolean DEBUG_APPLICATION = false;
+ public static final boolean DEBUG = false;
+
+ public static class ApplicationException extends Exception {
+
+ private static final long serialVersionUID = 1L;
+
+ public ApplicationException(String message) {
+ super(message);
+ }
+
+ }
+
+ final ReadGraph graph;
+ final Variable variable;
+ final Formatter formatter;
+
+ Stack<Object> stack = new Stack<Object>();
+
+ HashMap<String, Function> builtins = new HashMap<String, Function>();
+
+ public MonitorExpressionVisitor(ReadGraph graph, Formatter formatter, Variable variable) {
+
+ this.graph = graph;
+ this.formatter = formatter;
+ this.variable = variable;
+
+ }
+
+ public Object getResult() {
+ if(exception != null) return exception;
+ return stack.pop();
+ }
+
+ public void outAConstantValue(AConstantValue node) {
+ if(DEBUG) System.out.println("outAConstantValue " + node);
+ stack.push(Double.valueOf(node.toString()));
+ }
+
+ public void outAStringValue(AStringValue node) {
+ if(DEBUG) System.out.println("outAStringValue " + node);
+ String value = node.toString();
+ stack.push(value.substring(1, value.length() - 2));
+ }
+
+ public void outAAddressValue(AAddressValue node) {
+ if(DEBUG) System.out.println("outAAddressValue " + node);
+ stack.push('&' + node.getRange().toString());
+ }
+
+ @Override
+ public void outASingleRange(ASingleRange node) {
+
+ if(DEBUG) System.out.println("outASingleRange " + node);
+
+ }
+
+ @Override
+ public void outARviValue(ARviValue node) {
+
+ if(DEBUG) System.out.println("outARviValue " + node);
+
+ String rvi = node.toString().trim();
+
+ try {
+ Variable var = variable.browse(graph, rvi);
+ stack.push(format(var.getValue(graph)));
+ } catch (DatabaseException e) {
+ Logger.defaultLogError(e);
+ stack.push("<No value for '" + rvi + "'>");
+ }
+
+ }
+
+ @Override
+ public void outAVariablePrimary(AVariablePrimary node) {
+
+ if(DEBUG) System.out.println("outAVariablePrimary " + node);
+
+ String identifier = node.toString().trim();
+ if("value".equals(identifier)) {
+ try {
+ stack.push(format(variable.getValue(graph)));
+ } catch (DatabaseException e) {
+ stack.push(e);
+ }
+ } else {
+ stack.push(identifier);
+ }
+
+ }
+
+ public void outARangeValue(ARangeValue node) {
+
+ if(DEBUG) System.out.println("outARangeValue " + node);
+
+ String identifier = node.getRange().toString().trim();
+ stack.push(identifier);
+
+ }
+
+ private String format(Object o) {
+ if(formatter != null)
+ return formatter.format(o);
+ else return o != null ? o.toString() : "";
+ }
+
+ private double extractValue(Object o) {
+ if (o instanceof Number) {
+ return ((Number) o).doubleValue();
+ } else if (o instanceof String) {
+ String s = (String) o;
+ if (s.isEmpty())
+ return 0;
+ return Double.valueOf((String) o);
+ } else {
+ return Double.NaN;
+ }
+ }
+
+ private Object extractSum(Object o1, Object o2) {
+
+ if(o1 instanceof String) {
+ return o1.toString() + o2;
+ } else if (o2 instanceof String) {
+ return o1.toString() + o2.toString();
+ } else if (o1 instanceof Number && o2 instanceof Number) {
+ return ((Number) o1).doubleValue() + ((Number) o2).doubleValue();
+ } else {
+ return o1.toString() + o2.toString();
+ }
+
+ }
+
+ public void outAPlusExpression(APlusExpression node) {
+
+ if(DEBUG) System.out.println("outAPlusExpression " + node);
+
+ Object o2 = stack.pop();
+ Object o1 = stack.pop();
+
+ Object out = extractSum(o1, o2);
+ stack.push(out);
+
+ }
+
+ public void outAMultMultiplicative(AMultMultiplicative node) {
+
+ if(DEBUG) System.out.println("outAMultiplicative " + node);
+
+ Object o1 = stack.pop();
+ Object o2 = stack.pop();
+ double d1 = extractValue(o1);
+ double d2 = extractValue(o2);
+ stack.push(d1 * d2);
+
+ }
+
+ int countArguments(PArgList args) {
+ if (args == null)
+ return 0;
+ if (args instanceof ASingleArgList)
+ return 1;
+ ASequenceArgList seq = (ASequenceArgList) args;
+ return 1 + countArguments(seq.getArgList());
+ }
+
+ public void outAFunctionPrimary(AFunctionPrimary node) {
+
+ if(DEBUG) System.out.println("outAFunctionPrimary " + node);
+
+ try {
+
+ String functionName = node.getFunc().getText().replace("(", "");
+
+ if (DEBUG_APPLICATION)
+ System.out.println("function apply " + functionName);
+
+ Function function = builtins.get(functionName);
+ if (function != null) {
+
+ LinkedList<Object> args = new LinkedList<Object>();
+ int argc = countArguments(node.getArgList());
+ for (int i = 0; i < argc; i++) {
+ args.addFirst(stack.pop());
+ }
+ args.addFirst(formatter);
+ args.addFirst(variable);
+ args.addFirst(graph);
+
+ Object result = function.applyArray(args);
+ stack.push(format(result));
+
+ } else {
+
+ // Instances instances = graph.adapt(L0.Function, Instances.class);
+ // Collection<Resource> functions = instances.find(graph, Variables.getModel(graph, variable),
+ // "Name:" + functionName);
+ // if (DEBUG_APPLICATION)
+ // System.out.println("Found " + functions.size() + " matches.");
+ // if (functions != null && functions.size() == 1) {
+ Layer0 L0 = Layer0.getInstance(graph);
+ Resource functionResource = null;
+ Resource indexRoot = graph.sync(new VariableIndexRoot(variable));
+ if (indexRoot != null) {
+ Map<String, Resource> functions = graph.syncRequest(
+ new ModelInstances(indexRoot, L0.Function),
+ TransientCacheListener.<Map<String, Resource>> instance());
+ functionResource = functions.get(functionName);
+ }
+ if(functionResource != null) {
+// Resource functionResource = functions.iterator().next();
+ function = graph.adapt(functionResource, Function.class);
+ LinkedList<Object> args = new LinkedList<Object>();
+ int argc = countArguments(node.getArgList());
+ for (int i = 0; i < argc; i++) {
+ args.addFirst(stack.pop());
+ }
+ args.addFirst(formatter);
+ args.addFirst(variable);
+ args.addFirst(graph);
+ Object result = function.applyArray(args.toArray());
+ stack.push(format(result));
+
+ } else {
+
+ //stack.push(null);
+ throw new EvaluationException("Function not found in dependencies: '" + functionName + "'");
+
+ }
+
+ }
+
+ } catch (DatabaseException e) {
+
+ stack.push(null);
+
+ }
+
+ }
+
+}
Code Review / simantics / platform.git / blobdiff