<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
</dependency>
+ <dependency>
+ <groupId>commons-lang</groupId>
+ <artifactId>commons-lang</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.sonatype.sisu</groupId>
+ <artifactId>sisu-inject-plexus</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.sonatype.sisu</groupId>
+ <artifactId>sisu-guice</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.archiva</groupId>
+ <artifactId>archiva-plexus-bridge</artifactId>
+ </dependency>
<dependency>
<groupId>org.apache.maven.wagon</groupId>
<artifactId>wagon-file</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <excludes>
- <exclude>**/Abstract*</exclude>
- <exclude>**/*TestCase.java</exclude>
- <exclude>**/*Tests.java</exclude>
- <exclude>**/*TestSuite.java</exclude>
- <exclude>**/RelocateTransfer*</exclude>
- </excludes>
- </configuration>
- </plugin>
- </plugins>
- </build>
</project>
* under the License.
*/
-import java.io.File;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Properties;
-
import org.apache.archiva.scheduler.ArchivaTaskScheduler;
import org.apache.archiva.scheduler.repository.RepositoryTask;
import org.apache.commons.collections.CollectionUtils;
import org.apache.maven.wagon.authentication.AuthenticationInfo;
import org.apache.maven.wagon.proxy.ProxyInfo;
import org.apache.maven.wagon.repository.Repository;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
import org.codehaus.plexus.registry.Registry;
import org.codehaus.plexus.registry.RegistryListener;
import org.codehaus.plexus.taskqueue.TaskQueueException;
import org.codehaus.plexus.util.SelectorUtils;
+import org.codehaus.redback.components.springutils.ComponentContainer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import javax.inject.Inject;
+import javax.inject.Named;
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Properties;
/**
* DefaultRepositoryProxyConnectors
- *
+ *
* @version $Id$
* @todo exception handling needs work - "not modified" is not really an exceptional case, and it has more layers than
- * your average brown onion
- * @plexus.component role-hint="default"
+ * your average brown onion
+ * plexus.component role-hint="default"
*/
+@Service( "repositoryProxyConnectors#default" )
public class DefaultRepositoryProxyConnectors
- implements RepositoryProxyConnectors, RegistryListener, Initializable
+ implements RepositoryProxyConnectors, RegistryListener
{
private Logger log = LoggerFactory.getLogger( DefaultRepositoryProxyConnectors.class );
/**
- * @plexus.requirement
+ * plexus.requirement
*/
+ @Inject
+ @Named( value = "archivaConfiguration#default" )
private ArchivaConfiguration archivaConfiguration;
/**
- * @plexus.requirement
+ * plexus.requirement
*/
+ @Inject
private RepositoryContentFactory repositoryFactory;
/**
- * @plexus.requirement
+ * plexus.requirement
*/
+ @Inject
private MetadataTools metadataTools;
+ @Inject
+ private ComponentContainer componentContainer;
+
/**
* @plexus.requirement role="org.apache.maven.archiva.policies.PreDownloadPolicy"
*/
private Map<String, DownloadErrorPolicy> downloadErrorPolicies;
/**
- * @plexus.requirement role-hint="default"
+ * plexus.requirement role-hint="default"
*/
+ @Inject
private UrlFailureCache urlFailureCache;
private Map<String, List<ProxyConnector>> proxyConnectorMap = new HashMap<String, List<ProxyConnector>>();
private Map<String, ProxyInfo> networkProxyMap = new HashMap<String, ProxyInfo>();
/**
- * @plexus.requirement
+ * plexus.requirement
*/
+ @Inject
private WagonFactory wagonFactory;
-
+
/**
- * @plexus.requirement role="org.apache.archiva.scheduler.ArchivaTaskScheduler" role-hint="repository"
+ * plexus.requirement role="org.apache.archiva.scheduler.ArchivaTaskScheduler" role-hint="repository"
*/
+ @Inject
+ @Named( value = "archivaTaskScheduler#repository" )
private ArchivaTaskScheduler scheduler;
+ @PostConstruct
+ public void initialize()
+ {
+ initConnectorsAndNetworkProxies();
+ archivaConfiguration.addChangeListener( this );
+ this.postDownloadPolicies = componentContainer.buildMapWithRole( PostDownloadPolicy.class );
+ this.preDownloadPolicies = componentContainer.buildMapWithRole( PreDownloadPolicy.class );
+ this.downloadErrorPolicies = componentContainer.buildMapWithRole( DownloadErrorPolicy.class );
+ }
+
+ @SuppressWarnings( "unchecked" )
+ private void initConnectorsAndNetworkProxies()
+ {
+ synchronized ( this.proxyConnectorMap )
+ {
+ ProxyConnectorOrderComparator proxyOrderSorter = new ProxyConnectorOrderComparator();
+ this.proxyConnectorMap.clear();
+
+ List<ProxyConnectorConfiguration> proxyConfigs =
+ archivaConfiguration.getConfiguration().getProxyConnectors();
+ for ( ProxyConnectorConfiguration proxyConfig : proxyConfigs )
+ {
+ String key = proxyConfig.getSourceRepoId();
+
+ try
+ {
+ // Create connector object.
+ ProxyConnector connector = new ProxyConnector();
+
+ connector.setSourceRepository(
+ repositoryFactory.getManagedRepositoryContent( proxyConfig.getSourceRepoId() ) );
+ connector.setTargetRepository(
+ repositoryFactory.getRemoteRepositoryContent( proxyConfig.getTargetRepoId() ) );
+
+ connector.setProxyId( proxyConfig.getProxyId() );
+ connector.setPolicies( proxyConfig.getPolicies() );
+ connector.setOrder( proxyConfig.getOrder() );
+ connector.setDisabled( proxyConfig.isDisabled() );
+
+ // Copy any blacklist patterns.
+ List<String> blacklist = new ArrayList<String>();
+ if ( CollectionUtils.isNotEmpty( proxyConfig.getBlackListPatterns() ) )
+ {
+ blacklist.addAll( proxyConfig.getBlackListPatterns() );
+ }
+ connector.setBlacklist( blacklist );
+
+ // Copy any whitelist patterns.
+ List<String> whitelist = new ArrayList<String>();
+ if ( CollectionUtils.isNotEmpty( proxyConfig.getWhiteListPatterns() ) )
+ {
+ whitelist.addAll( proxyConfig.getWhiteListPatterns() );
+ }
+ connector.setWhitelist( whitelist );
+
+ // Get other connectors
+ List<ProxyConnector> connectors = this.proxyConnectorMap.get( key );
+ if ( connectors == null )
+ {
+ // Create if we are the first.
+ connectors = new ArrayList<ProxyConnector>();
+ }
+
+ // Add the connector.
+ connectors.add( connector );
+
+ // Ensure the list is sorted.
+ Collections.sort( connectors, proxyOrderSorter );
+
+ // Set the key to the list of connectors.
+ this.proxyConnectorMap.put( key, connectors );
+ }
+ catch ( RepositoryNotFoundException e )
+ {
+ log.warn( "Unable to use proxy connector: " + e.getMessage(), e );
+ }
+ catch ( RepositoryException e )
+ {
+ log.warn( "Unable to use proxy connector: " + e.getMessage(), e );
+ }
+ }
+
+ }
+
+ synchronized ( this.networkProxyMap )
+ {
+ this.networkProxyMap.clear();
+
+ List<NetworkProxyConfiguration> networkProxies =
+ archivaConfiguration.getConfiguration().getNetworkProxies();
+ for ( NetworkProxyConfiguration networkProxyConfig : networkProxies )
+ {
+ String key = networkProxyConfig.getId();
+
+ ProxyInfo proxy = new ProxyInfo();
+
+ proxy.setType( networkProxyConfig.getProtocol() );
+ proxy.setHost( networkProxyConfig.getHost() );
+ proxy.setPort( networkProxyConfig.getPort() );
+ proxy.setUserName( networkProxyConfig.getUsername() );
+ proxy.setPassword( networkProxyConfig.getPassword() );
+
+ this.networkProxyMap.put( key, proxy );
+ }
+ }
+ }
+
public File fetchFromProxies( ManagedRepositoryContent repository, ArtifactReference artifact )
throws ProxyDownloadException
{
catch ( NotFoundException e )
{
log.debug( "Artifact " + Keys.toKey( artifact ) + " not found on repository \""
- + targetRepository.getRepository().getId() + "\"." );
+ + targetRepository.getRepository().getId() + "\"." );
}
catch ( NotModifiedException e )
{
log.debug( "Artifact " + Keys.toKey( artifact ) + " not updated on repository \""
- + targetRepository.getRepository().getId() + "\"." );
+ + targetRepository.getRepository().getId() + "\"." );
}
catch ( ProxyException e )
{
}
catch ( NotFoundException e )
{
- log.debug( "Resource " + path + " not found on repository \""
- + targetRepository.getRepository().getId() + "\"." );
+ log.debug( "Resource " + path + " not found on repository \"" + targetRepository.getRepository().getId()
+ + "\"." );
}
catch ( NotModifiedException e )
{
- log.debug( "Resource " + path + " not updated on repository \""
- + targetRepository.getRepository().getId() + "\"." );
+ log.debug(
+ "Resource " + path + " not updated on repository \"" + targetRepository.getRepository().getId()
+ + "\"." );
}
catch ( ProxyException e )
{
- log.warn( "Transfer error from repository \"" + targetRepository.getRepository().getId()
- + "\" for resource " + path + ", continuing to next repository. Error message: " + e.getMessage() );
+ log.warn(
+ "Transfer error from repository \"" + targetRepository.getRepository().getId() + "\" for resource "
+ + path + ", continuing to next repository. Error message: " + e.getMessage() );
log.debug( "Full stack trace", e );
}
}
catch ( NotFoundException e )
{
log.debug( "Metadata " + logicalPath + " not found on remote repository \""
- + targetRepository.getRepository().getId() + "\".", e );
+ + targetRepository.getRepository().getId() + "\".", e );
}
catch ( NotModifiedException e )
{
log.debug( "Metadata " + logicalPath + " not updated on remote repository \""
- + targetRepository.getRepository().getId() + "\".", e );
+ + targetRepository.getRepository().getId() + "\".", e );
}
catch ( ProxyException e )
{
log.warn( "Transfer error from repository \"" + targetRepository.getRepository().getId()
- + "\" for versioned Metadata " + logicalPath + ", continuing to next repository. Error message: "
- + e.getMessage() );
+ + "\" for versioned Metadata " + logicalPath
+ + ", continuing to next repository. Error message: " + e.getMessage() );
log.debug( "Full stack trace", e );
}
}
/**
* Simple method to test if the file exists on the local disk.
- *
+ *
* @param file the file to test. (may be null)
* @return true if file exists. false if the file param is null, doesn't exist, or is not of type File.
*/
/**
* Perform the transfer of the file.
- *
- * @param connector the connector configuration to use.
- * @param remoteRepository the remote repository get the resource from.
- * @param remotePath the path in the remote repository to the resource to get.
- * @param repository the managed repository that will hold the file
- * @param resource the local file to place the downloaded resource into
+ *
+ * @param connector the connector configuration to use.
+ * @param remoteRepository the remote repository get the resource from.
+ * @param remotePath the path in the remote repository to the resource to get.
+ * @param repository the managed repository that will hold the file
+ * @param resource the local file to place the downloaded resource into
* @param requestProperties the request properties to utilize for policy handling.
- * @param executeConsumers whether to execute the consumers after proxying
+ * @param executeConsumers whether to execute the consumers after proxying
* @return the local file that was downloaded, or null if not downloaded.
- * @throws NotFoundException if the file was not found on the remote repository.
+ * @throws NotFoundException if the file was not found on the remote repository.
* @throws NotModifiedException if the localFile was present, and the resource was present on remote repository, but
- * the remote resource is not newer than the local File.
- * @throws ProxyException if transfer was unsuccessful.
+ * the remote resource is not newer than the local File.
+ * @throws ProxyException if transfer was unsuccessful.
*/
private File transferFile( ProxyConnector connector, RemoteRepositoryContent remoteRepository, String remotePath,
ManagedRepositoryContent repository, File resource, Properties requestProperties,
// Path must belong to whitelist.
if ( !matchesPattern( remotePath, connector.getWhitelist() ) )
{
- log.debug( "Path [" + remotePath
- + "] is not part of defined whitelist (skipping transfer from repository ["
- + remoteRepository.getRepository().getName() + "])." );
+ log.debug( "Path [{}] is not part of defined whitelist (skipping transfer from repository [{}]).",
+ remotePath, remoteRepository.getRepository().getName() );
return null;
}
}
// Is target path part of blacklist?
if ( matchesPattern( remotePath, connector.getBlacklist() ) )
{
- log.debug( "Path [" + remotePath + "] is part of blacklist (skipping transfer from repository ["
- + remoteRepository.getRepository().getName() + "])." );
+ log.debug( "Path [{}] is part of blacklist (skipping transfer from repository [{}]).", remotePath,
+ remoteRepository.getRepository().getName() );
return null;
}
String emsg = "Transfer not attempted on " + url + " : " + e.getMessage();
if ( fileExists( resource ) )
{
- log.debug( emsg + ": using already present local file." );
+ log.debug( "{} : using already present local file.", emsg );
return resource;
}
{
RepositoryURL repoUrl = remoteRepository.getURL();
String protocol = repoUrl.getProtocol();
- wagon = (Wagon) wagonFactory.getWagon( "wagon#" + protocol );
+ wagon = wagonFactory.getWagon( "wagon#" + protocol );
if ( wagon == null )
{
throw new ProxyException( "Unsupported target repository protocol: " + protocol );
urlFailureCache.cacheFailure( url );
throw e;
}
+ catch ( WagonFactoryException e )
+ {
+ throw new ProxyException( e.getMessage(), e );
+ }
finally
{
if ( wagon != null )
}
catch ( PolicyViolationException e )
{
- log.warn( "Transfer invalidated from " + url + " : " + e.getMessage() );
+ log.warn( "Transfer invalidated from {} : {}", url, e.getMessage() );
executeConsumers = false;
if ( !fileExists( tmpResource ) )
{
}
catch ( TaskQueueException e )
{
- log.error( "Unable to queue repository task to execute consumers on resource file ['" +
- localFile.getName() + "']." );
+ log.error( "Unable to queue repository task to execute consumers on resource file ['" + localFile.getName()
+ + "']." );
}
}
/**
* Moves the file into repository location if it exists
- *
+ *
* @param fileToMove this could be either the main artifact, sha1 or md5 checksum file.
- * @param directory directory to write files to
+ * @param directory directory to write files to
*/
private void moveFileIfExists( File fileToMove, File directory )
throws ProxyException
* <p>
* Quietly transfer the checksum file from the remote repository to the local file.
* </p>
- *
- * @param wagon the wagon instance (should already be connected) to use.
+ *
+ * @param wagon the wagon instance (should already be connected) to use.
* @param remoteRepository the remote repository to transfer from.
- * @param remotePath the remote path to the resource to get.
- * @param repository the managed repository that will hold the file
- * @param resource the local file that should contain the downloaded contents
- * @param tmpDirectory the temporary directory to download to
- * @param ext the type of checksum to transfer (example: ".md5" or ".sha1")
+ * @param remotePath the remote path to the resource to get.
+ * @param repository the managed repository that will hold the file
+ * @param resource the local file that should contain the downloaded contents
+ * @param tmpDirectory the temporary directory to download to
+ * @param ext the type of checksum to transfer (example: ".md5" or ".sha1")
* @throws ProxyException if copying the downloaded file into place did not succeed.
*/
private File transferChecksum( Wagon wagon, RemoteRepositoryContent remoteRepository, String remotePath,
catch ( NotFoundException e )
{
urlFailureCache.cacheFailure( url );
- log.debug( "Transfer failed, checksum not found: " + url );
+ log.debug( "Transfer failed, checksum not found: {}", url );
// Consume it, do not pass this on.
}
catch ( NotModifiedException e )
{
- log.debug( "Transfer skipped, checksum not modified: " + url );
+ log.debug( "Transfer skipped, checksum not modified: {}", url );
// Consume it, do not pass this on.
}
catch ( ProxyException e )
/**
* Perform the transfer of the remote file to the local file specified.
- *
- * @param wagon the wagon instance to use.
+ *
+ * @param wagon the wagon instance to use.
* @param remoteRepository the remote repository to use
- * @param remotePath the remote path to attempt to get
- * @param repository the managed repository that will hold the file
- * @param origFile the local file to save to
+ * @param remotePath the remote path to attempt to get
+ * @param repository the managed repository that will hold the file
+ * @param origFile the local file to save to
* @return The local file that was transfered.
* @throws ProxyException if there was a problem moving the downloaded file into place.
* @throws WagonException if there was a problem tranfering the file.
if ( !origFile.exists() )
{
- log.debug( "Retrieving " + remotePath + " from " + remoteRepository.getRepository().getName() );
+ log.debug( "Retrieving {} from {}", remotePath, remoteRepository.getRepository().getName() );
wagon.get( remotePath, destFile );
success = true;
}
else
{
- log.debug( "Retrieving " + remotePath + " from " + remoteRepository.getRepository().getName()
- + " if updated" );
+ log.debug( "Retrieving {} from {} if updated", remotePath, remoteRepository.getRepository().getName() );
success = wagon.getIfNewer( remotePath, destFile, origFile.lastModified() );
if ( !success )
{
- throw new NotModifiedException( "Not downloaded, as local file is newer than remote side: "
- + origFile.getAbsolutePath() );
+ throw new NotModifiedException(
+ "Not downloaded, as local file is newer than remote side: " + origFile.getAbsolutePath() );
}
if ( destFile.exists() )
}
catch ( ResourceDoesNotExistException e )
{
- throw new NotFoundException( "Resource [" + remoteRepository.getURL() + "/" + remotePath
- + "] does not exist: " + e.getMessage(), e );
+ throw new NotFoundException(
+ "Resource [" + remoteRepository.getURL() + "/" + remotePath + "] does not exist: " + e.getMessage(),
+ e );
}
catch ( WagonException e )
{
/**
* Apply the policies.
- *
- * @param policies the map of policies to execute. (Map of String policy keys, to {@link DownloadPolicy} objects)
- * @param settings the map of settings for the policies to execute. (Map of String policy keys, to String policy
- * setting)
- * @param request the request properties (utilized by the {@link DownloadPolicy#applyPolicy(String,Properties,File)}
- * )
- * @param localFile the local file (utilized by the {@link DownloadPolicy#applyPolicy(String,Properties,File)})
+ *
+ * @param policies the map of policies to execute. (Map of String policy keys, to {@link DownloadPolicy} objects)
+ * @param settings the map of settings for the policies to execute. (Map of String policy keys, to String policy
+ * setting)
+ * @param request the request properties (utilized by the {@link DownloadPolicy#applyPolicy(String, Properties, File)}
+ * )
+ * @param localFile the local file (utilized by the {@link DownloadPolicy#applyPolicy(String, Properties, File)})
*/
private void validatePolicies( Map<String, ? extends DownloadPolicy> policies, Map<String, String> settings,
Properties request, File localFile )
if ( !previousExceptions.containsKey( content.getId() ) )
{
throw new ProxyDownloadException(
- "An error occurred in downloading from the remote repository, and the policy is to fail immediately",
- content.getId(), exception );
+ "An error occurred in downloading from the remote repository, and the policy is to fail immediately",
+ content.getId(), exception );
}
}
else
}
log.warn( "Transfer error from repository \"" + content.getRepository().getId() + "\" for artifact "
- + Keys.toKey( artifact ) + ", continuing to next repository. Error message: " + exception.getMessage() );
+ + Keys.toKey( artifact ) + ", continuing to next repository. Error message: "
+ + exception.getMessage() );
log.debug( "Full stack trace", exception );
}
/**
* Creates a working directory in the repository root for this request
- *
+ *
* @param repository
* @return file location of working directory
* @throws IOException
/**
* Used to move the temporary file to its real destination. This is patterned from the way WagonManager handles its
* downloaded files.
- *
- * @param temp The completed download file
+ *
+ * @param temp The completed download file
* @param target The final location of the downloaded file
* @throws ProxyException when the temp file cannot replace the target file
*/
if ( target.exists() )
{
log.debug( "Tried to copy file " + temp.getName() + " to " + target.getAbsolutePath()
- + " but file with this name already exists." );
+ + " but file with this name already exists." );
}
else
{
- throw new ProxyException( "Cannot copy tmp file " + temp.getAbsolutePath()
- + " to its final location", e );
+ throw new ProxyException(
+ "Cannot copy tmp file " + temp.getAbsolutePath() + " to its final location", e );
}
}
finally
/**
* Using wagon, connect to the remote repository.
- *
- * @param connector the connector configuration to utilize (for obtaining network proxy configuration from)
- * @param wagon the wagon instance to establish the connection on.
+ *
+ * @param connector the connector configuration to utilize (for obtaining network proxy configuration from)
+ * @param wagon the wagon instance to establish the connection on.
* @param remoteRepository the remote repository to connect to.
* @return true if the connection was successful. false if not connected.
*/
- private boolean connectToRepository( ProxyConnector connector, Wagon wagon, RemoteRepositoryContent remoteRepository )
+ private boolean connectToRepository( ProxyConnector connector, Wagon wagon,
+ RemoteRepositoryContent remoteRepository )
{
boolean connected = false;
if ( networkProxy != null )
{
// TODO: move to proxyInfo.toString()
- String msg =
- "Using network proxy " + networkProxy.getHost() + ":" + networkProxy.getPort()
- + " to connect to remote repository " + remoteRepository.getURL();
+ String msg = "Using network proxy " + networkProxy.getHost() + ":" + networkProxy.getPort()
+ + " to connect to remote repository " + remoteRepository.getURL();
if ( networkProxy.getNonProxyHosts() != null )
{
msg += "; excluding hosts: " + networkProxy.getNonProxyHosts();
/**
* Tests whitelist and blacklist patterns against path.
- *
- * @param path the path to test.
+ *
+ * @param path the path to test.
* @param patterns the list of patterns to check.
* @return true if the path matches at least 1 pattern in the provided patterns list.
*/
{
path = "/" + path;
}
-
+
for ( String pattern : patterns )
{
if ( !pattern.startsWith( "/" ) )
{
pattern = "/" + pattern;
}
-
+
if ( SelectorUtils.matchPath( pattern, path, false ) )
{
return true;
{
if ( ConfigurationNames.isNetworkProxy( propertyName )
|| ConfigurationNames.isManagedRepositories( propertyName )
- || ConfigurationNames.isRemoteRepositories( propertyName )
- || ConfigurationNames.isProxyConnector( propertyName ) )
+ || ConfigurationNames.isRemoteRepositories( propertyName ) || ConfigurationNames.isProxyConnector(
+ propertyName ) )
{
initConnectorsAndNetworkProxies();
}
/* do nothing */
}
- @SuppressWarnings( "unchecked" )
- private void initConnectorsAndNetworkProxies()
- {
- synchronized ( this.proxyConnectorMap )
- {
- ProxyConnectorOrderComparator proxyOrderSorter = new ProxyConnectorOrderComparator();
- this.proxyConnectorMap.clear();
-
- List<ProxyConnectorConfiguration> proxyConfigs =
- archivaConfiguration.getConfiguration().getProxyConnectors();
- for ( ProxyConnectorConfiguration proxyConfig : proxyConfigs )
- {
- String key = proxyConfig.getSourceRepoId();
-
- try
- {
- // Create connector object.
- ProxyConnector connector = new ProxyConnector();
-
- connector.setSourceRepository( repositoryFactory.getManagedRepositoryContent( proxyConfig.getSourceRepoId() ) );
- connector.setTargetRepository( repositoryFactory.getRemoteRepositoryContent( proxyConfig.getTargetRepoId() ) );
-
- connector.setProxyId( proxyConfig.getProxyId() );
- connector.setPolicies( proxyConfig.getPolicies() );
- connector.setOrder( proxyConfig.getOrder() );
- connector.setDisabled( proxyConfig.isDisabled() );
-
- // Copy any blacklist patterns.
- List<String> blacklist = new ArrayList<String>();
- if ( CollectionUtils.isNotEmpty( proxyConfig.getBlackListPatterns() ) )
- {
- blacklist.addAll( proxyConfig.getBlackListPatterns() );
- }
- connector.setBlacklist( blacklist );
-
- // Copy any whitelist patterns.
- List<String> whitelist = new ArrayList<String>();
- if ( CollectionUtils.isNotEmpty( proxyConfig.getWhiteListPatterns() ) )
- {
- whitelist.addAll( proxyConfig.getWhiteListPatterns() );
- }
- connector.setWhitelist( whitelist );
-
- // Get other connectors
- List<ProxyConnector> connectors = this.proxyConnectorMap.get( key );
- if ( connectors == null )
- {
- // Create if we are the first.
- connectors = new ArrayList<ProxyConnector>();
- }
-
- // Add the connector.
- connectors.add( connector );
-
- // Ensure the list is sorted.
- Collections.sort( connectors, proxyOrderSorter );
-
- // Set the key to the list of connectors.
- this.proxyConnectorMap.put( key, connectors );
- }
- catch ( RepositoryNotFoundException e )
- {
- log.warn( "Unable to use proxy connector: " + e.getMessage(), e );
- }
- catch ( RepositoryException e )
- {
- log.warn( "Unable to use proxy connector: " + e.getMessage(), e );
- }
- }
-
- }
-
- synchronized ( this.networkProxyMap )
- {
- this.networkProxyMap.clear();
-
- List<NetworkProxyConfiguration> networkProxies =
- archivaConfiguration.getConfiguration().getNetworkProxies();
- for ( NetworkProxyConfiguration networkProxyConfig : networkProxies )
- {
- String key = networkProxyConfig.getId();
-
- ProxyInfo proxy = new ProxyInfo();
-
- proxy.setType( networkProxyConfig.getProtocol() );
- proxy.setHost( networkProxyConfig.getHost() );
- proxy.setPort( networkProxyConfig.getPort() );
- proxy.setUserName( networkProxyConfig.getUsername() );
- proxy.setPassword( networkProxyConfig.getPassword() );
-
- this.networkProxyMap.put( key, proxy );
- }
- }
- }
-
- public void initialize()
- throws InitializationException
- {
- initConnectorsAndNetworkProxies();
- archivaConfiguration.addChangeListener( this );
- }
}
import org.apache.maven.wagon.Wagon;
/**
- * Create a Wagon instance for the given protocol. Implementation will be provided by a Spring service locator.
- *
+ * Create a Wagon instance for the given protocol.
*/
public interface WagonFactory
{
/**
* Create a new Wagon instance for the given protocol.
- *
- * @param protocol the protocol to find the Wagon for, which must be prefixed with <code>wagon#</code>, for example
- * <code>wagon#http</code>.
- * @return the Wagon instance
+ *
+ * @param protocol the protocol to find the Wagon for, which must be prefixed with <code>wagon#</code>, for example
+ * <code>wagon#http</code>.
+ * @return the Wagon instance
*/
- Wagon getWagon( String protocol );
+ Wagon getWagon( String protocol )
+ throws WagonFactoryException;
}
~ KIND, either express or implied. See the License for the
~ specific language governing permissions and limitations
~ under the License.
--->
+ -->
+
<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans
+ http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+ http://www.springframework.org/schema/context
+ http://www.springframework.org/schema/context/spring-context-3.0.xsd"
+ default-lazy-init="true">
+
+ <context:annotation-config/>
+ <context:component-scan base-package="org.apache.maven.archiva.proxy"/>
+
- <bean id="wagonFactory"
- class="org.springframework.beans.factory.config.ServiceLocatorFactoryBean">
- <property name="serviceLocatorInterface"
- value="org.apache.maven.archiva.proxy.WagonFactory" />
- </bean>
</beans>
\ No newline at end of file
package org.apache.archiva.metadata.repository;
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
+import org.springframework.stereotype.Service;
+/*
+* Licensed to the Apache Software Foundation (ASF) under one
+* or more contributor license agreements. See the NOTICE file
+* distributed with this work for additional information
+* regarding copyright ownership. The ASF licenses this file
+* to you under the Apache License, Version 2.0 (the
+* "License"); you may not use this file except in compliance
+* with the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied. See the License for the
+* specific language governing permissions and limitations
+* under the License.
+*/
+@Service("repositorySessionFactory")
public class TestRepositorySessionFactory
implements RepositorySessionFactory
{
* under the License.
*/
+import junit.framework.TestCase;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.ArrayUtils;
import org.apache.maven.archiva.configuration.ArchivaConfiguration;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
import org.apache.maven.archiva.repository.ManagedRepositoryContent;
import org.apache.maven.wagon.Wagon;
-import org.codehaus.plexus.spring.PlexusInSpringTestCase;
import org.easymock.ArgumentsMatcher;
import org.easymock.MockControl;
-
+import org.junit.Before;
+import org.junit.runner.RunWith;
+import org.springframework.context.ApplicationContext;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import javax.inject.Inject;
+import javax.inject.Named;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
*
* @version $Id$
*/
+@RunWith( SpringJUnit4ClassRunner.class )
+@ContextConfiguration( locations = { "classpath*:/META-INF/spring-context.xml", "classpath:/spring-context.xml" } )
public abstract class AbstractProxyTestCase
- extends PlexusInSpringTestCase
+ extends TestCase
{
+
+ @Inject
+ protected ApplicationContext applicationContext;
+
protected static final String ID_LEGACY_PROXIED = "legacy-proxied";
protected static final String ID_PROXIED1 = "proxied1";
protected static final String REPOPATH_LEGACY_MANAGED_TARGET = "target/test-repository/legacy-managed";
+ protected MockControl wagonMockControl;
+
+ protected Wagon wagonMock;
+
+
+ protected RepositoryProxyConnectors proxyHandler;
+
+ protected ManagedRepositoryContent managedDefaultRepository;
+
+ protected File managedDefaultDir;
+
+ protected ManagedRepositoryContent managedLegacyRepository;
+
+ protected File managedLegacyDir;
+
+ protected MockConfiguration config;
+
+ @Inject
+ @Named( value = "wagon#test" )
+ WagonDelegate delegate;
+
+ @Before
+ public void setUp()
+ throws Exception
+ {
+ super.setUp();
+
+ proxyHandler = applicationContext.getBean( RepositoryProxyConnectors.class );
+
+ config =
+ (MockConfiguration) applicationContext.getBean( "archivaConfiguration#mock", ArchivaConfiguration.class );
+
+ // Setup source repository (using default layout)
+ String repoPath = "target/test-repository/managed/" + getName();
+ File repoLocation = new File( repoPath );
+
+ managedDefaultRepository =
+ createRepository( ID_DEFAULT_MANAGED, "Default Managed Repository", repoPath, "default" );
+
+ managedDefaultDir = new File( managedDefaultRepository.getRepoRoot() );
+
+ ManagedRepositoryConfiguration repoConfig = managedDefaultRepository.getRepository();
+
+ config.getConfiguration().addManagedRepository( repoConfig );
+
+ // Setup source repository (using legacy layout)
+ repoLocation = new File( REPOPATH_LEGACY_MANAGED_TARGET );
+ FileUtils.deleteDirectory( repoLocation );
+ copyDirectoryStructure( new File( REPOPATH_LEGACY_MANAGED ), repoLocation );
+
+ managedLegacyRepository =
+ createRepository( ID_LEGACY_MANAGED, "Legacy Managed Repository", REPOPATH_LEGACY_MANAGED_TARGET,
+ "legacy" );
+
+ managedLegacyDir = new File( managedLegacyRepository.getRepoRoot() );
+
+ repoConfig = managedLegacyRepository.getRepository();
+
+ config.getConfiguration().addManagedRepository( repoConfig );
+
+ // Setup target (proxied to) repository.
+ saveRemoteRepositoryConfig( ID_PROXIED1, "Proxied Repository 1",
+ new File( REPOPATH_PROXIED1 ).toURL().toExternalForm(), "default" );
+
+ // Setup target (proxied to) repository.
+ saveRemoteRepositoryConfig( ID_PROXIED2, "Proxied Repository 2",
+ new File( REPOPATH_PROXIED2 ).toURL().toExternalForm(), "default" );
+
+ // Setup target (proxied to) repository using legacy layout.
+ saveRemoteRepositoryConfig( ID_LEGACY_PROXIED, "Proxied Legacy Repository",
+ new File( REPOPATH_PROXIED_LEGACY ).toURL().toExternalForm(), "legacy" );
+
+ // Setup the proxy handler.
+ //proxyHandler = applicationContext.getBean (RepositoryProxyConnectors) lookup( RepositoryProxyConnectors.class.getName() );
+
+ // Setup the wagon mock.
+ wagonMockControl = MockControl.createNiceControl( Wagon.class );
+ wagonMock = (Wagon) wagonMockControl.getMock();
+
+ delegate.setDelegate( wagonMock );
+
+ System.out.println( "\n.\\ " + getName() + "() \\._________________________________________\n" );
+ }
+
protected static final ArgumentsMatcher customWagonGetIfNewerMatcher = new ArgumentsMatcher()
{
{
return false;
}
- return MockControl.ARRAY_MATCHER.matches( ArrayUtils.remove( expected, 1 ), ArrayUtils.remove( actual,
- 1 ) );
+ return MockControl.ARRAY_MATCHER.matches( ArrayUtils.remove( expected, 1 ),
+ ArrayUtils.remove( actual, 1 ) );
}
public String toString( Object[] arguments )
}
};
- protected MockControl wagonMockControl;
-
- protected Wagon wagonMock;
-
- protected RepositoryProxyConnectors proxyHandler;
-
- protected ManagedRepositoryContent managedDefaultRepository;
-
- protected File managedDefaultDir;
-
- protected ManagedRepositoryContent managedLegacyRepository;
-
- protected File managedLegacyDir;
-
- protected MockConfiguration config;
protected void assertChecksums( File expectedFile, String expectedSha1Contents, String expectedMd5Contents )
throws Exception
return;
}
- Collection<File> tmpFiles = FileUtils.listFiles( workingDir, new String[]{"tmp"}, false );
+ Collection<File> tmpFiles = FileUtils.listFiles( workingDir, new String[]{ "tmp" }, false );
if ( !tmpFiles.isEmpty() )
{
StringBuffer emsg = new StringBuffer();
repo.setLocation( path );
repo.setLayout( layout );
- ManagedRepositoryContent repoContent = (ManagedRepositoryContent) lookup( ManagedRepositoryContent.class,
- layout );
+ ManagedRepositoryContent repoContent =
+ applicationContext.getBean( "managedRepositoryContent#" + layout, ManagedRepositoryContent.class );
repoContent.setRepository( repo );
return repoContent;
}
config.triggerChange( prefix + ".policies.checksum", connectorConfig.getPolicy( "checksum", "" ) );
config.triggerChange( prefix + ".policies.snapshots", connectorConfig.getPolicy( "snapshots", "" ) );
config.triggerChange( prefix + ".policies.cache-failures", connectorConfig.getPolicy( "cache-failures", "" ) );
- config.triggerChange( prefix + ".policies.propagate-errors", connectorConfig.getPolicy( "propagate-errors",
- "" ) );
- config.triggerChange( prefix + ".policies.propagate-errors-on-update", connectorConfig.getPolicy(
- "propagate-errors-on-update", "" ) );
+ config.triggerChange( prefix + ".policies.propagate-errors",
+ connectorConfig.getPolicy( "propagate-errors", "" ) );
+ config.triggerChange( prefix + ".policies.propagate-errors-on-update",
+ connectorConfig.getPolicy( "propagate-errors-on-update", "" ) );
}
protected void saveManagedRepositoryConfig( String id, String name, String path, String layout )
protected File saveTargetedRepositoryConfig( String id, String originalPath, String targetPath, String layout )
throws IOException
{
- File repoLocation = getTestFile( targetPath );
+ File repoLocation = new File( targetPath );
FileUtils.deleteDirectory( repoLocation );
- copyDirectoryStructure( getTestFile( originalPath ), repoLocation );
+ copyDirectoryStructure( new File( originalPath ), repoLocation );
saveRemoteRepositoryConfig( id, "Target Repo-" + id, targetPath, layout );
return repoLocation;
}
- /**
- * {@inheritDoc}
- *
- * @see org.codehaus.plexus.spring.PlexusInSpringTestCase#getConfigLocation()
- */
- @Override
- protected String getSpringConfigLocation()
- {
- return "org/apache/maven/archiva/proxy/spring-context.xml";
- }
-
- @Override
- protected void setUp()
- throws Exception
- {
- super.setUp();
-
- config = (MockConfiguration) lookup( ArchivaConfiguration.class.getName(), "mock" );
-
- // Setup source repository (using default layout)
- String repoPath = "target/test-repository/managed/" + getName();
- File repoLocation = getTestFile( repoPath );
-
- managedDefaultRepository = createRepository( ID_DEFAULT_MANAGED, "Default Managed Repository", repoPath,
- "default" );
-
- managedDefaultDir = new File( managedDefaultRepository.getRepoRoot() );
-
- ManagedRepositoryConfiguration repoConfig = managedDefaultRepository.getRepository();
-
- config.getConfiguration().addManagedRepository( repoConfig );
-
- // Setup source repository (using legacy layout)
- repoLocation = getTestFile( REPOPATH_LEGACY_MANAGED_TARGET );
- FileUtils.deleteDirectory( repoLocation );
- copyDirectoryStructure( getTestFile( REPOPATH_LEGACY_MANAGED ), repoLocation );
-
- managedLegacyRepository = createRepository( ID_LEGACY_MANAGED, "Legacy Managed Repository",
- REPOPATH_LEGACY_MANAGED_TARGET, "legacy" );
-
- managedLegacyDir = new File( managedLegacyRepository.getRepoRoot() );
-
- repoConfig = managedLegacyRepository.getRepository();
-
- config.getConfiguration().addManagedRepository( repoConfig );
-
- // Setup target (proxied to) repository.
- saveRemoteRepositoryConfig( ID_PROXIED1, "Proxied Repository 1", new File(
- REPOPATH_PROXIED1 ).toURL().toExternalForm(), "default" );
-
- // Setup target (proxied to) repository.
- saveRemoteRepositoryConfig( ID_PROXIED2, "Proxied Repository 2", new File(
- REPOPATH_PROXIED2 ).toURL().toExternalForm(), "default" );
-
- // Setup target (proxied to) repository using legacy layout.
- saveRemoteRepositoryConfig( ID_LEGACY_PROXIED, "Proxied Legacy Repository", new File(
- REPOPATH_PROXIED_LEGACY ).toURL().toExternalForm(), "legacy" );
-
- // Setup the proxy handler.
- try
- {
- proxyHandler = (RepositoryProxyConnectors) lookup( RepositoryProxyConnectors.class.getName() );
- }
- catch ( Exception e )
- {
- // TODO: handle in plexus-spring instead
- applicationContext.close();
- throw e;
- }
-
- // Setup the wagon mock.
- wagonMockControl = MockControl.createNiceControl( Wagon.class );
- wagonMock = (Wagon) wagonMockControl.getMock();
- WagonDelegate delegate = (WagonDelegate) lookup( Wagon.ROLE, "test" );
- delegate.setDelegate( wagonMock );
-
- System.out.println( "\n.\\ " + getName() + "() \\._________________________________________\n" );
- }
/**
* Copy the specified resource directory from the src/test/repository/managed/ to
* the testable directory under target/test-repository/managed/${testName}/
*
- * @param resourceDir
+ * @param resourcePath
* @throws IOException
*/
protected void setupTestableManagedRepository( String resourcePath )
String managedLegacyPath = managedLegacyDir.getCanonicalPath();
String testFile = file.getCanonicalPath();
- assertTrue( "Unit Test Failure: File <" + testFile +
- "> should be have been defined within the legacy managed path of <" + managedLegacyPath + ">",
- testFile.startsWith( managedLegacyPath ) );
+ assertTrue(
+ "Unit Test Failure: File <" + testFile + "> should be have been defined within the legacy managed path of <"
+ + managedLegacyPath + ">", testFile.startsWith( managedLegacyPath ) );
assertFalse( "File < " + testFile + "> should not exist in managed legacy repository.", file.exists() );
}
String managedDefaultPath = managedDefaultDir.getCanonicalPath();
String testFile = file.getCanonicalPath();
- assertTrue( "Unit Test Failure: File <" + testFile +
- "> should be have been defined within the managed default path of <" + managedDefaultPath + ">",
- testFile.startsWith( managedDefaultPath ) );
+ assertTrue( "Unit Test Failure: File <" + testFile
+ + "> should be have been defined within the managed default path of <" + managedDefaultPath
+ + ">", testFile.startsWith( managedDefaultPath ) );
assertFalse( "File < " + testFile + "> should not exist in managed default repository.", file.exists() );
}
import org.apache.maven.archiva.policies.SnapshotsPolicy;
import org.apache.maven.archiva.policies.urlcache.UrlFailureCache;
import org.apache.maven.wagon.ResourceDoesNotExistException;
+import org.junit.Test;
+import javax.inject.Inject;
import java.io.File;
/**
// TODO: test some hard failures (eg TransferFailedException)
// TODO: test the various combinations of fetchFrom* (note: need only test when caching is enabled)
+ @Test
public void testGetWithCacheFailuresOn()
throws Exception
{
wagonMock.get( path, new File( expectedFile.getParentFile(), expectedFile.getName() + ".tmp" ) );
- wagonMockControl.setMatcher(customWagonGetMatcher);
+ wagonMockControl.setMatcher( customWagonGetMatcher );
wagonMockControl.setThrowable( new ResourceDoesNotExistException( "resource does not exist." ), 2 );
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetWithCacheFailuresOff()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, "badproxied1", ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, "badproxied2", ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
wagonMock.get( path, new File( expectedFile.getParentFile(), expectedFile.getName() + ".tmp" ) );
- wagonMockControl.setMatcher(customWagonGetMatcher);
+ wagonMockControl.setMatcher( customWagonGetMatcher );
wagonMockControl.setThrowable( new ResourceDoesNotExistException( "resource does not exist." ), 2 );
wagonMockControl.replay();
wagonMockControl.reset();
wagonMock.get( path, new File( expectedFile.getParentFile(), expectedFile.getName() + ".tmp" ) );
- wagonMockControl.setMatcher(customWagonGetMatcher);
+ wagonMockControl.setMatcher( customWagonGetMatcher );
wagonMockControl.setThrowable( new ResourceDoesNotExistException( "resource does not exist." ), 2 );
wagonMockControl.replay();
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetWhenInBothProxiedButFirstCacheFailure()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Inject
+ UrlFailureCache urlFailureCache;
+
protected UrlFailureCache lookupUrlFailureCache()
throws Exception
{
- UrlFailureCache urlFailureCache = (UrlFailureCache) lookup( "urlFailureCache" );
+ //UrlFailureCache urlFailureCache = (UrlFailureCache) lookup( "urlFailureCache" );
assertNotNull( "URL Failure Cache cannot be null.", urlFailureCache );
return urlFailureCache;
}
import org.apache.maven.archiva.policies.ReleasesPolicy;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
import org.apache.maven.wagon.ResourceDoesNotExistException;
+import org.junit.Test;
import java.io.File;
public class ChecksumTransferTest
extends AbstractProxyTestCase
{
+ @Test
public void testGetChecksumWhenConnectorIsDisabled()
throws Exception
{
assertNull(downloadedFile);
}
-
+
+ @Test
public void testGetChecksumBothCorrect()
throws Exception
{
"e58f30c6a150a2e843552438d18e15cb *get-checksum-both-right-1.0.jar" );
}
+ @Test
public void testGetChecksumCorrectSha1NoMd5()
throws Exception
{
null );
}
+ @Test
public void testGetChecksumNoSha1CorrectMd5()
throws Exception
{
assertChecksums( expectedFile, null, "f3af5201bf8da801da37db8842846e1c *get-checksum-md5-only-1.0.jar" );
}
+ @Test
public void testGetWithNoChecksumsUsingIgnoredSetting()
throws Exception
{
assertChecksums( expectedFile, null, null );
}
+ @Test
public void testGetChecksumBadSha1BadMd5IgnoredSetting()
throws Exception
{
assertChecksums( expectedFile, "invalid checksum file", "invalid checksum file" );
}
+ @Test
public void testGetChecksumBadSha1BadMd5FailSetting()
throws Exception
{
assertChecksums( expectedFile, null, null );
}
+ @Test
public void testGetChecksumBadSha1BadMd5FixSetting()
throws Exception
{
"a292491a35925465e693a44809a078b5 get-checksum-both-bad-1.0.jar" );
}
+ @Test
public void testGetChecksumCorrectSha1BadMd5UsingFailSetting()
throws Exception
{
assertChecksums( expectedFile, null, null );
}
+ @Test
public void testGetChecksumNoSha1CorrectMd5UsingFailSetting()
throws Exception
{
assertChecksums( expectedFile, null, "f3af5201bf8da801da37db8842846e1c *get-checksum-md5-only-1.0.jar" );
}
+ @Test
public void testGetWithNoChecksumsUsingFailSetting()
throws Exception
{
assertChecksums( expectedFile, null, null );
}
+ @Test
public void testGetChecksumCorrectSha1BadMd5UsingIgnoredSetting()
throws Exception
{
"invalid checksum file" );
}
+ @Test
public void testGetChecksumCorrectSha1BadMd5UsingFixSetting()
throws Exception
{
"c35f3b76268b73a4ba617f6f275c49ab get-checksum-sha1-bad-md5-1.0.jar" );
}
+ @Test
public void testGetChecksumNoSha1CorrectMd5UsingFixSetting()
throws Exception
{
"f3af5201bf8da801da37db8842846e1c *get-checksum-md5-only-1.0.jar" );
}
+ @Test
public void testGetWithNoChecksumsUsingFixSetting()
throws Exception
{
"3f7341545f21226b6f49a3c2704cb9be get-default-layout-1.0.jar" );
}
+ @Test
public void testGetChecksumNotFoundOnRemote()
throws Exception
{
null );
}
+ @Test
public void testGetAlwaysBadChecksumPresentLocallyAbsentRemoteUsingIgnoredSetting()
throws Exception
{
assertChecksums( expectedFile, "invalid checksum file", "invalid checksum file" );
}
+ @Test
public void testGetAlwaysBadChecksumPresentLocallyAbsentRemoteUsingFailSetting()
throws Exception
{
assertChecksums( expectedFile, "invalid checksum file", "invalid checksum file" );
}
+ @Test
public void testGetAlwaysBadChecksumPresentLocallyAbsentRemoteUsingFixSetting()
throws Exception
{
import org.apache.maven.wagon.ResourceDoesNotExistException;
import org.apache.maven.wagon.TransferFailedException;
import org.apache.maven.wagon.authorization.AuthorizationException;
+import org.junit.Test;
import java.io.File;
private static final String NAME_MOCKED_PROXIED2 = "Bad Proxied 2";
+ @Test
public void testPropagateErrorImmediatelyWithErrorThenSuccess()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateErrorImmediatelyWithNotFoundThenError()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED2 );
}
+ @Test
public void testPropagateErrorImmediatelyWithSuccessThenError()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED1 );
}
+ @Test
public void testPropagateErrorImmediatelyWithNotFoundThenSuccess()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED2 );
}
+ @Test
public void testPropagateErrorAtEndWithErrorThenSuccess()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateErrorAtEndWithSuccessThenError()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED1 );
}
+ @Test
public void testPropagateErrorAtEndWithNotFoundThenError()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED2 );
}
+ @Test
public void testPropagateErrorAtEndWithErrorThenNotFound()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateErrorAtEndWithErrorThenError()
throws Exception
{
confirmFailures( path, new String[]{ID_MOCKED_PROXIED1, ID_MOCKED_PROXIED2} );
}
+ @Test
public void testPropagateErrorAtEndWithNotFoundThenSuccess()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED2 );
}
+ @Test
public void testIgnoreErrorWithErrorThenSuccess()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED2 );
}
+ @Test
public void testIgnoreErrorWithSuccessThenError()
throws Exception
{
confirmSuccess( path, expectedFile, REPOPATH_PROXIED1 );
}
+ @Test
public void testIgnoreErrorWithNotFoundThenError()
throws Exception
{
confirmNotDownloadedNoError( path );
}
+ @Test
public void testIgnoreErrorWithErrorThenNotFound()
throws Exception
{
confirmNotDownloadedNoError( path );
}
+ @Test
public void testIgnoreErrorWithErrorThenError()
throws Exception
{
confirmNotDownloadedNoError( path );
}
+ @Test
public void testPropagateOnUpdateAlwaysArtifactNotPresent()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateOnUpdateAlwaysArtifactPresent()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateOnUpdateAlwaysQueueArtifactNotPresent()
throws Exception
{
confirmFailures( path, new String[] { ID_MOCKED_PROXIED1, ID_MOCKED_PROXIED2 } );
}
+ @Test
public void testPropagateOnUpdateAlwaysQueueArtifactPresent()
throws Exception
{
confirmFailures( path, new String[] { ID_MOCKED_PROXIED1, ID_MOCKED_PROXIED2 } );
}
+ @Test
public void testPropagateOnUpdateAlwaysIgnoreArtifactNotPresent()
throws Exception
{
confirmNotDownloadedNoError( path );
}
+ @Test
public void testPropagateOnUpdateAlwaysIgnoreArtifactPresent()
throws Exception
{
assertTrue( expectedFile.exists() );
}
+ @Test
public void testPropagateOnUpdateNotPresentArtifactNotPresent()
throws Exception
{
confirmSingleFailure( path, ID_MOCKED_PROXIED1 );
}
+ @Test
public void testPropagateOnUpdateNotPresentArtifactPresent()
throws Exception
{
assertTrue( expectedFile.exists() );
}
+ @Test
public void testPropagateOnUpdateNotPresentQueueArtifactNotPresent()
throws Exception
{
confirmFailures( path, new String[] { ID_MOCKED_PROXIED1, ID_MOCKED_PROXIED2 } );
}
+ @Test
public void testPropagateOnUpdateNotPresentQueueArtifactPresent()
throws Exception
{
assertTrue( expectedFile.exists() );
}
+ @Test
public void testPropagateOnUpdateNotPresentIgnoreArtifactNotPresent()
throws Exception
{
confirmNotDownloadedNoError( path );
}
+ @Test
public void testPropagateOnUpdateNotPresentIgnoreArtifactPresent()
throws Exception
{
* under the License.
*/
+import junit.framework.TestCase;
import org.apache.commons.io.FileUtils;
import org.apache.maven.archiva.configuration.ArchivaConfiguration;
import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
import org.apache.maven.archiva.policies.ReleasesPolicy;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
import org.apache.maven.archiva.repository.ManagedRepositoryContent;
-import org.codehaus.plexus.spring.PlexusInSpringTestCase;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
import org.mortbay.jetty.Handler;
import org.mortbay.jetty.Request;
import org.mortbay.jetty.Server;
import org.mortbay.jetty.handler.AbstractHandler;
+import org.springframework.context.ApplicationContext;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-import java.io.File;
-import java.io.IOException;
+import javax.inject.Inject;
+import javax.inject.Named;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import java.io.File;
+import java.io.IOException;
/**
* Integration test for connecting over a HTTP proxy.
*
* @version $Id: ManagedDefaultTransferTest.java 677852 2008-07-18 08:16:24Z brett $
*/
+@RunWith( SpringJUnit4ClassRunner.class )
+@ContextConfiguration( locations = { "classpath*:/META-INF/spring-context.xml", "classpath:/spring-context.xml" } )
public class HttpProxyTransferTest
- extends PlexusInSpringTestCase
+ extends TestCase
{
private static final String PROXY_ID = "proxy";
private ManagedRepositoryContent managedDefaultRepository;
+ @Inject
+ private ApplicationContext applicationContext;
+
private Server server;
- @Override
- protected void setUp()
+ @Before
+ public void setUp()
throws Exception
{
super.setUp();
+ proxyHandler = applicationContext.getBean( RepositoryProxyConnectors.class );
+
+ config =
+ (MockConfiguration) applicationContext.getBean( "archivaConfiguration#mock", ArchivaConfiguration.class );
+
// Setup source repository (using default layout)
String repoPath = "target/test-repository/managed/" + getName();
repo.setLocation( repoPath );
repo.setLayout( "default" );
- ManagedRepositoryContent repoContent = (ManagedRepositoryContent) lookup( ManagedRepositoryContent.class,
- "default" );
+ ManagedRepositoryContent repoContent =
+ applicationContext.getBean( "managedRepositoryContent#default", ManagedRepositoryContent.class );
+
repoContent.setRepository( repo );
managedDefaultRepository = repoContent;
- config = (MockConfiguration) lookup( ArchivaConfiguration.class.getName(), "mock" );
config.getConfiguration().addManagedRepository( repo );
Handler handler = new AbstractHandler()
config.getConfiguration().addRemoteRepository( repoConfig );
- // Setup the proxy handler.
- try
- {
- proxyHandler = (RepositoryProxyConnectors) lookup( RepositoryProxyConnectors.class.getName() );
- }
- catch ( Exception e )
- {
- server.stop();
- applicationContext.close();
- throw e;
- }
+
}
- @Override
- protected void tearDown()
+ @After
+ public void tearDown()
throws Exception
{
super.tearDown();
server.stop();
}
+ @Test
public void testGetOverHttpProxy()
throws Exception
{
import org.apache.maven.archiva.policies.ReleasesPolicy;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
import org.apache.maven.wagon.ResourceDoesNotExistException;
+import org.junit.Test;
import java.io.File;
public class ManagedDefaultTransferTest
extends AbstractProxyTestCase
{
+ @Test
public void testGetDefaultLayoutNotPresentConnectorOffline()
throws Exception
{
File downloadedFile = proxyHandler.fetchFromProxies( managedDefaultRepository, artifact );
assertNull("File should not have been downloaded", downloadedFile);
}
-
+
+ @Test
public void testGetDefaultLayoutNotPresent()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetDefaultLayoutNotPresentPassthrough()
throws Exception
{
*
* @throws Exception
*/
+ @Test
public void testGetDefaultLayoutAlreadyPresentPolicyOnce()
throws Exception
{
*
* @throws Exception
*/
+ @Test
public void testGetDefaultLayoutAlreadyPresentPassthrough()
throws Exception
{
*
* @throws Exception
*/
+ @Test
public void testGetDefaultLayoutAlreadyPresentNewerThanRemotePolicyIgnored()
throws Exception
{
*
* @throws Exception
*/
+ @Test
public void testGetDefaultLayoutAlreadyPresentOlderThanRemotePolicyIgnored()
throws Exception
{
*
* @throws Exception
*/
+ @Test
public void testGetDefaultLayoutRemoteUpdate()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetWhenInBothProxiedRepos()
throws Exception
{
StringUtils.equals( actualContents, badContents ) );
}
+ @Test
public void testGetInSecondProxiedRepo()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testNotFoundInAnyProxies()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetInSecondProxiedRepoFirstFails()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetAllRepositoriesFail()
throws Exception
{
// TODO: How much information on each failure should we pass back to the user vs. logging in the proxy?
}
+ @Test
public void testGetFromLegacyProxyAlreadyPresentInManaged_NewerThanRemote()
throws Exception
{
assertNotModified( expectedFile, expectedTimestamp );
assertNoTempFiles( expectedFile );
}
-
+
+ @Test
public void testGetFromLegacyProxyAlreadyPresentInManaged_OlderThanRemote()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetFromLegacyProxyNotPresentInManaged()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetFromLegacyProxyPluginNotPresentInManaged()
throws Exception
{
import org.apache.maven.archiva.policies.ChecksumPolicy;
import org.apache.maven.archiva.policies.ReleasesPolicy;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
+import org.junit.Test;
import java.io.File;
* Incoming request on a Managed Legacy repository, for content that does not
* exist in the managed legacy repository, but does exist on a remote default layout repository.
*/
+ @Test
public void testManagedLegacyNotPresentRemoteDefaultPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that already
* exist in the managed legacy repository, and also exist on a remote default layout repository.
*/
+ @Test
public void testManagedLegacyPresentRemoteDefaultPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does not
* exist in the managed legacy repository, and does not exist on a remote legacy layout repository.
*/
+ @Test
public void testManagedLegacyNotPresentRemoteLegacyPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does exist in the
* managed legacy repository, and also exists on a remote legacy layout repository.
*/
+ @Test
public void testManagedLegacyPresentRemoteLegacyPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does exist in the
* managed legacy repository, and does not exist on a remote legacy layout repository.
*/
+ @Test
public void testManagedLegacyPresentRemoteLegacyNotPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does exist in the
* managed legacy repository, and does not exists on a remote default layout repository.
*/
+ @Test
public void testManagedLegacyPresentRemoteDefaultNotPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does not exist in the
* managed legacy repository, and does not exists on a remote legacy layout repository.
*/
+ @Test
public void testManagedLegacyNotPresentRemoteLegacyNotPresent()
throws Exception
{
* Incoming request on a Managed Legacy repository, for content that does not exist in the
* managed legacy repository, and does not exists on a remote default layout repository.
*/
+ @Test
public void testManagedLegacyNotPresentRemoteDefaultNotPresent()
throws Exception
{
import org.apache.maven.wagon.TransferFailedException;
import org.custommonkey.xmlunit.DetailedDiff;
import org.custommonkey.xmlunit.Diff;
+import org.junit.Before;
+import org.junit.Test;
import java.io.File;
import java.io.StringWriter;
/**
* MetadataTransferTest - Tests the various fetching / merging concepts surrounding the maven-metadata.xml files
* present in the repository.
- *
+ * <p/>
* Test Case Naming is as follows.
- *
+ * <p/>
* <code>
* public void testGet[Release|Snapshot|Project]Metadata[Not]Proxied[Not|On]Local[Not|On|Multiple]Remote
* </code>
- *
+ * <p/>
* <pre>
* Which should leave the following matrix of test cases.
*
public class MetadataTransferTest
extends AbstractProxyTestCase
{
- /**
- * @plexus.requirement
- */
+
private MetadataTools metadataTools;
-
+
+ @Before
+ public void init()
+ throws Exception
+ {
+ super.setUp();
+ metadataTools = applicationContext.getBean( MetadataTools.class );
+ }
+
+ @Test
public void testGetProjectMetadataProxiedNotLocalOnRemoteConnectoDisabled()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, true);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, true );
assertResourceNotFound( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
ProjectReference metadata = createProjectReference( requestedResource );
- File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository, managedDefaultRepository.toMetadataPath(metadata) );
+ File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository,
+ managedDefaultRepository.toMetadataPath(
+ metadata ) );
assertNull( "Should not have downloaded a file.", downloadedFile );
assertNoTempFiles( expectedFile );
}
// TODO: same test for other fetch* methods
+ @Test
public void testFetchFromTwoProxiesWhenFirstConnectionFails()
throws Exception
{
File expectedFile = new File( managedDefaultDir.getAbsoluteFile(),
metadataTools.getRepositorySpecificName( "badproxied1", requestedResource ) );
wagonMock.get( requestedResource, new File( expectedFile.getParentFile(), expectedFile.getName() + ".tmp" ) );
-
- wagonMockControl.setMatcher(customWagonGetMatcher);
-
+
+ wagonMockControl.setMatcher( customWagonGetMatcher );
+
wagonMockControl.setThrowable( new TransferFailedException( "can't connect" ) );
wagonMockControl.replay();
wagonMockControl.verify();
- assertProjectMetadataContents( requestedResource, new String[] { "1.0.1" }, "1.0.1", "1.0.1" );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0.1" }, "1.0.1", "1.0.1" );
assertNoRepoMetadata( "badproxied1", requestedResource );
- assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[] { "1.0.1" } );
+ assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[]{ "1.0.1" } );
}
/**
* Attempt to get the project metadata for non-existant artifact.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is not created on the managed repository, nor returned
- * to the requesting client.
+ * to the requesting client.
*/
+ @Test
public void testGetProjectMetadataNotProxiedNotLocal()
throws Exception
{
assertResourceNotFound( requestedResource );
}
+ @Test
public void testGetProjectMetadataNotProxiedOnLocal()
throws Exception
{
// Nothing fetched. Should only contain contents of what is in the repository.
// A metadata update is not performed in this use case. Local metadata content is only
// updated via the metadata updater consumer.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0" }, null, null );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0" }, null, null );
}
+ @Test
public void testGetProjectMetadataProxiedNotLocalMultipleRemotes()
throws Exception
{
assertFetchProjectOrGroup( requestedResource );
// Nothing fetched. Should only contain contents of what is in the repository.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0", "1.0.1" }, "1.0.1", "1.0.1" );
- assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[] { "1.0" } );
- assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[] { "1.0.1" } );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0", "1.0.1" }, "1.0.1", "1.0.1" );
+ assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[]{ "1.0" } );
+ assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[]{ "1.0.1" } );
}
+ @Test
public void testGetProjectMetadataProxiedNotLocalNotRemote()
throws Exception
{
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
}
+ @Test
public void testGetProjectMetadataProxiedNotLocalOnRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertFetchProjectOrGroup( requestedResource );
// Remote fetched. Local created/updated.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0.5" }, "1.0.5", "1.0.5" );
- assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[] { "1.0.5" } );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0.5" }, "1.0.5", "1.0.5" );
+ assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[]{ "1.0.5" } );
}
+ @Test
public void testGetProjectMetadataProxiedOnLocalMultipleRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertProjectMetadataContents( requestedResource, new String[] { "1.0" }, null, null );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0" }, null, null );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
assertFetchProjectOrGroup( requestedResource );
// metadata fetched from both repos, and merged with local version.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0", "1.0.1", "2.0" }, "2.0", "2.0" );
- assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[] { "1.0", "2.0" } );
- assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[] { "1.0", "1.0.1" } );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0", "1.0.1", "2.0" }, "2.0", "2.0" );
+ assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[]{ "1.0", "2.0" } );
+ assertRepoProjectMetadata( ID_PROXIED2, requestedResource, new String[]{ "1.0", "1.0.1" } );
}
+ @Test
public void testGetProjectMetadataProxiedOnLocalNotRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertProjectMetadataContents( requestedResource, new String[] { "1.0-beta-2" }, null, null );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0-beta-2" }, null, null );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
// metadata not fetched from both repos, and local version exists.
// Since there was no updated metadata content from a remote/proxy, a metadata update on
// the local file never ran. Local only updates are performed via the metadata updater consumer.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0-beta-2" }, null, null );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0-beta-2" }, null, null );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
}
+ @Test
public void testGetProjectMetadataProxiedOnLocalOnRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertProjectMetadataContents( requestedResource, new String[] { "1.0.8", "1.0.22" }, null, null );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0.8", "1.0.22" }, null, null );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
// One proxy setup, metadata fetched from remote, local exists.
assertFetchProjectOrGroup( requestedResource );
// Remote fetched. Local updated.
- assertProjectMetadataContents( requestedResource, new String[] { "1.0.8", "1.0.22", "2.0" }, "2.0", "2.0" );
- assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[] { "1.0.22", "2.0" } );
+ assertProjectMetadataContents( requestedResource, new String[]{ "1.0.8", "1.0.22", "2.0" }, "2.0", "2.0" );
+ assertRepoProjectMetadata( ID_PROXIED1, requestedResource, new String[]{ "1.0.22", "2.0" } );
}
/**
* A request for a release maven-metadata.xml file that does not exist locally, and the managed
* repository has no proxied repositories set up.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is not created on the managed repository, nor returned
- * to the requesting client.
+ * to the requesting client.
*/
+ @Test
public void testGetReleaseMetadataNotProxiedNotLocal()
throws Exception
{
/**
* A request for a maven-metadata.xml file that does exist locally, and the managed
* repository has no proxied repositories set up.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is updated locally, based off of the managed repository
- * information, and then returned to the client.
+ * information, and then returned to the client.
*/
+ @Test
public void testGetReleaseMetadataNotProxiedOnLocal()
throws Exception
{
/**
* A request for a release maven-metadata.xml file that does not exist on the managed repository, but
* exists on multiple remote repositories.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is downloaded from the remote into the repository specific
- * file location on the managed repository, a merge of the contents to the requested
- * maven-metadata.xml is performed, and then the merged maven-metadata.xml file is
- * returned to the client.
+ * file location on the managed repository, a merge of the contents to the requested
+ * maven-metadata.xml is performed, and then the merged maven-metadata.xml file is
+ * returned to the client.
*/
+ @Test
public void testGetReleaseMetadataProxiedNotLocalMultipleRemotes()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
/**
* A request for a maven-metadata.xml file that does not exist locally, nor does it exist in a remote
* proxied repository.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is created locally, based off of managed repository
- * information, and then return to the client.
+ * information, and then return to the client.
*/
+ @Test
public void testGetReleaseMetadataProxiedNotLocalNotRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
/**
* A request for a maven-metadata.xml file that does not exist on the managed repository, but
* exists on 1 remote repository.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file is downloaded from the remote into the repository specific
- * file location on the managed repository, a merge of the contents to the requested
- * maven-metadata.xml is performed, and then the merged maven-metadata.xml file is
- * returned to the client.
+ * file location on the managed repository, a merge of the contents to the requested
+ * maven-metadata.xml is performed, and then the merged maven-metadata.xml file is
+ * returned to the client.
*/
+ @Test
public void testGetReleaseMetadataProxiedNotLocalOnRemote()
throws Exception
{
/**
* A request for a maven-metadata.xml file that exists in the managed repository, but
* not on any remote repository.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file does not exist on the remote proxied repository and
- * is not downloaded. There is no repository specific metadata file on the managed
- * repository. The managed repository maven-metadata.xml is returned to the
- * client as-is.
+ * is not downloaded. There is no repository specific metadata file on the managed
+ * repository. The managed repository maven-metadata.xml is returned to the
+ * client as-is.
*/
+ @Test
public void testGetReleaseMetadataProxiedOnLocalNotRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertReleaseMetadataContents( requestedResource );
/**
* A request for a maven-metadata.xml file that exists in the managed repository, and on multiple
* remote repositories.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file on the remote proxied repository is downloaded
- * and merged into the contents of the existing managed repository copy of
- * the maven-metadata.xml file.
+ * and merged into the contents of the existing managed repository copy of
+ * the maven-metadata.xml file.
*/
+ @Test
public void testGetReleaseMetadataProxiedOnLocalMultipleRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertReleaseMetadataContents( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
/**
* A request for a maven-metadata.xml file that exists in the managed repository, and on one
* remote repository.
- *
+ * <p/>
* Expected result: the maven-metadata.xml file on the remote proxied repository is downloaded
- * and merged into the contents of the existing managed repository copy of
- * the maven-metadata.xml file.
+ * and merged into the contents of the existing managed repository copy of
+ * the maven-metadata.xml file.
*/
+ @Test
public void testGetReleaseMetadataProxiedOnLocalOnRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertReleaseMetadataContents( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertRepoReleaseMetadataContents( ID_PROXIED1, requestedResource );
}
+ @Test
public void testGetSnapshotMetadataNotProxiedNotLocal()
throws Exception
{
// The artifactId "get-default-metadata-nonexistant" does not exist (intentionally).
- String requestedResource = "org/apache/maven/test/get-default-metadata-nonexistant/1.0-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-default-metadata-nonexistant/1.0-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
assertNoMetadata( requestedResource );
assertNoMetadata( requestedResource );
}
+ @Test
public void testGetSnapshotMetadataNotProxiedOnLocal()
throws Exception
{
// The artifactId exists locally (but not on a remote repo)
- String requestedResource = "org/apache/maven/test/get-snapshot-on-local-not-remote/2.0-alpha-2-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-snapshot-on-local-not-remote/2.0-alpha-2-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
assertResourceExists( requestedResource );
assertSnapshotMetadataContents( requestedResource, "20070821", "220304", 2 );
}
+ @Test
public void testGetSnapshotMetadataProxiedNotLocalMultipleRemotes()
throws Exception
{
- String requestedResource = "org/apache/maven/test/get-timestamped-snapshot-in-both/1.0-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-timestamped-snapshot-in-both/1.0-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertRepoSnapshotMetadataContents( ID_PROXIED2, requestedResource, "20070101", "000103", 2 );
}
+ @Test
public void testGetSnapshotMetadataProxiedNotLocalNotRemote()
throws Exception
{
// The artifactId "get-default-metadata-nonexistant" does not exist (intentionally).
- String requestedResource = "org/apache/maven/test/get-default-metadata-nonexistant/1.0-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-default-metadata-nonexistant/1.0-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertNoMetadata( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
}
+ @Test
public void testGetSnapshotMetadataProxiedNotLocalOnRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
assertRepoSnapshotMetadataContents( ID_PROXIED1, requestedResource, "20050831", "101112", 1 );
}
+ @Test
public void testGetSnapshotMetadataProxiedOnLocalMultipleRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertSnapshotMetadataContents( requestedResource, "20070822", "021008", 3 );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertRepoSnapshotMetadataContents( ID_PROXIED2, requestedResource, "20070823", "212711", 6 );
}
+ @Test
public void testGetSnapshotMetadataProxiedOnLocalNotRemote()
throws Exception
{
// The artifactId exists locally (but not on a remote repo)
- String requestedResource = "org/apache/maven/test/get-snapshot-on-local-not-remote/2.0-alpha-2-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-snapshot-on-local-not-remote/2.0-alpha-2-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceExists( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
}
+ @Test
public void testGetSnapshotMetadataProxiedOnLocalOnRemote()
throws Exception
{
// The artifactId exists locally (but not on a remote repo)
- String requestedResource = "org/apache/maven/test/get-present-metadata-snapshot/1.0-SNAPSHOT/maven-metadata.xml";
+ String requestedResource =
+ "org/apache/maven/test/get-present-metadata-snapshot/1.0-SNAPSHOT/maven-metadata.xml";
setupTestableManagedRepository( requestedResource );
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertSnapshotMetadataContents( requestedResource, "20050831", "101112", 1 );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertRepoSnapshotMetadataContents( ID_PROXIED1, requestedResource, "20050831", "101112", 1 );
}
+ @Test
public void testGetGroupMetadataNotProxiedNotLocal()
throws Exception
{
assertResourceNotFound( requestedResource );
}
+ @Test
public void testGetGroupMetadataNotProxiedOnLocal()
throws Exception
{
// Nothing fetched. Should only contain contents of what is in the repository.
// A metadata update is not performed in this use case. Local metadata content is only
// updated via the metadata updater consumer.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin1" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin1" } );
}
+ @Test
public void testGetGroupMetadataProxiedNotLocalMultipleRemotes()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertResourceNotFound( requestedResource );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertFetchProjectOrGroup( requestedResource );
// Nothing fetched. Should only contain contents of what is in the repository.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin2", "plugin1" } );
- assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[] { "plugin1" } );
- assertRepoGroupMetadataContents( ID_PROXIED2, requestedResource, new String[] { "plugin2" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin2", "plugin1" } );
+ assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[]{ "plugin1" } );
+ assertRepoGroupMetadataContents( ID_PROXIED2, requestedResource, new String[]{ "plugin2" } );
}
+ @Test
public void testGetGroupsMetadataProxiedNotLocalNotRemote()
throws Exception
{
// Configure Connector (usually done within archiva.xml configuration)
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
- SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false);
+ SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
}
+ @Test
public void testGetGroupMetadataProxiedNotLocalOnRemote()
throws Exception
{
assertFetchProjectOrGroup( requestedResource );
// Remote fetched. Local created/updated.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin3" } );
- assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[] { "plugin3" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin3" } );
+ assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[]{ "plugin3" } );
}
+ @Test
public void testGetGroupMetadataProxiedOnLocalMultipleRemote()
throws Exception
{
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertGroupMetadataContents( requestedResource, new String[] { "plugin1" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin1" } );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
assertFetchProjectOrGroup( requestedResource );
// metadata fetched from both repos, and merged with local version.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin1", "plugin2", "plugin4" } );
- assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[] { "plugin1", "plugin4" } );
- assertRepoGroupMetadataContents( ID_PROXIED2, requestedResource, new String[] { "plugin1", "plugin2" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin1", "plugin2", "plugin4" } );
+ assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[]{ "plugin1", "plugin4" } );
+ assertRepoGroupMetadataContents( ID_PROXIED2, requestedResource, new String[]{ "plugin1", "plugin2" } );
}
+ @Test
public void testGetGroupMetadataProxiedOnLocalNotRemote()
throws Exception
{
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED2, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertGroupMetadataContents( requestedResource, new String[] { "plugin5" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin5" } );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
// metadata not fetched from both repos, and local version exists.
// Since there was no updated metadata content from a remote/proxy, a metadata update on
// the local file never ran. Local only updates are performed via the metadata updater consumer.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin5" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin5" } );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
assertNoRepoMetadata( ID_PROXIED2, requestedResource );
}
+ @Test
public void testGetGroupMetadataProxiedOnLocalOnRemote()
throws Exception
{
saveConnector( ID_DEFAULT_MANAGED, ID_PROXIED1, ChecksumPolicy.FIX, ReleasesPolicy.ALWAYS,
SnapshotsPolicy.ALWAYS, CachedFailuresPolicy.NO, false );
- assertGroupMetadataContents( requestedResource, new String[] { "plugin6", "plugin7" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin6", "plugin7" } );
assertNoRepoMetadata( ID_PROXIED1, requestedResource );
// One proxy setup, metadata fetched from remote, local exists.
assertFetchProjectOrGroup( requestedResource );
// Remote fetched. Local updated.
- assertGroupMetadataContents( requestedResource, new String[] { "plugin6", "plugin7", "plugin4" } );
- assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[] { "plugin7", "plugin4" } );
+ assertGroupMetadataContents( requestedResource, new String[]{ "plugin6", "plugin7", "plugin4" } );
+ assertRepoGroupMetadataContents( ID_PROXIED1, requestedResource, new String[]{ "plugin7", "plugin4" } );
}
/**
ProjectReference metadata = createProjectReference( requestedResource );
- File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository, managedDefaultRepository.toMetadataPath(metadata) );
+ File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository,
+ managedDefaultRepository.toMetadataPath(
+ metadata ) );
assertNotNull( "Should have downloaded a file.", downloadedFile );
assertNoTempFiles( expectedFile );
File expectedFile = new File( managedDefaultDir, requestedResource );
ProjectReference metadata = createProjectReference( requestedResource );
- File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository, managedDefaultRepository.toMetadataPath(metadata) );
+ File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository,
+ managedDefaultRepository.toMetadataPath(
+ metadata ) );
assertNull( downloadedFile );
assertNoTempFiles( expectedFile );
VersionedReference metadata = createVersionedReference( requestedResource );
- File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository, managedDefaultRepository.toMetadataPath(metadata) );
+ File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository,
+ managedDefaultRepository.toMetadataPath(
+ metadata ) );
assertNotNull( "Should have downloaded a file.", downloadedFile );
assertNoTempFiles( expectedFile );
File expectedFile = new File( managedDefaultDir, requestedResource );
VersionedReference metadata = createVersionedReference( requestedResource );
- File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository, managedDefaultRepository.toMetadataPath(metadata) );
+ File downloadedFile = proxyHandler.fetchMetatadaFromProxies( managedDefaultRepository,
+ managedDefaultRepository.toMetadataPath(
+ metadata ) );
assertNull( downloadedFile );
assertNoTempFiles( expectedFile );
/**
* Ensures that the proxied repository specific maven metadata file does NOT exist in the
* managed repository.
- * @param proxiedRepoId the proxied repository id to validate with.
+ *
+ * @param proxiedRepoId the proxied repository id to validate with.
* @param requestedResource the resource requested.
*/
private void assertNoRepoMetadata( String proxiedRepoId, String requestedResource )
* Test for the existance of the snapshot metadata in the default managed repository, and if it exists,
* does it contain the expected release maven-metadata.xml contents?
*
- * @param requestedResource the requested resource
- * @param expectedDate the date in "yyyyMMdd" format
- * @param expectedTime the time in "hhmmss" format
+ * @param requestedResource the requested resource
+ * @param expectedDate the date in "yyyyMMdd" format
+ * @param expectedTime the time in "hhmmss" format
* @param expectedBuildnumber the build number
- *
* @throws Exception
*/
private void assertSnapshotMetadataContents( String requestedResource, String expectedDate, String expectedTime,
* Test for the existance of the proxied repository specific snapshot metadata in the default managed
* repository, and if it exists, does it contain the expected release maven-metadata.xml contents?
*
- * @param proxiedRepoId the repository id of the proxied repository.
- * @param requestedResource the requested resource
- * @param expectedDate the date in "yyyyMMdd" format
- * @param expectedTime the time in "hhmmss" format
+ * @param proxiedRepoId the repository id of the proxied repository.
+ * @param requestedResource the requested resource
+ * @param expectedDate the date in "yyyyMMdd" format
+ * @param expectedTime the time in "hhmmss" format
* @param expectedBuildnumber the build number
- *
* @throws Exception
*/
private void assertRepoSnapshotMetadataContents( String proxiedRepoId, String requestedResource,
/**
* Ensures that the repository specific maven metadata file exists, and contains the appropriate
* list of expected versions within.
+ *
* @param proxiedRepoId
* @param requestedResource
* @param expectedProxyVersions
assertFalse( "Resource should not exist: " + requestedResource, actualFile.exists() );
}
- protected void setUp()
- throws Exception
- {
- super.setUp();
-
- metadataTools = (MetadataTools) lookup( MetadataTools.class );
- }
-
}
import org.apache.maven.archiva.configuration.ArchivaConfiguration;
import org.apache.maven.archiva.configuration.Configuration;
import org.apache.maven.archiva.configuration.ConfigurationListener;
+import org.apache.maven.archiva.configuration.FileType;
+import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
+import org.apache.maven.archiva.configuration.RepositoryScanningConfiguration;
+import org.apache.maven.archiva.repository.ManagedRepositoryContent;
import org.codehaus.plexus.registry.Registry;
import org.codehaus.plexus.registry.RegistryException;
import org.codehaus.plexus.registry.RegistryListener;
import org.easymock.MockControl;
+import org.springframework.context.ApplicationContext;
+import org.springframework.stereotype.Service;
+import javax.annotation.PostConstruct;
+import javax.inject.Inject;
+import java.io.File;
+import java.util.Collections;
import java.util.HashSet;
+import java.util.List;
import java.util.Set;
/**
- * MockConfiguration
+ * MockConfiguration
*
* @version $Id$
- *
- * @plexus.component role="org.apache.maven.archiva.configuration.ArchivaConfiguration"
- * role-hint="mock"
+ * <p/>
+ * plexus.component role="org.apache.maven.archiva.configuration.ArchivaConfiguration"
+ * role-hint="mock"
*/
+@Service( "archivaConfiguration#mock" )
public class MockConfiguration
implements ArchivaConfiguration
{
+
+ @Inject
+ protected ApplicationContext applicationContext;
+
private Configuration configuration = new Configuration();
private Set<RegistryListener> registryListeners = new HashSet<RegistryListener>();
+
private Set<ConfigurationListener> configListeners = new HashSet<ConfigurationListener>();
private MockControl registryControl;
registryMock = (Registry) registryControl.getMock();
}
+ @PostConstruct
+ public void initialize()
+ throws Exception
+ {
+
+ // random name or cleanup ??
+ String repoPath = "target/test-repository/managed/" + "foo";//getName();
+ File repoLocation = new File( repoPath );
+ ManagedRepositoryContent managedDefaultRepository =
+ createRepository( AbstractProxyTestCase.ID_DEFAULT_MANAGED, "Default Managed Repository", repoPath,
+ "default" );
+ ManagedRepositoryConfiguration repoConfig = managedDefaultRepository.getRepository();
+ configuration.addManagedRepository( repoConfig );
+
+ configuration.setRepositoryScanning( new RepositoryScanningConfiguration(){
+ @Override
+ public List<FileType> getFileTypes()
+ {
+ return Collections.emptyList();
+ }
+ } );
+ }
+
+ protected ManagedRepositoryContent createRepository( String id, String name, String path, String layout )
+ throws Exception
+ {
+ ManagedRepositoryConfiguration repo = new ManagedRepositoryConfiguration();
+ repo.setId( id );
+ repo.setName( name );
+ repo.setLocation( path );
+ repo.setLayout( layout );
+
+ ManagedRepositoryContent repoContent =
+ applicationContext.getBean( "managedRepositoryContent#" + layout, ManagedRepositoryContent.class );
+ repoContent.setRepository( repo );
+ return repoContent;
+ }
+
public void addChangeListener( RegistryListener listener )
{
registryListeners.add( listener );
public void triggerChange( String name, String value )
{
- for(RegistryListener listener: registryListeners)
+ for ( RegistryListener listener : registryListeners )
{
try
{
public void addListener( ConfigurationListener listener )
{
- configListeners.add(listener);
+ configListeners.add( listener );
}
public void removeListener( ConfigurationListener listener )
import org.apache.maven.archiva.policies.ChecksumPolicy;
import org.apache.maven.archiva.policies.ReleasesPolicy;
import org.apache.maven.archiva.policies.SnapshotsPolicy;
+import org.junit.Test;
import java.io.File;
public class SnapshotTransferTest
extends AbstractProxyTestCase
{
+ @Test
public void testSnapshotNonExistant()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testTimestampDrivenSnapshotNotPresentAlready()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testNewerTimestampDrivenSnapshotOnFirstRepo()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testOlderTimestampDrivenSnapshotOnFirstRepo()
throws Exception
{
assertNoTempFiles( expectedFile );
} */
+ @Test
public void testTimestampDrivenSnapshotNotExpired()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testTimestampDrivenSnapshotNotUpdated()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testTimestampDrivenSnapshotNotPresentAlreadyExpiredCacheFailure()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testMetadataDrivenSnapshotNotPresentAlready()
throws Exception
{
assertNoTempFiles( expectedFile );
}
+ @Test
public void testGetMetadataDrivenSnapshotRemoteUpdate()
throws Exception
{
import org.apache.maven.wagon.repository.Repository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
/**
* A dummy wagon implementation
*
*/
+@Service("wagon#test")
public class WagonDelegate
implements Wagon
{
* under the License.
*/
+import junit.framework.TestCase;
+import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
import org.apache.maven.wagon.Wagon;
-import org.codehaus.plexus.spring.PlexusInSpringTestCase;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import javax.inject.Inject;
/**
* Test the WagonFactory works through Spring to be bound into the RepositoryProxyConnectors implementation.
*
*/
+@RunWith( SpringJUnit4ClassRunner.class )
+@ContextConfiguration( locations = {"classpath*:/META-INF/spring-context.xml","classpath:/spring-context.xml"} )
public class WagonFactoryTest
- extends PlexusInSpringTestCase
+ extends TestCase
{
+
+ @Inject
+ WagonFactory factory;
+
+ @Test
public void testLookupSuccessiveWagons()
+ throws Exception
{
- WagonFactory factory = (WagonFactory) lookup( WagonFactory.class );
-
+
Wagon first = factory.getWagon( "wagon#file" );
Wagon second = factory.getWagon( "wagon#file" );
+
+ // ensure we support only protocol name too
+ Wagon third = factory.getWagon( "file" );
assertNotSame( first, second );
+
+ assertNotSame( first, third );
}
}
~ "License"); you may not use this file except in compliance
~ with the License. You may obtain a copy of the License at
~
- ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~ http://www.apache.org/licenses/LICENSE-2.0
~
~ Unless required by applicable law or agreed to in writing,
~ software distributed under the License is distributed on an
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
+ xmlns:context="http://www.springframework.org/schema/context"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans
+ http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+ http://www.springframework.org/schema/context
+ http://www.springframework.org/schema/context/spring-context-3.0.xsd"
+ default-lazy-init="true">
<bean id="repositorySessionFactory" class="org.apache.archiva.metadata.repository.TestRepositorySessionFactory"/>
</beans>
\ No newline at end of file
/**
* The component that takes care of scheduling in the application.
- *
*/
public interface ArchivaTaskScheduler<T extends Task>
{
/**
* Adds the task to the scanning queue.
- *
+ *
* @param task
* @throws TaskQueueException
*/
- public void queueTask( T task )
+ void queueTask( T task )
throws TaskQueueException;
}
<groupId>org.apache.archiva</groupId>
<artifactId>archiva-scheduler-api</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.codehaus.redback.components</groupId>
+ <artifactId>spring-quartz</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.quartz-scheduler</groupId>
+ <artifactId>quartz</artifactId>
+ <exclusions>
+ <exclusion>
+ <groupId>c3p0</groupId>
+ <artifactId>c3p0</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>javax.transaction</groupId>
+ <artifactId>jta</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
<dependency>
<groupId>org.apache.archiva</groupId>
<artifactId>repository-statistics</artifactId>
<artifactId>archiva-repository-layer</artifactId>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>org.codehaus.plexus</groupId>
- <artifactId>plexus-quartz</artifactId>
- </dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
public void initialize()
throws InitializationException
{
- log.info( "Initialized " + this.getClass().getName() );
+ log.info( "Initialized {}", this.getClass().getName() );
}
@SuppressWarnings( "unchecked" )
import org.apache.maven.archiva.configuration.ConfigurationEvent;
import org.apache.maven.archiva.configuration.ConfigurationListener;
import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.StartingException;
-import org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException;
-import org.codehaus.plexus.scheduler.CronExpressionValidator;
-import org.codehaus.plexus.scheduler.Scheduler;
-import org.codehaus.plexus.taskqueue.Task;
import org.codehaus.plexus.taskqueue.TaskQueue;
import org.codehaus.plexus.taskqueue.TaskQueueException;
+import org.codehaus.redback.components.scheduler.CronExpressionValidator;
+import org.codehaus.redback.components.scheduler.Scheduler;
import org.quartz.CronTrigger;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.SchedulerException;
+import org.quartz.impl.JobDetailImpl;
+import org.quartz.impl.triggers.CronTriggerImpl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
import javax.inject.Inject;
import javax.inject.Named;
import java.text.ParseException;
/**
* Default implementation of a scheduling component for archiva.
- *
+ * <p/>
* plexus.component role="org.apache.archiva.scheduler.ArchivaTaskScheduler" role-hint="repository"
*/
-@Service("archivaTaskScheduler#repository")
+@Service( "archivaTaskScheduler#repository" )
public class RepositoryArchivaTaskScheduler
- implements ArchivaTaskScheduler<RepositoryTask>, Startable, ConfigurationListener
+ implements ArchivaTaskScheduler<RepositoryTask>, ConfigurationListener
{
private Logger log = LoggerFactory.getLogger( RepositoryArchivaTaskScheduler.class );
@Inject
private Scheduler scheduler;
+ @Inject
+ CronExpressionValidator cronValidator;
+
/**
* plexus.requirement role-hint="repository-scanning"
*/
- @Inject @Named(value = "taskQueue#repository-scanning")
+ @Inject
+ @Named( value = "taskQueue#repository-scanning" )
private TaskQueue repositoryScanningQueue;
/**
* plexus.requirement
*/
@Inject
- @Named(value = "repositoryStatisticsManager#default")
+ @Named( value = "repositoryStatisticsManager#default" )
private RepositoryStatisticsManager repositoryStatisticsManager;
/**
* TODO: could have multiple implementations
- *
+ * <p/>
* plexus.requirement
*/
@Inject
private List<String> queuedRepos = new ArrayList<String>();
+ @PostConstruct
public void startup()
throws ArchivaException
{
archivaConfiguration.addListener( this );
- try
- {
- start();
- }
- catch ( StartingException e )
- {
- throw new ArchivaException( e.getMessage(), e );
- }
- }
-
- public void start()
- throws StartingException
- {
List<ManagedRepositoryConfiguration> repositories =
archivaConfiguration.getConfiguration().getManagedRepositories();
}
catch ( SchedulerException e )
{
- throw new StartingException( "Unable to start scheduler: " + e.getMessage(), e );
+ throw new ArchivaException( "Unable to start scheduler: " + e.getMessage(), e );
}
try
}
catch ( MetadataRepositoryException e )
{
- log.warn( "Unable to determine if a repository is already scanned, skipping initial scan: " +
- e.getMessage(), e );
+ log.warn( "Unable to determine if a repository is already scanned, skipping initial scan: "
+ + e.getMessage(), e );
}
}
}
{
repositorySession.close();
}
+
}
+
+ @PreDestroy
public void stop()
- throws StoppingException
+ throws SchedulerException
{
- try
+ for ( String job : jobs )
{
- for ( String job : jobs )
- {
- scheduler.unscheduleJob( job, REPOSITORY_SCAN_GROUP );
- }
- jobs.clear();
- queuedRepos.clear();
- }
- catch ( SchedulerException e )
- {
- throw new StoppingException( "Unable to unschedule tasks", e );
+ scheduler.unscheduleJob( job, REPOSITORY_SCAN_GROUP );
}
+ jobs.clear();
+ queuedRepos.clear();
+
}
@SuppressWarnings( "unchecked" )
{
if ( isProcessingRepositoryTask( task ) )
{
- log.debug( "Repository task '" + task + "' is already queued. Skipping task." );
+ log.debug( "Repository task '{}' is already queued. Skipping task.", task );
}
else
{
// get the cron string for these database scanning jobs
String cronString = repoConfig.getRefreshCronExpression();
- CronExpressionValidator cronValidator = new CronExpressionValidator();
if ( !cronValidator.validate( cronString ) )
{
- log.warn( "Cron expression [" + cronString + "] for repository [" + repoConfig.getId() +
- "] is invalid. Defaulting to hourly." );
+ log.warn( "Cron expression [" + cronString + "] for repository [" + repoConfig.getId()
+ + "] is invalid. Defaulting to hourly." );
cronString = CRON_HOURLY;
}
// setup the unprocessed artifact job
- JobDetail repositoryJob = new JobDetail( REPOSITORY_JOB + ":" + repoConfig.getId(), REPOSITORY_SCAN_GROUP,
- RepositoryTaskJob.class );
+ JobDetailImpl repositoryJob =
+ new JobDetailImpl( REPOSITORY_JOB + ":" + repoConfig.getId(), REPOSITORY_SCAN_GROUP, RepositoryTaskJob.class );
- JobDataMap dataMap = new JobDataMap();
- dataMap.put( TASK_QUEUE, repositoryScanningQueue );
- dataMap.put( TASK_REPOSITORY, repoConfig.getId() );
- repositoryJob.setJobDataMap( dataMap );
+ repositoryJob.getJobDataMap().put( TASK_QUEUE, repositoryScanningQueue );
+ repositoryJob.getJobDataMap().put( TASK_REPOSITORY, repoConfig.getId() );
try
{
- CronTrigger trigger = new CronTrigger( REPOSITORY_JOB_TRIGGER + ":" + repoConfig.getId(),
- REPOSITORY_SCAN_GROUP, cronString );
+ CronTriggerImpl trigger =
+ new CronTriggerImpl( REPOSITORY_JOB_TRIGGER + ":" + repoConfig.getId(), REPOSITORY_SCAN_GROUP, cronString );
jobs.add( REPOSITORY_JOB + ":" + repoConfig.getId() );
scheduler.scheduleJob( repositoryJob, trigger );
}
catch ( ParseException e )
{
- log.error( "ParseException in repository scanning cron expression, disabling repository scanning for '" +
- repoConfig.getId() + "': " + e.getMessage() );
+ log.error( "ParseException in repository scanning cron expression, disabling repository scanning for '"
+ + repoConfig.getId() + "': " + e.getMessage() );
}
}
* under the License.
*/
-import org.codehaus.plexus.scheduler.AbstractJob;
import org.codehaus.plexus.taskqueue.TaskQueue;
import org.codehaus.plexus.taskqueue.TaskQueueException;
+import org.codehaus.redback.components.scheduler.AbstractJob;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
+ xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
- http://www.springframework.org/schema/context/spring-context-3.0.xsd"
+ http://www.springframework.org/schema/context/spring-context-3.0.xsd
+ http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd"
default-lazy-init="true">
<context:annotation-config/>
<property name="executor" ref="taskExecutor#repository-scanning"/>
<property name="queue" ref="taskQueue#repository-scanning"/>
</bean>
+ <alias name="archivaTaskScheduler#repository" alias="scheduler#repository"/>
+
+ <task:scheduler id="scheduler" pool-size="10"/>
+
</beans>
\ No newline at end of file
<scope>provided</scope>
</dependency>
<dependency>
- <groupId>org.codehaus.plexus</groupId>
- <artifactId>plexus-quartz</artifactId>
+ <groupId>org.codehaus.redback.components</groupId>
+ <artifactId>spring-taskqueue</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.codehaus.redback.components</groupId>
+ <artifactId>spring-quartz</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.quartz-scheduler</groupId>
+ <artifactId>quartz</artifactId>
<exclusions>
<exclusion>
- <groupId>org.codehaus.plexus</groupId>
- <artifactId>plexus-component-api</artifactId>
+ <groupId>c3p0</groupId>
+ <artifactId>c3p0</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>javax.transaction</groupId>
+ <artifactId>jta</artifactId>
</exclusion>
</exclusions>
</dependency>
- <dependency>
- <groupId>org.codehaus.redback.components</groupId>
- <artifactId>spring-taskqueue</artifactId>
- </dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<excludes>
<exclude>org.codehaus.plexus:plexus-container-default</exclude>
<exclude>org.codehaus.plexus:plexus-log4j-logging</exclude>
-
+ <exclude>org.codehaus.plexus:plexus-quartz</exclude>
<exclude>org.codehaus.plexus:plexus-spring</exclude>
<exclude>org.codehaus.redback:plexus-spring</exclude>
<exclude>commons-logging:commons-logging</exclude>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
- <version>2.2</version>
+ <version>2.5</version>
</dependency>
<dependency>
<groupId>org.apache.derby</groupId>
</exclusion>
</exclusions>
</dependency>
- <dependency>
- <groupId>org.codehaus.plexus</groupId>
- <artifactId>plexus-quartz</artifactId>
- <version>1.0-alpha-3</version>
- <exclusions>
- <exclusion>
- <groupId>commons-logging</groupId>
- <artifactId>commons-logging</artifactId>
- </exclusion>
- <exclusion>
- <groupId>org.codehaus.plexus</groupId>
- <artifactId>plexus-container-default</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
<dependency>
<groupId>org.codehaus.plexus</groupId>
<artifactId>plexus-slf4j-logging</artifactId>
<artifactId>spring-taskqueue</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
+ <dependency>
+ <groupId>org.codehaus.redback.components</groupId>
+ <artifactId>spring-quartz</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.quartz-scheduler</groupId>
+ <artifactId>quartz</artifactId>
+ <version>2.0.1</version>
+ <exclusions>
+ <exclusion>
+ <groupId>c3p0</groupId>
+ <artifactId>c3p0</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>javax.transaction</groupId>
+ <artifactId>jta</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
<dependency>
<groupId>org.codehaus.plexus</groupId>
<artifactId>plexus-utils</artifactId>
projects / archiva.git / commitdiff