use bitwarden_api_api::models::ProjectUpdateRequestModel;
use bitwarden_core::{OrganizationId, key_management::SymmetricKeySlotId};
use bitwarden_crypto::PrimitiveEncryptable;
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use uuid::Uuid;
use validator::Validate;
use crate::{
SecretsManagerClient,
error::{SecretsManagerError, validate_only_whitespaces},
projects::ProjectResponse,
};
#[allow(missing_docs)]
#[derive(Serialize, Deserialize, Debug, JsonSchema, Validate)]
#[serde(rename_all = "camelCase", deny_unknown_fields)]
pub struct ProjectPutRequest {
pub id: Uuid,
pub organization_id: Uuid,
#[validate(length(min = 1, max = 500), custom(function = validate_only_whitespaces))]
pub name: String,
}
pub(crate) async fn update_project(
client: &SecretsManagerClient,
input: &ProjectPutRequest,
) -> Result<ProjectResponse, SecretsManagerError> {
let client = client.client();
input.validate()?;
let key_store = client.internal.get_key_store();
let key = SymmetricKeySlotId::Organization(OrganizationId::new(input.organization_id));
let project = Some(ProjectUpdateRequestModel {
name: input
.name
.clone()
.trim()
.encrypt(&mut key_store.context(), key)?
.to_string(),
});
let config = client.internal.get_api_configurations();
let res = config
.api_client
.projects_api()
.update(input.id, project)
.await?;
ProjectResponse::process_response(res, &mut key_store.context())
}
#[cfg(test)]
mod tests {
use super::*;
async fn update_project(name: String) -> Result<ProjectResponse, SecretsManagerError> {
let input = ProjectPutRequest {
id: Uuid::new_v4(),
organization_id: Uuid::new_v4(),
name,
};
super::update_project(&SecretsManagerClient::new(None), &input).await
}
#[tokio::test]
async fn test_update_project_request_name_empty_string() {
let response = update_project("".into()).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not be empty"
);
}
#[tokio::test]
async fn test_update_project_request_name_all_whitespaces_space() {
let response = update_project(" ".into()).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not contain only whitespaces"
);
}
#[tokio::test]
async fn test_update_project_request_name_all_whitespaces_tab() {
let response = update_project("\t".into()).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not contain only whitespaces"
);
}
#[tokio::test]
async fn test_update_project_request_name_all_whitespaces_newline() {
let response = update_project("\n".into()).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not contain only whitespaces"
);
}
#[tokio::test]
async fn test_update_project_request_name_all_whitespaces_combined() {
let response = update_project(" \t\n".into()).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not contain only whitespaces"
);
}
#[tokio::test]
async fn test_update_project_request_name_501_character_length() {
let response = update_project("a".repeat(501)).await;
assert!(response.is_err());
assert_eq!(
response.err().unwrap().to_string(),
"name must not exceed 500 characters in length"
);
}
}