bundles/org.simantics.modeling.ui/src/org/simantics/modeling/ui/modelBrowser2/contributions/RelationView.java

   1 /*******************************************************************************
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management
   3  * in Industry THTH ry.
   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
   8  *
   9  * Contributors:
  10  *     VTT Technical Research Centre of Finland - initial API and implementation
  11  *******************************************************************************/
  12 package org.simantics.modeling.ui.modelBrowser2.contributions;
  13
  14 import java.util.Collection;
  15 import java.util.Map;
  16 import java.util.function.Consumer;
  17
  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;
  37
  38 public class RelationView extends ContextInputCallbackViewpointContributor {
  39
  40     public RelationView() {
  41         super(RelationViewNode.class);
  42     }
  43
  44     @Override
  45     public Tester getNodeContextTester() {
  46         return GraphTesters.type(Layer0X.URIs.RelationView);
  47     }
  48
  49     @Override
  50     public String getViewpointId() {
  51         return "Standard";
  52     }
  53
  54     @Override
  55     protected void finalize() throws Throwable {
  56         //System.out.println("**** FINALIZING RelationView " + this);
  57         super.finalize();
  58     }
  59
  60     @Override
  61     public void getContribution(ReadGraph graph, final NodeContext context, final Consumer<Collection<?>> callback) throws DatabaseException {
  62
  63         final Session session = graph.getSession();
  64
  65         RelationViewNode model = (RelationViewNode)context.getConstant(BuiltinKeys.INPUT);
  66         final Resource view = model.resource;
  67
  68         final String filter = context.getConstant(BuiltinKeys.FILTER);
  69         Layer0 l0 = Layer0.getInstance(graph);
  70         Layer0X L0X = Layer0X.getInstance(graph);
  71
  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);
  75
  76         final GenericRelationIndex index = graph.syncRequest(new org.simantics.db.common.primitiverequest.Adapter<GenericRelationIndex>(relation, GenericRelationIndex.class));
  77
  78         // TODO: use DB ExternalRead instead of this listener hack which proliferates the index with listeners.
  79
  80         index.addListener(session, input, new Runnable() {
  81             @Override
  82             public void run() {
  83                 Simantics.async(new Runnable() {
  84                     @Override
  85                     public void run() {
  86                         try {
  87                             callback.accept(compute(session, filter, bindingPattern, view, relation, input));
  88                         } catch (DatabaseException e) {
  89                             e.printStackTrace();
  90                         }
  91                     }
  92                 });
  93             }
  94         });
  95
  96         callback.accept(compute(graph, filter, bindingPattern, view, relation, input));
  97
  98     }
  99
 100     Collection<?> compute(RequestProcessor processor, String filter, String bindingPattern, final Resource view, Resource relation, Resource input) throws DatabaseException {
 101         if (filter == null)
 102             filter = "";
 103
 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);
 106
 107         return processor.syncRequest(new Read<Collection<?>>() {
 108             @Override
 109             public Collection<?> perform(ReadGraph graph) throws DatabaseException {
 110                 RelationViewContributor contrib = graph.syncRequest(Queries.adapt(view, RelationViewContributor.class));
 111                 return contrib.getContribution(graph, results);
 112             }
 113         });
 114     }
 115
 116 }