switch to custom convert

Author: msoler8785

src/SocketLabs.EventWebhooks.Extensions/Models/WebhookEventBase.cs

@@ -2,14 +2,16 @@
 
 namespace SocketLabs.EventWebhooks.Extensions.Models
 {
-    [JsonPolymorphic(TypeDiscriminatorPropertyName = nameof(Type))]
-    [JsonDerivedType(typeof(EngagementEvent), typeDiscriminator: "Tracking")]
-    [JsonDerivedType(typeof(ComplaintEvent), typeDiscriminator: "Complaint")]
-    [JsonDerivedType(typeof(FailedEvent), typeDiscriminator: "Failed")]
-    [JsonDerivedType(typeof(SentEvent), typeDiscriminator: "Delivered")]
-    [JsonDerivedType(typeof(ValidationEvent), typeDiscriminator: "Validation")]
-    [JsonDerivedType(typeof(QueuedEvent), typeDiscriminator: "Queued")]
-    [JsonDerivedType(typeof(DeferredEvent), typeDiscriminator: "Deferred")]
+    //[JsonPolymorphic(TypeDiscriminatorPropertyName = nameof(Type))]
+    //[JsonDerivedType(typeof(EngagementEvent), typeDiscriminator: "Tracking")]
+    //[JsonDerivedType(typeof(ComplaintEvent), typeDiscriminator: "Complaint")]
+    //[JsonDerivedType(typeof(FailedEvent), typeDiscriminator: "Failed")]
+    //[JsonDerivedType(typeof(SentEvent), typeDiscriminator: "Delivered")]
+    //[JsonDerivedType(typeof(ValidationEvent), typeDiscriminator: "Validation")]
+    //[JsonDerivedType(typeof(QueuedEvent), typeDiscriminator: "Queued")]
+    //[JsonDerivedType(typeof(DeferredEvent), typeDiscriminator: "Deferred")]
+
+    [JsonConverter(typeof(WebhookEventConverter))]
     public abstract class WebhookEventBase
     {
         public string? Type { get; set; }

src/SocketLabs.EventWebhooks.Extensions/Models/WebhookEventConverter.cs

@@ -0,0 +1,42 @@
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace SocketLabs.EventWebhooks.Extensions.Models
+{
+    internal class WebhookEventConverter : JsonConverter<WebhookEventBase>
+    {
+        public override WebhookEventBase? Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
+        {
+            Utf8JsonReader readerClone = reader;
+
+            if (JsonDocument.TryParseValue(ref readerClone, out var document))
+            {
+                if (document.RootElement.TryGetProperty("Type", out var element))
+                {
+                    var typeDiscriminator = element.GetString();
+
+                    WebhookEventBase? webhookEvent = typeDiscriminator switch
+                    {
+                        "Complaint" => JsonSerializer.Deserialize<ComplaintEvent>(ref reader),
+                        "Deferred" => JsonSerializer.Deserialize<DeferredEvent>(ref reader),
+                        "Tracking" => JsonSerializer.Deserialize<EngagementEvent>(ref reader),
+                        "Failed" => JsonSerializer.Deserialize<FailedEvent>(ref reader),
+                        "Queued" => JsonSerializer.Deserialize<QueuedEvent>(ref reader),
+                        "Delivered" => JsonSerializer.Deserialize<SentEvent>(ref reader),
+                        "Validation" => JsonSerializer.Deserialize<ValidationEvent>(ref reader),
+                        _ => throw new JsonException("Unknown event type")
+                    };
+
+                    return webhookEvent;
+                }
+            }
+
+            throw new JsonException();
+        }
+
+        public override void Write(Utf8JsonWriter writer, WebhookEventBase value, JsonSerializerOptions options)
+        {
+            JsonSerializer.Serialize(writer, value, options);
+        }
+    }
+}