ClientSideProjectionSnippetsDeserializer.cs

/* 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.
*/

usingSystem;
usingMongoDB.Bson;
usingMongoDB.Bson.IO;
usingMongoDB.Bson.Serialization;
usingMongoDB.Bson.Serialization.Serializers;

namespaceMongoDB.Driver
{
internalstaticclassClientSideProjectionSnippetsDeserializer
{
publicstaticIBsonSerializerCreate(
TypeprojectionType,
IBsonSerializer[]snippetDeserializers,
Delegateprojector)
{
vardeserializerType=typeof(ClientSideProjectionSnippetsDeserializer<>).MakeGenericType(projectionType);
return(IBsonSerializer)Activator.CreateInstance(deserializerType,[snippetDeserializers,projector]);
}
}

internalsealedclassClientSideProjectionSnippetsDeserializer<TProjection>:SerializerBase<TProjection>,IClientSideProjectionDeserializer
{
privatereadonlyIBsonSerializer[]_snippetDeserializers;
privatereadonlyFunc<object[],TProjection>_projector;

publicClientSideProjectionSnippetsDeserializer(IBsonSerializer[]snippetDeserializers,Func<object[],TProjection>projector)
{
_snippetDeserializers=snippetDeserializers;
_projector=projector;
}

publicoverrideTProjectionDeserialize(BsonDeserializationContextcontext,BsonDeserializationArgsargs)
{
varsnippets=DeserializeSnippets(context);
return_projector(snippets);
}

privateobject[]DeserializeSnippets(BsonDeserializationContextcontext)
{
varreader=context.Reader;

reader.ReadStartDocument();
reader.ReadName("_snippets");
reader.ReadStartArray();
varsnippets=newobject[_snippetDeserializers.Length];
vari=0;
while(reader.ReadBsonType()!=BsonType.EndOfDocument)
{
if(i>=_snippetDeserializers.Length)
{
thrownewBsonSerializationException($"Expected {_snippetDeserializers.Length} snippets but found more than that.");
}
snippets[i]=_snippetDeserializers[i].Deserialize(context);
i++;
}
if(i!=_snippetDeserializers.Length)
{
thrownewBsonSerializationException($"Expected {_snippetDeserializers.Length} snippets but found {i}.");
}
reader.ReadEndArray();
reader.ReadEndDocument();

returnsnippets;
}
}
}