using System; using System.Linq; using System.Threading.Tasks; using Bit.Core.Enums; using Bit.Core.Exceptions; using Bit.Core.Models.Table; using Bit.Core.Repositories; namespace Bit.Core.Services { public class SsoConfigService : ISsoConfigService { private readonly ISsoConfigRepository _ssoConfigRepository; private readonly IPolicyRepository _policyRepository; private readonly IOrganizationRepository _organizationRepository; private readonly IOrganizationUserRepository _organizationUserRepository; private readonly IEventService _eventService; public SsoConfigService( ISsoConfigRepository ssoConfigRepository, IPolicyRepository policyRepository, IOrganizationRepository organizationRepository, IOrganizationUserRepository organizationUserRepository, IEventService eventService) { _ssoConfigRepository = ssoConfigRepository; _policyRepository = policyRepository; _organizationRepository = organizationRepository; _organizationUserRepository = organizationUserRepository; _eventService = eventService; } public async Task SaveAsync(SsoConfig config, Organization organization) { var now = DateTime.UtcNow; config.RevisionDate = now; if (config.Id == default) { config.CreationDate = now; } var useKeyConnector = config.GetData().KeyConnectorEnabled; if (useKeyConnector) { await VerifyDependenciesAsync(config, organization); } var oldConfig = await _ssoConfigRepository.GetByOrganizationIdAsync(config.OrganizationId); var disabledKeyConnector = oldConfig?.GetData()?.KeyConnectorEnabled == true && !useKeyConnector; if (disabledKeyConnector && await AnyOrgUserHasKeyConnectorEnabledAsync(config.OrganizationId)) { throw new BadRequestException("Key Connector cannot be disabled at this moment."); } await LogEventsAsync(config, oldConfig); await _ssoConfigRepository.UpsertAsync(config); } private async Task AnyOrgUserHasKeyConnectorEnabledAsync(Guid organizationId) { var userDetails = await _organizationUserRepository.GetManyDetailsByOrganizationAsync(organizationId); return userDetails.Any(u => u.UsesKeyConnector); } private async Task VerifyDependenciesAsync(SsoConfig config, Organization organization) { if (!organization.UseKeyConnector) { throw new BadRequestException("Organization cannot use Key Connector."); } var singleOrgPolicy = await _policyRepository.GetByOrganizationIdTypeAsync(config.OrganizationId, PolicyType.SingleOrg); if (singleOrgPolicy is not { Enabled: true }) { throw new BadRequestException("Key Connector requires the Single Organization policy to be enabled."); } var ssoPolicy = await _policyRepository.GetByOrganizationIdTypeAsync(config.OrganizationId, PolicyType.RequireSso); if (ssoPolicy is not { Enabled: true }) { throw new BadRequestException("Key Connector requires the Single Sign-On Authentication policy to be enabled."); } if (!config.Enabled) { throw new BadRequestException("You must enable SSO to use Key Connector."); } } private async Task LogEventsAsync(SsoConfig config, SsoConfig oldConfig) { var organization = await _organizationRepository.GetByIdAsync(config.OrganizationId); if (oldConfig?.Enabled != config.Enabled) { var e = config.Enabled ? EventType.Organization_EnabledSso : EventType.Organization_DisabledSso; await _eventService.LogOrganizationEventAsync(organization, e); } var keyConnectorEnabled = config.GetData().KeyConnectorEnabled; if (oldConfig?.GetData()?.KeyConnectorEnabled != keyConnectorEnabled) { var e = keyConnectorEnabled ? EventType.Organization_EnabledKeyConnector : EventType.Organization_DisabledKeyConnector; await _eventService.LogOrganizationEventAsync(organization, e); } } } }