Revise serialization of entitymessages

src/DurableTask.Core/Entities/EntityMessageEvent.cs

@@ -13,8 +13,8 @@
 #nullable enable
 using System;
 using DurableTask.Core.Entities.EventFormat;
+using DurableTask.Core.Serializing.Internal;
 using Newtonsoft.Json;
-using Newtonsoft.Json.Linq;
 
 namespace DurableTask.Core.Entities
 {
@@ -50,21 +50,11 @@ public override string ToString()
         /// </summary>
         public OrchestrationInstance TargetInstance => this.target;
 
-        /// <summary>
-        /// Returns the content of this event, as an object that can be serialized later.
-        /// </summary>
-        /// <returns></returns>
-        public object ContentAsObject()
-        {
-            // we pre-serialize this now to avoid interference from the application-defined serialization settings
-            return JObject.FromObject(message, Serializer.InternalSerializer);
-        }
-
         /// <summary>
         /// Returns the content of this event, as a serialized string.
         /// </summary>
         /// <returns></returns>
-        public string ContentAsString()
+        public string AsSerializedString()
         {
             return JsonConvert.SerializeObject(message, Serializer.InternalSerializerSettings);
         }
@@ -78,13 +68,24 @@ public TaskMessage AsTaskMessage()
             return new TaskMessage
             {
                 OrchestrationInstance = this.target,
-                Event = new History.EventRaisedEvent(-1, this.ContentAsString())
+                Event = new History.EventRaisedEvent(-1, this.AsSerializedString())
                 {
                     Name = this.eventName
                 }
             };
         }
 
+#pragma warning disable CS0618 // Type or member is obsolete. Intentional internal usage.
+        /// <summary>
+        /// Returns the content as an already-serialized string. Can be used to bypass the application-defined serializer.
+        /// </summary>
+        /// <returns></returns>
+        public RawInput AsRawInput()
+        {
+            return new RawInput(this.AsSerializedString());
+        }
+#pragma warning restore CS0618 // Type or member is obsolete
+
         /// <summary>
         /// Utility function to compute a capped scheduled time, given a scheduled time, a timestamp representing the current time, and the maximum delay.
         /// </summary>

src/DurableTask.Core/TaskOrchestrationContext.cs

@@ -199,7 +199,8 @@ public override void SendEvent(OrchestrationInstance orchestrationInstance, stri
             }
 
             int id = this.idCounter++;
-            string serializedEventData = this.MessageDataConverter.SerializeInternal(eventData);
+
+            string serializedEventData = this.MessageDataConverter.SerializeInternal(eventData);             
 
             var action = new SendEventOrchestratorAction
             {