using System;

using System.Collections.Generic;

using Newtonsoft.Json;

using Newtonsoft.Json.Linq;

using Newtonsoft.Json.Schema;

using Newtonsoft.Json.Schema.Generation;

using Newtonsoft.Json.Serialization;

​

public class Program

{

    public static void Main()

    {               

        string json = "{\"Id\":\"94b672d2-1851-4730-bc4c-9cd4cf3c1b5e\",\"Type\":\"PriviumExtendRtpMessage\",\"Timestamp\":\"2023-10-18T11:01:34.2306468Z\",\"Content\":{\"MemberNumber\":\"PriviumNumber123\",\"ExpiryDate\":\"2024-04-18T11:01:34.2306419Z\",\"RtpMembershipId\":\"ef858743-1dab-49ea-9892-7f665c3e2d2b\"}}\r\n";

​

        var message = SerializerUtils.Deserialize<EventMessageExtended>(json);

        Console.WriteLine(message == null || message == default(EventMessageExtended));

    }   

    public static class SerializerUtils

    {

        public static string Serialize<T>(T value)

        {

            try

            {

                return JsonConvert.SerializeObject(value);

            }

            catch (Exception e)

            {

                return null;

            }

        }

​

        public static T? Deserialize<T>(string jsonObject)

        {

            try

            {

                bool isValid = SerializerUtils.ValidateSchema<T>(jsonObject);

​

                if (isValid)

                {

                    return JsonConvert.DeserializeObject<T>(jsonObject);

                }

                return default(T);

            }

            catch (Exception e)

            {

                return default(T);

            }

        }

​

        private static bool ValidateSchema<T>(string jsonData)

        {

            // Create a JSON schema generator

            var generator = new JSchemaGenerator

            {

                ContractResolver = new CaseInsensitiveContractResolver()

            };

​

            // Generate the JSON schema

            JSchema schema = generator.Generate(typeof(T));

​

            // Validate the JSON data against the schema

            JToken token = JToken.Parse(jsonData.ToLower());

            bool isValid = token.IsValid(schema, out IList<string> messages);

​

            return isValid;

        }

    }

​

    public class CaseInsensitiveContractResolver : DefaultContractResolver

    {

        protected override string ResolvePropertyName(string propertyName)

        {

            return propertyName.ToLower();

        }

    }

    public class EventMessageExtended : EventMessage

    {

        /// <summary>

        /// Number of times message was processed

        /// </summary>

        [JsonProperty(NullValueHandling = NullValueHandling.Ignore)]

        public int ProcessingCount { get; set; }

​

        /// <summary>

        /// Last time the message was processed

        /// </summary>

        [JsonProperty(NullValueHandling = NullValueHandling.Ignore)]

        public DateTime? LastProcessing { get; set; }

​

        /// <summary>

        /// The maximum timestamp of a reserved message

        /// </summary>

        [JsonProperty(NullValueHandling = NullValueHandling.Ignore)]

        public DateTime? ReservedUntil { get; set; }

​

        /// <summary>

        /// Indicates if message was deleted

        /// </summary>

        [JsonProperty(NullValueHandling = NullValueHandling.Ignore)]

        public bool Deleted { get; set; }

    }

    public class EventMessage

    {

        /// <summary>

        /// Id of the message

        /// </summary>

        public Guid Id { get; set; }

​

        /// <summary>

        /// Type of the message

        /// </summary>

        public string Type { get; set; }

​

        /// <summary>

        /// Message sending date

        /// </summary>

        public DateTime Timestamp { get; set; }

​

        public JObject Content { get; set; }

​

        public T GetContent<T>()

        {

            return this.Content.ToObject<T>();

        }

    }

​

​

​

}