Refactor MessageExtras

src/IO.Ably.Shared/Types/MessageExtras.cs

@@ -1,3 +1,4 @@
+using IO.Ably.CustomSerialisers;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 
@@ -6,6 +7,7 @@ namespace IO.Ably.Types
     /// <summary>
     /// Extra properties on the Message.
     /// </summary>
+    [JsonConverter(typeof(MessageExtrasConverter))]
     public class MessageExtras
     {
         private const string DeltaProperty = "delta";
@@ -16,6 +18,7 @@ public class MessageExtras
         /// <summary>
         /// Delta extras is part of the Ably delta's functionality.
         /// </summary>
+        [JsonIgnore]
         public DeltaExtras Delta { get; }
 
         /// <summary>
@@ -41,18 +44,7 @@ public MessageExtras(JToken data = null)
         /// <returns>returns the inner json.</returns>
         public JToken ToJson()
         {
-            if (Data == null && Delta == null)
-            {
-                return null;
-            }
-
-            var result = Data?.DeepClone() ?? new JObject();
-            if (Delta != null)
-            {
-                result[DeltaProperty] = JObject.FromObject(Delta);
-            }
-
-            return result;
+            return Data?.DeepClone();
         }
     }
 

src/IO.Ably.Tests.Shared/CustomSerializers/MessageExtrasConverterTests.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using System.Linq;
 using FluentAssertions;
 using IO.Ably.CustomSerialisers;
 using IO.Ably.Types;
@@ -11,38 +12,129 @@ namespace IO.Ably.Tests.DotNetCore20.CustomSerializers
 {
     public class MessageExtrasConverterTests
     {
-        public JsonSerializerSettings JsonSettings
+        public JsonSerializerSettings JsonSettings = JsonHelper.Settings;
+
+        [Fact]
+        [Trait("spec ", "tm2i")]
+        public void ShouldParse_MessageExtrasJson()
         {
-            get
-            {
-                JsonSerializerSettings res = new JsonSerializerSettings();
-                res.Converters = new List<JsonConverter>()
-                {
-                    new MessageExtrasConverter(),
-                };
-                res.DateTimeZoneHandling = DateTimeZoneHandling.RoundtripKind;
-                res.NullValueHandling = NullValueHandling.Ignore;
-                res.ContractResolver = new CamelCasePropertyNamesContractResolver();
-                return res;
-            }
+            var json = @"
+                        {
+                            'random':'boo',
+                            'delta': {
+                                'From': '1',
+                                'Format':'best'
+                             }
+                        }";
+            var originalJToken = JToken.Parse(json);
+            var messageExtras = JsonConvert.DeserializeObject<MessageExtras>(json, JsonSettings);
+
+            messageExtras.Delta.Should().NotBeNull();
+            messageExtras.Delta.From.Should().Be("1");
+            messageExtras.Delta.Format.Should().Be("best");
+
+            ((string)messageExtras.ToJson()["random"]).Should().Be("boo");
+
+            var serialized = JsonConvert.SerializeObject(messageExtras, JsonSettings);
+            var serializedJToken = JToken.Parse(serialized);
+
+            Assert.True(JToken.DeepEquals(serializedJToken, originalJToken));
+
+            // todo: upgrade testing library - https://github.com/fluentassertions/fluentassertions.json/issues/7
+            // https://stackoverflow.com/questions/52645603/how-to-compare-two-json-objects-using-c-sharp
+
+            // serializedJToken.Should().BeEquivalentTo(originalJToken);
         }
 
         [Fact]
         [Trait("spec ", "tm2i")]
-        public void Should_parse_MessageExtras_json_correctly()
+        public void ShouldParse_MessageExtrasJson_WithEmptyDelta()
         {
-            var json = "{ \"random\":\"boo\", \"delta\":{ \"From\": \"1\", \"Format\":\"best\" } }";
-            var originalJObject = JObject.Parse(json);
+            var json = @"{
+                            'random':'boo',
+                            'foo':'fooValue',
+                            'bar':'barValue',
+                            'object' : {
+                                'key1': 'value1',
+                                'key2': 'value2'
+                            }
+                        }";
+            var originalJToken = JToken.Parse(json);
+            var messageExtras = JsonConvert.DeserializeObject<MessageExtras>(json, JsonSettings);
+            ((string)messageExtras.ToJson()["random"]).Should().Be("boo");
+            ((string)messageExtras.ToJson()["foo"]).Should().Be("fooValue");
+            ((string)messageExtras.ToJson()["bar"]).Should().Be("barValue");
+            ((string)messageExtras.ToJson()["object"]["key1"]).Should().Be("value1");
+            ((string)messageExtras.ToJson()["object"]["key2"]).Should().Be("value2");
+
+            var serialized = JsonConvert.SerializeObject(messageExtras, JsonSettings);
+            var serializedJToken = JToken.Parse(serialized);
+            Assert.True(JToken.DeepEquals(serializedJToken, originalJToken));
+        }
+
+        [Fact]
+        [Trait("spec ", "tm2i")]
+        public void ShouldParse_MessageExtrasJson_WithDelta()
+        {
+            var json = @"{
+                            'delta': {
+                                'From': '1',
+                                'Format':'best'
+                             }
+                        }";
+            var originalJToken = JToken.Parse(json);
             var messageExtras = JsonConvert.DeserializeObject<MessageExtras>(json, JsonSettings);
 
             messageExtras.Delta.Should().NotBeNull();
             messageExtras.Delta.From.Should().Be("1");
             messageExtras.Delta.Format.Should().Be("best");
-            ((string)messageExtras.ToJson()["random"]).Should().Be("boo");
 
             var serialized = JsonConvert.SerializeObject(messageExtras, JsonSettings);
-            var serializedJObject = JObject.Parse(serialized);
-            JToken.DeepEquals(serializedJObject, originalJObject).Should().BeTrue();
+            var serializedJToken = JToken.Parse(serialized);
+            Assert.True(JToken.DeepEquals(serializedJToken, originalJToken));
+        }
+
+        [Fact]
+        [Trait("spec ", "tm2i")]
+        public void ShouldParse_Message_WithNullMessageExtras()
+        {
+            var json = @"{
+                            'id':'UniqueId',
+                            'clientId':'clientId',
+                            'connectionId':'connectionId',
+                            'name':'connectionName',
+                            'data':'data',
+                            'encoding':'encoding',
+                            'extras': null
+                        }";
+
+            var messageObject = JsonConvert.DeserializeObject<Message>(json, JsonSettings);
+            messageObject.Extras.Should().BeNull();
+            var serialized = JsonConvert.SerializeObject(messageObject, JsonSettings);
+            var serializedJToken = JToken.Parse(serialized);
+            serializedJToken.Contains("extras").Should().Be(false);
+        }
+
+        [Fact]
+        [Trait("spec ", "tm2i")]
+        public void ShouldSerialize_Message_WithArbitraryMessageExtras()
+        {
+            var json = @"{
+                            'id':'UniqueId',
+                            'clientId':'clientId',
+                            'connectionId':'connectionId',
+                            'name':'connectionName',
+                            'data':'data',
+                            'extras': 'extraData',
+                            'encoding':'encoding'
+                        }";
+
+            var messageObject = JsonConvert.DeserializeObject<Message>(json, JsonSettings);
+            messageObject.Extras.Delta.Should().BeNull();
+            messageObject.Extras.ToJson().ToString().Should().Be("extraData");
+            var serialized = JsonConvert.SerializeObject(messageObject, JsonSettings);
+            var serializedJToken = JToken.Parse(serialized);
+            serializedJToken.Contains("extras").Should().Be(false);
         }
     }
 }