SpreadsheetSynchronizationEventHandler handler = new SpreadsheetSynchronizationEventHandler(graph, book);
-// System.err.println("sessionName : " + sessionName);
-// System.err.println("bookResource : " + graph.getURI(bookResource));
-// System.err.println("configuration : " + configuration.getURI(graph));
-// System.err.println("realm : " + realm);
-// System.err.println("book : " + book);
-
if (changeFlags == null) {
synchronizer.fullSynchronization(configuration, handler);
} else {
synchronizer.partialSynchronization(configuration, handler, changeFlags);
}
-// book.accept(new InvalidateAll());
-// realm.getNodeManager().refreshVariables();
-// mapping.currentRevision = synchronizer.getHeadRevisionId();
-// mapping.setTrustUids(true);
- // Clean up queries
-// QueryControl qc = g.getService(QueryControl.class);
-// qc.flush(g);
-// TimeLogger.log("Finished full synchronization");
realm.getNodeManager().fireNodeListeners();
return handler.getDidChanges();
}
public static Variant extRefVariable(ReadGraph graph, Variable var) throws DatabaseException {
- System.err.println("extRefVariable " + var.getURI(graph));
return new Variant(Bindings.VOID, new ExternalRefVariable(graph, var));
}
@Override
public void listen(Object context, ExternalRefListener listener) {
- System.err.println("listen " + listener);
Simantics.getSession().asyncRequest(new UnaryRead<String, Variant>(uri) {
@Override
public Variant perform(ReadGraph graph) throws DatabaseException {
Variable variable = Variables.getVariable(graph, parameter);
- System.err.println("ExternalRef value for " + variable.getURI(graph));
return variable.getVariantValue(graph);
}
@Override
public void execute(Variant result) {
- System.err.println("execute " + result);
listener.newValue(result);
}
}
public static Variant extRefActiveVariable(ReadGraph graph, Variable var) throws DatabaseException {
- System.err.println("extRefActiveVariable " + var.getURI(graph));
return new Variant(Bindings.VOID, new ExternalRefActiveVariable(graph, var));
}
@Override
public void listen(Object context, ExternalRefListener listener) {
- System.err.println("listen " + context + " " + listener);
Simantics.getSession().asyncRequest(new BinaryRead<String, String, Variant>((String)context, uri) {
@Override
public Variant perform(ReadGraph graph) throws DatabaseException {
Variable contextVariable = Variables.getVariable(graph, parameter);
- System.err.println("extref1 " + contextVariable.getURI(graph));
Variable configVariable = Variables.getVariable(graph, parameter2);
- System.err.println("extref2 " + configVariable.getURI(graph));
Variable activeVariable = Variables.switchPossibleContext(graph, configVariable, contextVariable.getRepresents(graph));
- System.err.println("ExternalRef value for " + activeVariable.getURI(graph));
return activeVariable.getVariantValue(graph);
}
}, new Listener<Variant>() {
@Override
public void execute(Variant result) {
- System.err.println("execute " + result);
listener.newValue(result);
}