source.dussan.org Git - archiva.git/blob

   1 package org.apache.maven.archiva.repository.scanner;
   2
   3 /*
   4  * Licensed to the Apache Software Foundation (ASF) under one
   5  * or more contributor license agreements.  See the NOTICE file
   6  * distributed with this work for additional information
   7  * regarding copyright ownership.  The ASF licenses this file
   8  * to you under the Apache License, Version 2.0 (the
   9  * "License"); you may not use this file except in compliance
  10  * with the License.  You may obtain a copy of the License at
  11  *
  12  *  http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing,
  15  * software distributed under the License is distributed on an
  16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  17  * KIND, either express or implied.  See the License for the
  18  * specific language governing permissions and limitations
  19  * under the License.
  20  */
  21
  22 import org.apache.commons.lang.SystemUtils;
  23 import org.apache.maven.archiva.common.utils.BaseFile;
  24 import org.apache.maven.archiva.consumers.Consumer;
  25 import org.apache.maven.archiva.model.ArchivaRepository;
  26 import org.apache.maven.archiva.model.RepositoryContentStatistics;
  27 import org.apache.maven.artifact.repository.ArtifactRepository;
  28 import org.codehaus.plexus.util.DirectoryWalkListener;
  29 import org.codehaus.plexus.util.SelectorUtils;
  30 import org.codehaus.plexus.util.StringUtils;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 import java.io.File;
  35 import java.util.Iterator;
  36 import java.util.List;
  37
  38 /**
  39  * RepositoryScannerInstance
  40  *
  41  * @author <a href="mailto:joakim@erdfelt.com">Joakim Erdfelt</a>
  42  * @version $Id$
  43  */
  44 public class RepositoryScannerInstance implements DirectoryWalkListener
  45 {
  46     private static Logger log = LoggerFactory.getLogger( RepositoryScannerInstance.class );
  47
  48     private List consumers;
  49
  50     private ArchivaRepository repository;
  51
  52     private boolean isCaseSensitive = true;
  53
  54     private RepositoryContentStatistics stats;
  55
  56     private long onlyModifiedAfterTimestamp = 0;
  57
  58     public RepositoryScannerInstance( ArchivaRepository repository, List consumerList )
  59     {
  60         this.repository = repository;
  61         this.consumers = consumerList;
  62         stats = new RepositoryContentStatistics();
  63         stats.setRepositoryId( repository.getId() );
  64
  65
  66         Iterator it = this.consumers.iterator();
  67         while ( it.hasNext() )
  68         {
  69             Consumer consumer = (Consumer) it.next();
  70
  71             if ( !consumer.init( this.repository ) )
  72             {
  73                 throw new IllegalStateException( "Consumer [" + consumer.getName() +
  74                     "] is reporting that it is incompatible with the [" + repository.getId() + "] repository." );
  75             }
  76         }
  77
  78         if ( SystemUtils.IS_OS_WINDOWS )
  79         {
  80             isCaseSensitive = false;
  81         }
  82     }
  83
  84     public RepositoryContentStatistics getStatistics()
  85     {
  86         return stats;
  87     }
  88
  89     public void directoryWalkStarting( File basedir )
  90     {
  91         log.info( "Walk Started: [" + this.repository.getId() + "] " + this.repository.getRepositoryURL() );
  92         stats.triggerStart();
  93     }
  94
  95     public void directoryWalkStep( int percentage, File file )
  96     {
  97         log.debug( "Walk Step: " + percentage + ", " + file );
  98
  99         stats.increaseFileCount();
 100
 101         // Timestamp finished points to the last successful scan, not this current one.
 102         if ( file.lastModified() < onlyModifiedAfterTimestamp )
 103         {
 104             // Skip file as no change has occured.
 105             log.debug( "Skipping, No Change: " + file.getAbsolutePath() );
 106             return;
 107         }
 108
 109         synchronized ( consumers )
 110         {
 111             stats.increaseNewFileCount();
 112
 113             BaseFile basefile = new BaseFile( repository.getRepositoryURL().getPath(), file );
 114
 115             Iterator itConsumers = this.consumers.iterator();
 116             while ( itConsumers.hasNext() )
 117             {
 118                 Consumer consumer = (Consumer) itConsumers.next();
 119
 120                 if ( wantsFile( consumer, StringUtils.replace( basefile.getRelativePath(), "\\", "/" ) ) )
 121                 {
 122                     try
 123                     {
 124                         log.debug( "Sending to consumer: " + consumer.getName() );
 125                         consumer.processFile( basefile );
 126                     }
 127                     catch ( Exception e )
 128                     {
 129                         /* Intentionally Catch all exceptions.
 130                          * So that the discoverer processing can continue.
 131                          */
 132                         log.error( "Consumer [" + consumer.getName() + "] had an error when processing file [" +
 133                             basefile.getAbsolutePath() + "]: " + e.getMessage(), e );
 134                     }
 135                 }
 136                 else
 137                 {
 138                     log.debug(
 139                         "Skipping consumer " + consumer.getName() + " for file " + basefile.getRelativePath() );
 140                 }
 141             }
 142         }
 143     }
 144
 145     public void directoryWalkFinished()
 146     {
 147         log.info( "Walk Finished: [" + this.repository.getId() + "] " + this.repository.getRepositoryURL() );
 148         stats.triggerFinished();
 149     }
 150
 151     private boolean wantsFile( Consumer consumer, String relativePath )
 152     {
 153         Iterator it;
 154
 155         // Test excludes first.
 156         it = consumer.getExcludePatterns().iterator();
 157         while ( it.hasNext() )
 158         {
 159             String pattern = (String) it.next();
 160             if ( SelectorUtils.matchPath( pattern, relativePath, isCaseSensitive ) )
 161             {
 162                 // Definately does NOT WANT FILE.
 163                 return false;
 164             }
 165         }
 166
 167         // Now test includes.
 168         it = consumer.getIncludePatterns().iterator();
 169         while ( it.hasNext() )
 170         {
 171             String pattern = (String) it.next();
 172             if ( SelectorUtils.matchPath( pattern, relativePath, isCaseSensitive ) )
 173             {
 174                 // Specifically WANTS FILE.
 175                 return true;
 176             }
 177         }
 178
 179         // Not included, and Not excluded?  Default to EXCLUDE.
 180         return false;
 181     }
 182
 183     public long getOnlyModifiedAfterTimestamp()
 184     {
 185         return onlyModifiedAfterTimestamp;
 186     }
 187
 188     public void setOnlyModifiedAfterTimestamp( long onlyModifiedAfterTimestamp )
 189     {
 190         this.onlyModifiedAfterTimestamp = onlyModifiedAfterTimestamp;
 191     }
 192
 193     /**
 194      * Debug method from DirectoryWalker.
 195      */
 196     public void debug( String message )
 197     {
 198         log.debug( "Repository Scanner: " + message );
 199     }
 200 }