bundles/org.simantics.simulation/src/org/simantics/simulation/export/DiscoverExperimentResults.java

   1 package org.simantics.simulation.export;
   2
   3 import java.util.ArrayList;
   4 import java.util.Collection;
   5
   6 import org.simantics.db.ReadGraph;
   7 import org.simantics.db.Resource;
   8 import org.simantics.db.exception.DatabaseException;
   9 import org.simantics.db.layer0.adapter.Instances;
  10 import org.simantics.db.request.Read;
  11 import org.simantics.export.core.ExportContext;
  12 import org.simantics.export.core.error.ExportException;
  13 import org.simantics.export.core.intf.DiscoverAction;
  14 import org.simantics.simulation.ontology.SimulationResource;
  15
  16 /**
  17  * Discovers experiment results
  18  *
  19  * @author toni.kalajainen@semantum.fi
  20  */
  21 public class DiscoverExperimentResults implements DiscoverAction {
  22
  23         public Read<Collection<String>> discoverRequest(
  24                         final Collection<String> startLocations) throws ExportException {
  25                 return new Read<Collection<String>>() {
  26                         public Collection<String> perform(ReadGraph graph) throws DatabaseException {
  27                                 SimulationResource SIM = SimulationResource.getInstance(graph);
  28
  29                                 // Ask Indexer
  30                                 Instances instances = graph.adapt(SIM.Experiment, Instances.class);
  31                                 ArrayList<String> result = new ArrayList<String>();
  32                                 for ( String startingLocation : startLocations ) {
  33                                         Resource sl = graph.getResource( startingLocation );
  34                                         for ( Resource diagram : instances.find(graph, sl) ) {
  35                                                 result.add( graph.getURI(diagram) );
  36                                         }
  37                                 }
  38                                 return result;
  39
  40
  41                                 // Query
  42                                 /*
  43                                 Layer0 L0 = Layer0.getInstance(graph);
  44                                 TraverseQueryBuilder builder = new TraverseQueryBuilder();
  45                                 builder.setStartResources( graph.syncRequest( ExportQueries.toResources(startLocations) ) );
  46                                 builder.followRelation( L0.ConsistsOf );
  47                                 builder.followInstanceOf( SIM.Experiment );
  48                                 builder.followAndReturnInstanceOf( SIM.Run );
  49                                 TraverseResult traverseResult = graph.syncRequest( builder.build() );
  50                                 return graph.syncRequest( ExportQueries.toUris( traverseResult.result ) );
  51                                 */
  52                         }
  53
  54                 };
  55         }
  56
  57         @Override
  58         public Collection<String> discoverContent(ExportContext ctx, Collection<String> startLocations) throws ExportException {
  59                 try {
  60                         return ctx.session.syncRequest( discoverRequest(startLocations) );
  61                 } catch (DatabaseException e) {
  62                         if ( e.getCause() instanceof ExportException ) throw (ExportException) e.getCause();
  63                         throw new ExportException( e );
  64                 }
  65         }
  66
  67 }