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

   1 package org.apache.maven.archiva.consumers.core.repository;
   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.audit.AuditEvent;
  23 import org.apache.archiva.repository.events.RepositoryListener;
  24 import org.apache.maven.archiva.model.ArtifactReference;
  25 import org.apache.maven.archiva.repository.ManagedRepositoryContent;
  26 import org.slf4j.Logger;
  27 import org.slf4j.LoggerFactory;
  28
  29 import java.io.File;
  30 import java.io.FilenameFilter;
  31 import java.util.List;
  32 import java.util.Set;
  33
  34 /**
  35  * Base class for all repository purge tasks.
  36  */
  37 public abstract class AbstractRepositoryPurge
  38     implements RepositoryPurge
  39 {
  40     protected Logger log = LoggerFactory.getLogger( AbstractRepositoryPurge.class );
  41
  42     protected final ManagedRepositoryContent repository;
  43
  44     protected final List<RepositoryListener> listeners;
  45
  46     private Logger logger = LoggerFactory.getLogger( "org.apache.archiva.AuditLog" );
  47
  48     private static final char DELIM = ' ';
  49
  50     public AbstractRepositoryPurge( ManagedRepositoryContent repository, List<RepositoryListener> listeners )
  51     {
  52         this.repository = repository;
  53         this.listeners = listeners;
  54     }
  55
  56     /**
  57      * Purge the repo. Update db and index of removed artifacts.
  58      *
  59      * @param references
  60      */
  61     protected void purge( Set<ArtifactReference> references )
  62     {
  63         if ( references != null && !references.isEmpty() )
  64         {
  65             for ( ArtifactReference reference : references )
  66             {
  67                 File artifactFile = repository.toFile( reference );
  68
  69                 // FIXME: looks incomplete, might not delete related metadata?
  70                 for ( RepositoryListener listener : listeners )
  71                 {
  72                     listener.deleteArtifact( repository.getId(), reference.getGroupId(), reference.getArtifactId(),
  73                                              reference.getVersion(), artifactFile.getName() );
  74                 }
  75
  76                 // TODO: this needs to be logged
  77                 artifactFile.delete();
  78                 triggerAuditEvent( repository.getRepository().getId(), ArtifactReference.toKey( reference ),
  79                                    AuditEvent.PURGE_ARTIFACT );
  80                 purgeSupportFiles( artifactFile );
  81             }
  82         }
  83     }
  84
  85     /**
  86      * <p>
  87      * This find support files for the artifactFile and deletes them.
  88      * </p>
  89      * <p>
  90      * Support Files are things like ".sha1", ".md5", ".asc", etc.
  91      * </p>
  92      *
  93      * @param artifactFile the file to base off of.
  94      */
  95     private void purgeSupportFiles( File artifactFile )
  96     {
  97         File parentDir = artifactFile.getParentFile();
  98
  99         if ( !parentDir.exists() )
 100         {
 101             return;
 102         }
 103
 104         FilenameFilter filter = new ArtifactFilenameFilter( artifactFile.getName() );
 105
 106         File[] files = parentDir.listFiles( filter );
 107
 108         for ( File file : files )
 109         {
 110             if ( file.exists() && file.isFile() )
 111             {
 112                 String fileName = file.getName();
 113                 file.delete();
 114                 // TODO: log that it was deleted
 115                 triggerAuditEvent( repository.getRepository().getId(), fileName, AuditEvent.PURGE_FILE );
 116             }
 117         }
 118     }
 119
 120     private void triggerAuditEvent( String repoId, String resource, String action )
 121     {
 122         String msg =
 123             repoId + DELIM + "<system-purge>" + DELIM + "<system>" + DELIM + '\"' + resource + '\"' + DELIM + '\"' +
 124                 action + '\"';
 125
 126         logger.info( msg );
 127     }
 128 }