JAL-2844 partitioning code made slightly clearer
[jalview.git] / forester / java / src / org / forester / application / rio.java
index 6ef7350..24acfe8 100644 (file)
@@ -2,10 +2,7 @@
 // FORESTER -- software libraries and applications
 // for evolutionary biology research and applications.
 //
-// Copyright (C) 2008-2009 Christian M. Zmasek
-// Copyright (C) 2008-2009 Burnham Institute for Medical Research
-// Copyright (C) 2000-2001 Washington University School of Medicine
-// and Howard Hughes Medical Institute
+// Copyright (C) 2017 Christian M. Zmasek
 // All rights reserved
 //
 // This library is free software; you can redistribute it and/or
 // License along with this library; if not, write to the Free Software
 // Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA
 //
-// Contact: phylosoft @ gmail . com
 // WWW: https://sites.google.com/site/cmzmasek/home/software/forester
 
 package org.forester.application;
 
 import java.io.File;
+import java.io.FilenameFilter;
 import java.io.IOException;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 
-import org.forester.datastructures.IntMatrix;
-import org.forester.io.parsers.IteratingPhylogenyParser;
-import org.forester.io.parsers.PhylogenyParser;
-import org.forester.io.parsers.nexus.NexusPhylogeniesParser;
-import org.forester.io.parsers.nhx.NHXParser;
-import org.forester.io.parsers.nhx.NHXParser.TAXONOMY_EXTRACTION;
-import org.forester.io.parsers.phyloxml.PhyloXmlParser;
-import org.forester.io.parsers.util.ParserUtils;
-import org.forester.io.writers.PhylogenyWriter;
-import org.forester.phylogeny.Phylogeny;
 import org.forester.rio.RIO;
 import org.forester.rio.RIO.REROOTING;
-import org.forester.rio.RIOException;
-import org.forester.sdi.SDIException;
+import org.forester.rio.RIOUtil;
 import org.forester.sdi.SDIutil.ALGORITHM;
