Rust Reveal

rust_reveal.rs

extern crate hyper;
extern crate hyper_tls;
extern crate hyper_proxy;
extern crate envy;
extern crate reqwest;
#[macro_use]
extern crate serde_derive;
extern crate serde_json;
#[macro_use]
extern crate fake;
extern crate base64;

use std::io::{self, Read};
use std::fs::File;
use serde_json::Value;
use reqwest::header::{ContentType};
use hyper::header::Basic;

fn reveal_via_forward_proxy(redacted_data: String, username: String, password: String,
     forward_proxy: String) -> String {

   let s: &str = &*redacted_data;
   let json_data: Value = serde_json::from_str(&s).unwrap();

   let raw_proxy = format!("http://{}", forward_proxy);
   let mut proxy = reqwest::Proxy::all(&raw_proxy).unwrap();
   proxy.set_authorization(Basic {
        username: username.to_owned().into(),
        password: Some(password.to_owned().into()),
    });

   let mut buf = Vec::new();
   File::open("cert.der").unwrap().read_to_end(&mut buf).unwrap();
   let cert = reqwest::Certificate::from_der(&buf).unwrap();
   let client = reqwest::Client::builder()
     .add_root_certificate(cert)
     .proxy(proxy)
     .build().unwrap();

   let url = format!("{}", "https://httpbin.verygoodsecurity.io/post");

   let mut res = client.post(&url)
       .json(&json_data)
       .send().unwrap();

   let mut buf = String::new();
   res.read_to_string(&mut buf).expect("Failed to read response");
   let v: Value = serde_json::from_str(&buf).map_err(|e| {
       io::Error::new(
            io::ErrorKind::Other,
            e
       )
   }).unwrap();
   let revealed_data = format!("{}", &v["json"]);
   println!("{}", revealed_data);
   return format!("{}", revealed_data);

}

fn main(){
    //import environment variables to use for functions
    #[derive(Deserialize, Debug)]
    struct Environment {
        forward_http_proxy_username: String,
        forward_http_proxy_password: String,
        forward_http_proxy_host: String,
        reverse_http_proxy_host: String,
    }
    let e: Environment = envy::from_env()
        .expect("Couldn't parse environment");

    println!("{:#?}", e);
    let username = e.forward_http_proxy_username;
    let password = e.forward_http_proxy_password;
    let forward_proxy = e.forward_http_proxy_host;
    let reverse_proxy = e.reverse_http_proxy_host;

        //reveal_data
        let revealed_data = reveal_via_forward_proxy(redacted_data.clone(), username, password, forward_proxy);

}