Abstract serialization

Author: wieslawsoltes

ChatGPT.Core/Defaults.cs

@@ -42,6 +42,7 @@ public static IServiceProvider ConfigureDefaultServices()
     {
         IServiceCollection serviceCollection = new ServiceCollection();
 
+        serviceCollection.AddSingleton<IChatSerializer, SystemTextJsonChatSerializer>();
         serviceCollection.AddSingleton<IStorageFactory, IsolatedStorageFactory>();
         serviceCollection.AddSingleton<IChatService, ChatService>();
 

ChatGPT.UI.Browser/Program.cs

@@ -38,6 +38,7 @@ private static void ConfigureDefaultServices()
         serviceCollection.AddSingleton<IStorageFactory, BrowserStorageFactory>();
         serviceCollection.AddSingleton<IApplicationService, ApplicationService>();
         serviceCollection.AddSingleton<IPluginsService, PluginsService>();
+        serviceCollection.AddSingleton<IChatSerializer, SystemTextJsonChatSerializer>();
         serviceCollection.AddSingleton<IChatService, ChatService>();
         serviceCollection.AddSingleton<ICompletionsService, CompletionsService>();
         serviceCollection.AddSingleton<MainViewModel>();

ChatGPT.UI/App.axaml.cs

@@ -37,6 +37,7 @@ public static void ConfigureDefaultServices()
         serviceCollection.AddSingleton<IStorageFactory, IsolatedStorageFactory>();
         serviceCollection.AddSingleton<IApplicationService, ApplicationService>();
         serviceCollection.AddSingleton<IPluginsService, PluginsService>();
+        serviceCollection.AddSingleton<IChatSerializer, SystemTextJsonChatSerializer>();
         serviceCollection.AddSingleton<IChatService, ChatService>();
         serviceCollection.AddSingleton<ICompletionsService, CompletionsService>();
         serviceCollection.AddSingleton<MainViewModel>();

ChatGPT/Model/Services/IChatSerializer.cs

@@ -0,0 +1,7 @@
+namespace AI.Model.Services;
+
+public interface IChatSerializer
+{
+    string Serialize<T>(T value);
+    T? Deserialize<T>(string json);
+}

ChatGPT/Model/Services/ICompletionsSerializer.cs

@@ -0,0 +1,7 @@
+namespace AI.Model.Services;
+
+public interface ICompletionsSerializer
+{
+    string Serialize<T>(T value);
+    T? Deserialize<T>(string json);
+}

ChatGPT/Services/ChatService.cs

@@ -2,8 +2,6 @@
 using System.Net;
 using System.Net.Http;
 using System.Text;
-using System.Text.Json;
-using System.Text.Json.Serialization;
 using System.Threading;
 using System.Threading.Tasks;
 using AI.Model.Json.Chat;
@@ -13,23 +11,20 @@ namespace AI.Services;
 
 public class ChatService : IChatService
 {
+    private readonly IChatSerializer _serializer;
     private static readonly HttpClient s_client;
 
-    private static readonly ChatJsonContext s_serializerContext;
-
     static ChatService()
     {
         s_client = new();
+    }
 
-        s_serializerContext = new(
-            new JsonSerializerOptions
-            {
-                DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
-                IgnoreReadOnlyProperties = true
-            });
+    public ChatService(IChatSerializer serializer)
+    {
+        _serializer = serializer;
     }
 
-    private static string GetRequestBodyJson(ChatServiceSettings settings)
+    private string GetRequestBodyJson(ChatServiceSettings settings)
     {
         // Set up the request body
         var requestBody = new ChatRequestBody
@@ -48,10 +43,10 @@ private static string GetRequestBodyJson(ChatServiceSettings settings)
         };
 
         // Serialize the request body to JSON using the JsonSerializer.
-        return JsonSerializer.Serialize(requestBody, s_serializerContext.ChatRequestBody);
+        return _serializer.Serialize(requestBody);
     }
 
-    private static async Task<ChatResponse?> SendApiRequestAsync(string apiUrl, string apiKey, string requestBodyJson, CancellationToken token)
+    private async Task<ChatResponse?> SendApiRequestAsync(string apiUrl, string apiKey, string requestBodyJson, CancellationToken token)
     {
         // Create a new HttpClient for making the API request
 
@@ -86,7 +81,7 @@ private static string GetRequestBodyJson(ChatServiceSettings settings)
             case HttpStatusCode.NotFound:
             case HttpStatusCode.BadRequest:
             {
-                return JsonSerializer.Deserialize(responseBody, s_serializerContext.ChatResponseError);
+                return _serializer.Deserialize<ChatResponseError>(responseBody);
             }
         }
 
@@ -96,7 +91,7 @@ private static string GetRequestBodyJson(ChatServiceSettings settings)
         }
 
         // Return the response data
