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

Update WriteWorkflowExecutionLog.cs

Browse source 
Closes #2591
This commit is contained in:
Sipke Schoorstra 2021-12-20 12:53:11 +01:00
parent 834475cfca
commit 70b86f1759
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/core/Elsa.Core/Handlers/WriteWorkflowExecutionLog.cs
View file

@ -3,9 +3,11 @@ using System.Threading.Tasks;
using AutoMapper;
using Elsa.Events;
using Elsa.Models;
using Elsa.Serialization;
using Elsa.Services;
using Elsa.Services.Models;
using MediatR;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace Elsa.Handlers
@ -13,10 +15,12 @@ namespace Elsa.Handlers
public class WriteWorkflowExecutionLog : INotificationHandler<ActivityExecuting>, INotificationHandler<ActivityExecutionResultExecuted>, INotificationHandler<ActivityFaulted>
{
private readonly IMapper _mapper;
private readonly JsonSerializer _jsonSerializer;
public WriteWorkflowExecutionLog(IMapper mapper)
public WriteWorkflowExecutionLog(IMapper mapper, JsonSerializer jsonSerializer)
{
_mapper = mapper;
_jsonSerializer = jsonSerializer;
}
public Task Handle(ActivityExecuting notification, CancellationToken cancellationToken)
@ -31,11 +35,11 @@ namespace Elsa.Handlers
var data = new JObject
{
["Outcomes"] = JToken.FromObject(activityExecutionContext.Outcomes)
["Outcomes"] = JToken.FromObject(activityExecutionContext.Outcomes, _jsonSerializer)
};
foreach (var entry in activityExecutionContext.JournalData)
data[entry.Key] = entry.Value != null ? JToken.FromObject(entry.Value) : JValue.CreateNull();
data[entry.Key] = entry.Value != null ? JToken.FromObject(entry.Value, _jsonSerializer) : JValue.CreateNull();
var resuming = activityExecutionContext.Resuming;
WriteEntry(resuming ? "Resumed" : "Executed", default, activityExecutionContext, data);