--- /dev/null
+/*******************************************************************************\r
+ * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
+ * in Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ * VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+package org.simantics.workbench.internal;\r
+\r
+import java.lang.reflect.InvocationTargetException;\r
+import java.net.InetSocketAddress;\r
+import java.util.HashSet;\r
+import java.util.Set;\r
+\r
+import org.eclipse.core.runtime.IProgressMonitor;\r
+import org.eclipse.core.runtime.IStatus;\r
+import org.eclipse.core.runtime.MultiStatus;\r
+import org.eclipse.core.runtime.Status;\r
+import org.eclipse.jface.action.IAction;\r
+import org.eclipse.jface.dialogs.ProgressMonitorDialog;\r
+import org.eclipse.jface.operation.IRunnableWithProgress;\r
+import org.eclipse.swt.widgets.Display;\r
+import org.eclipse.ui.IWorkbenchWindow;\r
+import org.simantics.application.arguments.ApplicationUtils;\r
+import org.simantics.application.arguments.IArguments;\r
+import org.simantics.application.arguments.SimanticsArguments;\r
+import org.simantics.db.ReadGraph;\r
+import org.simantics.db.Resource;\r
+import org.simantics.db.Session;\r
+import org.simantics.db.common.request.ReadRequest;\r
+import org.simantics.db.common.utils.NameUtils;\r
+import org.simantics.db.exception.DatabaseException;\r
+import org.simantics.db.layer0.util.SimanticsKeys;\r
+import org.simantics.db.management.ISessionContext;\r
+import org.simantics.db.management.discovery.InetAddressUtils;\r
+import org.simantics.db.request.Read;\r
+import org.simantics.project.IProject;\r
+import org.simantics.project.ProjectKeys;\r
+import org.simantics.project.ProjectUtil;\r
+import org.simantics.project.exception.ProjectException;\r
+import org.simantics.project.utils.GraphPathUtils;\r
+import org.simantics.ui.db.SessionData;\r
+import org.simantics.ui.db.SessionRestoreUtils;\r
+import org.simantics.ui.internal.Activator;\r
+import org.simantics.ui.workbench.action.ChooseActionRequest;\r
+import org.simantics.utils.ui.ExceptionUtils;\r
+import org.simantics.utils.ui.action.IPriorityAction;\r
+import org.simantics.utils.ui.dialogs.ShowMessage;\r
+\r
+public class Initializer implements Runnable {\r
+\r
+ private final IArguments args;\r
+\r
+// private String defaultPerspectiveId;\r
+\r
+ /**\r
+ * This will be !ok if something fatal for startup has happened.\r
+ */\r
+ private final IStatus status = Status.OK_STATUS;\r
+\r
+ private ISessionContext ctx;\r
+\r
+ private IProject project;\r
+\r
+ private Resource model;\r
+\r
+ private final IWorkbenchWindow window;\r
+\r
+// private Resource experiment;\r
+\r
+\r
+ public Initializer(IArguments args, IWorkbenchWindow window) {\r
+ this.args = args;\r
+ this.window = window;\r
+// this.defaultPerspectiveId = defaultPerspectiveId;\r
+ }\r
+\r
+ @Override\r
+ public void run() {\r
+ try {\r
+ perform();\r
+ } catch (DatabaseException e) {\r
+ e.printStackTrace();\r
+ } catch (ProjectException e) {\r
+ e.printStackTrace();\r
+ }\r
+ }\r
+\r
+ public IStatus getStatus() {\r
+ return status;\r
+ }\r
+\r
+ public ISessionContext getSessionContext() {\r
+ return ctx;\r
+ }\r
+\r
+ public IProject getProject() {\r
+ return project;\r
+ }\r
+\r
+ public Resource getModel() {\r
+ return model;\r
+ }\r
+\r
+ public boolean perform() throws DatabaseException, ProjectException {\r
+ // Nothing further can be done if no server is specified\r
+ if (!args.contains(SimanticsArguments.SERVER))\r
+ return true;\r
+\r
+ // Try to connect to designated server and project.\r
+ // Use null local server location to indicate checkout\r
+ String server = args.get(SimanticsArguments.SERVER);\r
+ if(server.indexOf(':') == -1 && args.contains(SimanticsArguments.PORT)) {\r
+ server = server+":"+args.get(SimanticsArguments.PORT);\r
+ }\r
+ InetSocketAddress serverAddress = InetAddressUtils.parseUnresolved(server);\r
+ String[] projectPath = ApplicationUtils.decodePath(args.get(SimanticsArguments.PROJECT));\r
+ final SessionData data = new SessionData(null, serverAddress, projectPath);\r
+\r
+ final MultiStatus status = new MultiStatus(Activator.PLUGIN_ID, IStatus.OK, "Database session could not be initialized.", null);\r
+ // final ProgressMonitorDialog dialog = new ProgressMonitorDialog(null);\r
+\r
+ final ProgressMonitorDialog dialog = new ProgressMonitorDialog(null);\r
+ try {\r
+ dialog.run(false, true, new IRunnableWithProgress() {\r
+ @Override\r
+ public void run(final IProgressMonitor monitor) throws InvocationTargetException, InterruptedException {\r
+ ctx = SessionRestoreUtils.restoreSession(status, monitor, data);\r
+ //ctx = sessionResult;\r
+ }\r
+ });\r
+ } catch (InvocationTargetException e) {\r
+ ExceptionUtils.logAndShowError(e);\r
+ } catch (InterruptedException e) {\r
+ ExceptionUtils.logAndShowError(e);\r
+ }\r
+\r
+ //IDiscoveryModel model =\r
+\r
+\r
+// IDiscoveryData[] iData = ProjectPlugin.getWorkspace().getDiscoveryModel().getDataSources();\r
+// for(int i = 0; i < iData.length; i++) {\r
+// IDiscoveryData d = iData[i];\r
+// if(d.getLabel().equals(IWorkspaceConstants.DIRECT_SERVERS_LABEL)) {\r
+// ServerInfo serverInfo = new ServerInfo(d.getLabel(), serverAddress);\r
+// ServerData serverData = new ServerData(null, serverInfo, null);\r
+// IServerData[] iServerData = d.getServers();\r
+//\r
+// IServerData[] newServerData = new IServerData[iServerData.length+1];\r
+//\r
+// int y;\r
+// for(y = 0; y < iServerData.length; y++) {\r
+// newServerData[y] = iServerData[y];\r
+// }\r
+//\r
+// newServerData[y] = serverData;\r
+//\r
+// d.setServers(newServerData);\r
+// ProjectPlugin.getWorkspace().getDiscoveryModel().updateDataSource(d);\r
+// break;\r
+// }\r
+//\r
+// }\r
+\r
+ //status = sessionResult.status;\r
+ //if (!status.isOK()) {\r
+ // return false;\r
+ //}\r
+\r
+ if (ctx == null) {\r
+ // Its okay to start the workbench, it will just be reset as the\r
+ // connection failed.\r
+ return true;\r
+ }\r
+\r
+ // FIXME: COMPLETE HACK for simupedia\r
+ // Add a discovery service to get in touch\r
+ /*\r
+ IDiscoveryModel discoveryModel = ProjectPlugin.getWorkspace().getDiscoveryModel();\r
+ File discoveryFile = ProjectPlugin.getDefault().getStateLocation().append("simupedia-discovery.txt").toFile();\r
+ FileWriter fw = null;\r
+ try {\r
+ // Overwrite the file.\r
+ fw = new FileWriter(discoveryFile, false);\r
+ String serverLine = String.format("'%s' %s\n", data.getAddress().getHostName(), server);\r
+ fw.write(serverLine);\r
+ } catch (IOException e) {\r
+ e.printStackTrace();\r
+ } finally {\r
+ FileUtils.uncheckedClose(fw);\r
+ }\r
+ try {\r
+ // Add a non-persistent simupedia discovery\r
+ DiscoveryData d = new DiscoveryData(IDiscoveryType.REMOTE, "Simupedia", discoveryFile);\r
+ discoveryModel.addDataSource(d);\r
+ } catch (MalformedURLException e) {\r
+ // Should never happen.\r
+ throw new Error(e);\r
+ }\r
+ */\r
+\r
+ // Initialize project\r
+ if (args.contains(SimanticsArguments.NEW_PROJECT)) {\r
+ throw new UnsupportedOperationException();\r
+ //project = newProject(ctx);\r
+ } else if (args.contains(SimanticsArguments.PROJECT)) {\r
+ project = loadProject(ctx, projectPath);\r
+ }\r
+\r
+ // Only proceed with model and experiment loading if a project was\r
+ // successfully created or loaded.\r
+ if (project != null) {\r
+ ctx.setHint(ProjectKeys.KEY_PROJECT, project);\r
+ ctx.setHint(SimanticsKeys.KEY_PROJECT, project.get());\r
+\r
+ // Load model\r
+ if (args.contains(SimanticsArguments.NEW_MODEL)) {\r
+ //model = newModel(ctx.getSession(), project);\r
+ } else if (args.contains(SimanticsArguments.MODEL)) {\r
+ String[] modelPath = ApplicationUtils.decodePath(args.get(SimanticsArguments.MODEL));\r
+ model = findModel(ctx.getSession(), project, modelPath);\r
+ }\r
+// if (model != null) {\r
+// findDiagram(ctx.getSession(), model, project);\r
+// }\r
+\r
+ // TODO: load experiment\r
+ if (args.contains(SimanticsArguments.EXPERIMENT)) {\r
+ // String[] experimentPath = decodePath(args.get(ProConfArguments.EXPERIMENT));\r
+ }\r
+ }\r
+\r
+ return true;\r
+ }\r
+\r
+ IProject loadProject(ISessionContext ctx, final String[] projectNamePath) throws DatabaseException, ProjectException {\r
+\r
+ IProject project = ctx.getSession().syncRequest(new Read<IProject>() {\r
+\r
+ @Override\r
+ public IProject perform(ReadGraph graph) throws DatabaseException {\r
+ Resource projects = graph.getResource("http://Projects");\r
+ Resource[] path = GraphPathUtils.toResourcePath(graph, projects, projectNamePath, graph\r
+ .getBuiltins().ConsistsOf);\r
+ if (path.length == 0) {\r
+ IllegalArgumentException e = new IllegalArgumentException("");\r
+ ShowMessage.showError("Error loading the existing project", e.getMessage());\r
+ throw new DatabaseException(e);\r
+ }\r
+ return ProjectUtil.loadProject(graph, path[path.length - 1]);\r
+ }\r
+\r
+ });\r
+\r
+ project.activate();\r
+\r
+ return project;\r
+\r
+// final GraphRequestWithResult<IProject> request = new GraphRequestWithResult<IProject>() {\r
+// @Override\r
+// public IProject performWithResult(Graph g) throws Exception {\r
+// }\r
+// };\r
+// ctx.getSession().syncRead(request);\r
+// if (request.getException() != null) {\r
+// ShowMessage.showError("Error loading the existing project", request.getException().getMessage());\r
+// return null;\r
+// }\r
+// return request.getResult();\r
+ }\r
+\r
+ Resource findModel(final Session session, final IProject project, final String[] modelPath) throws DatabaseException {\r
+\r
+ return session.syncRequest(new Read<Resource>() {\r
+\r
+ @Override\r
+ public Resource perform(ReadGraph graph) throws DatabaseException {\r
+ Resource[] path = GraphPathUtils.toResourcePath(graph, project.get(), modelPath, graph\r
+ .getBuiltins().ConsistsOf);\r
+ if (path.length == 0) {\r
+ IllegalArgumentException e = new IllegalArgumentException("");\r
+ ShowMessage.showError("Error loading the existing project", e.getMessage());\r
+ throw new DatabaseException(e);\r
+ }\r
+ else return path[path.length - 1];\r
+ }\r
+\r
+ });\r
+\r
+// final GraphRequestWithResult<Resource> request = new GraphRequestWithResult<Resource>() {\r
+// @Override\r
+// public Resource performWithResult(Graph g) {\r
+// Resource[] path = GraphPathUtils.toResourcePath(g, project.getResource(), modelPath,\r
+// g.getBuiltins().ConsistsOf);\r
+// if (path.length == 0)\r
+// throw new IllegalArgumentException("");\r
+// return path[path.length - 1];\r
+// }\r
+// };\r
+// session.syncRead(request);\r
+// if (request.getException() != null) {\r
+// ShowMessage.showError("Error loading the existing project", request.getException().getMessage());\r
+// return null;\r
+// }\r
+// return request.getResult();\r
+ }\r
+\r
+ final Set<String> reservedProjectNames = new HashSet<String>();\r
+// IProject newProject(final ISessionContext ctx) throws DatabaseException {\r
+// // ---------------------------------------------------------------------\r
+// // Show the wizard to the user.\r
+// final NewProjectModel2 model = ProjectWizardUtil.initializeNewProjectModel2(new NullProgressMonitor(), ctx);\r
+// final NewProjectWizard2 wizard = new NewProjectWizard2(ctx.getSession(), model, null);\r
+// int ok = new WizardDialog(null, wizard).open();\r
+// if (ok != Window.OK) {\r
+// // User cancelled the wizard.\r
+// return null;\r
+// }\r
+//\r
+// final DataContainer<IProject> project = new DataContainer<IProject>();\r
+//\r
+// ctx.getSession().syncRequest(new WriteRequest() {\r
+//\r
+// @Override\r
+// public void perform(WriteGraph g) {\r
+//\r
+// try {\r
+//\r
+// // TODO: add features\r
+// System.out.println("TODO: add features to project");\r
+// Collection<IProjectFeatureDescriptor> fds = Collections.emptyList();\r
+// Resource res = ProjectUtil.createProject(g, model.projectName, fds);\r
+// project.set(ProjectUtil.loadProject(g, res, false));\r
+//\r
+// } catch (Exception e) {\r
+// ShowMessage.showError("Error creating new project", e.getMessage());\r
+// }\r
+//\r
+// }\r
+//\r
+// });\r
+//\r
+// return project.get();\r
+//\r
+// }\r
+\r
+ /*\r
+ Resource newModel(final Session session, final IProject project) {\r
+ final ISimulationProjectParticipant sim = project.getSingleParticipant(ISimulationProjectParticipant.class);\r
+ if (sim == null)\r
+ return null;\r
+\r
+ final Resource[] result = { null };\r
+ final Semaphore sem = new Semaphore(0);\r
+ findModelLibrary(session, project.getResource(), new RunnableWithParameter<Resource>() {\r
+ @Override\r
+ public void run(Resource modelLibrary) {\r
+ sim.createModel(modelLibrary,\r
+ new RunnableWithParameter<Resource>() {\r
+ @Override\r
+ public void run(Resource model) {\r
+ result[0] = model;\r
+ sem.release();\r
+ }\r
+ },\r
+ new RunnableWithParameter<Throwable>() {\r
+ @Override\r
+ public void run(Throwable e) {\r
+ ErrorLogger.defaultLogError("New model creation failed, see exception for details.", e);\r
+ sem.release();\r
+ }\r
+ });\r
+ }\r
+ },\r
+ new RunnableWithParameter<Throwable>() {\r
+ @Override\r
+ public void run(Throwable e) {\r
+ if (e != null)\r
+ ErrorLogger.defaultLogError("New model creation failed, see exception for details.", e);\r
+ else\r
+ ErrorLogger.defaultLogError("New model creation failed, no model library found.", null);\r
+ sem.release();\r
+ }\r
+ });\r
+\r
+ // Wait until the model creation has finished or failed.\r
+ try {\r
+ sem.acquire();\r
+ } catch (InterruptedException e) {\r
+ }\r
+ return result[0];\r
+ }\r
+ */\r
+\r
+ /*\r
+ void findModelLibrary(Session session,\r
+ final Resource project,\r
+ final RunnableWithParameter<Resource> libraryAction,\r
+ final RunnableWithParameter<Throwable> errorCallback)\r
+ {\r
+ // TODO: all of this is not that generic, what is someone decices he/she\r
+ // doesn't want a model library called Models at the root of his/her\r
+ // project ??\r
+\r
+ // If the new model consists of a single diagram, open it.\r
+ session.asyncRequest(new WriteRequest() {\r
+ @Override\r
+ public void perform(WriteGraph g) throws Exception {\r
+ Resource modelLibrary = null;\r
+ try {\r
+ Builtins b = g.getBuiltins();\r
+ for (Resource r : g.getObjects2(project, b.ConsistsOf)) {\r
+ if (g.isInstanceOf2(r, b.ModelLibrary)) {\r
+ modelLibrary = r;\r
+ break;\r
+ }\r
+ }\r
+ // FIXME: this is definitely project specific, not generic.\r
+ if (modelLibrary == null) {\r
+ modelLibrary = InstanceFactory.instantiate(g, b.ModelLibrary);\r
+ GraphUtils.addRelatedScalarString(g, modelLibrary, b.HasName, "Models");\r
+ g.claim(project, b.ConsistsOf, modelLibrary);\r
+ }\r
+ libraryAction.run(modelLibrary);\r
+ } catch (Exception e) {\r
+ errorCallback.run(e);\r
+ }\r
+ }\r
+ });\r
+ }\r
+ */\r
+\r
+// void findDiagram(Session session, final Resource model, final IProject project) {\r
+// // If the new model consists of a single diagram, open it.\r
+// session.asyncRequest(new ReadRequest() {\r
+// @Override\r
+// public void run(ReadGraph g) throws DatabaseException {\r
+// Builtins b = g.getBuiltins();\r
+// DiagramResource dr = DiagramResource.getInstance(g);\r
+// for (Resource r : g.getObjects(model, b.ConsistsOf)) {\r
+// if (g.isInstanceOf(r, dr.Diagram)) {\r
+// String defaultPerspective = project.getHint(ProjectKeys.DEFAULT_PERSPECTIVE);\r
+// openPreferredEditor(ctx.getSession(), r, defaultPerspective);\r
+// break;\r
+// }\r
+// }\r
+// }\r
+// });\r
+// }\r
+\r
+ void openPreferredEditor(Session s, final Resource r, final String defaultPerspective) {\r
+\r
+ s.asyncRequest(new ReadRequest() {\r
+\r
+ @Override\r
+ public void run(ReadGraph g) throws DatabaseException {\r
+ final String resourceName = NameUtils.getSafeName(g, r);\r
+ final IPriorityAction[] actions = ChooseActionRequest.findActions(g, r, defaultPerspective);\r
+ if (actions == null)\r
+ return;\r
+ Display.getDefault().asyncExec(new Runnable() {\r
+ @Override\r
+ public void run() {\r
+ IAction action = ChooseActionRequest.chooseAction(null, actions, resourceName);\r
+ if (action == null)\r
+ return;\r
+ action.run();\r
+ }\r
+ });\r
+ }\r
+\r
+ });\r
+ }\r
+\r
+}\r
Code Review / simantics / platform.git / blobdiff