James Moger
2011-10-28 c75304637f5535e634e57d4ed933c0fdb594d890
src/com/gitblit/utils/SyndicationUtils.java
@@ -16,40 +16,71 @@
package com.gitblit.utils;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.URLConnection;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.List;
import org.eclipse.jgit.revwalk.RevCommit;
import com.gitblit.Constants;
import com.sun.syndication.feed.synd.SyndContent;
import com.sun.syndication.feed.synd.SyndContentImpl;
import com.sun.syndication.feed.synd.SyndEntry;
import com.sun.syndication.feed.synd.SyndEntryImpl;
import com.sun.syndication.feed.synd.SyndFeed;
import com.sun.syndication.feed.synd.SyndFeedImpl;
import com.sun.syndication.feed.synd.SyndImageImpl;
import com.sun.syndication.io.FeedException;
import com.sun.syndication.io.SyndFeedInput;
import com.sun.syndication.io.SyndFeedOutput;
import com.sun.syndication.io.XmlReader;
/**
 * Utility class for RSS feeds.
 *
 * @author James Moger
 *
 */
public class SyndicationUtils {
   public static void toRSS(String hostUrl, String title, String description, String repository, List<RevCommit> commits, OutputStream os)
         throws IOException, FeedException {
   /**
    * Outputs an RSS feed of the list of commits to the outputstream.
    *
    * @param hostUrl
    * @param title
    * @param description
    * @param repository
    * @param commits
    * @param os
    * @throws IOException
    * @throws FeedException
    */
   public static void toRSS(String hostUrl, String title, String description, String repository,
         List<RevCommit> commits, OutputStream os) throws IOException, FeedException {
      SyndFeed feed = new SyndFeedImpl();
      feed.setFeedType("rss_1.0");
      feed.setFeedType("rss_2.0");
      feed.setTitle(title);
      feed.setLink(MessageFormat.format("{0}/summary/{1}", hostUrl, repository));
      feed.setLink(MessageFormat.format("{0}/summary/{1}", hostUrl,
            StringUtils.encodeURL(repository)));
      feed.setDescription(description);
      SyndImageImpl image = new SyndImageImpl();
      image.setTitle(Constants.NAME);
      image.setUrl(hostUrl + "/gitblt_25.png");
      image.setLink(hostUrl);
      feed.setImage(image);
      List<SyndEntry> entries = new ArrayList<SyndEntry>();
      for (RevCommit commit : commits) {
         SyndEntry entry = new SyndEntryImpl();
         entry.setTitle(commit.getShortMessage());
         entry.setAuthor(commit.getAuthorIdent().getName());
         entry.setLink(MessageFormat.format("{0}/commit/{1}/{2}", hostUrl, repository, commit.getName()));
         entry.setLink(MessageFormat.format("{0}/commit/{1}/{2}", hostUrl,
               StringUtils.encodeURL(repository), commit.getName()));
         entry.setPublishedDate(commit.getCommitterIdent().getWhen());
         SyndContent content = new SyndContentImpl();
@@ -66,4 +97,53 @@
      output.output(feed, writer);
      writer.close();
   }
   /**
    * Reads a Gitblit RSS feed.
    *
    * @param url
    *            the url of the Gitblit server
    * @param repository
    *            the repository name
    * @param branch
    *            the branch name (optional)
    * @param numberOfEntries
    *            the number of entries to retrieve. if <= 0 the server default
    *            is used.
    * @param username
    * @param password
    * @return the JSON message as a string
    * @throws {@link IOException}
    */
   public static SyndFeed readFeed(String url, String repository, String branch,
         int numberOfEntries, String username, char[] password) throws IOException,
         FeedException {
      String feedUrl;
      if (StringUtils.isEmpty(branch)) {
         // no branch specified
         if (numberOfEntries > 0) {
            // fixed number of entries
            feedUrl = MessageFormat.format("{0}/feed/{1}?l={2,number,0}", url, repository);
         } else {
            // server default number of entries
            feedUrl = MessageFormat.format("{0}/feed/{1}", url, repository);
         }
      } else {
         // branch specified
         if (numberOfEntries > 0) {
            // fixed number of entries
            feedUrl = MessageFormat.format("{0}/feed/{1}?h={2}&l={3,number,0}", url,
                  repository, branch, numberOfEntries);
         } else {
            // server default number of entries
            feedUrl = MessageFormat.format("{0}/feed/{1}?h={2}", url, repository, branch);
         }
      }
      URLConnection conn = ConnectionUtils.openReadConnection(feedUrl, username, password);
      InputStream is = conn.getInputStream();
      SyndFeedInput input = new SyndFeedInput();
      SyndFeed feed = input.build(new XmlReader(is));
      is.close();
      return feed;
   }
}