strava-client-rs 0.2.1

Strava API Client lib
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
76
77
78
79
80
81
82

//! # redirect.rs
//! Set up a server to listen for the OAuth2 redirect and returns the code and state from the redirect URL as a HashMap.
//! It binds to localhost on port 8888.
//! The server is stopped after the redirect is received and the code and state are returned.
//! If the code or state are not received, the program will exit.

use log::{info, trace, warn};
use std::collections::HashMap;
use std::process;
use tiny_http::{Response, Server};
use url::Url;

/// ## mod server
/// uses tiny_http crate to bind to port 8888 on localhost
/// Returns Hashmap that includes code and the CSRF token sent from the Oauth flow
pub mod server {
    use super::*;

    #[allow(unused_assignments)]
    pub(crate) fn run() -> HashMap<&'static str, String> {
        // Create Tiny-Http server on port 8888
        let server = Server::http("0.0.0.0:8888").unwrap_or_else(|e| {
            warn!("Could not bind to port 8888: {}", e);
            panic!("Could not bind to port 8888: {}", e);
        });

        info!("Listening on port 8888 for redirect of OAuth2 code.");

        let mut code = String::new();
        let mut state = String::new();
        let mut params = HashMap::new();

        // Listen for redirect
        let req = server.incoming_requests().next();
        if let Some(req) = req {
            // Get the URL from the request and format it with the query parameters.
            // Tiny-Http doesn't parse the URL, so we have to do it ourselves.
            let url = format!("http://localhost{}", req.url());
            let parsed_url = Url::parse(&url).unwrap();

            // Get the code and state from the query parameters
            code = parsed_url
                .query_pairs()
                .find(|(key, _)| key == "code")
                .map(|(_, value)| value.into_owned())
                .unwrap_or_default();

            trace!("Code: {}", code);

            // Get the state from the query parameters
            state = parsed_url
                .query_pairs()
                .find(|(key, _)| key == "state")
                .map(|(_, value)| value.into_owned())
                .unwrap_or_default();

            // Insert the code and state into a HashMap
            if state.is_empty() || { code.is_empty() } {
                warn!("Could not get code or state from redirect URL. Exiting.");
                process::exit(1);
            }

            trace!("State: {}", state);

            params.insert("code", code.to_string());
            params.insert("state", state.to_string());

            // Respond to the request
            let response = Response::from_string("Please return to the terminal.");
            req.respond(response).unwrap_or_else(|e| {
                warn!("Could not respond to request: {}", e);
                panic!("Could not respond to request: {}", e);
            });

            // Stop the server
            drop(server);
        }

        // Return the HashMap
        params
    }
}