JsonReaderDelegator.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / NetFx35 / System.ServiceModel.Web / System / Runtime / Serialization / Json / JsonReaderDelegator.cs / 1 / JsonReaderDelegator.cs
                        

                        
                            //---------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------

namespace System.Runtime.Serialization.Json 
{
    using System.Xml; 
    using System.ServiceModel; 
    using System.Runtime.Serialization;
    using System.Globalization; 

#if USE_REFEMIT
    public class JsonReaderDelegator : XmlReaderDelegator
#else 
    internal class JsonReaderDelegator : XmlReaderDelegator
#endif 
    { 
        public JsonReaderDelegator(XmlReader reader)
            : base(reader) 
        {
        }

        internal XmlDictionaryReaderQuotas ReaderQuotas 
        {
            get 
            { 
                if (this.dictionaryReader == null)
                { 
                    return null;
                }
                else
                { 
                    return dictionaryReader.Quotas;
                } 
            } 
        }
 
        internal static XmlQualifiedName ParseQualifiedName(string qname)
        {
            string name, ns;
            if (string.IsNullOrEmpty(qname)) 
            {
                name = ns = String.Empty; 
            } 
            else
            { 
                qname = qname.Trim();
                int colon = qname.IndexOf(':');
                if (colon >= 0)
                { 
                    name = qname.Substring(0, colon);
                    ns = qname.Substring(colon + 1); 
                } 
                else
                { 
                    name = qname;
                    ns = string.Empty;
                }
            } 
            return new XmlQualifiedName(name, ns);
        } 
 
        internal override char ReadContentAsChar()
        { 
            return XmlConvert.ToChar(ReadContentAsString());
        }

        internal override XmlQualifiedName ReadContentAsQName() 
        {
            return ParseQualifiedName(ReadContentAsString()); 
        } 

#if USE_REFEMIT 
        public override char ReadElementContentAsChar()
#else
        internal override char ReadElementContentAsChar()
#endif 
        {
            return XmlConvert.ToChar(ReadElementContentAsString()); 
        } 

#if USE_REFEMIT 
        public override byte[] ReadContentAsBase64()
#else
        internal override byte[] ReadContentAsBase64()
#endif 
        {
            if (isEndOfEmptyElement) 
                return new byte[0]; 

            byte[] buffer; 

            if (dictionaryReader == null)
            {
                XmlDictionaryReader tempDictionaryReader = XmlDictionaryReader.CreateDictionaryReader(reader); 
                buffer = ByteArrayHelperWithString.Instance.ReadArray(tempDictionaryReader, JsonGlobals.itemString, string.Empty, tempDictionaryReader.Quotas.MaxArrayLength);
            } 
            else 
            {
                buffer = ByteArrayHelperWithString.Instance.ReadArray(dictionaryReader, JsonGlobals.itemString, string.Empty, dictionaryReader.Quotas.MaxArrayLength); 
            }
            return buffer;
        }
 
#if USE_REFEMIT
        public override byte[] ReadElementContentAsBase64() 
#else 
        internal override byte[] ReadElementContentAsBase64()
#endif 
        {
            if (isEndOfEmptyElement)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(new XmlException(System.Runtime.Serialization.SR.GetString(System.Runtime.Serialization.SR.XmlStartElementExpected, "EndElement"))); 
            }
 
            bool isEmptyElement = reader.IsStartElement() && reader.IsEmptyElement; 
            byte[] buffer;
 
            if (isEmptyElement)
            {
                reader.Read();
                buffer = new byte[0]; 
            }
            else 
            { 
                reader.ReadStartElement();
                buffer = ReadContentAsBase64(); 
                reader.ReadEndElement();
            }

            return buffer; 
        }
 
        internal override DateTime ReadContentAsDateTime() 
        {
            return ParseJsonDate(ReadContentAsString()); 
        }

        internal static DateTime ParseJsonDate(string originalDateTimeValue)
        { 
            // Dates are represented in JSON as "\/Date(number of ticks)\/".
            // The number of ticks is the number of milliseconds since January 1, 1970. 
 
            string dateTimeValue;
 
            if (!string.IsNullOrEmpty(originalDateTimeValue))
            {
                dateTimeValue = originalDateTimeValue.Trim();
            } 
            else
            { 
                dateTimeValue = originalDateTimeValue; 
            }
 
            if (string.IsNullOrEmpty(dateTimeValue) ||
                !dateTimeValue.StartsWith(JsonGlobals.DateTimeStartGuardReader, StringComparison.Ordinal) ||
                !dateTimeValue.EndsWith(JsonGlobals.DateTimeEndGuardReader, StringComparison.Ordinal))
            { 
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(
                    new FormatException(SR2.GetString(SR2.JsonInvalidDateTimeString, originalDateTimeValue, JsonGlobals.DateTimeStartGuardWriter, JsonGlobals.DateTimeEndGuardWriter))); 
            } 

            string ticksvalue = dateTimeValue.Substring(6, dateTimeValue.Length - 8); 
            long millisecondsSinceUnixEpoch;
            DateTimeKind dateTimeKind = DateTimeKind.Utc;
            int indexOfTimeZoneOffset = ticksvalue.IndexOf('+', 1);
 
            if (indexOfTimeZoneOffset == -1)
            { 
                indexOfTimeZoneOffset = ticksvalue.IndexOf('-', 1); 
            }
 
            if (indexOfTimeZoneOffset != -1)
            {
                dateTimeKind = DateTimeKind.Local;
                ticksvalue = ticksvalue.Substring(0, indexOfTimeZoneOffset); 
            }
 
            try 
            {
                millisecondsSinceUnixEpoch = Int64.Parse(ticksvalue, CultureInfo.InvariantCulture); 
            }
            catch (ArgumentException exception)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(ticksvalue, "Int64", exception)); 
            }
            catch (FormatException exception) 
            { 
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(ticksvalue, "Int64", exception));
            } 
            catch (OverflowException exception)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(ticksvalue, "Int64", exception));
            } 

            // Convert from # millseconds since epoch to # of 100-nanosecond units, which is what DateTime understands 
            long ticks = millisecondsSinceUnixEpoch * 10000 + JsonGlobals.unixEpochTicks; 

            try 
            {
                DateTime dateTime = new DateTime(ticks, DateTimeKind.Utc);
                switch (dateTimeKind)
                { 
                    case DateTimeKind.Local:
                        return dateTime.ToLocalTime(); 
                    case DateTimeKind.Unspecified: 
                        return DateTime.SpecifyKind(dateTime.ToLocalTime(), DateTimeKind.Unspecified);
                    case DateTimeKind.Utc: 
                    default:
                        return dateTime;
                }
            } 
            catch (ArgumentException exception)
            { 
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(ticksvalue, "DateTime", exception)); 
            }
        } 

