001    package org.apache.archiva.indexer.merger;
002    /*
003     * Licensed to the Apache Software Foundation (ASF) under one
004     * or more contributor license agreements.  See the NOTICE file
005     * distributed with this work for additional information
006     * regarding copyright ownership.  The ASF licenses this file
007     * to you under the Apache License, Version 2.0 (the
008     * "License"); you may not use this file except in compliance
009     * with the License.  You may obtain a copy of the License at
010     *
011     *   http://www.apache.org/licenses/LICENSE-2.0
012     *
013     * Unless required by applicable law or agreed to in writing,
014     * software distributed under the License is distributed on an
015     * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
016     * KIND, either express or implied.  See the License for the
017     * specific language governing permissions and limitations
018     * under the License.
019     */
020    
021    import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
022    import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
023    import org.apache.maven.index.NexusIndexer;
024    import org.slf4j.Logger;
025    import org.slf4j.LoggerFactory;
026    import org.springframework.scheduling.annotation.Scheduled;
027    import org.springframework.stereotype.Service;
028    
029    import javax.inject.Inject;
030    import java.util.Date;
031    
032    /**
033     * @author Olivier Lamy
034     * @since 1.4-M2
035     */
036    @Service
037    public class TemporaryGroupIndexCleaner
038    {
039        private Logger log = LoggerFactory.getLogger( getClass() );
040    
041        @Inject
042        private IndexMerger indexMerger;
043    
044        private NexusIndexer indexer;
045    
046        @Inject
047        public TemporaryGroupIndexCleaner( PlexusSisuBridge plexusSisuBridge )
048            throws PlexusSisuBridgeException
049        {
050            indexer = plexusSisuBridge.lookup( NexusIndexer.class );
051        }
052    
053        // 900000
054        @Scheduled(fixedDelay = 900000)
055        public void cleanTemporaryIndex()
056        {
057    
058            for ( TemporaryGroupIndex temporaryGroupIndex : indexMerger.getTemporaryGroupIndexes() )
059            {
060                // cleanup files older than the ttl
061                if ( new Date().getTime() - temporaryGroupIndex.getCreationTime() > temporaryGroupIndex.getMergedIndexTtl() )
062                {
063                    log.info( "cleanTemporaryIndex for groupId {}", temporaryGroupIndex.getGroupId() );
064                    indexMerger.cleanTemporaryGroupIndex( temporaryGroupIndex );
065    
066                }
067            }
068        }
069    }