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

   1 package org.apache.archiva.rss.processor;
   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.util.Calendar;
  23 import java.util.List;
  24 import java.util.Map;
  25
  26 import org.apache.archiva.rss.RssFeedEntry;
  27 import org.apache.archiva.rss.RssFeedGenerator;
  28 import org.apache.commons.lang.time.DateUtils;
  29 import org.apache.maven.archiva.database.ArchivaDatabaseException;
  30 import org.apache.maven.archiva.database.ArtifactDAO;
  31 import org.apache.maven.archiva.database.Constraint;
  32 import org.apache.maven.archiva.database.constraints.ArtifactsByRepositoryConstraint;
  33 import org.apache.maven.archiva.model.ArchivaArtifact;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 import com.sun.syndication.feed.synd.SyndFeed;
  38
  39 /**
  40  * Retrieve and process all artifacts of a repository from the database and generate a rss feed.
  41  * The artifacts will be grouped by the date when the artifacts were gathered.
  42  * Each group will appear as one entry in the feed.
  43  *
  44  * @author <a href="mailto:oching@apache.org">Maria Odea Ching</a>
  45  * @version
  46  * @plexus.component role="org.apache.archiva.rss.processor.RssFeedProcessor" role-hint="new-artifacts"
  47  */
  48 public class NewArtifactsRssFeedProcessor
  49     extends AbstractArtifactsRssFeedProcessor
  50 {
  51     public static int numberOfDaysBeforeNow = 100;
  52
  53     private String title = "New Artifacts in Repository ";
  54
  55     private String desc = "These are the new artifacts found in the repository ";
  56
  57     /**
  58      * @plexus.requirement
  59      */
  60     private RssFeedGenerator generator;
  61
  62     private Logger log = LoggerFactory.getLogger( NewArtifactsRssFeedProcessor.class );
  63
  64     /**
  65      * @plexus.requirement role-hint="jdo"
  66      */
  67     private ArtifactDAO artifactDAO;
  68
  69     /**
  70      * Process the newly discovered artifacts in the repository. Generate feeds for new artifacts in the repository and
  71      * new versions of artifact.
  72      */
  73     public SyndFeed process( Map<String, String> reqParams )
  74     {
  75         log.debug( "Process new artifacts into rss feeds." );
  76
  77         String repoId = reqParams.get( RssFeedProcessor.KEY_REPO_ID );
  78         if ( repoId != null )
  79         {
  80             return processNewArtifactsInRepo( repoId );
  81         }
  82
  83         return null;
  84     }
  85
  86     private SyndFeed processNewArtifactsInRepo( String repoId )
  87     {
  88         try
  89         {
  90             Calendar greaterThanThisDate = Calendar.getInstance( DateUtils.UTC_TIME_ZONE );
  91             greaterThanThisDate.add( Calendar.DATE, -numberOfDaysBeforeNow );
  92
  93             Constraint artifactsByRepo = new ArtifactsByRepositoryConstraint( repoId, greaterThanThisDate.getTime(), "whenGathered" );
  94             List<ArchivaArtifact> artifacts = artifactDAO.queryArtifacts( artifactsByRepo );
  95
  96             List<RssFeedEntry> entries = processData( artifacts, true );
  97
  98             return generator.generateFeed( getTitle() + "\'" + repoId + "\'", "New artifacts found in repository " +
  99                 "\'" + repoId + "\'" + " during repository scan.", entries, "rss_feeds?repoId=" + repoId );
 100         }
 101         catch ( ArchivaDatabaseException ae )
 102         {
 103             log.error( ae.getMessage() );
 104         }
 105
 106         return null;
 107     }
 108
 109     public String getTitle()
 110     {
 111         return title;
 112     }
 113
 114     public String getDescription()
 115     {
 116         return desc;
 117     }
 118
 119     public RssFeedGenerator getGenerator()
 120     {
 121         return generator;
 122     }
 123
 124     public void setGenerator( RssFeedGenerator generator )
 125     {
 126         this.generator = generator;
 127     }
 128
 129     public ArtifactDAO getArtifactDAO()
 130     {
 131         return artifactDAO;
 132     }
 133
 134     public void setArtifactDAO( ArtifactDAO artifactDAO )
 135     {
 136         this.artifactDAO = artifactDAO;
 137     }
 138 }