archiva-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ol...@apache.org
Subject svn commit: r1196832 - /archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java
Date Wed, 02 Nov 2011 22:28:47 GMT
Author: olamy
Date: Wed Nov  2 22:28:47 2011
New Revision: 1196832

URL: http://svn.apache.org/viewvc?rev=1196832&view=rev
Log:
fix formatting

Modified:
    archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java

Modified: archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java
URL: http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java?rev=1196832&r1=1196831&r2=1196832&view=diff
==============================================================================
--- archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java
(original)
+++ archiva/trunk/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/search/NexusRepositorySearch.java
Wed Nov  2 22:28:47 2011
@@ -63,7 +63,7 @@ import java.util.Set;
 public class NexusRepositorySearch
     implements RepositorySearch
 {
-    private Logger log = LoggerFactory.getLogger(getClass());
+    private Logger log = LoggerFactory.getLogger( getClass() );
 
     private NexusIndexer indexer;
 
@@ -79,11 +79,11 @@ public class NexusRepositorySearch
     }
 
     @Inject
-    public NexusRepositorySearch(PlexusSisuBridge plexusSisuBridge, ManagedRepositoryAdmin
managedRepositoryAdmin,
-                                 MavenIndexerUtils mavenIndexerUtils, ProxyConnectorAdmin
proxyConnectorAdmin)
+    public NexusRepositorySearch( PlexusSisuBridge plexusSisuBridge, ManagedRepositoryAdmin
managedRepositoryAdmin,
+                                  MavenIndexerUtils mavenIndexerUtils, ProxyConnectorAdmin
proxyConnectorAdmin )
         throws PlexusSisuBridgeException
     {
-        this.indexer = plexusSisuBridge.lookup(NexusIndexer.class);
+        this.indexer = plexusSisuBridge.lookup( NexusIndexer.class );
         this.managedRepositoryAdmin = managedRepositoryAdmin;
         this.mavenIndexerUtils = mavenIndexerUtils;
         this.proxyConnectorAdmin = proxyConnectorAdmin;
@@ -92,207 +92,213 @@ public class NexusRepositorySearch
     /**
      * @see RepositorySearch#search(String, List, String, SearchResultLimits, List)
      */
-    public SearchResults search(String principal, List<String> selectedRepos, String
term, SearchResultLimits limits,
-                                List<String> previousSearchTerms)
+    public SearchResults search( String principal, List<String> selectedRepos, String
term, SearchResultLimits limits,
+                                 List<String> previousSearchTerms )
         throws RepositorySearchException
     {
         List<String> indexingContextIds = addIndexingContexts( selectedRepos );
 
         // since upgrade to nexus 2.0.0, query has changed from g:[QUERIED TERM]* to g:*[QUERIED
TERM]*
         //      resulting to more wildcard searches so we need to increase max clause count
-        BooleanQuery.setMaxClauseCount(Integer.MAX_VALUE);
+        BooleanQuery.setMaxClauseCount( Integer.MAX_VALUE );
         BooleanQuery q = new BooleanQuery();
 
         if ( previousSearchTerms == null || previousSearchTerms.isEmpty() )
         {
-            constructQuery(term, q);
+            constructQuery( term, q );
         }
         else
         {
             for ( String previousTerm : previousSearchTerms )
             {
                 BooleanQuery iQuery = new BooleanQuery();
-                constructQuery(previousTerm, iQuery);
+                constructQuery( previousTerm, iQuery );
 
-                q.add(iQuery, Occur.MUST);
+                q.add( iQuery, Occur.MUST );
             }
 
             BooleanQuery iQuery = new BooleanQuery();
-            constructQuery(term, iQuery);
-            q.add(iQuery, Occur.MUST);
+            constructQuery( term, iQuery );
+            q.add( iQuery, Occur.MUST );
         }
 
         // we retun only artifacts without classifier in quick search, olamy cannot find
a way to say with this field empty
         // FIXME  cannot find a way currently to setup this in constructQuery !!!
-        return search(limits, q, indexingContextIds, NoClassifierArtifactInfoFiler.LIST,
principal, selectedRepos);
+        return search( limits, q, indexingContextIds, NoClassifierArtifactInfoFiler.LIST,
principal, selectedRepos );
 
     }
 
     /**
      * @see RepositorySearch#search(String, SearchFields, SearchResultLimits)
      */
