-package org.simantics.modeling.ui.actions;\r
-\r
-import static org.simantics.db.common.utils.Transaction.endTransaction;\r
-\r
-import java.io.ByteArrayInputStream;\r
-import java.io.Closeable;\r
-import java.io.File;\r
-import java.io.FileNotFoundException;\r
-import java.io.FileOutputStream;\r
-import java.io.IOException;\r
-import java.io.InputStream;\r
-import java.io.UnsupportedEncodingException;\r
-import java.net.URL;\r
-import java.net.URLDecoder;\r
-import java.util.ArrayList;\r
-import java.util.Collection;\r
-import java.util.Collections;\r
-import java.util.HashMap;\r
-import java.util.Map;\r
-import java.util.Set;\r
-\r
-import org.eclipse.core.runtime.FileLocator;\r
-import org.eclipse.jface.dialogs.MessageDialog;\r
-import org.eclipse.jface.layout.GridDataFactory;\r
-import org.eclipse.jface.layout.GridLayoutFactory;\r
-import org.eclipse.swt.SWT;\r
-import org.eclipse.swt.widgets.Composite;\r
-import org.eclipse.swt.widgets.Control;\r
-import org.eclipse.swt.widgets.Display;\r
-import org.eclipse.swt.widgets.Shell;\r
-import org.osgi.framework.Bundle;\r
-import org.simantics.PlatformException;\r
-import org.simantics.Simantics;\r
-import org.simantics.databoard.Bindings;\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.WriteGraph;\r
-import org.simantics.db.common.request.ObjectsWithType;\r
-import org.simantics.db.common.request.ReadRequest;\r
-import org.simantics.db.common.request.UniqueRead;\r
-import org.simantics.db.common.request.WriteRequest;\r
-import org.simantics.db.common.utils.Logger;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.layer0.adapter.ActionFactory;\r
-import org.simantics.db.layer0.adapter.CopyHandler;\r
-import org.simantics.db.layer0.adapter.SubgraphExtent.ExtentStatus;\r
-import org.simantics.db.layer0.adapter.impl.DefaultCopyHandler;\r
-import org.simantics.db.layer0.adapter.impl.DefaultPasteHandler;\r
-import org.simantics.db.layer0.adapter.impl.DefaultPasteImportAdvisor;\r
-import org.simantics.db.layer0.util.ClipboardUtils;\r
-import org.simantics.db.layer0.util.DomainProcessorState;\r
-import org.simantics.db.layer0.util.Layer0Utils;\r
-import org.simantics.db.layer0.util.ModelTransferableGraphSource;\r
-import org.simantics.db.layer0.util.ModelTransferableGraphSourceRequest;\r
-import org.simantics.db.layer0.util.SimanticsClipboard.Representation;\r
-import org.simantics.db.layer0.util.SimanticsClipboardImpl;\r
-import org.simantics.db.layer0.util.SimanticsKeys;\r
-import org.simantics.db.layer0.util.TransferableGraphConfiguration2;\r
-import org.simantics.db.service.SerialisationSupport;\r
-import org.simantics.graph.compiler.CompilationResult;\r
-import org.simantics.graph.compiler.GraphCompiler;\r
-import org.simantics.graph.compiler.GraphCompilerPreferences;\r
-import org.simantics.graph.compiler.ValidationMode;\r
-import org.simantics.graph.db.TransferableGraphSource;\r
-import org.simantics.graph.db.TransferableGraphs;\r
-import org.simantics.graph.diff.Diff;\r
-import org.simantics.graph.diff.TransferableGraphDelta1;\r
-import org.simantics.graph.representation.Identity;\r
-import org.simantics.graph.representation.Root;\r
-import org.simantics.graph.representation.TransferableGraph1;\r
-import org.simantics.layer0.Layer0;\r
-import org.simantics.ltk.ISource;\r
-import org.simantics.ltk.Problem;\r
-import org.simantics.modeling.ui.Activator;\r
-import org.simantics.utils.datastructures.Pair;\r
-\r
-/**\r
- * @author Antti Villberg\r
- */\r
-public class CompilePGraphs implements ActionFactory {\r
-\r
- @Override\r
- public Runnable create(Object target) {\r
- \r
- if (!(target instanceof Resource))\r
- return null;\r
- \r
- final Resource r = (Resource)target;\r
-\r
- return new Runnable() {\r
- \r
- private void uncheckedClose(Closeable closeable) {\r
- try {\r
- if (closeable != null)\r
- closeable.close();\r
- } catch (IOException e) {\r
- //ignore\r
- }\r
- }\r
- \r
- private File copyResource(URL url, File targetFile) throws IOException, FileNotFoundException {\r
- FileOutputStream os = null;\r
- InputStream is = null;\r
- try {\r
- if (targetFile.exists())\r
- targetFile.delete();\r
-\r
- is = url.openStream();\r
- int read;\r
- byte [] buffer = new byte [16384];\r
- os = new FileOutputStream (targetFile);\r
- while ((read = is.read (buffer)) != -1) {\r
- os.write(buffer, 0, read);\r
- }\r
- os.close ();\r
- is.close ();\r
-\r
- return targetFile;\r
- } finally {\r
- uncheckedClose(os);\r
- uncheckedClose(is);\r
- }\r
- }\r
- \r
- private File extractLib(URL libURL, String libName) throws FileNotFoundException, IOException {\r
- String tmpDirStr = System.getProperty("java.io.tmpdir");\r
- if (tmpDirStr == null)\r
- throw new NullPointerException("java.io.tmpdir property is null");\r
- File tmpDir = new File(tmpDirStr);\r
- File libFile = new File(tmpDir, libName);\r
- return copyResource(libURL, libFile);\r
- }\r
- \r
- private File url2file(URL url, String fileName) {\r
- if ("file".equals(url.getProtocol())) {\r
- try {\r
- File path = new File(URLDecoder.decode(url.getPath(), "UTF-8"));\r
- return path;\r
- } catch (UnsupportedEncodingException e) {\r
- Logger.defaultLogError(e);\r
- }\r
- } else if ("jar".equals(url.getProtocol())) {\r
- try {\r
- File libFile = extractLib(url, fileName);\r
- return libFile;\r
- } catch (FileNotFoundException e) {\r
- Logger.defaultLogError(e);\r
- } catch (IOException e) {\r
- Logger.defaultLogError(e);\r
- }\r
- } else {\r
- System.err.println("Unsupported URL protocol '" + url + "' for FastLZ native library file '" + fileName);\r
- } \r
- return null;\r
- }\r
- @Override\r
- public void run() {\r
- \r
- try {\r
- \r
- final Collection<ISource> sources = new ArrayList<ISource>();\r
- Collection<TransferableGraph1> dependencies = new ArrayList<TransferableGraph1>();\r
-\r
- for(Bundle b : Activator.getContext().getBundles()) {\r
- URL tg = b.getEntry("/graph.tg");\r
- if(tg == null) continue;\r
- File f = url2file(FileLocator.resolve(tg), b.getSymbolicName());\r
- dependencies.add(GraphCompiler.read(f));\r
- }\r
-\r
- final TransferableGraph1 thisOntology = Simantics.sync(new UniqueRead<TransferableGraph1>() {\r
-\r
- @Override\r
- public TransferableGraph1 perform(ReadGraph graph) throws DatabaseException {\r
- \r
- Layer0 L0 = Layer0.getInstance(graph);\r
- Resource parent = graph.getSingleObject(r, L0.PartOf);\r
- \r
- CopyHandler ch = new DefaultCopyHandler(r) {\r
- \r
- protected TransferableGraphConfiguration2 createConfiguration(ReadGraph graph, boolean cut) throws DatabaseException {\r
-\r
- Map<Resource, ExtentStatus> preStatus = new HashMap<Resource, ExtentStatus>();\r
- preStatus.put(r, ExtentStatus.EXTERNAL);\r
- if(!parent.equals(graph.getRootLibrary()))\r
- preStatus.put(parent, ExtentStatus.EXTERNAL);\r
- \r
- return new TransferableGraphConfiguration2(null, Collections.emptyList(), preStatus, true, true);\r
- \r
- }\r
-\r
- protected TransferableGraphSource computeSource(ReadGraph graph, TransferableGraphConfiguration2 conf) throws DatabaseException {\r
- return graph.syncRequest(new ModelTransferableGraphSourceRequest(conf) {\r
-\r
- protected ModelTransferableGraphSource getSource(ReadGraph graph, TransferableGraphConfiguration2 configuration, DomainProcessorState state, File otherStatementsFile, File valueFile) throws DatabaseException {\r
- return new ModelTransferableGraphSource(graph, configuration, state, otherStatementsFile, valueFile) {\r
-\r
- @Override\r
- protected Identity getRootIdentity(DomainProcessorState state, SerialisationSupport support, Resource rootLibrary) throws DatabaseException {\r
- return new Identity(state.ids.get(support.getTransientId(rootLibrary)), new Root("", ""));\r
- }\r
-\r
- };\r
- }\r
-\r
- });\r
- }\r
- \r
- };\r
- SimanticsClipboardImpl clipboard = new SimanticsClipboardImpl();\r
- ch.copyToClipboard(graph, clipboard);\r
- for (Set<Representation> object : clipboard.getContents()) {\r
- TransferableGraph1 tg = ClipboardUtils.accept(graph, object, SimanticsKeys.KEY_TRANSFERABLE_GRAPH);\r
- if(tg != null) return tg;\r
- }\r
- return null;\r
- }\r
- \r
- });\r
-\r
- dependencies.add(thisOntology);\r
- \r
- Simantics.sync(new ReadRequest() {\r
-\r
- @Override\r
- public void run(ReadGraph graph) throws DatabaseException {\r
- Layer0 L0 = Layer0.getInstance(graph);\r
- for(Resource file : graph.syncRequest(new ObjectsWithType(r, L0.ConsistsOf, L0.PGraph))) {\r
- \r
- final String src = graph.getRelatedValue(file, L0.PGraph_definition, Bindings.STRING);\r
-\r
- final ByteArrayInputStream baos = new ByteArrayInputStream(src.getBytes()); \r
- \r
- sources.add(new ISource() {\r
- \r
- @Override\r
- public int startPos() {\r
- return 0;\r
- }\r
- \r
- @Override\r
- public int startLine() {\r
- return 0;\r
- }\r
- \r
- @Override\r
- public InputStream open() throws IOException {\r
- return baos;\r
- }\r
- \r
- @Override\r
- public int length() throws IOException {\r
- return src.length();\r
- }\r
- \r
- @Override\r
- public String getName() {\r
- return "Source";\r
- }\r
- \r
- });\r
- \r
- }\r
- }\r
- \r
- });\r
- \r
- final StringBuilder errorStringBuilder = new StringBuilder();\r
- GraphCompilerPreferences prefs = new GraphCompilerPreferences();\r
- prefs.validate = true;\r
- prefs.validateRelationRestrictions = ValidationMode.ERROR;\r
- prefs.validateResourceHasType = ValidationMode.IGNORE;\r
- final CompilationResult result = GraphCompiler.compile("1.1", sources, dependencies, null, prefs);\r
- \r
- for(Problem problem : result.getErrors())\r
- errorStringBuilder.append(problem.getLocation() + ": " + problem.getDescription() + "\n");\r
- for(Problem problem : result.getWarnings())\r
- errorStringBuilder.append(problem.getLocation() + ": " + problem.getDescription() + "\n");\r
- \r
- if(!result.getErrors().isEmpty() || !result.getWarnings().isEmpty()) {\r
-\r
- class ErrorMessageDialog extends MessageDialog {\r
-\r
- public ErrorMessageDialog(Shell shell) {\r
- super(shell, \r
- "Unsatisfied dependencies", null, \r
- "The following dependencies were missing. Please import the dependencies and try again.", \r
- MessageDialog.ERROR, new String[] { "Continue" }, 0);\r
- }\r
-\r
- @Override\r
- protected Control createCustomArea(Composite composite) {\r
- \r
- GridLayoutFactory.fillDefaults().applyTo(composite);\r
- \r
- org.eclipse.swt.widgets.List list = new org.eclipse.swt.widgets.List(composite, SWT.BORDER | SWT.READ_ONLY);\r
- GridDataFactory.fillDefaults().grab(true, true).applyTo(list);\r
- for(Problem problem : result.getErrors())\r
- list.add(problem.getLocation() + ": " + problem.getDescription() + "\n");\r
- for(Problem problem : result.getWarnings())\r
- list.add(problem.getLocation() + ": " + problem.getDescription() + "\n");\r
-\r
- return composite;\r
- \r
- }\r
-\r
- }\r
-\r
- ErrorMessageDialog md = new ErrorMessageDialog(Display.getCurrent().getActiveShell());\r
- md.open();\r
-\r
- return;\r
- }\r
- \r
- \r
- final Pair<TransferableGraph1, long[]> existing = Simantics.sync(new UniqueRead<Pair<TransferableGraph1, long[]>>() {\r
-\r
- @Override\r
- public Pair<TransferableGraph1, long[]> perform(ReadGraph graph) throws DatabaseException {\r
- Layer0 L0 = Layer0.getInstance(graph);\r
- TransferableGraph1 tg = graph.getPossibleRelatedValue(r, L0.SharedOntology_tg, Bindings.getBindingUnchecked( TransferableGraph1.class ));\r
- if(tg == null) return null;\r
- long[] tgResources = graph.getPossibleRelatedValue(r, L0.SharedOntology_tgResources, Bindings.LONG_ARRAY);\r
- if(tgResources == null) return null;\r
- return Pair.make(tg, tgResources);\r
- }\r
- \r
- });\r
- \r
- if(existing != null) {\r
- \r
- try {\r
- \r
- Simantics.sync(new WriteRequest() {\r
- \r
- @Override\r
- public void perform(WriteGraph graph) throws DatabaseException {\r
-\r
- TransferableGraphDelta1 delta = new Diff(existing.first, result.getGraph()).diff();\r
- long[] resourceArray = TransferableGraphs.applyDelta(graph, existing.second, delta);\r
-\r
- Layer0 L0 = Layer0.getInstance(graph);\r
- graph.claimLiteral(r, L0.SharedOntology_tg, result.getGraph(), Bindings.getBindingUnchecked( TransferableGraph1.class ));\r
- graph.claimLiteral(r, L0.SharedOntology_tgResources, L0.ResourceIdArray, resourceArray, Bindings.LONG_ARRAY);\r
- \r
- Layer0Utils.addCommentMetadata(graph, "Compiled ontology " + graph.getURI(r));\r
-\r
- }\r
- \r
- });\r
-\r
- } catch (Throwable t) {\r
- throw new PlatformException(t);\r
- } finally {\r
- endTransaction();\r
- }\r
- \r
- } else {\r
- \r
- final DefaultPasteImportAdvisor advisor = new DefaultPasteImportAdvisor(r);\r
- \r
- DefaultPasteHandler.defaultExecute(result.getGraph(), r, advisor);\r
- \r
- Simantics.sync(new WriteRequest() {\r
- \r
- @Override\r
- public void perform(WriteGraph graph) throws DatabaseException {\r
- \r
- Layer0 L0 = Layer0.getInstance(graph);\r
- graph.claimLiteral(r, L0.SharedOntology_tg, result.getGraph(), Bindings.getBindingUnchecked( TransferableGraph1.class ));\r
- graph.claimLiteral(r, L0.SharedOntology_tgResources, L0.ResourceIdArray, advisor.getResourceIds(), Bindings.LONG_ARRAY);\r
-\r
- Layer0Utils.addCommentMetadata(graph, "Compiled ontology " + graph.getURI(r));\r
-\r
- }\r
- \r
- });\r
- \r
- }\r
- \r
- } catch (Exception e) {\r
- Logger.defaultLogError(e);\r
- }\r
- \r
- }\r
- \r
- };\r
- \r
- }\r
-\r
-}\r
+package org.simantics.modeling.ui.actions;
+
+import static org.simantics.db.common.utils.Transaction.endTransaction;
+
+import java.io.ByteArrayInputStream;
+import java.io.Closeable;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+import java.net.URL;
+import java.net.URLDecoder;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+import org.eclipse.core.runtime.FileLocator;
+import org.eclipse.jface.dialogs.MessageDialog;
+import org.eclipse.jface.layout.GridDataFactory;
+import org.eclipse.jface.layout.GridLayoutFactory;
+import org.eclipse.swt.SWT;
+import org.eclipse.swt.widgets.Composite;
+import org.eclipse.swt.widgets.Control;
+import org.eclipse.swt.widgets.Display;
+import org.eclipse.swt.widgets.Shell;
+import org.osgi.framework.Bundle;
+import org.simantics.PlatformException;
+import org.simantics.Simantics;
+import org.simantics.databoard.Bindings;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.WriteGraph;
+import org.simantics.db.common.request.IndexRoot;
+import org.simantics.db.common.request.ObjectsWithType;
+import org.simantics.db.common.request.ReadRequest;
+import org.simantics.db.common.request.UniqueRead;
+import org.simantics.db.common.request.WriteRequest;
+import org.simantics.db.common.utils.Logger;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.layer0.adapter.ActionFactory;
+import org.simantics.db.layer0.adapter.CopyHandler;
+import org.simantics.db.layer0.adapter.SubgraphExtent.ExtentStatus;
+import org.simantics.db.layer0.adapter.impl.DefaultCopyHandler;
+import org.simantics.db.layer0.adapter.impl.DefaultPasteHandler;
+import org.simantics.db.layer0.adapter.impl.DefaultPasteImportAdvisor;
+import org.simantics.db.layer0.util.ClipboardUtils;
+import org.simantics.db.layer0.util.DomainProcessorState;
+import org.simantics.db.layer0.util.Layer0Utils;
+import org.simantics.db.layer0.util.ModelTransferableGraphSource;
+import org.simantics.db.layer0.util.ModelTransferableGraphSourceRequest;
+import org.simantics.db.layer0.util.SimanticsClipboard.Representation;
+import org.simantics.db.layer0.util.SimanticsClipboardImpl;
+import org.simantics.db.layer0.util.SimanticsKeys;
+import org.simantics.db.layer0.util.TransferableGraphConfiguration2;
+import org.simantics.db.service.SerialisationSupport;
+import org.simantics.graph.compiler.CompilationResult;
+import org.simantics.graph.compiler.ExternalFileLoader;
+import org.simantics.graph.compiler.GraphCompiler;
+import org.simantics.graph.compiler.GraphCompilerPreferences;
+import org.simantics.graph.compiler.ValidationMode;
+import org.simantics.graph.db.TransferableGraphSource;
+import org.simantics.graph.db.TransferableGraphs;
+import org.simantics.graph.diff.Diff;
+import org.simantics.graph.diff.TransferableGraphDelta1;
+import org.simantics.graph.representation.Identity;
+import org.simantics.graph.representation.Root;
+import org.simantics.graph.representation.TransferableGraph1;
+import org.simantics.graphfile.ontology.GraphFileResource;
+import org.simantics.layer0.Layer0;
+import org.simantics.ltk.ISource;
+import org.simantics.ltk.Problem;
+import org.simantics.modeling.ui.Activator;
+import org.simantics.utils.datastructures.Pair;
+
+/**
+ * @author Antti Villberg
+ */
+public class CompilePGraphs implements ActionFactory {
+
+ @Override
+ public Runnable create(Object target) {
+
+ if (!(target instanceof Resource))
+ return null;
+
+ final Resource r = (Resource)target;
+
+ return new Runnable() {
+
+ private void uncheckedClose(Closeable closeable) {
+ try {
+ if (closeable != null)
+ closeable.close();
+ } catch (IOException e) {
+ //ignore
+ }
+ }
+
+ private File copyResource(URL url, File targetFile) throws IOException, FileNotFoundException {
+ FileOutputStream os = null;
+ InputStream is = null;
+ try {
+ if (targetFile.exists())
+ targetFile.delete();
+
+ is = url.openStream();
+ int read;
+ byte [] buffer = new byte [16384];
+ os = new FileOutputStream (targetFile);
+ while ((read = is.read (buffer)) != -1) {
+ os.write(buffer, 0, read);
+ }
+ os.close ();
+ is.close ();
+
+ return targetFile;
+ } finally {
+ uncheckedClose(os);
+ uncheckedClose(is);
+ }
+ }
+
+ private File extractLib(URL libURL, String libName) throws FileNotFoundException, IOException {
+ String tmpDirStr = System.getProperty("java.io.tmpdir");
+ if (tmpDirStr == null)
+ throw new NullPointerException("java.io.tmpdir property is null");
+ File tmpDir = new File(tmpDirStr);
+ File libFile = new File(tmpDir, libName);
+ return copyResource(libURL, libFile);
+ }
+
+ private File url2file(URL url, String fileName) {
+ if ("file".equals(url.getProtocol())) {
+ try {
+ File path = new File(URLDecoder.decode(url.getPath(), "UTF-8"));
+ return path;
+ } catch (UnsupportedEncodingException e) {
+ Logger.defaultLogError(e);
+ }
+ } else if ("jar".equals(url.getProtocol())) {
+ try {
+ File libFile = extractLib(url, fileName);
+ return libFile;
+ } catch (FileNotFoundException e) {
+ Logger.defaultLogError(e);
+ } catch (IOException e) {
+ Logger.defaultLogError(e);
+ }
+ } else {
+ System.err.println("Unsupported URL protocol '" + url + "' for FastLZ native library file '" + fileName);
+ }
+ return null;
+ }
+ @Override
+ public void run() {
+
+ try {
+
+ final Collection<ISource> sources = new ArrayList<ISource>();
+ Collection<TransferableGraph1> dependencies = new ArrayList<TransferableGraph1>();
+
+ for(Bundle b : Activator.getContext().getBundles()) {
+ URL tg = b.getEntry("/graph.tg");
+ if(tg == null) continue;
+ File f = url2file(FileLocator.resolve(tg), b.getSymbolicName());
+ dependencies.add(GraphCompiler.read(f));
+ }
+
+ final TransferableGraph1 thisOntology = Simantics.sync(new UniqueRead<TransferableGraph1>() {
+
+ @Override
+ public TransferableGraph1 perform(ReadGraph graph) throws DatabaseException {
+
+ Layer0 L0 = Layer0.getInstance(graph);
+ Resource parent = graph.getSingleObject(r, L0.PartOf);
+
+ CopyHandler ch = new DefaultCopyHandler(r) {
+
+ protected TransferableGraphConfiguration2 createConfiguration(ReadGraph graph, boolean cut) throws DatabaseException {
+
+ Map<Resource, ExtentStatus> preStatus = new HashMap<Resource, ExtentStatus>();
+ preStatus.put(r, ExtentStatus.EXTERNAL);
+ if(!parent.equals(graph.getRootLibrary()))
+ preStatus.put(parent, ExtentStatus.EXTERNAL);
+
+ return new TransferableGraphConfiguration2(null, Collections.emptyList(), preStatus, true, true);
+
+ }
+
+ protected TransferableGraphSource computeSource(ReadGraph graph, TransferableGraphConfiguration2 conf) throws DatabaseException {
+ return graph.syncRequest(new ModelTransferableGraphSourceRequest(conf) {
+
+ protected ModelTransferableGraphSource getSource(ReadGraph graph, TransferableGraphConfiguration2 configuration, DomainProcessorState state, File otherStatementsFile, File valueFile) throws DatabaseException {
+ return new ModelTransferableGraphSource(graph, configuration, state, otherStatementsFile, valueFile) {
+
+ @Override
+ protected Identity getRootIdentity(DomainProcessorState state, SerialisationSupport support, Resource rootLibrary) throws DatabaseException {
+ return new Identity(state.ids.get(support.getTransientId(rootLibrary)), new Root("", ""));
+ }
+
+ };
+ }
+
+ });
+ }
+
+ };
+ SimanticsClipboardImpl clipboard = new SimanticsClipboardImpl();
+ ch.copyToClipboard(graph, clipboard);
+ for (Set<Representation> object : clipboard.getContents()) {
+ TransferableGraph1 tg = ClipboardUtils.accept(graph, object, SimanticsKeys.KEY_TRANSFERABLE_GRAPH);
+ if(tg != null) return tg;
+ }
+ return null;
+ }
+
+ });
+
+ dependencies.add(thisOntology);
+
+ Simantics.sync(new ReadRequest() {
+
+ @Override
+ public void run(ReadGraph graph) throws DatabaseException {
+ Layer0 L0 = Layer0.getInstance(graph);
+ for(Resource file : graph.syncRequest(new ObjectsWithType(r, L0.ConsistsOf, L0.PGraph))) {
+
+ final String src = graph.getRelatedValue(file, L0.PGraph_definition, Bindings.STRING);
+
+ final ByteArrayInputStream baos = new ByteArrayInputStream(src.getBytes());
+
+ sources.add(new ISource() {
+
+ @Override
+ public int startPos() {
+ return 0;
+ }
+
+ @Override
+ public int startLine() {
+ return 0;
+ }
+
+ @Override
+ public InputStream open() throws IOException {
+ return baos;
+ }
+
+ @Override
+ public int length() throws IOException {
+ return src.length();
+ }
+
+ @Override
+ public String getName() {
+ return "Source";
+ }
+
+ });
+
+ }
+ }
+
+ });
+
+ final StringBuilder errorStringBuilder = new StringBuilder();
+ GraphCompilerPreferences prefs = new GraphCompilerPreferences();
+ prefs.validate = true;
+ prefs.validateRelationRestrictions = ValidationMode.ERROR;
+ prefs.validateResourceHasType = ValidationMode.IGNORE;
+
+ final CompilationResult result = Simantics.sync(new UniqueRead<CompilationResult>() {
+
+ @Override
+ public CompilationResult perform(ReadGraph graph) throws DatabaseException {
+
+ final Resource root = graph.syncRequest(new IndexRoot(r));
+ final String baseURI = graph.getURI(root);
+
+ ExternalFileLoader fileLoader = new ExternalFileLoader() {
+ @Override
+ public byte[] load(String fileName) throws IOException {
+ try {
+ GraphFileResource GF = GraphFileResource.getInstance(graph);
+ Resource file = graph.getResource(baseURI + "/" + fileName);
+ return graph.getRelatedValue(file, GF.HasFiledata, Bindings.BYTE_ARRAY);
+ } catch (DatabaseException e) {
+ throw new IOException(e);
+ }
+ }
+ };
+
+ return GraphCompiler.compile("1.1", sources, dependencies, fileLoader, prefs);
+
+ }
+
+ });
+
+ for(Problem problem : result.getErrors())
+ errorStringBuilder.append(problem.getLocation() + ": " + problem.getDescription() + "\n");
+ for(Problem problem : result.getWarnings())
+ errorStringBuilder.append(problem.getLocation() + ": " + problem.getDescription() + "\n");
+
+ if(!result.getErrors().isEmpty() || !result.getWarnings().isEmpty()) {
+
+ class ErrorMessageDialog extends MessageDialog {
+
+ public ErrorMessageDialog(Shell shell) {
+ super(shell,
+ "Unsatisfied dependencies", null,
+ "The following dependencies were missing. Please import the dependencies and try again.",
+ MessageDialog.ERROR, new String[] { "Continue" }, 0);
+ }
+
+ @Override
+ protected Control createCustomArea(Composite composite) {
+
+ GridLayoutFactory.fillDefaults().applyTo(composite);
+
+ org.eclipse.swt.widgets.List list = new org.eclipse.swt.widgets.List(composite, SWT.BORDER | SWT.READ_ONLY);
+ GridDataFactory.fillDefaults().grab(true, true).applyTo(list);
+ for(Problem problem : result.getErrors())
+ list.add(problem.getLocation() + ": " + problem.getDescription() + "\n");
+ for(Problem problem : result.getWarnings())
+ list.add(problem.getLocation() + ": " + problem.getDescription() + "\n");
+
+ return composite;
+
+ }
+
+ }
+
+ ErrorMessageDialog md = new ErrorMessageDialog(Display.getCurrent().getActiveShell());
+ md.open();
+
+ return;
+ }
+
+
+ final Pair<TransferableGraph1, long[]> existing = Simantics.sync(new UniqueRead<Pair<TransferableGraph1, long[]>>() {
+
+ @Override
+ public Pair<TransferableGraph1, long[]> perform(ReadGraph graph) throws DatabaseException {
+ Layer0 L0 = Layer0.getInstance(graph);
+ TransferableGraph1 tg = graph.getPossibleRelatedValue(r, L0.SharedOntology_tg, Bindings.getBindingUnchecked( TransferableGraph1.class ));
+ if(tg == null) return null;
+ long[] tgResources = graph.getPossibleRelatedValue(r, L0.SharedOntology_tgResources, Bindings.LONG_ARRAY);
+ if(tgResources == null) return null;
+ return Pair.make(tg, tgResources);
+ }
+
+ });
+
+ if(existing != null) {
+
+ try {
+
+ Simantics.sync(new WriteRequest() {
+
+ @Override
+ public void perform(WriteGraph graph) throws DatabaseException {
+
+ TransferableGraphDelta1 delta = new Diff(existing.first, result.getGraph()).diff();
+ long[] resourceArray = TransferableGraphs.applyDelta(graph, existing.second, delta);
+
+ Layer0 L0 = Layer0.getInstance(graph);
+ graph.claimLiteral(r, L0.SharedOntology_tg, result.getGraph(), Bindings.getBindingUnchecked( TransferableGraph1.class ));
+ graph.claimLiteral(r, L0.SharedOntology_tgResources, L0.ResourceIdArray, resourceArray, Bindings.LONG_ARRAY);
+
+ Layer0Utils.addCommentMetadata(graph, "Compiled ontology " + graph.getURI(r));
+
+ }
+
+ });
+
+ } catch (Throwable t) {
+ throw new PlatformException(t);
+ } finally {
+ endTransaction();
+ }
+
+ } else {
+
+ final DefaultPasteImportAdvisor advisor = new DefaultPasteImportAdvisor(r);
+
+ DefaultPasteHandler.defaultExecute(result.getGraph(), r, advisor);
+
+ Simantics.sync(new WriteRequest() {
+
+ @Override
+ public void perform(WriteGraph graph) throws DatabaseException {
+
+ Layer0 L0 = Layer0.getInstance(graph);
+ graph.claimLiteral(r, L0.SharedOntology_tg, result.getGraph(), Bindings.getBindingUnchecked( TransferableGraph1.class ));
+ graph.claimLiteral(r, L0.SharedOntology_tgResources, L0.ResourceIdArray, advisor.getResourceIds(), Bindings.LONG_ARRAY);
+
+ Layer0Utils.addCommentMetadata(graph, "Compiled ontology " + graph.getURI(r));
+
+ }
+
+ });
+
+ }
+
+ } catch (Exception e) {
+ Logger.defaultLogError(e);
+ }
+
+ }
+
+ };
+
+ }
+
+}
Code Review / simantics / platform.git / blobdiff