James Moger
2013-06-24 f59874809d61baf25244756cb280beaeecc33e96
src/main/java/com/gitblit/utils/JGitUtils.java
@@ -19,12 +19,14 @@
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.text.DecimalFormat;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
@@ -33,6 +35,7 @@
import org.eclipse.jgit.api.CloneCommand;
import org.eclipse.jgit.api.FetchCommand;
import org.eclipse.jgit.api.Git;
import org.eclipse.jgit.api.TagCommand;
import org.eclipse.jgit.api.errors.GitAPIException;
import org.eclipse.jgit.diff.DiffEntry;
import org.eclipse.jgit.diff.DiffEntry.ChangeType;
@@ -64,7 +67,7 @@
import org.eclipse.jgit.revwalk.RevWalk;
import org.eclipse.jgit.revwalk.filter.CommitTimeRevFilter;
import org.eclipse.jgit.revwalk.filter.RevFilter;
import org.eclipse.jgit.storage.file.FileRepository;
import org.eclipse.jgit.storage.file.FileRepositoryBuilder;
import org.eclipse.jgit.transport.CredentialsProvider;
import org.eclipse.jgit.transport.FetchResult;
import org.eclipse.jgit.transport.RefSpec;
@@ -195,7 +198,7 @@
      File folder = new File(repositoriesFolder, name);
      if (folder.exists()) {
         File gitDir = FileKey.resolve(new File(repositoriesFolder, name), FS.DETECTED);
         FileRepository repository = new FileRepository(gitDir);
         Repository repository = new FileRepositoryBuilder().setGitDir(gitDir).build();
         result.fetchResult = fetchRepository(credentialsProvider, repository);
         repository.close();
      } else {
@@ -294,6 +297,7 @@
      list.addAll(getRepositoryList(repositoriesFolder.getAbsolutePath(), repositoriesFolder,
            onlyBare, searchSubfolders, depth, patterns));
      StringUtils.sortRepositorynames(list);
      list.remove(".git"); // issue-256
      return list;
   }
@@ -768,6 +772,51 @@
   }
   /**
    * Returns the list of files changed in a specified commit. If the
    * repository does not exist or is empty, an empty list is returned.
    *
    * @param repository
    * @param startCommit
    *            earliest commit
    * @param endCommit
    *            most recent commit. if null, HEAD is assumed.
    * @return list of files changed in a commit range
    */
   public static List<PathChangeModel> getFilesInRange(Repository repository, RevCommit startCommit, RevCommit endCommit) {
      List<PathChangeModel> list = new ArrayList<PathChangeModel>();
      if (!hasCommits(repository)) {
         return list;
      }
      try {
         DiffFormatter df = new DiffFormatter(null);
         df.setRepository(repository);
         df.setDiffComparator(RawTextComparator.DEFAULT);
         df.setDetectRenames(true);
         List<DiffEntry> diffEntries = df.scan(startCommit.getTree(), endCommit.getTree());
         for (DiffEntry diff : diffEntries) {
            if (diff.getChangeType().equals(ChangeType.DELETE)) {
               list.add(new PathChangeModel(diff.getOldPath(), diff.getOldPath(), 0, diff
                     .getNewMode().getBits(), diff.getOldId().name(), null, diff
                     .getChangeType()));
            } else if (diff.getChangeType().equals(ChangeType.RENAME)) {
               list.add(new PathChangeModel(diff.getOldPath(), diff.getNewPath(), 0, diff
                     .getNewMode().getBits(), diff.getNewId().name(), null, diff
                     .getChangeType()));
            } else {
               list.add(new PathChangeModel(diff.getNewPath(), diff.getNewPath(), 0, diff
                     .getNewMode().getBits(), diff.getNewId().name(), null, diff
                     .getChangeType()));
            }
         }
         Collections.sort(list);
      } catch (Throwable t) {
         error(t, repository, "{0} failed to determine files in range {1}..{2}!", startCommit, endCommit);
      }
      return list;
   }
   /**
    * Returns the list of files in the repository on the default branch that
    * match one of the specified extensions. This is a CASE-SENSITIVE search.
    * If the repository does not exist or is empty, an empty list is returned.
@@ -978,18 +1027,30 @@
      }
      try {
         // resolve branch
         ObjectId branchObject;
         ObjectId startRange = null;
         ObjectId endRange;
         if (StringUtils.isEmpty(objectId)) {
            branchObject = getDefaultBranch(repository);
            endRange = getDefaultBranch(repository);
         } else {
            branchObject = repository.resolve(objectId);
            if( objectId.contains("..") ) {
               // range expression
               String[] parts = objectId.split("\\.\\.");
               startRange = repository.resolve(parts[0]);
               endRange = repository.resolve(parts[1]);
            } else {
               // objectid
               endRange= repository.resolve(objectId);
            }
         }
         if (branchObject == null) {
         if (endRange == null) {
            return list;
         }
         RevWalk rw = new RevWalk(repository);
         rw.markStart(rw.parseCommit(branchObject));
         rw.markStart(rw.parseCommit(endRange));
         if (startRange != null) {
            rw.markUninteresting(rw.parseCommit(startRange));
         }
         if (!StringUtils.isEmpty(path)) {
            TreeFilter filter = AndTreeFilter.create(
                  PathFilterGroup.createFromStrings(Collections.singleton(path)),
@@ -1689,6 +1750,70 @@
   }
   /**
    * this method creates an incremental revision number as a tag according to
    * the amount of already existing tags, which start with a defined prefix.
    *
    * @param repository
    * @param objectId
    * @param tagger
    * @param prefix
    * @param intPattern
    * @param message
    * @return true if operation was successful, otherwise false
    */
   public static boolean createIncrementalRevisionTag(Repository repository,
         String objectId, PersonIdent tagger, String prefix, String intPattern, String message) {
      boolean result = false;
      Iterator<Entry<String, Ref>> iterator = repository.getTags().entrySet().iterator();
      long lastRev = 0;
      while (iterator.hasNext()) {
         Entry<String, Ref> entry = iterator.next();
         if (entry.getKey().startsWith(prefix)) {
            try {
               long val = Long.parseLong(entry.getKey().substring(prefix.length()));
               if (val > lastRev) {
                  lastRev = val;
               }
            } catch (Exception e) {
               // this tag is NOT an incremental revision tag
            }
         }
      }
      DecimalFormat df = new DecimalFormat(intPattern);
      result = createTag(repository, objectId, tagger, prefix + df.format((lastRev + 1)), message);
      return result;
   }
   /**
    * creates a tag in a repository
    *
    * @param repository
    * @param objectId, the ref the tag points towards
    * @param tagger, the person tagging the object
    * @param tag, the string label
    * @param message, the string message
    * @return boolean, true if operation was successful, otherwise false
    */
   public static boolean createTag(Repository repository, String objectId, PersonIdent tagger, String tag, String message) {
      try {
         Git gitClient = Git.open(repository.getDirectory());
         TagCommand tagCommand = gitClient.tag();
         tagCommand.setTagger(tagger);
         tagCommand.setMessage(message);
         if (objectId != null) {
            RevObject revObj = getCommit(repository, objectId);
            tagCommand.setObjectId(revObj);
         }
         tagCommand.setName(tag);
         Ref call = tagCommand.call();
         return call != null ? true : false;
      } catch (Exception e) {
         error(e, repository, "Failed to create tag {1} in repository {0}", objectId, tag);
      }
      return false;
   }
   /**
    * Create an orphaned branch in a repository.
    * 
    * @param repository