package org.apache.maven.index.incremental;
   
   /*
    * 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.lucene.search.IndexSearcher;
  import org.apache.maven.index.AbstractIndexCreatorHelper;
  import org.apache.maven.index.NexusIndexer;
  import org.apache.maven.index.context.IndexingContext;
  import org.apache.maven.index.packer.IndexPackingRequest;
  import org.apache.maven.index.updater.IndexUpdateRequest;
  import org.apache.maven.index.updater.ResourceFetcher;
  import org.codehaus.plexus.util.FileUtils;
  import org.junit.Test;
  
  import java.io.File;
  import java.io.FileNotFoundException;
  import java.io.IOException;
  import java.io.InputStream;
  import java.util.List;
  import java.util.Properties;
  
  import static org.junit.Assert.assertEquals;
  import static org.junit.Assert.assertNull;
  
  public class DefaultIncrementalHandlerTest
      extends AbstractIndexCreatorHelper
  {
      IncrementalHandler handler = null;
  
      NexusIndexer indexer = null;
  
      IndexingContext context = null;
  
      File indexDir = null;
  
      File repoDir = null;
  
      @Override
      public void setUp()
          throws Exception
      {
          super.setUp();
  
          indexer = lookup( NexusIndexer.class );
          handler = lookup( IncrementalHandler.class );
  
          indexDir = new File( getBasedir(), "target/index/nexus-incremental-test" );
          repoDir = new File( getBasedir(), "target/repos/nexus-incremental-test" );
          FileUtils.deleteDirectory( indexDir );
          FileUtils.deleteDirectory( repoDir );
  
          context = indexer.addIndexingContext( "test", "test", repoDir, indexDir, null, null, DEFAULT_CREATORS );
      }
  
      @Override
      public void tearDown()
          throws Exception
      {
          super.tearDown();
  
          indexer.removeIndexingContext( context, true );
      }
  
      @Test
      public void testUpdateInvalidProperties()
          throws Exception
      {
          final IndexSearcher indexSearcher = context.acquireIndexSearcher();
          try
          {
              Properties properties = new Properties();
  
              IndexPackingRequest request = new IndexPackingRequest( context, indexSearcher.getIndexReader(), indexDir );
  
              // No properties definite fail
              assertNull( handler.getIncrementalUpdates( request, properties ) );
  
              properties.setProperty( IndexingContext.INDEX_TIMESTAMP, "junk" );
  
              // property set, but invalid
              assertNull( handler.getIncrementalUpdates( request, properties ) );
  
             properties.setProperty( IndexingContext.INDEX_TIMESTAMP, "19991112182432.432 -0600" );
 
             List<Integer> updates = handler.getIncrementalUpdates( request, properties );
 
             assertEquals( updates.size(), 0 );
         }
         finally
         {
             context.releaseIndexSearcher( indexSearcher );
         }
     }
 
     @Test
     public void testUpdateValid()
         throws Exception
     {
         Properties properties = new Properties();
 
         properties.setProperty( IndexingContext.INDEX_TIMESTAMP, "19991112182432.432 -0600" );
 
         FileUtils.copyDirectoryStructure( new File( getBasedir(), "src/test/repo/ch" ), new File( repoDir, "ch" ) );
 
         indexer.scan( context );
 
         final IndexSearcher indexSearcher = context.acquireIndexSearcher();
         try
         {
             IndexPackingRequest request = new IndexPackingRequest( context, indexSearcher.getIndexReader(), indexDir );
             List<Integer> updates = handler.getIncrementalUpdates( request, properties );
 
             assertEquals( updates.size(), 1 );
         }
         finally
         {
             context.releaseIndexSearcher( indexSearcher );
         }
     }
 
     @Test
     public void testRemoteUpdatesInvalidProperties()
         throws Exception
     {
         // just a dummy fetcher, it's not used here anyway
         IndexUpdateRequest request = new IndexUpdateRequest( context, new ResourceFetcher()
         {
             public InputStream retrieve( String name )
                 throws IOException, FileNotFoundException
             {
                 // TODO Auto-generated method stub
                 return null;
             }
 
             public void retrieve( String name, File targetFile )
                 throws IOException, FileNotFoundException
             {
                 // TODO Auto-generated method stub
 
             }
 
             public void disconnect()
                 throws IOException
             {
                 // TODO Auto-generated method stub
 
             }
 
             public void connect( String id, String url )
                 throws IOException
             {
                 // TODO Auto-generated method stub
 
             }
         } );
 
         Properties localProperties = new Properties();
         Properties remoteProperties = new Properties();
 
         List<String> filenames = handler.loadRemoteIncrementalUpdates( request, localProperties, remoteProperties );
 
         assertNull( filenames );
     }
 }