Remove HealActivity alteration and handler
- Deleted `HealActivity` alteration type and associated `HealActivityHandler`. - Unregistered `HealActivity` from alteration services.
This commit is contained in:
parent
ce3a0b9ce0
commit
2cbcefee83
|
|
@ -1,42 +0,0 @@
|
|||
using Elsa.Alterations.AlterationTypes;
|
||||
using Elsa.Alterations.Core.Abstractions;
|
||||
using Elsa.Alterations.Core.Contexts;
|
||||
using Elsa.Extensions;
|
||||
using Elsa.Workflows;
|
||||
using JetBrains.Annotations;
|
||||
|
||||
namespace Elsa.Alterations.AlterationHandlers;
|
||||
|
||||
/// <summary>
|
||||
/// Cancels an activity.
|
||||
/// </summary>
|
||||
[UsedImplicitly]
|
||||
public class HealActivityHandler : AlterationHandlerBase<HealActivity>
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override ValueTask HandleAsync(AlterationContext context, HealActivity alteration)
|
||||
{
|
||||
var activityExecutionContexts = context.WorkflowExecutionContext.FindActivityExecutionContexts(alteration.ActivityHandle).ToList();
|
||||
|
||||
if (!activityExecutionContexts.Any())
|
||||
{
|
||||
context.Fail($"Activity execution context with handle {alteration.ActivityHandle} not found");
|
||||
|
||||
return ValueTask.CompletedTask;
|
||||
}
|
||||
|
||||
context.Succeed(() => Heal(activityExecutionContexts));
|
||||
return ValueTask.CompletedTask;
|
||||
}
|
||||
|
||||
private void Heal(IEnumerable<ActivityExecutionContext> activityExecutionContexts)
|
||||
{
|
||||
foreach (var activityExecutionContext in activityExecutionContexts)
|
||||
Heal(activityExecutionContext);
|
||||
}
|
||||
|
||||
private void Heal(ActivityExecutionContext activityExecutionContext)
|
||||
{
|
||||
activityExecutionContext.RecoverFromFault();
|
||||
}
|
||||
}
|
||||
|
|
@ -1,17 +0,0 @@
|
|||
using Elsa.Alterations.Core.Abstractions;
|
||||
using Elsa.Workflows.Models;
|
||||
using JetBrains.Annotations;
|
||||
|
||||
namespace Elsa.Alterations.AlterationTypes;
|
||||
|
||||
/// <summary>
|
||||
/// Heals an activity from the Faulted state.
|
||||
/// </summary>
|
||||
[UsedImplicitly]
|
||||
public class HealActivity : AlterationBase
|
||||
{
|
||||
/// <summary>
|
||||
/// The handle to the to be healed.
|
||||
/// </summary>
|
||||
public ActivityHandle ActivityHandle { get; set; } = null!;
|
||||
}
|
||||
|
|
@ -20,7 +20,6 @@ public static class ServiceCollectionExtensions
|
|||
services.AddAlteration<ModifyVariable, ModifyVariableHandler>();
|
||||
services.AddAlteration<ScheduleActivity, ScheduleActivityHandler>();
|
||||
services.AddAlteration<CancelActivity, CancelActivityHandler>();
|
||||
services.AddAlteration<HealActivity, HealActivityHandler>();
|
||||
services.AddAlteration<Cancel, CancelHandler>();
|
||||
services.AddNotificationHandlersFrom<AlterationsFeature>();
|
||||
return services;
|
||||
|
|
|
|||
Loading…
Reference in a new issue