import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Map<String, VerificationInfo> apply(RevisionResource rsrc)
    throws IOException, OrmException {
  Map<String, VerificationInfo> out = Maps.newHashMap();
  try (CiDb db = schemaFactory.open()) {
    for (PatchSetVerification v : db.patchSetVerifications()
        .byPatchSet(rsrc.getPatchSet().getId())) {
      VerificationInfo info = new VerificationInfo();
      info.value = v.getValue();
      info.url = v.getUrl();
      info.verifier = v.getVerifier();
      info.comment = v.getComment();
      out.put(v.getLabelId().get(), info);
    }
  }
  return out;
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Response<?> apply(RevisionResource revision, VerifyInput input)
    throws AuthException, BadRequestException, UnprocessableEntityException,
    OrmException, IOException {
  if (input.verifications == null) {
    throw new BadRequestException("Missing verifications field");
  }

  try (CiDb db = schemaFactory.open()) {
    // Only needed for Google Megastore (that we don't use yet)
    db.patchSetVerifications().beginTransaction(null);
    boolean dirty = false;
    try {
      dirty |= updateLabels(revision, db, input.verifications);
      if (dirty) {
        db.commit();
      }
    } finally {
      db.rollback();
    }
  }
  return Response.none();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
protected final void run() throws UnloggedFailure {
  try {
    RevisionResource revision =
        revisions.parse(
            changes.parse(TopLevelResource.INSTANCE, IdString.fromUrl(changeId)),
            IdString.fromUrl("current"));
    if (useStdin) {
      ByteBuffer buf = IO.readWholeStream(in, 4096);
      input.rule = RawParseUtils.decode(buf.array(), buf.arrayOffset(), buf.limit());
    }
    Object result = createView().apply(revision, input);
    OutputFormat.JSON.newGson().toJson(result, stdout);
    stdout.print('\n');
  } catch (Exception e) {
    throw die("Processing of prolog script failed: " + e);
  }
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Test
public void commentBeforeFirstPatchSet() throws Exception {
  PushOneCommit.Result r = createChange();
  PatchSet.Id psId = r.getPatchSetId();
  Change.Id id = psId.getParentKey();

  Change c = db.changes().get(id);
  c.setCreatedOn(new Timestamp(c.getCreatedOn().getTime() - 5000));
  db.changes().update(Collections.singleton(c));
  indexer.index(db, project, id);

  ReviewInput rin = new ReviewInput();
  rin.message = "comment";

  Timestamp ts = new Timestamp(c.getCreatedOn().getTime() + 2000);
  assertThat(ts).isGreaterThan(c.getCreatedOn());
  assertThat(ts).isLessThan(db.patchSets().get(psId).getCreatedOn());
  RevisionResource revRsrc = parseCurrentRevisionResource(r.getChangeId());
  postReview.get().apply(batchUpdateFactory, revRsrc, rin, ts);

  checker.rebuildAndCheckChanges(id);
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Test
public void commentPredatingChangeBySomeoneOtherThanOwner() throws Exception {
  PushOneCommit.Result r = createChange();
  PatchSet.Id psId = r.getPatchSetId();
  Change.Id id = psId.getParentKey();
  Change c = db.changes().get(id);

  ReviewInput rin = new ReviewInput();
  rin.message = "comment";

  Timestamp ts = new Timestamp(c.getCreatedOn().getTime() - 10000);
  RevisionResource revRsrc = parseCurrentRevisionResource(r.getChangeId());
  setApiUser(user);
  postReview.get().apply(batchUpdateFactory, revRsrc, rin, ts);

  checker.rebuildAndCheckChanges(id);
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public String apply(RevisionResource rrsc) throws AuthException, BadRequestException, ResourceConflictException,
Exception {
  PatchSetCreatedEvent event = new PatchSetCreatedEvent();

  ChangeAttribute change = eventFactory.asChangeAttribute(rrsc.getChange());
  PatchSetAttribute patchSet = eventFactory.asPatchSetAttribute(rrsc.getPatchSet());
  AccountAttribute uploader = eventFactory.asAccountAttribute(reviewDb.accounts().get(rrsc.getPatchSet().getUploader()));

  event.change = change;
  event.patchSet = patchSet;
  event.uploader = uploader;

  changeHooks.postEvent(rrsc.getChange(), event, reviewDb);

  return "Triggered.";
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
private void applyVerification(PatchSet patchSet, VerifyInput verify)
    throws RestApiException, NoSuchChangeException, OrmException,
    IOException {
  ChangeControl ctl =
      genericFactory.validateFor(db, patchSet.getId().getParentKey(),
          currentUser);
  ChangeResource changeResource = new ChangeResource(ctl);
  RevisionResource revResource = new RevisionResource(changeResource,
      patchSet);
  postVerification.apply(revResource, verify);
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
private Map<String, PatchSetVerification> scanLabels(
    RevisionResource resource, CiDb db)
    throws OrmException {
  Map<String, PatchSetVerification> current = Maps.newHashMap();
  for (PatchSetVerification v : db.patchSetVerifications()
      .byPatchSet(resource.getPatchSet().getId())) {
    current.put(v.getLabelId().get(), v);
  }
  return current;
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
public static List<String> getGroups(RevisionResource rsrc) {
  if (rsrc.getEdit().isPresent()) {
    // Groups for an edit are just the base revision's groups, since they have
    // the same parent.
    return rsrc.getEdit().get().getBasePatchSet().getGroups();
  }
  return rsrc.getPatchSet().getGroups();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
protected void assertSubmittable(String changeId) throws Exception {
  assertThat(get(changeId, SUBMITTABLE).submittable)
      .named("submit bit on ChangeInfo")
      .isEqualTo(true);
  RevisionResource rsrc = parseCurrentRevisionResource(changeId);
  UiAction.Description desc = submitHandler.getDescription(rsrc);
  assertThat(desc.isVisible()).named("visible bit on submit action").isTrue();
  assertThat(desc.isEnabled()).named("enabled bit on submit action").isTrue();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Test
public void insertCommentsWithHistoricTimestamp() throws Exception {
  Timestamp timestamp = new Timestamp(0);
  for (Integer line : lines) {
    String file = "file";
    String contents = "contents " + line;
    PushOneCommit push =
        pushFactory.create(db, admin.getIdent(), testRepo, "first subject", file, contents);
    PushOneCommit.Result r = push.to("refs/for/master");
    String changeId = r.getChangeId();
    String revId = r.getCommit().getName();
    Timestamp origLastUpdated = r.getChange().change().getLastUpdatedOn();

    ReviewInput input = new ReviewInput();
    CommentInput comment = newComment(file, Side.REVISION, line, "comment 1", false);
    comment.updated = timestamp;
    input.comments = new HashMap<>();
    input.comments.put(comment.path, Lists.newArrayList(comment));
    ChangeResource changeRsrc =
        changes.get().parse(TopLevelResource.INSTANCE, IdString.fromDecoded(changeId));
    RevisionResource revRsrc = revisions.parse(changeRsrc, IdString.fromDecoded(revId));
    postReview.get().apply(batchUpdateFactory, revRsrc, input, timestamp);
    Map<String, List<CommentInfo>> result = getPublishedComments(changeId, revId);
    assertThat(result).isNotEmpty();
    CommentInfo actual = Iterables.getOnlyElement(result.get(comment.path));
    CommentInput ci = infoToInput(file).apply(actual);
    ci.updated = comment.updated;
    assertThat(comment).isEqualTo(ci);
    assertThat(actual.updated).isEqualTo(gApi.changes().id(r.getChangeId()).info().created);

    // Updating historic comments doesn't cause lastUpdatedOn to regress.
    assertThat(r.getChange().change().getLastUpdatedOn()).isEqualTo(origLastUpdated);
  }
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Void apply(RevisionResource revision, PatchCoverageInput input)
        throws AuthException, BadRequestException, ResourceConflictException,
        UnprocessableEntityException, OrmException, IOException {
    coverageDb.registerCoverage(revision, input);
    return null;
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Object apply(RevisionResource rsrc, Input input)
    throws ResourceConflictException, OrmException {
  Change change = rsrc.getChange();
  if (change.getStatus() != Status.WORKINPROGRESS) {
    throw new ResourceConflictException("change is " + status(change));
  }

  if (!change.currentPatchSetId().equals(rsrc.getPatchSet().getId())) {
    throw new ResourceConflictException("not current patch set");
  }

  changeStatus(change, input, Status.WORKINPROGRESS, Status.NEW);
  return Response.none();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Description getDescription(RevisionResource rsrc) {
  PatchSet.Id current = rsrc.getChange().currentPatchSetId();
  return new Description()
      .setLabel("Ready")
      .setTitle("Set Ready For Review")
      .setVisible(rsrc.getChange().getStatus() == Status.WORKINPROGRESS
         && rsrc.getPatchSet().getId().equals(current));
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
private void mark(PatchSet patchSet) throws NoSuchChangeException,
    ResourceConflictException, OrmException {
  RevisionResource rsrc = new RevisionResource(
      new ChangeResource(changeControlFactory
          .controlFor(patchSet.getId().getParentKey())), patchSet);
  BaseAction.Input input = new BaseAction.Input();
  input.message = changeComment;
  if (wipChange) {
    wipProvider.get().apply(rsrc, input);
  } else {
    readyProvider.get().apply(rsrc, input);
  }
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Object apply(RevisionResource rsrc, Input input)
    throws ResourceConflictException, OrmException {
  Change change = rsrc.getChange();
  if (change.getStatus() != Status.NEW) {
    throw new ResourceConflictException("change is " + status(change));
  }

  if (!change.currentPatchSetId().equals(rsrc.getPatchSet().getId())) {
    throw new ResourceConflictException("not current patch set");
  }

  changeStatus(change, input, Status.NEW, Status.WORKINPROGRESS);
  return Response.none();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
@Override
public Description getDescription(RevisionResource rsrc) {
  PatchSet.Id current = rsrc.getChange().currentPatchSetId();
  return new Description()
      .setLabel("WIP")
      .setTitle("Set Work In Progress")
      .setVisible(rsrc.getChange().getStatus() == Status.NEW
         && rsrc.getPatchSet().getId().equals(current));
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
private boolean updateLabels(RevisionResource resource, CiDb db,
    Map<String, VerificationInfo> jobs)
    throws OrmException, BadRequestException {
  Preconditions.checkNotNull(jobs);

  List<PatchSetVerification> ups = Lists.newArrayList();
  Map<String, PatchSetVerification> current = scanLabels(resource, db);

  Timestamp ts = TimeUtil.nowTs();
  for (Map.Entry<String, VerificationInfo> ent : jobs.entrySet()) {
    String name = ent.getKey();
    PatchSetVerification c = current.remove(name);
    Short value = ent.getValue().value;
    if (value == null) {
      throw new BadRequestException("Missing value field");
    }
    if (c != null) {
      c.setGranted(ts);
      c.setValue(value);
      String url = ent.getValue().url;
      if (url != null) {
        c.setUrl(url);
      }
      String verifier = ent.getValue().verifier;
      if (verifier != null) {
        c.setVerifier(verifier);
      }
      String comment = ent.getValue().comment;
      if (comment != null) {
        c.setComment(comment);
      }
      log.info("Updating job " + c.getLabel() + " for change "
          + c.getPatchSetId());
      ups.add(c);
    } else {
      c = new PatchSetVerification(new PatchSetVerification.Key(
              resource.getPatchSet().getId(),
              new LabelId(name)),
          value, TimeUtil.nowTs());
      c.setGranted(ts);
      c.setUrl(ent.getValue().url);
      c.setVerifier(ent.getValue().verifier);
      c.setComment(ent.getValue().comment);
      log.info("Adding job " + c.getLabel() + " for change "
          + c.getPatchSetId());
      ups.add(c);
    }
  }

  db.patchSetVerifications().upsert(ups);
  return !ups.isEmpty();
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
protected RevisionResource parseCurrentRevisionResource(String changeId) throws Exception {
  ChangeResource cr = parseChangeResource(changeId);
  int psId = cr.getChange().currentPatchSetId().get();
  return revisions.parse(cr, IdString.fromDecoded(Integer.toString(psId)));
}
 

import com.google.gerrit.server.change.RevisionResource; //导入依赖的package包/类
protected RevisionResource parseRevisionResource(String changeId, int n) throws Exception {
  return revisions.parse(
      parseChangeResource(changeId), IdString.fromDecoded(Integer.toString(n)));
}