| | | 1 | | using Elsa.Workflows.Runtime.Entities; |
| | | 2 | | |
| | | 3 | | namespace Elsa.Workflows.Runtime; |
| | | 4 | | |
| | | 5 | | /// <inheritdoc /> |
| | 519 | 6 | | public class WorkflowExecutionLogRecordExtractor(IIdentityGenerator identityGenerator) : ILogRecordExtractor<WorkflowExe |
| | | 7 | | { |
| | | 8 | | /// <inheritdoc /> |
| | | 9 | | public Task<IEnumerable<WorkflowExecutionLogRecord>> ExtractLogRecordsAsync(WorkflowExecutionContext context) |
| | | 10 | | { |
| | 8530 | 11 | | var records = context.ExecutionLog.Select(x => new WorkflowExecutionLogRecord |
| | 8530 | 12 | | { |
| | 8530 | 13 | | Id = identityGenerator.GenerateId(), |
| | 8530 | 14 | | ActivityInstanceId = x.ActivityInstanceId, |
| | 8530 | 15 | | ParentActivityInstanceId = x.ParentActivityInstanceId, |
| | 8530 | 16 | | ActivityNodeId = x.NodeId, |
| | 8530 | 17 | | ActivityId = x.ActivityId, |
| | 8530 | 18 | | ActivityType = x.ActivityType, |
| | 8530 | 19 | | ActivityTypeVersion = x.ActivityTypeVersion, |
| | 8530 | 20 | | ActivityName = x.ActivityName, |
| | 8530 | 21 | | Message = x.Message, |
| | 8530 | 22 | | EventName = x.EventName, |
| | 8530 | 23 | | WorkflowDefinitionId = context.Workflow.Identity.DefinitionId, |
| | 8530 | 24 | | WorkflowDefinitionVersionId = context.Workflow.Identity.Id, |
| | 8530 | 25 | | WorkflowInstanceId = context.Id, |
| | 8530 | 26 | | WorkflowVersion = context.Workflow.Version, |
| | 8530 | 27 | | Source = x.Source, |
| | 8530 | 28 | | Payload = x.Payload, |
| | 8530 | 29 | | Timestamp = x.Timestamp, |
| | 8530 | 30 | | Sequence = x.Sequence |
| | 8530 | 31 | | }); |
| | | 32 | | |
| | 540 | 33 | | return Task.FromResult(records); |
| | | 34 | | } |
| | | 35 | | } |