From a502d96a860456ec5e8c96761db70f7cabb74751 Mon Sep 17 00:00:00 2001 From: Paul Martin <paul@paulsputer.com> Date: Sat, 30 Apr 2016 04:19:14 -0400 Subject: [PATCH] Merge pull request #1073 from gitblit/1062-DocEditorUpdates --- src/main/java/com/gitblit/git/PatchsetReceivePack.java | 135 +++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 125 insertions(+), 10 deletions(-) diff --git a/src/main/java/com/gitblit/git/PatchsetReceivePack.java b/src/main/java/com/gitblit/git/PatchsetReceivePack.java index 77d5a71..ef0b409 100644 --- a/src/main/java/com/gitblit/git/PatchsetReceivePack.java +++ b/src/main/java/com/gitblit/git/PatchsetReceivePack.java @@ -73,6 +73,7 @@ import com.gitblit.utils.JGitUtils.MergeStatus; import com.gitblit.utils.RefLogUtils; import com.gitblit.utils.StringUtils; +import com.google.common.collect.Lists; /** @@ -148,6 +149,11 @@ defaultBranch = getRepository().getBranch(); } catch (Exception e) { LOGGER.error("failed to determine default branch for " + repository.name, e); + } + + if (!StringUtils.isEmpty(getRepositoryModel().mergeTo)) { + // repository settings specifies a default integration branch + defaultBranch = Repository.shortenRefName(getRepositoryModel().mergeTo); } long ticketId = 0L; @@ -309,6 +315,7 @@ } if (isPatchsetRef(cmd.getRefName()) && processPatchsets) { + if (ticketService == null) { sendRejection(cmd, "Sorry, the ticket service is unavailable and can not accept patchsets at this time."); continue; @@ -343,6 +350,20 @@ LOGGER.error("{} already has refs in the {} namespace", repository.name, Constants.R_FOR); sendRejection(cmd, "Sorry, a repository administrator will have to remove the {} namespace", Constants.R_FOR); + continue; + } + + if (cmd.getNewId().equals(ObjectId.zeroId())) { + // ref deletion request + if (cmd.getRefName().startsWith(Constants.R_TICKET)) { + if (user.canDeleteRef(repository)) { + batch.addCommand(cmd); + } else { + sendRejection(cmd, "Sorry, you do not have permission to delete {}", cmd.getRefName()); + } + } else { + sendRejection(cmd, "Sorry, you can not delete {}", cmd.getRefName()); + } continue; } @@ -521,8 +542,10 @@ break; } } - sendError("Sorry, {0} already merged {1} from ticket {2,number,0} to {3}!", + if (mergeChange != null) { + sendError("Sorry, {0} already merged {1} from ticket {2,number,0} to {3}!", mergeChange.author, mergeChange.patchset, number, ticket.mergeTo); + } sendRejection(cmd, "Ticket {0,number,0} already resolved", number); return null; } else if (!StringUtils.isEmpty(ticket.mergeTo)) { @@ -604,14 +627,102 @@ if (patchset.commits > 1) { sendError(""); - sendError("To create a proposal ticket, please squash your commits and"); - sendError("provide a meaningful commit message with a short title &"); - sendError("an optional description/body."); + sendError("You may not create a ''{0}'' branch proposal ticket from {1} commits!", + forBranch, patchset.commits); sendError(""); - sendError(minTitle); - sendError(maxTitle); + // display an ellipsized log of the commits being pushed + RevWalk walk = getRevWalk(); + walk.reset(); + walk.sort(RevSort.TOPO); + int boundary = 3; + int count = 0; + try { + walk.markStart(tipCommit); + walk.markUninteresting(mergeBase); + + for (;;) { + + RevCommit c = walk.next(); + if (c == null) { + break; + } + + if (count < boundary || count >= (patchset.commits - boundary)) { + + walk.parseBody(c); + sendError(" {0} {1}", c.getName().substring(0, shortCommitIdLen), + StringUtils.trimString(c.getShortMessage(), 60)); + + } else if (count == boundary) { + + sendError(" ... more commits ..."); + + } + + count++; + } + + } catch (IOException e) { + // Should never happen, the core receive process would have + // identified the missing object earlier before we got control. + LOGGER.error("failed to get commit count", e); + } finally { + walk.close(); + } + sendError(""); - sendRejection(cmd, "please squash to one commit"); + sendError("Possible Solutions:"); + sendError(""); + int solution = 1; + String forSpec = cmd.getRefName().substring(Constants.R_FOR.length()); + if (forSpec.equals("default") || forSpec.equals("new")) { + try { + // determine other possible integration targets + List<String> bases = Lists.newArrayList(); + for (Ref ref : getRepository().getRefDatabase().getRefs(Constants.R_HEADS).values()) { + if (!ref.getName().startsWith(Constants.R_TICKET) + && !ref.getName().equals(forBranchRef.getName())) { + if (JGitUtils.isMergedInto(getRepository(), ref.getObjectId(), tipCommit)) { + bases.add(Repository.shortenRefName(ref.getName())); + } + } + } + + if (!bases.isEmpty()) { + + if (bases.size() == 1) { + // suggest possible integration targets + String base = bases.get(0); + sendError("{0}. Propose this change for the ''{1}'' branch.", solution++, base); + sendError(""); + sendError(" git push origin HEAD:refs/for/{0}", base); + sendError(" pt propose {0}", base); + sendError(""); + } else { + // suggest possible integration targets + sendError("{0}. Propose this change for a different branch.", solution++); + sendError(""); + for (String base : bases) { + sendError(" git push origin HEAD:refs/for/{0}", base); + sendError(" pt propose {0}", base); + sendError(""); + } + } + + } + } catch (IOException e) { + LOGGER.error(null, e); + } + } + sendError("{0}. Squash your changes into a single commit with a meaningful message.", solution++); + sendError(""); + sendError("{0}. Open a ticket for your changes and then push your {1} commits to the ticket.", + solution++, patchset.commits); + sendError(""); + sendError(" git push origin HEAD:refs/for/{id}"); + sendError(" pt propose {id}"); + sendError(""); + sendRejection(cmd, "too many commits"); return null; } @@ -967,7 +1078,7 @@ LOGGER.error("failed to get commit count", e); return 0; } finally { - walk.release(); + walk.close(); } return count; } @@ -1185,11 +1296,15 @@ if (ticket != null) { ticketNotifier.queueMailing(ticket); - // update the reflog with the merge if (oldRef != null) { ReceiveCommand cmd = new ReceiveCommand(oldRef.getObjectId(), ObjectId.fromString(mergeResult.sha), oldRef.getName()); - RefLogUtils.updateRefLog(user, getRepository(), Arrays.asList(cmd)); + cmd.setResult(Result.OK); + List<ReceiveCommand> commands = Arrays.asList(cmd); + + logRefChange(commands); + updateIncrementalPushTags(commands); + updateGitblitRefLog(commands); } // call patchset hooks -- Gitblit v1.9.1