diff options
| -rw-r--r-- | src/jenkins.rs | 41 |
1 files changed, 39 insertions, 2 deletions
diff --git a/src/jenkins.rs b/src/jenkins.rs index 7b17b5c..b491a75 100644 --- a/src/jenkins.rs +++ b/src/jenkins.rs @@ -26,6 +26,8 @@ extern crate reqwest; extern crate url; use std::thread; +use std::thread::sleep; +use std::time::{Duration, Instant}; use self::reqwest::header::{Authorization, Basic}; use self::url::Url; @@ -80,6 +82,7 @@ pub fn find_and_track_build_and_update_status( commit_ref: CommitRef ) { let jobs = get_jobs(repo_name); + let t20_minutes = 60 * 20; for job_url in jobs { let job = request_job(job_url.as_ref()); @@ -88,16 +91,20 @@ pub fn find_and_track_build_and_update_status( if job_for_commit(&job, &commit_ref) { thread::spawn(move || { // Start timer + let now = Instant::now(); + + let job_status = job.result; + let commit_status = job_status.commit_status(); github::update_commit_status( &commit_ref, - &job.result.commit_status(), + &commit_status, job_url.clone(), None, "continuous-integration/jenkins".to_string() ); - if job.result == JobStatus::Pending { + if job_status == JobStatus::Pending { // loop // if timer > 20 minutes // call github::update_commit_status with timeout error @@ -107,6 +114,36 @@ pub fn find_and_track_build_and_update_status( // if the status is different // call github::update_commit_status // stop + + loop { + if now.elapsed().as_secs() == t20_minutes { + github::update_commit_status( + &commit_ref, + &github::CommitStatus::Error, + job_url.clone(), + Some("The status checker timed out.".to_string()), + "continuous-integration/jenkins".to_string() + ); + + return + } + + sleep(Duration::from_secs(30)); + + let job = request_job(job_url.as_ref()); + + if job.result != job_status { + github::update_commit_status( + &commit_ref, + &job.result.commit_status(), + job_url.clone(), + None, + "continuous-integration/jenkins".to_string() + ); + + return + } + } } }); |