package org.apache.maven.continuum.scm.queue;
   
   /*
    * 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.continuum.dao.ProjectDao;
  import org.apache.continuum.taskqueue.CheckOutTask;
  import org.apache.maven.continuum.core.action.AbstractContinuumAction;
  import org.apache.maven.continuum.core.action.CheckoutProjectContinuumAction;
  import org.apache.maven.continuum.model.project.Project;
  import org.apache.maven.continuum.store.ContinuumStoreException;
  import org.codehaus.plexus.action.ActionManager;
  import org.codehaus.plexus.taskqueue.Task;
  import org.codehaus.plexus.taskqueue.execution.TaskExecutionException;
  import org.codehaus.plexus.taskqueue.execution.TaskExecutor;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import java.util.HashMap;
  import java.util.Map;
  
  /**
   * @author <a href="mailto:trygvis@inamo.no">Trygve Laugst&oslash;l</a>
   * @version $Id: CheckOutTaskExecutor.java 1372260 2012-08-13 04:29:09Z brett $
   * @plexus.component role="org.codehaus.plexus.taskqueue.execution.TaskExecutor"
   * role-hint="check-out-project" instantiation-strategy="per-lookup"
   */
  public class CheckOutTaskExecutor
      implements TaskExecutor
  {
      private static final Logger log = LoggerFactory.getLogger( CheckOutTaskExecutor.class );
  
      /**
       * @plexus.requirement
       */
      private ActionManager actionManager;
  
      /**
       * @plexus.requirement
       */
      private ProjectDao projectDao;
  
      // ----------------------------------------------------------------------
      // TaskExecutor Implementation
      // ----------------------------------------------------------------------
  
      public void executeTask( Task t )
          throws TaskExecutionException
      {
          log.info( "Checkout task executor.." );
  
          CheckOutTask task = (CheckOutTask) t;
  
          int projectId = task.getProjectId();
  
          Project project;
  
          try
          {
              project = projectDao.getProjectWithBuildDetails( projectId );
          }
          catch ( ContinuumStoreException ex )
          {
              log.error( "Internal error while getting the project.", ex );
  
              return;
          }
  
          String workingDirectory = task.getWorkingDirectory().getAbsolutePath();
  
          Map<String, Object> context = new HashMap<String, Object>();
  
          AbstractContinuumAction.setProjectId( context, projectId );
  
          AbstractContinuumAction.setProject( context, project );
  
          AbstractContinuumAction.setWorkingDirectory( context, workingDirectory );
  
          CheckoutProjectContinuumAction.setScmUsername( context, task.getScmUserName() );
  
          CheckoutProjectContinuumAction.setScmPassword( context, task.getScmPassword() );
  
          AbstractContinuumAction.setProjectScmRootUrl( context, task.getScmRootUrl() );
 
         AbstractContinuumAction.setListOfProjectsInGroupWithCommonScmRoot( context,
                                                                            task.getProjectsWithCommonScmRoot() );
 
         try
         {
             actionManager.lookup( "checkout-project" ).execute( context );
 
             actionManager.lookup( "store-checkout-scm-result" ).execute( context );
         }
         catch ( Exception e )
         {
             throw new TaskExecutionException( "Error checking out project.", e );
         }
     }
 }