-package org.simantics.scl.commands.internal;\r
-\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.db.RequestProcessor;\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.WriteGraph;\r
-import org.simantics.db.common.request.WriteResultRequest;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.procedure.Procedure;\r
-import org.simantics.db.request.Read;\r
-import org.simantics.scl.commands.Command;\r
-import org.simantics.scl.commands.internal.checker.Checker;\r
-import org.simantics.scl.commands.internal.serialization.CommandSerializer;\r
-import org.simantics.scl.commands.internal.serialization.CommandSerializerFactory;\r
-import org.simantics.scl.compiler.elaboration.modules.SCLValue;\r
-import org.simantics.scl.compiler.top.ValueNotFound;\r
-import org.simantics.scl.compiler.types.Type;\r
-import org.simantics.scl.compiler.types.Types;\r
-import org.simantics.scl.compiler.types.util.MultiFunction;\r
-import org.simantics.scl.osgi.SCLOsgi;\r
-import org.simantics.scl.runtime.SCLContext;\r
-import org.simantics.scl.runtime.function.Function;\r
-import org.simantics.utils.logging.TimeLogger;\r
-\r
-/**\r
- * Default command implementation\r
- * \r
- * @author Hannu Niemistö\r
- */\r
-@SuppressWarnings({"rawtypes", "restriction"})\r
-public class CommandImpl implements Command {\r
-\r
- String name;\r
- Function command;\r
- Type[] parameterTypes;\r
- CommandSerializer serializer; \r
- Checker checker;\r
- \r
- public CommandImpl(String name, Function command, Type[] parameterTypes,\r
- CommandSerializer serializer, Checker checker) {\r
- this.name = name;\r
- this.command = command;\r
- this.parameterTypes = parameterTypes;\r
- this.serializer = serializer;\r
- this.checker = checker;\r
- }\r
- \r
- private class CheckRequest implements Read<Boolean> {\r
- Object[] parameters;\r
- \r
- public CheckRequest(Object[] parameters) {\r
- this.parameters = parameters;\r
- }\r
-\r
- @Override\r
- public Boolean perform(ReadGraph graph) throws DatabaseException {\r
- SCLContext sclContext = SCLContext.getCurrent();\r
- Object oldGraph = sclContext.put("graph", graph);\r
- boolean result = checker.check(parameters);\r
- sclContext.put("graph", oldGraph);\r
- return result;\r
- }\r
- }\r
- \r
- @Override\r
- public boolean check(RequestProcessor processor, Resource model,\r
- Object... parameters) throws DatabaseException {\r
- CheckRequest request = new CheckRequest(parameters);\r
- if(processor instanceof ReadGraph)\r
- return request.perform((ReadGraph)processor);\r
- else\r
- return processor.syncRequest(request);\r
- }\r
-\r
- private static boolean serializationErrorAlreadySeen = false;\r
- \r
- private class CommitRequest extends WriteResultRequest<Object> {\r
- Resource model;\r
- Object[] parameters;\r
- \r
- public CommitRequest(Resource model, Object[] parameters) {\r
- this.model = model;\r
- this.parameters = parameters;\r
- }\r
-\r
- @Override\r
- public Object perform(WriteGraph graph) throws DatabaseException {\r
- SCLContext sclContext = SCLContext.getCurrent();\r
- Object oldGraph = sclContext.put("graph", graph);\r
- // Serialize command first\r
- try {\r
- serializer.serialize(graph, model, parameters);\r
- } catch(Exception e) {\r
- if(!serializationErrorAlreadySeen) {\r
- e.printStackTrace();\r
- serializationErrorAlreadySeen = true;\r
- }\r
- } \r
- \r
- // Then execute (otherwise target of the command might not exist anymore)\r
- try {\r
- return command.applyArray(parameters);\r
- } finally {\r
- sclContext.put("graph", oldGraph);\r
- }\r
- }\r
- \r
- }\r
- \r
- @Override\r
- public Object execute(RequestProcessor processor, Resource model, Object ... parameters) throws DatabaseException {\r
- if(parameters.length != parameterTypes.length)\r
- throw new IllegalArgumentException("Wrong number of parameters given (" + parameters.length + ") expected " +\r
- parameterTypes.length + " parameters.");\r
- CommitRequest request = new CommitRequest(model, parameters);\r
- try {\r
- if(processor instanceof WriteGraph)\r
- return request.perform((WriteGraph)processor);\r
- else\r
- return processor.syncRequest(request);\r
- } finally {\r
- TimeLogger.log("Executed command " + name);\r
- }\r
- }\r
-\r
- @Override\r
- public void asyncExecute(RequestProcessor processor, Resource model,\r
- Object[] parameters, Procedure<Object> procedure) {\r
- processor.asyncRequest(new CommitRequest(model, parameters), procedure);\r
- }\r
-\r
- public static Command create(ReadGraph graph, String name) {\r
- Object oldGraph = SCLContext.getCurrent().put("graph", graph);\r
- try {\r
- SCLValue commandRef = SCLOsgi.MODULE_REPOSITORY.getValueRef(name);\r
- MultiFunction mfun = Types.matchFunction(commandRef.getType());\r
- Type[] parameterTypes = mfun.parameterTypes;\r
- Function command = (Function)SCLOsgi.MODULE_REPOSITORY.getValue(name);\r
- CommandSerializer serializer = CommandSerializerFactory.create(name, parameterTypes);\r
- Checker checker = Checker.create(name + "_check");\r
- return new CommandImpl(name, command, parameterTypes, serializer, checker);\r
- } catch(ValueNotFound e) {\r
- e.printStackTrace();\r
- return new ErrorCommand(name);\r
- } finally {\r
- SCLContext.getCurrent().put("graph", oldGraph);\r
- }\r
- }\r
-}\r
+package org.simantics.scl.commands.internal;
+
+import org.simantics.db.ReadGraph;
+import org.simantics.db.RequestProcessor;
+import org.simantics.db.Resource;
+import org.simantics.db.WriteGraph;
+import org.simantics.db.common.request.WriteResultRequest;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.procedure.Procedure;
+import org.simantics.db.request.Read;
+import org.simantics.scl.commands.Command;
+import org.simantics.scl.commands.internal.checker.Checker;
+import org.simantics.scl.commands.internal.serialization.CommandSerializer;
+import org.simantics.scl.commands.internal.serialization.CommandSerializerFactory;
+import org.simantics.scl.compiler.elaboration.modules.SCLValue;
+import org.simantics.scl.compiler.top.ValueNotFound;
+import org.simantics.scl.compiler.types.Type;
+import org.simantics.scl.compiler.types.Types;
+import org.simantics.scl.compiler.types.util.MultiFunction;
+import org.simantics.scl.osgi.SCLOsgi;
+import org.simantics.scl.runtime.SCLContext;
+import org.simantics.scl.runtime.function.Function;
+import org.simantics.utils.logging.TimeLogger;
+
+/**
+ * Default command implementation
+ *
+ * @author Hannu Niemistö
+ */
+@SuppressWarnings({"rawtypes", "restriction"})
+public class CommandImpl implements Command {
+
+ String name;
+ Function command;
+ Type[] parameterTypes;
+ CommandSerializer serializer;
+ Checker checker;
+
+ public CommandImpl(String name, Function command, Type[] parameterTypes,
+ CommandSerializer serializer, Checker checker) {
+ this.name = name;
+ this.command = command;
+ this.parameterTypes = parameterTypes;
+ this.serializer = serializer;
+ this.checker = checker;
+ }
+
+ private class CheckRequest implements Read<Boolean> {
+ Object[] parameters;
+
+ public CheckRequest(Object[] parameters) {
+ this.parameters = parameters;
+ }
+
+ @Override
+ public Boolean perform(ReadGraph graph) throws DatabaseException {
+ SCLContext sclContext = SCLContext.getCurrent();
+ Object oldGraph = sclContext.put("graph", graph);
+ boolean result = checker.check(parameters);
+ sclContext.put("graph", oldGraph);
+ return result;
+ }
+ }
+
+ @Override
+ public boolean check(RequestProcessor processor, Resource model,
+ Object... parameters) throws DatabaseException {
+ CheckRequest request = new CheckRequest(parameters);
+ if(processor instanceof ReadGraph)
+ return request.perform((ReadGraph)processor);
+ else
+ return processor.syncRequest(request);
+ }
+
+ private static boolean serializationErrorAlreadySeen = false;
+
+ private class CommitRequest extends WriteResultRequest<Object> {
+ Resource model;
+ Object[] parameters;
+
+ public CommitRequest(Resource model, Object[] parameters) {
+ this.model = model;
+ this.parameters = parameters;
+ }
+
+ @Override
+ public Object perform(WriteGraph graph) throws DatabaseException {
+ SCLContext sclContext = SCLContext.getCurrent();
+ Object oldGraph = sclContext.put("graph", graph);
+ // Serialize command first
+ try {
+ serializer.serialize(graph, model, parameters);
+ } catch(Exception e) {
+ if(!serializationErrorAlreadySeen) {
+ e.printStackTrace();
+ serializationErrorAlreadySeen = true;
+ }
+ }
+
+ // Then execute (otherwise target of the command might not exist anymore)
+ try {
+ return command.applyArray(parameters);
+ } finally {
+ sclContext.put("graph", oldGraph);
+ }
+ }
+
+ }
+
+ @Override
+ public Object execute(RequestProcessor processor, Resource model, Object ... parameters) throws DatabaseException {
+ if(parameters.length != parameterTypes.length)
+ throw new IllegalArgumentException("Wrong number of parameters given (" + parameters.length + ") expected " +
+ parameterTypes.length + " parameters.");
+ CommitRequest request = new CommitRequest(model, parameters);
+ try {
+ if(processor instanceof WriteGraph)
+ return request.perform((WriteGraph)processor);
+ else
+ return processor.syncRequest(request);
+ } finally {
+ TimeLogger.log("Executed command " + name);
+ }
+ }
+
+ @Override
+ public void asyncExecute(RequestProcessor processor, Resource model,
+ Object[] parameters, Procedure<Object> procedure) {
+ processor.asyncRequest(new CommitRequest(model, parameters), procedure);
+ }
+
+ public static Command create(ReadGraph graph, String name) {
+ Object oldGraph = SCLContext.getCurrent().put("graph", graph);
+ try {
+ SCLValue commandRef = SCLOsgi.MODULE_REPOSITORY.getValueRef(name);
+ MultiFunction mfun = Types.matchFunction(commandRef.getType());
+ Type[] parameterTypes = mfun.parameterTypes;
+ Function command = (Function)SCLOsgi.MODULE_REPOSITORY.getValue(name);
+ CommandSerializer serializer = CommandSerializerFactory.create(name, parameterTypes);
+ Checker checker = Checker.create(name + "_check");
+ return new CommandImpl(name, command, parameterTypes, serializer, checker);
+ } catch(ValueNotFound e) {
+ e.printStackTrace();
+ return new ErrorCommand(name);
+ } finally {
+ SCLContext.getCurrent().put("graph", oldGraph);
+ }
+ }
+}
Code Review / simantics / platform.git / blobdiff