X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=lib%2FcpPlugins%2FInterface%2FWorkspace.cxx;h=d1d2c0daa7b412935ce6c4909b1ccdfc4b879c2d;hb=f6e163be0bf2ffeb19239bb31c1df936017cdc8e;hp=9e8d4e1e7ab3d35ee94b332a7ff4fc0ee8a2816f;hpb=f654620df52b811be7bd263a1775c93d29c69a65;p=cpPlugins.git

diff --git a/lib/cpPlugins/Interface/Workspace.cxx b/lib/cpPlugins/Interface/Workspace.cxx
index 9e8d4e1..d1d2c0d 100644
--- a/lib/cpPlugins/Interface/Workspace.cxx
+++ b/lib/cpPlugins/Interface/Workspace.cxx
@@ -1,262 +1,468 @@
 #include <cpPlugins/Interface/Workspace.h>
+#include <cpPlugins/BaseObjects/Widget.h>
 
 // -------------------------------------------------------------------------
-cpPlugins::Interface::Workspace::
-Workspace( )
-  : m_LastLoadedPlugin( "" )
+void cpPlugins::Interface::Workspace::
+Clear( )
+{
+  this->m_Filters.clear( );
+  this->m_ExposedInputs.clear( );
+  this->m_ExposedOutputs.clear( );
+}
+
+// -------------------------------------------------------------------------
+std::vector< std::string > cpPlugins::Interface::Workspace::
+GetFiltersNames( ) const
 {
+  std::vector< std::string > n;
+  for( auto i = this->m_Filters.begin( ); i != this->m_Filters.end( ); ++i )
+    n.push_back( i->first );
+  return( n );
 }
 
 // -------------------------------------------------------------------------
 cpPlugins::Interface::Workspace::
-~Workspace( )
+TProcess* cpPlugins::Interface::Workspace::
+GetFilter( const std::string& name )
+{
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
+    return( i->second.GetPointer( ) );
+  else
+    return( NULL );
+}
+
+// -------------------------------------------------------------------------
+const cpPlugins::Interface::Workspace::
+TProcess* cpPlugins::Interface::Workspace::
+GetFilter( const std::string& name ) const
 {
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
+    return( i->second.GetPointer( ) );
+  else
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-LoadPluginsPath( const std::string& path, bool r )
+HasFilter( const std::string& name ) const
+{
+  return( this->m_Filters.find( name ) != this->m_Filters.end( ) );
+}
+
+// -------------------------------------------------------------------------
+cpPlugins::Interface::Workspace::
+TProcess* cpPlugins::Interface::Workspace::
+CreateFilter(
+  const std::string& category,
+  const std::string& filter,
+  const std::string& name
+  )
 {
-  // Load all plugins from given folder
-  std::list< std::string > files =
-    this->m_Interface.LoadFromFolder( path, r );
+  typedef cpPlugins::BaseObjects::Widget _TWidget;
 
-  // Update a simple track
-  bool ret = false;
-  if( files.size( ) > 0 )
+  TInterface::Pointer interface = TInterface::New( );
+  TProcess::Pointer o = this->GetFilter( name );
+  if( o.IsNull( ) )
   {
-    for( auto fIt = files.begin( ); fIt != files.end( ); ++fIt )
+    o = interface->CreateProcessObject( category, filter );
+    if( o.IsNotNull( ) )
     {
-      this->m_LoadedPlugins.insert( *fIt );
-      this->m_LastLoadedPlugin = *fIt;
+      o->SetPrintExecution( this->m_PrintExecution );
+      o->SetName( name );
 
-    } // rof
-    this->_UpdateLoadedPluginsInformation( );
-    ret = true;
+      // Interactors
+      for(
+        auto i = this->m_Interactors.begin( );
+        i != this->m_Interactors.end( );
+        ++i
+        )
+        o->AddInteractor( *i );
+
+      // Finish association
+      this->m_Filters[ name ] = o;
+
+    } // fi
 
   } // fi
-  return( ret );
+  return( o.GetPointer( ) );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-LoadPlugins( const std::string& fname )
+RenameFilter( const std::string& old_name, const std::string& new_name )
 {
-  // Is it already loaded?
-  bool ret = true;
-  if( this->m_LoadedPlugins.find( fname ) == this->m_LoadedPlugins.end( ) )
+  auto o = this->m_Filters.find( old_name );
+  auto n = this->m_Filters.find( new_name );
+  if( o != this->m_Filters.end( ) && n == this->m_Filters.end( ) )
   {
-    // Was it succesfully loaded?
-    ret = this->m_Interface.Load( fname );
+    // Rename filter
+    o->second->SetName( new_name );
+    this->m_Filters[ new_name ] = o->second;
+    this->m_Filters.erase( o );
 
-    // Update a simple track
-    if( ret )
-    {
-      this->m_LoadedPlugins.insert( fname );
-      this->m_LastLoadedPlugin = fname;
-      this->_UpdateLoadedPluginsInformation( );
+    // Rename exposed ports
+    auto e = this->m_ExposedInputs.begin( );
+    for( ; e != this->m_ExposedInputs.end( ); ++e )
+      if( e->second.first == old_name )
+        e->second.first = new_name;
+    e = this->m_ExposedOutputs.begin( );
+    for( ; e != this->m_ExposedOutputs.end( ); ++e )
+      if( e->second.first == old_name )
+        e->second.first = new_name;
 
-    } // fi
+    return( true );
+  }
+  else
+    return( false );
+}
 
-  } // fi
-  return( ret );
+// -------------------------------------------------------------------------
+bool cpPlugins::Interface::Workspace::
+RemoveFilter( const std::string& name )
+{
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
+  {
+    i->second->Disconnect( );
+    this->m_Filters.erase( i );
+    return( true );
+  }
+  else
+    return( false );
 }
 
 // -------------------------------------------------------------------------
