use crate::common::{request, request_bare, SerializableNone};
use crate::error::ApiError;
use anyhow::Context;
use lrzcc_wire::user::{
Project, ProjectCreateData, ProjectListParams, ProjectModifyData,
ProjectRetrieved,
};
use reqwest::blocking::Client;
use reqwest::{Method, StatusCode};
use std::rc::Rc;
pub struct ProjectApi {
pub url: String,
pub client: Rc<Client>,
}
#[derive(Debug)]
pub struct ProjectListRequest {
url: String,
client: Rc<Client>,
params: ProjectListParams,
}
impl ProjectListRequest {
pub fn new(url: &str, client: &Rc<Client>) -> Self {
Self {
url: url.to_string(),
client: Rc::clone(client),
params: ProjectListParams {
all: None,
userclass: None,
},
}
}
pub fn send(&self) -> Result<Vec<Project>, ApiError> {
let params = serde_urlencoded::to_string(&self.params)
.context("Failed to encode URL parameters.")?;
let url = if params.is_empty() {
self.url.clone()
} else {
format!("{}?{}", self.url, params)
};
request(
&self.client,
Method::GET,
url.as_str(),
SerializableNone!(),
StatusCode::OK,
)
}
pub fn all(&mut self) -> &mut Self {
self.params.all = Some(true);
self
}
pub fn user_class(&mut self, userclass: u32) -> &mut Self {
self.params.userclass = Some(userclass);
self
}
}
pub struct ProjectCreateRequest {
url: String,
client: Rc<Client>,
data: ProjectCreateData,
}
impl ProjectCreateRequest {
pub fn new(
url: &str,
client: &Rc<Client>,
name: String,
openstack_id: String,
) -> Self {
Self {
url: url.to_string(),
client: Rc::clone(client),
data: ProjectCreateData::new(name, openstack_id),
}
}
pub fn user_class(&mut self, user_class: u32) -> &mut Self {
self.data.user_class = Some(user_class);
self
}
pub fn send(&self) -> Result<Project, ApiError> {
request(
&self.client,
Method::POST,
&self.url,
Some(&self.data),
StatusCode::CREATED,
)
}
}
pub struct ProjectModifyRequest {
url: String,
client: Rc<Client>,
data: ProjectModifyData,
}
impl ProjectModifyRequest {
pub fn new(url: &str, client: &Rc<Client>, id: u32) -> Self {
Self {
url: url.to_string(),
client: Rc::clone(client),
data: ProjectModifyData::new(id),
}
}
pub fn name(&mut self, name: String) -> &mut Self {
self.data.name = Some(name);
self
}
pub fn openstack_id(&mut self, openstack_id: String) -> &mut Self {
self.data.openstack_id = Some(openstack_id);
self
}
pub fn user_class(&mut self, user_class: u32) -> &mut Self {
self.data.user_class = Some(user_class);
self
}
pub fn send(&self) -> Result<Project, ApiError> {
request(
&self.client,
Method::PATCH,
&self.url,
Some(&self.data),
StatusCode::OK,
)
}
}
impl ProjectApi {
pub fn new(base_url: &str, client: &Rc<Client>) -> ProjectApi {
ProjectApi {
url: format!("{}/user/projects", base_url),
client: Rc::clone(client),
}
}
pub fn list(&self) -> ProjectListRequest {
ProjectListRequest::new(self.url.as_ref(), &self.client)
}
pub fn get(&self, id: u32) -> Result<ProjectRetrieved, ApiError> {
let url = format!("{}/{}", self.url, id);
request(
&self.client,
Method::GET,
url.as_str(),
SerializableNone!(),
StatusCode::OK,
)
}
pub fn create(
&self,
name: String,
openstack_id: String,
) -> ProjectCreateRequest {
let url = format!("{}/", self.url);
ProjectCreateRequest::new(
url.as_ref(),
&self.client,
name,
openstack_id,
)
}
pub fn modify(&self, id: u32) -> ProjectModifyRequest {
let url = format!("{}/{}/", self.url, id);
ProjectModifyRequest::new(url.as_ref(), &self.client, id)
}
pub fn delete(&self, id: u32) -> Result<(), ApiError> {
let url = format!("{}/{}/", self.url, id);
request_bare(
&self.client,
Method::DELETE,
url.as_str(),
SerializableNone!(),
StatusCode::NO_CONTENT,
)?;
Ok(())
}
}