From 1c97796ad13fdc5d78d44a459be3286e8d79530b Mon Sep 17 00:00:00 2001
From: Teddy Wing
Date: Thu, 9 Nov 2017 22:01:10 +0100
Subject: `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.
---
 src/jenkins.rs | 41 +++++++++++++++++++++++++++++++++++++++--
 1 file changed, 39 insertions(+), 2 deletions(-)

(limited to 'src')

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
+                        }
+                    }
                 }
             });
 
-- 
cgit v1.2.3