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

   1 package org.apache.maven.archiva.repository.scanner.functors;
   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.collections.Predicate;
  23 import org.apache.maven.archiva.common.utils.BaseFile;
  24 import org.apache.maven.archiva.consumers.RepositoryContentConsumer;
  25 import org.codehaus.plexus.util.SelectorUtils;
  26 import org.codehaus.plexus.util.StringUtils;
  27
  28 import java.util.List;
  29
  30 /**
  31  * ConsumerWantsFilePredicate
  32  *
  33  * @author <a href="mailto:joakime@apache.org">Joakim Erdfelt</a>
  34  * @version $Id$
  35  */
  36 public class ConsumerWantsFilePredicate
  37     implements Predicate
  38 {
  39     private BaseFile basefile;
  40
  41     private boolean isCaseSensitive = true;
  42
  43     private int wantedFileCount = 0;
  44
  45     private long changesSince = 0;
  46
  47     public boolean evaluate( Object object )
  48     {
  49         boolean satisfies = false;
  50
  51         if ( object instanceof RepositoryContentConsumer )
  52         {
  53             RepositoryContentConsumer consumer = (RepositoryContentConsumer) object;
  54             if ( wantsFile( consumer, StringUtils.replace( basefile.getRelativePath(), "\\", "/" ) ) )
  55             {
  56                 satisfies = true;
  57
  58                 // regardless of the timestamp, we record that it was wanted so it doesn't get counted as invalid
  59                 wantedFileCount++;
  60
  61                 if ( !consumer.isProcessUnmodified() )
  62                 {
  63                     // Timestamp finished points to the last successful scan, not this current one.
  64                     if ( basefile.lastModified() < changesSince )
  65                     {
  66                         // Skip file as no change has occured.
  67                         satisfies = false;
  68                     }
  69                 }
  70             }
  71         }
  72
  73         return satisfies;
  74     }
  75
  76     public BaseFile getBasefile()
  77     {
  78         return basefile;
  79     }
  80
  81     public int getWantedFileCount()
  82     {
  83         return wantedFileCount;
  84     }
  85
  86     public boolean isCaseSensitive()
  87     {
  88         return isCaseSensitive;
  89     }
  90
  91     public void setBasefile( BaseFile basefile )
  92     {
  93         this.basefile = basefile;
  94         this.wantedFileCount = 0;
  95     }
  96
  97     public void setCaseSensitive( boolean isCaseSensitive )
  98     {
  99         this.isCaseSensitive = isCaseSensitive;
 100     }
 101
 102     private boolean wantsFile( RepositoryContentConsumer consumer, String relativePath )
 103     {
 104         // Test excludes first.
 105         List<String> excludes = consumer.getExcludes();
 106         if ( excludes != null )
 107         {
 108             for ( String pattern : excludes )
 109             {
 110                 if ( SelectorUtils.matchPath( pattern, relativePath, isCaseSensitive ) )
 111                 {
 112                     // Definately does NOT WANT FILE.
 113                     return false;
 114                 }
 115             }
 116         }
 117
 118         // Now test includes.
 119         for ( String pattern : consumer.getIncludes() )
 120         {
 121             if ( SelectorUtils.matchPath( pattern, relativePath, isCaseSensitive ) )
 122             {
 123                 // Specifically WANTS FILE.
 124                 return true;
 125             }
 126         }
 127
 128         // Not included, and Not excluded?  Default to EXCLUDE.
 129         return false;
 130     }
 131
 132     public void setChangesSince( long changesSince )
 133     {
 134         this.changesSince = changesSince;
 135     }
 136 }