import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public void perform(@Nonnull Run<?, ?> run, @Nonnull FilePath workspace, @Nonnull Launcher launcher,
                    @Nonnull TaskListener listener) throws InterruptedException, IOException {
    if (getStatusVerifier() != null && !getStatusVerifier().isRunAllowed(run)) {
        return;
    }
    try {
        HashSet<String> remoteLabels = new HashSet<>();
        final GHIssue ghIssue = getGhIssue(run);
        //remote labels List -> Set
        ghIssue.getLabels().stream()
                .map(GHLabel::getName)
                .collect(Collectors.toList())
                .forEach(remoteLabels::add);

        remoteLabels.addAll(getLabelProperty().getLabelsSet());
        ghIssue.setLabels(remoteLabels.toArray(new String[remoteLabels.size()]));
    } catch (IOException ex) {
        final int number = getPRNumberFromPRCause(run);
        listener.getLogger().println("Couldn't add label for PR #" + number + ex.getMessage());
        LOGGER.error("Couldn't add label for PR #{}", number, ex);
        handlePublisherError(run);
    }
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public void perform(@Nonnull Run<?, ?> run, @Nonnull FilePath workspace, @Nonnull Launcher launcher,
                    @Nonnull TaskListener listener) throws InterruptedException, IOException {
    if (getStatusVerifier() != null && !getStatusVerifier().isRunAllowed(run)) {
        return;
    }

    final int number = getPRNumberFromPRCause(run);
    try {
        HashSet<String> remoteLabels = getGhIssue(run).getLabels().stream()
                .map(GHLabel::getName)
                .collect(Collectors.toCollection(HashSet::new));

        //remote labels List -> Set
        remoteLabels.removeAll(getLabelProperty().getLabelsSet());
        // TODO print only really removing
        listener.getLogger().println("Removing labels: " + getLabelProperty().getLabelsSet());
        getGhIssue(run).setLabels(remoteLabels.toArray(new String[remoteLabels.size()]));
    } catch (IOException ex) {
        listener.getLogger().println("Couldn't remove label for PR #" + number + ex);
        LOGGER.error("Couldn't remove label for PR #{}", number, ex);
        handlePublisherError(run);
    }
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public GitHubPRCause check(GitHubPRTrigger gitHubPRTrigger, GHPullRequest remotePR,
                           @CheckForNull GitHubPRPullRequest localPR, TaskListener listener) throws IOException {
    if (remotePR.getState().equals(GHIssueState.CLOSED)) {
        return null; // already closed, skip check?
    }

    GitHubPRCause cause = null;

    Collection<GHLabel> remoteLabels = remotePR.getRepository().getIssue(remotePR.getNumber()).getLabels();
    Set<String> existingLabels = new HashSet<String>();

    for (GHLabel ghLabel : remoteLabels) {
        existingLabels.add(ghLabel.getName());
    }

    if (existingLabels.containsAll(label.getLabelsSet())) {
        final PrintStream logger = listener.getLogger();
        logger.println(DISPLAY_NAME + ": " + label.getLabelsSet() + " found");
        cause = new GitHubPRCause(remotePR, label.getLabelsSet() + " labels exist", isSkip());
    }

    return cause;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public GitHubPRCause check(GitHubPRTrigger gitHubPRTrigger, GHPullRequest remotePR,
                           @CheckForNull GitHubPRPullRequest localPR, TaskListener listener) throws IOException {
    final PrintStream logger = listener.getLogger();

    for (GHLabel ghLabel : remotePR.getRepository().getIssue(remotePR.getNumber()).getLabels()) {
        for (String labelPatternStr : label.getLabelsSet()) {
            Pattern labelPattern = Pattern.compile(labelPatternStr);
            if (labelPattern.matcher(ghLabel.getName()).matches()) {
                logger.println(DISPLAY_NAME + ": Pull request has label: " + labelPatternStr);
                LOGGER.info("Pull request has '{}' label.", labelPatternStr);
                return new GitHubPRCause(remotePR, "PR has label: " + labelPatternStr, isSkip());
            }
        }
    }

    return null;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and there is one that wasn't removed yet.
 */
@Test
public void twoOfThreeLabelsWasRemoved() throws IOException {
    Set<String> localLabels = new HashSet<>();
    localLabels.add(TESTS_FAILURE);

    List<GHLabel> remoteLabels = new ArrayList<GHLabel>();
    remoteLabels.add(label);

    commonExpectations(localLabels);
    when(issue.getLabels()).thenReturn(remoteLabels);
    when(label.getName()).thenReturn(TESTS_FAILURE);

    GitHubPRLabelRemovedEvent instance = new GitHubPRLabelRemovedEvent(labels);
    GitHubPRCause cause = instance.check(null, remotePr, localPR, listener);
    Assert.assertNull(cause);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and no one of them was removed.
 */
@Test
public void noLabelsWasRemoved() throws IOException {
    Set<String> localLabels = new HashSet<>();
    localLabels.add(NOT_READY_FOR_MERGE);
    localLabels.add(NOT_REVIEWED);
    localLabels.add(TESTS_FAILURE);

    List<GHLabel> remoteLabels = new ArrayList<GHLabel>();
    for (int i = 0; i < localLabels.size(); i++) {
        remoteLabels.add(label);
    }

    commonExpectations(localLabels);
    when(issue.getLabels()).thenReturn(remoteLabels);
    when(label.getName()).thenReturn(TESTS_FAILURE);
    when(label.getName()).thenReturn(NOT_READY_FOR_MERGE);
    when(label.getName()).thenReturn(NOT_REVIEWED);

    GitHubPRLabelRemovedEvent instance = new GitHubPRLabelRemovedEvent(labels);
    GitHubPRCause cause = instance.check(null, remotePr, localPR, listener);
    Assert.assertNull(cause);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and there is one that was added and one that already exists.
 */
@Test
public void secondOfThreeLabelsWasAdded() throws IOException {
    Set<String> localLabels = new HashSet<>(Collections.singleton(LOCALLY_TESTED));

    List<GHLabel> remoteLabels = asList(testLabel, reviewedLabel);

    commonExpectations(localLabels);
    
    when(issue.getLabels()).thenReturn(remoteLabels);
    when(testLabel.getName()).thenReturn(LOCALLY_TESTED);
    when(reviewedLabel.getName()).thenReturn(REVIEWED);

    GitHubPRCause cause = new GitHubPRLabelAddedEvent(labels).check(null, remotePr, localPR, listener);
    assertNull(cause);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and all of them was already added.
 */
@Test
@Ignore
public void thirdOfThreeLabelsWasAdded() throws IOException {
    Set<String> localLabels = new HashSet<>(asList(LOCALLY_TESTED, MERGE));

    List<GHLabel> remoteLabels = asList(testLabel, reviewedLabel, mergeLabel);

    commonExpectations(localLabels);

    when(issue.getLabels()).thenReturn(remoteLabels);
    when(testLabel.getName()).thenReturn(LOCALLY_TESTED);
    when(reviewedLabel.getName()).thenReturn(REVIEWED);
    when(mergeLabel.getName()).thenReturn(MERGE);

    causeCreationExpectations();

    GitHubPRCause cause = new GitHubPRLabelAddedEvent(labels).check(null, remotePr, localPR, listener);
    assertThat(cause.getLabels(), equalTo(localLabels));
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and all of them was already added.
 */
@Test
public void allLabelsAlreadyExist() throws IOException {
    Set<String> localLabels = new HashSet<>(asList(LOCALLY_TESTED, MERGE, REVIEWED));
    List<GHLabel> remoteLabels = asList(testLabel, reviewedLabel, mergeLabel);

    commonExpectations(localLabels);

    when(issue.getLabels()).thenReturn(remoteLabels);
    when(testLabel.getName()).thenReturn(LOCALLY_TESTED);
    when(reviewedLabel.getName()).thenReturn(REVIEWED);
    when(mergeLabel.getName()).thenReturn(MERGE);

    GitHubPRLabelAddedEvent instance = new GitHubPRLabelAddedEvent(labels);
    GitHubPRCause cause = instance.check(null, remotePr, localPR, listener);
    assertNull(cause);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and no one of them was removed.
 */
@Test
public void noLabelsWasRemoved() throws IOException {
    Set<String> localLabels = new HashSet<>(asList(MERGE, REVIEWED, LOCALLY_TESTED));
    List<GHLabel> remoteLabels = asList(testLabel, reviewedLabel, mergeLabel);

    commonExpectations(localLabels);
    
    when(issue.getLabels()).thenReturn(remoteLabels);
    when(testLabel.getName()).thenReturn(LOCALLY_TESTED);
    when(reviewedLabel.getName()).thenReturn(REVIEWED);
    when(mergeLabel.getName()).thenReturn(MERGE);

    GitHubPRCause cause = new GitHubPRLabelAddedEvent(labels).check(null, remotePr, localPR, listener);
    assertNull(cause);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
public static boolean hasLabel(Collection<GHLabel> labels, String label) {
    if (labels != null) {
        for (GHLabel ghLabel : labels) {
            if (Objects.equal(label, ghLabel.getName())) {
                return true;
            }
        }
    }
    return false;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
public static boolean isSlackIssue(GHIssue issue) throws IOException {
	for (GHLabel label : issue.getLabels()) {
		for (String slackLabel : getSlackLabels()) {
			if (label.getName().equalsIgnoreCase(slackLabel)) {
				return true;
			}
		}
	}
	return false;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public GitHubPRCause check(GitHubPRTrigger gitHubPRTrigger, GHPullRequest remotePR,
                           @CheckForNull GitHubPRPullRequest localPR, TaskListener listener) throws IOException {
    if (remotePR.getState().equals(GHIssueState.CLOSED)) {
        return null; // already closed, skip check?
    }

    if (label == null) {
        LOG.error("Label is null. Bad configured event: {}", getDescriptor().getDisplayName());
        throw new IllegalStateException("Label is null. Bad configured event: " + getDescriptor().getDisplayName());
    }

    //localPR exists before, checking for changes
    if (localPR != null && localPR.getLabels().containsAll(label.getLabelsSet())) {
        return null; // label existed before exiting
    }

    GitHubPRCause cause = null;

    Collection<GHLabel> labels = remotePR.getRepository().getIssue(remotePR.getNumber()).getLabels();
    Set<String> existingLabels = new HashSet<String>();

    for (GHLabel curLabel : labels) {
        existingLabels.add(curLabel.getName());
    }

    if (existingLabels.containsAll(label.getLabelsSet())) {
        final PrintStream logger = listener.getLogger();
        logger.println(DISPLAY_NAME + ": state has changed (" + label.getLabelsSet() + " labels were added");
        cause = new GitHubPRCause(remotePR, label.getLabelsSet() + " labels were added", false);
    }

    return cause;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Override
public GitHubPRCause check(GitHubPRTrigger gitHubPRTrigger, GHPullRequest remotePR,
                           @CheckForNull GitHubPRPullRequest localPR, TaskListener listener) throws IOException {
    if (remotePR.getState().equals(GHIssueState.CLOSED)) {
        return null; // already closed, skip check?
    }

    GitHubPRCause cause = null;

    Collection<GHLabel> remoteLabels = remotePR.getRepository().getIssue(remotePR.getNumber()).getLabels();
    Set<String> existingLabels = new HashSet<>();

    for (GHLabel ghLabel : remoteLabels) {
        existingLabels.add(ghLabel.getName());
    }

    existingLabels.retainAll(label.getLabelsSet());

    if (existingLabels.isEmpty()) {
        final PrintStream logger = listener.getLogger();
        LOG.debug("{}:{} not found", DISPLAY_NAME, label.getLabelsSet());
        logger.println(DISPLAY_NAME + ": " + label.getLabelsSet() + " not found");
        cause = new GitHubPRCause(remotePR, label.getLabelsSet() + " labels not exist", isSkip());
    }

    return cause;
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
@Before
public void before() throws IOException {
    when(remotePr.getUser()).thenReturn(ghUser);
    when(remotePr.getHead()).thenReturn(ghCommitPointer);
    when(remotePr.getBase()).thenReturn(ghCommitPointer);
    when(ghCommitPointer.getSha()).thenReturn("1r134rsha324");
    when(ghCommitPointer.getRef()).thenReturn("some/branch");
    when(remotePr.getRepository()).thenReturn(ghRepository);
    when(ghRepository.getIssue(0)).thenReturn(ghIssue);
    when(ghIssue.getLabels()).thenReturn(Collections.<GHLabel>emptySet());
    when(remotePr.getState()).thenReturn(GHIssueState.OPEN);
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Case when there is three checked labels and all of them was already removed.
 */
@Test
public void threeOfThreeLabelsWasRemoved() throws IOException {
    Set<String> localLabels = new HashSet<>();
    localLabels.add(TESTS_FAILURE);

    commonExpectations(localLabels);
    when(issue.getLabels())
            .thenReturn(new ArrayList<GHLabel>());
    causeCreationExpectations();

    GitHubPRLabelRemovedEvent instance = new GitHubPRLabelRemovedEvent(labels);
    GitHubPRCause cause = instance.check(null, remotePr, localPR, listener);
    Assert.assertEquals("[tests failure, not reviewed, not ready for merge] labels were removed", cause.getReason());
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Returns issue label for release notes.
 * @param issue issue.
 * @return issue label for release notes
 * @throws IOException if an I/o error occurs.
 */
private static String getIssueLabelFrom(GHIssue issue) throws IOException {
    final Collection<GHLabel> issueLabels = issue.getLabels();
    final Optional<GHLabel> label = issueLabels.stream()
        .filter(input -> Arrays.binarySearch(Constants.ISSUE_LABELS, input.getName()) >= 0)
        .findFirst();
    return label.map(GHLabel::getName).orElse("");
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
private String toLabels(Collection<GHLabel> collection) {
	StringBuilder result = new StringBuilder();
	
	for (GHLabel label : collection) {
		if (result.length() > 0)
			result.append(", ");
		result.append(label.getName());
	}
	
	if (result.length() > 0)
		return result.toString();
	else
		return "Issue";
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
/**
 * Lets return the labels on an issue with retries
 */
public static Collection<GHLabel> getLabels(GHIssue issue) throws IOException {
    return retryGithub(() -> issue.getLabels());
}
 

import org.kohsuke.github.GHLabel; //导入依赖的package包/类
private void updateLabels(Collection<GHLabel> labels) {
    this.labels = new HashSet<>();
    for (GHLabel label : labels) {
        this.labels.add(label.getName());
    }
}