SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Publish WorkflowDefinitionPublished event when publishing workflow definition

Browse source
This commit is contained in:
Sipke Schoorstra 2021-03-04 12:02:33 +01:00
parent 9cf13df50d
commit 59d2cf8239
2 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/core/Elsa.Abstractions/Events/WorkflowDefinitionPublished.cs Normal file
View file

@ -0,0 +1,15 @@
using Elsa.Models;
using MediatR;
namespace Elsa.Events
{
public class WorkflowDefinitionPublished : INotification
{
public WorkflowDefinitionPublished(WorkflowDefinition workflowDefinition)
{
WorkflowDefinition = workflowDefinition;
}
public WorkflowDefinition WorkflowDefinition { get; }
}
}

7
src/core/Elsa.Core/Services/WorkflowPublisher.cs
View file

@ -1,7 +1,9 @@
using System.Threading;
using System.Threading.Tasks;
using Elsa.Events;
using Elsa.Models;
using Elsa.Persistence;
using MediatR;
using WorkflowDefinitionIdSpecification = Elsa.Persistence.Specifications.WorkflowInstances.WorkflowDefinitionIdSpecification;
namespace Elsa.Services
@ -12,13 +14,15 @@ namespace Elsa.Services
private readonly IWorkflowInstanceStore _workflowInstanceStore;
private readonly IIdGenerator _idGenerator;
private readonly ICloner _cloner;
private readonly IMediator _mediator;
public WorkflowPublisher(IWorkflowDefinitionStore workflowDefinitionStore, IWorkflowInstanceStore workflowInstanceStore, IIdGenerator idGenerator, ICloner cloner)
public WorkflowPublisher(IWorkflowDefinitionStore workflowDefinitionStore, IWorkflowInstanceStore workflowInstanceStore, IIdGenerator idGenerator, ICloner cloner, IMediator mediator)
{
_workflowDefinitionStore = workflowDefinitionStore;
_workflowInstanceStore = workflowInstanceStore;
_idGenerator = idGenerator;
_cloner = cloner;
_mediator = mediator;
}
public WorkflowDefinition New()
@ -74,6 +78,7 @@ namespace Elsa.Services
workflowDefinition = Initialize(workflowDefinition);
await _workflowDefinitionStore.SaveAsync(workflowDefinition, cancellationToken);
await _mediator.Publish(new WorkflowDefinitionPublished(workflowDefinition), cancellationToken);
return workflowDefinition;
}