`find_and_track_build_and_update_status`: Fill in thread status polling

Inside the thread, while the job is pending, poll the job on Jenkins
until either its status changes (to success or failed), or until 20
minutes have passed.

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
+                        }
+                    }
                 }
             });