SetReviewersCommand: Factor code out to ChangeArgumentParser

Factor code to parse changes from the argument list out to a new
utility class.

Change-Id: I277981f3128d9f958eda2e8ebc7d5d2ca988d18c
This commit is contained in:
David Pursehouse
2016-05-25 21:45:23 +09:00
parent b44d1f526a
commit e643ae86b3
2 changed files with 88 additions and 49 deletions

View File

@@ -0,0 +1,85 @@
// Copyright (C) 2016 The Android Open Source Project
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package com.google.gerrit.sshd;
import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeFinder;
import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.change.ChangesCollection;
import com.google.gerrit.server.project.ChangeControl;
import com.google.gerrit.server.project.ProjectControl;
import com.google.gerrit.sshd.BaseCommand.UnloggedFailure;
import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
public class ChangeArgumentParser {
private final CurrentUser currentUser;
private final ChangesCollection changesCollection;
private final ChangeFinder changeFinder;
private final ReviewDb db;
@Inject
ChangeArgumentParser(CurrentUser currentUser,
ChangesCollection changesCollection,
ChangeFinder changeFinder,
ReviewDb db) {
this.currentUser = currentUser;
this.changesCollection = changesCollection;
this.changeFinder = changeFinder;
this.db = db;
}
public void addChange(String id, Map<Change.Id, ChangeResource> changes)
throws UnloggedFailure, OrmException {
addChange(id, changes, null);
}
public void addChange(String id, Map<Change.Id, ChangeResource> changes,
ProjectControl projectControl) throws UnloggedFailure, OrmException {
List<ChangeControl> matched = changeFinder.find(id, currentUser);
List<ChangeControl> toAdd = new ArrayList<>(changes.size());
for (ChangeControl ctl : matched) {
if (!changes.containsKey(ctl.getId())
&& inProject(projectControl, ctl.getProject())
&& ctl.isVisible(db)) {
toAdd.add(ctl);
}
}
if (toAdd.isEmpty()) {
throw new UnloggedFailure(1, "\"" + id + "\" no such change");
} else if (toAdd.size() > 1) {
throw new UnloggedFailure(1, "\"" + id + "\" matches multiple changes");
}
ChangeControl ctl = toAdd.get(0);
changes.put(ctl.getId(), changesCollection.parse(ctl));
}
private boolean inProject(ProjectControl projectControl, Project project) {
if (projectControl != null) {
return projectControl.getProject().getNameKey().equals(project.getNameKey());
} else {
// No --project option, so they want every project.
return true;
}
}
}

View File

@@ -18,17 +18,12 @@ import com.google.gerrit.extensions.api.changes.AddReviewerInput;
import com.google.gerrit.extensions.restapi.ResourceNotFoundException;
import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeFinder;
import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.change.ChangesCollection;
import com.google.gerrit.server.change.DeleteReviewer;
import com.google.gerrit.server.change.PostReviewers;
import com.google.gerrit.server.change.ReviewerResource;
import com.google.gerrit.server.project.ChangeControl;
import com.google.gerrit.server.project.ProjectControl;
import com.google.gerrit.sshd.ChangeArgumentParser;
import com.google.gerrit.sshd.CommandMetaData;
import com.google.gerrit.sshd.SshCommand;
import com.google.gwtorm.server.OrmException;
@@ -65,7 +60,7 @@ public class SetReviewersCommand extends SshCommand {
@Argument(index = 0, required = true, multiValued = true, metaVar = "CHANGE", usage = "changes to modify")
void addChange(String token) {
try {
addChangeImpl(token);
changeArgumentParser.addChange(token, changes, projectControl);
} catch (UnloggedFailure e) {
throw new IllegalArgumentException(e.getMessage(), e);
} catch (OrmException e) {
@@ -73,9 +68,6 @@ public class SetReviewersCommand extends SshCommand {
}
}
@Inject
private ReviewDb db;
@Inject
private ReviewerResource.Factory reviewerFactory;
@@ -86,13 +78,7 @@ public class SetReviewersCommand extends SshCommand {
private DeleteReviewer deleteReviewer;
@Inject
private CurrentUser currentUser;
@Inject
private ChangesCollection changesCollection;
@Inject
private ChangeFinder changeFinder;
private ChangeArgumentParser changeArgumentParser;
private Set<Account.Id> toRemove = new HashSet<>();
@@ -158,36 +144,4 @@ public class SetReviewersCommand extends SshCommand {
return ok;
}
private void addChangeImpl(String id) throws UnloggedFailure, OrmException {
List<ChangeControl> matched = changeFinder.find(id, currentUser);
List<ChangeControl> toAdd = new ArrayList<>(changes.size());
for (ChangeControl ctl : matched) {
if (!changes.containsKey(ctl.getId()) && inProject(ctl.getProject())
&& ctl.isVisible(db)) {
toAdd.add(ctl);
}
}
switch (toAdd.size()) {
case 0:
throw die("\"" + id + "\" no such change");
case 1:
ChangeControl ctl = toAdd.get(0);
changes.put(ctl.getId(), changesCollection.parse(ctl));
break;
default:
throw die("\"" + id + "\" matches multiple changes");
}
}
private boolean inProject(Project project) {
if (projectControl != null) {
return projectControl.getProject().getNameKey().equals(project.getNameKey());
} else {
// No --project option, so they want every project.
return true;
}
}
}