| | | 1 | | using System.Text.Json.Nodes; |
| | | 2 | | using Elsa.AI.Abstractions.Models; |
| | | 3 | | using Elsa.Workflows.Management.Entities; |
| | | 4 | | using Elsa.Workflows.Management.Models; |
| | | 5 | | |
| | | 6 | | namespace Elsa.AI.Host.Services; |
| | | 7 | | |
| | | 8 | | public class WorkflowGroundingMapper |
| | | 9 | | { |
| | | 10 | | public WorkflowGroundingSummary Map(WorkflowDefinitionSummary summary) => |
| | 0 | 11 | | new() |
| | 0 | 12 | | { |
| | 0 | 13 | | Id = summary.Id, |
| | 0 | 14 | | DefinitionId = summary.DefinitionId, |
| | 0 | 15 | | Name = summary.Name, |
| | 0 | 16 | | Description = summary.Description, |
| | 0 | 17 | | Version = summary.Version, |
| | 0 | 18 | | IsLatest = summary.IsLatest, |
| | 0 | 19 | | IsPublished = summary.IsPublished, |
| | 0 | 20 | | IsReadonly = summary.IsReadonly, |
| | 0 | 21 | | MaterializerName = summary.MaterializerName, |
| | 0 | 22 | | ProviderName = summary.ProviderName, |
| | 0 | 23 | | CreatedAt = summary.CreatedAt |
| | 0 | 24 | | }; |
| | | 25 | | |
| | | 26 | | public WorkflowGroundingSummary Map(WorkflowDefinition definition) |
| | | 27 | | { |
| | 1 | 28 | | var graph = GetGraph(definition); |
| | 1 | 29 | | return new WorkflowGroundingSummary |
| | 1 | 30 | | { |
| | 1 | 31 | | Id = definition.Id, |
| | 1 | 32 | | DefinitionId = definition.DefinitionId, |
| | 1 | 33 | | Name = definition.Name, |
| | 1 | 34 | | Description = definition.Description, |
| | 1 | 35 | | Version = definition.Version, |
| | 1 | 36 | | IsLatest = definition.IsLatest, |
| | 1 | 37 | | IsPublished = definition.IsPublished, |
| | 1 | 38 | | IsReadonly = definition.IsReadonly, |
| | 1 | 39 | | MaterializerName = definition.MaterializerName, |
| | 1 | 40 | | ProviderName = definition.ProviderName, |
| | 1 | 41 | | CreatedAt = definition.CreatedAt, |
| | 1 | 42 | | ActivityTypes = graph.ActivityTypes, |
| | 0 | 43 | | Variables = definition.Variables.Select(x => x.Name).Where(x => !string.IsNullOrWhiteSpace(x)).Distinct(Stri |
| | 0 | 44 | | Inputs = definition.Inputs.Select(x => x.Name).Where(x => !string.IsNullOrWhiteSpace(x)).Distinct(StringComp |
| | 0 | 45 | | Outputs = definition.Outputs.Select(x => x.Name).Where(x => !string.IsNullOrWhiteSpace(x)).Distinct(StringCo |
| | 1 | 46 | | }; |
| | | 47 | | } |
| | | 48 | | |
| | | 49 | | public JsonObject MapGraph(WorkflowDefinition definition) |
| | | 50 | | { |
| | 1 | 51 | | var graph = GetGraph(definition); |
| | 1 | 52 | | return new JsonObject |
| | 1 | 53 | | { |
| | 1 | 54 | | ["definitionId"] = definition.DefinitionId, |
| | 1 | 55 | | ["versionId"] = definition.Id, |
| | 1 | 56 | | ["version"] = definition.Version, |
| | 1 | 57 | | ["activityTypes"] = AIGroundingJson.ToJsonArray(graph.ActivityTypes), |
| | 1 | 58 | | ["activityCount"] = graph.ActivityCount, |
| | 1 | 59 | | ["activities"] = AIGroundingJson.ToJsonArray(graph.Activities), |
| | 0 | 60 | | ["variables"] = AIGroundingJson.ToJsonArray(definition.Variables.Select(x => x.Name).Where(x => !string.IsNu |
| | 0 | 61 | | ["inputs"] = AIGroundingJson.ToJsonArray(definition.Inputs.Select(x => x.Name).Where(x => !string.IsNullOrWh |
| | 0 | 62 | | ["outputs"] = AIGroundingJson.ToJsonArray(definition.Outputs.Select(x => x.Name).Where(x => !string.IsNullOr |
| | 1 | 63 | | }; |
| | | 64 | | } |
| | | 65 | | |
| | | 66 | | public WorkflowGraphSummary GetGraph(WorkflowDefinition definition) |
| | | 67 | | { |
| | 3 | 68 | | var root = TryParseWorkflowJson(definition); |
| | 3 | 69 | | var activities = root == null ? [] : FindActivities(root).Take(200).ToList(); |
| | 3 | 70 | | var activityTypes = activities |
| | 4 | 71 | | .Select(x => x.Type) |
| | 4 | 72 | | .Where(x => !string.IsNullOrWhiteSpace(x)) |
| | 3 | 73 | | .Distinct(StringComparer.OrdinalIgnoreCase) |
| | 3 | 74 | | .Order(StringComparer.OrdinalIgnoreCase) |
| | 3 | 75 | | .ToList(); |
| | | 76 | | |
| | 3 | 77 | | return new WorkflowGraphSummary(activities, activityTypes, activities.Count); |
| | | 78 | | } |
| | | 79 | | |
| | | 80 | | private static JsonNode? TryParseWorkflowJson(WorkflowDefinition definition) |
| | | 81 | | { |
| | 3 | 82 | | var json = !string.IsNullOrWhiteSpace(definition.OriginalSource) ? definition.OriginalSource : definition.String |
| | 3 | 83 | | if (string.IsNullOrWhiteSpace(json)) |
| | 0 | 84 | | return null; |
| | | 85 | | |
| | | 86 | | try |
| | | 87 | | { |
| | 3 | 88 | | return JsonNode.Parse(json); |
| | | 89 | | } |
| | 0 | 90 | | catch |
| | | 91 | | { |
| | 0 | 92 | | return null; |
| | | 93 | | } |
| | 3 | 94 | | } |
| | | 95 | | |
| | | 96 | | private static IEnumerable<WorkflowActivitySummary> FindActivities(JsonNode node) |
| | | 97 | | { |
| | 18 | 98 | | if (node is JsonObject jsonObject) |
| | | 99 | | { |
| | 7 | 100 | | var type = ReadString(jsonObject, "type") ?? ReadString(jsonObject, "typeName") ?? ReadString(jsonObject, "a |
| | 7 | 101 | | var id = ReadString(jsonObject, "id") ?? ReadString(jsonObject, "activityId") ?? ReadString(jsonObject, "nod |
| | 7 | 102 | | if (!string.IsNullOrWhiteSpace(type)) |
| | 4 | 103 | | yield return new WorkflowActivitySummary(id, type, ReadString(jsonObject, "name") ?? ReadString(jsonObje |
| | | 104 | | |
| | 50 | 105 | | foreach (var child in jsonObject.Select(x => x.Value).OfType<JsonNode>()) |
| | | 106 | | { |
| | 34 | 107 | | foreach (var activity in FindActivities(child)) |
| | 5 | 108 | | yield return activity; |
| | | 109 | | } |
| | | 110 | | } |
| | 11 | 111 | | else if (node is JsonArray jsonArray) |
| | | 112 | | { |
| | 12 | 113 | | foreach (var child in jsonArray.OfType<JsonNode>()) |
| | | 114 | | { |
| | 12 | 115 | | foreach (var activity in FindActivities(child)) |
| | 3 | 116 | | yield return activity; |
| | | 117 | | } |
| | | 118 | | } |
| | 18 | 119 | | } |
| | | 120 | | |
| | | 121 | | private static string? ReadString(JsonObject jsonObject, string name) => |
| | 35 | 122 | | jsonObject.TryGetPropertyValue(name, out var node) && node is JsonValue value && value.TryGetValue<string>(out v |
| | | 123 | | } |
| | | 124 | | |
| | | 125 | | public record WorkflowGraphSummary(IReadOnlyCollection<WorkflowActivitySummary> Activities, IReadOnlyCollection<string> |
| | | 126 | | |
| | | 127 | | public record WorkflowActivitySummary(string? Id, string Type, string? Name); |