#1445: API: Create user and add to org

Author: dragonpoo

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/usermanagement/OrgApiService.java

@@ -6,6 +6,7 @@
 import org.lowcoder.api.usermanagement.view.OrgView;
 import org.lowcoder.api.usermanagement.view.UpdateOrgRequest;
 import org.lowcoder.api.usermanagement.view.UpdateRoleRequest;
+import org.lowcoder.domain.organization.model.OrgMember;
 import org.lowcoder.domain.organization.model.Organization;
 import org.lowcoder.domain.organization.model.Organization.OrganizationCommonSettings;
 import org.lowcoder.infra.annotation.NonEmptyMono;
@@ -23,8 +24,12 @@ public interface OrgApiService {
 
     Mono<Boolean> updateRoleForMember(String orgId, UpdateRoleRequest updateRoleRequest);
 
+    Mono<OrgMember> checkVisitorAdminRole(String orgId);
+
     Mono<Boolean> switchCurrentOrganizationTo(String orgId);
 
+    Mono<Boolean> switchCurrentOrganizationTo(String userId, String orgId);
+
     Mono<Boolean> deleteLogo(String orgId);
 
     Mono<Boolean> uploadLogo(String orgId, Mono<Part> fileMono);

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/usermanagement/OrgApiServiceImpl.java

@@ -158,7 +158,8 @@ public Mono<Boolean> updateRoleForMember(String orgId, UpdateRoleRequest updateR
                         MemberRole.fromValue(updateRoleRequest.getRole())));
     }
 
-    private Mono<OrgMember> checkVisitorAdminRole(String orgId) {
+    @Override
+    public Mono<OrgMember> checkVisitorAdminRole(String orgId) {
         return sessionUserService.getVisitorId()
                 .flatMap(visitor -> orgMemberService.getOrgMember(orgId, visitor))
                 .filter(it -> it.getRole() == MemberRole.ADMIN || it.getRole() == MemberRole.SUPER_ADMIN)
@@ -177,15 +178,18 @@ private Mono<Void> checkDeveloperCount(String orgId, String role, String userId)
     @Override
     public Mono<Boolean> switchCurrentOrganizationTo(String nextCurrentOrgId) {
         return sessionUserService.getVisitorId()
-                .flatMap(it -> orgMemberService.getAllActiveOrgs(it).collectList())
+                .flatMap(it -> switchCurrentOrganizationTo(it, nextCurrentOrgId));
+    }
+
+    @Override
+    public Mono<Boolean> switchCurrentOrganizationTo(String userId, String nextCurrentOrgId) {
+        return orgMemberService.getAllActiveOrgs(userId).collectList()
                 .defaultIfEmpty(Collections.emptyList())
                 .flatMap(orgMembers -> {
                     if (!collectSet(orgMembers, OrgMember::getOrgId).contains(nextCurrentOrgId)) {
                         return Mono.error(new BizException(BizError.INVALID_ORG_ID, "INVALID_ORG_ID"));
                     }
 
-                    String userId = orgMembers.get(0).getUserId();
-
                     Optional<OrgMember> previousCurrentOrgMember = orgMembers.stream()
                             .filter(OrgMember::isCurrentOrg)
                             .findFirst();

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/usermanagement/UserController.java

@@ -3,17 +3,21 @@
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.StringUtils;
 import org.lowcoder.api.authentication.dto.OrganizationDomainCheckResult;
+import org.lowcoder.api.authentication.service.AuthenticationApiService;
 import org.lowcoder.api.framework.view.ResponseView;
 import org.lowcoder.api.home.SessionUserService;
 import org.lowcoder.api.home.UserHomeApiService;
 import org.lowcoder.api.usermanagement.view.UpdateUserRequest;
 import org.lowcoder.api.usermanagement.view.UserProfileView;
+import org.lowcoder.domain.organization.model.MemberRole;
+import org.lowcoder.domain.organization.service.OrgMemberService;
 import org.lowcoder.domain.user.constant.UserStatusType;
 import org.lowcoder.domain.user.model.User;
 import org.lowcoder.domain.user.model.UserDetail;
 import org.lowcoder.domain.user.service.UserService;
 import org.lowcoder.domain.user.service.UserStatusService;
 import org.lowcoder.sdk.config.CommonConfig;
+import org.lowcoder.sdk.constants.AuthSourceConstants;
 import org.lowcoder.sdk.exception.BizError;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.codec.multipart.Part;
@@ -35,6 +39,19 @@ public class UserController implements UserEndpoints
     private final UserStatusService userStatusService;
     private final UserApiService userApiService;
     private final CommonConfig commonConfig;
+    private final AuthenticationApiService authenticationApiService;
+    private final OrgMemberService orgMemberService;
+
+    @Override
+    public Mono<ResponseView<?>> createUserAndAddToOrg(@PathVariable String orgId, CreateUserRequest request) {
+        return orgApiService.checkVisitorAdminRole(orgId).flatMap(__ ->
+                        authenticationApiService.authenticateByForm(request.email(), request.password(),
+                                AuthSourceConstants.EMAIL, true, null, orgId))
+                .flatMap(authUser -> userService.createNewUserByAuthUser(authUser, false))
+                .delayUntil(user -> orgMemberService.tryAddOrgMember(orgId, user.getId(), MemberRole.MEMBER))
+                .delayUntil(user -> orgApiService.switchCurrentOrganizationTo(user.getId(), orgId))
+                .map(ResponseView::success);
+    }
 
     @Override
     public Mono<ResponseView<?>> getUserProfile(ServerWebExchange exchange) {

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/usermanagement/UserEndpoints.java

@@ -25,12 +25,20 @@
 
 @RestController
 @RequestMapping(value = {Url.USER_URL, NewUrl.USER_URL})
-public interface UserEndpoints 
+public interface UserEndpoints
 {
 	public static final String TAG_USER_MANAGEMENT = "User APIs";
 	public static final String TAG_USER_PASSWORD_MANAGEMENT = "User Password APIs";
 	public static final String TAG_USER_PROFILE_PHOTO_MANAGEMENT = "User Profile Photo APIs";
-	
+	@Operation(
+			tags = TAG_USER_MANAGEMENT,
+			operationId = "createUserAndAddToOrg",
+			summary = "Create user and add to the org",
+			description = "Create a new user and add to specified organization."
+	)
+	@PostMapping("/new/{orgId}")
+	public Mono<ResponseView<?>> createUserAndAddToOrg(@PathVariable String orgId, @RequestBody CreateUserRequest request);
+
 	@Operation(
 			tags = TAG_USER_MANAGEMENT,
 		    operationId = "getUserProfile",
@@ -181,4 +189,7 @@ public record UpdatePasswordRequest(String oldPassword, String newPassword) {
     public record MarkUserStatusRequest(String type, Object value) {
     }
 
+	public record CreateUserRequest(String email, String password) {
+	}
+
 }