chore: update dto
This commit is contained in:
parent
7a309c6f69
commit
ec13239bdd
|
|
@ -25,7 +25,7 @@ use scraper::{Html, Selector};
|
||||||
use shared_entity::app_error::AppError;
|
use shared_entity::app_error::AppError;
|
||||||
use shared_entity::data::AppResponse;
|
use shared_entity::data::AppResponse;
|
||||||
use shared_entity::dto::auth_dto::SignInTokenResponse;
|
use shared_entity::dto::auth_dto::SignInTokenResponse;
|
||||||
use shared_entity::dto::auth_dto::UpdateUsernameParams;
|
use shared_entity::dto::auth_dto::UpdateUserParams;
|
||||||
use shared_entity::dto::workspace_dto::{
|
use shared_entity::dto::workspace_dto::{
|
||||||
CreateWorkspaceMembers, WorkspaceBlobMetadata, WorkspaceMemberChangeset, WorkspaceMembers,
|
CreateWorkspaceMembers, WorkspaceBlobMetadata, WorkspaceMemberChangeset, WorkspaceMembers,
|
||||||
WorkspaceSpaceUsage,
|
WorkspaceSpaceUsage,
|
||||||
|
|
@ -517,7 +517,7 @@ impl Client {
|
||||||
}
|
}
|
||||||
|
|
||||||
#[instrument(level = "debug", skip_all, err)]
|
#[instrument(level = "debug", skip_all, err)]
|
||||||
pub async fn update_user(&self, params: UpdateUsernameParams) -> Result<(), AppError> {
|
pub async fn update_user(&self, params: UpdateUserParams) -> Result<(), AppError> {
|
||||||
let gotrue_params = UpdateGotrueUserParams::new()
|
let gotrue_params = UpdateGotrueUserParams::new()
|
||||||
.with_opt_email(params.email.clone())
|
.with_opt_email(params.email.clone())
|
||||||
.with_opt_password(params.password.clone());
|
.with_opt_password(params.password.clone());
|
||||||
|
|
|
||||||
|
|
@ -26,14 +26,14 @@ impl UserMetaData {
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(serde::Deserialize, serde::Serialize, Default)]
|
#[derive(serde::Deserialize, serde::Serialize, Default)]
|
||||||
pub struct UpdateUsernameParams {
|
pub struct UpdateUserParams {
|
||||||
pub name: Option<String>,
|
pub name: Option<String>,
|
||||||
pub password: Option<String>,
|
pub password: Option<String>,
|
||||||
pub email: Option<String>,
|
pub email: Option<String>,
|
||||||
pub metadata: Option<UserMetaData>,
|
pub metadata: Option<UserMetaData>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl UpdateUsernameParams {
|
impl UpdateUserParams {
|
||||||
pub fn new() -> Self {
|
pub fn new() -> Self {
|
||||||
Self::default()
|
Self::default()
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,7 @@ use crate::domain::{UserEmail, UserName, UserPassword};
|
||||||
use crate::state::AppState;
|
use crate::state::AppState;
|
||||||
use database_entity::AFUserProfileView;
|
use database_entity::AFUserProfileView;
|
||||||
use shared_entity::data::{AppResponse, JsonAppResponse};
|
use shared_entity::data::{AppResponse, JsonAppResponse};
|
||||||
use shared_entity::dto::auth_dto::{SignInTokenResponse, UpdateUsernameParams};
|
use shared_entity::dto::auth_dto::{SignInTokenResponse, UpdateUserParams};
|
||||||
|
|
||||||
use crate::component::auth::jwt::{Authorization, UserUuid};
|
use crate::component::auth::jwt::{Authorization, UserUuid};
|
||||||
use actix_web::web::{Data, Json};
|
use actix_web::web::{Data, Json};
|
||||||
|
|
@ -59,7 +59,7 @@ async fn get_user_profile_handler(
|
||||||
#[tracing::instrument(skip(state, auth, payload), err)]
|
#[tracing::instrument(skip(state, auth, payload), err)]
|
||||||
async fn update_user_handler(
|
async fn update_user_handler(
|
||||||
auth: Authorization,
|
auth: Authorization,
|
||||||
payload: Json<UpdateUsernameParams>,
|
payload: Json<UpdateUserParams>,
|
||||||
state: Data<AppState>,
|
state: Data<AppState>,
|
||||||
required_id: RequestId,
|
required_id: RequestId,
|
||||||
) -> Result<JsonAppResponse<()>> {
|
) -> Result<JsonAppResponse<()>> {
|
||||||
|
|
|
||||||
|
|
@ -6,7 +6,7 @@ use serde_json::json;
|
||||||
use shared_entity::app_error::AppError;
|
use shared_entity::app_error::AppError;
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
use shared_entity::dto::auth_dto::UpdateUsernameParams;
|
use shared_entity::dto::auth_dto::UpdateUserParams;
|
||||||
use sqlx::{types::uuid, PgPool};
|
use sqlx::{types::uuid, PgPool};
|
||||||
|
|
||||||
pub async fn token_verify(
|
pub async fn token_verify(
|
||||||
|
|
@ -34,7 +34,7 @@ pub async fn get_profile(
|
||||||
pub async fn update_user(
|
pub async fn update_user(
|
||||||
pg_pool: &PgPool,
|
pg_pool: &PgPool,
|
||||||
user_uuid: Uuid,
|
user_uuid: Uuid,
|
||||||
params: UpdateUsernameParams,
|
params: UpdateUserParams,
|
||||||
) -> Result<(), AppError> {
|
) -> Result<(), AppError> {
|
||||||
let metadata = params.metadata.map(|m| json!(m.into_inner()));
|
let metadata = params.metadata.map(|m| json!(m.into_inner()));
|
||||||
Ok(database::user::update_user(pg_pool, &user_uuid, params.name, params.email, metadata).await?)
|
Ok(database::user::update_user(pg_pool, &user_uuid, params.name, params.email, metadata).await?)
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
use serde_json::json;
|
use serde_json::json;
|
||||||
use shared_entity::dto::auth_dto::{UpdateUsernameParams, UserMetaData};
|
use shared_entity::dto::auth_dto::{UpdateUserParams, UserMetaData};
|
||||||
use shared_entity::error_code::ErrorCode;
|
use shared_entity::error_code::ErrorCode;
|
||||||
|
|
||||||
use crate::localhost_client;
|
use crate::localhost_client;
|
||||||
|
|
@ -9,7 +9,7 @@ use crate::user::utils::generate_unique_registered_user_client;
|
||||||
async fn update_but_not_logged_in() {
|
async fn update_but_not_logged_in() {
|
||||||
let client = localhost_client();
|
let client = localhost_client();
|
||||||
let error = client
|
let error = client
|
||||||
.update_user(UpdateUsernameParams::new().with_name("new name"))
|
.update_user(UpdateUserParams::new().with_name("new name"))
|
||||||
.await
|
.await
|
||||||
.unwrap_err();
|
.unwrap_err();
|
||||||
|
|
||||||
|
|
@ -24,7 +24,7 @@ async fn update_password_same_password() {
|
||||||
.unwrap();
|
.unwrap();
|
||||||
let err = c
|
let err = c
|
||||||
.update_user(
|
.update_user(
|
||||||
UpdateUsernameParams::new()
|
UpdateUserParams::new()
|
||||||
.with_password(user.password)
|
.with_password(user.password)
|
||||||
.with_email(user.email),
|
.with_email(user.email),
|
||||||
)
|
)
|
||||||
|
|
@ -47,7 +47,7 @@ async fn update_password_and_revert() {
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
c.update_user(UpdateUsernameParams::new().with_password(new_password))
|
c.update_user(UpdateUserParams::new().with_password(new_password))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
@ -55,7 +55,7 @@ async fn update_password_and_revert() {
|
||||||
// revert password to old_password
|
// revert password to old_password
|
||||||
let c = localhost_client();
|
let c = localhost_client();
|
||||||
c.sign_in_password(&user.email, new_password).await.unwrap();
|
c.sign_in_password(&user.email, new_password).await.unwrap();
|
||||||
c.update_user(UpdateUsernameParams::new().with_password(user.password))
|
c.update_user(UpdateUserParams::new().with_password(user.password))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
@ -67,7 +67,7 @@ async fn update_user_name() {
|
||||||
c.sign_in_password(&user.email, &user.password)
|
c.sign_in_password(&user.email, &user.password)
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
c.update_user(UpdateUsernameParams::new().with_name("lucas"))
|
c.update_user(UpdateUserParams::new().with_name("lucas"))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
|
@ -86,7 +86,7 @@ async fn update_user_metadata() {
|
||||||
metadata.insert("str_value", "value");
|
metadata.insert("str_value", "value");
|
||||||
metadata.insert("int_value", 1);
|
metadata.insert("int_value", 1);
|
||||||
|
|
||||||
c.update_user(UpdateUsernameParams::new().with_metadata(metadata.clone()))
|
c.update_user(UpdateUserParams::new().with_metadata(metadata.clone()))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
|
@ -104,13 +104,13 @@ async fn user_metadata_override() {
|
||||||
let mut metadata_1 = UserMetaData::new();
|
let mut metadata_1 = UserMetaData::new();
|
||||||
metadata_1.insert("str_value", "value");
|
metadata_1.insert("str_value", "value");
|
||||||
metadata_1.insert("int_value", 1);
|
metadata_1.insert("int_value", 1);
|
||||||
c.update_user(UpdateUsernameParams::new().with_metadata(metadata_1.clone()))
|
c.update_user(UpdateUserParams::new().with_metadata(metadata_1.clone()))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
let mut metadata_2 = UserMetaData::new();
|
let mut metadata_2 = UserMetaData::new();
|
||||||
metadata_2.insert("bool_value", false);
|
metadata_2.insert("bool_value", false);
|
||||||
c.update_user(UpdateUsernameParams::new().with_metadata(metadata_2))
|
c.update_user(UpdateUserParams::new().with_metadata(metadata_2))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
metadata_1.insert("bool_value", false);
|
metadata_1.insert("bool_value", false);
|
||||||
|
|
@ -129,11 +129,11 @@ async fn user_empty_metadata_override() {
|
||||||
let mut metadata_1 = UserMetaData::new();
|
let mut metadata_1 = UserMetaData::new();
|
||||||
metadata_1.insert("str_value", "value");
|
metadata_1.insert("str_value", "value");
|
||||||
metadata_1.insert("int_value", 1);
|
metadata_1.insert("int_value", 1);
|
||||||
c.update_user(UpdateUsernameParams::new().with_metadata(metadata_1.clone()))
|
c.update_user(UpdateUserParams::new().with_metadata(metadata_1.clone()))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
c.update_user(UpdateUsernameParams::new().with_metadata(UserMetaData::new()))
|
c.update_user(UpdateUserParams::new().with_metadata(UserMetaData::new()))
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue