X-Git-Url: https://git.creatis.insa-lyon.fr/pubgit/?a=blobdiff_plain;f=lib%2FcpPlugins%2FInterface%2FWorkspace.cxx;h=faef957a1aa042ff1285d46b2b099c14e57617de;hb=22c3c302e6fb4932c6598a8acbf043436c4c06c6;hp=67eaf0a677b3937809c3f5431fc9023a68aea909;hpb=e992c2468610352a34187d9180e2e8f3fd3a6e68;p=cpPlugins.git

diff --git a/lib/cpPlugins/Interface/Workspace.cxx b/lib/cpPlugins/Interface/Workspace.cxx
index 67eaf0a..faef957 100644
--- a/lib/cpPlugins/Interface/Workspace.cxx
+++ b/lib/cpPlugins/Interface/Workspace.cxx
@@ -1,140 +1,158 @@
 #include <cpPlugins/Interface/Workspace.h>
+#include <cpPlugins/BaseObjects/Widget.h>
 
 // -------------------------------------------------------------------------
-cpPlugins::Interface::Workspace::
-Workspace( )
-  : m_Plugins( NULL )
+void cpPlugins::Interface::Workspace::
+Clear( )
 {
-  this->m_Graph = TGraph::New( );
+  this->m_Filters.clear( );
+  this->m_ExposedInputs.clear( );
+  this->m_ExposedOutputs.clear( );
 }
 
 // -------------------------------------------------------------------------
-cpPlugins::Interface::Workspace::
-~Workspace( )
+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::
-TPlugins* cpPlugins::Interface::Workspace::
-GetPlugins( )
+TProcess* cpPlugins::Interface::Workspace::
+GetFilter( const std::string& name )
 {
-  return( this->m_Plugins );
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
+    return( i->second.GetPointer( ) );
+  else
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
 const cpPlugins::Interface::Workspace::
-TPlugins* cpPlugins::Interface::Workspace::
-GetPlugins( ) const
-{
-  return( this->m_Plugins );
-}
-
-// -------------------------------------------------------------------------
-void cpPlugins::Interface::Workspace::
-SetPlugins( TPlugins* i )
+TProcess* cpPlugins::Interface::Workspace::
+GetFilter( const std::string& name ) const
 {
-  if( this->m_Plugins != i )
-    this->m_Plugins = i;
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
+    return( i->second.GetPointer( ) );
+  else
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
 cpPlugins::Interface::Workspace::
-TGraph* cpPlugins::Interface::Workspace::
-GetGraph( )
+TWidget* cpPlugins::Interface::Workspace::
+GetWidget( const std::string& name )
 {
-  return( this->m_Graph );
+  TProcess* process = this->GetFilter( name );
+  return( dynamic_cast< TWidget* >( process ) );
 }
 
 // -------------------------------------------------------------------------
 const cpPlugins::Interface::Workspace::
-TGraph* cpPlugins::Interface::Workspace::
-GetGraph( ) const
+TWidget* cpPlugins::Interface::Workspace::
+GetWidget( const std::string& name ) const
 {
-  return( this->m_Graph );
+  const TProcess* process = this->GetFilter( name );
+  return( dynamic_cast< const TWidget* >( process ) );
 }
 
 // -------------------------------------------------------------------------
-void cpPlugins::Interface::Workspace::
-Clear( )
+bool cpPlugins::Interface::Workspace::
+HasFilter( const std::string& name ) const
 {
-  if( this->m_Graph.IsNotNull( ) )
-    this->m_Graph->Clear( );
+  return( this->m_Filters.find( name ) != this->m_Filters.end( ) );
 }
 
 // -------------------------------------------------------------------------
-void cpPlugins::Interface::Workspace::
-ClearConnections( )
+bool cpPlugins::Interface::Workspace::
+HasWidget( const std::string& name ) const
 {
+  const TWidget* wdg = this->GetWidget( name );
+  return( wdg != NULL );
 }
 
 // -------------------------------------------------------------------------
 cpPlugins::Interface::Workspace::
-TFilter* cpPlugins::Interface::Workspace::
-GetFilter( const std::string& name )
+TProcess* cpPlugins::Interface::Workspace::
+CreateFilter(
+  const std::string& category,
+  const std::string& filter,
+  const std::string& name
+  )
 {
-  TFilter* f =
-    dynamic_cast< TFilter* >(
-      this->m_Graph->GetVertex( name ).GetPointer( )
-      );
-  return( f );
-}
+  typedef cpPlugins::BaseObjects::Widget _TWidget;
 
-// -------------------------------------------------------------------------
-const cpPlugins::Interface::Workspace::
-TFilter* cpPlugins::Interface::Workspace::
-GetFilter( const std::string& name ) const
-{
-  const TFilter* f =
-    dynamic_cast< const TFilter* >(
-      this->m_Graph->GetVertex( name ).GetPointer( )
-      );
-  return( f );
-}
+  TInterface::Pointer interface = TInterface::New( );
+  TProcess::Pointer o = this->GetFilter( name );
+  if( o.IsNull( ) )
+  {
+    o = interface->CreateProcessObject( category, filter );
+    if( o.IsNotNull( ) )
+    {
+      o->SetPrintExecution( this->m_PrintExecution );
+      o->SetName( name );
 
-// -------------------------------------------------------------------------
-bool cpPlugins::Interface::Workspace::
-HasFilter( const std::string& name ) const
-{
-  if( this->m_Graph->HasVertexIndex( name ) )
-    return( this->GetFilter( name ) != NULL );
-  else
-    return( false );
+      // 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( o.GetPointer( ) );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-CreateFilter( const std::string& filter, const std::string& name )
+RenameFilter( const std::string& old_name, const std::string& new_name )
 {
-  if( this->m_Plugins == NULL )
-    return( false );
-
-  // Get or create new filter from name
-  if( !( this->m_Graph->HasVertexIndex( name ) ) )
+  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( ) )
   {
-    TFilter::Pointer f = this->m_Plugins->CreateObject( filter );
-    if( f.IsNotNull( ) )
-    {
-      f->SetName( name );
-      TObject::Pointer o = f.GetPointer( );
-      this->m_Graph->SetVertex( name, o );
-      return( true );
-    }
-    else
-      return( false );
+    // Rename filter
+    o->second->SetName( new_name );
+    this->m_Filters[ new_name ] = o->second;
+    this->m_Filters.erase( o );
+
+    // 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;
+
+    return( true );
   }
   else
-    return( true );
+    return( false );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-RenameFilter( const std::string& old_name, const std::string& new_name )
+RemoveFilter( const std::string& name )
 {
-  if( this->m_Graph->RenameVertex( old_name, new_name ) )
+  auto i = this->m_Filters.find( name );
+  if( i != this->m_Filters.end( ) )
   {
-    TFilter* f = this->GetFilter( new_name );
-    f->SetName( new_name );
+    i->second->Disconnect( );
+    this->m_Filters.erase( i );
     return( true );
   }
   else
@@ -143,113 +161,152 @@ RenameFilter( const std::string& old_name, const std::string& new_name )
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-RemoveFilter( const std::string& name )
+SetPrintExecution( bool b )
 {
+  this->m_PrintExecution = b;
+  for( auto i = this->m_Filters.begin( ); i != this->m_Filters.end( ); ++i )
+    i->second->SetPrintExecution( b );
 }
 
 // -------------------------------------------------------------------------
-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
-  )
+void cpPlugins::Interface::Workspace::
+PrintExecutionOn( )
 {
-  // Get filters
-  TFilter* orig = this->GetFilter( orig_filter );
-  TFilter* dest = this->GetFilter( dest_filter );
-  if( orig == NULL || dest == NULL )
-    return( false );
+  this->SetPrintExecution( true );
+}
 
-  // Real connection
-  dest->SetInput( input_name, orig->GetOutput< TData >( output_name ) );
-  this->m_Graph->AddEdge(
-    orig_filter, dest_filter,
-    TConnection( output_name, input_name )
-    );
-  return( false );
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+PrintExecutionOff( )
+{
+  this->SetPrintExecution( true );
 }
 
 // -------------------------------------------------------------------------
-bool cpPlugins::Interface::Workspace::
-Connect( TData* input_object, const std::string& input_name )
+void cpPlugins::Interface::Workspace::
+AddInteractor( vtkRenderWindowInteractor* iren )
 {
-  auto port = this->m_ExposedInputPorts.find( input_name );
-  if( port != this->m_ExposedInputPorts.end( ) )
+  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::
+TExposedPorts& cpPlugins::Interface::Workspace::
+GetExposedOutputs( ) const
+{
+  return( this->m_ExposedOutputs );
+}
+
+// -------------------------------------------------------------------------
+cpPlugins::BaseObjects::DataObject* cpPlugins::Interface::Workspace::
+GetExposedOutput( const std::string& name )
+{
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i != this->m_ExposedOutputs.end( ) )
   {
-    TFilter* filter = this->GetFilter( port->second.first );
-    if( filter != NULL )
-    {
-      filter->SetInput( port->second.second, input_object );
-      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( false );
+    return( NULL );
 }
 
 // -------------------------------------------------------------------------
-bool cpPlugins::Interface::Workspace::
-Reduce( const std::string& name )
+const cpPlugins::BaseObjects::DataObject* cpPlugins::Interface::Workspace::
+GetExposedOutput( const std::string& name ) const
 {
-  return( false );
+  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( NULL );
 }
 
 // -------------------------------------------------------------------------
-void cpPlugins::Interface::Workspace::
-ExposeInputPort(
+bool cpPlugins::Interface::Workspace::
+ExposeInput(
   const std::string& name,
   const std::string& filter, const std::string& filter_input
   )
 {
-  this->m_ExposedInputPorts[ name ] = TExposedPort( filter, filter_input );
+  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 );
 }
 
 // -------------------------------------------------------------------------
-void cpPlugins::Interface::Workspace::
-ExposeOutputPort(
+bool cpPlugins::Interface::Workspace::
+ExposeOutput(
   const std::string& name,
   const std::string& filter, const std::string& filter_output
   )
 {
-  this->m_ExposedOutputPorts[ name ] = TExposedPort( filter, 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 );
 }
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-HideInputPort( const std::string& name )
+HideInput( const std::string& name )
 {
-  auto i = this->m_ExposedInputPorts.find( name );
-  if( i != this->m_ExposedInputPorts.end( ) )
-    this->m_ExposedInputPorts.erase( i );
+  auto i = this->m_ExposedInputs.find( name );
+  if( i != this->m_ExposedInputs.end( ) )
+    this->m_ExposedInputs.erase( i );
 }
 
 // -------------------------------------------------------------------------
 void cpPlugins::Interface::Workspace::
-HideOutputPort( const std::string& name )
+HideOutput( const std::string& name )
 {
-  auto i = this->m_ExposedOutputPorts.find( name );
-  if( i != this->m_ExposedOutputPorts.end( ) )
-    this->m_ExposedOutputPorts.erase( i );
+  auto i = this->m_ExposedOutputs.find( name );
+  if( i != this->m_ExposedOutputs.end( ) )
+    this->m_ExposedOutputs.erase( i );
 }
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-RenameExposedInputPort(
-  const std::string& old_name,
-  const std::string& new_name
+RenameExposedInput(
+  const std::string& old_name, const std::string& new_name
   )
 {
-  auto o = this->m_ExposedInputPorts.find( old_name );
-  auto n = this->m_ExposedInputPorts.find( new_name );
-  if(
-    o != this->m_ExposedInputPorts.end( ) &&
-    n == this->m_ExposedInputPorts.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( ) )
   {
-    this->m_ExposedInputPorts[ new_name ] = o->second;
-    this->m_ExposedInputPorts.erase( o );
+    this->m_ExposedInputs[ new_name ] = o->second;
+    this->m_ExposedInputs.erase( o );
+    return( true );
   }
   else
     return( false );
@@ -257,83 +314,186 @@ RenameExposedInputPort(
 
 // -------------------------------------------------------------------------
 bool cpPlugins::Interface::Workspace::
-RenameExposedOutputPort(
-  const std::string& old_name,
-  const std::string& new_name
+RenameExposedOutput(
+  const std::string& old_name, const std::string& new_name
   )
 {
-  auto o = this->m_ExposedOutputPorts.find( old_name );
-  auto n = this->m_ExposedOutputPorts.find( new_name );
+  auto o = this->m_ExposedOutputs.find( old_name );
+  auto n = this->m_ExposedOutputs.find( new_name );
   if(
-    o != this->m_ExposedOutputPorts.end( ) &&
-    n == this->m_ExposedOutputPorts.end( )
+    o != this->m_ExposedOutputs.end( ) && n == this->m_ExposedOutputs.end( )
     )
   {
-    this->m_ExposedOutputPorts[ new_name ] = o->second;
-    this->m_ExposedOutputPorts.erase( o );
+    this->m_ExposedOutputs[ new_name ] = o->second;
+    this->m_ExposedOutputs.erase( o );
+    return( true );
   }
   else
     return( false );
 }
 
 // -------------------------------------------------------------------------
-const cpPlugins::Interface::Workspace::
-TExposedPorts& cpPlugins::Interface::Workspace::
-GetExposedInputPorts( ) const
+std::vector< std::pair< std::string, std::string > >
+cpPlugins::Interface::Workspace::
+GetConnections(
+  const std::string& origin, const std::string& destination
+  ) const
 {
-  return( this->m_ExposedInputPorts );
+  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 )
+      {
+        unsigned int nInputs = dest->GetInputSize( *i );
+        for( unsigned j = 0; j < nInputs; ++j )
+        {
+          auto od = orig->GetOutput( *o );
+          auto id = dest->GetInput( *i, j );
+          if( od != NULL && od == id )
+            conns.push_back(
+              std::pair< std::string, std::string >( *o, *i )
+              );
+
+        } // rof
+
+      } // rof
+
+    } // rof
+
+  } // fi
+  return( conns );
 }
 
 // -------------------------------------------------------------------------
-const cpPlugins::Interface::Workspace::
-TExposedPorts& cpPlugins::Interface::Workspace::
-GetExposedOutputPorts( ) const
+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
+  )
+{
+  auto o = this->GetFilter( orig_filter );
+  auto d = this->GetFilter( dest_filter );
+  if( o != NULL && d != NULL )
+  {
+    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
+
+  } // fi
+}
+
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Connect(
+  cpPlugins::BaseObjects::DataObject* output,
+  const std::string& dest_filter, const std::string& input_name
+  )
 {
-  return( this->m_ExposedOutputPorts );
+  auto d = this->GetFilter( dest_filter );
+  if( d != NULL )
+    d->AddInput( input_name, output );
 }
 
 // -------------------------------------------------------------------------
-std::string cpPlugins::Interface::Workspace::
-Execute( QWidget* p )
+void cpPlugins::Interface::Workspace::
+Connect(
+  cpPlugins::BaseObjects::DataObject* output,
+  const std::string& exposed_input_name
+  )
 {
-  // Find sinks
-  std::set< std::string > sinks = this->m_Graph->GetSinks( );
+  auto i = this->m_ExposedInputs.find( exposed_input_name );
+  if( i != this->m_ExposedInputs.end( ) )
+    this->Connect( output, i->second.first, i->second.second );
+}
 
-  // Update sinks
-  std::string err = "";
-  for( auto sIt = sinks.begin( ); sIt != sinks.end( ); ++sIt )
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Disconnect(
+  const std::string& orig_filter, const std::string& dest_filter,
+  const std::string& output_name, const std::string& input_name
+  )
+{
+  auto orig = this->GetFilter( orig_filter );
+  auto dest = this->GetFilter( dest_filter );
+  if( orig != NULL && dest != NULL )
   {
-    std::string lerr = this->Execute( *sIt, p );
-    if( lerr != "" )
-      err += lerr + std::string( "\n" );
+    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
+}
 
-  } // rof
-  return( err );
+// -------------------------------------------------------------------------
+void cpPlugins::Interface::Workspace::
+Disconnect(
+  const std::string& dest_filter, const std::string& input_name
+  )
+{
+  throw std::logic_error( "Disconnect 1" );
 }
 
 // -------------------------------------------------------------------------
-std::string cpPlugins::Interface::Workspace::
-Execute( const std::string& name, QWidget* p )
+void cpPlugins::Interface::Workspace::
+Disconnect( const std::string& dest_filter )
 {
-  // Get filter
-  TFilter* f = this->GetFilter( name );
-  if( f == NULL )
-    return(
-      std::string( "cpPlugins::Interface::Workspace: Vertex \"" ) +
-      name + std::string( "\" is not a filter." )
-      );
+  throw std::logic_error( "Disconnect 2" );
+}
 
-  // Execute and return
-  if( p != NULL )
-  {
-    auto diag_res = f->ExecConfigurationDialog( p );
-    if( diag_res == TFilter::DialogResult_NoModal )
-      return( f->Update( ) );
-    else
-      return( "" );
-  }
-  else
-    return( f->Update( ) );
+// -------------------------------------------------------------------------
+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$