Skip to main content

devops_armory/cloud/gcp/vpc/address/
create_internal.rs

1use std::time::Duration;
2use super::models::IpAddress;
3
4/// Create internal IP global address
5/// Project ID, token, ip_name need to be provided
6pub async fn create_internal_address(
7    token: String,
8    project: String,
9    ip_name: String,
10    ip_address: String,
11    ip_prefix: String,
12    network_tier: String,
13    ip_version: String,
14    ip_address_type: String,
15    ip_address_purpose: String,
16    net_name: String
17) -> Result<(), std::io::Error> {
18
19    let parent_network_url = format!("https://www.googleapis.com/compute/v1/projects/{project}/global/networks/{net_name}");
20
21    let address_body: IpAddress = IpAddress { 
22        name: ip_name, 
23        address: ip_address, 
24        prefixLength: ip_prefix,
25        networkTier: network_tier, 
26        ipVersion: ip_version, 
27        addressType: ip_address_type, 
28        purpose: ip_address_purpose, 
29        network: parent_network_url 
30    };
31
32    let client = awc::Client::default();
33    let request = client.post(format!("https://compute.googleapis.com/compute/v1/projects/{project}/global/addresses"))
34        .bearer_auth(&token)
35        .insert_header(("Content-Type", "application/json"))
36        .timeout(Duration::from_secs(30))
37        .send_json(&address_body)
38        .await
39        .expect("Request POST new address could not been sent");
40
41    let mut req = request;
42    let req_status = req.status().as_u16();
43    let respone = req.body().await.unwrap_or_default();
44
45    match req_status {
46        200 => {
47            println!("Request has been successfull: Status: {:?}, {:?}", req_status, respone);
48        },
49        400 => {
50            println!("Bad Request. Check URL parameters or body: {:?}", respone);
51        },
52        403 => {
53            println!("You don't have access to perform such request: {:?}", respone);
54        }
55        404 => {
56            println!("Requested resource does not exists: {:?}", respone);
57        },
58        409 => {
59            println!("Requested resource already exists! {:?}", respone)
60        }
61        _ => {
62            println!("Request status mismatch. Check response: {:?}", respone);
63        }
64    }
65
66    Ok(())
67
68}
69