From b09d28bf2b79f58fabdf96f9daa94f841d6f0e7a Mon Sep 17 00:00:00 2001 From: Joakim Erdfelt Date: Thu, 5 Apr 2007 21:45:01 +0000 Subject: [PATCH] Adding auto-remove Consumer. Updating create-missing-checksums Consumer. git-svn-id: https://svn.apache.org/repos/asf/maven/archiva/branches/archiva-jpox-database-refactor@525975 13f79535-47bb-0310-9956-ffa450edef68 --- .../ArtifactMissingChecksumsConsumer.java | 3 - .../consumers/core/AutoRemoveConsumer.java | 167 ++++++++++++++++++ 2 files changed, 167 insertions(+), 3 deletions(-) create mode 100644 archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/AutoRemoveConsumer.java diff --git a/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/ArtifactMissingChecksumsConsumer.java b/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/ArtifactMissingChecksumsConsumer.java index eeebd5cac..4ecb1331c 100644 --- a/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/ArtifactMissingChecksumsConsumer.java +++ b/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/ArtifactMissingChecksumsConsumer.java @@ -19,10 +19,8 @@ package org.apache.maven.archiva.consumers.core; * under the License. */ -import org.apache.commons.lang.StringUtils; import org.apache.maven.archiva.configuration.ArchivaConfiguration; import org.apache.maven.archiva.configuration.FileType; -import org.apache.maven.archiva.configuration.RepositoryScanningConfiguration; import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer; import org.apache.maven.archiva.consumers.ConsumerException; import org.apache.maven.archiva.consumers.RepositoryContentConsumer; @@ -39,7 +37,6 @@ import org.codehaus.plexus.registry.RegistryListener; import java.io.File; import java.io.IOException; import java.util.ArrayList; -import java.util.Iterator; import java.util.List; import java.util.Map; diff --git a/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/AutoRemoveConsumer.java b/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/AutoRemoveConsumer.java new file mode 100644 index 000000000..89e307fd3 --- /dev/null +++ b/archiva-base/archiva-consumers/archiva-core-consumers/src/main/java/org/apache/maven/archiva/consumers/core/AutoRemoveConsumer.java @@ -0,0 +1,167 @@ +package org.apache.maven.archiva.consumers.core; + +/* + * 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.apache.maven.archiva.configuration.ArchivaConfiguration; +import org.apache.maven.archiva.configuration.FileType; +import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer; +import org.apache.maven.archiva.consumers.ConsumerException; +import org.apache.maven.archiva.consumers.RepositoryContentConsumer; +import org.apache.maven.archiva.model.ArchivaRepository; +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 java.io.File; +import java.util.ArrayList; +import java.util.List; + +/** + * AutoRemoveConsumer + * + * @author Joakim Erdfelt + * @version $Id$ + * + * @plexus.component role-hint="auto-remove" + * instantiation-strategy="per-lookup" + */ +public class AutoRemoveConsumer + extends AbstractMonitoredConsumer + implements RepositoryContentConsumer, RegistryListener, Initializable +{ + /** + * @plexus.configuration default-value="auto-remove" + */ + private String id; + + /** + * @plexus.configuration default-value="Automatically Remove File from Filesystem." + */ + private String description; + + /** + * @plexus.requirement + */ + private ArchivaConfiguration configuration; + + private File repositoryDir; + + private List propertyNameTriggers = new ArrayList(); + + private List includes = new ArrayList(); + + public String getId() + { + return this.id; + } + + public String getDescription() + { + return this.description; + } + + public boolean isPermanent() + { + return false; + } + + public void beginScan( ArchivaRepository repository ) + throws ConsumerException + { + if ( !repository.isManaged() ) + { + throw new ConsumerException( "Consumer requires managed repository." ); + } + + this.repositoryDir = new File( repository.getUrl().getPath() ); + } + + public void completeScan() + { + /* do nothing */ + } + + public List getExcludes() + { + return null; + } + + public List getIncludes() + { + return includes; + } + + public void processFile( String path ) + throws ConsumerException + { + File file = new File( this.repositoryDir, path ); + if ( file.exists() ) + { + triggerConsumerInfo( "(Auto) Removing File: " + file.getAbsolutePath() ); + file.delete(); + } + } + + public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue ) + { + if ( propertyNameTriggers.contains( propertyName ) ) + { + initIncludes(); + } + } + + public void beforeConfigurationChange( Registry registry, String propertyName, Object propertyValue ) + { + /* do nothing */ + } + + private void initIncludes() + { + includes.clear(); + + FileType artifactTypes = configuration.getConfiguration().getRepositoryScanning() + .getFileTypeById( "auto-remove" ); + if ( artifactTypes != null ) + { + includes.addAll( artifactTypes.getPatterns() ); + } + } + + public void initialize() + throws InitializationException + { + propertyNameTriggers = new ArrayList(); + propertyNameTriggers.add( "repositoryScanning" ); + propertyNameTriggers.add( "fileTypes" ); + propertyNameTriggers.add( "fileType" ); + propertyNameTriggers.add( "patterns" ); + propertyNameTriggers.add( "pattern" ); + + configuration.addChangeListener( this ); + + initIncludes(); + + if ( includes.isEmpty() ) + { + throw new InitializationException( "Unable to use " + getId() + " due to empty includes list." ); + } + } +}