1 /*******************************************************************************
2 * Copyright (c) 2007, 2010 Association for Decentralized Information Management
4 * All rights reserved. This program and the accompanying materials
5 * are made available under the terms of the Eclipse Public License v1.0
6 * which accompanies this distribution, and is available at
7 * http://www.eclipse.org/legal/epl-v10.html
10 * VTT Technical Research Centre of Finland - initial API and implementation
11 *******************************************************************************/
12 package org.simantics.modeling.ui.modelBrowser2.contributions;
14 import java.util.Collection;
16 import java.util.function.Consumer;
18 import org.simantics.Simantics;
19 import org.simantics.browsing.ui.BuiltinKeys;
20 import org.simantics.browsing.ui.NodeContext;
21 import org.simantics.browsing.ui.Tester;
22 import org.simantics.browsing.ui.graph.contributor.viewpoint.ContextInputCallbackViewpointContributor;
23 import org.simantics.browsing.ui.graph.tester.GraphTesters;
24 import org.simantics.databoard.Bindings;
25 import org.simantics.db.ReadGraph;
26 import org.simantics.db.RequestProcessor;
27 import org.simantics.db.Resource;
28 import org.simantics.db.Session;
29 import org.simantics.db.common.primitiverequest.Adapter;
30 import org.simantics.db.common.request.Queries;
31 import org.simantics.db.exception.DatabaseException;
32 import org.simantics.db.layer0.adapter.GenericRelationIndex;
33 import org.simantics.db.request.Read;
34 import org.simantics.layer0.Layer0;
35 import org.simantics.modeling.ui.modelBrowser2.model.RelationViewNode;
36 import org.simantics.operation.Layer0X;
38 public class RelationView extends ContextInputCallbackViewpointContributor {
40 public RelationView() {
41 super(RelationViewNode.class);
45 public Tester getNodeContextTester() {
46 return GraphTesters.type(Layer0X.URIs.RelationView);
50 public String getViewpointId() {
55 protected void finalize() throws Throwable {
56 //System.out.println("**** FINALIZING RelationView " + this);
61 public void getContribution(ReadGraph graph, final NodeContext context, final Consumer<Collection<?>> callback) throws DatabaseException {
63 final Session session = graph.getSession();
65 RelationViewNode model = (RelationViewNode)context.getConstant(BuiltinKeys.INPUT);
66 final Resource view = model.resource;
68 final String filter = context.getConstant(BuiltinKeys.FILTER);
69 Layer0 l0 = Layer0.getInstance(graph);
70 Layer0X L0X = Layer0X.getInstance(graph);
72 final Resource input = graph.getPossibleObject(view, l0.PartOf);
73 final Resource relation = graph.getPossibleObject(view, L0X.AppliesRelation);
74 final String bindingPattern = graph.getPossibleRelatedValue(view, L0X.HasBindingPattern, Bindings.STRING);
76 final GenericRelationIndex index = graph.syncRequest(new org.simantics.db.common.primitiverequest.Adapter<GenericRelationIndex>(relation, GenericRelationIndex.class));
78 // TODO: use DB ExternalRead instead of this listener hack which proliferates the index with listeners.
80 index.addListener(session, input, new Runnable() {
83 Simantics.async(new Runnable() {
87 callback.accept(compute(session, filter, bindingPattern, view, relation, input));
88 } catch (DatabaseException e) {
96 callback.accept(compute(graph, filter, bindingPattern, view, relation, input));
100 Collection<?> compute(RequestProcessor processor, String filter, String bindingPattern, final Resource view, Resource relation, Resource input) throws DatabaseException {
104 GenericRelationIndex index = processor.syncRequest(new Adapter<GenericRelationIndex>(relation, GenericRelationIndex.class));
105 final Collection<Map<String, Object>> results = index.query(processor, filter, bindingPattern, new Object[] { input }, 1000);
107 return processor.syncRequest(new Read<Collection<?>>() {
109 public Collection<?> perform(ReadGraph graph) throws DatabaseException {
110 RelationViewContributor contrib = graph.syncRequest(Queries.adapt(view, RelationViewContributor.class));
111 return contrib.getContribution(graph, results);