Remove ReviewDb argument from BatchUpdate.Factory

Change-Id: I76ab694f67d3fa56ffa0b32b9f8dfaf061dbe62d
This commit is contained in:
Dave Borowitz
2018-12-14 14:42:29 -08:00
parent 2b4ffdaf8f
commit 495e5c7b36
46 changed files with 54 additions and 239 deletions

View File

@@ -22,7 +22,6 @@ import com.google.gerrit.extensions.restapi.ResourceConflictException;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Account; import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.account.AccountState; import com.google.gerrit.server.account.AccountState;
import com.google.gerrit.server.query.change.ChangeData; import com.google.gerrit.server.query.change.ChangeData;
@@ -30,18 +29,15 @@ import com.google.gerrit.server.update.BatchUpdate;
import com.google.gerrit.server.update.UpdateException; import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.util.Collection; import java.util.Collection;
@Singleton @Singleton
public class BatchAbandon { public class BatchAbandon {
private final Provider<ReviewDb> dbProvider;
private final AbandonOp.Factory abandonOpFactory; private final AbandonOp.Factory abandonOpFactory;
@Inject @Inject
BatchAbandon(Provider<ReviewDb> dbProvider, AbandonOp.Factory abandonOpFactory) { BatchAbandon(AbandonOp.Factory abandonOpFactory) {
this.dbProvider = dbProvider;
this.abandonOpFactory = abandonOpFactory; this.abandonOpFactory = abandonOpFactory;
} }
@@ -65,7 +61,7 @@ public class BatchAbandon {
return; return;
} }
AccountState accountState = user.isIdentifiedUser() ? user.asIdentifiedUser().state() : null; AccountState accountState = user.isIdentifiedUser() ? user.asIdentifiedUser().state() : null;
try (BatchUpdate u = updateFactory.create(dbProvider.get(), project, user, TimeUtil.nowTs())) { try (BatchUpdate u = updateFactory.create(project, user, TimeUtil.nowTs())) {
for (ChangeData change : changes) { for (ChangeData change : changes) {
if (!project.equals(change.project())) { if (!project.equals(change.project())) {
throw new ResourceConflictException( throw new ResourceConflictException(

View File

@@ -37,7 +37,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.reviewdb.server.ReviewDbUtil; import com.google.gerrit.reviewdb.server.ReviewDbUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
@@ -113,7 +112,6 @@ public class ConsistencyChecker {
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
private final Provider<CurrentUser> user; private final Provider<CurrentUser> user;
private final Provider<PersonIdent> serverIdent; private final Provider<PersonIdent> serverIdent;
private final Provider<ReviewDb> db;
private final RetryHelper retryHelper; private final RetryHelper retryHelper;
private BatchUpdate.Factory updateFactory; private BatchUpdate.Factory updateFactory;
@@ -141,11 +139,9 @@ public class ConsistencyChecker {
PatchSetInserter.Factory patchSetInserterFactory, PatchSetInserter.Factory patchSetInserterFactory,
PatchSetUtil psUtil, PatchSetUtil psUtil,
Provider<CurrentUser> user, Provider<CurrentUser> user,
Provider<ReviewDb> db,
RetryHelper retryHelper) { RetryHelper retryHelper) {
this.accounts = accounts; this.accounts = accounts;
this.accountPatchReviewStore = accountPatchReviewStore; this.accountPatchReviewStore = accountPatchReviewStore;
this.db = db;
this.notesFactory = notesFactory; this.notesFactory = notesFactory;
this.patchSetInfoFactory = patchSetInfoFactory; this.patchSetInfoFactory = patchSetInfoFactory;
this.patchSetInserterFactory = patchSetInserterFactory; this.patchSetInserterFactory = patchSetInserterFactory;
@@ -585,7 +581,7 @@ public class ConsistencyChecker {
} }
private BatchUpdate newBatchUpdate() { private BatchUpdate newBatchUpdate() {
return updateFactory.create(db.get(), change().getProject(), user.get(), TimeUtil.nowTs()); return updateFactory.create(change().getProject(), user.get(), TimeUtil.nowTs());
} }
private void fixPatchSetRef(ProblemInfo p, PatchSet ps) { private void fixPatchSetRef(ProblemInfo p, PatchSet ps) {

View File

@@ -27,7 +27,6 @@ import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.RefNames; import com.google.gerrit.reviewdb.client.RefNames;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
@@ -69,7 +68,6 @@ public class ChangeEditUtil {
private final GitRepositoryManager gitManager; private final GitRepositoryManager gitManager;
private final PatchSetInserter.Factory patchSetInserterFactory; private final PatchSetInserter.Factory patchSetInserterFactory;
private final ChangeIndexer indexer; private final ChangeIndexer indexer;
private final Provider<ReviewDb> db;
private final Provider<CurrentUser> userProvider; private final Provider<CurrentUser> userProvider;
private final ChangeKindCache changeKindCache; private final ChangeKindCache changeKindCache;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
@@ -79,14 +77,12 @@ public class ChangeEditUtil {
GitRepositoryManager gitManager, GitRepositoryManager gitManager,
PatchSetInserter.Factory patchSetInserterFactory, PatchSetInserter.Factory patchSetInserterFactory,
ChangeIndexer indexer, ChangeIndexer indexer,
Provider<ReviewDb> db,
Provider<CurrentUser> userProvider, Provider<CurrentUser> userProvider,
ChangeKindCache changeKindCache, ChangeKindCache changeKindCache,
PatchSetUtil psUtil) { PatchSetUtil psUtil) {
this.gitManager = gitManager; this.gitManager = gitManager;
this.patchSetInserterFactory = patchSetInserterFactory; this.patchSetInserterFactory = patchSetInserterFactory;
this.indexer = indexer; this.indexer = indexer;
this.db = db;
this.userProvider = userProvider; this.userProvider = userProvider;
this.changeKindCache = changeKindCache; this.changeKindCache = changeKindCache;
this.psUtil = psUtil; this.psUtil = psUtil;
@@ -201,8 +197,7 @@ public class ChangeEditUtil {
.append("."); .append(".");
} }
try (BatchUpdate bu = try (BatchUpdate bu = updateFactory.create(change.getProject(), user, TimeUtil.nowTs())) {
updateFactory.create(db.get(), change.getProject(), user, TimeUtil.nowTs())) {
bu.setRepository(repo, rw, oi); bu.setRepository(repo, rw, oi);
bu.addOp(change.getId(), inserter.setMessage(message.toString())); bu.addOp(change.getId(), inserter.setMessage(message.toString()));
bu.addOp( bu.addOp(

View File

@@ -634,7 +634,7 @@ class ReceiveCommits {
try (BatchUpdate bu = try (BatchUpdate bu =
batchUpdateFactory.create( batchUpdateFactory.create(
db, project.getNameKey(), user.materializedCopy(), TimeUtil.nowTs()); project.getNameKey(), user.materializedCopy(), TimeUtil.nowTs());
ObjectInserter ins = repo.newObjectInserter(); ObjectInserter ins = repo.newObjectInserter();
ObjectReader reader = ins.newReader(); ObjectReader reader = ins.newReader();
RevWalk rw = new RevWalk(reader)) { RevWalk rw = new RevWalk(reader)) {
@@ -782,7 +782,7 @@ class ReceiveCommits {
try (BatchUpdate bu = try (BatchUpdate bu =
batchUpdateFactory.create( batchUpdateFactory.create(
db, project.getNameKey(), user.materializedCopy(), TimeUtil.nowTs()); project.getNameKey(), user.materializedCopy(), TimeUtil.nowTs());
ObjectInserter ins = repo.newObjectInserter(); ObjectInserter ins = repo.newObjectInserter();
ObjectReader reader = ins.newReader(); ObjectReader reader = ins.newReader();
RevWalk rw = new RevWalk(reader)) { RevWalk rw = new RevWalk(reader)) {
@@ -3094,7 +3094,7 @@ class ReceiveCommits {
retryHelper.execute( retryHelper.execute(
updateFactory -> { updateFactory -> {
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db, projectState.getNameKey(), user, TimeUtil.nowTs()); updateFactory.create(projectState.getNameKey(), user, TimeUtil.nowTs());
ObjectInserter ins = repo.newObjectInserter(); ObjectInserter ins = repo.newObjectInserter();
ObjectReader reader = ins.newReader(); ObjectReader reader = ins.newReader();
RevWalk rw = new RevWalk(reader)) { RevWalk rw = new RevWalk(reader)) {

View File

@@ -39,7 +39,6 @@ import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchLineComment.Status; import com.google.gerrit.reviewdb.client.PatchLineComment.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
@@ -85,7 +84,6 @@ import java.util.Set;
public class MailProcessor { public class MailProcessor {
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final Provider<ReviewDb> dbProvider;
private final Emails emails; private final Emails emails;
private final InboundEmailRejectionSender.Factory emailRejectionSender; private final InboundEmailRejectionSender.Factory emailRejectionSender;
private final RetryHelper retryHelper; private final RetryHelper retryHelper;
@@ -104,7 +102,6 @@ public class MailProcessor {
@Inject @Inject
public MailProcessor( public MailProcessor(
Provider<ReviewDb> dbProvider,
Emails emails, Emails emails,
InboundEmailRejectionSender.Factory emailRejectionSender, InboundEmailRejectionSender.Factory emailRejectionSender,
RetryHelper retryHelper, RetryHelper retryHelper,
@@ -120,7 +117,6 @@ public class MailProcessor {
CommentAdded commentAdded, CommentAdded commentAdded,
AccountCache accountCache, AccountCache accountCache,
UrlFormatter urlFormatter) { UrlFormatter urlFormatter) {
this.dbProvider = dbProvider;
this.emails = emails; this.emails = emails;
this.emailRejectionSender = emailRejectionSender; this.emailRejectionSender = emailRejectionSender;
this.retryHelper = retryHelper; this.retryHelper = retryHelper;
@@ -263,8 +259,7 @@ public class MailProcessor {
} }
Op o = new Op(new PatchSet.Id(cd.getId(), metadata.patchSet), parsedComments, message.id()); Op o = new Op(new PatchSet.Id(cd.getId(), metadata.patchSet), parsedComments, message.id());
BatchUpdate batchUpdate = BatchUpdate batchUpdate = buf.create(project, ctx.getUser(), TimeUtil.nowTs());
buf.create(dbProvider.get(), project, ctx.getUser(), TimeUtil.nowTs());
batchUpdate.addOp(cd.getId(), o); batchUpdate.addOp(cd.getId(), o);
batchUpdate.execute(); batchUpdate.execute();
} }

View File

@@ -36,7 +36,6 @@ import com.google.gerrit.reviewdb.client.Account.Id;
import com.google.gerrit.reviewdb.client.Comment; import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
@@ -74,7 +73,6 @@ import java.util.Objects;
public class DeleteDraftComments public class DeleteDraftComments
implements RestModifyView<AccountResource, DeleteDraftCommentsInput> { implements RestModifyView<AccountResource, DeleteDraftCommentsInput> {
private final Provider<ReviewDb> db;
private final Provider<CurrentUser> userProvider; private final Provider<CurrentUser> userProvider;
private final BatchUpdate.Factory batchUpdateFactory; private final BatchUpdate.Factory batchUpdateFactory;
private final Provider<ChangeQueryBuilder> queryBuilderProvider; private final Provider<ChangeQueryBuilder> queryBuilderProvider;
@@ -88,7 +86,6 @@ public class DeleteDraftComments
@Inject @Inject
DeleteDraftComments( DeleteDraftComments(
Provider<ReviewDb> db,
Provider<CurrentUser> userProvider, Provider<CurrentUser> userProvider,
Factory batchUpdateFactory, Factory batchUpdateFactory,
Provider<ChangeQueryBuilder> queryBuilderProvider, Provider<ChangeQueryBuilder> queryBuilderProvider,
@@ -99,7 +96,6 @@ public class DeleteDraftComments
CommentsUtil commentsUtil, CommentsUtil commentsUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
PatchListCache patchListCache) { PatchListCache patchListCache) {
this.db = db;
this.userProvider = userProvider; this.userProvider = userProvider;
this.batchUpdateFactory = batchUpdateFactory; this.batchUpdateFactory = batchUpdateFactory;
this.queryBuilderProvider = queryBuilderProvider; this.queryBuilderProvider = queryBuilderProvider;
@@ -142,7 +138,7 @@ public class DeleteDraftComments
.query(predicate(accountId, input))) { .query(predicate(accountId, input))) {
BatchUpdate update = BatchUpdate update =
updates.computeIfAbsent( updates.computeIfAbsent(
cd.project(), p -> batchUpdateFactory.create(db.get(), p, rsrc.getUser(), now)); cd.project(), p -> batchUpdateFactory.create(p, rsrc.getUser(), now));
Op op = new Op(commentFormatter, accountId); Op op = new Op(commentFormatter, accountId);
update.addOp(cd.getId(), op); update.addOp(cd.getId(), op);
ops.add(op); ops.add(op);

View File

@@ -25,7 +25,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Account; import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.account.AccountState; import com.google.gerrit.server.account.AccountState;
@@ -43,7 +42,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import org.eclipse.jgit.errors.ConfigInvalidException; import org.eclipse.jgit.errors.ConfigInvalidException;
@@ -53,7 +51,6 @@ public class Abandon extends RetryingRestModifyView<ChangeResource, AbandonInput
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final Provider<ReviewDb> dbProvider;
private final ChangeJson.Factory json; private final ChangeJson.Factory json;
private final AbandonOp.Factory abandonOpFactory; private final AbandonOp.Factory abandonOpFactory;
private final NotifyUtil notifyUtil; private final NotifyUtil notifyUtil;
@@ -61,14 +58,12 @@ public class Abandon extends RetryingRestModifyView<ChangeResource, AbandonInput
@Inject @Inject
Abandon( Abandon(
Provider<ReviewDb> dbProvider,
ChangeJson.Factory json, ChangeJson.Factory json,
RetryHelper retryHelper, RetryHelper retryHelper,
AbandonOp.Factory abandonOpFactory, AbandonOp.Factory abandonOpFactory,
NotifyUtil notifyUtil, NotifyUtil notifyUtil,
PatchSetUtil patchSetUtil) { PatchSetUtil patchSetUtil) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.json = json; this.json = json;
this.abandonOpFactory = abandonOpFactory; this.abandonOpFactory = abandonOpFactory;
this.notifyUtil = notifyUtil; this.notifyUtil = notifyUtil;
@@ -134,8 +129,7 @@ public class Abandon extends RetryingRestModifyView<ChangeResource, AbandonInput
throws RestApiException, UpdateException { throws RestApiException, UpdateException {
AccountState accountState = user.isIdentifiedUser() ? user.asIdentifiedUser().state() : null; AccountState accountState = user.isIdentifiedUser() ? user.asIdentifiedUser().state() : null;
AbandonOp op = abandonOpFactory.create(accountState, msgTxt, notifyHandling, accountsToNotify); AbandonOp op = abandonOpFactory.create(accountState, msgTxt, notifyHandling, accountsToNotify);
try (BatchUpdate u = try (BatchUpdate u = updateFactory.create(notes.getProjectName(), user, TimeUtil.nowTs())) {
updateFactory.create(dbProvider.get(), notes.getProjectName(), user, TimeUtil.nowTs())) {
u.addOp(notes.getChangeId(), op).execute(); u.addOp(notes.getChangeId(), op).execute();
} }
return op.getChange(); return op.getChange();

View File

@@ -31,7 +31,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Change.Status; import com.google.gerrit.reviewdb.client.Change.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.GerritPersonIdent; import com.google.gerrit.server.GerritPersonIdent;
@@ -93,7 +92,6 @@ public class CherryPickChange {
abstract ImmutableSet<String> filesWithGitConflicts(); abstract ImmutableSet<String> filesWithGitConflicts();
} }
private final Provider<ReviewDb> dbProvider;
private final Sequences seq; private final Sequences seq;
private final Provider<InternalChangeQuery> queryProvider; private final Provider<InternalChangeQuery> queryProvider;
private final GitRepositoryManager gitManager; private final GitRepositoryManager gitManager;
@@ -109,7 +107,6 @@ public class CherryPickChange {
@Inject @Inject
CherryPickChange( CherryPickChange(
Provider<ReviewDb> dbProvider,
Sequences seq, Sequences seq,
Provider<InternalChangeQuery> queryProvider, Provider<InternalChangeQuery> queryProvider,
@GerritPersonIdent PersonIdent myIdent, @GerritPersonIdent PersonIdent myIdent,
@@ -122,7 +119,6 @@ public class CherryPickChange {
ProjectCache projectCache, ProjectCache projectCache,
ApprovalsUtil approvalsUtil, ApprovalsUtil approvalsUtil,
NotifyUtil notifyUtil) { NotifyUtil notifyUtil) {
this.dbProvider = dbProvider;
this.seq = seq; this.seq = seq;
this.queryProvider = queryProvider; this.queryProvider = queryProvider;
this.gitManager = gitManager; this.gitManager = gitManager;
@@ -248,8 +244,7 @@ public class CherryPickChange {
+ " reside on the same branch. " + " reside on the same branch. "
+ "Cannot create a new patch set."); + "Cannot create a new patch set.");
} }
try (BatchUpdate bu = try (BatchUpdate bu = batchUpdateFactory.create(project, identifiedUser, now)) {
batchUpdateFactory.create(dbProvider.get(), project, identifiedUser, now)) {
bu.setRepository(git, revWalk, oi); bu.setRepository(git, revWalk, oi);
Change.Id changeId; Change.Id changeId;
if (destChanges.size() == 1) { if (destChanges.size() == 1) {

View File

@@ -39,7 +39,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.client.RefNames; import com.google.gerrit.reviewdb.client.RefNames;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.GerritPersonIdent; import com.google.gerrit.server.GerritPersonIdent;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
@@ -101,7 +100,6 @@ public class CreateChange
extends RetryingRestCollectionModifyView< extends RetryingRestCollectionModifyView<
TopLevelResource, ChangeResource, ChangeInput, Response<ChangeInfo>> { TopLevelResource, ChangeResource, ChangeInput, Response<ChangeInfo>> {
private final String anonymousCowardName; private final String anonymousCowardName;
private final Provider<ReviewDb> db;
private final GitRepositoryManager gitManager; private final GitRepositoryManager gitManager;
private final Sequences seq; private final Sequences seq;
private final TimeZone serverTimeZone; private final TimeZone serverTimeZone;
@@ -122,7 +120,6 @@ public class CreateChange
@Inject @Inject
CreateChange( CreateChange(
@AnonymousCowardName String anonymousCowardName, @AnonymousCowardName String anonymousCowardName,
Provider<ReviewDb> db,
GitRepositoryManager gitManager, GitRepositoryManager gitManager,
Sequences seq, Sequences seq,
@GerritPersonIdent PersonIdent myIdent, @GerritPersonIdent PersonIdent myIdent,
@@ -141,7 +138,6 @@ public class CreateChange
ContributorAgreementsChecker contributorAgreements) { ContributorAgreementsChecker contributorAgreements) {
super(retryHelper); super(retryHelper);
this.anonymousCowardName = anonymousCowardName; this.anonymousCowardName = anonymousCowardName;
this.db = db;
this.gitManager = gitManager; this.gitManager = gitManager;
this.seq = seq; this.seq = seq;
this.serverTimeZone = myIdent.getTimeZone(); this.serverTimeZone = myIdent.getTimeZone();
@@ -319,7 +315,7 @@ public class CreateChange
ins.setGroups(groups); ins.setGroups(groups);
ins.setNotify(input.notify); ins.setNotify(input.notify);
ins.setAccountsToNotify(notifyUtil.resolveAccounts(input.notifyDetails)); ins.setAccountsToNotify(notifyUtil.resolveAccounts(input.notifyDetails));
try (BatchUpdate bu = updateFactory.create(db.get(), project, me, now)) { try (BatchUpdate bu = updateFactory.create(project, me, now)) {
bu.setRepository(git, rw, oi); bu.setRepository(git, rw, oi);
bu.insertChange(ins); bu.insertChange(ins);
bu.execute(); bu.execute();

View File

@@ -28,7 +28,6 @@ import com.google.gerrit.extensions.restapi.Url;
import com.google.gerrit.reviewdb.client.Comment; import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchLineComment.Status; import com.google.gerrit.reviewdb.client.PatchLineComment.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.change.RevisionResource; import com.google.gerrit.server.change.RevisionResource;
@@ -51,7 +50,6 @@ import java.util.Collections;
@Singleton @Singleton
public class CreateDraftComment public class CreateDraftComment
extends RetryingRestModifyView<RevisionResource, DraftInput, Response<CommentInfo>> { extends RetryingRestModifyView<RevisionResource, DraftInput, Response<CommentInfo>> {
private final Provider<ReviewDb> db;
private final Provider<CommentJson> commentJson; private final Provider<CommentJson> commentJson;
private final CommentsUtil commentsUtil; private final CommentsUtil commentsUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
@@ -59,14 +57,12 @@ public class CreateDraftComment
@Inject @Inject
CreateDraftComment( CreateDraftComment(
Provider<ReviewDb> db,
RetryHelper retryHelper, RetryHelper retryHelper,
Provider<CommentJson> commentJson, Provider<CommentJson> commentJson,
CommentsUtil commentsUtil, CommentsUtil commentsUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
PatchListCache patchListCache) { PatchListCache patchListCache) {
super(retryHelper); super(retryHelper);
this.db = db;
this.commentJson = commentJson; this.commentJson = commentJson;
this.commentsUtil = commentsUtil; this.commentsUtil = commentsUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
@@ -88,7 +84,7 @@ public class CreateDraftComment
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Op op = new Op(rsrc.getPatchSet().getId(), in); Op op = new Op(rsrc.getPatchSet().getId(), in);
bu.addOp(rsrc.getChange().getId(), op); bu.addOp(rsrc.getChange().getId(), op);
bu.execute(); bu.execute();

View File

@@ -33,7 +33,6 @@ import com.google.gerrit.reviewdb.client.Branch;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.GerritPersonIdent; import com.google.gerrit.server.GerritPersonIdent;
@@ -79,7 +78,6 @@ import org.eclipse.jgit.util.ChangeIdUtil;
@Singleton @Singleton
public class CreateMergePatchSet public class CreateMergePatchSet
extends RetryingRestModifyView<ChangeResource, MergePatchSetInput, Response<ChangeInfo>> { extends RetryingRestModifyView<ChangeResource, MergePatchSetInput, Response<ChangeInfo>> {
private final Provider<ReviewDb> db;
private final GitRepositoryManager gitManager; private final GitRepositoryManager gitManager;
private final CommitsCollection commits; private final CommitsCollection commits;
private final TimeZone serverTimeZone; private final TimeZone serverTimeZone;
@@ -94,7 +92,6 @@ public class CreateMergePatchSet
@Inject @Inject
CreateMergePatchSet( CreateMergePatchSet(
Provider<ReviewDb> db,
GitRepositoryManager gitManager, GitRepositoryManager gitManager,
CommitsCollection commits, CommitsCollection commits,
@GerritPersonIdent PersonIdent myIdent, @GerritPersonIdent PersonIdent myIdent,
@@ -108,7 +105,6 @@ public class CreateMergePatchSet
ChangeFinder changeFinder, ChangeFinder changeFinder,
PermissionBackend permissionBackend) { PermissionBackend permissionBackend) {
super(retryHelper); super(retryHelper);
this.db = db;
this.gitManager = gitManager; this.gitManager = gitManager;
this.commits = commits; this.commits = commits;
this.serverTimeZone = myIdent.getTimeZone(); this.serverTimeZone = myIdent.getTimeZone();
@@ -185,7 +181,7 @@ public class CreateMergePatchSet
PatchSet.Id nextPsId = ChangeUtil.nextPatchSetId(ps.getId()); PatchSet.Id nextPsId = ChangeUtil.nextPatchSetId(ps.getId());
PatchSetInserter psInserter = PatchSetInserter psInserter =
patchSetInserterFactory.create(rsrc.getNotes(), nextPsId, newCommit); patchSetInserterFactory.create(rsrc.getNotes(), nextPsId, newCommit);
try (BatchUpdate bu = updateFactory.create(db.get(), project, me, now)) { try (BatchUpdate bu = updateFactory.create(project, me, now)) {
bu.setRepository(git, rw, oi); bu.setRepository(git, rw, oi);
psInserter psInserter
.setMessage("Uploaded patch set " + nextPsId.get() + ".") .setMessage("Uploaded patch set " + nextPsId.get() + ".")

View File

@@ -21,7 +21,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Account; import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
import com.google.gerrit.server.account.AccountLoader; import com.google.gerrit.server.account.AccountLoader;
@@ -41,7 +40,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
@@ -49,7 +47,6 @@ public class DeleteAssignee
extends RetryingRestModifyView<ChangeResource, Input, Response<AccountInfo>> { extends RetryingRestModifyView<ChangeResource, Input, Response<AccountInfo>> {
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final Provider<ReviewDb> db;
private final AssigneeChanged assigneeChanged; private final AssigneeChanged assigneeChanged;
private final IdentifiedUser.GenericFactory userFactory; private final IdentifiedUser.GenericFactory userFactory;
private final AccountLoader.Factory accountLoaderFactory; private final AccountLoader.Factory accountLoaderFactory;
@@ -58,13 +55,11 @@ public class DeleteAssignee
DeleteAssignee( DeleteAssignee(
RetryHelper retryHelper, RetryHelper retryHelper,
ChangeMessagesUtil cmUtil, ChangeMessagesUtil cmUtil,
Provider<ReviewDb> db,
AssigneeChanged assigneeChanged, AssigneeChanged assigneeChanged,
IdentifiedUser.GenericFactory userFactory, IdentifiedUser.GenericFactory userFactory,
AccountLoader.Factory accountLoaderFactory) { AccountLoader.Factory accountLoaderFactory) {
super(retryHelper); super(retryHelper);
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.db = db;
this.assigneeChanged = assigneeChanged; this.assigneeChanged = assigneeChanged;
this.userFactory = userFactory; this.userFactory = userFactory;
this.accountLoaderFactory = accountLoaderFactory; this.accountLoaderFactory = accountLoaderFactory;
@@ -77,7 +72,7 @@ public class DeleteAssignee
rsrc.permissions().check(ChangePermission.EDIT_ASSIGNEE); rsrc.permissions().check(ChangePermission.EDIT_ASSIGNEE);
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Op op = new Op(); Op op = new Op();
bu.addOp(rsrc.getChange().getId(), op); bu.addOp(rsrc.getChange().getId(), op);
bu.execute(); bu.execute();

View File

@@ -22,7 +22,6 @@ import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.permissions.ChangePermission; import com.google.gerrit.server.permissions.ChangePermission;
import com.google.gerrit.server.permissions.PermissionBackend; import com.google.gerrit.server.permissions.PermissionBackend;
@@ -41,14 +40,11 @@ import com.google.inject.Singleton;
public class DeleteChange extends RetryingRestModifyView<ChangeResource, Input, Response<?>> public class DeleteChange extends RetryingRestModifyView<ChangeResource, Input, Response<?>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final Provider<ReviewDb> db;
private final Provider<DeleteChangeOp> opProvider; private final Provider<DeleteChangeOp> opProvider;
@Inject @Inject
public DeleteChange( public DeleteChange(RetryHelper retryHelper, Provider<DeleteChangeOp> opProvider) {
Provider<ReviewDb> db, RetryHelper retryHelper, Provider<DeleteChangeOp> opProvider) {
super(retryHelper); super(retryHelper);
this.db = db;
this.opProvider = opProvider; this.opProvider = opProvider;
} }
@@ -62,7 +58,7 @@ public class DeleteChange extends RetryingRestModifyView<ChangeResource, Input,
rsrc.permissions().check(ChangePermission.DELETE); rsrc.permissions().check(ChangePermission.DELETE);
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Change.Id id = rsrc.getChange().getId(); Change.Id id = rsrc.getChange().getId();
bu.setOrder(Order.DB_BEFORE_REPO); bu.setOrder(Order.DB_BEFORE_REPO);
bu.addOp(id, opProvider.get()); bu.addOp(id, opProvider.get());

View File

@@ -28,7 +28,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.account.AccountLoader; import com.google.gerrit.server.account.AccountLoader;
@@ -58,7 +57,6 @@ public class DeleteChangeMessage
ChangeMessageResource, DeleteChangeMessageInput, Response<ChangeMessageInfo>> { ChangeMessageResource, DeleteChangeMessageInput, Response<ChangeMessageInfo>> {
private final Provider<CurrentUser> userProvider; private final Provider<CurrentUser> userProvider;
private final Provider<ReviewDb> dbProvider;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final ChangeMessagesUtil changeMessagesUtil; private final ChangeMessagesUtil changeMessagesUtil;
private final AccountLoader.Factory accountLoaderFactory; private final AccountLoader.Factory accountLoaderFactory;
@@ -67,7 +65,6 @@ public class DeleteChangeMessage
@Inject @Inject
public DeleteChangeMessage( public DeleteChangeMessage(
Provider<CurrentUser> userProvider, Provider<CurrentUser> userProvider,
Provider<ReviewDb> dbProvider,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
ChangeMessagesUtil changeMessagesUtil, ChangeMessagesUtil changeMessagesUtil,
AccountLoader.Factory accountLoaderFactory, AccountLoader.Factory accountLoaderFactory,
@@ -75,7 +72,6 @@ public class DeleteChangeMessage
RetryHelper retryHelper) { RetryHelper retryHelper) {
super(retryHelper); super(retryHelper);
this.userProvider = userProvider; this.userProvider = userProvider;
this.dbProvider = dbProvider;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.changeMessagesUtil = changeMessagesUtil; this.changeMessagesUtil = changeMessagesUtil;
this.accountLoaderFactory = accountLoaderFactory; this.accountLoaderFactory = accountLoaderFactory;
@@ -97,8 +93,7 @@ public class DeleteChangeMessage
DeleteChangeMessageOp deleteChangeMessageOp = DeleteChangeMessageOp deleteChangeMessageOp =
new DeleteChangeMessageOp(resource.getChangeMessageIndex(), newChangeMessage); new DeleteChangeMessageOp(resource.getChangeMessageIndex(), newChangeMessage);
try (BatchUpdate batchUpdate = try (BatchUpdate batchUpdate =
updateFactory.create( updateFactory.create(resource.getChangeResource().getProject(), user, TimeUtil.nowTs())) {
dbProvider.get(), resource.getChangeResource().getProject(), user, TimeUtil.nowTs())) {
batchUpdate.addOp(resource.getChangeId(), deleteChangeMessageOp).execute(); batchUpdate.addOp(resource.getChangeId(), deleteChangeMessageOp).execute();
} }

View File

@@ -22,7 +22,6 @@ import com.google.gerrit.extensions.restapi.ResourceNotFoundException;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Comment; import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.change.CommentResource; import com.google.gerrit.server.change.CommentResource;
@@ -51,7 +50,6 @@ public class DeleteComment
extends RetryingRestModifyView<CommentResource, DeleteCommentInput, CommentInfo> { extends RetryingRestModifyView<CommentResource, DeleteCommentInput, CommentInfo> {
private final Provider<CurrentUser> userProvider; private final Provider<CurrentUser> userProvider;
private final Provider<ReviewDb> dbProvider;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final CommentsUtil commentsUtil; private final CommentsUtil commentsUtil;
private final Provider<CommentJson> commentJson; private final Provider<CommentJson> commentJson;
@@ -60,7 +58,6 @@ public class DeleteComment
@Inject @Inject
public DeleteComment( public DeleteComment(
Provider<CurrentUser> userProvider, Provider<CurrentUser> userProvider,
Provider<ReviewDb> dbProvider,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
RetryHelper retryHelper, RetryHelper retryHelper,
CommentsUtil commentsUtil, CommentsUtil commentsUtil,
@@ -68,7 +65,6 @@ public class DeleteComment
ChangeNotes.Factory notesFactory) { ChangeNotes.Factory notesFactory) {
super(retryHelper); super(retryHelper);
this.userProvider = userProvider; this.userProvider = userProvider;
this.dbProvider = dbProvider;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.commentsUtil = commentsUtil; this.commentsUtil = commentsUtil;
this.commentJson = commentJson; this.commentJson = commentJson;
@@ -91,7 +87,7 @@ public class DeleteComment
DeleteCommentOp deleteCommentOp = new DeleteCommentOp(rsrc, newMessage); DeleteCommentOp deleteCommentOp = new DeleteCommentOp(rsrc, newMessage);
try (BatchUpdate batchUpdate = try (BatchUpdate batchUpdate =
batchUpdateFactory.create( batchUpdateFactory.create(
dbProvider.get(), rsrc.getRevisionResource().getProject(), user, TimeUtil.nowTs())) { rsrc.getRevisionResource().getProject(), user, TimeUtil.nowTs())) {
batchUpdate.addOp(rsrc.getRevisionResource().getChange().getId(), deleteCommentOp).execute(); batchUpdate.addOp(rsrc.getRevisionResource().getChange().getId(), deleteCommentOp).execute();
} }

View File

@@ -23,7 +23,6 @@ import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Comment; import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.change.DraftCommentResource; import com.google.gerrit.server.change.DraftCommentResource;
@@ -38,7 +37,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.util.Collections; import java.util.Collections;
import java.util.Optional; import java.util.Optional;
@@ -47,20 +45,17 @@ import java.util.Optional;
public class DeleteDraftComment public class DeleteDraftComment
extends RetryingRestModifyView<DraftCommentResource, Input, Response<CommentInfo>> { extends RetryingRestModifyView<DraftCommentResource, Input, Response<CommentInfo>> {
private final Provider<ReviewDb> db;
private final CommentsUtil commentsUtil; private final CommentsUtil commentsUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
private final PatchListCache patchListCache; private final PatchListCache patchListCache;
@Inject @Inject
DeleteDraftComment( DeleteDraftComment(
Provider<ReviewDb> db,
CommentsUtil commentsUtil, CommentsUtil commentsUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
RetryHelper retryHelper, RetryHelper retryHelper,
PatchListCache patchListCache) { PatchListCache patchListCache) {
super(retryHelper); super(retryHelper);
this.db = db;
this.commentsUtil = commentsUtil; this.commentsUtil = commentsUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
this.patchListCache = patchListCache; this.patchListCache = patchListCache;
@@ -71,8 +66,7 @@ public class DeleteDraftComment
BatchUpdate.Factory updateFactory, DraftCommentResource rsrc, Input input) BatchUpdate.Factory updateFactory, DraftCommentResource rsrc, Input input)
throws RestApiException, UpdateException { throws RestApiException, UpdateException {
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
db.get(), rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Op op = new Op(rsrc.getComment().key); Op op = new Op(rsrc.getComment().key);
bu.addOp(rsrc.getChange().getId(), op); bu.addOp(rsrc.getChange().getId(), op);
bu.execute(); bu.execute();

View File

@@ -21,7 +21,6 @@ import com.google.gerrit.extensions.restapi.AuthException;
import com.google.gerrit.extensions.restapi.ResourceConflictException; import com.google.gerrit.extensions.restapi.ResourceConflictException;
import com.google.gerrit.extensions.restapi.Response; import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.permissions.GlobalPermission; import com.google.gerrit.server.permissions.GlobalPermission;
@@ -32,26 +31,22 @@ import com.google.gerrit.server.update.RetryingRestModifyView;
import com.google.gerrit.server.update.UpdateException; import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
public class DeletePrivate public class DeletePrivate
extends RetryingRestModifyView<ChangeResource, SetPrivateOp.Input, Response<String>> { extends RetryingRestModifyView<ChangeResource, SetPrivateOp.Input, Response<String>> {
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final Provider<ReviewDb> dbProvider;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final SetPrivateOp.Factory setPrivateOpFactory; private final SetPrivateOp.Factory setPrivateOpFactory;
@Inject @Inject
DeletePrivate( DeletePrivate(
Provider<ReviewDb> dbProvider,
RetryHelper retryHelper, RetryHelper retryHelper,
ChangeMessagesUtil cmUtil, ChangeMessagesUtil cmUtil,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
SetPrivateOp.Factory setPrivateOpFactory) { SetPrivateOp.Factory setPrivateOpFactory) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.setPrivateOpFactory = setPrivateOpFactory; this.setPrivateOpFactory = setPrivateOpFactory;
@@ -71,8 +66,7 @@ public class DeletePrivate
SetPrivateOp op = setPrivateOpFactory.create(cmUtil, false, input); SetPrivateOp op = setPrivateOpFactory.create(cmUtil, false, input);
try (BatchUpdate u = try (BatchUpdate u =
updateFactory.create( updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
u.addOp(rsrc.getId(), op).execute(); u.addOp(rsrc.getId(), op).execute();
} }

View File

@@ -17,25 +17,22 @@ package com.google.gerrit.server.restapi.change;
import static com.google.gerrit.extensions.conditions.BooleanCondition.and; import static com.google.gerrit.extensions.conditions.BooleanCondition.and;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.permissions.PermissionBackend; import com.google.gerrit.server.permissions.PermissionBackend;
import com.google.gerrit.server.update.RetryHelper; import com.google.gerrit.server.update.RetryHelper;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
public class DeletePrivateByPost extends DeletePrivate implements UiAction<ChangeResource> { public class DeletePrivateByPost extends DeletePrivate implements UiAction<ChangeResource> {
@Inject @Inject
DeletePrivateByPost( DeletePrivateByPost(
Provider<ReviewDb> dbProvider,
RetryHelper retryHelper, RetryHelper retryHelper,
ChangeMessagesUtil cmUtil, ChangeMessagesUtil cmUtil,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
SetPrivateOp.Factory setPrivateOpFactory) { SetPrivateOp.Factory setPrivateOpFactory) {
super(dbProvider, retryHelper, cmUtil, permissionBackend, setPrivateOpFactory); super(retryHelper, cmUtil, permissionBackend, setPrivateOpFactory);
} }
@Override @Override

View File

@@ -17,7 +17,6 @@ package com.google.gerrit.server.restapi.change;
import com.google.gerrit.extensions.api.changes.DeleteReviewerInput; import com.google.gerrit.extensions.api.changes.DeleteReviewerInput;
import com.google.gerrit.extensions.restapi.Response; import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.change.ReviewerResource; import com.google.gerrit.server.change.ReviewerResource;
import com.google.gerrit.server.update.BatchUpdate; import com.google.gerrit.server.update.BatchUpdate;
import com.google.gerrit.server.update.BatchUpdateOp; import com.google.gerrit.server.update.BatchUpdateOp;
@@ -26,25 +25,21 @@ import com.google.gerrit.server.update.RetryingRestModifyView;
import com.google.gerrit.server.update.UpdateException; import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
public class DeleteReviewer public class DeleteReviewer
extends RetryingRestModifyView<ReviewerResource, DeleteReviewerInput, Response<?>> { extends RetryingRestModifyView<ReviewerResource, DeleteReviewerInput, Response<?>> {
private final Provider<ReviewDb> dbProvider;
private final DeleteReviewerOp.Factory deleteReviewerOpFactory; private final DeleteReviewerOp.Factory deleteReviewerOpFactory;
private final DeleteReviewerByEmailOp.Factory deleteReviewerByEmailOpFactory; private final DeleteReviewerByEmailOp.Factory deleteReviewerByEmailOpFactory;
@Inject @Inject
DeleteReviewer( DeleteReviewer(
Provider<ReviewDb> dbProvider,
RetryHelper retryHelper, RetryHelper retryHelper,
DeleteReviewerOp.Factory deleteReviewerOpFactory, DeleteReviewerOp.Factory deleteReviewerOpFactory,
DeleteReviewerByEmailOp.Factory deleteReviewerByEmailOpFactory) { DeleteReviewerByEmailOp.Factory deleteReviewerByEmailOpFactory) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.deleteReviewerOpFactory = deleteReviewerOpFactory; this.deleteReviewerOpFactory = deleteReviewerOpFactory;
this.deleteReviewerByEmailOpFactory = deleteReviewerByEmailOpFactory; this.deleteReviewerByEmailOpFactory = deleteReviewerByEmailOpFactory;
} }
@@ -59,7 +54,6 @@ public class DeleteReviewer
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(
dbProvider.get(),
rsrc.getChangeResource().getProject(), rsrc.getChangeResource().getProject(),
rsrc.getChangeResource().getUser(), rsrc.getChangeResource().getUser(),
TimeUtil.nowTs())) { TimeUtil.nowTs())) {

View File

@@ -31,7 +31,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.PatchSetApproval; import com.google.gerrit.reviewdb.client.PatchSetApproval;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
@@ -58,7 +57,6 @@ import com.google.gerrit.server.util.LabelVote;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import java.util.HashMap; import java.util.HashMap;
@@ -68,7 +66,6 @@ import java.util.Map;
public class DeleteVote extends RetryingRestModifyView<VoteResource, DeleteVoteInput, Response<?>> { public class DeleteVote extends RetryingRestModifyView<VoteResource, DeleteVoteInput, Response<?>> {
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final Provider<ReviewDb> db;
private final ApprovalsUtil approvalsUtil; private final ApprovalsUtil approvalsUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
@@ -81,7 +78,6 @@ public class DeleteVote extends RetryingRestModifyView<VoteResource, DeleteVoteI
@Inject @Inject
DeleteVote( DeleteVote(
Provider<ReviewDb> db,
RetryHelper retryHelper, RetryHelper retryHelper,
ApprovalsUtil approvalsUtil, ApprovalsUtil approvalsUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
@@ -93,7 +89,6 @@ public class DeleteVote extends RetryingRestModifyView<VoteResource, DeleteVoteI
RemoveReviewerControl removeReviewerControl, RemoveReviewerControl removeReviewerControl,
ProjectCache projectCache) { ProjectCache projectCache) {
super(retryHelper); super(retryHelper);
this.db = db;
this.approvalsUtil = approvalsUtil; this.approvalsUtil = approvalsUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
@@ -127,7 +122,7 @@ public class DeleteVote extends RetryingRestModifyView<VoteResource, DeleteVoteI
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(
db.get(), change.getProject(), r.getChangeResource().getUser(), TimeUtil.nowTs())) { change.getProject(), r.getChangeResource().getUser(), TimeUtil.nowTs())) {
bu.addOp( bu.addOp(
change.getId(), change.getId(),
new Op( new Op(

View File

@@ -40,7 +40,6 @@ import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.PatchSetApproval; import com.google.gerrit.reviewdb.client.PatchSetApproval;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.client.RefNames; import com.google.gerrit.reviewdb.client.RefNames;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
@@ -82,7 +81,6 @@ public class Move extends RetryingRestModifyView<ChangeResource, MoveInput, Chan
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final Provider<ReviewDb> dbProvider;
private final ChangeJson.Factory json; private final ChangeJson.Factory json;
private final GitRepositoryManager repoManager; private final GitRepositoryManager repoManager;
private final Provider<InternalChangeQuery> queryProvider; private final Provider<InternalChangeQuery> queryProvider;
@@ -95,7 +93,6 @@ public class Move extends RetryingRestModifyView<ChangeResource, MoveInput, Chan
@Inject @Inject
Move( Move(
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
Provider<ReviewDb> dbProvider,
ChangeJson.Factory json, ChangeJson.Factory json,
GitRepositoryManager repoManager, GitRepositoryManager repoManager,
Provider<InternalChangeQuery> queryProvider, Provider<InternalChangeQuery> queryProvider,
@@ -107,7 +104,6 @@ public class Move extends RetryingRestModifyView<ChangeResource, MoveInput, Chan
@GerritServerConfig Config gerritConfig) { @GerritServerConfig Config gerritConfig) {
super(retryHelper); super(retryHelper);
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.dbProvider = dbProvider;
this.json = json; this.json = json;
this.repoManager = repoManager; this.repoManager = repoManager;
this.queryProvider = queryProvider; this.queryProvider = queryProvider;
@@ -159,8 +155,7 @@ public class Move extends RetryingRestModifyView<ChangeResource, MoveInput, Chan
projectCache.checkedGet(project).checkStatePermitsWrite(); projectCache.checkedGet(project).checkStatePermitsWrite();
Op op = new Op(input); Op op = new Op(input);
try (BatchUpdate u = try (BatchUpdate u = updateFactory.create(project, caller, TimeUtil.nowTs())) {
updateFactory.create(dbProvider.get(), project, caller, TimeUtil.nowTs())) {
u.addOp(change.getId(), op); u.addOp(change.getId(), op);
u.execute(); u.execute();
} }

View File

@@ -19,7 +19,6 @@ import com.google.gerrit.extensions.api.changes.HashtagsInput;
import com.google.gerrit.extensions.restapi.Response; import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.change.SetHashtagsOp; import com.google.gerrit.server.change.SetHashtagsOp;
import com.google.gerrit.server.permissions.ChangePermission; import com.google.gerrit.server.permissions.ChangePermission;
@@ -30,7 +29,6 @@ import com.google.gerrit.server.update.RetryingRestModifyView;
import com.google.gerrit.server.update.UpdateException; import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
@@ -38,14 +36,11 @@ public class PostHashtags
extends RetryingRestModifyView< extends RetryingRestModifyView<
ChangeResource, HashtagsInput, Response<ImmutableSortedSet<String>>> ChangeResource, HashtagsInput, Response<ImmutableSortedSet<String>>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final Provider<ReviewDb> db;
private final SetHashtagsOp.Factory hashtagsFactory; private final SetHashtagsOp.Factory hashtagsFactory;
@Inject @Inject
PostHashtags( PostHashtags(RetryHelper retryHelper, SetHashtagsOp.Factory hashtagsFactory) {
Provider<ReviewDb> db, RetryHelper retryHelper, SetHashtagsOp.Factory hashtagsFactory) {
super(retryHelper); super(retryHelper);
this.db = db;
this.hashtagsFactory = hashtagsFactory; this.hashtagsFactory = hashtagsFactory;
} }
@@ -56,8 +51,7 @@ public class PostHashtags
req.permissions().check(ChangePermission.EDIT_HASHTAGS); req.permissions().check(ChangePermission.EDIT_HASHTAGS);
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(req.getChange().getProject(), req.getUser(), TimeUtil.nowTs())) {
db.get(), req.getChange().getProject(), req.getUser(), TimeUtil.nowTs())) {
SetHashtagsOp op = hashtagsFactory.create(input); SetHashtagsOp op = hashtagsFactory.create(input);
bu.addOp(req.getId(), op); bu.addOp(req.getId(), op);
bu.execute(); bu.execute();

View File

@@ -24,7 +24,6 @@ import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.config.GerritServerConfig; import com.google.gerrit.server.config.GerritServerConfig;
@@ -36,7 +35,6 @@ import com.google.gerrit.server.update.RetryingRestModifyView;
import com.google.gerrit.server.update.UpdateException; import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import org.eclipse.jgit.lib.Config; import org.eclipse.jgit.lib.Config;
@@ -45,21 +43,18 @@ public class PostPrivate
extends RetryingRestModifyView<ChangeResource, SetPrivateOp.Input, Response<String>> extends RetryingRestModifyView<ChangeResource, SetPrivateOp.Input, Response<String>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final Provider<ReviewDb> dbProvider;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final SetPrivateOp.Factory setPrivateOpFactory; private final SetPrivateOp.Factory setPrivateOpFactory;
private final boolean disablePrivateChanges; private final boolean disablePrivateChanges;
@Inject @Inject
PostPrivate( PostPrivate(
Provider<ReviewDb> dbProvider,
RetryHelper retryHelper, RetryHelper retryHelper,
ChangeMessagesUtil cmUtil, ChangeMessagesUtil cmUtil,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
SetPrivateOp.Factory setPrivateOpFactory, SetPrivateOp.Factory setPrivateOpFactory,
@GerritServerConfig Config config) { @GerritServerConfig Config config) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.setPrivateOpFactory = setPrivateOpFactory; this.setPrivateOpFactory = setPrivateOpFactory;
@@ -84,8 +79,7 @@ public class PostPrivate
SetPrivateOp op = setPrivateOpFactory.create(cmUtil, true, input); SetPrivateOp op = setPrivateOpFactory.create(cmUtil, true, input);
try (BatchUpdate u = try (BatchUpdate u =
updateFactory.create( updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
u.addOp(rsrc.getId(), op).execute(); u.addOp(rsrc.getId(), op).execute();
} }

View File

@@ -76,7 +76,6 @@ import com.google.gerrit.reviewdb.client.PatchLineComment.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.PatchSetApproval; import com.google.gerrit.reviewdb.client.PatchSetApproval;
import com.google.gerrit.reviewdb.client.RobotComment; import com.google.gerrit.reviewdb.client.RobotComment;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
@@ -124,7 +123,6 @@ import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gson.Gson; import com.google.gson.Gson;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
@@ -158,7 +156,6 @@ public class PostReview
private static final Gson GSON = OutputFormat.JSON_COMPACT.newGson(); private static final Gson GSON = OutputFormat.JSON_COMPACT.newGson();
private static final int DEFAULT_ROBOT_COMMENT_SIZE_LIMIT_IN_BYTES = 1024 * 1024; private static final int DEFAULT_ROBOT_COMMENT_SIZE_LIMIT_IN_BYTES = 1024 * 1024;
private final Provider<ReviewDb> db;
private final ChangeResource.Factory changeResourceFactory; private final ChangeResource.Factory changeResourceFactory;
private final ChangeData.Factory changeDataFactory; private final ChangeData.Factory changeDataFactory;
private final ApprovalsUtil approvalsUtil; private final ApprovalsUtil approvalsUtil;
@@ -181,7 +178,6 @@ public class PostReview
@Inject @Inject
PostReview( PostReview(
Provider<ReviewDb> db,
RetryHelper retryHelper, RetryHelper retryHelper,
ChangeResource.Factory changeResourceFactory, ChangeResource.Factory changeResourceFactory,
ChangeData.Factory changeDataFactory, ChangeData.Factory changeDataFactory,
@@ -202,7 +198,6 @@ public class PostReview
ProjectCache projectCache, ProjectCache projectCache,
PermissionBackend permissionBackend) { PermissionBackend permissionBackend) {
super(retryHelper); super(retryHelper);
this.db = db;
this.changeResourceFactory = changeResourceFactory; this.changeResourceFactory = changeResourceFactory;
this.changeDataFactory = changeDataFactory; this.changeDataFactory = changeDataFactory;
this.commentsUtil = commentsUtil; this.commentsUtil = commentsUtil;
@@ -303,7 +298,7 @@ public class PostReview
output.labels = input.labels; output.labels = input.labels;
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), revision.getChange().getProject(), revision.getUser(), ts)) { updateFactory.create(revision.getChange().getProject(), revision.getUser(), ts)) {
Account.Id id = revision.getUser().getAccountId(); Account.Id id = revision.getUser().getAccountId();
boolean ccOrReviewer = false; boolean ccOrReviewer = false;
if (input.labels != null && !input.labels.isEmpty()) { if (input.labels != null && !input.labels.isEmpty()) {

View File

@@ -19,7 +19,6 @@ import com.google.gerrit.extensions.api.changes.AddReviewerResult;
import com.google.gerrit.extensions.restapi.BadRequestException; import com.google.gerrit.extensions.restapi.BadRequestException;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
import com.google.gerrit.server.change.ReviewerAdder; import com.google.gerrit.server.change.ReviewerAdder;
import com.google.gerrit.server.change.ReviewerAdder.ReviewerAddition; import com.google.gerrit.server.change.ReviewerAdder.ReviewerAddition;
@@ -33,7 +32,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import org.eclipse.jgit.errors.ConfigInvalidException; import org.eclipse.jgit.errors.ConfigInvalidException;
@@ -43,18 +41,13 @@ public class PostReviewers
extends RetryingRestCollectionModifyView< extends RetryingRestCollectionModifyView<
ChangeResource, ReviewerResource, AddReviewerInput, AddReviewerResult> { ChangeResource, ReviewerResource, AddReviewerInput, AddReviewerResult> {
private final Provider<ReviewDb> dbProvider;
private final ChangeData.Factory changeDataFactory; private final ChangeData.Factory changeDataFactory;
private final ReviewerAdder reviewerAdder; private final ReviewerAdder reviewerAdder;
@Inject @Inject
PostReviewers( PostReviewers(
Provider<ReviewDb> db, ChangeData.Factory changeDataFactory, RetryHelper retryHelper, ReviewerAdder reviewerAdder) {
ChangeData.Factory changeDataFactory,
RetryHelper retryHelper,
ReviewerAdder reviewerAdder) {
super(retryHelper); super(retryHelper);
this.dbProvider = db;
this.changeDataFactory = changeDataFactory; this.changeDataFactory = changeDataFactory;
this.reviewerAdder = reviewerAdder; this.reviewerAdder = reviewerAdder;
} }
@@ -73,8 +66,7 @@ public class PostReviewers
return addition.result; return addition.result;
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Change.Id id = rsrc.getChange().getId(); Change.Id id = rsrc.getChange().getId();
bu.addOp(id, addition.op); bu.addOp(id, addition.op);
bu.execute(); bu.execute();

View File

@@ -25,7 +25,6 @@ import com.google.gerrit.extensions.restapi.BadRequestException;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.restapi.UnprocessableEntityException; import com.google.gerrit.extensions.restapi.UnprocessableEntityException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
import com.google.gerrit.server.account.AccountLoader; import com.google.gerrit.server.account.AccountLoader;
import com.google.gerrit.server.account.AccountResolver; import com.google.gerrit.server.account.AccountResolver;
@@ -43,7 +42,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import org.eclipse.jgit.errors.ConfigInvalidException; import org.eclipse.jgit.errors.ConfigInvalidException;
@@ -54,7 +52,6 @@ public class PutAssignee extends RetryingRestModifyView<ChangeResource, Assignee
private final AccountResolver accountResolver; private final AccountResolver accountResolver;
private final SetAssigneeOp.Factory assigneeFactory; private final SetAssigneeOp.Factory assigneeFactory;
private final Provider<ReviewDb> db;
private final ReviewerAdder reviewerAdder; private final ReviewerAdder reviewerAdder;
private final AccountLoader.Factory accountLoaderFactory; private final AccountLoader.Factory accountLoaderFactory;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
@@ -64,14 +61,12 @@ public class PutAssignee extends RetryingRestModifyView<ChangeResource, Assignee
AccountResolver accountResolver, AccountResolver accountResolver,
SetAssigneeOp.Factory assigneeFactory, SetAssigneeOp.Factory assigneeFactory,
RetryHelper retryHelper, RetryHelper retryHelper,
Provider<ReviewDb> db,
ReviewerAdder reviewerAdder, ReviewerAdder reviewerAdder,
AccountLoader.Factory accountLoaderFactory, AccountLoader.Factory accountLoaderFactory,
PermissionBackend permissionBackend) { PermissionBackend permissionBackend) {
super(retryHelper); super(retryHelper);
this.accountResolver = accountResolver; this.accountResolver = accountResolver;
this.assigneeFactory = assigneeFactory; this.assigneeFactory = assigneeFactory;
this.db = db;
this.reviewerAdder = reviewerAdder; this.reviewerAdder = reviewerAdder;
this.accountLoaderFactory = accountLoaderFactory; this.accountLoaderFactory = accountLoaderFactory;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
@@ -103,8 +98,7 @@ public class PutAssignee extends RetryingRestModifyView<ChangeResource, Assignee
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
db.get(), rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
SetAssigneeOp op = assigneeFactory.create(assignee); SetAssigneeOp op = assigneeFactory.create(assignee);
bu.addOp(rsrc.getId(), op); bu.addOp(rsrc.getId(), op);

View File

@@ -21,7 +21,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.change.RevisionResource; import com.google.gerrit.server.change.RevisionResource;
@@ -37,25 +36,18 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
public class PutDescription public class PutDescription
extends RetryingRestModifyView<RevisionResource, DescriptionInput, Response<String>> extends RetryingRestModifyView<RevisionResource, DescriptionInput, Response<String>>
implements UiAction<RevisionResource> { implements UiAction<RevisionResource> {
private final Provider<ReviewDb> dbProvider;
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
@Inject @Inject
PutDescription( PutDescription(ChangeMessagesUtil cmUtil, RetryHelper retryHelper, PatchSetUtil psUtil) {
Provider<ReviewDb> dbProvider,
ChangeMessagesUtil cmUtil,
RetryHelper retryHelper,
PatchSetUtil psUtil) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
} }
@@ -68,8 +60,7 @@ public class PutDescription
Op op = new Op(input != null ? input : new DescriptionInput(), rsrc.getPatchSet().getId()); Op op = new Op(input != null ? input : new DescriptionInput(), rsrc.getPatchSet().getId());
try (BatchUpdate u = try (BatchUpdate u =
updateFactory.create( updateFactory.create(rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
u.addOp(rsrc.getChange().getId(), op); u.addOp(rsrc.getChange().getId(), op);
u.execute(); u.execute();
} }

View File

@@ -26,7 +26,6 @@ import com.google.gerrit.extensions.restapi.Url;
import com.google.gerrit.reviewdb.client.Comment; import com.google.gerrit.reviewdb.client.Comment;
import com.google.gerrit.reviewdb.client.PatchLineComment.Status; import com.google.gerrit.reviewdb.client.PatchLineComment.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CommentsUtil; import com.google.gerrit.server.CommentsUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.change.DraftCommentResource; import com.google.gerrit.server.change.DraftCommentResource;
@@ -53,7 +52,6 @@ import java.util.Optional;
public class PutDraftComment public class PutDraftComment
extends RetryingRestModifyView<DraftCommentResource, DraftInput, Response<CommentInfo>> { extends RetryingRestModifyView<DraftCommentResource, DraftInput, Response<CommentInfo>> {
private final Provider<ReviewDb> db;
private final DeleteDraftComment delete; private final DeleteDraftComment delete;
private final CommentsUtil commentsUtil; private final CommentsUtil commentsUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
@@ -62,7 +60,6 @@ public class PutDraftComment
@Inject @Inject
PutDraftComment( PutDraftComment(
Provider<ReviewDb> db,
DeleteDraftComment delete, DeleteDraftComment delete,
CommentsUtil commentsUtil, CommentsUtil commentsUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
@@ -70,7 +67,6 @@ public class PutDraftComment
Provider<CommentJson> commentJson, Provider<CommentJson> commentJson,
PatchListCache patchListCache) { PatchListCache patchListCache) {
super(retryHelper); super(retryHelper);
this.db = db;
this.delete = delete; this.delete = delete;
this.commentsUtil = commentsUtil; this.commentsUtil = commentsUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
@@ -93,8 +89,7 @@ public class PutDraftComment
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
db.get(), rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
Op op = new Op(rsrc.getComment().key, in); Op op = new Op(rsrc.getComment().key, in);
bu.addOp(rsrc.getChange().getId(), op); bu.addOp(rsrc.getChange().getId(), op);
bu.execute(); bu.execute();

View File

@@ -24,7 +24,6 @@ import com.google.gerrit.extensions.restapi.Response;
import com.google.gerrit.extensions.restapi.RestApiException; import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.BooleanProjectConfig; import com.google.gerrit.reviewdb.client.BooleanProjectConfig;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.GerritPersonIdent; import com.google.gerrit.server.GerritPersonIdent;
@@ -68,7 +67,6 @@ public class PutMessage
private final GitRepositoryManager repositoryManager; private final GitRepositoryManager repositoryManager;
private final Provider<CurrentUser> userProvider; private final Provider<CurrentUser> userProvider;
private final Provider<ReviewDb> db;
private final TimeZone tz; private final TimeZone tz;
private final PatchSetInserter.Factory psInserterFactory; private final PatchSetInserter.Factory psInserterFactory;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
@@ -81,7 +79,6 @@ public class PutMessage
RetryHelper retryHelper, RetryHelper retryHelper,
GitRepositoryManager repositoryManager, GitRepositoryManager repositoryManager,
Provider<CurrentUser> userProvider, Provider<CurrentUser> userProvider,
Provider<ReviewDb> db,
PatchSetInserter.Factory psInserterFactory, PatchSetInserter.Factory psInserterFactory,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
@GerritPersonIdent PersonIdent gerritIdent, @GerritPersonIdent PersonIdent gerritIdent,
@@ -91,7 +88,6 @@ public class PutMessage
super(retryHelper); super(retryHelper);
this.repositoryManager = repositoryManager; this.repositoryManager = repositoryManager;
this.userProvider = userProvider; this.userProvider = userProvider;
this.db = db;
this.psInserterFactory = psInserterFactory; this.psInserterFactory = psInserterFactory;
this.tz = gerritIdent.getTimeZone(); this.tz = gerritIdent.getTimeZone();
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
@@ -138,8 +134,7 @@ public class PutMessage
Timestamp ts = TimeUtil.nowTs(); Timestamp ts = TimeUtil.nowTs();
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create( updateFactory.create(resource.getChange().getProject(), userProvider.get(), ts)) {
db.get(), resource.getChange().getProject(), userProvider.get(), ts)) {
// Ensure that BatchUpdate will update the same repo // Ensure that BatchUpdate will update the same repo
bu.setRepository(repository, new RevWalk(objectInserter.newReader()), objectInserter); bu.setRepository(repository, new RevWalk(objectInserter.newReader()), objectInserter);

View File

@@ -22,7 +22,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
@@ -40,24 +39,17 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
@Singleton @Singleton
public class PutTopic extends RetryingRestModifyView<ChangeResource, TopicInput, Response<String>> public class PutTopic extends RetryingRestModifyView<ChangeResource, TopicInput, Response<String>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final Provider<ReviewDb> dbProvider;
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final TopicEdited topicEdited; private final TopicEdited topicEdited;
@Inject @Inject
PutTopic( PutTopic(ChangeMessagesUtil cmUtil, RetryHelper retryHelper, TopicEdited topicEdited) {
Provider<ReviewDb> dbProvider,
ChangeMessagesUtil cmUtil,
RetryHelper retryHelper,
TopicEdited topicEdited) {
super(retryHelper); super(retryHelper);
this.dbProvider = dbProvider;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.topicEdited = topicEdited; this.topicEdited = topicEdited;
} }
@@ -82,8 +74,7 @@ public class PutTopic extends RetryingRestModifyView<ChangeResource, TopicInput,
Op op = new Op(sanitizedInput); Op op = new Op(sanitizedInput);
try (BatchUpdate u = try (BatchUpdate u =
updateFactory.create( updateFactory.create(req.getChange().getProject(), req.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), req.getChange().getProject(), req.getUser(), TimeUtil.nowTs())) {
u.addOp(req.getId(), op); u.addOp(req.getId(), op);
u.execute(); u.execute();
} }

View File

@@ -29,7 +29,6 @@ import com.google.gerrit.reviewdb.client.Branch;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Change.Status; import com.google.gerrit.reviewdb.client.Change.Status;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
import com.google.gerrit.server.change.ChangeJson; import com.google.gerrit.server.change.ChangeJson;
@@ -51,7 +50,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
import org.eclipse.jgit.lib.ObjectId; import org.eclipse.jgit.lib.ObjectId;
@@ -74,7 +72,6 @@ public class Rebase extends RetryingRestModifyView<RevisionResource, RebaseInput
private final RebaseChangeOp.Factory rebaseFactory; private final RebaseChangeOp.Factory rebaseFactory;
private final RebaseUtil rebaseUtil; private final RebaseUtil rebaseUtil;
private final ChangeJson.Factory json; private final ChangeJson.Factory json;
private final Provider<ReviewDb> dbProvider;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final ProjectCache projectCache; private final ProjectCache projectCache;
private final PatchSetUtil patchSetUtil; private final PatchSetUtil patchSetUtil;
@@ -86,7 +83,6 @@ public class Rebase extends RetryingRestModifyView<RevisionResource, RebaseInput
RebaseChangeOp.Factory rebaseFactory, RebaseChangeOp.Factory rebaseFactory,
RebaseUtil rebaseUtil, RebaseUtil rebaseUtil,
ChangeJson.Factory json, ChangeJson.Factory json,
Provider<ReviewDb> dbProvider,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
ProjectCache projectCache, ProjectCache projectCache,
PatchSetUtil patchSetUtil) { PatchSetUtil patchSetUtil) {
@@ -95,7 +91,6 @@ public class Rebase extends RetryingRestModifyView<RevisionResource, RebaseInput
this.rebaseFactory = rebaseFactory; this.rebaseFactory = rebaseFactory;
this.rebaseUtil = rebaseUtil; this.rebaseUtil = rebaseUtil;
this.json = json; this.json = json;
this.dbProvider = dbProvider;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.projectCache = projectCache; this.projectCache = projectCache;
this.patchSetUtil = patchSetUtil; this.patchSetUtil = patchSetUtil;
@@ -118,8 +113,7 @@ public class Rebase extends RetryingRestModifyView<RevisionResource, RebaseInput
ObjectReader reader = oi.newReader(); ObjectReader reader = oi.newReader();
RevWalk rw = new RevWalk(reader); RevWalk rw = new RevWalk(reader);
BatchUpdate bu = BatchUpdate bu =
updateFactory.create( updateFactory.create(change.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), change.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
if (!change.getStatus().isOpen()) { if (!change.getStatus().isOpen()) {
throw new ResourceConflictException("change is " + ChangeUtil.status(change)); throw new ResourceConflictException("change is " + ChangeUtil.status(change));
} else if (!hasOneParent(rw, rsrc.getPatchSet())) { } else if (!hasOneParent(rw, rsrc.getPatchSet())) {

View File

@@ -25,7 +25,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Change.Status; import com.google.gerrit.reviewdb.client.Change.Status;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.PatchSetUtil; import com.google.gerrit.server.PatchSetUtil;
@@ -48,7 +47,6 @@ import com.google.gerrit.server.update.UpdateException;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
import com.google.gwtorm.server.OrmException; import com.google.gwtorm.server.OrmException;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.Singleton; import com.google.inject.Singleton;
import java.io.IOException; import java.io.IOException;
@@ -58,7 +56,6 @@ public class Restore extends RetryingRestModifyView<ChangeResource, RestoreInput
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final RestoredSender.Factory restoredSenderFactory; private final RestoredSender.Factory restoredSenderFactory;
private final Provider<ReviewDb> dbProvider;
private final ChangeJson.Factory json; private final ChangeJson.Factory json;
private final ChangeMessagesUtil cmUtil; private final ChangeMessagesUtil cmUtil;
private final PatchSetUtil psUtil; private final PatchSetUtil psUtil;
@@ -68,7 +65,6 @@ public class Restore extends RetryingRestModifyView<ChangeResource, RestoreInput
@Inject @Inject
Restore( Restore(
RestoredSender.Factory restoredSenderFactory, RestoredSender.Factory restoredSenderFactory,
Provider<ReviewDb> dbProvider,
ChangeJson.Factory json, ChangeJson.Factory json,
ChangeMessagesUtil cmUtil, ChangeMessagesUtil cmUtil,
PatchSetUtil psUtil, PatchSetUtil psUtil,
@@ -77,7 +73,6 @@ public class Restore extends RetryingRestModifyView<ChangeResource, RestoreInput
ProjectCache projectCache) { ProjectCache projectCache) {
super(retryHelper); super(retryHelper);
this.restoredSenderFactory = restoredSenderFactory; this.restoredSenderFactory = restoredSenderFactory;
this.dbProvider = dbProvider;
this.json = json; this.json = json;
this.cmUtil = cmUtil; this.cmUtil = cmUtil;
this.psUtil = psUtil; this.psUtil = psUtil;
@@ -98,8 +93,7 @@ public class Restore extends RetryingRestModifyView<ChangeResource, RestoreInput
Op op = new Op(input); Op op = new Op(input);
try (BatchUpdate u = try (BatchUpdate u =
updateFactory.create( updateFactory.create(rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
dbProvider.get(), rsrc.getChange().getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
u.addOp(rsrc.getId(), op).execute(); u.addOp(rsrc.getId(), op).execute();
} }
return json.noOptions().format(op.change); return json.noOptions().format(op.change);

View File

@@ -33,7 +33,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.ChangeMessage; import com.google.gerrit.reviewdb.client.ChangeMessage;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.ChangeMessagesUtil; import com.google.gerrit.server.ChangeMessagesUtil;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
@@ -92,7 +91,6 @@ public class Revert extends RetryingRestModifyView<ChangeResource, RevertInput,
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private static final FluentLogger logger = FluentLogger.forEnclosingClass(); private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private final Provider<ReviewDb> db;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final GitRepositoryManager repoManager; private final GitRepositoryManager repoManager;
private final ChangeInserter.Factory changeInserterFactory; private final ChangeInserter.Factory changeInserterFactory;
@@ -110,7 +108,6 @@ public class Revert extends RetryingRestModifyView<ChangeResource, RevertInput,
@Inject @Inject
Revert( Revert(
Provider<ReviewDb> db,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
GitRepositoryManager repoManager, GitRepositoryManager repoManager,
ChangeInserter.Factory changeInserterFactory, ChangeInserter.Factory changeInserterFactory,
@@ -127,7 +124,6 @@ public class Revert extends RetryingRestModifyView<ChangeResource, RevertInput,
ProjectCache projectCache, ProjectCache projectCache,
NotifyUtil notifyUtil) { NotifyUtil notifyUtil) {
super(retryHelper); super(retryHelper);
this.db = db;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.repoManager = repoManager; this.repoManager = repoManager;
this.changeInserterFactory = changeInserterFactory; this.changeInserterFactory = changeInserterFactory;
@@ -242,7 +238,7 @@ public class Revert extends RetryingRestModifyView<ChangeResource, RevertInput,
ins.setReviewersAndCcs(reviewers, ccs); ins.setReviewersAndCcs(reviewers, ccs);
ins.setRevertOf(changeIdToRevert); ins.setRevertOf(changeIdToRevert);
try (BatchUpdate bu = updateFactory.create(db.get(), project, user, now)) { try (BatchUpdate bu = updateFactory.create(project, user, now)) {
bu.setRepository(git, revWalk, oi); bu.setRepository(git, revWalk, oi);
bu.insertChange(ins); bu.insertChange(ins);
bu.addOp(changeId, new NotifyOp(changeToRevert, ins, input.notify, accountsToNotify)); bu.addOp(changeId, new NotifyOp(changeToRevert, ins, input.notify, accountsToNotify));

View File

@@ -23,7 +23,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Change.Status; import com.google.gerrit.reviewdb.client.Change.Status;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
@@ -46,7 +45,6 @@ import com.google.inject.Singleton;
public class SetReadyForReview extends RetryingRestModifyView<ChangeResource, Input, Response<?>> public class SetReadyForReview extends RetryingRestModifyView<ChangeResource, Input, Response<?>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final WorkInProgressOp.Factory opFactory; private final WorkInProgressOp.Factory opFactory;
private final Provider<ReviewDb> db;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final Provider<CurrentUser> user; private final Provider<CurrentUser> user;
@@ -54,12 +52,10 @@ public class SetReadyForReview extends RetryingRestModifyView<ChangeResource, In
SetReadyForReview( SetReadyForReview(
RetryHelper retryHelper, RetryHelper retryHelper,
WorkInProgressOp.Factory opFactory, WorkInProgressOp.Factory opFactory,
Provider<ReviewDb> db,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
Provider<CurrentUser> user) { Provider<CurrentUser> user) {
super(retryHelper); super(retryHelper);
this.opFactory = opFactory; this.opFactory = opFactory;
this.db = db;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.user = user; this.user = user;
} }
@@ -80,7 +76,7 @@ public class SetReadyForReview extends RetryingRestModifyView<ChangeResource, In
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
bu.addOp(rsrc.getChange().getId(), opFactory.create(false, input)); bu.addOp(rsrc.getChange().getId(), opFactory.create(false, input));
bu.execute(); bu.execute();
return Response.ok(""); return Response.ok("");

View File

@@ -23,7 +23,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.extensions.webui.UiAction; import com.google.gerrit.extensions.webui.UiAction;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Change.Status; import com.google.gerrit.reviewdb.client.Change.Status;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ChangeUtil; import com.google.gerrit.server.ChangeUtil;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.change.ChangeResource; import com.google.gerrit.server.change.ChangeResource;
@@ -46,7 +45,6 @@ import com.google.inject.Singleton;
public class SetWorkInProgress extends RetryingRestModifyView<ChangeResource, Input, Response<?>> public class SetWorkInProgress extends RetryingRestModifyView<ChangeResource, Input, Response<?>>
implements UiAction<ChangeResource> { implements UiAction<ChangeResource> {
private final WorkInProgressOp.Factory opFactory; private final WorkInProgressOp.Factory opFactory;
private final Provider<ReviewDb> db;
private final PermissionBackend permissionBackend; private final PermissionBackend permissionBackend;
private final Provider<CurrentUser> user; private final Provider<CurrentUser> user;
@@ -54,12 +52,10 @@ public class SetWorkInProgress extends RetryingRestModifyView<ChangeResource, In
SetWorkInProgress( SetWorkInProgress(
WorkInProgressOp.Factory opFactory, WorkInProgressOp.Factory opFactory,
RetryHelper retryHelper, RetryHelper retryHelper,
Provider<ReviewDb> db,
PermissionBackend permissionBackend, PermissionBackend permissionBackend,
Provider<CurrentUser> user) { Provider<CurrentUser> user) {
super(retryHelper); super(retryHelper);
this.opFactory = opFactory; this.opFactory = opFactory;
this.db = db;
this.permissionBackend = permissionBackend; this.permissionBackend = permissionBackend;
this.user = user; this.user = user;
} }
@@ -80,7 +76,7 @@ public class SetWorkInProgress extends RetryingRestModifyView<ChangeResource, In
} }
try (BatchUpdate bu = try (BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getProject(), rsrc.getUser(), TimeUtil.nowTs())) {
bu.addOp(rsrc.getChange().getId(), opFactory.create(true, input)); bu.addOp(rsrc.getChange().getId(), opFactory.create(true, input));
bu.execute(); bu.execute();
return Response.ok(""); return Response.ok("");

View File

@@ -28,7 +28,6 @@ import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.client.RefNames; import com.google.gerrit.reviewdb.client.RefNames;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.ApprovalsUtil; import com.google.gerrit.server.ApprovalsUtil;
import com.google.gerrit.server.Sequences; import com.google.gerrit.server.Sequences;
import com.google.gerrit.server.change.ChangeInserter; import com.google.gerrit.server.change.ChangeInserter;
@@ -64,7 +63,6 @@ public class CreateAccessChange implements RestModifyView<ProjectResource, Proje
private final ChangeInserter.Factory changeInserterFactory; private final ChangeInserter.Factory changeInserterFactory;
private final BatchUpdate.Factory updateFactory; private final BatchUpdate.Factory updateFactory;
private final Provider<MetaDataUpdate.User> metaDataUpdateFactory; private final Provider<MetaDataUpdate.User> metaDataUpdateFactory;
private final Provider<ReviewDb> db;
private final SetAccessUtil setAccess; private final SetAccessUtil setAccess;
private final ChangeJson.Factory jsonFactory; private final ChangeJson.Factory jsonFactory;
private final ProjectCache projectCache; private final ProjectCache projectCache;
@@ -77,7 +75,6 @@ public class CreateAccessChange implements RestModifyView<ProjectResource, Proje
BatchUpdate.Factory updateFactory, BatchUpdate.Factory updateFactory,
Sequences seq, Sequences seq,
Provider<MetaDataUpdate.User> metaDataUpdateFactory, Provider<MetaDataUpdate.User> metaDataUpdateFactory,
Provider<ReviewDb> db,
SetAccessUtil accessUtil, SetAccessUtil accessUtil,
ChangeJson.Factory jsonFactory, ChangeJson.Factory jsonFactory,
ProjectCache projectCache, ProjectCache projectCache,
@@ -87,7 +84,6 @@ public class CreateAccessChange implements RestModifyView<ProjectResource, Proje
this.changeInserterFactory = changeInserterFactory; this.changeInserterFactory = changeInserterFactory;
this.updateFactory = updateFactory; this.updateFactory = updateFactory;
this.metaDataUpdateFactory = metaDataUpdateFactory; this.metaDataUpdateFactory = metaDataUpdateFactory;
this.db = db;
this.setAccess = accessUtil; this.setAccess = accessUtil;
this.jsonFactory = jsonFactory; this.jsonFactory = jsonFactory;
this.projectCache = projectCache; this.projectCache = projectCache;
@@ -153,7 +149,7 @@ public class CreateAccessChange implements RestModifyView<ProjectResource, Proje
ObjectReader objReader = objInserter.newReader(); ObjectReader objReader = objInserter.newReader();
RevWalk rw = new RevWalk(objReader); RevWalk rw = new RevWalk(objReader);
BatchUpdate bu = BatchUpdate bu =
updateFactory.create(db.get(), rsrc.getNameKey(), rsrc.getUser(), TimeUtil.nowTs())) { updateFactory.create(rsrc.getNameKey(), rsrc.getUser(), TimeUtil.nowTs())) {
bu.setRepository(md.getRepository(), rw, objInserter); bu.setRepository(md.getRepository(), rw, objInserter);
ChangeInserter ins = newInserter(changeId, commit); ChangeInserter ins = newInserter(changeId, commit);
bu.insertChange(ins); bu.insertChange(ins);

View File

@@ -904,7 +904,7 @@ public class MergeOp implements AutoCloseable {
try { try {
for (ChangeData cd : queryProvider.get().byProjectOpen(destProject)) { for (ChangeData cd : queryProvider.get().byProjectOpen(destProject)) {
try (BatchUpdate bu = try (BatchUpdate bu =
batchUpdateFactory.create(db, destProject, internalUserFactory.create(), ts)) { batchUpdateFactory.create(destProject, internalUserFactory.create(), ts)) {
bu.addOp( bu.addOp(
cd.getId(), cd.getId(),
new BatchUpdateOp() { new BatchUpdateOp() {

View File

@@ -109,7 +109,7 @@ public class MergeOpRepoManager implements AutoCloseable {
if (update == null) { if (update == null) {
update = update =
batchUpdateFactory batchUpdateFactory
.create(db, getProjectName(), caller, ts) .create(getProjectName(), caller, ts)
.setRepository(repo, rw, ins) .setRepository(repo, rw, ins)
.setOnSubmitValidators(onSubmitValidatorsFactory.create()); .setOnSubmitValidators(onSubmitValidatorsFactory.create());
} }

View File

@@ -37,7 +37,6 @@ import com.google.gerrit.extensions.restapi.RestApiException;
import com.google.gerrit.reviewdb.client.Change; import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.PatchSet; import com.google.gerrit.reviewdb.client.PatchSet;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.GerritPersonIdent; import com.google.gerrit.server.GerritPersonIdent;
import com.google.gerrit.server.account.AccountState; import com.google.gerrit.server.account.AccountState;
@@ -110,7 +109,7 @@ public class BatchUpdate implements AutoCloseable {
// TODO(dborowitz): Make this package-private to force all callers to use RetryHelper. // TODO(dborowitz): Make this package-private to force all callers to use RetryHelper.
public interface Factory { public interface Factory {
BatchUpdate create(ReviewDb db, Project.NameKey project, CurrentUser user, Timestamp when); BatchUpdate create(Project.NameKey project, CurrentUser user, Timestamp when);
} }
public static void execute( public static void execute(
@@ -385,7 +384,6 @@ public class BatchUpdate implements AutoCloseable {
NoteDbUpdateManager.Factory updateManagerFactory, NoteDbUpdateManager.Factory updateManagerFactory,
ChangeIndexer indexer, ChangeIndexer indexer,
GitReferenceUpdated gitRefUpdated, GitReferenceUpdated gitRefUpdated,
@SuppressWarnings("unused") @Assisted ReviewDb db,
@Assisted Project.NameKey project, @Assisted Project.NameKey project,
@Assisted CurrentUser user, @Assisted CurrentUser user,
@Assisted Timestamp when) { @Assisted Timestamp when) {

View File

@@ -3850,7 +3850,7 @@ public class ChangeIT extends AbstractDaemonTest {
private void setChangeStatus(Change.Id id, Change.Status newStatus) throws Exception { private void setChangeStatus(Change.Id id, Change.Status newStatus) throws Exception {
try (BatchUpdate batchUpdate = try (BatchUpdate batchUpdate =
batchUpdateFactory.create(db, project, atrScope.get().getUser(), TimeUtil.nowTs())) { batchUpdateFactory.create(project, atrScope.get().getUser(), TimeUtil.nowTs())) {
batchUpdate.addOp(id, new ChangeStatusUpdateOp(newStatus)); batchUpdate.addOp(id, new ChangeStatusUpdateOp(newStatus));
batchUpdate.execute(); batchUpdate.execute();
} }

View File

@@ -1114,7 +1114,7 @@ public abstract class AbstractSubmit extends AbstractDaemonTest {
private void setChangeStatusToNew(PushOneCommit.Result... changes) throws Exception { private void setChangeStatusToNew(PushOneCommit.Result... changes) throws Exception {
for (PushOneCommit.Result change : changes) { for (PushOneCommit.Result change : changes) {
try (BatchUpdate bu = try (BatchUpdate bu =
batchUpdateFactory.create(db, project, userFactory.create(admin.id), TimeUtil.nowTs())) { batchUpdateFactory.create(project, userFactory.create(admin.id), TimeUtil.nowTs())) {
bu.addOp( bu.addOp(
change.getChange().getId(), change.getChange().getId(),
new BatchUpdateOp() { new BatchUpdateOp() {

View File

@@ -733,7 +733,7 @@ public class ConsistencyCheckerIT extends AbstractDaemonTest {
} }
private BatchUpdate newUpdate(Account.Id owner) { private BatchUpdate newUpdate(Account.Id owner) {
return batchUpdateFactory.create(db, project, userFactory.create(owner), TimeUtil.nowTs()); return batchUpdateFactory.create(project, userFactory.create(owner), TimeUtil.nowTs());
} }
private ChangeNotes insertChange() throws Exception { private ChangeNotes insertChange() throws Exception {

View File

@@ -601,7 +601,7 @@ public class GetRelatedIT extends AbstractDaemonTest {
} }
private void clearGroups(PatchSet.Id psId) throws Exception { private void clearGroups(PatchSet.Id psId) throws Exception {
try (BatchUpdate bu = batchUpdateFactory.create(db, project, user(user), TimeUtil.nowTs())) { try (BatchUpdate bu = batchUpdateFactory.create(project, user(user), TimeUtil.nowTs())) {
bu.addOp( bu.addOp(
psId.getParentKey(), psId.getParentKey(),
new BatchUpdateOp() { new BatchUpdateOp() {

View File

@@ -276,7 +276,7 @@ public class NoteDbOnlyIT extends AbstractDaemonTest {
} }
private BatchUpdate newBatchUpdate(BatchUpdate.Factory buf) { private BatchUpdate newBatchUpdate(BatchUpdate.Factory buf) {
return buf.create(db, project, identifiedUserFactory.create(user.getId()), TimeUtil.nowTs()); return buf.create(project, identifiedUserFactory.create(user.getId()), TimeUtil.nowTs());
} }
private Optional<ObjectId> getRef(String name) throws Exception { private Optional<ObjectId> getRef(String name) throws Exception {

View File

@@ -2969,7 +2969,7 @@ public abstract class AbstractQueryChangesTest extends GerritServerTests {
new Project.NameKey(repo.getRepository().getDescription().getRepositoryName()); new Project.NameKey(repo.getRepository().getDescription().getRepositoryName());
Account.Id ownerId = owner != null ? owner : userId; Account.Id ownerId = owner != null ? owner : userId;
IdentifiedUser user = userFactory.create(ownerId); IdentifiedUser user = userFactory.create(ownerId);
try (BatchUpdate bu = updateFactory.create(db, project, user, createdOn)) { try (BatchUpdate bu = updateFactory.create(project, user, createdOn)) {
bu.insertChange(ins); bu.insertChange(ins);
bu.execute(); bu.execute();
return ins.getChange(); return ins.getChange();
@@ -2989,7 +2989,7 @@ public abstract class AbstractQueryChangesTest extends GerritServerTests {
.setNotify(NotifyHandling.NONE) .setNotify(NotifyHandling.NONE)
.setFireRevisionCreated(false) .setFireRevisionCreated(false)
.setValidate(false); .setValidate(false);
try (BatchUpdate bu = updateFactory.create(db, c.getProject(), user, TimeUtil.nowTs()); try (BatchUpdate bu = updateFactory.create(c.getProject(), user, TimeUtil.nowTs());
ObjectInserter oi = repo.getRepository().newObjectInserter(); ObjectInserter oi = repo.getRepository().newObjectInserter();
ObjectReader reader = oi.newReader(); ObjectReader reader = oi.newReader();
RevWalk rw = new RevWalk(reader)) { RevWalk rw = new RevWalk(reader)) {

View File

@@ -17,7 +17,6 @@ package com.google.gerrit.server.update;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.CurrentUser; import com.google.gerrit.server.CurrentUser;
import com.google.gerrit.server.git.GitRepositoryManager; import com.google.gerrit.server.git.GitRepositoryManager;
import com.google.gerrit.server.util.time.TimeUtil; import com.google.gerrit.server.util.time.TimeUtil;
@@ -37,7 +36,6 @@ public class BatchUpdateTest extends GerritBaseTests {
@Inject private GitRepositoryManager repoManager; @Inject private GitRepositoryManager repoManager;
@Inject private BatchUpdate.Factory batchUpdateFactory; @Inject private BatchUpdate.Factory batchUpdateFactory;
@Inject private ReviewDb db;
@Inject private Provider<CurrentUser> user; @Inject private Provider<CurrentUser> user;
private Project.NameKey project; private Project.NameKey project;
@@ -56,7 +54,7 @@ public class BatchUpdateTest extends GerritBaseTests {
final RevCommit masterCommit = repo.branch("master").commit().create(); final RevCommit masterCommit = repo.branch("master").commit().create();
final RevCommit branchCommit = repo.branch("branch").commit().parent(masterCommit).create(); final RevCommit branchCommit = repo.branch("branch").commit().parent(masterCommit).create();
try (BatchUpdate bu = batchUpdateFactory.create(db, project, user.get(), TimeUtil.nowTs())) { try (BatchUpdate bu = batchUpdateFactory.create(project, user.get(), TimeUtil.nowTs())) {
bu.addRepoOnlyOp( bu.addRepoOnlyOp(
new RepoOnlyOp() { new RepoOnlyOp() {
@Override @Override