-        return JsonSerializer.Deserialize(responseBody, s_serializerContext.ChatResponseSuccess);
+        return _serializer.Deserialize<ChatResponseSuccess>(responseBody);
     }
 
     public async Task<ChatResponse?> GetResponseDataAsync(ChatServiceSettings settings, CancellationToken token)

ChatGPT/Services/SystemTextJsonChatSerializer.cs

@@ -0,0 +1,34 @@
+using System.Text.Json;
+using System.Text.Json.Serialization;
+using System.Text.Json.Serialization.Metadata;
+using AI.Model.Json.Chat;
+using AI.Model.Services;
+
+namespace AI.Services;
+
+public class SystemTextJsonChatSerializer : IChatSerializer
+{
+    private static readonly ChatJsonContext s_serializerContext;
+
+    static SystemTextJsonChatSerializer()
+    {
+        s_serializerContext = new(
+            new JsonSerializerOptions
+            {
+                DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
+                IgnoreReadOnlyProperties = true
+            });
+    }
+
+    public string Serialize<T>(T value)
+    {
+        var typeInfo = (JsonTypeInfo<T>)s_serializerContext.GetTypeInfo(typeof(T));
+        return JsonSerializer.Serialize(value, typeInfo);
+    }
+
+    public T? Deserialize<T>(string json)
+    {
+        var typeInfo = (JsonTypeInfo<T?>)s_serializerContext.GetTypeInfo(typeof(T));
+        return JsonSerializer.Deserialize(json, typeInfo);
+    }
+}

ChatGPT/Services/SystemTextJsonCompletionsSerializer.cs

@@ -0,0 +1,34 @@
+using System.Text.Json;
+using System.Text.Json.Serialization;
+using System.Text.Json.Serialization.Metadata;
+using AI.Model.Json.Completions;
+using AI.Model.Services;
+
+namespace AI.Services;
+
+public class SystemTextJsonCompletionsSerializer : ICompletionsSerializer
+{
+    private static readonly CompletionsJsonContext s_serializerContext;
+
+    static SystemTextJsonCompletionsSerializer()
+    {
+        s_serializerContext = new(
+            new JsonSerializerOptions
+            {
+                DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
+                IgnoreReadOnlyProperties = true
+            });
+    }
+
+    public string Serialize<T>(T value)
+    {
+        var typeInfo = (JsonTypeInfo<T>)s_serializerContext.GetTypeInfo(typeof(T));
+        return JsonSerializer.Serialize(value, typeInfo);
+    }
+
+    public T? Deserialize<T>(string json)
+    {
+        var typeInfo = (JsonTypeInfo<T?>)s_serializerContext.GetTypeInfo(typeof(T));
+        return JsonSerializer.Deserialize(json, typeInfo);
+    }
+}

ChatGptCom/Chat.cs

@@ -1,5 +1,6 @@
 using System.Runtime.InteropServices;
 using AI.Model.Services;
+using AI.Services;
 using ChatGPT;
 using ChatGPT.Model.Services;
 using ChatGPT.Services;
@@ -48,6 +49,7 @@ static Chat()
         IServiceCollection serviceCollection = new ServiceCollection();
 
         serviceCollection.AddSingleton<IStorageFactory, IsolatedStorageFactory>();
+        serviceCollection.AddSingleton<IChatSerializer, NewtonsoftChatSerializer>();
         serviceCollection.AddSingleton<IChatService, ChatService>();
 
         serviceCollection.AddTransient<ChatMessageViewModel>();

ChatGptCom/ChatService.cs

@@ -0,0 +1,28 @@
+using AI.Model.Services;
+using Newtonsoft.Json;
+
+namespace ChatGptCom;
+
+public class NewtonsoftChatSerializer : IChatSerializer
+{
+    private static readonly JsonSerializerSettings s_settings;
+
+    static NewtonsoftChatSerializer()
+    {
+        s_settings = new JsonSerializerSettings
+        {
+            Formatting = Formatting.Indented,
+            NullValueHandling = NullValueHandling.Ignore,
+        };
+    }
+
+    public string Serialize<T>(T value)
+    {
+        return JsonConvert.SerializeObject(value, s_settings);
+    }
+
+    public T? Deserialize<T>(string json)
+    {
+        return JsonConvert.DeserializeObject<T>(json, s_settings);
+    }
+}