Handle event sources in DynamicSerializer (#224)

fauna · Nov 12, 2024 · 86b3039 · 86b3039
1 parent 2424860
commit 86b3039
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/Fauna.Test/Serialization/Serializers/DynamicSerializer.Tests.cs b/Fauna.Test/Serialization/Serializers/DynamicSerializer.Tests.cs
@@ -191,4 +191,26 @@ public void RoundTripMappedClass()
         string serialized = Helpers.Serialize(Serializer.Dynamic, _ctx, deserialized);
         Assert.AreEqual("{\"@ref\":{\"id\":\"123\",\"coll\":{\"@mod\":\"MappedColl\"}}}", serialized);
     }
+
+    [Test]
+    public void RoundTripEventSource()
+    {
+        const string wire = """{"@stream":"test123="}""";
+        object? deserialized = Helpers.Deserialize(Serializer.Dynamic, _ctx, wire);
+        switch (deserialized)
+        {
+            case EventSource e:
+                Assert.AreEqual("test123=", e.Token);
+                Assert.IsNull(e.Options.Cursor);
+                Assert.IsNull(e.Options.StartTs);
+                Assert.IsNull(e.Options.PageSize);
+                break;
+            default:
+                Assert.Fail($"result is type: {deserialized?.GetType()}");
+                break;
+        }
+
+        // We do not support encoding EventSources
+        Assert.Throws<NotImplementedException>(() => Helpers.Serialize(Serializer.Dynamic, _ctx, deserialized));
+    }
 }
diff --git a/Fauna/Serialization/DynamicSerializer.cs b/Fauna/Serialization/DynamicSerializer.cs
@@ -59,6 +59,7 @@ private DynamicSerializer()
             TokenType.Module => reader.GetModule(),
             TokenType.Bytes => reader.GetBytes(),
             TokenType.Null => null,
+            TokenType.EventSource => reader.GetEventSource(),
             _ => throw new SerializationException(
                 $"Unexpected token while deserializing: {reader.CurrentTokenType}"),
         };