import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
/**
 * Wait for the build to be queued and complete
 *
 * @param jenkins          Jenkins server instance
 * @param expectedBuildNbr the build number we're are expecting
 * @param timeOut          the maximum time in millisecond we are waiting
 * @throws InterruptedException the build was interrupted
 * @throws TimeoutException     we exeeded the timeout period.
 * @throws IOException          an unexpected error occurred while communicating with Jenkins
 */
private void waitForBuildToComplete(JenkinsServer jenkins, int expectedBuildNbr, long timeOut) throws InterruptedException, TimeoutException, IOException {
    boolean buildCompleted = false;
    Long timeoutCounter = 0L;
    while (!buildCompleted) {
        Thread.sleep(2000);
        timeoutCounter = timeoutCounter + 2000L;
        if (timeoutCounter > timeOut) {
            throw new TimeoutException("The job did not complete in the expected time");
        }
        //When the build is in the queue, the nextbuild number didn't change.
        //When it changed, It might still be running.
        JobWithDetails wrkJobData = jenkins.getJob(JENKINS_JOB_NAME);
        int newNextNbr = wrkJobData.getNextBuildNumber();
        log.info("New Next Nbr:" + newNextNbr);
        if (expectedBuildNbr != newNextNbr) {
            log.info("The expected build is there");
            boolean isBuilding = wrkJobData.getLastBuild().details().isBuilding();
            if (!isBuilding) {
                buildCompleted = true;
            }
        }
    }
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void testCreateJob() throws Exception {
    final String sourceJob = "pr";
    final String jobName = "test-job-" + UUID.randomUUID().toString();

    String sourceXml = server.getJobXml(sourceJob);

    server.createJob(jobName, sourceXml);

    Map<String, Job> jobs = server.getJobs();
    assertTrue(jobs.containsKey(jobName));
    JobWithDetails thisJob = jobs.get(jobName).details();
    assertNotNull(thisJob);
    assertTrue(thisJob.getBuilds().size() == 0);
    thisJob.build(ImmutableMap.of("foo_param", "MUST_PROVIDE_VALUES_DEFAULTS_DONT_WORK"));

    // wait to see if the job finishes, but with a timeout
    Future<Void> future = executor.submit(new PerformPollingTest(server, jobName));

    // If this times out, either jenkins is slow or our test failed!
    // IME, usually takes about 10-15 seconds
    future.get(30, TimeUnit.SECONDS);

    Build b = server.getJobs().get(jobName).details().getLastSuccessfulBuild();
    assertTrue(b != null);
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void testStopBuildById() throws IOException, InterruptedException {
    
    String jobName = "testing-jenkins-api";
    String parameterNameForJob = "ParamForTesting";
    final ImmutableMap<String, String> params = ImmutableMap.of(parameterNameForJob, "master");
    
    BuildVerifier buildVerifier = CollectorApi.getJenkinsVerifier();
    JenkinsServer jenkninsServer = CollectorApi.getJenkinsServer();
    JobWithDetails job = jenkninsServer.getJob(jobName);
    int nextBuildNumber = job.getNextBuildNumber();
    job.build(params);
    Thread.sleep(5000);
    boolean stopBuildResult =
            ((JenkinsVerifier) buildVerifier).stop(jobName, Integer.toString(nextBuildNumber));
    Assert.assertEquals(true, stopBuildResult);
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public void runJobIfFailing(String test, JSONObject repository) throws Exception {
    String jobName = ConfigParser.parseConfigString(repository.getString("jobName"), test);

    JobWithDetails job = jenkins.getJob(jobName);
    if (job == null) {
        System.out.println("Job not yet created, skipping: [" + jobName + "]");
        return;
    }
    Build lastBuild = job.getLastBuild();
    if (lastBuild == null) {
        runJob(test, repository);
        return;
    }
    BuildResult lastResult = lastBuild.details().getResult();
    if (lastResult != null && lastResult.equals(BuildResult.FAILURE)) {
        runJob(test, repository);
    }
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public static JobWithDetails assertJobExists(JenkinsServer jenkins, String jobName) {
    JobWithDetails job = tryFindJob(jenkins, jobName);
    if (job != null) {
        return job;
    }
    fail("No job found called `" + jobName + "` for jenkins at " + jenkins);
    return job;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public static void assertJobLastBuildIsSuccessful(long timeMillis, final JenkinsServer jenkins, final String jobName) throws Exception {
    Asserts.assertWaitFor(timeMillis, new Block() {
        @Override
        public void invoke() throws Exception {
            JobWithDetails job = assertJobExists(jenkins, jobName);
            Build lastBuild = job.getLastBuild();
            assertNotNull("No lastBuild for job `" + jobName + "`", lastBuild);
            System.out.println("Last build of `" + jobName + "` at " + lastBuild.getUrl());
            Build lastSuccessfulBuild = job.getLastSuccessfulBuild();
            assertNotNull("No lastSuccessfulBuild for job `" + jobName + "` at: " + lastBuild.getUrl(), lastSuccessfulBuild);
            assertEquals("Last successful build number was not the last build number: " + lastBuild.getUrl(), lastBuild.getNumber(), lastSuccessfulBuild.getNumber());
            System.out.println("Successful build of `" + jobName + "` at " + lastSuccessfulBuild.getUrl());
        }
    });
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
protected static JobWithDetails tryFindJob(JenkinsServer jenkins, String jobName) {
    for (int i = 0; i < 15; i++) {
        try {
            return jenkins.getJob(jobName);
        } catch (IOException e) {
            LOG.info("Caught: " + e, e);
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e1) {
                // ignore
            }
        }
    }
    return null;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void testBuild() throws IOException {
    
	String jobName = "testing-jenkins-api";
    String parameterNameForJob = "ParamForTesting";
    final ImmutableMap<String, String> params = ImmutableMap.of(parameterNameForJob, "master");
    JenkinsServer jenkninsServer = CollectorApi.getJenkinsServer();
    JobWithDetails job = jenkninsServer.getJob(jobName);
    job.build(params);
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
/**
 * Get a single Job from the server.
 * 
 * @return A single Job, null if not present
 * @throws IOException
 */
public JobWithDetails getJob(String jobName) throws IOException {
	try {
		JobWithDetails job = client.get("/job/" + encode(jobName),
				JobWithDetails.class);
		// JobWithDetails job = client.get("/job/" + jobName, JobWithDetails.class);
		job.setClient(client);

		return job;
	} catch (HttpResponseException e) {
		if (e.getStatusCode() == 404) {
			return null;
		}
		throw e;
	}

}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public static JobWithDetails assertJob(String projectName) throws URISyntaxException, IOException {
    JenkinsServer jenkins = createJenkinsServer();
    JobWithDetails job = jenkins.getJob(projectName);
    assertThat(job).describedAs("No Jenkins Job found for name: " + projectName).isNotNull();
    return job;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
/**
 * Loads the marker file of the last build (archived during the build)
 *
 * @param jenkins the jenkins instance we want to load from
 * @return the marker file loaded as a property file (so that it can be easily queried)
 * @throws IOException        Something unexpected went wrong when querying the Jenkins server
 * @throws URISyntaxException Something uunexpected went wrong loading the marker as a property
 */
private Properties loadMarkerArtifactAsProperty(JenkinsServer jenkins) throws IOException, URISyntaxException {
    JobWithDetails detailedJob = jenkins.getJob(JENKINS_JOB_NAME);
    BuildWithDetails lastBuild = detailedJob.getLastBuild().details();
    int buildNbr = lastBuild.getNumber();
    boolean isBuilding = lastBuild.isBuilding();
    log.info("BuildNbr we are examining: " + buildNbr);

    List<Artifact> artifactList = lastBuild.getArtifacts();
    assertEquals("Not the expected number of artifacts", 1, artifactList.size());

    Artifact markerArtifact = artifactList.get(0);
    String markerArtifactFileName = markerArtifact.getFileName();
    assertEquals("The artifact is not the expected one", "marker.txt", markerArtifactFileName);
    InputStream markerArtifactInputStream = lastBuild.details().downloadArtifact(markerArtifact);
    String markerAsText = IOUtils.toString(markerArtifactInputStream, Charset.defaultCharset());
    log.info("\n" + markerAsText);
    StringReader reader = new StringReader(markerAsText);
    Properties markerAsProperty = new Properties();
    markerAsProperty.load(reader);

    //check if the marker matches the build number we expect.
    String buildNbrFromMarker = markerAsProperty.getProperty("BUILD_NUMBER");
    String buildNbrFromQery = String.valueOf(buildNbr);
    assertEquals("The build number from the marker does not match the last build number", buildNbrFromMarker, buildNbrFromQery);
    return markerAsProperty;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public static Build assertJobHasBuild(JenkinsServer jenkins, String jobName) {
    JobWithDetails job = assertJobExists(jenkins, jobName);
    Build lastBuild = job.getLastBuild();
    assertNotNull("No lastBuild for job `" + jobName + "`", lastBuild);
    return lastBuild;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void shouldReturnBuildStatusForBuild() throws Exception {
    JobWithDetails job = server.getJobs().get("pr").details();
    BuildWithDetails build = job.getBuilds().get(0).details();
    assertEquals(BuildResult.SUCCESS, build.getResult());
    assertEquals("foobar", build.getParameters().get("REVISION"));
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void testGetJobByName() throws Exception {
    final String jobName = "trunk";

    JobWithDetails job = server.getJob(jobName);

    assertEquals("trunk",job.getName());
    assertEquals("trunk",job.getDisplayName());
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void testGetJobByNameDoesntExist() throws Exception {
    final String jobName = "imprettysurethereisnojobwiththisname";

    JobWithDetails job = server.getJob(jobName);

    assertEquals(null, job);
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public Void call() throws InterruptedException, IOException {
    while(true) {
        Thread.sleep(500);
        JobWithDetails jwd = server.getJobs().get(jobName).details();

        try {
            // Throws NPE until the first build succeeds
            jwd.getLastSuccessfulBuild();
        } catch (NullPointerException e) {
            continue;
        }
        // build succeeded
        return null;
    }
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Override
public boolean stop(String jobName, String buildIdToStop) {
    //TODO: Remove unnecessary calls to Jenkins for stopping a Build. Try to minimize the number of calls.   
    boolean ans = false;
    try {
        VerigreenLogger.get().log(
                getClass().getName(),
                RuntimeUtils.getCurrentMethodName(),
                String.format("Stopping build (%s)", buildIdToStop));
        JobWithDetails job = CollectorApi.getJenkinsServer().getJob(jobName);
        Build buildToStop = job.getBuildByNumber(Integer.parseInt(buildIdToStop));
        if (buildIdToStop != null) {
            buildToStop.Stop();
            ans = buildToStop.details().getResult().equals(BuildResult.ABORTED);
        } else {
            VerigreenLogger.get().error(
                    getClass().getName(),
                    RuntimeUtils.getCurrentMethodName(),
                    String.format(
                            "There is no build number [%s] for job [%s]",
                            buildIdToStop,
                            jobName));
        }
    } catch (Throwable e) {
        VerigreenLogger.get().error(
                getClass().getName(),
                RuntimeUtils.getCurrentMethodName(),
                String.format("Failed to stop build [%s] for job [%s]", buildIdToStop, jobName),
                e);
    }
    
    return ans;
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
protected Build assertCodeChangeTriggersWorkingBuild(final String projectName, Build firstBuild) throws Exception {
    File cloneDir = new File(getBasedir(), "target/projects/" + projectName);

    String gitUrl = asserGetAppGitCloneURL(forgeClient, projectName);
    Git git = ForgeClientAsserts.assertGitCloneRepo(gitUrl, cloneDir);

    // lets make a dummy commit...
    File readme = new File(cloneDir, "ReadMe.md");
    boolean mustAdd = false;
    String text = "";
    if (readme.exists()) {
        text = IOHelpers.readFully(readme);
    } else {
        mustAdd = true;
    }
    text += "\nupdated at: " + new Date();
    Files.writeToFile(readme, text, Charset.defaultCharset());

    if (mustAdd) {
        AddCommand add = git.add().addFilepattern("*").addFilepattern(".");
        add.call();
    }


    LOG.info("Committing change to " + readme);

    CommitCommand commit = git.commit().setAll(true).setAuthor(forgeClient.getPersonIdent()).setMessage("dummy commit to trigger a rebuild");
    commit.call();
    PushCommand command = git.push();
    command.setCredentialsProvider(forgeClient.createCredentialsProvider());
    command.setRemote("origin").call();

    LOG.info("Git pushed change to " + readme);

    // now lets wait for the next build to start
    int nextBuildNumber = firstBuild.getNumber() + 1;


    Asserts.assertWaitFor(10 * 60 * 1000, new Block() {
        @Override
        public void invoke() throws Exception {
            JobWithDetails job = assertJob(projectName);
            Build lastBuild = job.getLastBuild();
            assertThat(lastBuild.getNumber()).describedAs("Waiting for latest build for job " + projectName + " to start").isGreaterThanOrEqualTo(nextBuildNumber);
        }
    });

    return ForgeClientAsserts.assertBuildCompletes(forgeClient, projectName);
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
@Test
public void shouldReturnBuildsForJob() throws Exception {
    JobWithDetails job = server.getJobs().get("trunk").details();
    assertEquals(5, job.getBuilds().get(0).getNumber());
}
 

import com.offbytwo.jenkins.model.JobWithDetails; //导入依赖的package包/类
public JobWithDetails getJobDetails() {
	return jobDetails;
}