| | | 1 | | namespace Elsa.Diagnostics.ConsoleLogs.Services; |
| | | 2 | | |
| | | 3 | | internal static class ConsoleLogFilterMapper |
| | | 4 | | { |
| | | 5 | | public static ConsoleLogFilter ToStreamingFilter(ElsaConsoleLogFilter filter) |
| | | 6 | | { |
| | 17 | 7 | | var metadata = filter.Metadata != null |
| | 17 | 8 | | ? new Dictionary<string, string>(filter.Metadata, StringComparer.OrdinalIgnoreCase) |
| | 17 | 9 | | : new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase); |
| | | 10 | | |
| | 17 | 11 | | AddMetadata(metadata, ConsoleLogMetadataKeys.WorkflowInstanceId, filter.WorkflowInstanceId); |
| | 17 | 12 | | AddMetadata(metadata, ConsoleLogMetadataKeys.WorkflowDefinitionId, filter.WorkflowDefinitionId); |
| | 17 | 13 | | AddMetadata(metadata, ConsoleLogMetadataKeys.WorkflowDefinitionVersionId, filter.WorkflowDefinitionVersionId); |
| | 17 | 14 | | AddMetadata(metadata, ConsoleLogMetadataKeys.ActivityInstanceId, filter.ActivityInstanceId); |
| | 17 | 15 | | AddMetadata(metadata, ConsoleLogMetadataKeys.ActivityId, filter.ActivityId); |
| | 17 | 16 | | AddMetadata(metadata, ConsoleLogMetadataKeys.ActivityNodeId, filter.ActivityNodeId); |
| | | 17 | | |
| | 17 | 18 | | return new() |
| | 17 | 19 | | { |
| | 17 | 20 | | SourceId = filter.SourceId, |
| | 17 | 21 | | Stream = filter.Stream, |
| | 17 | 22 | | Query = filter.Query, |
| | 17 | 23 | | Metadata = metadata, |
| | 17 | 24 | | From = filter.From, |
| | 17 | 25 | | To = filter.To, |
| | 17 | 26 | | Limit = filter.Limit |
| | 17 | 27 | | }; |
| | | 28 | | } |
| | | 29 | | |
| | | 30 | | private static void AddMetadata(IDictionary<string, string> metadata, string key, string? value) |
| | | 31 | | { |
| | 102 | 32 | | if (!string.IsNullOrWhiteSpace(value)) |
| | 11 | 33 | | metadata[key] = value; |
| | 102 | 34 | | } |
| | | 35 | | } |