package org.apache.archiva.consumers.lucene;

/*
 * 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 java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

import org.apache.lucene.document.Document;
import org.apache.lucene.index.IndexReader;
import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer;
import org.apache.maven.archiva.consumers.ConsumerException;
import org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer;
import org.apache.maven.archiva.repository.content.ManagedDefaultRepositoryContent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.sonatype.nexus.index.ArtifactContext;
import org.sonatype.nexus.index.ArtifactContextProducer;
import org.sonatype.nexus.index.ArtifactInfo;
import org.sonatype.nexus.index.DefaultArtifactContextProducer;
import org.sonatype.nexus.index.NexusIndexer;
import org.sonatype.nexus.index.context.IndexingContext;
import org.sonatype.nexus.index.context.UnsupportedExistingLuceneIndexException;
import org.sonatype.nexus.index.creator.AbstractIndexCreator;
import org.sonatype.nexus.index.creator.IndexerEngine;
import org.sonatype.nexus.index.packer.IndexPacker;

/**
 * Consumer for indexing the repository to provide search and IDE integration features.
 */
public class NexusIndexerConsumer
    extends AbstractMonitoredConsumer
    implements KnownRepositoryContentConsumer
{
    private static final Logger log = LoggerFactory.getLogger( NexusIndexerConsumer.class );

    private NexusIndexer indexer;

    private ArtifactContextProducer artifactContextProducer;

    private IndexPacker indexPacker;

    private ManagedDefaultRepositoryContent repositoryContent;

    private IndexingContext context;

    private File managedRepository;
    
    private IndexerEngine indexerEngine;
    
    private Set<String> uinfos;

    public NexusIndexerConsumer( NexusIndexer indexer, IndexPacker indexPacker, IndexerEngine indexerEngine )
    {
        this.indexer = indexer;
        this.indexPacker = indexPacker;
        this.indexerEngine = indexerEngine;
        this.artifactContextProducer = new DefaultArtifactContextProducer();
    }

    public String getDescription()
    {
        return "Indexes the repository to provide search and IDE integration features";
    }

    public String getId()
    {
        return "index-content";
    }

    public boolean isPermanent()
    {
        return false;
    }

    public void beginScan( ManagedRepositoryConfiguration repository, Date whenGathered )
        throws ConsumerException
    {           
        managedRepository = new File( repository.getLocation() );
        String indexDir = repository.getIndexDir();
        
        File indexDirectory = null;
        if( indexDir != null && !"".equals( indexDir ) )
        {
            indexDirectory = new File( repository.getIndexDir() );
        }
        else
        {
            indexDirectory = new File( managedRepository, ".indexer" );
        }

        repositoryContent = new ManagedDefaultRepositoryContent();
        repositoryContent.setRepository( repository );
        uinfos = new HashSet<String>();

        synchronized ( indexer )
        {
            try
            {
                context =
                    indexer.addIndexingContext( repository.getId(), repository.getId(), managedRepository,
                                                indexDirectory, null, null, NexusIndexer.FULL_INDEX );
                context.setSearchable( repository.isScanned() );
                
                // read index to get all the artifacts already indexed
                IndexReader r = context.getIndexReader();                
                for ( int i = 0; i < r.numDocs(); i++ )
                {
                    if ( !r.isDeleted( i ) )
                    {
                        Document d = r.document( i );          
                        String uinfo = d.get( ArtifactInfo.UINFO );
          
                     // should we add a check here if the contents of the document still exist in the file system
                     // for cases when there is already an existing index & the contents of that index doesn't exist
                     // in the file system & in the database? 
                        if ( uinfo != null )
                        {
                            uinfos.add( uinfo );
                        }
                    }
                }
                
                indexerEngine.beginIndexing( context );
            }
            catch ( UnsupportedExistingLuceneIndexException e )
            {
                log.error( "Could not create index at " + indexDirectory.getAbsoluteFile(), e );
            }
            catch ( IOException e )
            {
                log.error( "Could not create index at " + indexDirectory.getAbsoluteFile(), e );
            }
        }
    }
    
    public void processFile( String path )
        throws ConsumerException
    {
        File artifactFile = new File( managedRepository, path );        
        ArtifactContext artifactContext = artifactContextProducer.getArtifactContext( context, artifactFile );
        
        if ( artifactContext != null )
        {
            try
            {                
                ArtifactInfo ai = artifactContext.getArtifactInfo();                
                String uinfo = AbstractIndexCreator.getGAV(
                    ai.groupId, ai.artifactId, ai.version, ai.classifier, ai.packaging );
                
                // already indexed so update!
                if ( uinfos.contains( uinfo ) )
                {
                    indexerEngine.update( context, artifactContext );
                }
                else
                {
                    indexerEngine.index( context, artifactContext );
                }    
            }
            catch ( IOException e )
            {
                throw new ConsumerException( e.getMessage(), e );
            }
        }
    }

    public void completeScan()
    {   
        final File indexLocation = new File( managedRepository, ".index" );
        try
        {
            indexerEngine.endIndexing( context );            
            indexPacker.packIndex( context, indexLocation );
            indexer.removeIndexingContext( context, false );
            uinfos = null;
        }
        catch ( IOException e )
        {
            log.error( "Could not pack index" + indexLocation.getAbsolutePath(), e );
        }
    }

    public List<String> getExcludes()
    {
        return new ArrayList<String>();
    }

    public List<String> getIncludes()
    {
        return Arrays.asList( "**/*" );
    }
}

@@ -5576,33 +5576,51 @@
             
-log.error
+throw new ConsumerException
 ( %22Could not
@@ -5755,33 +5755,51 @@
             
-log.error
+throw new ConsumerException
 ( %22Could not

throw consumer exception if it can't start so that it doesn't fail processing every file