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

   1 package org.apache.maven.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 java.io.File;
  23 import java.util.ArrayList;
  24 import java.util.Date;
  25 import java.util.List;
  26
  27 import org.apache.archiva.metadata.model.ArtifactMetadata;
  28 import org.apache.archiva.metadata.model.ProjectBuildMetadata;
  29 import org.apache.archiva.metadata.model.ProjectMetadata;
  30 import org.apache.archiva.metadata.repository.MetadataRepository;
  31 import org.apache.archiva.metadata.repository.file.FileMetadataRepository;
  32 import org.apache.maven.archiva.configuration.ArchivaConfiguration;
  33 import org.apache.maven.archiva.configuration.ConfigurationNames;
  34 import org.apache.maven.archiva.configuration.FileTypes;
  35 import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
  36 import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer;
  37 import org.apache.maven.archiva.consumers.ConsumerException;
  38 import org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer;
  39 import org.apache.maven.archiva.model.ArtifactReference;
  40 import org.apache.maven.archiva.repository.ManagedRepositoryContent;
  41 import org.apache.maven.archiva.repository.RepositoryContentFactory;
  42 import org.apache.maven.archiva.repository.RepositoryException;
  43 import org.apache.maven.archiva.repository.layout.LayoutException;
  44 import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
  45 import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
  46 import org.codehaus.plexus.registry.Registry;
  47 import org.codehaus.plexus.registry.RegistryListener;
  48
  49 /**
  50  * ArtifactUpdateDatabaseConsumer - Take an artifact off of disk and put it into the repository.
  51  *
  52  * @version $Id: ArtifactUpdateDatabaseConsumer.java 718864 2008-11-19 06:33:35Z brett $
  53  * @plexus.component role="org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer"
  54  *                   role-hint="create-archiva-metadata" instantiation-strategy="per-lookup"
  55  */
  56 public class ArchivaMetadataCreationConsumer
  57     extends AbstractMonitoredConsumer
  58     implements KnownRepositoryContentConsumer, RegistryListener, Initializable
  59 {
  60     /**
  61      * @plexus.configuration default-value="create-archiva-metadata"
  62      */
  63     private String id;
  64
  65     /**
  66      * @plexus.configuration default-value="Create basic metadata for Archiva to be able to reference the artifact"
  67      */
  68     private String description;
  69
  70     /**
  71      * @plexus.requirement
  72      */
  73     private ArchivaConfiguration configuration;
  74
  75     /**
  76      * @plexus.requirement
  77      */
  78     private FileTypes filetypes;
  79
  80     /**
  81      * @plexus.requirement
  82      */
  83     private RepositoryContentFactory repositoryFactory;
  84
  85     private Date whenGathered;
  86
  87     private ManagedRepositoryContent repository;
  88
  89     private List<String> includes = new ArrayList<String>();
  90
  91     private MetadataRepository metadataRepository;
  92
  93     public String getId()
  94     {
  95         return this.id;
  96     }
  97
  98     public String getDescription()
  99     {
 100         return this.description;
 101     }
 102
 103     public boolean isPermanent()
 104     {
 105         return true;
 106     }
 107
 108     public List<String> getExcludes()
 109     {
 110         return getDefaultArtifactExclusions();
 111     }
 112
 113     public List<String> getIncludes()
 114     {
 115         return this.includes;
 116     }
 117
 118     public void beginScan( ManagedRepositoryConfiguration repo, Date whenGathered )
 119         throws ConsumerException
 120     {
 121         try
 122         {
 123             this.repository = repositoryFactory.getManagedRepositoryContent( repo.getId() );
 124             this.metadataRepository = new FileMetadataRepository( new File( repository.getRepoRoot(), ".metadata" ) );
 125             this.whenGathered = whenGathered;
 126         }
 127         catch ( RepositoryException e )
 128         {
 129             throw new ConsumerException( "Unable to start ArtifactUpdateDatabaseConsumer: " + e.getMessage(), e );
 130         }
 131     }
 132
 133     public void processFile( String path )
 134         throws ConsumerException
 135     {
 136         // note that we do minimal processing including checksums and POM information for performance of
 137         // the initial scan. Any request for this information will be intercepted and populated on-demand
 138         // or picked up by subsequent scans
 139         ArtifactReference artifact;
 140         try
 141         {
 142             artifact = repository.toArtifactReference( path );
 143         }
 144         catch ( LayoutException e )
 145         {
 146             throw new ConsumerException( e.getMessage(), e );
 147         }
 148
 149         File file = new File( repository.getRepoRoot(), path );
 150
 151         // TODO: needed in a more central place, but trying to isolate impact to start with
 152         String metadataId = artifact.getGroupId() + "." + artifact.getArtifactId();
 153
 154         ProjectMetadata project = new ProjectMetadata();
 155         project.setId( metadataId );
 156
 157         ProjectBuildMetadata build = new ProjectBuildMetadata();
 158         build.setId( artifact.getVersion() );
 159
 160         ArtifactMetadata artifactMeta = new ArtifactMetadata();
 161         artifactMeta.setId( file.getName() );
 162         artifactMeta.setUpdated( file.lastModified() );
 163         artifactMeta.setSize( file.length() );
 164
 165         build.addArtifact( artifactMeta );
 166         project.addBuild( build );
 167
 168         // TODO: store "whenGathered"
 169
 170         // read the metadata and update it if it is newer or doesn't exist
 171         metadataRepository.update( project );
 172     }
 173
 174     public void completeScan()
 175     {
 176         /* do nothing */
 177     }
 178
 179     public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue )
 180     {
 181         if ( ConfigurationNames.isRepositoryScanning( propertyName ) )
 182         {
 183             initIncludes();
 184         }
 185     }
 186
 187     public void beforeConfigurationChange( Registry registry, String propertyName, Object propertyValue )
 188     {
 189         /* do nothing */
 190     }
 191
 192     private void initIncludes()
 193     {
 194         includes.clear();
 195
 196         includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
 197     }
 198
 199     public void initialize()
 200         throws InitializationException
 201     {
 202         configuration.addChangeListener( this );
 203
 204         initIncludes();
 205     }
 206 }