#if USE_REFEMIT
        public override DateTime ReadElementContentAsDateTime()
#else 
        internal override DateTime ReadElementContentAsDateTime()
#endif 
        { 
            return ParseJsonDate(ReadElementContentAsString());
        } 

        internal bool TryReadJsonDateTimeArray(XmlObjectSerializerReadContext context,
            XmlDictionaryString itemName, XmlDictionaryString itemNamespace,
            int arrayLength, out DateTime[] array) 
        {
            if ((dictionaryReader == null) || (arrayLength != -1)) 
            { 
                array = null;
                return false; 
            }

            array = DateTimeArrayJsonHelperWithString.Instance.ReadArray(dictionaryReader, XmlDictionaryString.GetString(itemName), XmlDictionaryString.GetString(itemNamespace), GetArrayLengthQuota(context));
            context.IncrementItemCount(array.Length); 

            return true; 
        } 

        class DateTimeArrayJsonHelperWithString : ArrayHelper 
        {
            static public readonly DateTimeArrayJsonHelperWithString Instance = new DateTimeArrayJsonHelperWithString();

            protected override int ReadArray(XmlDictionaryReader reader, string localName, string namespaceUri, DateTime[] array, int offset, int count) 
            {
 		XmlJsonReader.CheckArray(array, offset, count); 
                int actual = 0; 
                while (actual < count && reader.IsStartElement(JsonGlobals.itemString, string.Empty))
                { 
                    array[offset + actual] = JsonReaderDelegator.ParseJsonDate(reader.ReadElementContentAsString());
                    actual++;
                }
                return actual; 
            }
 
            protected override void WriteArray(XmlDictionaryWriter writer, string prefix, string localName, string namespaceUri, DateTime[] array, int offset, int count) 
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); 
            }
        }

        // Overridden because base reader relies on XmlConvert.ToUInt64 for conversion to ulong 
        internal override ulong ReadContentAsUnsignedLong()
        { 
            string value = reader.ReadContentAsString(); 

            if (value == null || value.Length == 0) 
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(new XmlException(XmlObjectSerializer.TryAddLineInfo(this, System.ServiceModel.SR.GetString(System.Runtime.Serialization.SR.XmlInvalidConversion, value, "UInt64"))));
            }
 
            try
            { 
                return ulong.Parse(value, NumberStyles.Float, NumberFormatInfo.InvariantInfo); 
            }
            catch (ArgumentException exception) 
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception));
            }
            catch (FormatException exception) 
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception)); 
            } 
            catch (OverflowException exception)
            { 
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception));
            }
        }
 
        // Overridden because base reader relies on XmlConvert.ToUInt64 for conversion to ulong
#if USE_REFEMIT 
        [CLSCompliant(false)] 
        public override UInt64 ReadElementContentAsUnsignedLong()
#else 
        internal override UInt64 ReadElementContentAsUnsignedLong()
#endif
        {
            if (isEndOfEmptyElement) 
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(new XmlException(System.Runtime.Serialization.SR.GetString(System.Runtime.Serialization.SR.XmlStartElementExpected, "EndElement"))); 
            } 

            string value = reader.ReadElementContentAsString(); 

            if (value == null || value.Length == 0)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(new XmlException(XmlObjectSerializer.TryAddLineInfo(this, System.Runtime.Serialization.SR.GetString(System.Runtime.Serialization.SR.XmlInvalidConversion, value, "UInt64")))); 
            }
 
            try 
            {
                return ulong.Parse(value, NumberStyles.Float, NumberFormatInfo.InvariantInfo); 
            }
            catch (ArgumentException exception)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception)); 
            }
            catch (FormatException exception) 
            { 
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception));
            } 
            catch (OverflowException exception)
            {
                throw System.ServiceModel.DiagnosticUtility.ExceptionUtility.ThrowHelperError(XmlExceptionHelper.CreateConversionException(value, "UInt64", exception));
            } 
        }
    } 
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.

Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK