| | | 1 | | using Elsa.Extensions; |
| | | 2 | | using Elsa.Mediator.Contracts; |
| | | 3 | | using Elsa.Workflows.Runtime.Entities; |
| | | 4 | | using Elsa.Workflows.Runtime.Notifications; |
| | | 5 | | |
| | | 6 | | namespace Elsa.Workflows.Runtime; |
| | | 7 | | |
| | | 8 | | /// <summary> |
| | | 9 | | /// This implementation saves <see cref="ActivityExecutionRecord"/> directly through the store. |
| | | 10 | | /// </summary> |
| | 536 | 11 | | public class StoreActivityExecutionLogSink( |
| | 536 | 12 | | IActivityExecutionStore activityExecutionStore, |
| | 536 | 13 | | INotificationSender notificationSender) |
| | | 14 | | : ILogRecordSink<ActivityExecutionRecord> |
| | | 15 | | { |
| | | 16 | | /// <inheritdoc /> |
| | | 17 | | public async Task PersistExecutionLogsAsync(WorkflowExecutionContext context, CancellationToken cancellationToken = |
| | | 18 | | { |
| | | 19 | | // Select tainted activity execution contexts to avoid saving untainted ones multiple times. |
| | 4861 | 20 | | var activityExecutionContexts = context.ActivityExecutionContexts.Where(x => x.IsDirty).ToList(); |
| | | 21 | | |
| | 567 | 22 | | if (activityExecutionContexts.Count == 0) |
| | 0 | 23 | | return; |
| | | 24 | | |
| | 4861 | 25 | | var records = await Task.WhenAll(activityExecutionContexts.Select(x => x.GetOrMapCapturedActivityExecutionRecord |
| | 567 | 26 | | await activityExecutionStore.SaveManyAsync(records, cancellationToken); |
| | | 27 | | // DefaultCommitStateHandler clears taint after the commit transaction succeeds. |
| | 567 | 28 | | await notificationSender.SendAsync(new ActivityExecutionLogUpdated(context, records), cancellationToken); |
| | 567 | 29 | | } |
| | | 30 | | } |