-const cpPlugins::Interface::Workspace::
-TStringContainer& cpPlugins::Interface::Workspace::
-GetLoadedPlugins( ) const
+void cpPlugins::Interface::Workspace::
+SetPrintExecution( bool b )
 {
-  return( this->m_LoadedPlugins );
+  this->m_PrintExecution = b;
+  for( auto i = this->m_Filters.begin( ); i != this->m_Filters.end( ); ++i )
+    i->second->SetPrintExecution( b );
 }
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-GetLoadedPluginCategories( TStringContainer& categories ) const
+PrintExecutionOn( )
 {
-  categories.clear( );
-  auto fIt = this->m_LoadedFilters.begin( );
-  for( ; fIt != this->m_LoadedFilters.end( ); ++fIt )
-    categories.insert( fIt->first );
+  this->SetPrintExecution( true );
 }
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-GetLoadedPluginFilters( TStringContainer& filters ) const
+PrintExecutionOff( )
 {
-  filters.clear( );
-  auto pIt = this->m_LoadedFilters.begin( );
-  for( ; pIt != this->m_LoadedFilters.end( ); ++pIt )
-    for( auto fIt = pIt->second.begin( ); fIt != pIt->second.end( ); ++fIt )
-      filters.insert( *fIt );
+  this->SetPrintExecution( true );
+}
+
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+AddInteractor( vtkRenderWindowInteractor* iren )
+{
+  if( iren != NULL )
+    this->m_Interactors.insert( iren );
+}
+
+// -------------------------------------------------------------------------
+const cpPlugins::Interface::Workspace::
+TExposedPorts& cpPlugins::Interface::Workspace::
+GetExposedInputs( ) const
+{
+  return( this->m_ExposedInputs );
 }
 
 // -------------------------------------------------------------------------
 const cpPlugins::Interface::Workspace::
-TStringContainer& cpPlugins::Interface::Workspace::
-GetLoadedPluginFilters( const std::string& category ) const
+TExposedPorts& cpPlugins::Interface::Workspace::
+GetExposedOutputs( ) const
+{
+  return( this->m_ExposedOutputs );
+}
+
+// -------------------------------------------------------------------------
+cpPlugins::BaseObjects::DataObject* cpPlugins::Interface::Workspace::
+GetExposedOutput( const std::string& name )
 {
-  static const TStringContainer EMPTY;
-  auto pIt = this->m_LoadedFilters.find( category );
-  if( pIt != this->m_LoadedFilters.end( ) )
-    return( pIt->second );
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i != this->m_ExposedOutputs.end( ) )
+  {
+    auto f = this->GetFilter( i->second.first );
+    if( f != NULL )
+      return( f->GetOutput( i->second.second ) );
+    else
+      return( NULL );
+  }
   else
