use crate::ScalewayApi;
use crate::ScalewayError;
use crate::data::security_group::{ScalewaySecurityGroupRule, ScalewaySecurityGroupRulesRoot};
pub struct ScalewayListSecurityGroupRulesBuilder {
api: ScalewayApi,
zone: String,
security_group_id: String,
params: Vec<(&'static str, String)>,
}
impl ScalewayListSecurityGroupRulesBuilder {
pub fn new(api: ScalewayApi, zone: &str, security_group_id: &str) -> Self {
ScalewayListSecurityGroupRulesBuilder {
api,
zone: zone.to_string(),
security_group_id: security_group_id.to_string(),
params: vec![],
}
}
pub fn per_page(mut self, per_page: u32) -> Self {
self.params.push(("per_page", per_page.to_string()));
self
}
#[cfg(feature = "blocking")]
pub fn run(self) -> Result<Vec<ScalewaySecurityGroupRule>, ScalewayError> {
let result = self.api.get(
&format!(
"https://api.scaleway.com/instance/v1/zones/{zone}/security_groups/{sg_id}/rules",
zone = self.zone,
sg_id = self.security_group_id
),
self.params,
)?;
let result = result.json::<ScalewaySecurityGroupRulesRoot>()?;
Ok(result.rules)
}
pub async fn run_async(self) -> Result<Vec<ScalewaySecurityGroupRule>, ScalewayError> {
let result = self
.api
.get_async(
&format!(
"https://api.scaleway.com/instance/v1/zones/{zone}/security_groups/{sg_id}/rules",
zone = self.zone,
sg_id = self.security_group_id
),
self.params,
)
.await?;
let result = result.json::<ScalewaySecurityGroupRulesRoot>().await?;
Ok(result.rules)
}
}