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.ArrayList;
  23 import java.util.Date;
  24 import java.util.List;
  25 import java.util.Map;
  26
  27 import org.apache.archiva.rss.RssFeedEntry;
  28 import org.apache.maven.archiva.model.ArchivaArtifact;
  29
  30 import com.sun.syndication.feed.synd.SyndFeed;
  31
  32 /**
  33  * @author <a href="mailto:oching@apache.org">Maria Odea Ching</a>
  34  * @version
  35  */
  36 public abstract class AbstractArtifactsRssFeedProcessor
  37     implements RssFeedProcessor
  38 {
  39     public abstract SyndFeed process( Map<String, String> reqParams );
  40
  41     protected List<RssFeedEntry> processData( List<ArchivaArtifact> artifacts, boolean isRepoLevel )
  42     {
  43         long tmp = 0;
  44         RssFeedEntry entry = null;
  45         List<RssFeedEntry> entries = new ArrayList<RssFeedEntry>();
  46         String description = "";
  47         int idx = 0;
  48         for ( ArchivaArtifact artifact : artifacts )
  49         {
  50             long whenGathered = artifact.getModel().getWhenGathered().getTime();
  51
  52             if ( tmp != whenGathered )
  53             {
  54                 if ( entry != null )
  55                 {
  56                     entry.setDescription( description );
  57                     entries.add( entry );
  58                     entry = null;
  59                 }
  60
  61                 if ( !isRepoLevel )
  62                 {
  63                     entry =
  64                         new RssFeedEntry( getTitle() + "\'" + artifact.getGroupId() + ":" + artifact.getArtifactId() +
  65                             "\'" + " as of " + new Date( whenGathered ) );
  66                     entry.setPublishedDate( artifact.getModel().getWhenGathered() );
  67                     description = getDescription() + "\'" + artifact.getGroupId() + ":" + artifact.getArtifactId() +
  68                         "\'" + ": \n" + artifact.toString() + " | ";
  69                 }
  70                 else
  71                 {
  72                     String repoId = artifact.getModel().getRepositoryId();
  73                     entry = new RssFeedEntry( getTitle() + "\'" + repoId + "\'" + " as of " + new Date( whenGathered ) );
  74                     entry.setPublishedDate( artifact.getModel().getWhenGathered() );
  75                     description = getDescription() + "\'" + repoId + "\'" + ": \n" + artifact.toString() + " | ";
  76                 }
  77             }
  78             else
  79             {
  80                 description = description + artifact.toString() + " | ";
  81             }
  82
  83             if ( idx == ( artifacts.size() - 1 ) )
  84             {
  85                 entry.setDescription( description );
  86                 entries.add( entry );
  87             }
  88
  89             tmp = whenGathered;
  90             idx++;
  91         }
  92
  93         return entries;
  94     }
  95
  96     protected abstract String getTitle();
  97
  98     protected abstract String getDescription();
  99
 100 }