octocrab 0.49.9

A modern, extensible GitHub API client.
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
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

use std::sync::Arc;

use http::{header::AUTHORIZATION, request::Request, HeaderValue, Uri};
use tower::{Layer, Service};

#[derive(Clone)]
/// Layer that adds the authentication header to github-bound requests
pub struct AuthHeaderLayer {
    pub(crate) auth_header: Arc<Option<HeaderValue>>,
    base_uri: Uri,
    upload_uri: Uri,
}

impl AuthHeaderLayer {
    pub fn new(auth_header: Option<HeaderValue>, base_uri: Uri, upload_uri: Uri) -> Self {
        AuthHeaderLayer {
            auth_header: Arc::new(auth_header),
            base_uri,
            upload_uri,
        }
    }
}

impl<S> Layer<S> for AuthHeaderLayer {
    type Service = AuthHeader<S>;

    fn layer(&self, inner: S) -> Self::Service {
        AuthHeader {
            inner,
            auth_header: self.auth_header.clone(),
            base_uri: self.base_uri.clone(),
            upload_uri: self.upload_uri.clone(),
        }
    }
}

#[derive(Clone)]
/// Service that adds a static set of extra headers to each request
pub struct AuthHeader<S> {
    inner: S,
    pub(crate) auth_header: Arc<Option<HeaderValue>>,
    base_uri: Uri,
    upload_uri: Uri,
}

impl<S, ReqBody> Service<Request<ReqBody>> for AuthHeader<S>
where
    S: Service<Request<ReqBody>>,
{
    type Error = S::Error;
    type Future = S::Future;
    type Response = S::Response;

    fn poll_ready(
        &mut self,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Result<(), Self::Error>> {
        self.inner.poll_ready(cx)
    }

    fn call(&mut self, mut req: Request<ReqBody>) -> Self::Future {
        // Only set the auth_header if the authority (host) is destined for
        // GitHub. Otherwise, leave it off as we could have been redirected
        // away from GitHub (via follow_location_to_data()), and we don't
        // want to give our credentials to third-party services.
        let authority = req.uri().authority();
        let allowed_authorities = [self.base_uri.authority(), self.upload_uri.authority()];
        if authority.is_none() || allowed_authorities.contains(&authority) {
            if let Some(auth_header) = &*self.auth_header {
                req.headers_mut().append(AUTHORIZATION, auth_header.clone());
            }
        }
        self.inner.call(req)
    }
}