-
Notifications
You must be signed in to change notification settings - Fork 26
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #28 from Mazyod/refactor/json-handling
Refactoring Json handling
- Loading branch information
Showing
15 changed files
with
402 additions
and
277 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,69 +1,161 @@ | ||
| using Newtonsoft.Json; | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using Newtonsoft.Json; | ||
| using Newtonsoft.Json.Converters; | ||
| using Newtonsoft.Json.Linq; | ||
|
|
||
| namespace Phoenix | ||
| { | ||
| /** | ||
| * An adapter for abstracting over the JSON library used. | ||
| */ | ||
| public sealed class JsonBox : IJsonBox | ||
| { | ||
| public readonly JToken Element; | ||
|
|
||
| public JsonBox(JToken element) | ||
| { | ||
| Element = element; | ||
| } | ||
|
|
||
| public static JsonBox Serialize(object obj) | ||
| { | ||
| var token = obj == null | ||
| ? JValue.CreateNull() | ||
| : JToken.FromObject(obj, JsonMessageSerializer.Serializer); | ||
|
|
||
| return new JsonBox(token); | ||
| } | ||
|
|
||
| public T Unbox<T>() | ||
| { | ||
| return Element.ToObject<T>(JsonMessageSerializer.Serializer); | ||
| } | ||
| } | ||
|
|
||
| public sealed class JsonMessageSerializer : IMessageSerializer | ||
| { | ||
| public string Serialize(Message message) | ||
| internal static readonly JsonSerializerSettings Settings = new JsonSerializerSettings | ||
| { | ||
| Converters = | ||
| { | ||
| new StringEnumConverter(), | ||
| new JsonBoxConverter(), | ||
| new MessageConverter(), | ||
| new PresencePayloadConverter(), | ||
| new PresenceMetaConverter() | ||
| }, | ||
| Formatting = Formatting.None | ||
| }; | ||
|
|
||
| internal static readonly JsonSerializer Serializer = JsonSerializer.Create(Settings); | ||
|
|
||
| public string Serialize(object element) | ||
| { | ||
| return JsonConvert.SerializeObject(element, Formatting.None, Settings); | ||
| } | ||
|
|
||
| public T Deserialize<T>(string json) | ||
| { | ||
| return JsonConvert.DeserializeObject<T>(json, Settings); | ||
| } | ||
|
|
||
| public IJsonBox Box(object element) | ||
| { | ||
| return JsonBox.Serialize(element); | ||
| } | ||
| } | ||
|
|
||
| internal sealed class JsonBoxConverter : JsonConverter<IJsonBox> | ||
| { | ||
| public override void WriteJson(JsonWriter writer, IJsonBox value, JsonSerializer serializer) | ||
| { | ||
| var element = value?.Unbox<JToken>(); | ||
| if (serializer.NullValueHandling != NullValueHandling.Ignore) | ||
| { | ||
| element ??= JValue.CreateNull(); | ||
| } | ||
|
|
||
| element?.WriteTo(writer); | ||
| } | ||
|
|
||
| public override IJsonBox ReadJson(JsonReader reader, Type objectType, IJsonBox existingValue, | ||
| bool hasExistingValue, JsonSerializer serializer) | ||
| { | ||
| return new JsonBox(JToken.Load(reader)); | ||
| } | ||
| } | ||
|
|
||
| internal sealed class MessageConverter : JsonConverter<Message> | ||
| { | ||
| public override void WriteJson(JsonWriter writer, Message value, JsonSerializer serializer) | ||
| { | ||
| return new JArray( | ||
| message.JoinRef, | ||
| message.Ref, | ||
| message.Topic, | ||
| message.Event, | ||
| // phoenix.js: consistent with phoenix, also backwards compatible | ||
| // e.g. if the backend has handle_in(event, {}, socket) | ||
| message.Payload == null | ||
| ? new JObject() | ||
| : JObject.FromObject(message.Payload) | ||
| ) | ||
| .ToString( | ||
| Formatting.None, | ||
| new StringEnumConverter() | ||
| ); | ||
| // phoenix.js: consistent with phoenix, also backwards compatible | ||
| // e.g. if the backend has handle_in(event, {}, socket) | ||
| var payload = value.Payload?.Unbox<JToken>(); | ||
| if (payload == null || payload.Type == JTokenType.Null || payload.Type == JTokenType.Undefined) | ||
| { | ||
| payload = new JObject(); | ||
| } | ||
|
|
||
| writer.WriteStartArray(); | ||
| writer.WriteValue(value.JoinRef); | ||
| writer.WriteValue(value.Ref); | ||
| writer.WriteValue(value.Topic); | ||
| writer.WriteValue(value.Event); | ||
| payload.WriteTo(writer); | ||
| writer.WriteEndArray(); | ||
| } | ||
|
|
||
| public Message Deserialize(string message) | ||
| public override Message ReadJson(JsonReader reader, Type objectType, Message existingValue, | ||
| bool hasExistingValue, JsonSerializer serializer) | ||
| { | ||
| var array = JArray.Parse(message); | ||
| var array = JArray.Load(reader); | ||
| return new Message( | ||
| joinRef: array[0].ToObject<string>(), | ||
| @ref: array[1].ToObject<string>(), | ||
| topic: array[2].ToObject<string>(), | ||
| @event: array[3].ToObject<string>(), | ||
| payload: array[4] | ||
| payload: new JsonBox(array[4]) | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| public Reply? MapReply(object payload) | ||
| internal sealed class PresencePayloadConverter : JsonConverter<PresencePayload> | ||
| { | ||
| public override void WriteJson(JsonWriter writer, PresencePayload value, JsonSerializer serializer) | ||
| { | ||
| var jObject = JObject.FromObject(payload); | ||
| return new Reply( | ||
| jObject.Value<string>("status"), | ||
| jObject["response"] | ||
| ); | ||
| value.Payload.Unbox<JToken>().WriteTo(writer); | ||
| } | ||
|
|
||
| public T MapPayload<T>(object payload) | ||
| public override PresencePayload ReadJson(JsonReader reader, Type objectType, PresencePayload existingValue, | ||
| bool hasExistingValue, JsonSerializer serializer) | ||
| { | ||
| return payload == null | ||
| ? default | ||
| : JToken.FromObject(payload).ToObject<T>(); | ||
| var obj = JObject.Load(reader); | ||
| return new PresencePayload | ||
| { | ||
| Metas = obj["metas"]?.ToObject<List<PresenceMeta>>(serializer), | ||
| Payload = new JsonBox(obj) | ||
| }; | ||
| } | ||
| } | ||
|
|
||
| public static class JsonPayloadExtensions | ||
| internal sealed class PresenceMetaConverter : JsonConverter<PresenceMeta> | ||
| { | ||
| public static T JsonResponse<T>(this Reply reply) | ||
| public override void WriteJson(JsonWriter writer, PresenceMeta value, JsonSerializer serializer) | ||
| { | ||
| return ((JToken) reply.Response).ToObject<T>(); | ||
| value.Payload.Unbox<JToken>().WriteTo(writer); | ||
| } | ||
|
|
||
| public static T JsonPayload<T>(this Message message) | ||
| public override PresenceMeta ReadJson(JsonReader reader, Type objectType, PresenceMeta existingValue, | ||
| bool hasExistingValue, JsonSerializer serializer) | ||
| { | ||
| return ((JToken) message.Payload).ToObject<T>(); | ||
| var meta = JObject.Load(reader); | ||
| return new PresenceMeta | ||
| { | ||
| PhxRef = meta.Value<string>("phx_ref"), | ||
| Payload = new JsonBox(meta) | ||
| }; | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.