-    return( EMPTY );
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
-bool cpPlugins::Interface::Workspace::
-CreateFilter( const std::string& filter, const std::string& name )
+const cpPlugins::BaseObjects::DataObject* cpPlugins::Interface::Workspace::
+GetExposedOutput( const std::string& name ) const
 {
-  // Get or create new filter from name
-  auto vIt = this->m_Vertices.find( name );
-  if( vIt == this->m_Vertices.end( ) )
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i != this->m_ExposedOutputs.end( ) )
   {
-    TFilter::Pointer o = this->m_Interface.CreateObject( filter );
-    if( o.IsNotNull( ) )
-    {
-      o->SetName( name );
-      this->m_Vertices[ name ] = o;
-      return( true );
-    }
+    auto f = this->GetFilter( i->second.first );
+    if( f != NULL )
+      return( f->GetOutput( i->second.second ) );
     else
-      return( false );
+      return( NULL );
   }
   else
-    return( true );
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-Connect(
-  const std::string& orig_filter, const std::string& dest_filter,
-  const std::string& output_name, const std::string& input_name
+ExposeInput(
+  const std::string& name,
+  const std::string& filter, const std::string& filter_input
   )
 {
-  // Get filters
-  auto oIt = this->m_Vertices.find( orig_filter );
-  if( oIt == this->m_Vertices.end( ) )
-    return( false );
-  auto dIt = this->m_Vertices.find( dest_filter );
-  if( dIt == this->m_Vertices.end( ) )
+  auto i = this->m_ExposedInputs.find( name );
+  if( i == this->m_ExposedInputs.end( ) )
+  {
+    this->m_ExposedInputs[ name ] =
+      std::pair< std::string, std::string >( filter, filter_input );
+    return( true );
+  }
+  else
     return( false );
-  TFilter* orig = dynamic_cast< TFilter* >( oIt->second.GetPointer( ) );
-  TFilter* dest = dynamic_cast< TFilter* >( dIt->second.GetPointer( ) );
-  if( orig == NULL || dest == NULL )
+}
+
+// -------------------------------------------------------------------------
+bool cpPlugins::Interface::Workspace::
+ExposeOutput(
+  const std::string& name,
+  const std::string& filter, const std::string& filter_output
+  )
+{
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i == this->m_ExposedOutputs.end( ) )
+  {
+    this->m_ExposedOutputs[ name ] =
+      std::pair< std::string, std::string >( filter, filter_output );
+    return( true );
+  }
+  else
     return( false );
+}
 
-  // Real connection
-  dest->SetInput( input_name, orig->GetOutput< TData >( output_name ) );
-  this->m_AdjMatrix[ orig_filter ][ dest_filter ].push_back(
-    TConnection( output_name, input_name )
-    );
-  return( false );
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+HideInput( const std::string& name )
+{
+  auto i = this->m_ExposedInputs.find( name );
+  if( i != this->m_ExposedInputs.end( ) )
+    this->m_ExposedInputs.erase( i );
 }
 
 // -------------------------------------------------------------------------
