Show busy cursors when executing workers

James Moger

2011-11-10 c7a721aad7c23640d59ad682854e066f4538436c

 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();