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

   1 package org.apache.archiva.consumers.core;
   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.archiva.common.plexusbridge.DigesterUtils;
  23 import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
  24 import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
  25 import org.apache.archiva.consumers.AbstractMonitoredConsumer;
  26 import org.apache.archiva.consumers.ConsumerException;
  27 import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
  28 import org.apache.archiva.repository.ManagedRepository;
  29 import org.codehaus.plexus.digest.ChecksumFile;
  30 import org.codehaus.plexus.digest.Digester;
  31 import org.codehaus.plexus.digest.DigesterException;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34 import org.springframework.context.annotation.Scope;
  35 import org.springframework.stereotype.Service;
  36
  37 import javax.annotation.PostConstruct;
  38 import javax.inject.Inject;
  39 import java.io.FileNotFoundException;
  40 import java.io.IOException;
  41 import java.nio.file.Path;
  42 import java.nio.file.Paths;
  43 import java.util.ArrayList;
  44 import java.util.Date;
  45 import java.util.List;
  46
  47 /**
  48  * ValidateChecksumConsumer - validate the provided checksum against the file it represents.
  49  */
  50 @Service( "knownRepositoryContentConsumer#validate-checksums" )
  51 @Scope( "prototype" )
  52 public class ValidateChecksumConsumer
  53     extends AbstractMonitoredConsumer
  54     implements KnownRepositoryContentConsumer
  55 {
  56     private Logger log = LoggerFactory.getLogger( ValidateChecksumConsumer.class );
  57
  58     private static final String NOT_VALID_CHECKSUM = "checksum-not-valid";
  59
  60     private static final String CHECKSUM_NOT_FOUND = "checksum-not-found";
  61
  62     private static final String CHECKSUM_DIGESTER_FAILURE = "checksum-digester-failure";
  63
  64     private static final String CHECKSUM_IO_ERROR = "checksum-io-error";
  65
  66     private String id = "validate-checksums";
  67
  68     private String description = "Validate checksums against file.";
  69
  70     private ChecksumFile checksum;
  71
  72     private List<Digester> allDigesters;
  73
  74     @Inject
  75     private PlexusSisuBridge plexusSisuBridge;
  76
  77     @Inject
  78     private DigesterUtils digesterUtils;
  79
  80     private Path repositoryDir;
  81
  82     private List<String> includes;
  83
  84     @Override
  85     public String getId( )
  86     {
  87         return this.id;
  88     }
  89
  90     @Override
  91     public String getDescription( )
  92     {
  93         return this.description;
  94     }
  95
  96     @Override
  97     public void beginScan( ManagedRepository repository, Date whenGathered )
  98         throws ConsumerException
  99     {
 100         this.repositoryDir = Paths.get( repository.getLocation( ) );
 101     }
 102
 103     @Override
 104     public void beginScan( ManagedRepository repository, Date whenGathered, boolean executeOnEntireRepo )
 105         throws ConsumerException
 106     {
 107         beginScan( repository, whenGathered );
 108     }
 109
 110     @Override
 111     public void completeScan( )
 112     {
 113         /* nothing to do */
 114     }
 115
 116     @Override
 117     public void completeScan( boolean executeOnEntireRepo )
 118     {
 119         completeScan( );
 120     }
 121
 122     @Override
 123     public List<String> getExcludes( )
 124     {
 125         return null;
 126     }
 127
 128     @Override
 129     public List<String> getIncludes( )
 130     {
 131         return this.includes;
 132     }
 133
 134     @Override
 135     public void processFile( String path )
 136         throws ConsumerException
 137     {
 138         Path checksumFile = this.repositoryDir.resolve( path );
 139         try
 140         {
 141             if ( !checksum.isValidChecksum( checksumFile.toFile() ) )
 142             {
 143                 log.warn( "The checksum for {} is invalid.", checksumFile );
 144                 triggerConsumerWarning( NOT_VALID_CHECKSUM, "The checksum for " + checksumFile + " is invalid." );
 145             }
 146         }
 147         catch ( FileNotFoundException e )
 148         {
 149             log.error( "File not found during checksum validation: ", e );
 150             triggerConsumerError( CHECKSUM_NOT_FOUND, "File not found during checksum validation: " + e.getMessage( ) );
 151         }
 152         catch ( DigesterException e )
 153         {
 154             log.error( "Digester failure during checksum validation on {}", checksumFile );
 155             triggerConsumerError( CHECKSUM_DIGESTER_FAILURE,
 156                 "Digester failure during checksum validation on " + checksumFile );
 157         }
 158         catch ( IOException e )
 159         {
 160             log.error( "Checksum I/O error during validation on {}", checksumFile );
 161             triggerConsumerError( CHECKSUM_IO_ERROR, "Checksum I/O error during validation on " + checksumFile );
 162         }
 163     }
 164
 165     @Override
 166     public void processFile( String path, boolean executeOnEntireReDpo )
 167         throws Exception
 168     {
 169         processFile( path );
 170     }
 171
 172     @PostConstruct
 173     public void initialize( )
 174         throws PlexusSisuBridgeException
 175     {
 176         checksum = plexusSisuBridge.lookup( ChecksumFile.class );
 177         List<Digester> allDigesters = new ArrayList<>( digesterUtils.getAllDigesters( ) );
 178         includes = new ArrayList<>( allDigesters.size( ) );
 179         for ( Digester digester : allDigesters )
 180         {
 181             includes.add( "**/*" + digester.getFilenameExtension( ) );
 182         }
 183     }
 184 }