From e19d3da3cdb4e3d0524e3a3ffc6a2cfa8876e927 Mon Sep 17 00:00:00 2001 From: James Moger <james.moger@gitblit.com> Date: Wed, 16 Nov 2011 22:33:18 -0500 Subject: [PATCH] Metric object now implements comparable. Adjust gravatar css. --- src/com/gitblit/client/GitblitClient.java | 102 +++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 83 insertions(+), 19 deletions(-) diff --git a/src/com/gitblit/client/GitblitClient.java b/src/com/gitblit/client/GitblitClient.java index 2a08b85..c027537 100644 --- a/src/com/gitblit/client/GitblitClient.java +++ b/src/com/gitblit/client/GitblitClient.java @@ -25,19 +25,21 @@ import java.util.Map; import java.util.Set; +import com.gitblit.Constants; import com.gitblit.GitBlitException.ForbiddenException; import com.gitblit.GitBlitException.NotAllowedException; import com.gitblit.GitBlitException.UnauthorizedException; import com.gitblit.GitBlitException.UnknownRequestException; import com.gitblit.Keys; import com.gitblit.models.FederationModel; +import com.gitblit.models.FeedEntryModel; import com.gitblit.models.FeedModel; import com.gitblit.models.RepositoryModel; import com.gitblit.models.ServerSettings; import com.gitblit.models.ServerStatus; -import com.gitblit.models.SyndicatedEntryModel; import com.gitblit.models.UserModel; import com.gitblit.utils.RpcUtils; +import com.gitblit.utils.StringUtils; import com.gitblit.utils.SyndicationUtils; /** @@ -50,6 +52,8 @@ public class GitblitClient implements Serializable { private static final long serialVersionUID = 1L; + + private static final Date NEVER = new Date(0); protected final GitblitRegistration reg; @@ -73,7 +77,7 @@ private final List<FeedModel> availableFeeds; - private final List<SyndicatedEntryModel> syndicatedEntries; + private final List<FeedEntryModel> syndicatedEntries; private final Set<String> subscribedRepositories; @@ -89,26 +93,20 @@ this.allRepositories = new ArrayList<RepositoryModel>(); this.federationRegistrations = new ArrayList<FederationModel>(); this.availableFeeds = new ArrayList<FeedModel>(); - this.syndicatedEntries = new ArrayList<SyndicatedEntryModel>(); + this.syndicatedEntries = new ArrayList<FeedEntryModel>(); this.subscribedRepositories = new HashSet<String>(); } public void login() throws IOException { + refreshSettings(); refreshAvailableFeeds(); refreshRepositories(); - - try { - // RSS feeds may be disabled by server - refreshSubscribedFeeds(); - } catch (IOException e) { - e.printStackTrace(); - } + refreshSubscribedFeeds(0); try { // credentials may not have administrator access // or server may have disabled rpc management refreshUsers(); - refreshSettings(); allowManagement = true; } catch (UnauthorizedException e) { } catch (ForbiddenException e) { @@ -130,7 +128,6 @@ } catch (IOException e) { e.printStackTrace(); } - } public boolean allowManagement() { @@ -143,6 +140,33 @@ public boolean isOwner(RepositoryModel model) { return account != null && account.equalsIgnoreCase(model.owner); + } + + public String getURL(String action, String repository, String objectId) { + boolean mounted = settings.get(Keys.web.mountParameters).getBoolean(true); + StringBuilder sb = new StringBuilder(); + sb.append(url); + sb.append('/'); + sb.append(action); + sb.append('/'); + if (mounted) { + // mounted url/action/repository/objectId + sb.append(StringUtils.encodeURL(repository)); + if (!StringUtils.isEmpty(objectId)) { + sb.append('/'); + sb.append(objectId); + } + return sb.toString(); + } else { + // parameterized url/action/&r=repository&h=objectId + sb.append("?r="); + sb.append(repository); + if (!StringUtils.isEmpty(objectId)) { + sb.append("&h="); + sb.append(objectId); + } + return sb.toString(); + } } public ServerSettings getSettings() { @@ -184,17 +208,31 @@ return status; } + public List<String> getBranches(String repository) { + List<FeedModel> feeds = getAvailableFeeds(repository); + List<String> branches = new ArrayList<String>(); + for (FeedModel feed : feeds) { + branches.add(feed.branch); + } + Collections.sort(branches); + return branches; + } + public List<FeedModel> getAvailableFeeds() { return availableFeeds; } public List<FeedModel> getAvailableFeeds(RepositoryModel repository) { + return getAvailableFeeds(repository.name); + } + + public List<FeedModel> getAvailableFeeds(String repository) { List<FeedModel> repositoryFeeds = new ArrayList<FeedModel>(); if (repository == null) { return repositoryFeeds; } for (FeedModel feed : availableFeeds) { - if (feed.repository.equalsIgnoreCase(repository.name)) { + if (feed.repository.equalsIgnoreCase(repository)) { repositoryFeeds.add(feed); } } @@ -209,16 +247,18 @@ return availableFeeds; } - public List<SyndicatedEntryModel> refreshSubscribedFeeds() throws IOException { - Set<SyndicatedEntryModel> allEntries = new HashSet<SyndicatedEntryModel>(); + public List<FeedEntryModel> refreshSubscribedFeeds(int page) throws IOException { + Set<FeedEntryModel> allEntries = new HashSet<FeedEntryModel>(); if (reg.feeds.size() > 0) { for (FeedModel feed : reg.feeds) { - feed.lastRefresh = new Date(); - List<SyndicatedEntryModel> entries = SyndicationUtils.readFeed(url, - feed.repository, feed.branch, -1, account, password); + feed.lastRefreshDate = feed.currentRefreshDate; + feed.currentRefreshDate = new Date(); + List<FeedEntryModel> entries = SyndicationUtils.readFeed(url, + feed.repository, feed.branch, -1, page, account, password); allEntries.addAll(entries); } } + reg.cacheFeeds(); syndicatedEntries.clear(); syndicatedEntries.addAll(allEntries); Collections.sort(syndicatedEntries); @@ -241,14 +281,38 @@ } } + public Date getLastFeedRefresh(String repository, String branch) { + FeedModel feed = new FeedModel(); + feed.repository = repository; + feed.branch = branch; + if (reg.feeds.contains(feed)) { + int idx = reg.feeds.indexOf(feed); + feed = reg.feeds.get(idx); + return feed.lastRefreshDate; + } + return NEVER; + } + public boolean isSubscribed(RepositoryModel repository) { return subscribedRepositories.contains(repository.name.toLowerCase()); } - public List<SyndicatedEntryModel> getSyndicatedEntries() { + public List<FeedEntryModel> getSyndicatedEntries() { return syndicatedEntries; } + public List<FeedEntryModel> log(String repository, String branch, int numberOfEntries, + int page) throws IOException { + return SyndicationUtils.readFeed(url, repository, branch, numberOfEntries, page, account, + password); + } + + public List<FeedEntryModel> search(String repository, String branch, String fragment, + Constants.SearchType type, int numberOfEntries, int page) throws IOException { + return SyndicationUtils.readSearchFeed(url, repository, branch, fragment, type, + numberOfEntries, page, account, password); + } + public List<FederationModel> refreshFederationRegistrations() throws IOException { List<FederationModel> list = RpcUtils.getFederationRegistrations(url, account, password); federationRegistrations.clear(); -- Gitblit v1.9.1