using System;
using System.Collections.Generic;
using System.Data.SqlTypes;
using System.Globalization;
using DPumpHydr.WinFrmUI.WenSkin.Json.Utilities;
namespace DPumpHydr.WinFrmUI.WenSkin.Json.Converters
{
///
/// Converts a binary value to and from a base 64 string value.
///
public class BinaryConverter : JsonConverter
{
private const string BinaryTypeName = "System.Data.Linq.Binary";
private const string BinaryToArrayName = "ToArray";
private ReflectionObject _reflectionObject;
///
/// Writes the JSON representation of the object.
///
/// The to write to.
/// The value.
/// The calling serializer.
public override void WriteJson(JsonWriter writer, object value, JsonSerializer serializer)
{
if (value == null)
{
writer.WriteNull();
return;
}
byte[] byteArray = GetByteArray(value);
writer.WriteValue(byteArray);
}
private byte[] GetByteArray(object value)
{
if (value.GetType().AssignableToTypeName("System.Data.Linq.Binary"))
{
EnsureReflectionObject(value.GetType());
return (byte[])_reflectionObject.GetValue(value, "ToArray");
}
if (value is SqlBinary)
{
return ((SqlBinary)value).Value;
}
throw new JsonSerializationException("Unexpected value type when writing binary: {0}".FormatWith(CultureInfo.InvariantCulture, value.GetType()));
}
private void EnsureReflectionObject(Type t)
{
if (_reflectionObject == null)
{
_reflectionObject = ReflectionObject.Create(t, t.GetConstructor(new Type[1] { typeof(byte[]) }), "ToArray");
}
}
///
/// Reads the JSON representation of the object.
///
/// The to read from.
/// Type of the object.
/// The existing value of object being read.
/// The calling serializer.
/// The object value.
public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)
{
if (reader.TokenType == JsonToken.Null)
{
if (!ReflectionUtils.IsNullable(objectType))
{
throw JsonSerializationException.Create(reader, "Cannot convert null value to {0}.".FormatWith(CultureInfo.InvariantCulture, objectType));
}
return null;
}
byte[] array;
if (reader.TokenType == JsonToken.StartArray)
{
array = ReadByteArray(reader);
}
else
{
if (reader.TokenType != JsonToken.String)
{
throw JsonSerializationException.Create(reader, "Unexpected token parsing binary. Expected String or StartArray, got {0}.".FormatWith(CultureInfo.InvariantCulture, reader.TokenType));
}
array = Convert.FromBase64String(reader.Value.ToString());
}
Type type = (ReflectionUtils.IsNullableType(objectType) ? Nullable.GetUnderlyingType(objectType) : objectType);
if (type.AssignableToTypeName("System.Data.Linq.Binary"))
{
EnsureReflectionObject(type);
return _reflectionObject.Creator(array);
}
if (type == typeof(SqlBinary))
{
return new SqlBinary(array);
}
throw JsonSerializationException.Create(reader, "Unexpected object type when writing binary: {0}".FormatWith(CultureInfo.InvariantCulture, objectType));
}
private byte[] ReadByteArray(JsonReader reader)
{
List list = new List();
while (reader.Read())
{
switch (reader.TokenType)
{
case JsonToken.Integer:
list.Add(Convert.ToByte(reader.Value, CultureInfo.InvariantCulture));
break;
case JsonToken.EndArray:
return list.ToArray();
default:
throw JsonSerializationException.Create(reader, "Unexpected token when reading bytes: {0}".FormatWith(CultureInfo.InvariantCulture, reader.TokenType));
case JsonToken.Comment:
break;
}
}
throw JsonSerializationException.Create(reader, "Unexpected end when reading bytes.");
}
///
/// Determines whether this instance can convert the specified object type.
///
/// Type of the object.
///
/// true if this instance can convert the specified object type; otherwise, false.
///
public override bool CanConvert(Type objectType)
{
if (objectType.AssignableToTypeName("System.Data.Linq.Binary"))
{
return true;
}
if (objectType == typeof(SqlBinary) || objectType == typeof(SqlBinary?))
{
return true;
}
return false;
}
}
}