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