/* Copyright 2010-present MongoDB Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using System.Text;
using MongoDB.Bson.IO;
namespace MongoDB.Bson.Serialization.Serializers
{
///
/// Represents a serializer for BitArrays.
///
public class BitArraySerializer : SealedClassSerializerBase, IRepresentationConfigurable
{
// private constants
private static class Flags
{
public const long Length = 1;
public const long Bytes = 2;
}
// private fields
private readonly SerializerHelper _helper;
private readonly Int32Serializer _int32Serializer = new Int32Serializer();
private readonly BsonType _representation;
// constructors
///
/// Initializes a new instance of the class.
///
public BitArraySerializer()
: this(BsonType.Binary)
{
}
///
/// Initializes a new instance of the class.
///
/// The representation.
public BitArraySerializer(BsonType representation)
{
switch (representation)
{
case BsonType.Binary:
case BsonType.String:
break;
default:
var message = string.Format("{0} is not a valid representation for a BitArraySerializer.", representation);
throw new ArgumentException(message);
}
_representation = representation;
_helper = new SerializerHelper
(
new SerializerHelper.Member("Length", Flags.Length),
new SerializerHelper.Member("Bytes", Flags.Bytes)
);
}
// public properties
///
/// Gets the representation.
///
///
/// The representation.
///
public BsonType Representation
{
get { return _representation; }
}
// public methods
#pragma warning disable 618 // about obsolete BsonBinarySubType.OldBinary
///
/// Deserializes a value.
///
/// The deserialization context.
/// The deserialization args.
/// A deserialized value.
protected override BitArray DeserializeValue(BsonDeserializationContext context, BsonDeserializationArgs args)
{
var bsonReader = context.Reader;
BitArray bitArray;
BsonType bsonType = bsonReader.GetCurrentBsonType();
switch (bsonType)
{
case BsonType.Binary:
return new BitArray(bsonReader.ReadBytes());
case BsonType.Document:
int length = 0;
byte[] bytes = null;
_helper.DeserializeMembers(context, (elementName, flag) =>
{
switch (flag)
{
case Flags.Length: length = _int32Serializer.Deserialize(context); break;
case Flags.Bytes: bytes = bsonReader.ReadBytes(); break;
}
});
bitArray = new BitArray(bytes);
bitArray.Length = length;
return bitArray;
case BsonType.String:
var s = bsonReader.ReadString();
bitArray = new BitArray(s.Length);
for (int i = 0; i < s.Length; i++)
{
var c = s[i];
switch (c)
{
case '0':
break;
case '1':
bitArray[i] = true;
break;
default:
throw new FormatException("String value is not a valid BitArray.");
}
}
return bitArray;
default:
throw CreateCannotDeserializeFromBsonTypeException(bsonType);
}
}
#pragma warning restore 618
///
/// Serializes a value.
///
/// The serialization context.
/// The serialization args.
/// The value.
protected override void SerializeValue(BsonSerializationContext context, BsonSerializationArgs args, BitArray value)
{
var bsonWriter = context.Writer;
switch (_representation)
{
case BsonType.Binary:
if ((value.Length % 8) == 0)
{
bsonWriter.WriteBytes(GetBytes(value));
}
else
{
bsonWriter.WriteStartDocument();
bsonWriter.WriteInt32("Length", value.Length);
bsonWriter.WriteBytes("Bytes", GetBytes(value));
bsonWriter.WriteEndDocument();
}
break;
case BsonType.String:
var sb = new StringBuilder(value.Length);
for (int i = 0; i < value.Length; i++)
{
sb.Append(value[i] ? '1' : '0');
}
bsonWriter.WriteString(sb.ToString());
break;
default:
var message = string.Format("'{0}' is not a valid BitArray representation.", _representation);
throw new BsonSerializationException(message);
}
}
///
/// Returns a serializer that has been reconfigured with the specified representation.
///
/// The representation.
/// The reconfigured serializer.
public BitArraySerializer WithRepresentation(BsonType representation)
{
if (representation == _representation)
{
return this;
}
else
{
return new BitArraySerializer(representation);
}
}
// private methods
private byte[] GetBytes(BitArray bitArray)
{
// TODO: is there a more efficient way to do this?
var bytes = new byte[(bitArray.Length + 7) / 8];
var i = 0;
foreach (bool value in bitArray)
{
if (value)
{
var index = i / 8;
var bit = i % 8;
bytes[index] |= (byte)(1 << bit);
}
i++;
}
return bytes;
}
// explicit interface implementations
IBsonSerializer IRepresentationConfigurable.WithRepresentation(BsonType representation)
{
return WithRepresentation(representation);
}
}
}