package org.apache.maven.archiva.consumers.core;

 /*

  * 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.commons.collections.CollectionUtils;

 import org.apache.commons.lang.StringUtils;

 import org.apache.maven.archiva.configuration.ArchivaConfiguration;

 import org.apache.maven.archiva.configuration.ConfigurationNames;

 import org.apache.maven.archiva.configuration.FileTypes;

 import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;

 import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer;

 import org.apache.maven.archiva.consumers.ConsumerException;

 import org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer;

 import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;

 import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;

 import org.codehaus.plexus.registry.Registry;

 import org.codehaus.plexus.registry.RegistryListener;

 import java.io.File;

 import java.util.ArrayList;

 import java.util.Date;

 import java.util.List;

 /**

  * AutoRemoveConsumer

  *

  * @version $Id: AutoRemoveConsumer.java 1041824 2010-12-03 14:11:05Z brett $

  * @plexus.component role="org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer"

  * role-hint="auto-remove"

  * instantiation-strategy="per-lookup"

  */

 public class AutoRemoveConsumer

     extends AbstractMonitoredConsumer

     implements KnownRepositoryContentConsumer, RegistryListener, Initializable

 {

     /**

      * @plexus.configuration default-value="auto-remove"

      */

     private String id;

     /**

      * @plexus.configuration default-value="Automatically Remove File from Filesystem."

      */

     private String description;

     /**

      * @plexus.requirement

      */

     private ArchivaConfiguration configuration;

     /**

      * @plexus.requirement

      */

     private FileTypes filetypes;

     private File repositoryDir;

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

     public String getId()

     {

         return this.id;

     }

     public String getDescription()

     {

         return this.description;

     }

     public boolean isPermanent()

     {

         return false;

     }

     public void beginScan( ManagedRepositoryConfiguration repository, Date whenGathered )

         throws ConsumerException

     {

         this.repositoryDir = new File( repository.getLocation() );

     }

     public void beginScan( ManagedRepositoryConfiguration repository, Date whenGathered, boolean executeOnEntireRepo )

         throws ConsumerException

     {

         beginScan( repository, whenGathered );

     }

     public void completeScan()

     {

         /* do nothing */

     }

     public void completeScan( boolean executeOnEntireRepo )

     {

         completeScan();

     }

     public List<String> getExcludes()

     {

         return null;

     }

     public List<String> getIncludes()

     {

         return includes;

     }

     public void processFile( String path )

         throws ConsumerException

     {

         File file = new File( this.repositoryDir, path );

         if ( file.exists() )

         {

             triggerConsumerInfo( "(Auto) Removing File: " + file.getAbsolutePath() );

             file.delete();

         }

     }

     public void processFile( String path, boolean executeOnEntireRepo )

         throws ConsumerException

     {

         processFile( path );    

     }

     public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue )

     {                

         if ( ConfigurationNames.isRepositoryScanning( propertyName ) )

         {

             initIncludes();

         }

     }

     public void beforeConfigurationChange( Registry registry, String propertyName, Object propertyValue )

     {

         /* do nothing */

     }

     private void initIncludes()

     {

         includes.clear();

         includes.addAll( filetypes.getFileTypePatterns( FileTypes.AUTO_REMOVE ) );

     }

     public void initialize()

         throws InitializationException

     {     

         configuration.addChangeListener( this );

         initIncludes();

     }

 }