Add OnSerialize event on JSON, JSV & CSV Serializers

Author: mythz

src/ServiceStack.Text/CsvSerializer.cs

@@ -17,6 +17,8 @@ public class CsvSerializer
         //Don't emit UTF8 BOM by default
         public static Encoding UseEncoding { get; set; } = PclExport.Instance.GetUTF8Encoding(false);
 
+        public static Action<object> OnSerialize { get; set; }
+
         private static Dictionary<Type, WriteObjectDelegate> WriteFnCache = new Dictionary<Type, WriteObjectDelegate>();
         internal static WriteObjectDelegate GetWriteFn(Type type)
         {
@@ -394,6 +396,7 @@ public static void WriteObject(TextWriter writer, object value)
             JsState.IsCsv = true;
             try
             {
+                CsvSerializer.OnSerialize?.Invoke(value);
                 WriteCacheFn(writer, value);
             }
             finally

src/ServiceStack.Text/Json/JsonWriter.Generic.cs

@@ -215,6 +215,7 @@ public static void WriteObject(TextWriter writer, object value)
         public static void WriteRootObject(TextWriter writer, object value)
         {
             TypeConfig<T>.Init();
+            JsonSerializer.OnSerialize?.Invoke(value);
 
             JsState.Depth = 0;
             CacheFn(writer, value);

src/ServiceStack.Text/JsonSerializer.cs

@@ -40,6 +40,8 @@ public static UTF8Encoding UTF8Encoding
             set => JsConfig.UTF8Encoding = value;
         }
 
+        public static Action<object> OnSerialize { get; set; }
+
         public static T DeserializeFromString<T>(string value)
         {
             return JsonReader<T>.Parse(value) is T obj ? obj : default(T);
@@ -112,6 +114,7 @@ public static string SerializeToString(object value, Type type)
             }
             else
             {
+                OnSerialize?.Invoke(value);
                 JsonWriter.GetWriteFn(type)(writer, value);
             }
             return StringWriterThreadStatic.ReturnAndFree(writer);
@@ -149,6 +152,7 @@ public static void SerializeToWriter(object value, Type type, TextWriter writer)
                 return;
             }
 
+            OnSerialize?.Invoke(value);
             JsonWriter.GetWriteFn(type)(writer, value);
         }
 
@@ -175,6 +179,7 @@ public static void SerializeToStream<T>(T value, Stream stream)
 
         public static void SerializeToStream(object value, Type type, Stream stream)
         {
+            OnSerialize?.Invoke(value);
             var writer = new StreamWriter(stream, JsConfig.UTF8Encoding, BufferSize, leaveOpen:true);
             JsonWriter.GetWriteFn(type)(writer, value);
             writer.Flush();

src/ServiceStack.Text/Jsv/JsvWriter.Generic.cs

@@ -162,6 +162,7 @@ public static void WriteRootObject(TextWriter writer, object value)
             if (writer == null) return; //AOT
 
             TypeConfig<T>.Init();
+            TypeSerializer.OnSerialize?.Invoke(value);
 
             JsState.Depth = 0;
             CacheFn(writer, value);

src/ServiceStack.Text/TypeSerializer.cs

@@ -42,6 +42,8 @@ public static UTF8Encoding UTF8Encoding
             set => JsConfig.UTF8Encoding = value;
         }
 
+        public static Action<object> OnSerialize { get; set; }
+
         public const string DoubleQuoteString = "\"\"";
 
         /// <summary>
@@ -129,6 +131,7 @@ public static string SerializeToString(object value, Type type)
             if (value is string str)
                 return str.EncodeJsv();
 
+            OnSerialize?.Invoke(value);
             var writer = StringWriterThreadStatic.Allocate();
             JsvWriter.GetWriteFn(type)(writer, value);
             return StringWriterThreadStatic.ReturnAndFree(writer);
@@ -166,6 +169,7 @@ public static void SerializeToWriter(object value, Type type, TextWriter writer)
                 return;
             }
 
+            OnSerialize?.Invoke(value);
             JsvWriter.GetWriteFn(type)(writer, value);
         }
 
@@ -192,6 +196,7 @@ public static void SerializeToStream<T>(T value, Stream stream)
 
         public static void SerializeToStream(object value, Type type, Stream stream)
         {
+            OnSerialize?.Invoke(value);
             var writer = new StreamWriter(stream, JsConfig.UTF8Encoding);
             JsvWriter.GetWriteFn(type)(writer, value);
             writer.Flush();