proxier 0.1.7

Auto proxy whitelist and delist crate for 3rd party services.
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

use reqwest::Client;
use std::env;

/// Get the user name password.
pub fn get_user_name_password() -> (String, String) {
    (
        env::var("DATA_INPULSE_USERNAME").unwrap_or_default(),
        env::var("DATA_INPULSE_PASSWORD").unwrap_or_default(),
    )
}

/// Create a new whitelist entry
pub async fn create_whitelist_entry(client: &Client, ip: &str) {
    let proxy_whitelist_url = format!("https://gw.dataimpulse.com:777/api/whitelist_ip/{}", ip);

    let (username, password) = get_user_name_password();

    match client
        .post(&proxy_whitelist_url)
        .basic_auth(username, Some(password))
        .send()
        .await
    {
        Ok(response) => {
            if response.status().is_success() {
                let value: serde_json::Value = response.json().await.unwrap_or_default();
                println!("Whitelisting datainpulse: {:?}", value);
            } else {
                if response.status() == 409 {
                    // attempt to get the whitelist entry.
                    println!("Failed to create whitelist entry: {}", response.status());
                    Default::default()
                } else {
                    println!(
                        "CRITICAL: Failed to create whitelist entry: {}",
                        response.status()
                    );
                }
            }
        }
        Err(err) => {
            println!("Request error: {:?}", err);
        }
    }
}

/// Delete the whitelist entry
pub async fn delete_whitelist_entry(client: &Client, ip: &str) {
    let url = format!("https://gw.dataimpulse.com:777/api/whitelist_ip/{}", ip);
    let (username, password) = get_user_name_password();

    match client
        .delete(&url)
        .basic_auth(username, Some(password))
        .send()
        .await
    {
        Ok(response) => {
            if response.status().is_success() {
                println!("Whitelist entry deleted successfully.");
            } else {
                println!("Failed to delete whitelist entry: {}", response.status());
            }
        }
        Err(err) => {
            println!("Request error: {:?}", err);
        }
    }
}