1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
//
// Copyright (C) 2019 The Qt Company
//
package com.googlesource.gerrit.plugins.qtcodereview;
import com.google.common.flogger.FluentLogger;
import com.google.gerrit.extensions.restapi.AuthException;
import com.google.gerrit.reviewdb.client.Branch;
import com.google.gerrit.reviewdb.client.Change;
import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.reviewdb.server.ReviewDb;
import com.google.gerrit.server.git.GitRepositoryManager;
import com.google.gerrit.server.permissions.PermissionBackend;
import com.google.gerrit.server.permissions.PermissionBackendException;
import com.google.gerrit.server.permissions.RefPermission;
import com.google.gerrit.server.query.change.ChangeData;
import com.google.gerrit.sshd.SshCommand;
import com.google.gerrit.sshd.CommandMetaData;
import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.gwtorm.server.OrmException;
import org.eclipse.jgit.errors.RepositoryNotFoundException;
import org.eclipse.jgit.lib.Repository;
import org.eclipse.jgit.revwalk.RevCommit;
import org.kohsuke.args4j.Option;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.List;
import java.util.Map.Entry;
@CommandMetaData(name = "staging-ls", description = "List all the changes that have been applied to the staging or build ref that are not in the destination branch yet.")
class QtCommandListStaging extends SshCommand {
@Inject
private PermissionBackend permissionBackend;
@Inject
private GitRepositoryManager gitManager;
@Inject
private ReviewDb db;
@Inject
private QtUtil qtUtil;
@Option(name = "--project", aliases = {"-p"},
required = true, usage = "project name")
private String project;
@Option(name = "--branch", aliases = {"-b"},
required = true, usage = "any ref, e.g. refs/staging/master or refs/builds/my_build")
private String branch;
@Option(name = "--destination", aliases = {"-d"},
required = true, usage = "destination branch filter, e.g. refs/heads/master or just master")
private String destination;
private static final FluentLogger logger = FluentLogger.forEnclosingClass();
private Repository git;
@Override
protected void run() throws UnloggedFailure {
logger.atInfo().log("qtcodereview: staging-ls -p %s -b %s", project, branch);
final PrintWriter stdout = toPrintWriter(out);
Project.NameKey projectKey = new Project.NameKey(project);
Branch.NameKey aBranchKey = new Branch.NameKey(projectKey, branch);
Branch.NameKey destBranchShortKey = QtUtil.getNameKeyShort(project, QtUtil.R_HEADS, destination);
try {
git = gitManager.openRepository(projectKey);
permissionBackend.user(user).project(projectKey).ref(aBranchKey.get()).check(RefPermission.READ);
permissionBackend.user(user).project(projectKey).ref(destBranchShortKey.get()).check(RefPermission.READ);
if (git.resolve(aBranchKey.get()) == null) {
throw die("branch ref not found");
}
final List<Entry<ChangeData,RevCommit>> open = qtUtil.listChangesNotMerged(git, aBranchKey, destBranchShortKey);
for (Entry<ChangeData, RevCommit> item : open) {
final Change change = item.getKey().change();
final Change.Status status = change.getStatus();
if (status == Change.Status.STAGED || status == Change.Status.INTEGRATING) {
final RevCommit commit = item.getValue();
stdout.println(commit.name() + " " + change.currentPatchSetId() + " " + change.getSubject());
}
}
logger.atInfo().log("qtcodereview: staging-ls done");
} catch (AuthException e) {
logger.atSevere().log("qtcodereview: staging-ls Authentication failed to access repository: %s", e);
throw die("not authorized");
} catch (PermissionBackendException e) {
logger.atSevere().log("qtcodereview: staging-ls permission error %s", e);
} catch (RepositoryNotFoundException e) {
logger.atSevere().log("qtcodereview: staging-ls repository not found: %s", e);
throw die("project not found");
} catch (QtUtil.BranchNotFoundException e) {
throw die("invalid branch " + e.getMessage());
} catch (IOException e) {
logger.atSevere().log("qtcodereview: staging-ls IOException %s", e);
throw die(e.getMessage());
} catch (OrmException e) {
logger.atSevere().log("qtcodereview: staging-ls cannot access Gerrit database %s", e);
throw die("cannot access Gerrit database");
} finally {
stdout.flush();
if (git != null) {
git.close();
}
}
}
}
|
