source.dussan.org Git - archiva.git/blob

   1 package org.apache.archiva.scheduler.indexing;
   2
   3 /*
   4  * Licensed to the Apache Software Foundation (ASF) under one
   5  * or more contributor license agreements.  See the NOTICE file
   6  * distributed with this work for additional information
   7  * regarding copyright ownership.  The ASF licenses this file
   8  * to you under the Apache License, Version 2.0 (the
   9  * "License"); you may not use this file except in compliance
  10  * with the License.  You may obtain a copy of the License at
  11  *
  12  *  http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing,
  15  * software distributed under the License is distributed on an
  16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  17  * KIND, either express or implied.  See the License for the
  18  * specific language governing permissions and limitations
  19  * under the License.
  20  */
  21
  22 import java.io.File;
  23 import java.io.IOException;
  24
  25 import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
  26 import org.codehaus.plexus.taskqueue.Task;
  27 import org.sonatype.nexus.index.NexusIndexer;
  28 import org.sonatype.nexus.index.context.DefaultIndexingContext;
  29 import org.sonatype.nexus.index.context.IndexingContext;
  30 import org.sonatype.nexus.index.context.UnsupportedExistingLuceneIndexException;
  31
  32 public class ArtifactIndexingTask
  33     implements Task
  34 {
  35     public enum Action
  36     {
  37         ADD, DELETE, FINISH
  38     }
  39
  40     private final ManagedRepositoryConfiguration repository;
  41
  42     private final File resourceFile;
  43
  44     private final Action action;
  45
  46     private final IndexingContext context;
  47
  48     public ArtifactIndexingTask( ManagedRepositoryConfiguration repository, File resourceFile, Action action,
  49                                  IndexingContext context )
  50     {
  51         this.repository = repository;
  52         this.resourceFile = resourceFile;
  53         this.action = action;
  54         this.context = context;
  55     }
  56
  57     public long getMaxExecutionTime()
  58     {
  59         return 0;
  60     }
  61
  62     public File getResourceFile()
  63     {
  64         return resourceFile;
  65     }
  66
  67     public Action getAction()
  68     {
  69         return action;
  70     }
  71
  72     @Override
  73     public String toString()
  74     {
  75         return "ArtifactIndexingTask [action=" + action + ", repositoryId=" + repository.getId() + ", resourceFile="
  76             + resourceFile + "]";
  77     }
  78
  79     public ManagedRepositoryConfiguration getRepository()
  80     {
  81         return repository;
  82     }
  83
  84     public IndexingContext getContext()
  85     {
  86         return context;
  87     }
  88
  89     @Override
  90     public int hashCode()
  91     {
  92         final int prime = 31;
  93         int result = 1;
  94         result = prime * result + action.hashCode();
  95         result = prime * result + repository.getId().hashCode();
  96         result = prime * result + ( ( resourceFile == null ) ? 0 : resourceFile.hashCode() );
  97         return result;
  98     }
  99
 100     @Override
 101     public boolean equals( Object obj )
 102     {
 103         if ( this == obj )
 104             return true;
 105         if ( obj == null )
 106             return false;
 107         if ( getClass() != obj.getClass() )
 108             return false;
 109         ArtifactIndexingTask other = (ArtifactIndexingTask) obj;
 110         if ( !action.equals( other.action ) )
 111             return false;
 112         if ( !repository.getId().equals( other.repository.getId() ) )
 113             return false;
 114         if ( resourceFile == null )
 115         {
 116             if ( other.resourceFile != null )
 117                 return false;
 118         }
 119         else if ( !resourceFile.equals( other.resourceFile ) )
 120             return false;
 121         return true;
 122     }
 123
 124     public static IndexingContext createContext( ManagedRepositoryConfiguration repository )
 125         throws IOException, UnsupportedExistingLuceneIndexException
 126     {
 127         String indexDir = repository.getIndexDir();
 128         File managedRepository = new File( repository.getLocation() );
 129
 130         File indexDirectory = null;
 131         if ( indexDir != null && !"".equals( indexDir ) )
 132         {
 133             indexDirectory = new File( repository.getIndexDir() );
 134         }
 135         else
 136         {
 137             indexDirectory = new File( managedRepository, ".indexer" );
 138         }
 139
 140         IndexingContext context =
 141             new DefaultIndexingContext( repository.getId(), repository.getId(), managedRepository, indexDirectory,
 142                                         null, null, NexusIndexer.FULL_INDEX, false );
 143         context.setSearchable( repository.isScanned() );
 144         return context;
 145     }
 146 }