1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
// maybe wait a few seconds to be sure a Jenkins job was created. This happens at the caller.
// make request to [branch]-branches
// if it comes back successfully with a `builds` hash
// request all URLs in `builds`
// if its `displayName` matches [branch]-commitsha{5}
// check `result` ('SUCCESS', 'FAILURE', nonexistent)
// update GitHub commit status
// if pending
// start a thread that checks every 30 seconds for the `result` and update GitHub commit status
// if time spent > 20 minutes
// set GH commit status to error (timeout)
// if `result` is successful or failed, update status and stop
// set GH status to error (no job found)
// fn update_github_status(commit_ref)
// fn get_jobs(repo_name)
// fn af83 job name from commit_ref (separate af83 module)
// fn update_github_commit_status(status, message) (lives in GitHub module)
// fn request_job(url)
// fn result_from_job(payload)
extern crate json;
extern crate reqwest;
use self::reqwest::header::{Authorization, Basic};
#[derive(Debug, PartialEq, Eq)]
pub enum JobStatus {
Success,
Failure,
Pending,
Unknown,
}
struct Job {
display_name: String,
result: String,
}
pub fn update_commit_status(commit_ref) {
let jobs = get_jobs();
for job_url in jobs {
let payload = request_job(job_url);
// Does `displayName` match
if job_for_commit(payload, commit_ref) {
// spawn thread
let status = result_from_job(payload);
}
}
}
pub fn auth_credentials() -> Basic {
Basic {
username: "username".to_string(),
password: Some("token".to_string()),
}
}
pub fn get_jobs(repo_name: String) {//-> Vec<String> {
let client = reqwest::Client::new();
let credentials = auth_credentials();
let mut res = client.get("http://jenkins.example.com/job/changes-branches/18/api/json")
.header(Authorization(credentials))
.send()
.unwrap();
println!("{}", res.status());
}
// Does the `commit_ref` correspond to the job in the `payload`?
pub fn job_for_commit(payload: String, commit_ref: CommitRef) -> bool {
}
pub fn result_from_job(payload: String) -> JobStatus {
let mut job = json::parse(payload.as_ref()).unwrap();
if job["result"].is_null() {
return JobStatus::Pending
}
let status = job["result"].take_string().unwrap();
if status == "SUCCESS" {
JobStatus::Success
} else if status == "FAILURE" {
JobStatus::Failure
} else {
JobStatus::Unknown
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn get_jobs_queries_jobs_from_jenkins_api() {
get_jobs("changes".to_string());
}
#[test]
fn result_from_job_is_success() {
let payload = r#"{
"result": "SUCCESS"
}"#;
assert_eq!(
result_from_job(payload.to_owned()),
JobStatus::Success
);
}
#[test]
fn result_from_job_is_failure() {
let payload = r#"{
"result": "FAILURE"
}"#;
assert_eq!(
result_from_job(payload.to_owned()),
JobStatus::Failure
);
}
#[test]
fn result_from_job_is_pending() {
let payload = r#"{
}"#;
assert_eq!(
result_from_job(payload.to_owned()),
JobStatus::Pending
);
}
}
|