-cpPlugins::Interface::Workspace::
-TParameters* cpPlugins::Interface::Workspace::
-GetParameters( const std::string& name )
+void cpPlugins::Interface::Workspace::
+HideOutput( const std::string& name )
+{
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i != this->m_ExposedOutputs.end( ) )
+    this->m_ExposedOutputs.erase( i );
+}
+
+// -------------------------------------------------------------------------
+bool cpPlugins::Interface::Workspace::
+RenameExposedInput(
+  const std::string& old_name, const std::string& new_name
+  )
 {
-  auto vIt = this->m_Vertices.find( name );
-  if( vIt != this->m_Vertices.end( ) )
+  auto o = this->m_ExposedInputs.find( old_name );
+  auto n = this->m_ExposedInputs.find( new_name );
+  if( o != this->m_ExposedInputs.end( ) && n == this->m_ExposedInputs.end( ) )
   {
-    TFilter* f = dynamic_cast< TFilter* >( vIt->second.GetPointer( ) );
-    if( f != NULL )
-      return( f->GetParameters( ) );
-    else
-      return( NULL );
+    this->m_ExposedInputs[ new_name ] = o->second;
+    this->m_ExposedInputs.erase( o );
+    return( true );
   }
   else
-    return( NULL );
+    return( false );
 }
 
 // -------------------------------------------------------------------------
-const cpPlugins::Interface::Workspace::
-TParameters* cpPlugins::Interface::Workspace::
-GetParameters( const std::string& name ) const
+bool cpPlugins::Interface::Workspace::
+RenameExposedOutput(
+  const std::string& old_name, const std::string& new_name
+  )
 {
-  auto vIt = this->m_Vertices.find( name );
-  if( vIt != this->m_Vertices.end( ) )
+  auto o = this->m_ExposedOutputs.find( old_name );
+  auto n = this->m_ExposedOutputs.find( new_name );
+  if(
+    o != this->m_ExposedOutputs.end( ) && n == this->m_ExposedOutputs.end( )
+    )
   {
-    const TFilter* f =
-      dynamic_cast< const TFilter* >( vIt->second.GetPointer( ) );
-    if( f != NULL )
-      return( f->GetParameters( ) );
-    else
-      return( NULL );
+    this->m_ExposedOutputs[ new_name ] = o->second;
+    this->m_ExposedOutputs.erase( o );
+    return( true );
   }
   else
-    return( NULL );
+    return( false );
 }
 
 // -------------------------------------------------------------------------
-bool cpPlugins::Interface::Workspace::
-Reduce( const std::string& name )
+std::vector< std::pair< std::string, std::string > >
+cpPlugins::Interface::Workspace::
+GetConnections(
+  const std::string& origin, const std::string& destination
+  ) const
 {
+  std::vector< std::pair< std::string, std::string > > conns;
+  auto orig = this->GetFilter( origin );
+  auto dest = this->GetFilter( destination );
+  if( orig != NULL && dest != NULL )
+  {
+    auto outs = orig->GetOutputsNames( );
+    auto ins = dest->GetInputsNames( );
+    for( auto o = outs.begin( ); o != outs.end( ); ++o )
+    {
+      for( auto i = ins.begin( ); i != ins.end( ); ++i )
+      {
+        auto od = orig->GetOutput( *o );
+        auto id = dest->GetInput( *i );
+        if( od != NULL && od == id )
+          conns.push_back(
+            std::pair< std::string, std::string >( *o, *i )
+            );
+
+      } // rof
+
+    } // rof
+
+  } // fi
+  return( conns );
 }
 
 // -------------------------------------------------------------------------
-std::string cpPlugins::Interface::Workspace::
-Execute( )
+void cpPlugins::Interface::Workspace::
+Connect(
+  const std::string& orig_filter, const std::string& dest_filter,
+  const std::string& output_name, const std::string& input_name
+  )
 {
-  // Find sinks
-  std::set< std::string > sinks;
-  auto vIt = this->m_Vertices.begin( );
-  for( ; vIt != this->m_Vertices.end( ); ++vIt )
-    sinks.insert( vIt->first );
-  auto mIt = this->m_AdjMatrix.begin( );
-  for( ; mIt != this->m_AdjMatrix.end( ); ++mIt )
-    sinks.erase( mIt->first );
-
-  // Update sinks
-  std::string err = "";
-  for( auto sIt = sinks.begin( ); sIt != sinks.end( ); ++sIt )
+  auto o = this->GetFilter( orig_filter );
+  auto d = this->GetFilter( dest_filter );
+  if( o != NULL && d != NULL )
   {
-    std::string lerr = this->Execute( *sIt );
-    if( lerr != "" )
-      err += lerr + std::string( "\n" );
+    try
+    {
+      d->AddInput( input_name, o->GetOutput( output_name ) );
+    }
+    catch( std::exception& err )
+    {
+      throw std::logic_error(
+        std::string( "Error connecting \"" ) +
+        output_name + std::string( "@" ) + orig_filter +
+        std::string( "\" with \"" ) +
+        input_name + std::string( "@" ) + dest_filter +
+        std::string( "\": " ) +
+        err.what( )
+        );
+
+    } // yrt
 
-  } // rof
-  return( err );
+  } // fi
 }
 
 // -------------------------------------------------------------------------
