fix(realtime): skip unreadable json arrays instead of failing the record

packages/Realtime/Realtime.Tests/Serialization/ArrayConverterTests.cs

@@ -140,6 +140,18 @@ public void NestedIntArrayRead_ShouldReturnNullAndKeepReading_GivenAJsonObject()
         Coerce("""{"nestedIntArray":{},"stringArray":"{ok}"}""")
             .Should().BeEquivalentTo(new { NestedIntArray = (List<List<int>>?) null, StringArray = new[] { "ok" } });
 
+    [TestMethod]
+    [DataRow("""{"intArray":[1,"x"],"stringArray":"{ok}"}""")]
+    [DataRow("""{"intArray":{},"stringArray":"{ok}"}""")]
+    public void IntArrayRead_ShouldReturnNullAndKeepReading_GivenABadJsonValue(string json) =>
+        Coerce(json).Should().BeEquivalentTo(new { IntArray = (List<int>?) null, StringArray = new[] { "ok" } });
+
+    [TestMethod]
+    [DataRow("""{"stringArray":["a",1],"intArray":"{1}"}""")]
+    [DataRow("""{"stringArray":{},"intArray":"{1}"}""")]
+    public void StringArrayRead_ShouldReturnNullAndKeepReading_GivenABadJsonValue(string json) =>
+        Coerce(json).Should().BeEquivalentTo(new { StringArray = (List<string>?) null, IntArray = new[] { 1 } });
+
     [TestMethod]
     public void IntArrayRead_ShouldReturnNull_GivenDeeplyNestedBraces() =>
         Coerce(JsonSerializer.Serialize(new { intArray = new string('{', 100_000) })).IntArray.Should().BeNull();

packages/Realtime/Realtime/Converters/IntArrayConverter.cs

@@ -18,6 +18,7 @@ public class IntArrayConverter : JsonConverter<List<int>>
     /// <inheritdoc />
     public override List<int>? Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
     {
+        var start = reader;
         try
         {
             switch (reader.TokenType)
@@ -32,11 +33,14 @@ public class IntArrayConverter : JsonConverter<List<int>>
                         list.Add(reader.GetInt32());
                     return list;
                 default:
+                    reader.Skip();
                     return null;
             }
         }
         catch
         {
+            reader = start;
+            reader.Skip();
             return null;
         }
     }

packages/Realtime/Realtime/Converters/PostgresNestedArrayConverter.cs

@@ -73,7 +73,7 @@ private class NestedConverter<TElement> : JsonConverter<List<TElement>>
                     case JsonTokenType.StartArray:
                         var list = new List<TElement>();
                         while (reader.Read() && reader.TokenType != JsonTokenType.EndArray)
-                            list.Add(JsonSerializer.Deserialize<TElement>(ref reader, options)!);
+                            list.Add(JsonSerializer.Deserialize<TElement>(ref reader, options) ?? throw new JsonException());
                         return list;
                     default:
                         reader.Skip();

packages/Realtime/Realtime/Converters/StringArrayConverter.cs

@@ -18,6 +18,7 @@ public class StringArrayConverter : JsonConverter<List<string>>
     /// <inheritdoc />
     public override List<string>? Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
     {
+        var start = reader;
         try
         {
             switch (reader.TokenType)
@@ -32,11 +33,14 @@ public class StringArrayConverter : JsonConverter<List<string>>
                         list.Add(reader.GetString()!);
                     return list;
                 default:
+                    reader.Skip();
                     return null;
             }
         }
         catch
         {
+            reader = start;
+            reader.Skip();
             return null;
         }
     }