mirror of
https://github.com/bitwarden/server.git
synced 2025-04-18 03:28:15 -05:00
85 lines
3.1 KiB
C#
85 lines
3.1 KiB
C#
using Bit.Core;
|
|
using Bit.Core.AdminConsole.Models.Business;
|
|
using Bit.Core.AdminConsole.OrganizationFeatures.OrganizationUsers.InviteUsers;
|
|
using Bit.Core.AdminConsole.OrganizationFeatures.OrganizationUsers.InviteUsers.Models;
|
|
using Bit.Core.Enums;
|
|
using Bit.Core.Exceptions;
|
|
using Bit.Core.Models.Data.Organizations.OrganizationUsers;
|
|
using Bit.Core.Repositories;
|
|
using Bit.Core.Services;
|
|
using Bit.Scim.Context;
|
|
using Bit.Scim.Models;
|
|
using Bit.Scim.Users.Interfaces;
|
|
|
|
namespace Bit.Scim.Users;
|
|
|
|
public class PostUserCommand(
|
|
IOrganizationRepository organizationRepository,
|
|
IOrganizationUserRepository organizationUserRepository,
|
|
IOrganizationService organizationService,
|
|
IPaymentService paymentService,
|
|
IScimContext scimContext,
|
|
IFeatureService featureService,
|
|
IInviteOrganizationUsersCommand inviteOrganizationUsersCommand,
|
|
TimeProvider timeProvider)
|
|
: IPostUserCommand
|
|
{
|
|
public async Task<OrganizationUserUserDetails> PostUserAsync(Guid organizationId, ScimUserRequestModel model)
|
|
{
|
|
var scimProvider = scimContext.RequestScimProvider;
|
|
var invite = model.ToOrganizationUserInvite(scimProvider);
|
|
|
|
var email = invite.Emails.Single();
|
|
var externalId = model.ExternalIdForInvite();
|
|
|
|
if (string.IsNullOrWhiteSpace(email) || !model.Active)
|
|
{
|
|
throw new BadRequestException();
|
|
}
|
|
|
|
var orgUsers = await organizationUserRepository.GetManyDetailsByOrganizationAsync(organizationId);
|
|
var orgUserByEmail = orgUsers.FirstOrDefault(ou => ou.Email?.ToLowerInvariant() == email);
|
|
if (orgUserByEmail != null)
|
|
{
|
|
throw new ConflictException();
|
|
}
|
|
|
|
var orgUserByExternalId = orgUsers.FirstOrDefault(ou => ou.ExternalId == externalId);
|
|
if (orgUserByExternalId != null)
|
|
{
|
|
throw new ConflictException();
|
|
}
|
|
|
|
var organization = await organizationRepository.GetByIdAsync(organizationId);
|
|
var hasStandaloneSecretsManager = await paymentService.HasSecretsManagerStandalone(organization);
|
|
invite.AccessSecretsManager = hasStandaloneSecretsManager;
|
|
|
|
if (featureService.IsEnabled(FeatureFlagKeys.ScimInviteUserOptimization))
|
|
{
|
|
var request = InviteScimOrganizationUserRequest.Create(
|
|
model.ToInvite(scimProvider, hasStandaloneSecretsManager),
|
|
OrganizationDto.FromOrganization(organization),
|
|
timeProvider.GetUtcNow(),
|
|
model.ExternalIdForInvite()
|
|
);
|
|
|
|
var result = await inviteOrganizationUsersCommand.InviteScimOrganizationUserAsync(request);
|
|
|
|
if (result.Success)
|
|
{
|
|
var invitedUser = await organizationUserRepository.GetDetailsByIdAsync(result.Value.Id);
|
|
|
|
return invitedUser;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
var invitedOrgUser = await organizationService.InviteUserAsync(organizationId, invitingUserId: null, EventSystemUser.SCIM,
|
|
invite, externalId);
|
|
var orgUser = await organizationUserRepository.GetDetailsByIdAsync(invitedOrgUser.Id);
|
|
|
|
return orgUser;
|
|
}
|
|
}
|