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

   1 package org.apache.archiva.metadata.repository.stats;
   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.text.ParseException;
  23 import java.util.ArrayList;
  24 import java.util.Collections;
  25 import java.util.Date;
  26 import java.util.List;
  27
  28 import org.apache.archiva.metadata.repository.MetadataRepository;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 /**
  33  * @plexus.component role="org.apache.archiva.metadata.repository.stats.RepositoryStatisticsManager" role-hint="default"
  34  */
  35 public class DefaultRepositoryStatisticsManager
  36     implements RepositoryStatisticsManager
  37 {
  38     private static final Logger log = LoggerFactory.getLogger( DefaultRepositoryStatisticsManager.class );
  39
  40     /**
  41      * @plexus.requirement
  42      */
  43     private MetadataRepository metadataRepository;
  44
  45     public RepositoryStatistics getLastStatistics( String repositoryId )
  46     {
  47         // TODO: consider a more efficient implementation that directly gets the last one from the content repository
  48         List<String> scans = metadataRepository.getMetadataFacets( repositoryId, RepositoryStatistics.FACET_ID );
  49         Collections.sort( scans );
  50         if ( !scans.isEmpty() )
  51         {
  52             String name = scans.get( scans.size() - 1 );
  53             return (RepositoryStatistics) metadataRepository.getMetadataFacet( repositoryId,
  54                                                                                RepositoryStatistics.FACET_ID, name );
  55         }
  56         else
  57         {
  58             return null;
  59         }
  60     }
  61
  62     public void addStatisticsAfterScan( String repositoryId, RepositoryStatistics repositoryStatistics )
  63     {
  64         // In the future, instead of being tied to a scan we might want to record information in the fly based on
  65         // events that are occurring. Even without these totals we could query much of the information on demand based
  66         // on information from the metadata content repository. In the mean time, we lock information in at scan time.
  67         // Note that if new types are later discoverable due to a code change or new plugin, historical stats will not
  68         // be updated and the repository will need to be rescanned.
  69
  70         // TODO, populate these and also a count per artifact type
  71         // populate total artifact count from content repository
  72 //        repositoryStatistics.setTotalArtifactCount(  );
  73         // populate total size from content repository
  74 //        repositoryStatistics.setTotalArtifactFileSize(  );
  75         // populate total group count from content repository
  76 //        repositoryStatistics.setTotalGroupCount(  );
  77         // populate total project count from content repository
  78 //        repositoryStatistics.setTotalProjectCount(  );
  79
  80         metadataRepository.addMetadataFacet( repositoryId, repositoryStatistics );
  81     }
  82
  83     public void deleteStatistics( String repositoryId )
  84     {
  85         metadataRepository.removeMetadataFacets( repositoryId, RepositoryStatistics.FACET_ID );
  86     }
  87
  88     public List<RepositoryStatistics> getStatisticsInRange( String repositoryId, Date startTime, Date endTime )
  89     {
  90         List<RepositoryStatistics> results = new ArrayList<RepositoryStatistics>();
  91         List<String> list = metadataRepository.getMetadataFacets( repositoryId, RepositoryStatistics.FACET_ID );
  92         Collections.sort( list, Collections.reverseOrder() );
  93         for ( String name : list )
  94         {
  95             try
  96             {
  97                 Date date = RepositoryStatistics.SCAN_TIMESTAMP.parse( name );
  98                 if ( ( startTime == null || !date.before( startTime ) ) &&
  99                     ( endTime == null || !date.after( endTime ) ) )
 100                 {
 101                     RepositoryStatistics stats =
 102                         (RepositoryStatistics) metadataRepository.getMetadataFacet( repositoryId,
 103                                                                                     RepositoryStatistics.FACET_ID,
 104                                                                                     name );
 105                     results.add( stats );
 106                 }
 107             }
 108             catch ( ParseException e )
 109             {
 110                 log.error( "Invalid scan result found in the metadata repository: " + e.getMessage() );
 111                 // continue and ignore this one
 112             }
 113         }
 114         return results;
 115     }
 116
 117     public void setMetadataRepository( MetadataRepository metadataRepository )
 118     {
 119         this.metadataRepository = metadataRepository;
 120     }
 121 }