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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
|
package bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket;
import org.apache.commons.httpclient.*;
import org.apache.commons.httpclient.auth.AuthScope;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.DeleteMethod;
import org.codehaus.jackson.map.ObjectMapper;
import org.codehaus.jackson.type.TypeReference;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.Collections;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import jenkins.model.Jenkins;
import hudson.ProxyConfiguration;
/**
* Created by nishio
*/
public class BitbucketApiClient {
private static final Logger logger = Logger.getLogger(BitbucketApiClient.class.getName());
private static final String BITBUCKET_HOST = "bitbucket.org";
private static final String V1_API_BASE_URL = "https://bitbucket.org/api/1.0/repositories/";
private static final String V2_API_BASE_URL = "https://bitbucket.org/api/2.0/repositories/";
private String owner;
private String repositoryName;
private Credentials credentials;
public BitbucketApiClient(String username, String password, String owner, String repositoryName) {
this.credentials = new UsernamePasswordCredentials(username, password);
this.owner = owner;
this.repositoryName = repositoryName;
}
public List<BitbucketPullRequestResponseValue> getPullRequests() {
String response = getRequest(V2_API_BASE_URL + this.owner + "/" + this.repositoryName + "/pullrequests/");
try {
return parsePullRequestJson(response).getPrValues();
} catch(Exception e) {
logger.log(Level.WARNING, "invalid pull request response.", e);
}
return Collections.EMPTY_LIST;
}
public List<BitbucketPullRequestComment> getPullRequestComments(String commentOwnerName, String commentRepositoryName, String pullRequestId) {
String response = getRequest(
V1_API_BASE_URL + commentOwnerName + "/" + commentRepositoryName + "/pullrequests/" + pullRequestId + "/comments");
try {
return parseCommentJson(response);
} catch(Exception e) {
logger.log(Level.WARNING, "invalid pull request response.", e);
}
return Collections.EMPTY_LIST;
}
public void deletePullRequestComment(String pullRequestId, String commentId) {
String path = V1_API_BASE_URL + this.owner + "/" + this.repositoryName + "/pullrequests/" + pullRequestId + "/comments/" + commentId;
//https://bitbucket.org/api/1.0/repositories/{accountname}/{repo_slug}/pullrequests/{pull_request_id}/comments/{comment_id}
deleteRequest(path);
}
public BitbucketPullRequestComment postPullRequestComment(String pullRequestId, String comment) {
String path = V1_API_BASE_URL + this.owner + "/" + this.repositoryName + "/pullrequests/" + pullRequestId + "/comments";
try {
NameValuePair content = new NameValuePair("content", comment);
String response = postRequest(path, new NameValuePair[]{ content });
return parseSingleCommentJson(response);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
catch (IOException e) {
e.printStackTrace();
}
return null;
}
public void deletePullRequestApproval(String pullRequestId) {
String path = V2_API_BASE_URL + this.owner + "/" + this.repositoryName + "/pullrequests/" + pullRequestId + "/approve";
deleteRequest(path);
}
public BitbucketPullRequestApproval postPullRequestApproval(String pullRequestId) {
String path = V2_API_BASE_URL + this.owner + "/" + this.repositoryName + "/pullrequests/" + pullRequestId + "/approve";
try {
String response = postRequest(path, new NameValuePair[]{});
return parseApprovalJson(response);
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
private HttpClient getHttpClient() {
HttpClient client = new HttpClient();
if (Jenkins.getInstance() != null) {
ProxyConfiguration proxy = Jenkins.getInstance().proxy;
if (proxy != null) {
logger.info("Jenkins proxy: " + proxy.name + ":" + proxy.port);
client.getHostConfiguration().setProxy(proxy.name, proxy.port);
String username = proxy.getUserName();
String password = proxy.getPassword();
// Consider it to be passed if username specified. Sufficient?
if (username != null && !"".equals(username.trim())) {
logger.info("Using proxy authentication (user=" + username + ")");
client.getState().setProxyCredentials(AuthScope.ANY,
new UsernamePasswordCredentials(username, password));
}
}
}
return client;
}
private String getRequest(String path) {
HttpClient client = getHttpClient();
client.getState().setCredentials(AuthScope.ANY, credentials);
GetMethod httpget = new GetMethod(path);
client.getParams().setAuthenticationPreemptive(true);
String response = null;
try {
client.executeMethod(httpget);
response = httpget.getResponseBodyAsString();
} catch (HttpException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return response;
}
public void deleteRequest(String path) {
HttpClient client = getHttpClient();
client.getState().setCredentials(AuthScope.ANY, credentials);
DeleteMethod httppost = new DeleteMethod(path);
client.getParams().setAuthenticationPreemptive(true);
String response = "";
try {
client.executeMethod(httppost);
} catch (IOException e) {
e.printStackTrace();
}
}
private String postRequest(String path, NameValuePair[] params) throws UnsupportedEncodingException {
HttpClient client = getHttpClient();
client.getState().setCredentials(AuthScope.ANY, credentials);
PostMethod httppost = new PostMethod(path);
httppost.setRequestBody(params);
client.getParams().setAuthenticationPreemptive(true);
String response = "";
try {
client.executeMethod(httppost);
response = httppost.getResponseBodyAsString();
logger.info("API Request Response: " + response);
} catch (HttpException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return response;
}
private BitbucketPullRequestResponse parsePullRequestJson(String response) throws IOException {
ObjectMapper mapper = new ObjectMapper();
BitbucketPullRequestResponse parsedResponse;
parsedResponse = mapper.readValue(response, BitbucketPullRequestResponse.class);
return parsedResponse;
}
private List<BitbucketPullRequestComment> parseCommentJson(String response) throws IOException {
ObjectMapper mapper = new ObjectMapper();
List<BitbucketPullRequestComment> parsedResponse;
parsedResponse = mapper.readValue(
response,
new TypeReference<List<BitbucketPullRequestComment>>() {
});
return parsedResponse;
}
private BitbucketPullRequestComment parseSingleCommentJson(String response) throws IOException {
ObjectMapper mapper = new ObjectMapper();
BitbucketPullRequestComment parsedResponse;
parsedResponse = mapper.readValue(
response,
BitbucketPullRequestComment.class);
return parsedResponse;
}
private BitbucketPullRequestApproval parseApprovalJson(String response) throws IOException {
ObjectMapper mapper = new ObjectMapper();
BitbucketPullRequestApproval parsedResponse;
parsedResponse = mapper.readValue(
response,
BitbucketPullRequestApproval.class);
return parsedResponse;
}
}
|
