blob: 609fa37c95f52afccfb0733f5be70d34dfb21c23 (
plain)
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
|
// 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 reqwest;
use self::reqwest::header::{Authorization, Basic};
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());
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn get_jobs_queries_jobs_from_jenkins_api() {
get_jobs("changes".to_string());
}
}
|
