Rename Dto to Model and minor formatting
This commit is contained in:
parent
b22a9f8f8c
commit
69c6fedc86
|
|
@ -22,7 +22,7 @@ namespace Elsa.Activities.Entity
|
|||
[SelectOptions("Added", "Updated", "Deleted")]
|
||||
public EntityChangedAction? Action { get; set; }
|
||||
|
||||
protected override IActivityExecutionResult OnExecute() => Done(new EntityChangedDto(EntityName, Action));
|
||||
protected override IActivityExecutionResult OnExecute() => Done(new EntityChangedModel(EntityName, Action));
|
||||
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,9 +1,9 @@
|
|||
// ReSharper disable once CheckNamespace
|
||||
using System;
|
||||
|
||||
using Elsa.Activities.Entity.Extensions;
|
||||
using Elsa.Builders;
|
||||
|
||||
// ReSharper disable once CheckNamespace
|
||||
namespace Elsa.Activities.Entity
|
||||
{
|
||||
public static class EntityChangedExtensions
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@ namespace Elsa.Activities.Entity.Attributes
|
|||
{
|
||||
[AttributeUsage(AttributeTargets.Class)]
|
||||
public class EntityNameAttribute : Attribute
|
||||
{
|
||||
{
|
||||
public string Name { get; }
|
||||
|
||||
public EntityNameAttribute(string name)
|
||||
|
|
@ -12,4 +12,4 @@ namespace Elsa.Activities.Entity.Attributes
|
|||
Name = name;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,20 +1,19 @@
|
|||
|
||||
namespace Elsa.Activities.Entity.Models
|
||||
{
|
||||
public class EntityChangedDto
|
||||
public class EntityChangedModel
|
||||
{
|
||||
public string? EntityName { get; set; }
|
||||
public EntityChangedAction? Action { get; set; }
|
||||
|
||||
public EntityChangedDto()
|
||||
public EntityChangedModel()
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
public EntityChangedDto(string? entityName, EntityChangedAction? action)
|
||||
public EntityChangedModel(string? entityName, EntityChangedAction? action)
|
||||
{
|
||||
EntityName = entityName;
|
||||
Action = action;
|
||||
}
|
||||
}
|
||||
|
||||
public string? EntityName { get; set; }
|
||||
public EntityChangedAction? Action { get; set; }
|
||||
}
|
||||
}
|
||||
|
|
@ -17,7 +17,6 @@ namespace Elsa.Activities.Entity.Triggers
|
|||
|
||||
public EntityChangedTrigger()
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
public EntityChangedTrigger(string? entityName, EntityChangedAction? action, string? contextId, string? correlationId)
|
||||
|
|
@ -27,7 +26,6 @@ namespace Elsa.Activities.Entity.Triggers
|
|||
ContextId = contextId;
|
||||
CorrelationId = correlationId;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public class EntityChangedTriggerProvider : TriggerProvider<EntityChangedTrigger, EntityChanged>
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ namespace Elsa.Samples.EntityChanged
|
|||
{
|
||||
workflow
|
||||
.EntityChanged<Entity>(EntityChangedAction.Added)
|
||||
.WriteLine(context => $"Entity '{((EntityChangedDto)context.Input).EntityName}' was '{((EntityChangedDto)context.Input).Action}'");
|
||||
.WriteLine(context => $"Entity '{((EntityChangedModel)context.Input)!.EntityName}' was '{((EntityChangedModel)context.Input).Action}'");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,22 +1,20 @@
|
|||
using System.Threading.Tasks;
|
||||
|
||||
using Elsa.Activities.Entity;
|
||||
using Elsa.Activities.Entity.Triggers;
|
||||
using Elsa.Activities.Entity.Extensions;
|
||||
using Elsa.Services;
|
||||
using Elsa.Triggers;
|
||||
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
using System.Linq;
|
||||
|
||||
namespace Elsa.Samples.EntityChanged
|
||||
{
|
||||
/// <summary>
|
||||
/// Demonstrates the use of declarative composite activities.
|
||||
/// Demonstrates the use of the EntityChanged activity.
|
||||
/// </summary>
|
||||
class Program
|
||||
internal class Program
|
||||
{
|
||||
static async Task Main()
|
||||
private static async Task Main()
|
||||
{
|
||||
// Create a service container with Elsa services.
|
||||
var services = new ServiceCollection()
|
||||
|
|
@ -32,15 +30,12 @@ namespace Elsa.Samples.EntityChanged
|
|||
|
||||
var workflowSelector = services.GetRequiredService<IWorkflowSelector>();
|
||||
|
||||
var workflowSelectionResult = (await workflowSelector.SelectWorkflowsAsync<EntityChangedTrigger>(evalute =>
|
||||
(evalute.Action.HasValue == false || evalute.Action == EntityChangedAction.Added)
|
||||
&& (evalute.EntityName == null || evalute.EntityName == typeof(Entity).GetEntityName()))).First();
|
||||
var workflowSelectionResult = (await workflowSelector.SelectWorkflowsAsync<EntityChangedTrigger>(trigger =>
|
||||
(trigger.Action.HasValue == false || trigger.Action == EntityChangedAction.Added)
|
||||
&& (trigger.EntityName == null || trigger.EntityName == typeof(Entity).GetEntityName()))).First();
|
||||
|
||||
var workflowRunner = services.GetRequiredService<IWorkflowRunner>();
|
||||
|
||||
await workflowRunner.RunWorkflowAsync(workflowSelectionResult.WorkflowBlueprint, workflowSelectionResult.ActivityId);
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
Loading…
Reference in a new issue