codealong-github 0.1.1

Codealong Github support
Documentation 
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

use codealong;
use git2;
use reqwest;

error_chain! {
    errors {
        RateLimitted {}
        Unknown {}
    }

    foreign_links {
        Git2(git2::Error);
        IO(std::io::Error);
        Reqwest(reqwest::Error);
    }

    links {
        Core(codealong::Error, codealong::ErrorKind);
    }
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ErrorPayload {
    pub message: String,
    pub documentation_url: Option<String>,
}

const MAX_RETRY: u64 = 4;
const RETRY_INTERVAL_SECONDS: u64 = 60;

pub fn retry_when_rate_limited(
    f: &mut FnMut() -> Result<reqwest::Response>,
    mut cb: Option<&mut FnMut(u64)>,
) -> Result<reqwest::Response> {
    for _ in 0..MAX_RETRY {
        match f() {
            Err(Error(ErrorKind::RateLimitted, _)) => {
                if let Some(ref mut cb) = cb {
                    cb(RETRY_INTERVAL_SECONDS);
                }
                std::thread::sleep(std::time::Duration::new(RETRY_INTERVAL_SECONDS, 0));
            }
            r => return r,
        }
    }
    Err(ErrorKind::RateLimitted.into())
}