package org.apache.archiva.rss.processor;

 /*

  * 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 java.util.Calendar;

 import java.util.List;

 import java.util.Map;

 import org.apache.archiva.rss.RssFeedEntry;

 import org.apache.archiva.rss.RssFeedGenerator;

 import org.apache.commons.lang.time.DateUtils;

 import org.apache.maven.archiva.database.ArchivaDatabaseException;

 import org.apache.maven.archiva.database.ArtifactDAO;

 import org.apache.maven.archiva.database.Constraint;

 import org.apache.maven.archiva.database.constraints.ArtifactsByRepositoryConstraint;

 import org.apache.maven.archiva.model.ArchivaArtifact;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 import com.sun.syndication.feed.synd.SyndFeed;

 /**

  * Retrieve and process all artifacts of a repository from the database and generate a rss feed.

  * The artifacts will be grouped by the date when the artifacts were gathered. 

  * Each group will appear as one entry in the feed.

  * 

  * @version

  * @plexus.component role="org.apache.archiva.rss.processor.RssFeedProcessor" role-hint="new-artifacts"

  */

 public class NewArtifactsRssFeedProcessor

     extends AbstractArtifactsRssFeedProcessor

 {

     private int numberOfDaysBeforeNow = 30;

     private static final String title = "New Artifacts in Repository ";

     private static final String desc = "These are the new artifacts found in the repository ";

     /**

      * @plexus.requirement

      */

     private RssFeedGenerator generator;

     private Logger log = LoggerFactory.getLogger( NewArtifactsRssFeedProcessor.class );

     /**

      * @plexus.requirement role-hint="jdo"

      */

     private ArtifactDAO artifactDAO;

     /**

      * Process the newly discovered artifacts in the repository. Generate feeds for new artifacts in the repository and

      * new versions of artifact.

      */

     public SyndFeed process( Map<String, String> reqParams ) throws ArchivaDatabaseException

     {

         log.debug( "Process new artifacts into rss feeds." );

         String repoId = reqParams.get( RssFeedProcessor.KEY_REPO_ID );

         if ( repoId != null )

         {

             return processNewArtifactsInRepo( repoId );

         }

         return null;

     }

     private SyndFeed processNewArtifactsInRepo( String repoId ) throws ArchivaDatabaseException

     {

         Calendar greaterThanThisDate = Calendar.getInstance( DateUtils.UTC_TIME_ZONE );

         greaterThanThisDate.add( Calendar.DATE, -( getNumberOfDaysBeforeNow() ) );

         Constraint artifactsByRepo = new ArtifactsByRepositoryConstraint( repoId, greaterThanThisDate.getTime(), "whenGathered", false );

         List<ArchivaArtifact> artifacts = artifactDAO.queryArtifacts( artifactsByRepo );

         List<RssFeedEntry> entries = processData( artifacts, true );

         return generator.generateFeed( getTitle() + "\'" + repoId + "\'", "New artifacts found in repository " +

             "\'" + repoId + "\'" + " during repository scan.", entries );

     }

     public String getTitle()

     {

         return title;

     }

     public String getDescription()

     {

         return desc;

     }

     public RssFeedGenerator getGenerator()

     {

         return generator;

     }

     public void setGenerator( RssFeedGenerator generator )

     {

         this.generator = generator;

     }

     public ArtifactDAO getArtifactDAO()

     {

         return artifactDAO;

     }

     public void setArtifactDAO( ArtifactDAO artifactDAO )

     {

         this.artifactDAO = artifactDAO;

     }

     public int getNumberOfDaysBeforeNow()

     {

         return numberOfDaysBeforeNow;

     }

     public void setNumberOfDaysBeforeNow( int numberOfDaysBeforeNow )

     {

         this.numberOfDaysBeforeNow = numberOfDaysBeforeNow;

     }

 }