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

   1 package org.apache.maven.archiva.repository.metadata;
   2
   3 /*
   4  * Copyright 2001-2007 The Apache Software Foundation.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18
  19 import org.apache.commons.collections.CollectionUtils;
  20 import org.apache.commons.lang.StringUtils;
  21 import org.apache.commons.lang.math.NumberUtils;
  22 import org.apache.commons.lang.time.DateUtils;
  23 import org.apache.maven.archiva.common.utils.Checksums;
  24 import org.apache.maven.archiva.common.utils.PathUtil;
  25 import org.apache.maven.archiva.common.utils.VersionComparator;
  26 import org.apache.maven.archiva.common.utils.VersionUtil;
  27 import org.apache.maven.archiva.configuration.ArchivaConfiguration;
  28 import org.apache.maven.archiva.configuration.ConfigurationNames;
  29 import org.apache.maven.archiva.configuration.FileTypes;
  30 import org.apache.maven.archiva.configuration.ProxyConnectorConfiguration;
  31 import org.apache.maven.archiva.model.ArchivaRepositoryMetadata;
  32 import org.apache.maven.archiva.model.ArtifactReference;
  33 import org.apache.maven.archiva.model.ProjectReference;
  34 import org.apache.maven.archiva.model.SnapshotVersion;
  35 import org.apache.maven.archiva.model.VersionedReference;
  36 import org.apache.maven.archiva.repository.ContentNotFoundException;
  37 import org.apache.maven.archiva.repository.ManagedRepositoryContent;
  38 import org.apache.maven.archiva.repository.RemoteRepositoryContent;
  39 import org.apache.maven.archiva.repository.layout.LayoutException;
  40 import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
  41 import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
  42 import org.codehaus.plexus.registry.Registry;
  43 import org.codehaus.plexus.registry.RegistryListener;
  44 import org.codehaus.plexus.util.SelectorUtils;
  45 import org.slf4j.Logger;
  46 import org.slf4j.LoggerFactory;
  47
  48 import java.io.File;
  49 import java.io.IOException;
  50 import java.text.ParseException;
  51 import java.text.SimpleDateFormat;
  52 import java.util.ArrayList;
  53 import java.util.Calendar;
  54 import java.util.Collections;
  55 import java.util.Date;
  56 import java.util.HashMap;
  57 import java.util.HashSet;
  58 import java.util.Iterator;
  59 import java.util.List;
  60 import java.util.Map;
  61 import java.util.Set;
  62 import java.util.regex.Matcher;
  63
  64 /**
  65  * MetadataTools
  66  *
  67  * @author <a href="mailto:joakime@apache.org">Joakim Erdfelt</a>
  68  * @version $Id$
  69  *
  70  * @plexus.component role="org.apache.maven.archiva.repository.metadata.MetadataTools"
  71  */
  72 public class MetadataTools
  73     implements RegistryListener, Initializable
  74 {
  75     private static Logger log = LoggerFactory.getLogger( MetadataTools.class );
  76
  77     public static final String MAVEN_METADATA = "maven-metadata.xml";
  78
  79     private static final char PATH_SEPARATOR = '/';
  80
  81     private static final char GROUP_SEPARATOR = '.';
  82
  83     /**
  84      * @plexus.requirement
  85      */
  86     private ArchivaConfiguration configuration;
  87
  88     /**
  89      * @plexus.requirement
  90      */
  91     private FileTypes filetypes;
  92
  93     /**
  94      * @plexus.requirement
  95      */
  96     private Checksums checksums;
  97
  98     private List<String> artifactPatterns;
  99
 100     private Map<String, Set<String>> proxies;
 101
 102     private static final char NUMS[] = new char[] { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9' };
 103
 104     private static final SimpleDateFormat lastUpdatedFormat;
 105
 106     static
 107     {
 108         lastUpdatedFormat = new SimpleDateFormat( "yyyyMMddHHmmss" );
 109         lastUpdatedFormat.setTimeZone( DateUtils.UTC_TIME_ZONE );
 110     }
 111
 112     public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue )
 113     {
 114         if ( ConfigurationNames.isProxyConnector( propertyName ) )
 115         {
 116             initConfigVariables();
 117         }
 118     }
 119
 120     public void beforeConfigurationChange( Registry registry, String propertyName, Object propertyValue )
 121     {
 122         /* nothing to do */
 123     }
 124
 125     /**
 126      * Gather the set of snapshot versions found in a particular versioned reference.
 127      *
 128      * @return the Set of snapshot artifact versions found.
 129      * @throws LayoutException
 130      * @throws ContentNotFoundException
 131      */
 132     public Set<String> gatherSnapshotVersions( ManagedRepositoryContent managedRepository, VersionedReference reference )
 133         throws LayoutException, IOException, ContentNotFoundException
 134     {
 135         Set<String> foundVersions = managedRepository.getVersions( reference );
 136
 137         // Next gather up the referenced 'latest' versions found in any proxied repositories
 138         // maven-metadata-${proxyId}.xml files that may be present.
 139
 140         // Does this repository have a set of remote proxied repositories?
 141         Set<String> proxiedRepoIds = this.proxies.get( managedRepository.getId() );
 142
 143         if ( CollectionUtils.isNotEmpty( proxiedRepoIds ) )
 144         {
 145             String baseVersion = VersionUtil.getBaseVersion( reference.getVersion() );
 146             baseVersion = baseVersion.substring( 0, baseVersion.indexOf( VersionUtil.SNAPSHOT ) - 1 );
 147
 148             // Add in the proxied repo version ids too.
 149             Iterator<String> it = proxiedRepoIds.iterator();
 150             while ( it.hasNext() )
 151             {
 152                 String proxyId = it.next();
 153
 154                 ArchivaRepositoryMetadata proxyMetadata = readProxyMetadata( managedRepository, reference, proxyId );
 155                 if ( proxyMetadata == null )
 156                 {
 157                     // There is no proxy metadata, skip it.
 158                     continue;
 159                 }
 160
 161                 // Is there some snapshot info?
 162                 SnapshotVersion snapshot = proxyMetadata.getSnapshotVersion();
 163                 if ( snapshot != null )
 164                 {
 165                     String timestamp = snapshot.getTimestamp();
 166                     int buildNumber = snapshot.getBuildNumber();
 167
 168                     // Only interested in the timestamp + buildnumber.
 169                     if ( StringUtils.isNotBlank( timestamp ) && ( buildNumber > 0 ) )
 170                     {
 171                         foundVersions.add( baseVersion + "-" + timestamp + "-" + buildNumber );
 172                     }
 173                 }
 174             }
 175         }
 176
 177         return foundVersions;
 178     }
 179
 180     /**
 181      * Take a path to a maven-metadata.xml, and attempt to translate it to a VersionedReference.
 182      *
 183      * @param path
 184      * @return
 185      */
 186     public VersionedReference toVersionedReference( String path )
 187         throws RepositoryMetadataException
 188     {
 189         if ( !path.endsWith( "/" + MAVEN_METADATA ) )
 190         {
 191             throw new RepositoryMetadataException( "Cannot convert to versioned reference, not a metadata file. " );
 192         }
 193
 194         VersionedReference reference = new VersionedReference();
 195
 196         String normalizedPath = StringUtils.replace( path, "\\", "/" );
 197         String pathParts[] = StringUtils.split( normalizedPath, '/' );
 198
 199         int versionOffset = pathParts.length - 2;
 200         int artifactIdOffset = versionOffset - 1;
 201         int groupIdEnd = artifactIdOffset - 1;
 202
 203         reference.setVersion( pathParts[versionOffset] );
 204
 205         if ( !hasNumberAnywhere( reference.getVersion() ) )
 206         {
 207             // Scary check, but without it, all paths are version references;
 208             throw new RepositoryMetadataException(
 209                                                    "Not a versioned reference, as version id on path has no number in it." );
 210         }
 211
 212         reference.setArtifactId( pathParts[artifactIdOffset] );
 213
 214         StringBuffer gid = new StringBuffer();
 215         for ( int i = 0; i <= groupIdEnd; i++ )
 216         {
 217             if ( i > 0 )
 218             {
 219                 gid.append( "." );
 220             }
 221             gid.append( pathParts[i] );
 222         }
 223
 224         reference.setGroupId( gid.toString() );
 225
 226         return reference;
 227     }
 228
 229     private boolean hasNumberAnywhere( String version )
 230     {
 231         return StringUtils.indexOfAny( version, NUMS ) != ( -1 );
 232     }
 233
 234     public ProjectReference toProjectReference( String path )
 235         throws RepositoryMetadataException
 236     {
 237         if ( !path.endsWith( "/" + MAVEN_METADATA ) )
 238         {
 239             throw new RepositoryMetadataException( "Cannot convert to versioned reference, not a metadata file. " );
 240         }
 241
 242         ProjectReference reference = new ProjectReference();
 243
 244         String normalizedPath = StringUtils.replace( path, "\\", "/" );
 245         String pathParts[] = StringUtils.split( normalizedPath, '/' );
 246
 247         // Assume last part of the path is the version.
 248
 249         int artifactIdOffset = pathParts.length - 2;
 250         int groupIdEnd = artifactIdOffset - 1;
 251
 252         reference.setArtifactId( pathParts[artifactIdOffset] );
 253
 254         StringBuffer gid = new StringBuffer();
 255         for ( int i = 0; i <= groupIdEnd; i++ )
 256         {
 257             if ( i > 0 )
 258             {
 259                 gid.append( "." );
 260             }
 261             gid.append( pathParts[i] );
 262         }
 263
 264         reference.setGroupId( gid.toString() );
 265
 266         return reference;
 267     }
 268
 269     public String toPath( ProjectReference reference )
 270     {
 271         StringBuffer path = new StringBuffer();
 272
 273         path.append( formatAsDirectory( reference.getGroupId() ) ).append( PATH_SEPARATOR );
 274         path.append( reference.getArtifactId() ).append( PATH_SEPARATOR );
 275         path.append( MAVEN_METADATA );
 276
 277         return path.toString();
 278     }
 279
 280     public String toPath( VersionedReference reference )
 281     {
 282         StringBuffer path = new StringBuffer();
 283
 284         path.append( formatAsDirectory( reference.getGroupId() ) ).append( PATH_SEPARATOR );
 285         path.append( reference.getArtifactId() ).append( PATH_SEPARATOR );
 286         if ( reference.getVersion() != null )
 287         {
 288             // add the version only if it is present
 289             path.append( VersionUtil.getBaseVersion( reference.getVersion() ) ).append( PATH_SEPARATOR );
 290         }
 291         path.append( MAVEN_METADATA );
 292
 293         return path.toString();
 294     }
 295
 296     private String formatAsDirectory( String directory )
 297     {
 298         return directory.replace( GROUP_SEPARATOR, PATH_SEPARATOR );
 299     }
 300
 301     /**
 302      * Adjusts a path for a metadata.xml file to its repository specific path.
 303      *
 304      * @param repository the repository to base new path off of.
 305      * @param path       the path to the metadata.xml file to adjust the name of.
 306      * @return the newly adjusted path reference to the repository specific metadata path.
 307      */
 308     public String getRepositorySpecificName( RemoteRepositoryContent repository, String path )
 309     {
 310         return getRepositorySpecificName( repository.getId(), path );
 311     }
 312
 313     /**
 314      * Adjusts a path for a metadata.xml file to its repository specific path.
 315      *
 316      * @param proxyId the repository id to base new path off of.
 317      * @param path    the path to the metadata.xml file to adjust the name of.
 318      * @return the newly adjusted path reference to the repository specific metadata path.
 319      */
 320     public String getRepositorySpecificName( String proxyId, String path )
 321     {
 322         StringBuffer ret = new StringBuffer();
 323
 324         int idx = path.lastIndexOf( "/" );
 325         if ( idx > 0 )
 326         {
 327             ret.append( path.substring( 0, idx + 1 ) );
 328         }
 329
 330         // TODO: need to filter out 'bad' characters from the proxy id.
 331         ret.append( "maven-metadata-" ).append( proxyId ).append( ".xml" );
 332
 333         return ret.toString();
 334     }
 335
 336     public void initialize()
 337         throws InitializationException
 338     {
 339         this.artifactPatterns = new ArrayList<String>();
 340         this.proxies = new HashMap<String, Set<String>>();
 341         initConfigVariables();
 342
 343         configuration.addChangeListener( this );
 344     }
 345
 346     public ArchivaRepositoryMetadata readProxyMetadata( ManagedRepositoryContent managedRepository,
 347                                                         ProjectReference reference, String proxyId )
 348     {
 349         String metadataPath = getRepositorySpecificName( proxyId, toPath( reference ) );
 350         File metadataFile = new File( managedRepository.getRepoRoot(), metadataPath );
 351
 352         if ( !metadataFile.exists() || !metadataFile.isFile() )
 353         {
 354             // Nothing to do. return null.
 355             return null;
 356         }
 357
 358         try
 359         {
 360             return RepositoryMetadataReader.read( metadataFile );
 361         }
 362         catch ( RepositoryMetadataException e )
 363         {
 364             // TODO: [monitor] consider a monitor for this event.
 365             // TODO: consider a read-redo on monitor return code?
 366             log.warn( "Unable to read metadata: " + metadataFile.getAbsolutePath(), e );
 367             return null;
 368         }
 369     }
 370
 371     public ArchivaRepositoryMetadata readProxyMetadata( ManagedRepositoryContent managedRepository,
 372                                                         VersionedReference reference, String proxyId )
 373     {
 374         String metadataPath = getRepositorySpecificName( proxyId, toPath( reference ) );
 375         File metadataFile = new File( managedRepository.getRepoRoot(), metadataPath );
 376
 377         if ( !metadataFile.exists() || !metadataFile.isFile() )
 378         {
 379             // Nothing to do. return null.
 380             return null;
 381         }
 382
 383         try
 384         {
 385             return RepositoryMetadataReader.read( metadataFile );
 386         }
 387         catch ( RepositoryMetadataException e )
 388         {
 389             // TODO: [monitor] consider a monitor for this event.
 390             // TODO: consider a read-redo on monitor return code?
 391             log.warn( "Unable to read metadata: " + metadataFile.getAbsolutePath(), e );
 392             return null;
 393         }
 394     }
 395
 396     /**
 397      * Update the metadata to represent the all versions of
 398      * the provided groupId:artifactId project reference,
 399      * based off of information present in the repository,
 400      * the maven-metadata.xml files, and the proxy/repository specific
 401      * metadata file contents.
 402      *
 403      * @param managedRepository the managed repository where the metadata is kept.
 404      * @param reference         the versioned referencfe to update.
 405      * @throws LayoutException
 406      * @throws RepositoryMetadataException
 407      * @throws IOException
 408      * @throws ContentNotFoundException
 409      */
 410     public void updateMetadata( ManagedRepositoryContent managedRepository, ProjectReference reference )
 411         throws LayoutException, RepositoryMetadataException, IOException, ContentNotFoundException
 412     {
 413         File metadataFile = new File( managedRepository.getRepoRoot(), toPath( reference ) );
 414
 415         long lastUpdated = getExistingLastUpdated( metadataFile );
 416
 417         ArchivaRepositoryMetadata metadata = new ArchivaRepositoryMetadata();
 418         metadata.setGroupId( reference.getGroupId() );
 419         metadata.setArtifactId( reference.getArtifactId() );
 420
 421         // Gather up all versions found in the managed repository.
 422         Set<String> allVersions = managedRepository.getVersions( reference );
 423
 424         // Does this repository have a set of remote proxied repositories?
 425         Set<String> proxiedRepoIds = this.proxies.get( managedRepository.getId() );
 426
 427         if ( CollectionUtils.isNotEmpty( proxiedRepoIds ) )
 428         {
 429             // Add in the proxied repo version ids too.
 430             Iterator<String> it = proxiedRepoIds.iterator();
 431             while ( it.hasNext() )
 432             {
 433                 String proxyId = it.next();
 434
 435                 ArchivaRepositoryMetadata proxyMetadata = readProxyMetadata( managedRepository, reference, proxyId );
 436                 if ( proxyMetadata != null )
 437                 {
 438                     allVersions.addAll( proxyMetadata.getAvailableVersions() );
 439                     long proxyLastUpdated = getLastUpdated( proxyMetadata );
 440
 441                     lastUpdated = Math.max( lastUpdated, proxyLastUpdated );
 442                 }
 443             }
 444         }
 445
 446         if ( allVersions.size() == 0 )
 447         {
 448             throw new IOException( "No versions found for reference." );
 449         }
 450
 451         // Sort the versions
 452         List<String> sortedVersions = new ArrayList<String>( allVersions );
 453         Collections.sort( sortedVersions, VersionComparator.getInstance() );
 454
 455         // Split the versions into released and snapshots.
 456         List<String> releasedVersions = new ArrayList<String>();
 457         List<String> snapshotVersions = new ArrayList<String>();
 458
 459         for ( String version : sortedVersions )
 460         {
 461             if ( VersionUtil.isSnapshot( version ) )
 462             {
 463                 snapshotVersions.add( version );
 464             }
 465             else
 466             {
 467                 releasedVersions.add( version );
 468             }
 469         }
 470
 471         Collections.sort( releasedVersions, VersionComparator.getInstance() );
 472         Collections.sort( snapshotVersions, VersionComparator.getInstance() );
 473
 474         String latestVersion = sortedVersions.get( sortedVersions.size() - 1 );
 475         String releaseVersion = null;
 476
 477         if ( CollectionUtils.isNotEmpty( releasedVersions ) )
 478         {
 479             releaseVersion = releasedVersions.get( releasedVersions.size() - 1 );
 480         }
 481
 482         // Add the versions to the metadata model.
 483         metadata.setAvailableVersions( sortedVersions );
 484
 485         metadata.setLatestVersion( latestVersion );
 486         metadata.setReleasedVersion( releaseVersion );
 487         if ( lastUpdated > 0 )
 488         {
 489             metadata.setLastUpdatedTimestamp( toLastUpdatedDate( lastUpdated ) );
 490         }
 491
 492         // Save the metadata model to disk.
 493         RepositoryMetadataWriter.write( metadata, metadataFile );
 494         checksums.update( metadataFile );
 495     }
 496
 497     private Date toLastUpdatedDate( long lastUpdated )
 498     {
 499         Calendar cal = Calendar.getInstance( DateUtils.UTC_TIME_ZONE );
 500         cal.setTimeInMillis( lastUpdated );
 501
 502         return cal.getTime();
 503     }
 504
 505     private long getLastUpdated( ArchivaRepositoryMetadata metadata )
 506     {
 507         if ( metadata == null )
 508         {
 509             // Doesn't exist.
 510             return 0;
 511         }
 512
 513         try
 514         {
 515             String lastUpdated = metadata.getLastUpdated();
 516             if ( StringUtils.isBlank( lastUpdated ) )
 517             {
 518                 // Not set.
 519                 return 0;
 520             }
 521
 522             Date lastUpdatedDate = lastUpdatedFormat.parse( lastUpdated );
 523             return lastUpdatedDate.getTime();
 524         }
 525         catch ( ParseException e )
 526         {
 527             // Bad format on the last updated string.
 528             return 0;
 529         }
 530     }
 531
 532     private long getExistingLastUpdated( File metadataFile )
 533     {
 534         if ( !metadataFile.exists() )
 535         {
 536             // Doesn't exist.
 537             return 0;
 538         }
 539
 540         try
 541         {
 542             ArchivaRepositoryMetadata metadata = RepositoryMetadataReader.read( metadataFile );
 543
 544             return getLastUpdated( metadata );
 545         }
 546         catch ( RepositoryMetadataException e )
 547         {
 548             // Error.
 549             return 0;
 550         }
 551     }
 552
 553     /**
 554      * Update the metadata based on the following rules.
 555      * <p/>
 556      * 1) If this is a SNAPSHOT reference, then utilize the proxy/repository specific
 557      * metadata files to represent the current / latest SNAPSHOT available.
 558      * 2) If this is a RELEASE reference, and the metadata file does not exist, then
 559      * create the metadata file with contents required of the VersionedReference
 560      *
 561      * @param managedRepository the managed repository where the metadata is kept.
 562      * @param reference         the versioned reference to update
 563      * @throws LayoutException
 564      * @throws RepositoryMetadataException
 565      * @throws IOException
 566      * @throws ContentNotFoundException
 567      */
 568     public void updateMetadata( ManagedRepositoryContent managedRepository, VersionedReference reference )
 569         throws LayoutException, RepositoryMetadataException, IOException, ContentNotFoundException
 570     {
 571         File metadataFile = new File( managedRepository.getRepoRoot(), toPath( reference ) );
 572
 573         long originalLastUpdated = getExistingLastUpdated( metadataFile );
 574
 575         ArchivaRepositoryMetadata metadata = new ArchivaRepositoryMetadata();
 576         metadata.setGroupId( reference.getGroupId() );
 577         metadata.setArtifactId( reference.getArtifactId() );
 578         if ( originalLastUpdated > 0 )
 579         {
 580             metadata.setLastUpdatedTimestamp( toLastUpdatedDate( originalLastUpdated ) );
 581         }
 582
 583         if ( VersionUtil.isSnapshot( reference.getVersion() ) )
 584         {
 585             // Do SNAPSHOT handling.
 586             metadata.setVersion( VersionUtil.getBaseVersion( reference.getVersion() ) );
 587
 588             // Gather up all of the versions found in the reference dir, and any
 589             // proxied maven-metadata.xml files.
 590             Set<String> snapshotVersions = gatherSnapshotVersions( managedRepository, reference );
 591
 592             if ( snapshotVersions.isEmpty() )
 593             {
 594                 throw new ContentNotFoundException( "No snapshot versions found on reference ["
 595                     + VersionedReference.toKey( reference ) + "]." );
 596             }
 597
 598             // sort the list to determine to aide in determining the Latest version.
 599             List<String> sortedVersions = new ArrayList<String>();
 600             sortedVersions.addAll( snapshotVersions );
 601             Collections.sort( sortedVersions, new VersionComparator() );
 602
 603             String latestVersion = sortedVersions.get( sortedVersions.size() - 1 );
 604
 605             if ( VersionUtil.isUniqueSnapshot( latestVersion ) )
 606             {
 607                 // The latestVersion will contain the full version string "1.0-alpha-5-20070821.213044-8"
 608                 // This needs to be broken down into ${base}-${timestamp}-${build_number}
 609
 610                 Matcher m = VersionUtil.UNIQUE_SNAPSHOT_PATTERN.matcher( latestVersion );
 611                 if ( m.matches() )
 612                 {
 613                     metadata.setSnapshotVersion( new SnapshotVersion() );
 614                     int buildNumber = NumberUtils.toInt( m.group( 3 ), -1 );
 615                     metadata.getSnapshotVersion().setBuildNumber( buildNumber );
 616
 617                     Matcher mtimestamp = VersionUtil.TIMESTAMP_PATTERN.matcher( m.group( 2 ) );
 618                     if ( mtimestamp.matches() )
 619                     {
 620                         String tsDate = mtimestamp.group( 1 );
 621                         String tsTime = mtimestamp.group( 2 );
 622                         metadata.setLastUpdated( tsDate + tsTime );
 623                         metadata.getSnapshotVersion().setTimestamp( m.group( 2 ) );
 624                     }
 625                 }
 626             }
 627             else if ( VersionUtil.isGenericSnapshot( latestVersion ) )
 628             {
 629                 // The latestVersion ends with the generic version string.
 630                 // Example: 1.0-alpha-5-SNAPSHOT
 631
 632                 metadata.setSnapshotVersion( new SnapshotVersion() );
 633
 634                 /* TODO: Should this be the last updated timestamp of the file, or in the case of an
 635                  * archive, the most recent timestamp in the archive?
 636                  */
 637                 ArtifactReference artifact = getFirstArtifact( managedRepository, reference );
 638
 639                 if ( artifact == null )
 640                 {
 641                     throw new IOException( "Not snapshot artifact found to reference in " + reference );
 642                 }
 643
 644                 File artifactFile = managedRepository.toFile( artifact );
 645
 646                 if ( artifactFile.exists() )
 647                 {
 648                     Date lastModified = new Date( artifactFile.lastModified() );
 649                     metadata.setLastUpdatedTimestamp( lastModified );
 650                 }
 651             }
 652             else
 653             {
 654                 throw new RepositoryMetadataException( "Unable to process snapshot version <" + latestVersion
 655                     + "> reference <" + reference + ">" );
 656             }
 657         }
 658         else
 659         {
 660             // Do RELEASE handling.
 661             metadata.setVersion( reference.getVersion() );
 662         }
 663
 664         // Save the metadata model to disk.
 665         RepositoryMetadataWriter.write( metadata, metadataFile );
 666         checksums.update( metadataFile );
 667     }
 668
 669     private void initConfigVariables()
 670     {
 671         synchronized ( this.artifactPatterns )
 672         {
 673             this.artifactPatterns.clear();
 674
 675             this.artifactPatterns.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
 676         }
 677
 678         synchronized ( proxies )
 679         {
 680             this.proxies.clear();
 681
 682             List<ProxyConnectorConfiguration> proxyConfigs = configuration.getConfiguration().getProxyConnectors();
 683             for( ProxyConnectorConfiguration proxyConfig: proxyConfigs )
 684             {
 685                 String key = proxyConfig.getSourceRepoId();
 686
 687                 Set<String> remoteRepoIds = this.proxies.get( key );
 688
 689                 if ( remoteRepoIds == null )
 690                 {
 691                     remoteRepoIds = new HashSet<String>();
 692                 }
 693
 694                 remoteRepoIds.add( proxyConfig.getTargetRepoId() );
 695
 696                 this.proxies.put( key, remoteRepoIds );
 697             }
 698         }
 699     }
 700
 701     /**
 702      * Get the first Artifact found in the provided VersionedReference location.
 703      *
 704      * @param managedRepository the repository to search within.
 705      * @param reference         the reference to the versioned reference to search within
 706      * @return the ArtifactReference to the first artifact located within the versioned reference. or null if
 707      *         no artifact was found within the versioned reference.
 708      * @throws IOException     if the versioned reference is invalid (example: doesn't exist, or isn't a directory)
 709      * @throws LayoutException
 710      */
 711     public ArtifactReference getFirstArtifact( ManagedRepositoryContent managedRepository, VersionedReference reference )
 712         throws LayoutException, IOException
 713     {
 714         String path = toPath( reference );
 715
 716         int idx = path.lastIndexOf( '/' );
 717         if ( idx > 0 )
 718         {
 719             path = path.substring( 0, idx );
 720         }
 721
 722         File repoDir = new File( managedRepository.getRepoRoot(), path );
 723
 724         if ( !repoDir.exists() )
 725         {
 726             throw new IOException( "Unable to gather the list of snapshot versions on a non-existant directory: "
 727                 + repoDir.getAbsolutePath() );
 728         }
 729
 730         if ( !repoDir.isDirectory() )
 731         {
 732             throw new IOException( "Unable to gather the list of snapshot versions on a non-directory: "
 733                 + repoDir.getAbsolutePath() );
 734         }
 735
 736         File repoFiles[] = repoDir.listFiles();
 737         for ( int i = 0; i < repoFiles.length; i++ )
 738         {
 739             if ( repoFiles[i].isDirectory() )
 740             {
 741                 // Skip it. it's a directory.
 742                 continue;
 743             }
 744
 745             String relativePath = PathUtil.getRelative( managedRepository.getRepoRoot(), repoFiles[i] );
 746
 747             if ( matchesArtifactPattern( relativePath ) )
 748             {
 749                 ArtifactReference artifact = managedRepository.toArtifactReference( relativePath );
 750
 751                 return artifact;
 752             }
 753         }
 754
 755         // No artifact was found.
 756         return null;
 757     }
 758
 759     private boolean matchesArtifactPattern( String relativePath )
 760     {
 761         // Correct the slash pattern.
 762         relativePath = relativePath.replace( '\\', '/' );
 763
 764         Iterator<String> it = this.artifactPatterns.iterator();
 765         while ( it.hasNext() )
 766         {
 767             String pattern = it.next();
 768
 769             if ( SelectorUtils.matchPath( pattern, relativePath, false ) )
 770             {
 771                 // Found match
 772                 return true;
 773             }
 774         }
 775
 776         // No match.
 777         return false;
 778     }
 779 }