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
|
package bitbucketpullrequestbuilder.bitbucketpullrequestbuilder;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketApiClient;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestComment;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestResponseValue;
import bitbucketpullrequestbuilder.bitbucketpullrequestbuilder.bitbucket.BitbucketPullRequestResponseValueRepository;
import jenkins.model.Jenkins;
import java.io.IOException;
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 = "[BuildStart]";
public static final String BUILD_FINISH_MARKER = "[BuildFinished]";
public static final String BUILD_REQUEST_MARKER = "test this please";
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 comment = BUILD_START_MARKER;
comment += " Build Triggered. Waiting to hear about " + pullRequest.getSource().getRepository().getFullName();
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());
this.builder.getTrigger().startJob(cause);
}
}
public void postFinishedComment(String pullRequestId, boolean success, String buildUrl) {
String comment = BUILD_FINISH_MARKER;
if (success) {
comment += " Test PASSed. Refer to this link for build results.";
} else {
comment += " Test FAILed. Refer to this link for build results.";
}
comment += 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;
}
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);
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(BUILD_START_MARKER.toLowerCase())) {
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) {
String[] phrases = skipPhrases.split(",");
for(String phrase : phrases) {
if (pullRequestTitle.toLowerCase().contains(phrase.trim().toLowerCase())) {
return true;
}
}
}
return false;
}
}
|
