Migrated source code from Simantics SVN

[simantics/platform.git] / bundles / org.simantics.document.server / src / org / simantics / document / server / handler / WriteEventHandler.java

diff --git a/bundles/org.simantics.document.server/src/org/simantics/document/server/handler/WriteEventHandler.java b/bundles/org.simantics.document.server/src/org/simantics/document/server/handler/WriteEventHandler.java
new file mode 100644 (file)
index 0000000..f58e9c3
--- /dev/null
+++ b/bundles/org.simantics.document.server/src/org/simantics/document/server/handler/WriteEventHandler.java
@@ -0,0 +1,44 @@
+package org.simantics.document.server.handler;\r
+\r
+import org.simantics.Simantics;\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.document.server.io.CommandContext;\r
+import org.simantics.document.server.io.CommandResult;\r
+import org.simantics.document.server.serverResponse.Error;\r
+import org.simantics.document.server.serverResponse.IDelayedResponse;\r
+\r
+public abstract class WriteEventHandler extends AbstractEventHandler {\r
+\r
+    protected abstract CommandResult handle(WriteGraph graph, CommandContext parameters) throws DatabaseException;\r
+\r
+    public CommandResult handle(final CommandContext parameters) {\r
+        try {\r
+               CommandResult response = Simantics.getSession().syncRequest(new WriteResultRequest<CommandResult>() {\r
+                @Override\r
+                public CommandResult perform(WriteGraph graph) throws DatabaseException {\r
+                    graph.markUndoPoint();\r
+                    return handle(graph, parameters);\r
+                }\r
+            });\r
+\r
+            if(response instanceof IDelayedResponse && !(((IDelayedResponse)response).hasRun())) {\r
+                try {\r
+                    synchronized(response) {\r
+                        response.wait(200000);\r
+                    }\r
+                } catch (InterruptedException e) {\r
+                    e.printStackTrace();\r
+                }\r
+            }\r
+            \r
+            return response;\r
+        } catch (DatabaseException e) {\r
+            e.printStackTrace();\r
+            return new Error(e.getMessage()); // Return some error\r
+        }\r
+    }\r
+\r
+\r
+}\r