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
|
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.List;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
* 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 null;
}
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 null;
}
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;
}
private String getRequest(String path) {
HttpClient client = new HttpClient();
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 = new HttpClient();
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 = new HttpClient();
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;
}
}
|
