fix: use back old role and af role

This commit is contained in:
Zack Fu Zi Xiang 2024-03-11 21:33:33 +08:00
parent cfec146164
commit 4952bc58fe
No known key found for this signature in database
9 changed files with 45 additions and 48 deletions

View File

@ -9,7 +9,7 @@ use flowy_user::entities::{
}; };
use flowy_user::errors::FlowyError; use flowy_user::errors::FlowyError;
use flowy_user::event_map::UserEvent; use flowy_user::event_map::UserEvent;
use flowy_user_pub::entities::WorkspaceRole; use flowy_user_pub::entities::Role;
use crate::event_builder::EventBuilder; use crate::event_builder::EventBuilder;
use crate::EventIntegrationTest; use crate::EventIntegrationTest;
@ -26,12 +26,7 @@ impl EventIntegrationTest {
.await; .await;
} }
pub async fn invite_workspace_member( pub async fn invite_workspace_member(&self, workspace_id: &str, email: &str, role: Role) {
&self,
workspace_id: &str,
email: &str,
role: WorkspaceRole,
) {
EventBuilder::new(self.clone()) EventBuilder::new(self.clone())
.event(UserEvent::InviteWorkspaceMember) .event(UserEvent::InviteWorkspaceMember)
.payload(WorkspaceMemberInvitationPB { .payload(WorkspaceMemberInvitationPB {

View File

@ -1,6 +1,6 @@
use event_integration::user_event::user_localhost_af_cloud; use event_integration::user_event::user_localhost_af_cloud;
use event_integration::EventIntegrationTest; use event_integration::EventIntegrationTest;
use flowy_user_pub::entities::WorkspaceRole; use flowy_user_pub::entities::Role;
use crate::user::af_cloud_test::workspace_test::get_synced_workspaces; use crate::user::af_cloud_test::workspace_test::get_synced_workspaces;
@ -14,7 +14,7 @@ async fn af_cloud_invite_workspace_member() {
let user_2 = test_2.af_cloud_sign_up().await; let user_2 = test_2.af_cloud_sign_up().await;
test_1 test_1
.invite_workspace_member(&user_1.workspace_id, &user_2.email, WorkspaceRole::Member) .invite_workspace_member(&user_1.workspace_id, &user_2.email, Role::Member)
.await; .await;
let invitations = test_2.list_workspace_invitations().await; let invitations = test_2.list_workspace_invitations().await;

View File

@ -17,8 +17,8 @@ use parking_lot::RwLock;
use flowy_error::{ErrorCode, FlowyError, FlowyResult}; use flowy_error::{ErrorCode, FlowyError, FlowyResult};
use flowy_user_pub::cloud::{UserCloudService, UserCollabParams, UserUpdate, UserUpdateReceiver}; use flowy_user_pub::cloud::{UserCloudService, UserCollabParams, UserUpdate, UserUpdateReceiver};
use flowy_user_pub::entities::{ use flowy_user_pub::entities::{
AFCloudOAuthParams, AuthResponse, UpdateUserProfileParams, UserCredentials, UserProfile, AFCloudOAuthParams, AuthResponse, Role, UpdateUserProfileParams, UserCredentials, UserProfile,
UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember, WorkspaceRole, UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember,
}; };
use lib_infra::box_any::BoxAny; use lib_infra::box_any::BoxAny;
use lib_infra::future::FutureResult; use lib_infra::future::FutureResult;
@ -206,7 +206,7 @@ where
&self, &self,
invitee_email: String, invitee_email: String,
workspace_id: String, workspace_id: String,
role: WorkspaceRole, role: Role,
) -> FutureResult<(), Error> { ) -> FutureResult<(), Error> {
let try_get_client = self.server.try_get_client(); let try_get_client = self.server.try_get_client();
FutureResult::new(async move { FutureResult::new(async move {
@ -269,7 +269,7 @@ where
&self, &self,
user_email: String, user_email: String,
workspace_id: String, workspace_id: String,
role: WorkspaceRole, role: Role,
) -> FutureResult<(), Error> { ) -> FutureResult<(), Error> {
let try_get_client = self.server.try_get_client(); let try_get_client = self.server.try_get_client();
FutureResult::new(async move { FutureResult::new(async move {

View File

@ -3,8 +3,9 @@ use client_api::entity::auth_dto::{UpdateUserParams, UserMetaData};
use client_api::entity::{AFRole, AFUserProfile, AFWorkspaceInvitationStatus, AFWorkspaceMember}; use client_api::entity::{AFRole, AFUserProfile, AFWorkspaceInvitationStatus, AFWorkspaceMember};
use flowy_user_pub::entities::{ use flowy_user_pub::entities::{
Authenticator, UpdateUserProfileParams, UserProfile, WorkspaceInvitationStatus, WorkspaceMember, Authenticator, Role, UpdateUserProfileParams, UserProfile, WorkspaceInvitationStatus,
WorkspaceRole, USER_METADATA_ICON_URL, USER_METADATA_OPEN_AI_KEY, USER_METADATA_STABILITY_AI_KEY, WorkspaceMember, USER_METADATA_ICON_URL, USER_METADATA_OPEN_AI_KEY,
USER_METADATA_STABILITY_AI_KEY,
}; };
use crate::af_cloud::impls::user::util::encryption_type_from_profile; use crate::af_cloud::impls::user::util::encryption_type_from_profile;
@ -67,19 +68,19 @@ pub fn user_profile_from_af_profile(
}) })
} }
pub fn to_af_role(role: WorkspaceRole) -> AFRole { pub fn to_af_role(role: Role) -> AFRole {
match role { match role {
WorkspaceRole::Owner => AFRole::Owner, Role::Owner => AFRole::Owner,
WorkspaceRole::Member => AFRole::Member, Role::Member => AFRole::Member,
WorkspaceRole::Guest => AFRole::Guest, Role::Guest => AFRole::Guest,
} }
} }
pub fn from_af_role(role: AFRole) -> WorkspaceRole { pub fn from_af_role(role: AFRole) -> Role {
match role { match role {
AFRole::Owner => WorkspaceRole::Owner, AFRole::Owner => Role::Owner,
AFRole::Member => WorkspaceRole::Member, AFRole::Member => Role::Member,
AFRole::Guest => WorkspaceRole::Guest, AFRole::Guest => Role::Guest,
} }
} }

View File

@ -15,9 +15,8 @@ use tokio_stream::wrappers::WatchStream;
use uuid::Uuid; use uuid::Uuid;
use crate::entities::{ use crate::entities::{
AuthResponse, Authenticator, UpdateUserProfileParams, UserCredentials, UserProfile, AuthResponse, Authenticator, Role, UpdateUserProfileParams, UserCredentials, UserProfile,
UserTokenState, UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember, UserTokenState, UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember,
WorkspaceRole,
}; };
#[derive(Debug, Clone, Serialize, Deserialize)] #[derive(Debug, Clone, Serialize, Deserialize)]
@ -196,7 +195,7 @@ pub trait UserCloudService: Send + Sync + 'static {
&self, &self,
invitee_email: String, invitee_email: String,
workspace_id: String, workspace_id: String,
role: WorkspaceRole, role: Role,
) -> FutureResult<(), Error> { ) -> FutureResult<(), Error> {
FutureResult::new(async { Ok(()) }) FutureResult::new(async { Ok(()) })
} }
@ -224,7 +223,7 @@ pub trait UserCloudService: Send + Sync + 'static {
&self, &self,
user_email: String, user_email: String,
workspace_id: String, workspace_id: String,
role: WorkspaceRole, role: Role,
) -> FutureResult<(), Error> { ) -> FutureResult<(), Error> {
FutureResult::new(async { Ok(()) }) FutureResult::new(async { Ok(()) })
} }

View File

@ -380,8 +380,9 @@ pub enum UserTokenState {
Invalid, Invalid,
} }
// Workspace Role
#[derive(Clone, Debug)] #[derive(Clone, Debug)]
pub enum WorkspaceRole { pub enum Role {
Owner, Owner,
Member, Member,
Guest, Guest,
@ -389,7 +390,7 @@ pub enum WorkspaceRole {
pub struct WorkspaceMember { pub struct WorkspaceMember {
pub email: String, pub email: String,
pub role: WorkspaceRole, pub role: Role,
pub name: String, pub name: String,
} }

View File

@ -1,7 +1,7 @@
use validator::Validate; use validator::Validate;
use flowy_derive::{ProtoBuf, ProtoBuf_Enum}; use flowy_derive::{ProtoBuf, ProtoBuf_Enum};
use flowy_user_pub::entities::{WorkspaceInvitation, WorkspaceMember, WorkspaceRole}; use flowy_user_pub::entities::{Role, WorkspaceInvitation, WorkspaceMember};
use lib_infra::validator_fn::required_not_empty_str; use lib_infra::validator_fn::required_not_empty_str;
#[derive(ProtoBuf, Default, Clone)] #[derive(ProtoBuf, Default, Clone)]
@ -13,7 +13,7 @@ pub struct WorkspaceMemberPB {
pub name: String, pub name: String,
#[pb(index = 3)] #[pb(index = 3)]
pub role: WorkspaceRolePB, pub role: AFRolePB,
} }
impl From<WorkspaceMember> for WorkspaceMemberPB { impl From<WorkspaceMember> for WorkspaceMemberPB {
@ -43,7 +43,7 @@ pub struct WorkspaceMemberInvitationPB {
pub invitee_email: String, pub invitee_email: String,
#[pb(index = 3)] #[pb(index = 3)]
pub role: WorkspaceRolePB, pub role: AFRolePB,
} }
#[derive(Debug, ProtoBuf, Default, Clone)] #[derive(Debug, ProtoBuf, Default, Clone)]
@ -131,33 +131,34 @@ pub struct UpdateWorkspaceMemberPB {
pub email: String, pub email: String,
#[pb(index = 3)] #[pb(index = 3)]
pub role: WorkspaceRolePB, pub role: AFRolePB,
} }
// Workspace Role
#[derive(ProtoBuf_Enum, Clone, Default)] #[derive(ProtoBuf_Enum, Clone, Default)]
pub enum WorkspaceRolePB { pub enum AFRolePB {
Owner = 0, Owner = 0,
Member = 1, Member = 1,
#[default] #[default]
Guest = 2, Guest = 2,
} }
impl From<WorkspaceRolePB> for WorkspaceRole { impl From<AFRolePB> for Role {
fn from(value: WorkspaceRolePB) -> Self { fn from(value: AFRolePB) -> Self {
match value { match value {
WorkspaceRolePB::Owner => WorkspaceRole::Owner, AFRolePB::Owner => Role::Owner,
WorkspaceRolePB::Member => WorkspaceRole::Member, AFRolePB::Member => Role::Member,
WorkspaceRolePB::Guest => WorkspaceRole::Guest, AFRolePB::Guest => Role::Guest,
} }
} }
} }
impl From<WorkspaceRole> for WorkspaceRolePB { impl From<Role> for AFRolePB {
fn from(value: WorkspaceRole) -> Self { fn from(value: Role) -> Self {
match value { match value {
WorkspaceRole::Owner => WorkspaceRolePB::Owner, Role::Owner => AFRolePB::Owner,
WorkspaceRole::Member => WorkspaceRolePB::Member, Role::Member => AFRolePB::Member,
WorkspaceRole::Guest => WorkspaceRolePB::Guest, Role::Guest => AFRolePB::Guest,
} }
} }
} }

View File

@ -10,7 +10,7 @@ use flowy_folder_pub::entities::{AppFlowyData, ImportData};
use flowy_sqlite::schema::user_workspace_table; use flowy_sqlite::schema::user_workspace_table;
use flowy_sqlite::{query_dsl::*, DBConnection, ExpressionMethods}; use flowy_sqlite::{query_dsl::*, DBConnection, ExpressionMethods};
use flowy_user_pub::entities::{ use flowy_user_pub::entities::{
UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember, WorkspaceRole, Role, UserWorkspace, WorkspaceInvitation, WorkspaceInvitationStatus, WorkspaceMember,
}; };
use lib_dispatch::prelude::af_spawn; use lib_dispatch::prelude::af_spawn;
@ -200,7 +200,7 @@ impl UserManager {
&self, &self,
workspace_id: String, workspace_id: String,
invitee_email: String, invitee_email: String,
role: WorkspaceRole, role: Role,
) -> FlowyResult<()> { ) -> FlowyResult<()> {
self self
.cloud_services .cloud_services
@ -272,7 +272,7 @@ impl UserManager {
&self, &self,
user_email: String, user_email: String,
workspace_id: String, workspace_id: String,
role: WorkspaceRole, role: Role,
) -> FlowyResult<()> { ) -> FlowyResult<()> {
self self
.cloud_services .cloud_services

View File

@ -1,2 +1,2 @@
[toolchain] [toolchain]
channel = "1.75" channel = "1.76"