Moved to version 1.0

[cpPlugins.git] / appli / bash / ExecutePipeline.cxx

diff --git a/appli/bash/ExecutePipeline.cxx b/appli/bash/ExecutePipeline.cxx
new file mode 100644 (file)
index 0000000..a293c3a
--- /dev/null
+++ b/appli/bash/ExecutePipeline.cxx
@@ -0,0 +1,143 @@
+// =========================================================================
+// @author Leonardo Florez-Valencia (florez-l@javeriana.edu.co)
+// =========================================================================
+
+#include <iostream>
+#include <vector>
+#include <boost/filesystem.hpp>
+#include <boost/program_options.hpp>
+#include <cpPlugins/Pipeline.h>
+
+int main( int argc, char* argv[] )
+{
+  typedef cpPlugins::Pipeline TPipeline;
+  namespace bpo = boost::program_options;
+
+  // Declare the supported options.
+  bpo::options_description d( "Allowed options" );
+  d.add_options( )
+    ( "help,h", "produce help message" )
+    ( "interactive,i", bpo::bool_switch( )->default_value( false ), "Run an interactive menu to configure pipeline" )
+    ( "overwrite,o", bpo::bool_switch( )->default_value( false ), "Overwrite XML file" )
+    ( "contents,c", bpo::bool_switch( )->default_value( false ), "Print pipeline contents" )
+    ( "value,v", bpo::value< std::vector< std::string > >( ), "Parameter values" )
+    ( "pipeline,p", bpo::value< std::string >( )->required( ), "Pipeline file" )
+    ;
+  bpo::positional_options_description p;
+  p.add( "pipeline", -1 );
+  
+  // Parse input arguments
+  bpo::variables_map v;
+  try
+  {
+    bpo::store(
+      bpo::
+      command_line_parser( argc, argv ).options( d ).positional( p ).run( ),
+      v
+      );
+    bpo::notify( v );
+    if( v.count( "help" ) > 0 )
+    {
+      std::cerr << d << std::endl;
+      return( 0 );
+
+    } // fi
+  }
+  catch( std::exception& err )
+  {
+    std::cerr << "Error caught: " << err.what( ) << std::endl;
+    std::cerr << d << std::endl;
+    return( 1 );
+
+  } // yrt
+
+  try
+  {
+    // Load pipeline
+    TPipeline::SharedPtr pipeline = TPipeline::New( );
+    pipeline->ExecutionDebugOn( );
+    pipeline->LoadXML( v[ "pipeline" ].as< std::string >( ) );
+
+    // Configure pipeline
+    if( v.count( "value" ) > 0 )
+    {
+      for(
+        const std::string& pv:
+          v[ "value" ].as< std::vector< std::string > >( )
+        )
+      {
+        std::size_t b = pv.find_first_of( "=" );
+        pipeline->SetInValue( pv.substr( 0, b ), pv.substr( b + 1 ) );
+
+      } // rof
+
+    } // fi
+
+    // Just print pipeline contents
+    if( v[ "contents" ].as< bool >( ) )
+    {
+      /* TODO
+         TPipeline::TParametersMap pmap = pipeline->GetParametersMap( );
+         TPipeline::TParametersMap::const_iterator pIt;
+         for( pIt = pmap.begin( ); pIt != pmap.end( ); ++pIt )
+         {
+         std::cout
+         << pIt->first << " ("
+         << pIt->second.first << "="
+         << pIt->second.second << ")"
+         << std::endl;
+
+         } // rof
+      */
+      return( 0 );
+
+    } // fi
+
+    // Interactively configure pipeline
+    if( v[ "interactive" ].as< bool >( ) )
+    {
+      std::cout << "** Interactively configuring pipeline **" << std::endl;
+      /* TODO
+         TPipeline::TParametersMap pmap = pipeline->GetParametersMap( );
+         TPipeline::TParametersMap::const_iterator pIt;
+         for( pIt = pmap.begin( ); pIt != pmap.end( ); ++pIt )
+         {
+         std::cout
+         << pIt->first << " ("
+         << pIt->second.first << "="
+         << pIt->second.second << "): "
+         << std::ends;
+         std::string line;
+         std::getline( std::cin, line );
+         if( line != "" )
+         {
+         std::size_t p = pIt->first.find( "@" );
+         pipeline->SetParameter(
+         pIt->first.substr( p + 1 ),
+         pIt->first.substr( 0, p ),
+         line
+         );
+
+         } // fi
+
+         } // rof
+      */
+    } // fi
+
+    // Execute pipeline
+    pipeline->Update( );
+
+    // Save pipeline
+    if( v[ "overwrite" ].as< bool >( ) )
+      pipeline->SaveXML( v[ "pipeline" ].as< std::string >( ) );
+  }
+  catch( std::exception& err )
+  {
+    std::cerr << "ERROR CAUGHT: " << err.what( ) << std::endl;
+    return( 1 );
+
+  } // yrt
+  return( 0 );
+}
+
+// eof - $RCSfile$