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
|
package bitbucketpullrequestbuilder.bitbucketpullrequestbuilder;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketApiClient;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestComment;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestResponseValue;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestResponseValueRepository;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.logging.Logger;
/**
* Created by nishio
*/
public class BitbucketRepository {
private static final Logger logger = Logger.getLogger(BitbucketRepository.class.getName());
public static final String BUILD_START_MARKER = "[*BuildStarted*] %s";
public static final String BUILD_FINISH_MARKER = "[*BuildFinished*] %s \n\n **%s** - %s";
public static final String BUILD_REQUEST_MARKER = "test this please";
public static final String BUILD_SUCCESS_COMMENT = ":star:SUCCESS";
public static final String BUILD_FAILURE_COMMENT = ":x:FAILURE";
private String projectPath;
private BitbucketPullRequestsBuilder builder;
private BitbucketBuildTrigger trigger;
private BitbucketApiClient client;
public BitbucketRepository(String projectPath, BitbucketPullRequestsBuilder builder) {
this.projectPath = projectPath;
this.builder = builder;
}
public void init() {
trigger = this.builder.getTrigger();
client = new BitbucketApiClient(
trigger.getUsername(),
trigger.getPassword(),
trigger.getRepositoryOwner(),
trigger.getRepositoryName());
}
public Collection<BitbucketPullRequestResponseValue> getTargetPullRequests() {
logger.info("Fetch PullRequests.");
List<BitbucketPullRequestResponseValue> pullRequests = client.getPullRequests();
List<BitbucketPullRequestResponseValue> targetPullRequests = new ArrayList<BitbucketPullRequestResponseValue>();
for(BitbucketPullRequestResponseValue pullRequest : pullRequests) {
if (isBuildTarget(pullRequest)) {
targetPullRequests.add(pullRequest);
}
}
return targetPullRequests;
}
public void postBuildStartCommentTo(Collection<BitbucketPullRequestResponseValue> pullRequests) {
for(BitbucketPullRequestResponseValue pullRequest : pullRequests) {
String commit = pullRequest.getSource().getCommit().getHash();
String comment = String.format(BUILD_START_MARKER, commit);
this.client.postPullRequestComment(pullRequest.getId(), comment);
}
}
public void addFutureBuildTasks(Collection<BitbucketPullRequestResponseValue> pullRequests) {
for(BitbucketPullRequestResponseValue pullRequest : pullRequests) {
BitbucketCause cause = new BitbucketCause(
pullRequest.getSource().getBranch().getName(),
pullRequest.getDestination().getBranch().getName(),
pullRequest.getSource().getRepository().getOwnerName(),
pullRequest.getSource().getRepository().getRepositoryName(),
pullRequest.getId(),
pullRequest.getDestination().getRepository().getOwnerName(),
pullRequest.getDestination().getRepository().getRepositoryName(),
pullRequest.getTitle(),
pullRequest.getSource().getCommit().getHash());
this.builder.getTrigger().startJob(cause);
}
}
public void postFinishedComment(String pullRequestId, String commit, boolean success, String buildUrl) {
String message = BUILD_FAILURE_COMMENT;
if (success){
message = BUILD_SUCCESS_COMMENT;
}
String comment = String.format(BUILD_FINISH_MARKER, commit, message, buildUrl);
this.client.postPullRequestComment(pullRequestId, comment);
}
private boolean isBuildTarget(BitbucketPullRequestResponseValue pullRequest) {
boolean shouldBuild = true;
if (pullRequest.getState() != null && pullRequest.getState().equals("OPEN")) {
if (isSkipBuild(pullRequest.getTitle())) {
return false;
}
String commit = pullRequest.getSource().getCommit().getHash();
BitbucketPullRequestResponseValueRepository destination = pullRequest.getDestination();
String owner = destination.getRepository().getOwnerName();
String repositoryName = destination.getRepository().getRepositoryName();
String id = pullRequest.getId();
List<BitbucketPullRequestComment> comments = client.getPullRequestComments(owner, repositoryName, id);
String searchString = String.format(BUILD_START_MARKER, commit).toLowerCase();
if (comments != null) {
Collections.sort(comments);
Collections.reverse(comments);
for(BitbucketPullRequestComment comment : comments) {
String content = comment.getContent();
if (content == null || content.isEmpty()) {
continue;
}
content = content.toLowerCase();
if (content.contains(searchString)) {
shouldBuild = false;
break;
}
if (content.contains(BUILD_REQUEST_MARKER.toLowerCase())) {
shouldBuild = true;
break;
}
}
}
}
return shouldBuild;
}
private boolean isSkipBuild(String pullRequestTitle) {
String skipPhrases = this.trigger.getCiSkipPhrases();
if (skipPhrases != null && !"".equals(skipPhrases)) {
String[] phrases = skipPhrases.split(",");
for(String phrase : phrases) {
if (pullRequestTitle.toLowerCase().contains(phrase.trim().toLowerCase())) {
return true;
}
}
}
return false;
}
}
|
