| | | 1 | | using System.Text.Json; |
| | | 2 | | using System.Text.Json.Serialization; |
| | | 3 | | using Elsa.Workflows.Activities.Flowchart.Models; |
| | | 4 | | using Microsoft.Extensions.Logging; |
| | | 5 | | |
| | | 6 | | namespace Elsa.Workflows.Activities.Flowchart.Serialization; |
| | | 7 | | |
| | | 8 | | /// <summary> |
| | | 9 | | /// Converts <see cref="Connection"/> to and from JSON. |
| | | 10 | | /// </summary> |
| | 4236 | 11 | | public class ConnectionJsonConverter(IDictionary<string, IActivity> activities, ILoggerFactory loggerFactory) : JsonConv |
| | | 12 | | { |
| | 4236 | 13 | | private readonly ILogger _logger = loggerFactory.CreateLogger<ConnectionJsonConverter>(); |
| | | 14 | | |
| | | 15 | | /// <inheritdoc /> |
| | 127002 | 16 | | public override bool CanConvert(Type typeToConvert) => typeToConvert == typeof(Connection); |
| | | 17 | | |
| | | 18 | | /// <inheritdoc /> |
| | | 19 | | public override Connection? Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) |
| | | 20 | | { |
| | 949 | 21 | | if (!JsonDocument.TryParseValue(ref reader, out var doc)) |
| | 0 | 22 | | throw new JsonException("Failed to parse JsonDocument"); |
| | | 23 | | |
| | 949 | 24 | | var root = doc.RootElement; |
| | | 25 | | |
| | | 26 | | // case‐insensitive get |
| | | 27 | | JsonElement Get(string name) |
| | | 28 | | { |
| | 1898 | 29 | | if (root.TryGetProperty(name, out var e)) |
| | 1898 | 30 | | return e; |
| | 0 | 31 | | var alt = char.ToUpperInvariant(name[0]) + name.Substring(1); |
| | 0 | 32 | | if (root.TryGetProperty(alt, out e)) |
| | 0 | 33 | | return e; |
| | 0 | 34 | | throw new JsonException($"Missing property '{name}' or '{alt}'"); |
| | | 35 | | } |
| | | 36 | | |
| | 949 | 37 | | var sourceElement = Get("source"); |
| | 949 | 38 | | var targetElement = Get("target"); |
| | | 39 | | |
| | | 40 | | // now inside sourceElement and targetElement, their children |
| | | 41 | | // are again PascalCased (“Activity”, “Port”), so do the same thing: |
| | | 42 | | |
| | | 43 | | string GetId(JsonElement container, string propName) |
| | | 44 | | { |
| | 1898 | 45 | | if (container.TryGetProperty(propName, out var p)) |
| | 1898 | 46 | | return p.GetString()!; |
| | 0 | 47 | | var alt = char.ToUpperInvariant(propName[0]) + propName.Substring(1); |
| | 0 | 48 | | return container.GetProperty(alt).GetString()!; |
| | | 49 | | } |
| | | 50 | | |
| | | 51 | | string? GetPort(JsonElement container, string propName) |
| | | 52 | | { |
| | 1898 | 53 | | if (container.TryGetProperty(propName, out var p)) |
| | 1898 | 54 | | return p.GetString(); |
| | 0 | 55 | | var alt = char.ToUpperInvariant(propName[0]) + propName.Substring(1); |
| | 0 | 56 | | return container.TryGetProperty(alt, out p) ? p.GetString() : null; |
| | | 57 | | } |
| | | 58 | | |
| | 949 | 59 | | var sourceId = GetId(sourceElement, "activity"); |
| | 949 | 60 | | var targetId = GetId(targetElement, "activity"); // Note: this could be null |
| | 949 | 61 | | var sourcePort = GetPort(sourceElement, "port"); |
| | 949 | 62 | | var targetPort = GetPort(targetElement, "port"); |
| | | 63 | | |
| | 949 | 64 | | var sourceAct = sourceId != null! && activities.TryGetValue(sourceId, out var s) ? s : null; |
| | 949 | 65 | | var targetAct = targetId != null! && activities.TryGetValue(targetId, out var t) ? t : null; |
| | | 66 | | |
| | 949 | 67 | | if (sourceAct == null || targetAct == null) |
| | | 68 | | { |
| | 0 | 69 | | _logger.LogWarning("Could not find source or target activity for connection. SourceId: {SourceId}, TargetId: |
| | 0 | 70 | | return null; |
| | | 71 | | } |
| | | 72 | | |
| | 949 | 73 | | var source = new Endpoint(sourceAct, sourcePort); |
| | 949 | 74 | | var target = new Endpoint(targetAct, targetPort); |
| | | 75 | | |
| | | 76 | | // vertices is already correct: |
| | 949 | 77 | | var vertices = Array.Empty<Position>(); |
| | 949 | 78 | | if (doc.RootElement.TryGetProperty("vertices", out var vertsEl) && vertsEl.ValueKind == JsonValueKind.Array) |
| | 0 | 79 | | vertices = vertsEl.Deserialize<Position[]>(options)!; |
| | | 80 | | |
| | 949 | 81 | | return new(source, target) |
| | 949 | 82 | | { |
| | 949 | 83 | | Vertices = vertices |
| | 949 | 84 | | }; |
| | | 85 | | } |
| | | 86 | | |
| | | 87 | | /// <inheritdoc /> |
| | | 88 | | public override void Write(Utf8JsonWriter writer, Connection? value, JsonSerializerOptions options) |
| | | 89 | | { |
| | 381 | 90 | | if (value == null || value.Source.Activity == null! || value.Target.Activity == null!) |
| | 0 | 91 | | return; |
| | | 92 | | |
| | 381 | 93 | | var model = new |
| | 381 | 94 | | { |
| | 381 | 95 | | Source = new |
| | 381 | 96 | | { |
| | 381 | 97 | | Activity = value.Source.Activity.Id, |
| | 381 | 98 | | Port = value.Source.Port |
| | 381 | 99 | | }, |
| | 381 | 100 | | Target = new |
| | 381 | 101 | | { |
| | 381 | 102 | | Activity = value.Target.Activity.Id, |
| | 381 | 103 | | Port = value.Target.Port |
| | 381 | 104 | | }, |
| | 381 | 105 | | Vertices = value.Vertices, |
| | 381 | 106 | | }; |
| | | 107 | | |
| | 381 | 108 | | JsonSerializer.Serialize(writer, model, options); |
| | 381 | 109 | | } |
| | | 110 | | } |