-std::string cpPlugins::Interface::Workspace::
-Execute( const std::string& name )
+void cpPlugins::Interface::Workspace::
+Connect(
+  cpPlugins::BaseObjects::DataObject* output,
+  const std::string& dest_filter, const std::string& input_name
+  )
 {
-  // Get filter
-  auto vIt = this->m_Vertices.find( name );
-  if( vIt == this->m_Vertices.end( ) )
-    return(
-      std::string( "cpPlugins::Interface::Workspace: No filter \"" ) +
-      name + std::string( "\"" )
-      );
-  TFilter* f = dynamic_cast< TFilter* >( vIt->second.GetPointer( ) );
-  if( f == NULL )
-    return(
-      std::string( "cpPlugins::Interface::Workspace: Vertex \"" ) +
-      name + std::string( "\" is not a filter." )
-      );
+  auto d = this->GetFilter( dest_filter );
+  if( d != NULL )
+    d->AddInput( input_name, output );
+}
 
-  // Execute and return
-  return( f->Update( ) );
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Connect(
+  cpPlugins::BaseObjects::DataObject* output,
+  const std::string& exposed_input_name
+  )
+{
+  auto i = this->m_ExposedInputs.find( exposed_input_name );
+  if( i != this->m_ExposedInputs.end( ) )
+    this->Connect( output, i->second.first, i->second.second );
 }
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-_UpdateLoadedPluginsInformation( )
+Disconnect(
+  const std::string& orig_filter, const std::string& dest_filter,
+  const std::string& output_name, const std::string& input_name
+  )
 {
-  this->m_LoadedFilters.clear( );
-  const TInterface::TClasses& cls = this->m_Interface.GetClasses( );
-  for( auto i = cls.begin( ); i != cls.end( ); ++i )
+  auto orig = this->GetFilter( orig_filter );
+  auto dest = this->GetFilter( dest_filter );
+  if( orig != NULL && dest != NULL )
   {
-    TFilter::Pointer o = this->m_Interface.CreateObject( i->first );
-    std::string name = o->GetClassName( );
-    std::string category = o->GetClassCategory( );
-    this->m_LoadedFilters[ category ].insert( name );
+    auto out = orig->GetOutput( output_name );
+    auto in = dest->GetInput( input_name );
+    if( out != NULL && out == in )
+      dest->SetInput(
+        input_name, ( cpPlugins::BaseObjects::DataObject* )( NULL )
+        );
+
+  } // fi
+}
+
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Disconnect(
+  const std::string& dest_filter, const std::string& input_name
+  )
+{
+  throw std::logic_error( "Disconnect 1" );
+}
 
-  } // rof
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Disconnect( const std::string& dest_filter )
+{
+  throw std::logic_error( "Disconnect 2" );
+}
+
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Execute( )
+{
+  for( auto f = this->m_Filters.begin( ); f != this->m_Filters.end( ); ++f )
+    f->second->Update( );
+}
+
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Execute( const std::string& name )
+{
+  auto filter = this->GetFilter( name );
+  if( filter != NULL )
+    filter->Update( );
+}
+
+// -------------------------------------------------------------------------
+cpPlugins::Interface::Workspace::
+Workspace( )
+  : Superclass( ),
+    m_PrintExecution( false )
+{
+}
+
+// -------------------------------------------------------------------------
+cpPlugins::Interface::Workspace::
+~Workspace( )
+{
+  this->m_ExposedOutputs.clear( );
+  this->m_ExposedInputs.clear( );
+  this->m_Filters.clear( );
 }
 
 // eof - $RCSfile$