-import org.forester.util.BasicDescriptiveStatistics;
 import org.forester.util.CommandLineArguments;
 import org.forester.util.EasyWriter;
 import org.forester.util.ForesterUtil;
 
 public class rio {
+    //
 
-    final static private String PRG_NAME              = "rio";
-    final static private String PRG_VERSION           = "4.000 beta 9";
-    final static private String PRG_DATE              = "2013.01.14";
-    final static private String E_MAIL                = "phyloxml@gmail.com";
-    final static private String WWW                   = "https://sites.google.com/site/cmzmasek/home/software/forester";
-    final static private String HELP_OPTION_1         = "help";
-    final static private String HELP_OPTION_2         = "h";
-    final static private String GT_FIRST              = "f";
-    final static private String GT_LAST               = "l";
-    final static private String REROOTING_OPT         = "r";
-    final static private String OUTGROUP              = "o";
-    final static private String RETURN_SPECIES_TREE   = "s";
-    final static private String RETURN_BEST_GENE_TREE = "g";
-    final static private String USE_SDIR              = "b";
+    public final static String  PRG_NAME                       = "rio";
+    public final static String  PRG_VERSION                    = "5.900";
+    public final static String  PRG_DATE                       = "170420";
+    final static private String E_MAIL                         = "phyloxml@gmail.com";
+    final static private String WWW                            = "https://sites.google.com/site/cmzmasek/home/software/forester";
+    final static private String HELP_OPTION_1                  = "help";
+    final static private String HELP_OPTION_2                  = "h";
+    final static private String GT_FIRST                       = "f";
+    final static private String GT_LAST                        = "l";
+    final static private String REROOTING_OPT                  = "r";
+    final static private String OUTGROUP                       = "o";
+    final static private String USE_SDIR                       = "s";
+    final static private String GENE_TREES_SUFFIX_OPTION       = "g";
+    final static private String MAPPINGS_DIR_OPTION            = "m";
+    final static private String MAPPINGS_SUFFIX_OPTION         = "ms";
+    final static private String CONSENSUS_TREES_DIR_OPTION     = "co";
+    final static private String CONSENSUS_TREES_SUFFIX_OPTION  = "cos";
+    final static private String MAPPINGS_SUFFIX_DEFAULT        = ".nim";
+    final static private String CONSENSUS_TREE_SUFFIX_DEFAULT  = ".xml";
+    final static private String ORTHOLOG_GROUPS_CUTOFF_OPTION  = "c";
+    final static private String GENE_TREES_SUFFIX_DEFAULT      = ".mlt";
+    final static private double ORTHOLOG_GROUPS_CUTOFF_DEFAULT = 0.5;
 
     public static void main( final String[] args ) {
         ForesterUtil.printProgramInformation( PRG_NAME,
@@ -87,7 +82,7 @@ public class rio {
         if ( cla.isOptionSet( HELP_OPTION_1 ) || cla.isOptionSet( HELP_OPTION_2 ) || ( args.length == 0 ) ) {
             printHelp();
         }
-        if ( ( args.length < 3 ) || ( args.length > 11 ) ) {
+        if ( ( args.length < 3 ) || ( args.length > 11 ) || ( cla.getNumberOfNames() < 3 ) ) {
             System.out.println();
             System.out.println( "error: incorrect number of arguments" );
             System.out.println();
@@ -99,24 +94,64 @@ public class rio {
         allowed_options.add( REROOTING_OPT );
         allowed_options.add( OUTGROUP );
         allowed_options.add( USE_SDIR );
-        allowed_options.add( RETURN_SPECIES_TREE );
-        allowed_options.add( RETURN_BEST_GENE_TREE );
+        allowed_options.add( GENE_TREES_SUFFIX_OPTION );
+        allowed_options.add( ORTHOLOG_GROUPS_CUTOFF_OPTION );
+        allowed_options.add( MAPPINGS_DIR_OPTION );
+        allowed_options.add( MAPPINGS_SUFFIX_OPTION );
+        allowed_options.add( CONSENSUS_TREES_DIR_OPTION );
+        allowed_options.add( CONSENSUS_TREES_SUFFIX_OPTION );
         final String dissallowed_options = cla.validateAllowedOptionsAsString( allowed_options );
         if ( dissallowed_options.length() > 0 ) {
             ForesterUtil.fatalError( "unknown option(s): " + dissallowed_options );
         }
         final File gene_trees_file = cla.getFile( 0 );
+        final boolean use_dir;
+        File indir = null;
+        File outdir = null;
+        if ( gene_trees_file.isDirectory() ) {
+            if ( !gene_trees_file.exists() ) {
+                ForesterUtil.fatalError( "gene trees directory \"" + gene_trees_file + "\" does not exist" );
+            }
+            if ( gene_trees_file.listFiles().length < 1 ) {
+                ForesterUtil.fatalError( "gene trees directory \"" + gene_trees_file + "\" is empty" );
+            }
+            use_dir = true;
+            indir = gene_trees_file;
+        }
+        else {
+            use_dir = false;
+        }
         final File species_tree_file = cla.getFile( 1 );
-        final File orthology_outtable = cla.getFile( 2 );
-        final File logfile;
-        if ( cla.getNumberOfNames() > 3 ) {
+        File orthology_outtable = null;
+        if ( use_dir ) {
+            outdir = cla.getFile( 2 );
+        }
+        else {
+            orthology_outtable = cla.getFile( 2 );
+        }
+        File logfile;
+        if ( use_dir ) {
+            if ( ( cla.getNumberOfNames() < 4 ) ) {
+                System.out.println();
+                System.out.println( "error: incorrect number of arguments" );
+                System.out.println();
+                printHelp();
+            }
             logfile = cla.getFile( 3 );
             if ( logfile.exists() ) {
                 ForesterUtil.fatalError( "\"" + logfile + "\" already exists" );
             }
         }
         else {
-            logfile = null;
+            if ( cla.getNumberOfNames() > 3 ) {
+                logfile = cla.getFile( 3 );
+                if ( logfile.exists() ) {
+                    ForesterUtil.fatalError( "\"" + logfile + "\" already exists" );
+                }
+            }
+            else {
+                logfile = null;
+            }
         }
         boolean sdir = false;
         if ( cla.isOptionSet( USE_SDIR ) ) {
@@ -124,18 +159,21 @@ public class rio {
                 ForesterUtil.fatalError( "no value allowed for -" + USE_SDIR );
             }
             sdir = true;
-            if ( logfile != null ) {
+            if ( !use_dir && logfile != null ) {
                 ForesterUtil.fatalError( "no logfile output for SDIR algorithm" );
             }
         }
         String outgroup = null;
         if ( cla.isOptionSet( OUTGROUP ) ) {
-            if ( !cla.isOptionHasAValue( OUTGROUP ) ) {
-                ForesterUtil.fatalError( "no value for -" + OUTGROUP );
-            }
             if ( sdir ) {
                 ForesterUtil.fatalError( "no outgroup option for SDIR algorithm" );
             }
+            if ( use_dir ) {
+                ForesterUtil.fatalError( "no outgroup option for operating on gene trees directory" );
+            }
+            if ( !cla.isOptionHasAValue( OUTGROUP ) ) {
+                ForesterUtil.fatalError( "no value for -" + OUTGROUP );
+            }
             outgroup = cla.getOptionValueAsCleanString( OUTGROUP );
         }
         REROOTING rerooting = REROOTING.BY_ALGORITHM;
@@ -154,6 +192,9 @@ public class rio {
                 rerooting = REROOTING.MIDPOINT;
             }
             else if ( rerooting_str.equals( "outgroup" ) ) {
+                if ( use_dir ) {
+                    ForesterUtil.fatalError( "no outgroup option for operating on gene trees directory" );
+                }
                 rerooting = REROOTING.OUTGROUP;
             }
             else {
@@ -170,12 +211,12 @@ public class rio {
         int gt_first = RIO.DEFAULT_RANGE;
         int gt_last = RIO.DEFAULT_RANGE;
         if ( cla.isOptionSet( GT_FIRST ) ) {
-            if ( !cla.isOptionHasAValue( GT_FIRST ) ) {
-                ForesterUtil.fatalError( "no value for -" + GT_FIRST );
-            }
             if ( sdir ) {
                 ForesterUtil.fatalError( "no gene tree range option for SDIR algorithm" );
             }
+            if ( !cla.isOptionHasAValue( GT_FIRST ) ) {
+                ForesterUtil.fatalError( "no value for -" + GT_FIRST );
+            }
             try {
                 gt_first = cla.getOptionValueAsInt( GT_FIRST );
             }
@@ -187,12 +228,12 @@ public class rio {
             }
         }
         if ( cla.isOptionSet( GT_LAST ) ) {
-            if ( !cla.isOptionHasAValue( GT_LAST ) ) {
-                ForesterUtil.fatalError( "no value for -" + GT_LAST );
-            }
             if ( sdir ) {
                 ForesterUtil.fatalError( "no gene tree range option for SDIR algorithm" );
             }
+            if ( !cla.isOptionHasAValue( GT_LAST ) ) {
+                ForesterUtil.fatalError( "no value for -" + GT_LAST );
+            }
             try {
                 gt_last = cla.getOptionValueAsInt( GT_LAST );
             }
@@ -207,45 +248,175 @@ public class rio {
             ForesterUtil.fatalError( "attempt to set range (0-based) of gene to analyze to: from " + gt_first + " to "
                     + gt_last );
         }
-        File return_species_tree = null;
-        if ( !sdir && cla.isOptionSet( RETURN_SPECIES_TREE ) ) {
-            if ( !cla.isOptionHasAValue( RETURN_SPECIES_TREE ) ) {
-                ForesterUtil.fatalError( "no value for -" + RETURN_SPECIES_TREE );
+        double ortholog_group_cutoff = ORTHOLOG_GROUPS_CUTOFF_DEFAULT;
+        if ( cla.isOptionSet( ORTHOLOG_GROUPS_CUTOFF_OPTION ) ) {
+            if ( sdir ) {
+                ForesterUtil.fatalError( "ortholog groups cutoff for SDIR algorithm" );
+            }
+            if ( !cla.isOptionHasAValue( ORTHOLOG_GROUPS_CUTOFF_OPTION ) ) {
+                ForesterUtil.fatalError( "no value for -" + ORTHOLOG_GROUPS_CUTOFF_OPTION );
+            }
+            try {
+                ortholog_group_cutoff = cla.getOptionValueAsDouble( ORTHOLOG_GROUPS_CUTOFF_OPTION );
+            }
+            catch ( final IOException e ) {
+                ForesterUtil.fatalError( "could not parse double for -" + ORTHOLOG_GROUPS_CUTOFF_OPTION + " option" );
+            }
+            if ( ortholog_group_cutoff < 0 ) {
+                ForesterUtil.fatalError( "attempt to set ortholog groups cutoff to: " + ortholog_group_cutoff );
+            }
+            if ( ortholog_group_cutoff > 1 ) {
+                ForesterUtil.fatalError( "attempt to set ortholog groups cutoff to: " + ortholog_group_cutoff );
+            }
+        }
+        if ( !use_dir ) {
+            ForesterUtil.fatalErrorIfFileNotReadable( gene_trees_file );
+        }
+        final String gene_trees_suffix;
+        if ( cla.isOptionSet( GENE_TREES_SUFFIX_OPTION ) ) {
+            if ( !use_dir ) {
+                ForesterUtil.fatalError( "no gene tree suffix option when operating on indivual gene trees" );
+            }
+            if ( !cla.isOptionHasAValue( GENE_TREES_SUFFIX_OPTION ) ) {
+                ForesterUtil.fatalError( "no value for -" + GENE_TREES_SUFFIX_OPTION );
+            }
+            gene_trees_suffix = cla.getOptionValueAsCleanString( GENE_TREES_SUFFIX_OPTION );
+        }
+        else {
+            gene_trees_suffix = GENE_TREES_SUFFIX_DEFAULT;
+        }
+        final boolean perform_id_mapping;
+        final File id_mapping_dir;
+        if ( cla.isOptionSet( MAPPINGS_DIR_OPTION ) ) {
+            id_mapping_dir = new File( cla.getOptionValue( MAPPINGS_DIR_OPTION ) );
+            perform_id_mapping = true;
+            if ( !use_dir ) {
+                ForesterUtil.fatalError( "no id mapping when operating on indivual gene trees" );
+            }
+            if ( !id_mapping_dir.exists() ) {
+                ForesterUtil.fatalError( "id mappings directory \"" + id_mapping_dir + "\" does not exist" );
+            }
+            if ( !id_mapping_dir.isDirectory() ) {
+                ForesterUtil.fatalError( "id mappings directory \"" + id_mapping_dir + "\" is not a directory" );
+            }
+            if ( id_mapping_dir.listFiles().length < 1 ) {
+                ForesterUtil.fatalError( "id mappings directory \"" + id_mapping_dir + "\" is empty" );
+            }
+        }
+        else {
+            id_mapping_dir = null;
+            perform_id_mapping = false;
+        }
+        final String id_mapping_suffix;
+        if ( cla.isOptionSet( MAPPINGS_SUFFIX_OPTION ) ) {
+            if ( !use_dir ) {
+                ForesterUtil.fatalError( "no id mapping file suffix option when operating on indivual gene trees" );
+            }
+            if ( !perform_id_mapping ) {
+                ForesterUtil.fatalError( "no id mapping directory given" );
+            }
+            if ( !cla.isOptionHasAValue( MAPPINGS_SUFFIX_OPTION ) ) {
+                ForesterUtil.fatalError( "no value for -" + MAPPINGS_SUFFIX_OPTION );
+            }
+            id_mapping_suffix = cla.getOptionValueAsCleanString( MAPPINGS_SUFFIX_OPTION );
+        }
+        else {
+            id_mapping_suffix = MAPPINGS_SUFFIX_DEFAULT;
+        }
+        boolean perform_gsdir_on_best_tree;
+        final File best_trees_indir;
+        if ( cla.isOptionSet( CONSENSUS_TREES_DIR_OPTION ) ) {
+            best_trees_indir = new File( cla.getOptionValue( CONSENSUS_TREES_DIR_OPTION ) );
+            perform_gsdir_on_best_tree = true;
+            if ( !use_dir ) {
+                ForesterUtil
+                        .fatalError( "no consensus (\"best\") gene tree GSDIR analysis when operating on individual gene trees" );
+            }
+            if ( !best_trees_indir.exists() ) {
+                ForesterUtil.fatalError( "consensus (\"best\") gene tree directory \"" + best_trees_indir
+                        + "\" does not exist" );
             }
-            final String s = cla.getOptionValueAsCleanString( RETURN_SPECIES_TREE );
-            return_species_tree = new File( s );
-            if ( return_species_tree.exists() ) {
-                ForesterUtil.fatalError( "\"" + return_species_tree + "\" already exists" );
+            if ( !best_trees_indir.isDirectory() ) {
+                ForesterUtil.fatalError( "consensus (\"best\") gene tree directory \"" + best_trees_indir
+                        + "\" is not a directory" );
+            }
+            if ( best_trees_indir.listFiles().length < 1 ) {
+                ForesterUtil
+                        .fatalError( "consensus (\"best\") gene tree directory \"" + best_trees_indir + "\" is empty" );
             }
         }
-        File return_gene_tree = null;
-        if ( !sdir && cla.isOptionSet( RETURN_BEST_GENE_TREE ) ) {
-            if ( !cla.isOptionHasAValue( RETURN_BEST_GENE_TREE ) ) {
-                ForesterUtil.fatalError( "no value for -" + RETURN_BEST_GENE_TREE );
+        else {
+            best_trees_indir = null;
+            perform_gsdir_on_best_tree = false;
+        }
+        final String best_trees_suffix;
+        if ( cla.isOptionSet( CONSENSUS_TREES_SUFFIX_OPTION ) ) {
+            if ( !use_dir ) {
+                ForesterUtil
+                        .fatalError( "no consensus (\"best\") gene tree suffix option when operating on individual gene trees" );
             }
-            final String s = cla.getOptionValueAsCleanString( RETURN_BEST_GENE_TREE );
-            return_gene_tree = new File( s );
-            if ( return_gene_tree.exists() ) {
-                ForesterUtil.fatalError( "\"" + return_gene_tree + "\" already exists" );
+            if ( !perform_gsdir_on_best_tree ) {
+                ForesterUtil.fatalError( "no consensus (\"best\") gene tree directory given" );
             }
+            if ( !cla.isOptionHasAValue( CONSENSUS_TREES_SUFFIX_OPTION ) ) {
+                ForesterUtil.fatalError( "no value for -" + CONSENSUS_TREES_SUFFIX_OPTION );
+            }
+            best_trees_suffix = cla.getOptionValueAsCleanString( CONSENSUS_TREES_SUFFIX_OPTION );
+        }
+        else {
+            best_trees_suffix = CONSENSUS_TREE_SUFFIX_DEFAULT;
         }
-        ForesterUtil.fatalErrorIfFileNotReadable( gene_trees_file );
         ForesterUtil.fatalErrorIfFileNotReadable( species_tree_file );
-        if ( orthology_outtable.exists() ) {
+        if ( !use_dir && orthology_outtable.exists() ) {
             ForesterUtil.fatalError( "\"" + orthology_outtable + "\" already exists" );
         }
         long time = 0;
-        System.out.println( "Gene trees                : " + gene_trees_file );
-        System.out.println( "Species tree              : " + species_tree_file );
-        System.out.println( "All vs all orthology table: " + orthology_outtable );
+        try {
+            if ( use_dir ) {
+                System.out.println( "Gene trees in-dir                   :\t" + indir.getCanonicalPath() );
+                System.out.println( "Gene trees suffix                   :\t" + gene_trees_suffix );
+            }
+            else {
+                System.out.println( "Gene trees                          :\t" + gene_trees_file.getCanonicalPath() );
+            }
+            System.out.println( "Species tree                        :\t" + species_tree_file.getCanonicalPath() );
+        }
+        catch ( final IOException e ) {
+            ForesterUtil.fatalError( e.getLocalizedMessage() );
+        }
+        if ( perform_id_mapping ) {
+            try {
+                System.out.println( "Id mappings in-dir                  :\t" + id_mapping_dir.getCanonicalPath() );
+            }
+            catch ( IOException e ) {
+                ForesterUtil.fatalError( e.getLocalizedMessage() );
+            }
+            System.out.println( "Id mappings suffix                  :\t" + id_mapping_suffix );
+        }
+        if ( perform_gsdir_on_best_tree ) {
+            try {
+                System.out.println( "Consensus (\"best\") gene trees in-dir:\t" + best_trees_indir.getCanonicalPath() );
+            }
+            catch ( IOException e ) {
+                ForesterUtil.fatalError( e.getLocalizedMessage() );
+            }
+            System.out.println( "Consensus (\"best\") gene trees suffix:\t" + best_trees_suffix );
+        }
+        if ( use_dir ) {
+            System.out.println( "Out-dir                             :\t" + outdir );
+        }
+        else {
+            System.out.println( "All vs all orthology results table  :\t" + orthology_outtable );
+        }
         if ( logfile != null ) {
-            System.out.println( "Logfile                   : " + logfile );
+            System.out.println( "Logfile                             :\t" + logfile );
         }
+        System.out.println( "Ortholog groups cutoff              :\t" + ortholog_group_cutoff );
         if ( gt_first != RIO.DEFAULT_RANGE ) {
-            System.out.println( "First gene tree to analyze: " + gt_first );
+            System.out.println( "First gene tree to analyze          :\t" + gt_first );
         }
         if ( gt_last != RIO.DEFAULT_RANGE ) {
-            System.out.println( "Last gene tree to analyze : " + gt_last );
+            System.out.println( "Last gene tree to analyze           :\t" + gt_last );
         }
         String rerooting_str = "";
         switch ( rerooting ) {
@@ -266,18 +437,12 @@ public class rio {
                 break;
             }
         }
-        System.out.println( "Re-rooting                : " + rerooting_str );
+        System.out.println( "Re-rooting                          : \t" + rerooting_str );
         if ( !sdir ) {
-            System.out.println( "Non binary species tree   : allowed" );
+            System.out.println( "Non binary species tree             :\tallowed" );
         }
         else {
-            System.out.println( "Non binary species tree   : disallowed" );
-        }
-        if ( return_species_tree != null ) {
-            System.out.println( "Write used species tree to: " + return_species_tree );
-        }
-        if ( return_gene_tree != null ) {
-            System.out.println( "Write best gene tree to   : " + return_gene_tree );
+            System.out.println( "Non binary species tree             :\tdisallowed" );
         }
         time = System.currentTimeMillis();
         final ALGORITHM algorithm;
@@ -287,142 +452,298 @@ public class rio {
         else {
             algorithm = ALGORITHM.GSDIR;
         }
-        try {
-            final RIO rio;
-            boolean iterating = false;
-            final PhylogenyParser p = ParserUtils.createParserDependingOnFileType( gene_trees_file, true );
-            if ( p instanceof PhyloXmlParser ) {
-                rio = RIO.executeAnalysis( gene_trees_file,
-                                           species_tree_file,
-                                           algorithm,
-                                           rerooting,
-                                           outgroup,
-                                           gt_first,
-                                           gt_last,
-                                           logfile != null,
-                                           true );
+        EasyWriter log = null;
+        if ( use_dir ) {
+            if ( outdir.exists() ) {
+                if ( !outdir.isDirectory() ) {
+                    ForesterUtil.fatalError( PRG_NAME,
+                                             "out-directory [" + outdir + "] already exists but is not a directory" );
+                }
             }
             else {
-                iterating = true;
-                if ( p instanceof NHXParser ) {
-                    final NHXParser nhx = ( NHXParser ) p;
-                    nhx.setReplaceUnderscores( false );
-                    nhx.setIgnoreQuotes( true );
-                    nhx.setTaxonomyExtraction( NHXParser.TAXONOMY_EXTRACTION.YES );
+                final boolean success = outdir.mkdirs();
+                if ( !success ) {
+                    ForesterUtil.fatalError( PRG_NAME, "could not create out-directory [" + outdir + "]" );
+                }
+            }
+            final String species_tree_file_name = species_tree_file.getName();
+            final File gene_trees_files[] = indir.listFiles( new FilenameFilter() {
+
+                @Override
+                public boolean accept( final File dir, final String name ) {
+                    return ( ( name.endsWith( gene_trees_suffix ) ) && !( name.equals( species_tree_file_name ) ) );
+                }
+            } );
+            if ( gene_trees_files.length < 1 ) {
+                ForesterUtil.fatalError( PRG_NAME,
+                                         "in-directory [" + indir
+                                                 + "] does not contain any gene tree files with suffix "
+                                                 + gene_trees_suffix );
+            }
+            try {
+                log = ForesterUtil.createEasyWriter( logfile );
+            }
+            catch ( final IOException e ) {
+                ForesterUtil.fatalError( PRG_NAME, "could not create [" + logfile + "]" );
+            }
+            Arrays.sort( gene_trees_files );
+            try {
+                log.print( "# program" );
+                log.print( "\t" );
+                log.print( PRG_NAME );
+                log.println();
+                log.print( "# version" );
+                log.print( "\t" );
+                log.print( PRG_VERSION );
+                log.println();
+                log.print( "# date" );
+                log.print( "\t" );
+                log.print( PRG_DATE );
+                log.println();
+                log.print( "# Algorithm " );
+                log.print( "\t" );
+                log.print( algorithm.toString() );
+                log.println();
+                log.print( "# Gene trees in-dir" );
+                log.print( "\t" );
+                log.print( indir.getCanonicalPath() );
+                log.println();
+                log.print( "# Gene trees suffix" );
+                log.print( "\t" );
+                log.print( gene_trees_suffix );
+                log.println();
+                log.print( "# Species tree" );
+                log.print( "\t" );
+                log.print( species_tree_file.getCanonicalPath() );
+                log.println();
+                if ( perform_id_mapping ) {
+                    log.print( "# Id mappings in-dir" );
+                    log.print( "\t" );
+                    log.print( id_mapping_dir.getCanonicalPath() );
+                    log.println();
+                    log.print( "# Id mappings suffix" );
+                    log.print( "\t" );
+                    log.print( id_mapping_suffix );
+                    log.println();
                 }
-                else if ( p instanceof NexusPhylogeniesParser ) {
-                    final NexusPhylogeniesParser nex = ( NexusPhylogeniesParser ) p;
-                    nex.setReplaceUnderscores( false );
-                    nex.setIgnoreQuotes( true );
-                    nex.setTaxonomyExtraction( TAXONOMY_EXTRACTION.YES );
+                if ( perform_gsdir_on_best_tree ) {
+                    log.print( "# Consensus (\"best\") gene tree dir" );
+                    log.print( "\t" );
+                    log.print( best_trees_indir.getCanonicalPath() );
+                    log.println();
+                    log.print( "# Consensus (\"best\") gene tree suffix" );
+                    log.print( "\t" );
+                    log.print( best_trees_suffix );
+                    log.println();
+                }
+                log.print( "# Out-dir" );
+                log.print( "\t" );
+                log.print( outdir.getCanonicalPath() );
+                log.println();
+                log.print( "# Logfile" );
+                log.print( "\t" );
+                log.print( logfile.getCanonicalPath() );
+                log.println();
+                log.print( "# Ortholog groups cutoff" );
+                log.print( "\t" );
+                log.print( Double.toString( ortholog_group_cutoff ) );
+                log.println();
+                if ( gt_first != RIO.DEFAULT_RANGE ) {
+                    log.print( "# First gene tree to analyze" );
+                    log.print( "\t" );
+                    log.print( Integer.toString( gt_first ) );
+                    log.println();
+                }
+                if ( gt_last != RIO.DEFAULT_RANGE ) {
+                    log.print( "# Last gene tree to analyze" );
+                    log.print( "\t" );
+                    log.print( Integer.toString( gt_last ) );
+                    log.println();
+                }
+                log.print( "# Re-rooting" );
+                log.print( "\t" );
+                log.print( rerooting_str );
+                log.println();
+                log.print( "# Non binary species tree" );
+                log.print( "\t" );
+                if ( !sdir ) {
+                    log.print( "allowed" );
                 }
                 else {
-                    throw new RuntimeException( "unknown parser type: " + p );
+                    log.print( "disallowed" );
+                }
+                log.println();
+                log.println();
+                log.print( "NAME" );
+                log.print( "\t" );
+                log.print( "EXT NODES" );
+                log.print( "\t" );
+                log.print( ortholog_group_cutoff + " O GROUPS" );
+                log.print( "\t" );
+                log.print( "0.05 O GROUPS" );
+                log.print( "\t" );
+                log.print( "0.25 O GROUPS" );
+                log.print( "\t" );
+                log.print( "0.5 O GROUPS" );
+                log.print( "\t" );
+                log.print( "0.75 O GROUPS" );
+                log.print( "\t" );
+                log.print( "0.95 O GROUPS" );
+                log.print( "\t" );
+                if ( perform_gsdir_on_best_tree ) {
+                    log.print( "BEST TREE DUP" );
+                    log.print( "\t" );
+                    log.print( "MEDIAN DUP - BEST TREE DUP" );
+                    log.print( "\t" );
+                }
+                log.print( "MEDIAN DUP" );
+                log.print( "\t" );
+                log.print( "MEAN DUP" );
+                log.print( "\t" );
+                log.print( "MEAN DUP SD" );
+                log.print( "\t" );
+                log.print( "MIN DUP" );
+                log.print( "\t" );
+                log.print( "MAX DUP" );
+                log.print( "\t" );
+                log.print( "REMOVED EXT NODES" );
+                log.print( "\t" );
+                log.print( "N" );
+                log.println();
+            }
+            catch ( IOException e ) {
+                ForesterUtil.fatalError( PRG_NAME, e.getLocalizedMessage() );
+            }
+            int counter = 1;
+            for( final File gf : gene_trees_files ) {
+                String outname = gf.getName();
+                System.out
+                        .print( "\r                                                                                            " );
+                System.out.print( "\r" + counter + "/" + gene_trees_files.length + ": " + outname );
+                counter++;
+                if ( outname.indexOf( "." ) > 0 ) {
+                    outname = outname.substring( 0, outname.lastIndexOf( "." ) );
+                }
+                try {
+                    RIOUtil.executeAnalysis( gf,
+                                             species_tree_file,
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.ORTHO_OUTTABLE_SUFFIX ),
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.ORTHO_OUTTABLE_WITH_MAP_SUFFIX ),
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.ORTHOLOG_GROUPS_SUFFIX ),
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.LOGFILE_SUFFIX ),
+                                             outgroup,
+                                             rerooting,
+                                             gt_first,
+                                             gt_last,
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.STRIPPED_SPECIES_TREE_SUFFIX ),
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.OUT_MIN_DUP_GENE_TREE_SUFFIX ),
+                                             new File( outdir.getCanonicalFile() + "/" + outname
+                                                     + RIOUtil.OUT_MED_DUP_GENE_TREE_SUFFIX ),
+                                             true,
+                                             algorithm,
+                                             true,
+                                             log,
+                                             ortholog_group_cutoff,
+                                             perform_id_mapping,
+                                             id_mapping_dir,
+                                             id_mapping_suffix,
+                                             perform_gsdir_on_best_tree,
+                                             outdir,
+                                             best_trees_indir,
+                                             best_trees_suffix );
+                }
+                catch ( IOException e ) {
+                    ForesterUtil.fatalError( PRG_NAME, e.getLocalizedMessage() );
                 }
-                final IteratingPhylogenyParser ip = ( IteratingPhylogenyParser ) p;
-                ip.setSource( gene_trees_file );
-                rio = RIO.executeAnalysis( ip,
-                                           species_tree_file,
-                                           algorithm,
-                                           rerooting,
-                                           outgroup,
-                                           gt_first,
-                                           gt_last,
-                                           logfile != null,
-                                           true );
-            }
-            if ( algorithm == ALGORITHM.GSDIR ) {
-                System.out.println( "Taxonomy linking based on : " + rio.getGSDIRtaxCompBase() );
-            }
-            final IntMatrix m;
-            if ( iterating ) {
-                m = rio.getOrthologTable();
             }
-            else {
-                m = RIO.calculateOrthologTable( rio.getAnalyzedGeneTrees(), true );
-            }
-            final BasicDescriptiveStatistics stats = rio.getDuplicationsStatistics();
-            writeTable( orthology_outtable, stats.getN(), m );
-            if ( ( algorithm != ALGORITHM.SDIR ) && ( logfile != null ) ) {
-                writeLogFile( logfile,
-                              rio,
-                              species_tree_file,
-                              gene_trees_file,
-                              orthology_outtable,
-                              PRG_NAME,
-                              PRG_VERSION,
-                              PRG_DATE,
-                              ForesterUtil.getForesterLibraryInformation() );
-            }
-            if ( return_species_tree != null ) {
-                writeTree( rio.getSpeciesTree(), return_species_tree, "Wrote (stripped) species tree to" );
-            }
-            if ( return_gene_tree != null ) {
-                writeTree( rio.getMinDuplicationsGeneTree(),
-                           return_gene_tree,
-                           "Wrote (one) minimal duplication gene tree to" );
-            }
-            final java.text.DecimalFormat df = new java.text.DecimalFormat( "0.#" );
-            System.out.println( "Mean number of duplications  : " + df.format( stats.arithmeticMean() ) + " (sd: "
-                    + df.format( stats.sampleStandardDeviation() ) + ") ("
-                    + df.format( 100.0 * stats.arithmeticMean() / rio.getIntNodesOfAnalyzedGeneTrees() ) + "%)" );
-            if ( stats.getN() > 3 ) {
-                System.out.println( "Median number of duplications: " + df.format( stats.median() ) + " ("
-                        + df.format( 100.0 * stats.median() / rio.getIntNodesOfAnalyzedGeneTrees() ) + "%)" );
-            }
-            System.out.println( "Minimum duplications         : " + ( int ) stats.getMin() + " ("
-                    + df.format( 100.0 * stats.getMin() / rio.getIntNodesOfAnalyzedGeneTrees() ) + "%)" );
-            System.out.println( "Maximum duplications         : " + ( int ) stats.getMax() + " ("
-                    + df.format( 100.0 * stats.getMax() / rio.getIntNodesOfAnalyzedGeneTrees() ) + "%)" );
-            System.out.println( "Gene tree internal nodes     : " + rio.getIntNodesOfAnalyzedGeneTrees() );
-            System.out.println( "Gene tree external nodes     : " + rio.getExtNodesOfAnalyzedGeneTrees() );
-        }
-        catch ( final RIOException e ) {
-            ForesterUtil.fatalError( e.getLocalizedMessage() );
-        }
-        catch ( final SDIException e ) {
-            ForesterUtil.fatalError( e.getLocalizedMessage() );
-        }
-        catch ( final IOException e ) {
-            ForesterUtil.fatalError( e.getLocalizedMessage() );
-        }
-        catch ( final OutOfMemoryError e ) {
-            ForesterUtil.outOfMemoryError( e );
+            System.out
+                    .print( "\r                                                                                        " );
+            System.out.println();
         }
-        catch ( final Exception e ) {
-            ForesterUtil.unexpectedFatalError( e );
+        else {
+            String outname = ForesterUtil.removeFileExtension( orthology_outtable.toString() );
+            RIOUtil.executeAnalysis( gene_trees_file,
+                                     species_tree_file,
+                                     orthology_outtable,
+                                     null,
+                                     new File( outname + RIOUtil.ORTHOLOG_GROUPS_SUFFIX ),
+                                     logfile,
+                                     outgroup,
+                                     rerooting,
+                                     gt_first,
+                                     gt_last,
+                                     new File( outname + RIOUtil.STRIPPED_SPECIES_TREE_SUFFIX ),
+                                     new File( outname + RIOUtil.OUT_MIN_DUP_GENE_TREE_SUFFIX ),
+                                     new File( outname + RIOUtil.OUT_MED_DUP_GENE_TREE_SUFFIX ),
+                                     algorithm == ALGORITHM.GSDIR,
+                                     algorithm,
+                                     false,
+                                     null,
+                                     ortholog_group_cutoff,
+                                     false,
+                                     null,
+                                     null,
+                                     false,
+                                     null,
+                                     null,
+                                     null );
+        }
+        if ( !use_dir ) {
+            time = System.currentTimeMillis() - time;
+            System.out.println( "Time                                :\t" + time + "ms" );
         }
-        catch ( final Error e ) {
-            ForesterUtil.unexpectedFatalError( e );
+        else {
+            try {
+                log.close();
+            }
+            catch ( IOException e ) {
+                ForesterUtil.fatalError( PRG_NAME, e.getLocalizedMessage() );
+            }
+            time = System.currentTimeMillis() - time;
+            System.out.println( "Time                                :\t" + time + "ms" );
         }
-        time = System.currentTimeMillis() - time;
-        System.out.println( "Time: " + time + "ms" );
-        System.out.println( "OK" );
         System.exit( 0 );
     }
 
     private final static void printHelp() {
         System.out.println( "Usage" );
         System.out.println();
-        System.out
-                .println( PRG_NAME
-                        + " [options] <gene trees infile> <species tree infile> <all vs all orthology table outfile> [logfile]" );
+        System.out.println( PRG_NAME
+                + " [options] <gene trees infile> <species tree infile> <all vs all orthology table outfile> [logfile]" );
+        System.out.println();
+        System.out.println( PRG_NAME + " [options] <gene trees indir> <species tree infile> <outdir> <logfile>" );
+        System.out.println();
         System.out.println();
         System.out.println( " Options" );
         System.out.println( "  -" + GT_FIRST + "=<first>     : first gene tree to analyze (0-based index)" );
         System.out.println( "  -" + GT_LAST + "=<last>      : last gene tree to analyze (0-based index)" );
+        System.out.println( "  -" + ORTHOLOG_GROUPS_CUTOFF_OPTION
+                + "=<cutoff>    : cutoff value for ortholog groups (default: " + ORTHOLOG_GROUPS_CUTOFF_DEFAULT + ")" );
         System.out.println( "  -" + REROOTING_OPT
                 + "=<re-rooting>: re-rooting method for gene trees, possible values or 'none', 'midpoint'," );
         System.out.println( "                   or 'outgroup' (default: by minizming duplications)" );
         System.out.println( "  -" + OUTGROUP
                 + "=<outgroup>  : for rooting by outgroup, name of outgroup (external gene tree node)" );
-        System.out
-                .println( "  -" + RETURN_SPECIES_TREE + "=<outfile>   : to write the (stripped) species tree to file" );
-        System.out.println( "  -" + RETURN_BEST_GENE_TREE
-                + "=<outfile>   : to write (one) minimal duplication gene tree to file" );
         System.out.println( "  -" + USE_SDIR
                 + "             : to use SDIR instead of GSDIR (faster, but non-binary species trees are" );
         System.out.println( "                   disallowed, as are most options)" );
+        System.out.println( "  -" + GENE_TREES_SUFFIX_OPTION
+                + "=<suffix>    : suffix for gene trees when operating on gene tree directories (default: "
+                + GENE_TREES_SUFFIX_DEFAULT + ")" );
+        System.out.println( "  -" + MAPPINGS_DIR_OPTION + "=<dir>       : directory for id mapping files" );
+        System.out.println( "  -" + MAPPINGS_SUFFIX_OPTION + "=<suffix>   : suffix for id mapping files (default: "
+                + MAPPINGS_SUFFIX_DEFAULT + ")" );
+        System.out.println( "  -" + CONSENSUS_TREES_DIR_OPTION
+                + "=<dir>      : directory with consenus (\"best\") gene trees to be analyzed with GSDIR" );
+        System.out.println( "  -" + CONSENSUS_TREES_SUFFIX_OPTION
+                + "=<suffix>  : suffix for consenus (\"best\") gene trees (default: " + CONSENSUS_TREE_SUFFIX_DEFAULT
+                + ")" );
         System.out.println();
         System.out.println( " Formats" );
         System.out
@@ -434,70 +755,15 @@ public class rio {
         System.out.println( "  in the species tree." );
         System.out.println();
         System.out.println( " Examples" );
-        System.out.println( "  \"rio gene_trees.nh species.xml outtable.tsv log.txt\"" );
-        System.out.println();
-        System.out.println( " More information: http://code.google.com/p/forester/wiki/RIO" );
+        System.out.println( "  rio -s gene_trees.nh species.xml outtable.tsv" );
+        System.out.println( "  rio gene_trees.nh species.xml outtable.tsv log.txt" );
+        System.out.println( "  rio -c=0.9 -f=10 -l=100 -r=none gene_trees.xml species.xml outtable.tsv log.txt" );
+        System.out.println( "  rio -g=.xml gene_trees_dir species.xml out_dir log.tsv" );
+        System.out.println( "  rio -g=.mlt -m=id_maps_dir -ms=.nim -c=0.8 gene_trees_dir species.xml out_dir log.tsv" );
+        System.out.println( "  rio -m=id_maps_dir -c=0.8 gene_trees_dir species.xml out_dir log.tsv" );
+        System.out
+                .println( "  rio -m=id_maps_dir -co=consensus_dir -cos=.xml -c=0.8 gene_trees_dir species.xml out_dir log.tsv" );
         System.out.println();
         System.exit( -1 );
     }
-
-    private static void writeLogFile( final File logfile,
-                                      final RIO rio,
-                                      final File species_tree_file,
-                                      final File gene_trees_file,
-                                      final File outtable,
-                                      final String prg_name,
-                                      final String prg_v,
-                                      final String prg_date,
-                                      final String f ) throws IOException {
-        final EasyWriter out = ForesterUtil.createEasyWriter( logfile );
-        out.println( prg_name );
-        out.println( "version : " + prg_v );
-        out.println( "date    : " + prg_date );
-        out.println( "based on: " + f );
-        out.println( "----------------------------------" );
-        out.println( "Gene trees                                      : " + gene_trees_file );
-        out.println( "Species tree                                    : " + species_tree_file );
-        out.println( "All vs all orthology table                      : " + outtable );
-        out.flush();
-        out.println( rio.getLog().toString() );
-        out.close();
-        System.out.println( "Wrote log to \"" + logfile + "\"" );
-    }
-
-    private static void writeTable( final File table_outfile, final int gene_trees_analyzed, final IntMatrix m )
-            throws IOException {
-        final EasyWriter w = ForesterUtil.createEasyWriter( table_outfile );
-        final java.text.DecimalFormat df = new java.text.DecimalFormat( "0.###" );
-        df.setDecimalSeparatorAlwaysShown( false );
-        for( int i = 0; i < m.size(); ++i ) {
-            w.print( "\t" );
-            w.print( m.getLabel( i ) );
-        }
-        w.println();
-        for( int x = 0; x < m.size(); ++x ) {
-            w.print( m.getLabel( x ) );
-            for( int y = 0; y < m.size(); ++y ) {
-                w.print( "\t" );
-                if ( x == y ) {
-                    if ( m.get( x, y ) != gene_trees_analyzed ) {
-                        ForesterUtil.unexpectedFatalError( "diagonal value is off" );
-                    }
-                    w.print( "-" );
-                }
-                else {
-                    w.print( df.format( ( ( double ) m.get( x, y ) ) / gene_trees_analyzed ) );
-                }
-            }
-            w.println();
-        }
-        w.close();
-        System.out.println( "Wrote table to \"" + table_outfile + "\"" );
-    }
-
-    private static void writeTree( final Phylogeny p, final File f, final String comment ) throws IOException {
-        final PhylogenyWriter writer = new PhylogenyWriter();
-        writer.toPhyloXML( f, p, 0 );
-        System.out.println( comment + " \"" + f + "\"" );
-    }
 }