package org.apache.maven.lifecycle;

 /*

  * Licensed to the Apache Software Foundation (ASF) under one

  * or more contributor license agreements.  See the NOTICE file

  * distributed with this work for additional information

  * regarding copyright ownership.  The ASF licenses this file

  * to you under the Apache License, Version 2.0 (the

  * "License"); you may not use this file except in compliance

  * with the License.  You may obtain a copy of the License at

  *

  *  http://www.apache.org/licenses/LICENSE-2.0

  *

  * Unless required by applicable law or agreed to in writing,

  * software distributed under the License is distributed on an

  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

  * KIND, either express or implied.  See the License for the

  * specific language governing permissions and limitations

  * under the License.

  */

 import org.apache.maven.BuildFailureException;

 import org.apache.maven.artifact.handler.ArtifactHandler;

 import org.apache.maven.artifact.handler.manager.ArtifactHandlerManager;

 import org.apache.maven.artifact.repository.ArtifactRepository;

 import org.apache.maven.artifact.resolver.ArtifactNotFoundException;

 import org.apache.maven.artifact.resolver.ArtifactResolutionException;

 import org.apache.maven.artifact.versioning.InvalidVersionSpecificationException;

 import org.apache.maven.execution.MavenSession;

 import org.apache.maven.execution.ReactorManager;

 import org.apache.maven.extension.ExtensionManager;

 import org.apache.maven.lifecycle.mapping.LifecycleMapping;

 import org.apache.maven.model.Extension;

 import org.apache.maven.model.Plugin;

 import org.apache.maven.model.PluginExecution;

 import org.apache.maven.model.ReportPlugin;

 import org.apache.maven.model.ReportSet;

 import org.apache.maven.monitor.event.EventDispatcher;

 import org.apache.maven.monitor.event.MavenEvents;

 import org.apache.maven.plugin.InvalidPluginException;

 import org.apache.maven.plugin.MojoExecution;

 import org.apache.maven.plugin.MojoExecutionException;

 import org.apache.maven.plugin.MojoFailureException;

 import org.apache.maven.plugin.PluginConfigurationException;

 import org.apache.maven.plugin.PluginManager;

 import org.apache.maven.plugin.PluginManagerException;

 import org.apache.maven.plugin.PluginNotFoundException;

 import org.apache.maven.plugin.descriptor.MojoDescriptor;

 import org.apache.maven.plugin.descriptor.PluginDescriptor;

 import org.apache.maven.plugin.lifecycle.Execution;

 import org.apache.maven.plugin.lifecycle.Phase;

 import org.apache.maven.plugin.version.PluginVersionNotFoundException;

 import org.apache.maven.plugin.version.PluginVersionResolutionException;

 import org.apache.maven.project.MavenProject;

 import org.apache.maven.project.artifact.InvalidDependencyVersionException;

 import org.apache.maven.reporting.MavenReport;

 import org.apache.maven.settings.Settings;

 import org.codehaus.plexus.PlexusContainerException;

 import org.codehaus.plexus.component.repository.exception.ComponentLookupException;

 import org.codehaus.plexus.logging.AbstractLogEnabled;

 import org.codehaus.plexus.util.StringUtils;

 import org.codehaus.plexus.util.xml.Xpp3Dom;

 import org.codehaus.plexus.util.xml.pull.XmlPullParserException;

 import java.io.IOException;

 import java.util.ArrayList;

 import java.util.Collections;

 import java.util.HashMap;

 import java.util.Iterator;

 import java.util.List;

 import java.util.Map;

 import java.util.Stack;

 import java.util.StringTokenizer;

 /**

  * @author <a href="mailto:jason@maven.org">Jason van Zyl</a>

  * @author <a href="mailto:brett@apache.org">Brett Porter</a>

  * @version $Id: DefaultLifecycleExecutor.java 728820 2008-12-22 22:58:16Z brett $

  * @todo because of aggregation, we ended up with cli-ish stuff in here (like line() and the project logging, without much of the event handling)

  */

 public class DefaultLifecycleExecutor

     extends AbstractLogEnabled

     implements LifecycleExecutor

 {

     // ----------------------------------------------------------------------

     // Components

     // ----------------------------------------------------------------------

     private PluginManager pluginManager;

     private ExtensionManager extensionManager;

     private List lifecycles;

     private ArtifactHandlerManager artifactHandlerManager;

     private List defaultReports;

     private Map phaseToLifecycleMap;

     // ----------------------------------------------------------------------

     //

     // ----------------------------------------------------------------------

     /**

      * Execute a task. Each task may be a phase in the lifecycle or the

      * execution of a mojo.

      *

      * @param session

      * @param rm

      * @param dispatcher

      */

     public void execute( MavenSession session, ReactorManager rm, EventDispatcher dispatcher )

         throws BuildFailureException, LifecycleExecutionException

     {

         // TODO: This is dangerous, particularly when it's just a collection of loose-leaf projects being built

         // within the same reactor (using an inclusion pattern to gather them up)...

         MavenProject rootProject = rm.getTopLevelProject();

         List goals = session.getGoals();

         if ( goals.isEmpty() && rootProject != null )

         {

             String goal = rootProject.getDefaultGoal();

             if ( goal != null )

             {

                 goals = Collections.singletonList( goal );

             }

         }

         if ( goals.isEmpty() )

         {

             throw new BuildFailureException( "\n\nYou must specify at least one goal. Try 'mvn install' to build or 'mvn --help' for options \nSee http://maven.apache.org for more information.\n\n" );

         }

         List taskSegments = segmentTaskListByAggregationNeeds( goals, session, rootProject );

         // TODO: probably don't want to do all this up front

         findExtensions( session );

         executeTaskSegments( taskSegments, rm, session, rootProject, dispatcher );

     }

     private void findExtensions( MavenSession session )

         throws LifecycleExecutionException

     {

         for ( Iterator i = session.getSortedProjects().iterator(); i.hasNext(); )

         {

             MavenProject project = (MavenProject) i.next();

             for ( Iterator j = project.getBuildExtensions().iterator(); j.hasNext(); )

             {

                 Extension extension = (Extension) j.next();

                 try

                 {

                     getLogger().debug( "Adding extension: " + extension );

                     extensionManager.addExtension( extension, project, session.getLocalRepository() );

                 }

                 catch ( PlexusContainerException e )

                 {

                     throw new LifecycleExecutionException( "Unable to initialise extensions", e );

                 }

                 catch ( ArtifactResolutionException e )

                 {

                     throw new LifecycleExecutionException( e.getMessage(), e );

                 }

                 catch ( ArtifactNotFoundException e )

                 {

                     throw new LifecycleExecutionException( e.getMessage(), e );

                 }

             }

             extensionManager.registerWagons();

             try

             {

                 Map handlers = findArtifactTypeHandlers( project, session.getSettings(), session.getLocalRepository() );

                 artifactHandlerManager.addHandlers( handlers );

             }

             catch ( PluginNotFoundException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

         }

     }

     private void executeTaskSegments( List taskSegments, ReactorManager rm, MavenSession session,

                                       MavenProject rootProject, EventDispatcher dispatcher )

         throws LifecycleExecutionException, BuildFailureException

     {

         for ( Iterator it = taskSegments.iterator(); it.hasNext(); )

         {

             TaskSegment segment = (TaskSegment) it.next();

             if ( segment.aggregate() )

             {

                 if ( !rm.isBlackListed( rootProject ) )

                 {

                     line();

                     getLogger().info( "Building " + rootProject.getName() );

                     getLogger().info( "  " + segment );

                     line();

                     // !! This is ripe for refactoring to an aspect.

                     // Event monitoring.

                     String event = MavenEvents.PROJECT_EXECUTION;

                     long buildStartTime = System.currentTimeMillis();

                     String target = rootProject.getId() + " ( " + segment + " )";

                     dispatcher.dispatchStart( event, target );

                     try

                     {

                         session.setCurrentProject( rootProject );

                         // only call once, with the top-level project (assumed to be provided as a parameter)...

                         for ( Iterator goalIterator = segment.getTasks().iterator(); goalIterator.hasNext(); )

                         {

                             String task = (String) goalIterator.next();

                             executeGoalAndHandleFailures( task, session, rootProject, dispatcher, event, rm, buildStartTime,

                                                           target );

                         }

                         rm.registerBuildSuccess( rootProject, System.currentTimeMillis() - buildStartTime );

                     }

                     finally

                     {

                         session.setCurrentProject( null );

                     }

                     dispatcher.dispatchEnd( event, target );

                 }

                 else

                 {

                     line();

                     getLogger().info( "SKIPPING " + rootProject.getName() );

                     getLogger().info( "  " + segment );

                     getLogger().info(

                         "This project has been banned from further executions due to previous failures." );

                     line();

                 }

             }

             else

             {

                 List sortedProjects = session.getSortedProjects();

                 // iterate over projects, and execute on each...

                 for ( Iterator projectIterator = sortedProjects.iterator(); projectIterator.hasNext(); )

                 {

                     MavenProject currentProject = (MavenProject) projectIterator.next();

                     if ( !rm.isBlackListed( currentProject ) )

                     {

                         line();

                         getLogger().info( "Building " + currentProject.getName() );

                         getLogger().info( "  " + segment );

                         line();

                         // !! This is ripe for refactoring to an aspect.

                         // Event monitoring.

                         String event = MavenEvents.PROJECT_EXECUTION;

                         long buildStartTime = System.currentTimeMillis();

                         String target = currentProject.getId() + " ( " + segment + " )";

                         dispatcher.dispatchStart( event, target );

                         try

                         {

                             session.setCurrentProject( currentProject );

                             for ( Iterator goalIterator = segment.getTasks().iterator(); goalIterator.hasNext(); )

                             {

                                 String task = (String) goalIterator.next();

                                 executeGoalAndHandleFailures( task, session, currentProject, dispatcher, event, rm,

                                                               buildStartTime, target );

                             }

                         }

                         finally

                         {

                             session.setCurrentProject( null );

                         }

                         rm.registerBuildSuccess( currentProject, System.currentTimeMillis() - buildStartTime );

                         dispatcher.dispatchEnd( event, target );

                     }

                     else

                     {

                         line();

                         getLogger().info( "SKIPPING " + currentProject.getName() );

                         getLogger().info( "  " + segment );

                         getLogger().info(

                             "This project has been banned from further executions due to previous failures." );

                         line();

                     }

                 }

             }

         }

     }

     private void executeGoalAndHandleFailures( String task, MavenSession session, MavenProject project,

                                                EventDispatcher dispatcher, String event, ReactorManager rm,

                                                long buildStartTime, String target )

         throws BuildFailureException, LifecycleExecutionException

     {

         try

         {

             executeGoal( task, session, project );

         }

         catch ( LifecycleExecutionException e )

         {

             dispatcher.dispatchError( event, target, e );

             if ( handleExecutionFailure( rm, project, e, task, buildStartTime ) )

             {

                 throw e;

             }

         }

         catch ( BuildFailureException e )

         {

             dispatcher.dispatchError( event, target, e );

             if ( handleExecutionFailure( rm, project, e, task, buildStartTime ) )

             {

                 throw e;

             }

         }

     }

     private boolean handleExecutionFailure( ReactorManager rm, MavenProject project, Exception e, String task,

                                             long buildStartTime )

     {

         rm.registerBuildFailure( project, e, task, System.currentTimeMillis() - buildStartTime );

         if ( ReactorManager.FAIL_FAST.equals( rm.getFailureBehavior() ) )

         {

             return true;

         }

         else if ( ReactorManager.FAIL_AT_END.equals( rm.getFailureBehavior() ) )

         {

             rm.blackList( project );

         }

         // if NEVER, don't blacklist

         return false;

     }

     private List segmentTaskListByAggregationNeeds( List tasks, MavenSession session, MavenProject project )

         throws LifecycleExecutionException, BuildFailureException

     {

         List segments = new ArrayList();

         if ( project != null )

         {

             TaskSegment currentSegment = null;

             for ( Iterator it = tasks.iterator(); it.hasNext(); )

             {

                 String task = (String) it.next();

                 // if it's a phase, then we don't need to check whether it's an aggregator.

                 // simply add it to the current task partition.

                 if ( getPhaseToLifecycleMap().containsKey( task ) )

                 {

                     if ( currentSegment != null && currentSegment.aggregate() )

                     {

                         segments.add( currentSegment );

                         currentSegment = null;

                     }

                     if ( currentSegment == null )

                     {

                         currentSegment = new TaskSegment();

                     }

                     currentSegment.add( task );

                 }

                 else

                 {

                     MojoDescriptor mojo = null;

                     try

                     {

                         // definitely a CLI goal, can use prefix

                         mojo = getMojoDescriptor( task, session, project, task, true, false );

                     }

                     catch ( PluginNotFoundException e )

                     {

                         // TODO: shouldn't hit this, investigate using the same resolution logic as otheres for plugins in the reactor

                         getLogger().info(

                             "Cannot find mojo descriptor for: \'" + task + "\' - Treating as non-aggregator." );

                         getLogger().debug( "", e );

                     }

                     // if the mojo descriptor was found, determine aggregator status according to:

                     // 1. whether the mojo declares itself an aggregator

                     // 2. whether the mojo DOES NOT require a project to function (implicitly avoid reactor)

                     if ( mojo != null && ( mojo.isAggregator() || !mojo.isProjectRequired() ) )

                     {

                         if ( currentSegment != null && !currentSegment.aggregate() )

                         {

                             segments.add( currentSegment );

                             currentSegment = null;

                         }

                         if ( currentSegment == null )

                         {

                             currentSegment = new TaskSegment( true );

                         }

                         currentSegment.add( task );

                     }

                     else

                     {

                         if ( currentSegment != null && currentSegment.aggregate() )

                         {

                             segments.add( currentSegment );

                             currentSegment = null;

                         }

                         if ( currentSegment == null )

                         {

                             currentSegment = new TaskSegment();

                         }

                         currentSegment.add( task );

                     }

                 }

             }

             segments.add( currentSegment );

         }

         else

         {

             TaskSegment segment = new TaskSegment( false );

             for ( Iterator i = tasks.iterator(); i.hasNext(); )

             {

                 segment.add( (String) i.next() );

             }

             segments.add( segment );

         }

         return segments;

     }

     private void executeGoal( String task, MavenSession session, MavenProject project )

         throws LifecycleExecutionException, BuildFailureException

     {

         try

         {

             Stack forkEntryPoints = new Stack();

             if ( getPhaseToLifecycleMap().containsKey( task ) )

             {

                 Lifecycle lifecycle = getLifecycleForPhase( task );

                 // we have a lifecycle phase, so lets bind all the necessary goals

                 Map lifecycleMappings = constructLifecycleMappings( session, task, project, lifecycle );

                 executeGoalWithLifecycle( task, forkEntryPoints, session, lifecycleMappings, project, lifecycle );

             }

             else

             {

                 executeStandaloneGoal( task, forkEntryPoints, session, project );

             }

         }

         catch ( PluginNotFoundException e )

         {

             throw new BuildFailureException( "A required plugin was not found: " + e.getMessage(), e );

         }

     }

     private void executeGoalWithLifecycle( String task, Stack forkEntryPoints, MavenSession session,

                                            Map lifecycleMappings, MavenProject project, Lifecycle lifecycle )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         List goals = processGoalChain( task, lifecycleMappings, lifecycle );

         if ( !goals.isEmpty() )

         {

             executeGoals( goals, forkEntryPoints, session, project );

         }

         else

         {

             getLogger().info( "No goals needed for project - skipping" );

         }

     }

     private void executeStandaloneGoal( String task, Stack forkEntryPoints, MavenSession session, MavenProject project )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         // guaranteed to come from the CLI and not be part of a phase

         MojoDescriptor mojoDescriptor = getMojoDescriptor( task, session, project, task, true, false );

         executeGoals( Collections.singletonList( new MojoExecution( mojoDescriptor ) ), forkEntryPoints, session,

                       project );

     }

     private void executeGoals( List goals, Stack forkEntryPoints, MavenSession session, MavenProject project )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         for ( Iterator i = goals.iterator(); i.hasNext(); )

         {

             MojoExecution mojoExecution = (MojoExecution) i.next();

             MojoDescriptor mojoDescriptor = mojoExecution.getMojoDescriptor();

             if ( mojoDescriptor.getExecutePhase() != null || mojoDescriptor.getExecuteGoal() != null )

             {

                 forkEntryPoints.push( mojoDescriptor );

                 forkLifecycle( mojoDescriptor, forkEntryPoints, session, project );

                 forkEntryPoints.pop();

             }

             if ( mojoDescriptor.isRequiresReports() )

             {

                 List reports = getReports( project, forkEntryPoints, mojoExecution, session );

                 mojoExecution.setReports( reports );

                 for ( Iterator j = mojoExecution.getForkedExecutions().iterator(); j.hasNext(); )

                 {

                     MojoExecution forkedExecution = (MojoExecution) j.next();

                     MojoDescriptor descriptor = forkedExecution.getMojoDescriptor();

                     if ( descriptor.getExecutePhase() != null )

                     {

                         forkEntryPoints.push( descriptor );

                         forkLifecycle( descriptor, forkEntryPoints, session, project );

                         forkEntryPoints.pop();

                     }

                 }

             }

             try

             {

                 pluginManager.executeMojo( project, mojoExecution, session );

             }

             catch ( PluginManagerException e )

             {

                 throw new LifecycleExecutionException( "Internal error in the plugin manager executing goal '" +

                     mojoDescriptor.getId() + "': " + e.getMessage(), e );

             }

             catch ( ArtifactNotFoundException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

             catch ( InvalidDependencyVersionException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

             catch ( ArtifactResolutionException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

             catch ( MojoFailureException e )

             {

                 throw new BuildFailureException( e.getMessage(), e );

             }

             catch ( MojoExecutionException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

             catch ( PluginConfigurationException e )

             {

                 throw new LifecycleExecutionException( e.getMessage(), e );

             }

         }

     }

     private List getReports( MavenProject project, Stack forkEntryPoints, MojoExecution mojoExecution, MavenSession session )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         List reportPlugins = project.getReportPlugins();

         if ( project.getModel().getReports() != null )

         {

             getLogger().error(

                 "Plugin contains a <reports/> section: this is IGNORED - please use <reporting/> instead." );

         }

         if ( project.getReporting() == null || !project.getReporting().isExcludeDefaults() )

         {

             if ( reportPlugins == null )

             {

                 reportPlugins = new ArrayList();

             }

             else

             {

                 reportPlugins = new ArrayList( reportPlugins );

             }

             for ( Iterator i = defaultReports.iterator(); i.hasNext(); )

             {

                 String report = (String) i.next();

                 StringTokenizer tok = new StringTokenizer( report, ":" );

                 int count = tok.countTokens();

                 if ( count != 2 && count != 3 )

                 {

                     getLogger().warn( "Invalid default report ignored: '" + report + "' (must be groupId:artifactId[:version])" );

                 }

                 else

                 {

                     String groupId = tok.nextToken();

                     String artifactId = tok.nextToken();

                     String version = tok.hasMoreTokens() ? tok.nextToken() : null;

                     boolean found = false;

                     for ( Iterator j = reportPlugins.iterator(); j.hasNext() && !found; )

                     {

                         ReportPlugin reportPlugin = (ReportPlugin) j.next();

                         if ( reportPlugin.getGroupId().equals( groupId ) &&

                             reportPlugin.getArtifactId().equals( artifactId ) )

                         {

                             found = true;

                         }

                     }

                     if ( !found )

                     {

                         ReportPlugin reportPlugin = new ReportPlugin();

                         reportPlugin.setGroupId( groupId );

                         reportPlugin.setArtifactId( artifactId );

                         reportPlugin.setVersion( version );

                         reportPlugins.add( reportPlugin );

                     }

                 }

             }

         }

         List reports = new ArrayList();

         if ( reportPlugins != null )

         {

             for ( Iterator it = reportPlugins.iterator(); it.hasNext(); )

             {

                 ReportPlugin reportPlugin = (ReportPlugin) it.next();

                 List reportSets = reportPlugin.getReportSets();

                 if ( reportSets == null || reportSets.isEmpty() )

                 {

                     reports.addAll( getReports( reportPlugin, forkEntryPoints, null, project, session, mojoExecution ) );

                 }

                 else

                 {

                     for ( Iterator j = reportSets.iterator(); j.hasNext(); )

                     {

                         ReportSet reportSet = (ReportSet) j.next();

                         reports.addAll( getReports( reportPlugin, forkEntryPoints, reportSet, project, session, mojoExecution ) );

                     }

                 }

             }

         }

         return reports;

     }

     private List getReports( ReportPlugin reportPlugin,

                              Stack forkEntryPoints,

                              ReportSet reportSet,

                              MavenProject project,

                              MavenSession session,

                              MojoExecution mojoExecution )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         PluginDescriptor pluginDescriptor = verifyReportPlugin( reportPlugin, project, session );

         List reports = new ArrayList();

         for ( Iterator i = pluginDescriptor.getMojos().iterator(); i.hasNext(); )

         {

             MojoDescriptor mojoDescriptor = (MojoDescriptor) i.next();

             if ( forkEntryPoints.contains( mojoDescriptor ) )

             {

                 getLogger().debug( "Omitting report: " + mojoDescriptor.getFullGoalName() + " from reports list. It initiated part of the fork currently executing." );

                 continue;

             }

             // TODO: check ID is correct for reports

             // if the POM configured no reports, give all from plugin

             if ( reportSet == null || reportSet.getReports().contains( mojoDescriptor.getGoal() ) )

             {

                 String id = null;

                 if ( reportSet != null )

                 {

                     id = reportSet.getId();

                 }

                 MojoExecution reportExecution = new MojoExecution( mojoDescriptor, id );

                 try

                 {

                     MavenReport reportMojo = pluginManager.getReport( project, reportExecution, session );

                     // Comes back null if it was a plugin, not a report - these are mojos in the reporting plugins that are not reports

                     if ( reportMojo != null )

                     {

                         reports.add( reportMojo );

                         mojoExecution.addMojoExecution( reportExecution );

                     }

                 }

                 catch ( PluginManagerException e )

                 {

                     throw new LifecycleExecutionException(

                         "Error getting reports from the plugin '" + reportPlugin.getKey() + "': " + e.getMessage(), e );

                 }

                 catch ( PluginConfigurationException e )

                 {

                     throw new LifecycleExecutionException(

                         "Error getting reports from the plugin '" + reportPlugin.getKey() + "'", e );

                 }

                 catch ( ArtifactNotFoundException e )

                 {

                     throw new LifecycleExecutionException( e.getMessage(), e );

                 }

                 catch ( ArtifactResolutionException e )

                 {

                     throw new LifecycleExecutionException( e.getMessage(), e );

                 }

             }

         }

         return reports;

     }

     private void forkLifecycle( MojoDescriptor mojoDescriptor, Stack ancestorLifecycleForkers, MavenSession session,

                                 MavenProject project )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         PluginDescriptor pluginDescriptor = mojoDescriptor.getPluginDescriptor();

         getLogger().info( "Preparing " + pluginDescriptor.getGoalPrefix() + ":" + mojoDescriptor.getGoal() );

         if ( mojoDescriptor.isAggregator() )

         {

             for ( Iterator i = session.getSortedProjects().iterator(); i.hasNext(); )

             {

                 MavenProject reactorProject = (MavenProject) i.next();

                 line();

                 getLogger().info( "Building " + reactorProject.getName() );

                 line();

                 forkProjectLifecycle( mojoDescriptor, ancestorLifecycleForkers, session, reactorProject );

             }

         }

         else

         {

             forkProjectLifecycle( mojoDescriptor, ancestorLifecycleForkers, session, project );

         }

     }

     private void forkProjectLifecycle( MojoDescriptor mojoDescriptor, Stack forkEntryPoints, MavenSession session,

                                        MavenProject project )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         forkEntryPoints.push( mojoDescriptor );

         PluginDescriptor pluginDescriptor = mojoDescriptor.getPluginDescriptor();

         String targetPhase = mojoDescriptor.getExecutePhase();

         Map lifecycleMappings = null;

         if ( targetPhase != null )

         {

             Lifecycle lifecycle = getLifecycleForPhase( targetPhase );

             // Create new lifecycle

             lifecycleMappings = constructLifecycleMappings( session, targetPhase, project, lifecycle );

             String executeLifecycle = mojoDescriptor.getExecuteLifecycle();

             if ( executeLifecycle != null )

             {

                 org.apache.maven.plugin.lifecycle.Lifecycle lifecycleOverlay;

                 try

                 {

                     lifecycleOverlay = pluginDescriptor.getLifecycleMapping( executeLifecycle );

                 }

                 catch ( IOException e )

                 {

                     throw new LifecycleExecutionException( "Unable to read lifecycle mapping file: " + e.getMessage(),

                                                            e );

                 }

                 catch ( XmlPullParserException e )

                 {

                     throw new LifecycleExecutionException( "Unable to parse lifecycle mapping file: " + e.getMessage(),

                                                            e );

                 }

                 if ( lifecycleOverlay == null )

                 {

                     throw new LifecycleExecutionException( "Lifecycle '" + executeLifecycle + "' not found in plugin" );

                 }

                 for ( Iterator i = lifecycleOverlay.getPhases().iterator(); i.hasNext(); )

                 {

                     Phase phase = (Phase) i.next();

                     for ( Iterator j = phase.getExecutions().iterator(); j.hasNext(); )

                     {

                         Execution exec = (Execution) j.next();

                         for ( Iterator k = exec.getGoals().iterator(); k.hasNext(); )

                         {

                             String goal = (String) k.next();

                             PluginDescriptor lifecyclePluginDescriptor;

                             String lifecycleGoal;

                             // Here we are looking to see if we have a mojo from an external plugin.

                             // If we do then we need to lookup the plugin descriptor for the externally

                             // referenced plugin so that we can overly the execution into the lifecycle.

                             // An example of this is the corbertura plugin that needs to call the surefire

                             // plugin in forking mode.

                             //

                             //<phase>

                             //  <id>test</id>

                             //  <executions>

                             //    <execution>

                             //      <goals>

                             //        <goal>org.apache.maven.plugins:maven-surefire-plugin:test</goal>

                             //      </goals>

                             //      <configuration>

                             //        <classesDirectory>${project.build.directory}/generated-classes/cobertura</classesDirectory>

                             //        <ignoreFailures>true</ignoreFailures>

                             //        <forkMode>once</forkMode>

                             //      </configuration>

                             //    </execution>

                             //  </executions>

                             //</phase>

                             // ----------------------------------------------------------------------

                             //

                             // ----------------------------------------------------------------------

                             if ( goal.indexOf( ":" ) > 0 )

                             {

                                 String[] s = StringUtils.split( goal, ":" );

                                 String groupId = s[0];

                                 String artifactId = s[1];

                                 lifecycleGoal = s[2];

                                 Plugin plugin = new Plugin();

                                 plugin.setGroupId( groupId );

                                 plugin.setArtifactId( artifactId );

                                 lifecyclePluginDescriptor = verifyPlugin( plugin, project, session.getSettings(),

                                                                           session.getLocalRepository() );

                                 if ( lifecyclePluginDescriptor == null )

                                 {

                                     throw new LifecycleExecutionException(

                                         "Unable to find plugin " + groupId + ":" + artifactId );

                                 }

                             }

                             else

                             {

                                 lifecyclePluginDescriptor = pluginDescriptor;

                                 lifecycleGoal = goal;

                             }

                             Xpp3Dom configuration = (Xpp3Dom) exec.getConfiguration();

                             if ( phase.getConfiguration() != null )

                             {

                                 configuration = Xpp3Dom.mergeXpp3Dom( new Xpp3Dom( (Xpp3Dom) phase.getConfiguration() ),

                                                                       configuration );

                             }

                             MojoDescriptor desc = getMojoDescriptor( lifecyclePluginDescriptor, lifecycleGoal );

                             MojoExecution mojoExecution = new MojoExecution( desc, configuration );

                             addToLifecycleMappings( lifecycleMappings, phase.getId(), mojoExecution,

                                                     session.getSettings() );

                         }

                     }

                     if ( phase.getConfiguration() != null )

                     {

                         // Merge in general configuration for a phase.

                         // TODO: this is all kind of backwards from the POMM. Let's align it all under 2.1.

                         //   We should create a new lifecycle executor for modelVersion >5.0.0

                         for ( Iterator j = lifecycleMappings.values().iterator(); j.hasNext(); )

                         {

                             List tasks = (List) j.next();

                             for ( Iterator k = tasks.iterator(); k.hasNext(); )

                             {

                                 MojoExecution exec = (MojoExecution) k.next();

                                 Xpp3Dom configuration = Xpp3Dom.mergeXpp3Dom(

                                     new Xpp3Dom( (Xpp3Dom) phase.getConfiguration() ), exec.getConfiguration() );

                                 exec.setConfiguration( configuration );

                             }

                         }

                     }

                 }

             }

             removeFromLifecycle( forkEntryPoints, lifecycleMappings );

         }

         MavenProject executionProject = new MavenProject( project );

         if ( targetPhase != null )

         {

             Lifecycle lifecycle = getLifecycleForPhase( targetPhase );

             executeGoalWithLifecycle( targetPhase, forkEntryPoints, session, lifecycleMappings, executionProject,

                                       lifecycle );

         }

         else

         {

             String goal = mojoDescriptor.getExecuteGoal();

             MojoDescriptor desc = getMojoDescriptor( pluginDescriptor, goal );

             executeGoals( Collections.singletonList( new MojoExecution( desc ) ), forkEntryPoints, session,

                           executionProject );

         }

         project.setExecutionProject( executionProject );

     }

     private Lifecycle getLifecycleForPhase( String phase )

         throws BuildFailureException, LifecycleExecutionException

     {

         Lifecycle lifecycle = (Lifecycle) getPhaseToLifecycleMap().get( phase );

         if ( lifecycle == null )

         {

             throw new BuildFailureException( "Unable to find lifecycle for phase '" + phase + "'" );

         }

         return lifecycle;

     }

     private MojoDescriptor getMojoDescriptor( PluginDescriptor pluginDescriptor, String goal )

         throws LifecycleExecutionException

     {

         MojoDescriptor desc = pluginDescriptor.getMojo( goal );

         if ( desc == null )

         {

             String message =

                 "Required goal '" + goal + "' not found in plugin '" + pluginDescriptor.getGoalPrefix() + "'";

             int index = goal.indexOf( ':' );

             if ( index >= 0 )

             {

                 String prefix = goal.substring( index + 1 );

                 if ( prefix.equals( pluginDescriptor.getGoalPrefix() ) )

                 {

                     message = message + " (goals should not be prefixed - try '" + prefix + "')";

                 }

             }

             throw new LifecycleExecutionException( message );

         }

         return desc;

     }

     private void removeFromLifecycle( Stack lifecycleForkers, Map lifecycleMappings )

     {

         for ( Iterator lifecycleIterator = lifecycleMappings.values().iterator(); lifecycleIterator.hasNext(); )

         {

             List tasks = (List) lifecycleIterator.next();

             for ( Iterator taskIterator = tasks.iterator(); taskIterator.hasNext(); )

             {

                 MojoExecution execution = (MojoExecution) taskIterator.next();

                 if ( lifecycleForkers.contains( execution.getMojoDescriptor() ) )

                 {

                     taskIterator.remove();

                     getLogger().warn( "Removing: " + execution.getMojoDescriptor().getGoal()

                                       + " from forked lifecycle, to prevent recursive invocation." );

                 }

             }

         }

     }

     private Map constructLifecycleMappings( MavenSession session, String selectedPhase, MavenProject project,

                                             Lifecycle lifecycle )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         // first, bind those associated with the packaging

         Map lifecycleMappings = bindLifecycleForPackaging( session, selectedPhase, project, lifecycle );

         // next, loop over plugins and for any that have a phase, bind it

         for ( Iterator i = project.getBuildPlugins().iterator(); i.hasNext(); )

         {

             Plugin plugin = (Plugin) i.next();

             bindPluginToLifecycle( plugin, session, lifecycleMappings, project );

         }

         return lifecycleMappings;

     }

     private Map bindLifecycleForPackaging( MavenSession session, String selectedPhase, MavenProject project,

                                            Lifecycle lifecycle )

         throws LifecycleExecutionException, BuildFailureException, PluginNotFoundException

     {

         Map mappings = findMappingsForLifecycle( session, project, lifecycle );

         List optionalMojos = findOptionalMojosForLifecycle( session, project, lifecycle );

         Map lifecycleMappings = new HashMap();

         for ( Iterator i = lifecycle.getPhases().iterator(); i.hasNext(); )

         {

             String phase = (String) i.next();

             String phaseTasks = (String) mappings.get( phase );

             if ( phaseTasks != null )

             {

                 for ( StringTokenizer tok = new StringTokenizer( phaseTasks, "," ); tok.hasMoreTokens(); )

                 {

                     String goal = tok.nextToken().trim();

                     // Not from the CLI, don't use prefix

                     MojoDescriptor mojoDescriptor = getMojoDescriptor( goal, session, project, selectedPhase, false,

                                                                        optionalMojos.contains( goal ) );

                     if ( mojoDescriptor == null )

                     {

                         continue;

                     }

                     if ( mojoDescriptor.isDirectInvocationOnly() )

                     {

                         throw new LifecycleExecutionException( "Mojo: \'" + goal +

                             "\' requires direct invocation. It cannot be used as part of lifecycle: \'" +

                             project.getPackaging() + "\'." );

                     }

                     addToLifecycleMappings( lifecycleMappings, phase, new MojoExecution( mojoDescriptor ),

                                             session.getSettings() );

                 }

             }

             if ( phase.equals( selectedPhase ) )

             {

                 break;

             }

         }

         return lifecycleMappings;

     }

     private Map findMappingsForLifecycle( MavenSession session, MavenProject project, Lifecycle lifecycle )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         String packaging = project.getPackaging();

         Map mappings = null;

         LifecycleMapping m = (LifecycleMapping) findExtension( project, LifecycleMapping.ROLE, packaging,

                                                                session.getSettings(), session.getLocalRepository() );

         if ( m != null )

         {

             mappings = m.getPhases( lifecycle.getId() );

         }

         Map defaultMappings = lifecycle.getDefaultPhases();

         if ( mappings == null )

         {

             try

             {

                 m = (LifecycleMapping) session.lookup( LifecycleMapping.ROLE, packaging );

                 mappings = m.getPhases( lifecycle.getId() );

             }

             catch ( ComponentLookupException e )

             {

                 if ( defaultMappings == null )

                 {

                     throw new LifecycleExecutionException(

                         "Cannot find lifecycle mapping for packaging: \'" + packaging + "\'.", e );

                 }

             }

         }

         if ( mappings == null )

         {

             if ( defaultMappings == null )

             {

                 throw new LifecycleExecutionException(

                     "Cannot find lifecycle mapping for packaging: \'" + packaging + "\', and there is no default" );

             }

             else

             {

                 mappings = defaultMappings;

             }

         }

         return mappings;

     }

     private List findOptionalMojosForLifecycle( MavenSession session, MavenProject project, Lifecycle lifecycle )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         String packaging = project.getPackaging();

         List optionalMojos = null;

         LifecycleMapping m = (LifecycleMapping) findExtension( project, LifecycleMapping.ROLE, packaging, session

             .getSettings(), session.getLocalRepository() );

         if ( m != null )

         {

             optionalMojos = m.getOptionalMojos( lifecycle.getId() );

         }

         if ( optionalMojos == null )

         {

             try

             {

                 m = (LifecycleMapping) session.lookup( LifecycleMapping.ROLE, packaging );

                 optionalMojos = m.getOptionalMojos( lifecycle.getId() );

             }

             catch ( ComponentLookupException e )

             {

                 getLogger().debug( "Error looking up lifecycle mapping to retrieve optional mojos. Lifecycle ID: " +

                     lifecycle.getId() + ". Error: " + e.getMessage(), e );

             }

         }

         if ( optionalMojos == null )

         {

             optionalMojos = Collections.EMPTY_LIST;

         }

         return optionalMojos;

     }

     private Object findExtension( MavenProject project, String role, String roleHint, Settings settings,

                                   ArtifactRepository localRepository )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         Object pluginComponent = null;

         for ( Iterator i = project.getBuildPlugins().iterator(); i.hasNext() && pluginComponent == null; )

         {

             Plugin plugin = (Plugin) i.next();

             if ( plugin.isExtensions() )

             {

                 verifyPlugin( plugin, project, settings, localRepository );

                 // TODO: if moved to the plugin manager we already have the descriptor from above and so do can lookup the container directly

                 try

                 {

                     pluginComponent = pluginManager.getPluginComponent( plugin, role, roleHint );

                 }

                 catch ( ComponentLookupException e )

                 {

                     getLogger().debug( "Unable to find the lifecycle component in the extension", e );

                 }

                 catch ( PluginManagerException e )

                 {

                     throw new LifecycleExecutionException(

                         "Error getting extensions from the plugin '" + plugin.getKey() + "': " + e.getMessage(), e );

                 }

             }

         }

         return pluginComponent;

     }

     /**

      * @todo Not particularly happy about this. Would like WagonManager and ArtifactTypeHandlerManager to be able to

      * lookup directly, or have them passed in

      */

     private Map findArtifactTypeHandlers( MavenProject project, Settings settings, ArtifactRepository localRepository )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         Map map = new HashMap();

         for ( Iterator i = project.getBuildPlugins().iterator(); i.hasNext(); )

         {

             Plugin plugin = (Plugin) i.next();

             if ( plugin.isExtensions() )

             {

                 verifyPlugin( plugin, project, settings, localRepository );

                 // TODO: if moved to the plugin manager we already have the descriptor from above and so do can lookup the container directly

                 try

                 {

                     Map components = pluginManager.getPluginComponents( plugin, ArtifactHandler.ROLE );

                     map.putAll( components );

                 }

                 catch ( ComponentLookupException e )

                 {

                     getLogger().debug( "Unable to find the lifecycle component in the extension", e );

                 }

                 catch ( PluginManagerException e )

                 {

                     throw new LifecycleExecutionException( "Error looking up available components from plugin '" +

                         plugin.getKey() + "': " + e.getMessage(), e );

                 }

                 // shudder...

                 for ( Iterator j = map.values().iterator(); j.hasNext(); )

                 {

                     ArtifactHandler handler = (ArtifactHandler) j.next();

                     if ( project.getPackaging().equals( handler.getPackaging() ) )

                     {

                         project.getArtifact().setArtifactHandler( handler );

                     }

                 }

             }

         }

         return map;

     }

     /**

      * Take each mojo contained with a plugin, look to see whether it contributes to a

      * phase in the lifecycle and if it does place it at the end of the list of goals

      * to execute for that given phase.

      *

      * @param project

      * @param session

      */

     private void bindPluginToLifecycle( Plugin plugin, MavenSession session, Map phaseMap, MavenProject project )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         Settings settings = session.getSettings();

         PluginDescriptor pluginDescriptor =

             verifyPlugin( plugin, project, session.getSettings(), session.getLocalRepository() );

         if ( pluginDescriptor.getMojos() != null && !pluginDescriptor.getMojos().isEmpty() )

         {

             // use the plugin if inherit was true in a base class, or it is in the current POM, otherwise use the default inheritence setting

             if ( plugin.isInheritanceApplied() || pluginDescriptor.isInheritedByDefault() )

             {

                 if ( plugin.getGoals() != null )

                 {

                     getLogger().error(

                         "Plugin contains a <goals/> section: this is IGNORED - please use <executions/> instead." );

                 }

                 List executions = plugin.getExecutions();

                 if ( executions != null )

                 {

                     for ( Iterator it = executions.iterator(); it.hasNext(); )

                     {

                         PluginExecution execution = (PluginExecution) it.next();

                         bindExecutionToLifecycle( pluginDescriptor, phaseMap, execution, settings );

                     }

                 }

             }

         }

     }

     private PluginDescriptor verifyPlugin( Plugin plugin, MavenProject project, Settings settings,

                                            ArtifactRepository localRepository )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         PluginDescriptor pluginDescriptor;

         try

         {

             pluginDescriptor = pluginManager.verifyPlugin( plugin, project, settings, localRepository );

         }

         catch ( PluginManagerException e )

         {

             throw new LifecycleExecutionException(

                 "Internal error in the plugin manager getting plugin '" + plugin.getKey() + "': " + e.getMessage(), e );

         }

         catch ( PluginVersionResolutionException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         catch ( InvalidVersionSpecificationException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         catch ( InvalidPluginException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         catch ( ArtifactNotFoundException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         catch ( ArtifactResolutionException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         catch ( PluginVersionNotFoundException e )

         {

             throw new LifecycleExecutionException( e.getMessage(), e );

         }

         return pluginDescriptor;

     }

     private PluginDescriptor verifyReportPlugin( ReportPlugin plugin, MavenProject project, MavenSession session )

         throws LifecycleExecutionException, PluginNotFoundException

     {

         PluginDescriptor pluginDescriptor;

         try