package org.apache.maven.archiva.policies;

 /*

  * 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 java.io.File;

 import java.util.ArrayList;

 import java.util.List;

 import java.util.Map;

 import java.util.Properties;

 import org.apache.commons.lang.StringUtils;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 /**

  * PropagateErrorsPolicy - a policy applied on error to determine how to treat the error.

  *

  * @plexus.component role="org.apache.maven.archiva.policies.DownloadErrorPolicy"

  * role-hint="propagate-errors"

  */

 public class PropagateErrorsDownloadPolicy

     implements DownloadErrorPolicy

 {

     private Logger log = LoggerFactory.getLogger( PropagateErrorsDownloadPolicy.class );

     /**

      * Signifies any error should stop searching for other proxies.

      */

     public static final String STOP = "stop";

     /**

      * Propagate errors at the end after all are gathered, if there was no successful download from other proxies.

      */

     public static final String QUEUE = "queue error";

     /**

      * Ignore errors and treat as if it were not found.

      */

     public static final String IGNORE = "ignore";

     private List<String> options = new ArrayList<String>();

     public PropagateErrorsDownloadPolicy()

     {

         options.add( STOP );

         options.add( QUEUE );

         options.add( IGNORE );

     }

     public boolean applyPolicy( String policySetting, Properties request, File localFile, Exception exception,

                                 Map<String, Exception> previousExceptions )

         throws PolicyConfigurationException

     {

         if ( !options.contains( policySetting ) )

         {

             // Not a valid code.

             throw new PolicyConfigurationException( "Unknown error policy setting [" + policySetting +

                 "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );

         }

         if ( IGNORE.equals( policySetting ) )

         {

             // Ignore.

             log.debug( "Error policy set to IGNORE." );

             return false;

         }

         String repositoryId = request.getProperty( "remoteRepositoryId" );

         if ( STOP.equals( policySetting ) )

         {

             return true;

         }

         if ( QUEUE.equals( policySetting ) )

         {

             previousExceptions.put( repositoryId, exception );

             return true;

         }

         throw new PolicyConfigurationException(

             "Unable to process checksum policy of [" + policySetting + "], please file a bug report." );

     }

     public String getDefaultOption()

     {

         return QUEUE;

     }

     public String getId()

     {

         return "propagate-errors";

     }

     public String getName()

     {

         return "On remote error";

     }

     public List<String> getOptions()

     {

         return options;

     }

 }