Add PersistWorkflow setting to Activity (#239)

src/core/Elsa.Abstractions/Messaging/Distributed/RunWorkflow.cs

@@ -1,6 +1,6 @@
 using Elsa.Models;
 
-namespace Elsa.Messages.Distributed
+namespace Elsa.Messaging.Distributed
 {
     public class RunWorkflow
     {

src/core/Elsa.Abstractions/Messaging/Domain/ActivityExecuted.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     public class ActivityExecuted : ActivityNotification
     {

src/core/Elsa.Abstractions/Messaging/Domain/ActivityExecuting.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     public class ActivityExecuting : ActivityNotification
     {

src/core/Elsa.Abstractions/Messaging/Domain/ActivityNotification.cs

@@ -2,7 +2,7 @@
 using Elsa.Services.Models;
 using MediatR;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     public abstract class ActivityNotification : INotification
     {

src/core/Elsa.Abstractions/Messaging/Domain/ExecutingWorkflow.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     public class ExecutingWorkflow : WorkflowNotification
     {

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowCancelled.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when a workflow transitioned into the Cancelled state.

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowCompleted.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when a workflow transitioned into the Completed state.

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowDefinitionStoreUpdated.cs

@@ -1,6 +1,6 @@
 using MediatR;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when the workflow definition store is updated. 

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowExecuted.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when a burst of execution finished.

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowFaulted.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when a workflow transitioned into the Faulted state.

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowNotification.cs

@@ -1,7 +1,7 @@
 using Elsa.Services.Models;
 using MediatR;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Common base for workflow-related events.

src/core/Elsa.Abstractions/Messaging/Domain/WorkflowSuspended.cs

@@ -1,6 +1,6 @@
 using Elsa.Services.Models;
 
-namespace Elsa.Messages.Domain
+namespace Elsa.Messaging.Domain
 {
     /// <summary>
     /// Published when a workflow transitioned into the Suspended state.

src/core/Elsa.Abstractions/Services/Activity.cs

@@ -21,6 +21,7 @@ namespace Elsa.Services
         public string? Name { get; set; }
         public string? DisplayName{ get; set; }
         public string? Description{ get; set; }
+        public bool PersistWorkflow { get; set; }
 
         public Task<bool> CanExecuteAsync(ActivityExecutionContext context, CancellationToken cancellationToken) => OnCanExecuteAsync(context, cancellationToken);
         public Task<IActivityExecutionResult> ExecuteAsync(ActivityExecutionContext context, CancellationToken cancellationToken) => OnExecuteAsync(context, cancellationToken);

src/core/Elsa.Abstractions/Services/IActivity.cs

@@ -37,6 +37,11 @@ namespace Elsa.Services
         /// Description of this activity.
         /// </summary>
         string? Description { get; set; }
+        
+        /// <summary>
+        /// A value indicating whether the workflow instance will be persisted automatically upon executing this activity.
+        /// </summary>
+        bool PersistWorkflow { get; set; }
 
         /// <summary>
         /// Activity output.

src/core/Elsa.Core/Activities/ControlFlow/Join/Join.cs

@@ -5,8 +5,7 @@ using System.Threading.Tasks;
 using Elsa.Attributes;
 using Elsa.Design;
 using Elsa.Extensions;
-using Elsa.Messages;
-using Elsa.Messages.Domain;
+using Elsa.Messaging.Domain;
 using Elsa.Results;
 using Elsa.Services;
 using Elsa.Services.Models;

src/core/Elsa.Core/Elsa.Core.csproj

@@ -54,7 +54,7 @@
     </ItemGroup>
 
     <ItemGroup>
-      <Folder Include="Messages\Domain" />
+      <Folder Include="Messaging\Domain" />
     </ItemGroup>
 
 </Project>

src/core/Elsa.Core/Extensions/ElsaServiceCollectionExtensions.cs

@@ -10,9 +10,9 @@ using Elsa.Caching;
 using Elsa.Converters;
 using Elsa.Expressions;
 using Elsa.Mapping;
-using Elsa.Messages;
-using Elsa.Messages.Distributed;
-using Elsa.Messages.Distributed.Handlers;
+using Elsa.Messaging;
+using Elsa.Messaging.Distributed;
+using Elsa.Messaging.Distributed.Handlers;
 using Elsa.Persistence;
 using Elsa.Persistence.Memory;
 using Elsa.Runtime;

src/core/Elsa.Core/Messages/Domain/Handlers/ActivityLoggingWorkflowEventHandler.cs

@@ -1,33 +0,0 @@
-// using Elsa.Models;
-// using Elsa.Services;
-// using Elsa.Services.Models;
-// using NodaTime;
-//
-// namespace Elsa.Messages.Handlers
-// {
-//     public class ActivityLoggingWorkflowEventHandler : WorkflowEventHandlerBase
-//     {
-//         private readonly IClock clock;
-//
-//         public ActivityLoggingWorkflowEventHandler(IClock clock)
-//         {
-//             this.clock = clock;
-//         }
-//
-//         protected override void ActivityExecuted(ProcessExecutionContext processExecutionContext, IActivity activity)
-//         {
-//             var timeStamp = clock.GetCurrentInstant();
-//             processExecutionContext.ProcessInstance.ExecutionLog.Add(
-//                 new LogEntry(activity.Id, timeStamp, $"Successfully executed at {timeStamp}"));
-//         }
-//
-//         protected override void ActivityFaulted(
-//             ProcessExecutionContext processExecutionContext,
-//             IActivity activity,
-//             string message)
-//         {
-//             processExecutionContext.ProcessInstance.ExecutionLog.Add(
-//                 new LogEntry(activity.Id, clock.GetCurrentInstant(), message, true));
-//         }
-//     }
-// }

src/core/Elsa.Core/Messaging/Distributed/Handlers/RunWorkflowHandler.cs

@@ -2,7 +2,7 @@ using System.Threading.Tasks;
 using Elsa.Services;
 using Rebus.Handlers;
 
-namespace Elsa.Messages.Distributed.Handlers
+namespace Elsa.Messaging.Distributed.Handlers
 {
     public class RunWorkflowHandler : IHandleMessages<RunWorkflow>
     {

src/core/Elsa.Core/Messaging/Domain/Handlers/PersistenceWorkflowEventHandler.cs

@@ -1,4 +1,3 @@
-using System;
 using System.Threading;
 using System.Threading.Tasks;
 using Elsa.Extensions;
@@ -8,7 +7,7 @@ using Elsa.Services.Models;
 using MediatR;
 using Microsoft.Extensions.Logging;
 
-namespace Elsa.Messages.Domain.Handlers
+namespace Elsa.Messaging.Domain.Handlers
 {
     public class PersistenceWorkflowEventHandler :
         INotificationHandler<WorkflowExecuted>,
@@ -39,7 +38,7 @@ namespace Elsa.Messages.Domain.Handlers
 
         public async Task Handle(ActivityExecuted notification, CancellationToken cancellationToken)
         {
-            if (notification.WorkflowExecutionContext.PersistenceBehavior == WorkflowPersistenceBehavior.ActivityExecuted)
+            if (notification.WorkflowExecutionContext.PersistenceBehavior == WorkflowPersistenceBehavior.ActivityExecuted || notification.Activity.PersistWorkflow)
                 await SaveWorkflowAsync(notification.WorkflowExecutionContext, cancellationToken);
         }
 

src/core/Elsa.Core/Messaging/Domain/Handlers/WorkflowExecutionLogEventHandler.cs

@@ -4,7 +4,7 @@ using Elsa.Services.Models;
 using MediatR;
 using NodaTime;
 
-namespace Elsa.Messages.Domain.Handlers
+namespace Elsa.Messaging.Domain.Handlers
 {
     public class WorkflowExecutionLogEventHandler : INotificationHandler<ActivityExecuted>
     {

src/core/Elsa.Core/Messaging/ServiceCollectionExtensions.cs

@@ -3,7 +3,7 @@ using Microsoft.Extensions.DependencyInjection;
 using Rebus.Config;
 using Rebus.ServiceProvider;
 
-namespace Elsa.Messages
+namespace Elsa.Messaging
 {
     public static class ServiceCollectionExtensions
     {

src/core/Elsa.Core/Persistence/PublishingWorkflowDefinitionStore.cs

@@ -1,8 +1,7 @@
 using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
-using Elsa.Messages;
-using Elsa.Messages.Domain;
+using Elsa.Messaging.Domain;
 using Elsa.Models;
 using MediatR;
 

src/core/Elsa.Core/Services/WorkflowHost.cs

@@ -6,8 +6,7 @@ using System.Threading.Tasks;
 using Elsa.Comparers;
 using Elsa.Expressions;
 using Elsa.Extensions;
-using Elsa.Messages;
-using Elsa.Messages.Domain;
+using Elsa.Messaging.Domain;
 using Elsa.Models;
 using Elsa.Persistence;
 using Elsa.Results;

src/core/Elsa.Core/Services/WorkflowScheduler.cs

@@ -6,8 +6,8 @@ using System.Threading.Tasks;
 using Elsa.Comparers;
 using Elsa.Expressions;
 using Elsa.Extensions;
-using Elsa.Messages.Distributed;
-using Elsa.Messages.Domain;
+using Elsa.Messaging.Distributed;
+using Elsa.Messaging.Domain;
 using Elsa.Models;
 using Elsa.Persistence;
 using Elsa.Services.Models;

src/core/Elsa.Core/StartupTasks/StartServiceBusTask.cs

@@ -1,6 +1,6 @@
 using System.Threading;
 using System.Threading.Tasks;
-using Elsa.Messages.Distributed;
+using Elsa.Messaging.Distributed;
 using Elsa.Runtime;
 using Rebus.Bus;
 

src/server/Elsa.Server.Host/Startup.cs

@@ -1,3 +1,4 @@
+using Elsa.Activities.Http.Extensions;
 using Elsa.Runtime;
 using Elsa.Server.GraphQL.Extensions;
 using Elsa.StartupTasks;