1 package org.simantics.db.layer0.util;
3 import org.simantics.db.ReadGraph;
4 import org.simantics.db.Resource;
5 import org.simantics.db.common.request.ParametrizedPrimitiveRead;
6 import org.simantics.db.common.request.UnaryRead;
7 import org.simantics.db.exception.DatabaseException;
8 import org.simantics.db.layer0.internal.SimanticsInternal;
9 import org.simantics.db.procedure.Listener;
10 import org.simantics.db.request.Read;
11 import org.simantics.scl.compiler.environment.specification.EnvironmentSpecification;
12 import org.simantics.scl.compiler.module.repository.ImportFailureException;
13 import org.simantics.scl.compiler.module.repository.UpdateListener;
14 import org.simantics.scl.compiler.runtime.RuntimeEnvironment;
15 import org.simantics.scl.osgi.SCLOsgi;
16 import org.simantics.scl.runtime.SCLContext;
19 * Finds the runtime environment of a model or other index root.
21 * @author Hannu Niemistö
22 * @author Antti Villberg
24 public class RuntimeEnvironmentRequest extends UnaryRead<Resource, RuntimeEnvironment> {
26 public RuntimeEnvironmentRequest(Resource parameter) {
30 protected void fillEnvironmentSpecification(EnvironmentSpecification environmentSpecification) {
33 static class UpdateListenerImpl extends UpdateListener {
35 final EnvironmentSpecification environmentSpecification;
36 final Listener<RuntimeEnvironment> callback;
38 UpdateListenerImpl(EnvironmentSpecification environmentSpecification, Listener<RuntimeEnvironment> callback) {
39 this.environmentSpecification = environmentSpecification;
40 this.callback = callback;
44 public void notifyAboutUpdate() {
45 if(callback.isDisposed()) {
49 getRuntimeEnvironment(environmentSpecification, callback, this);
53 public static void getRuntimeEnvironment(EnvironmentSpecification environmentSpecification, Listener<RuntimeEnvironment> callback, UpdateListenerImpl listener) {
57 SCLContext context = SCLContext.getCurrent();
59 RuntimeEnvironment env;
60 Object graph = context.get("graph");
63 env = SimanticsInternal.getSession().syncRequest(new Read<RuntimeEnvironment>() {
65 public RuntimeEnvironment perform(ReadGraph graph) throws DatabaseException {
67 SCLContext sclContext = SCLContext.getCurrent();
68 Object oldGraph = sclContext.get("graph");
70 sclContext.put("graph", graph);
71 return SCLOsgi.MODULE_REPOSITORY.createRuntimeEnvironment(
72 environmentSpecification,
73 callback.getClass().getClassLoader(), listener);
74 } catch (ImportFailureException e) {
75 throw new DatabaseException(e);
76 } catch (Throwable t) {
77 throw new DatabaseException(t);
79 sclContext.put("graph", oldGraph);
83 } catch (DatabaseException e) {
84 callback.exception(e);
88 env = SCLOsgi.MODULE_REPOSITORY.createRuntimeEnvironment(
89 environmentSpecification,
90 callback.getClass().getClassLoader(), listener);
91 callback.execute(env);
92 } catch (ImportFailureException e) {
93 callback.exception(new DatabaseException(e));
99 public RuntimeEnvironment perform(ReadGraph graph)
100 throws DatabaseException {
101 final EnvironmentSpecification environmentSpecification = EnvironmentSpecification.of(
103 "StandardLibrary", "",
104 "Simantics/All", "");
105 fillEnvironmentSpecification(environmentSpecification);
107 Resource mainModule = Layer0Utils.getPossibleChild(graph, parameter, "SCLMain");
108 String mainModuleUri;
109 if(mainModule != null) {
110 mainModuleUri = graph.getURI(mainModule);
111 environmentSpecification.importModule(mainModuleUri, "");
114 mainModuleUri = graph.getURI(parameter) + "/#"; // Add something dummy to the model uri that cannot be in a real URI
116 return graph.syncRequest(new ParametrizedPrimitiveRead<String, RuntimeEnvironment>(mainModuleUri) {
118 UpdateListenerImpl sclListener;
121 public void register(ReadGraph graph, Listener<RuntimeEnvironment> procedure) {
123 SCLContext context = SCLContext.getCurrent();
124 Object oldGraph = context.put("graph", graph);
127 if(procedure.isDisposed()) {
128 getRuntimeEnvironment(environmentSpecification, procedure, null);
130 sclListener = new UpdateListenerImpl(environmentSpecification, procedure);
131 sclListener.notifyAboutUpdate();
135 context.put("graph", oldGraph);
141 public void unregistered() {
142 if(sclListener != null)
143 sclListener.stopListening();
150 public int hashCode() {
151 return 31*getClass().hashCode() + super.hashCode();