-    public SearchResults search(String principal, SearchFields searchFields, SearchResultLimits
limits)
+    public SearchResults search( String principal, SearchFields searchFields, SearchResultLimits
limits )
         throws RepositorySearchException
     {
         if ( searchFields.getRepositories() == null )
         {
-            throw new RepositorySearchException("Repositories cannot be null.");
+            throw new RepositorySearchException( "Repositories cannot be null." );
         }
 
-        List<String> indexingContextIds = addIndexingContexts(searchFields.getRepositories());
+        List<String> indexingContextIds = addIndexingContexts( searchFields.getRepositories()
);
 
         // if no index found in the specified ones return an empty search result instead
of doing a search on all index
         // olamy: IMHO doesn't make sense
-        if ( !searchFields.getRepositories().isEmpty() && (indexingContextIds ==
null || indexingContextIds.isEmpty()) )
+        if ( !searchFields.getRepositories().isEmpty() && ( indexingContextIds ==
null
+            || indexingContextIds.isEmpty() ) )
         {
             return new SearchResults();
         }
 
         BooleanQuery q = new BooleanQuery();
-        if ( StringUtils.isNotBlank(searchFields.getGroupId()) )
+        if ( StringUtils.isNotBlank( searchFields.getGroupId() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.GROUP_ID, new StringSearchExpression(searchFields.getGroupId())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( MAVEN.GROUP_ID, new StringSearchExpression( searchFields.getGroupId()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getArtifactId()) )
+        if ( StringUtils.isNotBlank( searchFields.getArtifactId() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.ARTIFACT_ID, new StringSearchExpression(searchFields.getArtifactId())),
-                  Occur.MUST);
+            q.add(
+                indexer.constructQuery( MAVEN.ARTIFACT_ID, new StringSearchExpression( searchFields.getArtifactId()
) ),
+                Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getVersion()) )
+        if ( StringUtils.isNotBlank( searchFields.getVersion() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.VERSION, new StringSearchExpression(searchFields.getVersion())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( MAVEN.VERSION, new StringSearchExpression( searchFields.getVersion()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getPackaging()) )
+        if ( StringUtils.isNotBlank( searchFields.getPackaging() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.PACKAGING, new StringSearchExpression(searchFields.getPackaging())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( MAVEN.PACKAGING, new StringSearchExpression( searchFields.getPackaging()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getClassName()) )
+        if ( StringUtils.isNotBlank( searchFields.getClassName() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.CLASSNAMES, new StringSearchExpression(searchFields.getClassName())),
-                  Occur.MUST);
+            q.add(
+                indexer.constructQuery( MAVEN.CLASSNAMES, new StringSearchExpression( searchFields.getClassName()
) ),
+                Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleSymbolicName()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleSymbolicName() ) )
         {
-            q.add(indexer.constructQuery(OSGI.SYMBOLIC_NAME,
-                                         new StringSearchExpression(searchFields.getBundleSymbolicName())),
Occur.MUST);
+            q.add( indexer.constructQuery( OSGI.SYMBOLIC_NAME,
+                                           new StringSearchExpression( searchFields.getBundleSymbolicName()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleVersion()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleVersion() ) )
         {
-            q.add(indexer.constructQuery(OSGI.VERSION, new StringSearchExpression(searchFields.getBundleVersion())),
-                  Occur.MUST);
+            q.add(
+                indexer.constructQuery( OSGI.VERSION, new StringSearchExpression( searchFields.getBundleVersion()
) ),
+                Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleExportPackage()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleExportPackage() ) )
         {
-            q.add(indexer.constructQuery(OSGI.EXPORT_PACKAGE,
-                                         new StringSearchExpression(searchFields.getBundleExportPackage())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( OSGI.EXPORT_PACKAGE,
+                                           new StringSearchExpression( searchFields.getBundleExportPackage()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleExportService()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleExportService() ) )
         {
-            q.add(indexer.constructQuery(OSGI.EXPORT_SERVICE,
-                                         new StringSearchExpression(searchFields.getBundleExportService())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( OSGI.EXPORT_SERVICE,
+                                           new StringSearchExpression( searchFields.getBundleExportService()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleImportPackage()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleImportPackage() ) )
         {
-            q.add(indexer.constructQuery(OSGI.IMPORT_PACKAGE,
-                                         new StringSearchExpression(searchFields.getBundleImportPackage())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( OSGI.IMPORT_PACKAGE,
+                                           new StringSearchExpression( searchFields.getBundleImportPackage()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getBundleName()) )
+        if ( StringUtils.isNotBlank( searchFields.getBundleName() ) )
         {
-            q.add(indexer.constructQuery(OSGI.NAME, new StringSearchExpression(searchFields.getBundleName())),
-                  Occur.MUST);
+            q.add( indexer.constructQuery( OSGI.NAME, new StringSearchExpression( searchFields.getBundleName()
) ),
+                   Occur.MUST );
         }
 
-        if ( StringUtils.isNotBlank(searchFields.getClassifier()) )
+        if ( StringUtils.isNotBlank( searchFields.getClassifier() ) )
         {
-            q.add(indexer.constructQuery(MAVEN.CLASSIFIER, new StringSearchExpression(searchFields.getClassifier())),
-                  Occur.MUST);
+            q.add(
+                indexer.constructQuery( MAVEN.CLASSIFIER, new StringSearchExpression( searchFields.getClassifier()
) ),
+                Occur.MUST );
         }
 
         if ( q.getClauses() == null || q.getClauses().length <= 0 )
         {
-            throw new RepositorySearchException("No search fields set.");
+            throw new RepositorySearchException( "No search fields set." );
         }
 
-        return search(limits, q, indexingContextIds, Collections.<ArtifactInfoFiler>emptyList(),
principal,
-                      searchFields.getRepositories());
+        return search( limits, q, indexingContextIds, Collections.<ArtifactInfoFiler>emptyList(),
principal,
+                       searchFields.getRepositories() );
     }
 
-    private SearchResults search(SearchResultLimits limits, BooleanQuery q, List<String>
indexingContextIds,
-                                 List<? extends ArtifactInfoFiler> filters, String
principal,
-                                 List<String> selectedRepos)
+    private SearchResults search( SearchResultLimits limits, BooleanQuery q, List<String>
indexingContextIds,
+                                  List<? extends ArtifactInfoFiler> filters, String
principal,
+                                  List<String> selectedRepos )
         throws RepositorySearchException
     {
 
         try
         {
-            FlatSearchRequest request = new FlatSearchRequest(q);
-            request.setContexts(getIndexingContexts(indexingContextIds));
+            FlatSearchRequest request = new FlatSearchRequest( q );
+            request.setContexts( getIndexingContexts( indexingContextIds ) );
 
-            FlatSearchResponse response = indexer.searchFlat(request);
+            FlatSearchResponse response = indexer.searchFlat( request );
 
             if ( response == null || response.getTotalHits() == 0 )
             {
                 SearchResults results = new SearchResults();
-                results.setLimits(limits);
+                results.setLimits( limits );
                 return results;
             }
 
-            return convertToSearchResults(response, limits, filters, principal, selectedRepos);
+            return convertToSearchResults( response, limits, filters, principal, selectedRepos
);
         }
         catch ( IOException e )
         {
-            throw new RepositorySearchException(e.getMessage(), e);
+            throw new RepositorySearchException( e.getMessage(), e );
         }
         catch ( RepositoryAdminException e )
         {
-            throw new RepositorySearchException(e.getMessage(), e);
+            throw new RepositorySearchException( e.getMessage(), e );
         }
 
     }
 
-    private List<IndexingContext> getIndexingContexts(List<String> ids)
+    private List<IndexingContext> getIndexingContexts( List<String> ids )
     {
-        List<IndexingContext> contexts = new ArrayList<IndexingContext>(ids.size());
+        List<IndexingContext> contexts = new ArrayList<IndexingContext>( ids.size()
);
 
         for ( String id : ids )
         {
-            IndexingContext context = indexer.getIndexingContexts().get(id);
+            IndexingContext context = indexer.getIndexingContexts().get( id );
             if ( context != null )
             {
-                contexts.add(context);
+                contexts.add( context );
             }
             else
             {
-                log.warn("context with id {} not exists", id);
+                log.warn( "context with id {} not exists", id );
             }
         }
 
         return contexts;
     }
 
-    private void constructQuery(String term, BooleanQuery q)
+    private void constructQuery( String term, BooleanQuery q )
     {
-        q.add(indexer.constructQuery(MAVEN.GROUP_ID, new StringSearchExpression(term)), Occur.SHOULD);
-        q.add(indexer.constructQuery(MAVEN.ARTIFACT_ID, new StringSearchExpression(term)),
Occur.SHOULD);
-        q.add(indexer.constructQuery(MAVEN.VERSION, new StringSearchExpression(term)), Occur.SHOULD);
-        q.add(indexer.constructQuery(MAVEN.PACKAGING, new StringSearchExpression(term)),
Occur.SHOULD);
-        q.add(indexer.constructQuery(MAVEN.CLASSNAMES, new StringSearchExpression(term)),
Occur.SHOULD);
+        q.add( indexer.constructQuery( MAVEN.GROUP_ID, new StringSearchExpression( term )
), Occur.SHOULD );
+        q.add( indexer.constructQuery( MAVEN.ARTIFACT_ID, new StringSearchExpression( term
) ), Occur.SHOULD );
+        q.add( indexer.constructQuery( MAVEN.VERSION, new StringSearchExpression( term )
), Occur.SHOULD );
+        q.add( indexer.constructQuery( MAVEN.PACKAGING, new StringSearchExpression( term
) ), Occur.SHOULD );
+        q.add( indexer.constructQuery( MAVEN.CLASSNAMES, new StringSearchExpression( term
) ), Occur.SHOULD );
 
         //Query query =
         //    new WildcardQuery( new Term( MAVEN.CLASSNAMES.getFieldName(), "*" ) );
@@ -306,88 +312,88 @@ public class NexusRepositorySearch
      * @param selectedRepos
      * @return indexing contextId used
      */
-    private List<String> addIndexingContexts(List<String> selectedRepos)
+    private List<String> addIndexingContexts( List<String> selectedRepos )
     {
         Set<String> indexingContextIds = new HashSet<String>();
         for ( String repo : selectedRepos )
         {
             try
             {
-                ManagedRepository repoConfig = managedRepositoryAdmin.getManagedRepository(repo);
+                ManagedRepository repoConfig = managedRepositoryAdmin.getManagedRepository(
repo );
 
                 if ( repoConfig != null )
                 {
                     String indexDir = repoConfig.getIndexDirectory();
                     File indexDirectory = null;
-                    if ( indexDir != null && !"".equals(indexDir) )
+                    if ( indexDir != null && !"".equals( indexDir ) )
                     {
-                        indexDirectory = new File(repoConfig.getIndexDirectory());
+                        indexDirectory = new File( repoConfig.getIndexDirectory() );
                     }
                     else
                     {
-                        indexDirectory = new File(repoConfig.getLocation(), ".indexer");
+                        indexDirectory = new File( repoConfig.getLocation(), ".indexer" );
                     }
 
-                    IndexingContext context = indexer.getIndexingContexts().get(repoConfig.getId());
+                    IndexingContext context = indexer.getIndexingContexts().get( repoConfig.getId()
);
                     if ( context != null )
                     {
                         // alreday here so no need to record it again
-                        log.debug("index with id {} already exists skip adding it", repoConfig.getId());
+                        log.debug( "index with id {} already exists skip adding it", repoConfig.getId()
);
                         // set searchable flag
-                        context.setSearchable(repoConfig.isScanned());
-                        indexingContextIds.add(context.getId());
-                        indexingContextIds.addAll(getRemoteIndexingContextIds(repo));
+                        context.setSearchable( repoConfig.isScanned() );
+                        indexingContextIds.add( context.getId() );
+                        indexingContextIds.addAll( getRemoteIndexingContextIds( repo ) );
                         continue;
                     }
 
-                    context = indexer.addIndexingContext(repoConfig.getId(), repoConfig.getId(),
-                                                         new File(repoConfig.getLocation()),
indexDirectory, null, null,
-                                                         getAllIndexCreators());
-                    context.setSearchable(repoConfig.isScanned());
+                    context = indexer.addIndexingContext( repoConfig.getId(), repoConfig.getId(),
+                                                          new File( repoConfig.getLocation()
), indexDirectory, null,
+                                                          null, getAllIndexCreators() );
+                    context.setSearchable( repoConfig.isScanned() );
                     if ( context.isSearchable() )
                     {
-                        indexingContextIds.addAll(getRemoteIndexingContextIds(repo));
-                        indexingContextIds.add(context.getId());
+                        indexingContextIds.addAll( getRemoteIndexingContextIds( repo ) );
+                        indexingContextIds.add( context.getId() );
                     }
                     else
                     {
-                        log.warn("indexingContext with id {} not searchable", repoConfig.getId());
+                        log.warn( "indexingContext with id {} not searchable", repoConfig.getId()
);
                     }
 
                 }
                 else
                 {
-                    log.warn("Repository '" + repo + "' not found in configuration.");
+                    log.warn( "Repository '" + repo + "' not found in configuration." );
                 }
             }
             catch ( UnsupportedExistingLuceneIndexException e )
             {
-                log.warn("Error accessing index of repository '" + repo + "' : " + e.getMessage());
+                log.warn( "Error accessing index of repository '" + repo + "' : " + e.getMessage()
);
                 continue;
             }
             catch ( IOException e )
             {
-                log.warn("IO error occured while accessing index of repository '" + repo
+ "' : " + e.getMessage());
+                log.warn( "IO error occured while accessing index of repository '" + repo
+ "' : " + e.getMessage() );
                 continue;
             }
             catch ( RepositoryAdminException e )
             {
-                log.warn("RepositoryAdminException occured while accessing index of repository
'" + repo + "' : "
-                             + e.getMessage());
+                log.warn( "RepositoryAdminException occured while accessing index of repository
'" + repo + "' : "
+                              + e.getMessage() );
                 continue;
             }
         }
 
-        return new ArrayList<String>(indexingContextIds);
+        return new ArrayList<String>( indexingContextIds );
     }
 
 
-    private Set<String> getRemoteIndexingContextIds(String managedRepoId)
+    private Set<String> getRemoteIndexingContextIds( String managedRepoId )
         throws RepositoryAdminException
     {
         Set<String> ids = new HashSet<String>();
 
-        List<ProxyConnector> proxyConnectors = proxyConnectorAdmin.getProxyConnectorAsMap().get(managedRepoId);
+        List<ProxyConnector> proxyConnectors = proxyConnectorAdmin.getProxyConnectorAsMap().get(
managedRepoId );
 
         if ( proxyConnectors == null || proxyConnectors.isEmpty() )
         {
@@ -397,34 +403,35 @@ public class NexusRepositorySearch
         for ( ProxyConnector proxyConnector : proxyConnectors )
         {
             String remoteId = "remote-" + proxyConnector.getTargetRepoId();
-            IndexingContext context = indexer.getIndexingContexts().get(remoteId);
+            IndexingContext context = indexer.getIndexingContexts().get( remoteId );
             if ( context != null && context.isSearchable() )
             {
-                ids.add(remoteId);
+                ids.add( remoteId );
             }
         }
 
         return ids;
     }
 
-    public Collection<String> getAllGroupIds(String principal, List<String> selectedRepos)
+    public Collection<String> getAllGroupIds( String principal, List<String>
selectedRepos )
         throws RepositorySearchException
     {
         List<IndexingContext> indexContexts = getIndexingContexts( selectedRepos );
-        if (indexContexts == null || indexContexts.isEmpty())
+        if ( indexContexts == null || indexContexts.isEmpty() )
         {
             return Collections.emptyList();
         }
 
         try
         {
-            Set<String> allGroupIds = new HashSet<String>(  );
-            for (IndexingContext indexingContext : indexContexts)
+            Set<String> allGroupIds = new HashSet<String>();
+            for ( IndexingContext indexingContext : indexContexts )
             {
                 allGroupIds.addAll( indexingContext.getAllGroups() );
             }
             return allGroupIds;
-        } catch ( IOException e )
+        }
+        catch ( IOException e )
         {
             throw new RepositorySearchException( e.getMessage(), e );
         }
@@ -436,9 +443,9 @@ public class NexusRepositorySearch
     }
 
 
-    private SearchResults convertToSearchResults(FlatSearchResponse response, SearchResultLimits
limits,
-                                                 List<? extends ArtifactInfoFiler>
artifactInfoFilers, String principal,
-                                                 List<String> selectedRepos)
+    private SearchResults convertToSearchResults( FlatSearchResponse response, SearchResultLimits
limits,
+                                                  List<? extends ArtifactInfoFiler>
artifactInfoFilers,
+                                                  String principal, List<String> selectedRepos
)
         throws RepositoryAdminException
     {
         SearchResults results = new SearchResults();
@@ -446,55 +453,55 @@ public class NexusRepositorySearch
 
         for ( ArtifactInfo artifactInfo : artifactInfos )
         {
-            String id = SearchUtil.getHitId(artifactInfo.groupId, artifactInfo.artifactId,
artifactInfo.classifier,
-                                            artifactInfo.packaging);
+            String id = SearchUtil.getHitId( artifactInfo.groupId, artifactInfo.artifactId,
artifactInfo.classifier,
+                                             artifactInfo.packaging );
             Map<String, SearchResultHit> hitsMap = results.getHitsMap();
 
-            if ( !applyArtifactInfoFilters(artifactInfo, artifactInfoFilers, hitsMap) )
+            if ( !applyArtifactInfoFilters( artifactInfo, artifactInfoFilers, hitsMap ) )
             {
                 continue;
             }
 
-            SearchResultHit hit = hitsMap.get(id);
+            SearchResultHit hit = hitsMap.get( id );
             if ( hit != null )
             {
-                if ( !hit.getVersions().contains(artifactInfo.version) )
+                if ( !hit.getVersions().contains( artifactInfo.version ) )
                 {
-                    hit.addVersion(artifactInfo.version);
+                    hit.addVersion( artifactInfo.version );
                 }
             }
             else
             {
                 hit = new SearchResultHit();
-                hit.setArtifactId(artifactInfo.artifactId);
-                hit.setGroupId(artifactInfo.groupId);
-                hit.setRepositoryId(artifactInfo.repository);
-                hit.addVersion(artifactInfo.version);
-                hit.setBundleExportPackage(artifactInfo.bundleExportPackage);
-                hit.setBundleExportService(artifactInfo.bundleExportService);
-                hit.setBundleSymbolicName(artifactInfo.bundleSymbolicName);
-                hit.setBundleVersion(artifactInfo.bundleVersion);
-                hit.setBundleDescription(artifactInfo.bundleDescription);
-                hit.setBundleDocUrl(artifactInfo.bundleDocUrl);
-                hit.setBundleRequireBundle(artifactInfo.bundleRequireBundle);
-                hit.setBundleImportPackage(artifactInfo.bundleImportPackage);
-                hit.setBundleLicense(artifactInfo.bundleLicense);
-                hit.setBundleName(artifactInfo.bundleName);
-                hit.setContext(artifactInfo.context);
-                hit.setGoals(artifactInfo.goals);
-                hit.setPrefix(artifactInfo.prefix);
-                hit.setPackaging(artifactInfo.packaging);
-                hit.setClassifier(artifactInfo.classifier);
-                hit.setUrl(getBaseUrl(artifactInfo, selectedRepos));
-            }
-
-            results.addHit(id, hit);
-        }
-
-        results.setTotalHits(response.getTotalHitsCount());
-        results.setTotalHitsMapSize(results.getHitsMap().values().size());
-        results.setReturnedHitsCount(response.getReturnedHitsCount());
-        results.setLimits(limits);
+                hit.setArtifactId( artifactInfo.artifactId );
+                hit.setGroupId( artifactInfo.groupId );
+                hit.setRepositoryId( artifactInfo.repository );
+                hit.addVersion( artifactInfo.version );
+                hit.setBundleExportPackage( artifactInfo.bundleExportPackage );
+                hit.setBundleExportService( artifactInfo.bundleExportService );
+                hit.setBundleSymbolicName( artifactInfo.bundleSymbolicName );
+                hit.setBundleVersion( artifactInfo.bundleVersion );
+                hit.setBundleDescription( artifactInfo.bundleDescription );
+                hit.setBundleDocUrl( artifactInfo.bundleDocUrl );
+                hit.setBundleRequireBundle( artifactInfo.bundleRequireBundle );
+                hit.setBundleImportPackage( artifactInfo.bundleImportPackage );
+                hit.setBundleLicense( artifactInfo.bundleLicense );
+                hit.setBundleName( artifactInfo.bundleName );
+                hit.setContext( artifactInfo.context );
+                hit.setGoals( artifactInfo.goals );
+                hit.setPrefix( artifactInfo.prefix );
+                hit.setPackaging( artifactInfo.packaging );
+                hit.setClassifier( artifactInfo.classifier );
+                hit.setUrl( getBaseUrl( artifactInfo, selectedRepos ) );
+            }
+
+            results.addHit( id, hit );
+        }
+
+        results.setTotalHits( response.getTotalHitsCount() );
+        results.setTotalHitsMapSize( results.getHitsMap().values().size() );
+        results.setReturnedHitsCount( response.getReturnedHitsCount() );
+        results.setLimits( limits );
 
         if ( limits == null || limits.getSelectedPage() == SearchResultLimits.ALL_PAGES )
         {
@@ -502,7 +509,7 @@ public class NexusRepositorySearch
         }
         else
         {
-            return paginate(results);
+            return paginate( results );
         }
     }
 
@@ -512,43 +519,43 @@ public class NexusRepositorySearch
      * @param artifactInfo
      * @return
      */
-    protected String getBaseUrl(ArtifactInfo artifactInfo, List<String> selectedRepos)
+    protected String getBaseUrl( ArtifactInfo artifactInfo, List<String> selectedRepos
)
         throws RepositoryAdminException
     {
         StringBuilder sb = new StringBuilder();
-        if ( StringUtils.startsWith(artifactInfo.context, "remote-") )
+        if ( StringUtils.startsWith( artifactInfo.context, "remote-" ) )
         {
             // it's a remote index result we search a managed which proxying this remote
and on which
             // current user has read karma
             String managedRepoId =
-                getManagedRepoId(StringUtils.substringAfter(artifactInfo.context, "remote-"),
selectedRepos);
+                getManagedRepoId( StringUtils.substringAfter( artifactInfo.context, "remote-"
), selectedRepos );
             if ( managedRepoId != null )
             {
-                sb.append('/').append(managedRepoId);
+                sb.append( '/' ).append( managedRepoId );
             }
         }
         else
         {
-            sb.append('/').append(artifactInfo.context);
+            sb.append( '/' ).append( artifactInfo.context );
         }
 
-        sb.append('/').append(StringUtils.replaceChars(artifactInfo.groupId, '.', '/'));
-        sb.append('/').append(artifactInfo.artifactId);
-        sb.append('/').append(artifactInfo.version);
-        sb.append('/').append(artifactInfo.artifactId);
-        sb.append('-').append(artifactInfo.version);
-        if ( StringUtils.isNotBlank(artifactInfo.classifier) )
+        sb.append( '/' ).append( StringUtils.replaceChars( artifactInfo.groupId, '.', '/'
) );
+        sb.append( '/' ).append( artifactInfo.artifactId );
+        sb.append( '/' ).append( artifactInfo.version );
+        sb.append( '/' ).append( artifactInfo.artifactId );
+        sb.append( '-' ).append( artifactInfo.version );
+        if ( StringUtils.isNotBlank( artifactInfo.classifier ) )
         {
-            sb.append('-').append(artifactInfo.classifier);
+            sb.append( '-' ).append( artifactInfo.classifier );
         }
         // maven-plugin packaging is a jar
-        if ( StringUtils.equals("maven-plugin", artifactInfo.packaging) )
+        if ( StringUtils.equals( "maven-plugin", artifactInfo.packaging ) )
         {
-            sb.append("jar");
+            sb.append( "jar" );
         }
         else
         {
-            sb.append('.').append(artifactInfo.packaging);
+            sb.append( '.' ).append( artifactInfo.packaging );
         }
 
         return sb.toString();
@@ -562,7 +569,7 @@ public class NexusRepositorySearch
      * @return
      * @throws RepositoryAdminException
      */
-    private String getManagedRepoId(String remoteRepo, List<String> selectedRepos)
+    private String getManagedRepoId( String remoteRepo, List<String> selectedRepos
)
         throws RepositoryAdminException
     {
         Map<String, List<ProxyConnector>> proxyConnectorMap = proxyConnectorAdmin.getProxyConnectorAsMap();
@@ -574,11 +581,11 @@ public class NexusRepositorySearch
         {
             for ( Map.Entry<String, List<ProxyConnector>> entry : proxyConnectorMap.entrySet()
)
             {
-                if ( selectedRepos.contains(entry.getKey()) )
+                if ( selectedRepos.contains( entry.getKey() ) )
                 {
                     for ( ProxyConnector proxyConnector : entry.getValue() )
                     {
-                        if ( StringUtils.equals(remoteRepo, proxyConnector.getTargetRepoId())
)
+                        if ( StringUtils.equals( remoteRepo, proxyConnector.getTargetRepoId()
) )
                         {
                             return proxyConnector.getSourceRepoId();
                         }
@@ -593,7 +600,7 @@ public class NexusRepositorySearch
 
             for ( ProxyConnector proxyConnector : entry.getValue() )
             {
-                if ( StringUtils.equals(remoteRepo, proxyConnector.getTargetRepoId()) )
+                if ( StringUtils.equals( remoteRepo, proxyConnector.getTargetRepoId() ) )
                 {
                     return proxyConnector.getSourceRepoId();
                 }
@@ -603,9 +610,9 @@ public class NexusRepositorySearch
         return null;
     }
 
-    private boolean applyArtifactInfoFilters(ArtifactInfo artifactInfo,
-                                             List<? extends ArtifactInfoFiler> artifactInfoFilers,
-                                             Map<String, SearchResultHit> currentResult)
+    private boolean applyArtifactInfoFilters( ArtifactInfo artifactInfo,
+                                              List<? extends ArtifactInfoFiler> artifactInfoFilers,
+                                              Map<String, SearchResultHit> currentResult
)
     {
         if ( artifactInfoFilers == null || artifactInfoFilers.isEmpty() )
         {
@@ -614,7 +621,7 @@ public class NexusRepositorySearch
 
         for ( ArtifactInfoFiler filter : artifactInfoFilers )
         {
-            if ( !filter.addArtifactInResult(artifactInfo, currentResult) )
+            if ( !filter.addArtifactInResult( artifactInfo, currentResult ) )
             {
                 return false;
             }
@@ -622,7 +629,7 @@ public class NexusRepositorySearch
         return true;
     }
 
-    protected SearchResults paginate(SearchResults results)
+    protected SearchResults paginate( SearchResults results )
     {
         SearchResultLimits limits = results.getLimits();
         SearchResults paginated = new SearchResults();
@@ -647,12 +654,12 @@ public class NexusRepositorySearch
                     break;
                 }
 
-                SearchResultHit hit = results.getHits().get(( offset + i ));
+                SearchResultHit hit = results.getHits().get( ( offset + i ) );
                 if ( hit != null )
                 {
-                    String id = SearchUtil.getHitId(hit.getGroupId(), hit.getArtifactId(),
hit.getClassifier(),
-                                                    hit.getPackaging());
-                    paginated.addHit(id, hit);
+                    String id = SearchUtil.getHitId( hit.getGroupId(), hit.getArtifactId(),
hit.getClassifier(),
+                                                     hit.getPackaging() );
+                    paginated.addHit( id, hit );
                 }
                 else
                 {
@@ -660,10 +667,10 @@ public class NexusRepositorySearch
                 }
             }
         }
-        paginated.setTotalHits(results.getTotalHits());
-        paginated.setReturnedHitsCount(paginated.getHits().size());
+        paginated.setTotalHits( results.getTotalHits() );
+        paginated.setReturnedHitsCount( paginated.getHits().size() );
         paginated.setTotalHitsMapSize( results.getTotalHitsMapSize() );
-        paginated.setLimits(limits);
+        paginated.setLimits( limits );
 
         return paginated;
     }



Mime
View raw message