import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public boolean isExcluded(@NonNull SCMSourceRequest request, @NonNull SCMHead head) {
    if (head instanceof BranchSCMHead && request instanceof GiteaSCMSourceRequest) {
        for (GiteaPullRequest p : ((GiteaSCMSourceRequest) request).getPullRequests()) {
            // only match if the pull request is an origin pull request
            if (p.getBase().getRepo().getOwner().getUsername()
                    .equalsIgnoreCase(p.getHead().getRepo().getOwner().getUsername())
                    && p.getBase().getRepo().getName().equalsIgnoreCase(p.getHead().getRepo().getName())
                    && p.getHead().getRef().equals(head.getName())) {
                return true;
            }
        }
    }
    return false;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Test
public void given__child_file__when__content__then__contents_returned() throws Exception {
    ASFGitSCMFileSystem fs = new ASFGitSCMFileSystem(serverRootUrl + "/maven.git", new SCMHead("master"), null);
    assertThat(fs.getRoot().child(".gitignore").contentAsString(), is("target/\n"
            + ".project\n"
            + ".classpath\n"
            + ".settings/\n"
            + ".svn/\n"
            + "bin/\n"
            + "# Intellij\n"
            + "*.ipr\n"
            + "*.iml\n"
            + ".idea\n"
            + "out/\n"
            + ".DS_Store\n"
            + "/bootstrap\n"
            + "/dependencies.xml\n"
            + ".java-version\n"));
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@SuppressWarnings("SimplifiableIfStatement")
private boolean isAutomaticBuild(GitLabSCMSource source, SCMHead head) {
    if (head instanceof TagSCMHead) {
        return source.getSourceSettings().getTagMonitorStrategy().getBuild();
    }

    if (head instanceof GitLabSCMBranchHead) {
        return !((GitLabSCMBranchHead) head).hasMergeRequest() || source.getSourceSettings().getBranchMonitorStrategy().getBuildBranchesWithMergeRequests();
    }

    if (head instanceof GitLabSCMMergeRequestHead) {
        return isAutomaticBuild(source, (GitLabSCMMergeRequestHead) head);
    }

    return true;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Nonnull
private List<Action> retrieve(@Nonnull SCMRevisionImpl revision, @CheckForNull SCMHeadEvent event, @Nonnull TaskListener listener) throws IOException, InterruptedException {
    List<Action> actions = new ArrayList<>();

    String hash = revision.getHash();
    Action linkAction = GitLabLinkAction.toCommit(source.getProject(), hash);
    actions.add(linkAction);

    SCMHead head = revision.getHead();
    if (head instanceof GitLabSCMMergeRequestHead) {
        actions.add(createHeadMetadataAction(head.getName(), ((GitLabSCMMergeRequestHead) head).getSource(), hash, linkAction.getUrlName()));
    } else if (head instanceof GitLabSCMHead) {
        actions.add(createHeadMetadataAction(head.getName(), (GitLabSCMHead) head, hash, linkAction.getUrlName()));
    }

    if (event instanceof GitLabSCMEvent) {
        actions.add(new GitLabSCMCauseAction(((GitLabSCMEvent) event).getCause()));
    }

    return actions;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Nonnull
@Override
public Branch getBranch(@Nonnull P project) {
    BranchProjectProperty property = project.getProperty(BranchProjectProperty.class);

    /*
     * Ugly hackish stuff, in the event that the user configures a branch project directly, thereby removing the
     * BranchProjectProperty.  The property must exist and we can't bash the @Nonnull return value restriction!
     *
     * Fudge some generic Branch with the expectation that indexing will soon reset the Branch with proper values,
     * or that it will be converted to Branch.Dead and the guessed values for sourceId and properties won't matter.
     */
    if (property == null) {
        Branch branch = new Branch("unknown", new SCMHead(project.getDisplayName()), project.getScm(),
                Collections.<BranchProperty>emptyList());
        setBranch(project, branch);
        return branch;
    }

    return property.getBranch();
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected Result doRun(BuildListener listener)
    throws IOException, InterruptedException {

  // Attach an SCMRevisionAction with our revision
  {
    final SCMHead head = getParent().getBranch().getHead();
    final SCMSource source = getParent().getSource();
    final SCMRevision revision = source.fetch(head, listener);
    TestBuild.this.addAction(new SCMRevisionAction(checkNotNull(revision)));
  }

  try {
    project.innerItem.scheduleBuild2(0,
        new Cause.UpstreamCause(TestBuild.this)).get();
  } catch (ExecutionException e) {
    return Result.FAILURE;
  }
  return Result.SUCCESS;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Override
public PerforceScm build(SCMHead head, SCMRevision revision) {
	if (head instanceof P4Head && revision instanceof P4Revision) {
		P4Head perforceHead = (P4Head) head;
		P4Revision perforceRevision = (P4Revision) revision;

		// Build workspace from 'head' paths
		List<P4Path> paths = perforceHead.getPaths();
		Workspace workspace = getWorkspace(paths);

		// Build populate from revision
		String pin = perforceRevision.getRef().toString();
		Populate populate = new GraphHybridImpl(true, pin, null);
		PerforceScm scm = new PerforceScm(getCredential(), workspace, null, populate, getBrowser());
		return scm;
	} else {
		throw new IllegalArgumentException("SCMHead and/or SCMRevision not a Perforce instance!");
	}
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
public static PullRequestSCMHead getPullRequest(@Nonnull final Job job) throws Exception {
    PullRequestSCMHead head = (PullRequestSCMHead) SCMHead.HeadByItem.findHead(job);
    if (head == null) {
        throw new IllegalStateException("Build is not a pull request");
    }
    return head;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Override
public void start(final WorkflowJob project, final boolean newInstance) {
    super.start(project, newInstance);
    // we only care about pull requests
    if (SCMHead.HeadByItem.findHead(project) instanceof PullRequestSCMHead) {
        DescriptorImpl.jobs.put(getKey(project), project);
    }
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
private String getKey(final WorkflowJob project) {
    GitHubSCMSource scmSource = (GitHubSCMSource) SCMSource.SourceByItem.findSource(project);
    PullRequestSCMHead scmHead = (PullRequestSCMHead) SCMHead.HeadByItem.findHead(project);

    return String.format("%s/%s/%d",
            scmSource.getRepoOwner(),
            scmSource.getRepository(),
            scmHead.getNumber());
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Nonnull
@Override
public Collection<GlobalVariable> forRun(final Run<?, ?> run) {
    if (run == null) {
        return Collections.emptyList();
    }
    SCMHead scmHead = SCMHead.HeadByItem.findHead(run.getParent());
    if (scmHead instanceof PullRequestSCMHead) {
        Collection<GlobalVariable> result = new LinkedList<>();
        result.add(new PullRequestGlobalVariable());
        return result;
    }
    return Collections.emptyList();
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@NonNull
@Override
public Map<SCMHead, SCMRevision> headsFor(GiteaSCMSource source) {
    String ref = getPayload().getRef();
    ref = ref.startsWith(Constants.R_HEADS) ? ref.substring(Constants.R_HEADS.length()) : ref;
    BranchSCMHead h = new BranchSCMHead(ref);
    return Collections.<SCMHead, SCMRevision>singletonMap(h,
            StringUtils.isNotBlank(getPayload().getAfter())
                    ? new BranchSCMRevision(h, getPayload().getAfter()) : null);
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * Constructor.
 *
 * @param source   the source.
 * @param context  the context.
 * @param listener the listener.
 */
GiteaSCMSourceRequest(SCMSource source, GiteaSCMSourceContext context, TaskListener listener) {
    super(source, context, listener);
    fetchBranches = context.wantBranches();
    fetchTags = context.wantTags();
    fetchOriginPRs = context.wantOriginPRs();
    fetchForkPRs = context.wantForkPRs();
    originPRStrategies = fetchOriginPRs && !context.originPRStrategies().isEmpty()
            ? Collections.unmodifiableSet(EnumSet.copyOf(context.originPRStrategies()))
            : Collections.<ChangeRequestCheckoutStrategy>emptySet();
    forkPRStrategies = fetchForkPRs && !context.forkPRStrategies().isEmpty()
            ? Collections.unmodifiableSet(EnumSet.copyOf(context.forkPRStrategies()))
            : Collections.<ChangeRequestCheckoutStrategy>emptySet();
    Set<SCMHead> includes = context.observer().getIncludes();
    if (includes != null) {
        Set<Long> pullRequestNumbers = new HashSet<>(includes.size());
        Set<String> branchNames = new HashSet<>(includes.size());
        Set<String> tagNames = new HashSet<>(includes.size());
        for (SCMHead h : includes) {
            if (h instanceof BranchSCMHead) {
                branchNames.add(h.getName());
            } else if (h instanceof PullRequestSCMHead) {
                pullRequestNumbers.add(Long.parseLong(((PullRequestSCMHead) h).getId()));
                if (SCMHeadOrigin.DEFAULT.equals(h.getOrigin())) {
                    branchNames.add(((PullRequestSCMHead) h).getOriginName());
                }
            } else if (h instanceof TagSCMHead) { // TODO replace with concrete class when tag support added
                tagNames.add(h.getName());
            }
        }
        this.requestedPullRequestNumbers = Collections.unmodifiableSet(pullRequestNumbers);
        this.requestedOriginBranchNames = Collections.unmodifiableSet(branchNames);
        this.requestedTagNames = Collections.unmodifiableSet(tagNames);
    } else {
        requestedPullRequestNumbers = null;
        requestedOriginBranchNames = null;
        requestedTagNames = null;
    }
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@NonNull
@Override
public Map<SCMHead, SCMRevision> headsFor(GiteaSCMSource source) {
    String ref = getPayload().getRef();
    ref = ref.startsWith(Constants.R_HEADS) ? ref.substring(Constants.R_HEADS.length()) : ref;
    BranchSCMHead h = new BranchSCMHead(ref);
    return Collections.<SCMHead, SCMRevision>singletonMap(h, new BranchSCMRevision(h, getPayload().getSha()));
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * Constructor.
 *
 * @param source   the {@link GiteaSCMSource}.
 * @param head     the {@link SCMHead}
 * @param revision the (optional) {@link SCMRevision}
 */
public GiteaSCMBuilder(@NonNull GiteaSCMSource source,
                       @NonNull SCMHead head, @CheckForNull SCMRevision revision) {
    super(
            head,
            revision,
            checkoutUriTemplate(null, source.getServerUrl(), null, null)
                    .set("owner", source.getRepoOwner())
                    .set("repository", source.getRepository())
                    .expand(),
            source.getCredentialsId()
    );
    this.context = source.getOwner();
    serverUrl = source.getServerUrl();
    repoOwner = source.getRepoOwner();
    repository = source.getRepository();
    sshRemote = source.getSshRemote();
    // now configure the ref specs
    withoutRefSpecs();
    String repoUrl;
    if (head instanceof PullRequestSCMHead) {
        PullRequestSCMHead h = (PullRequestSCMHead) head;
        withRefSpec("+refs/pull/" + h.getId() + "/head:refs/remotes/@{remote}/" + head
                .getName());
        repoUrl = repositoryUrl(h.getOriginOwner(), h.getOriginRepository());
    } else {
        withRefSpec("+refs/heads/" + head.getName() + ":refs/remotes/@{remote}/" + head.getName());
        repoUrl = repositoryUrl(repoOwner, repository);
    }
    // pre-configure the browser
    withBrowser(new GiteaBrowser(repoUrl));
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Override
protected SCMRevision retrieve(@NonNull SCMHead head, @NonNull TaskListener listener)
        throws IOException, InterruptedException {
    try (GiteaConnection c = gitea().open()) {
        if (head instanceof BranchSCMHead) {
            listener.getLogger().format("Querying the current revision of branch %s...%n", head.getName());
            String revision = c.fetchBranch(repoOwner, repository, head.getName()).getCommit().getId();
            listener.getLogger().format("Current revision of branch %s is %s%n", head.getName(), revision);
            return new BranchSCMRevision((BranchSCMHead) head, revision);
        } else if (head instanceof PullRequestSCMHead) {
            PullRequestSCMHead h = (PullRequestSCMHead) head;
            listener.getLogger().format("Querying the current revision of pull request #%s...%n", h.getId());
            GiteaPullRequest pr =
                    c.fetchPullRequest(repoOwner, repository, Long.parseLong(h.getId()));
            if (pr.getState() == GiteaIssueState.OPEN) {
                listener.getLogger().format("Current revision of pull request #%s is %s%n",
                        h.getId(), pr.getHead().getSha());
                return new PullRequestSCMRevision(
                        h,
                        new BranchSCMRevision(
                                h.getTarget(),
                                pr.getBase().getSha()
                        ),
                        new BranchSCMRevision(
                                new BranchSCMHead(h.getOriginName()),
                                pr.getHead().getSha()
                        )
                );
            } else {
                listener.getLogger().format("Pull request #%s is CLOSED%n", h.getId());
                return null;
            }
        } else {
            listener.getLogger().format("Unknown head: %s of type %s%n", head.getName(), head.getClass().getName());
            return null;
        }
    }
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@NonNull
@Override
protected Set<String> retrieveRevisions(@NonNull TaskListener listener) throws IOException, InterruptedException {
    // don't pass through to git, instead use the super.super behaviour
    Set<String> revisions = new HashSet<String>();
    for (SCMHead head : retrieve(listener)) {
        revisions.add(head.getName());
    }
    return revisions;
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
/**
 * Constructor.
 *
 * @param remote the remote.
 * @param head   the head.
 * @param rev    the revision.
 */
public ASFGitSCMFileSystem(String remote, SCMHead head, SCMRevision rev) {
    super(rev instanceof AbstractGitSCMSource.SCMRevisionImpl ? rev : null);
    this.remote = remote;
    this.refOrHash = rev instanceof AbstractGitSCMSource.SCMRevisionImpl
            ? ((AbstractGitSCMSource.SCMRevisionImpl) rev).getHash()
            : (head instanceof GitTagSCMHead
                    ? Constants.R_TAGS + head.getName()
                    : Constants.R_HEADS + head.getName());
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Test
public void given__root__when__children__then__children_returned() throws Exception {
    ASFGitSCMFileSystem fs = new ASFGitSCMFileSystem(serverRootUrl + "/maven.git", new SCMHead("master"), null);
    SCMFile root = fs.getRoot();
    Iterable<SCMFile> children = root.children();
    Set<String> names = new TreeSet<>();
    for (SCMFile f : children) {
        names.add(f.getName());
    }
    assertThat(names, containsInAnyOrder(
            ".gitattributes",
            ".gitignore",
            "Jenkinsfile",
            "LICENSE",
            "NOTICE",
            "README.md",
            "apache-maven",
            "deploySite.sh",
            "doap_Maven.rdf",
            "maven-artifact",
            "maven-builder-support",
            "maven-compat",
            "maven-core",
            "maven-embedder",
            "maven-model-builder",
            "maven-model",
            "maven-plugin-api",
            "maven-repository-metadata",
            "maven-resolver-provider",
            "maven-settings-builder",
            "maven-settings",
            "maven-slf4j-provider",
            "pom.xml",
            "src"
    ));
}
 

import jenkins.scm.api.SCMHead; //导入依赖的package包/类
@Test
public void given__child__when__children__then__children_returned() throws Exception {
    ASFGitSCMFileSystem fs = new ASFGitSCMFileSystem(serverRootUrl + "/maven.git", new SCMHead("master"), null);
    SCMFile root = fs.getRoot().child("maven-settings");
    Iterable<SCMFile> children = root.children();
    Set<String> names = new TreeSet<>();
    for (SCMFile f : children) {
        names.add(f.getName());
    }
    assertThat(names, containsInAnyOrder(
            "pom.xml",
            "src"
    ));
}