| | | 1 | | using System.Text.Json; |
| | | 2 | | using Elsa.Platform.Integration.Services; |
| | | 3 | | using Loom; |
| | | 4 | | |
| | | 5 | | namespace Elsa.Platform.Integration.Steps; |
| | | 6 | | |
| | | 7 | | [Step("elsa.configure-features")] |
| | 0 | 8 | | public sealed class ConfigureFeaturesStep( |
| | 0 | 9 | | IShellConfigurationOverlayStore overlayStore, |
| | 0 | 10 | | PlatformShellReloadTracker reloadTracker) : IStep, IValidatingStep |
| | | 11 | | { |
| | 0 | 12 | | public string ShellId { get; init; } = "Default"; |
| | | 13 | | |
| | 0 | 14 | | public Dictionary<string, JsonElement>? Enable { get; init; } |
| | | 15 | | |
| | 0 | 16 | | public List<string>? Disable { get; init; } |
| | | 17 | | |
| | | 18 | | public ValueTask<IReadOnlyList<RecipeDiagnostic>> ValidateAsync( |
| | | 19 | | StepValidationContext context, |
| | | 20 | | CancellationToken cancellationToken = default) |
| | | 21 | | { |
| | 0 | 22 | | List<RecipeDiagnostic> diagnostics = []; |
| | 0 | 23 | | if (string.IsNullOrWhiteSpace(ShellId)) |
| | 0 | 24 | | diagnostics.Add(context.Error("ELSA_PLATFORM_SHELL_ID_REQUIRED", "Shell ID is required.", context.Target("in |
| | | 25 | | |
| | 0 | 26 | | if ((Enable is null || Enable.Count == 0) && (Disable is null || Disable.Count == 0)) |
| | 0 | 27 | | diagnostics.Add(context.Error("ELSA_PLATFORM_FEATURE_CHANGE_REQUIRED", "At least one feature enable or disab |
| | | 28 | | |
| | 0 | 29 | | foreach (var feature in Enable ?? []) |
| | | 30 | | { |
| | 0 | 31 | | if (feature.Value.ValueKind is not JsonValueKind.Object and not JsonValueKind.Null and not JsonValueKind.Und |
| | 0 | 32 | | diagnostics.Add(context.Error("ELSA_PLATFORM_FEATURE_CONFIG_INVALID", $"Feature '{feature.Key}' configur |
| | | 33 | | } |
| | | 34 | | |
| | 0 | 35 | | var duplicate = Enable?.Keys.FirstOrDefault(feature => Disable?.Contains(feature, StringComparer.OrdinalIgnoreCa |
| | 0 | 36 | | if (duplicate is not null) |
| | 0 | 37 | | diagnostics.Add(context.Error("ELSA_PLATFORM_FEATURE_CHANGE_CONFLICT", $"Feature '{duplicate}' cannot be ena |
| | | 38 | | |
| | 0 | 39 | | return ValueTask.FromResult<IReadOnlyList<RecipeDiagnostic>>(diagnostics); |
| | | 40 | | } |
| | | 41 | | |
| | | 42 | | public async ValueTask ExecuteAsync(StepContext context, CancellationToken cancellationToken = default) |
| | | 43 | | { |
| | 0 | 44 | | var changed = await overlayStore.ConfigureFeaturesAsync(ShellId, Enable, Disable, cancellationToken); |
| | 0 | 45 | | if (changed) |
| | 0 | 46 | | reloadTracker.MarkForReload(ShellId); |
| | 0 | 47 | | } |
| | | 48 | | } |