mirror of
https://github.com/bitwarden/server
synced 2026-01-05 10:03:23 +00:00
2504fd9de4
* Add CQRS and caching support for OrganizationIntegrations * Use primary constructor for Delete command, per Claude suggestion * Fix namespace * Add XMLDoc for new commands / queries * Remove unnecessary extra call to AddExtendedCache in Startup (call in EventIntegrationsServiceCollectionExtensions handles this instead) * Alter strategy to use one cache / database call to retrieve all configurations for an event (including wildcards) * Updated README documentation to reflect updated Caching doc and updated CQRS approach
39 lines
1.5 KiB
C#
39 lines
1.5 KiB
C#
using Bit.Core.AdminConsole.Entities;
|
|
using Bit.Core.AdminConsole.EventIntegrations.OrganizationIntegrations.Interfaces;
|
|
using Bit.Core.Exceptions;
|
|
using Bit.Core.Repositories;
|
|
using Bit.Core.Utilities;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using ZiggyCreatures.Caching.Fusion;
|
|
|
|
namespace Bit.Core.AdminConsole.EventIntegrations.OrganizationIntegrations;
|
|
|
|
/// <summary>
|
|
/// Command implementation for creating organization integrations with cache invalidation support.
|
|
/// </summary>
|
|
public class CreateOrganizationIntegrationCommand(
|
|
IOrganizationIntegrationRepository integrationRepository,
|
|
[FromKeyedServices(EventIntegrationsCacheConstants.CacheName)]
|
|
IFusionCache cache)
|
|
: ICreateOrganizationIntegrationCommand
|
|
{
|
|
public async Task<OrganizationIntegration> CreateAsync(OrganizationIntegration integration)
|
|
{
|
|
var existingIntegrations = await integrationRepository
|
|
.GetManyByOrganizationAsync(integration.OrganizationId);
|
|
if (existingIntegrations.Any(i => i.Type == integration.Type))
|
|
{
|
|
throw new BadRequestException("An integration of this type already exists for this organization.");
|
|
}
|
|
|
|
var created = await integrationRepository.CreateAsync(integration);
|
|
await cache.RemoveByTagAsync(
|
|
EventIntegrationsCacheConstants.BuildCacheTagForOrganizationIntegration(
|
|
organizationId: integration.OrganizationId,
|
|
integrationType: integration.Type
|
|
));
|
|
|
|
return created;
|
|
}
|
|
}
|