// Protocol Buffers - Google's data interchange format
// Copyright 2008 Google Inc.
// http://code.google.com/p/protobuf/
//
// 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.Collections.Generic;
using Google.ProtocolBuffers.Collections;
using Google.ProtocolBuffers.Descriptors;
namespace Google.ProtocolBuffers {
///
/// A class which represents an arbitrary set of fields of some message type.
/// This is used to implement DynamicMessage, and also to represent extensions
/// in GeneratedMessage. This class is internal, since outside users should probably
/// be using DynamicMessage.
///
/// As in the Java implementation, this class goes against the rest of the framework
/// in terms of mutability. Instead of having a mutable Builder class and an immutable
/// FieldSet class, FieldSet just has a MakeImmutable() method. This is safe so long as
/// all callers are careful not to let a mutable FieldSet escape into the open. This would
/// be impossible to guarantee if this were a public class, of course.
///
/// All repeated fields are stored as IList[object] even
/// TODO(jonskeet): Finish this comment!
///
internal sealed class FieldSet {
private static readonly FieldSet defaultInstance = new FieldSet(new Dictionary()).MakeImmutable();
private IDictionary fields;
private FieldSet(IDictionary fields) {
this.fields = fields;
}
public static FieldSet CreateInstance() {
// Use SortedList to keep fields in the canonical order
return new FieldSet(new SortedList());
}
///
/// Makes this FieldSet immutable, and returns it for convenience. Any
/// mutable repeated fields are made immutable, as well as the map itself.
///
internal FieldSet MakeImmutable() {
// First check if we have any repeated values
bool hasRepeats = false;
foreach (object value in fields.Values) {
IList list = value as IList;
if (list != null && !list.IsReadOnly) {
hasRepeats = true;
break;
}
}
if (hasRepeats) {
var tmp = new SortedList();
foreach (KeyValuePair entry in fields) {
IList list = entry.Value as IList;
tmp[entry.Key] = list == null ? entry.Value : Lists.AsReadOnly(list);
}
fields = tmp;
}
fields = Dictionaries.AsReadOnly(fields);
return this;
}
///
/// Returns the default, immutable instance with no fields defined.
///
internal static FieldSet DefaultInstance {
get { return defaultInstance; }
}
///
/// Returns an immutable mapping of fields. Note that although the mapping itself
/// is immutable, the entries may not be (i.e. any repeated values are represented by
/// mutable lists). The behaviour is not specified if the contents are mutated.
///
internal IDictionary AllFields {
get { return Dictionaries.AsReadOnly(fields); }
}
///
/// See .
///
public bool HasField(FieldDescriptor field) {
if (field.IsRepeated) {
throw new ArgumentException("HasField() can only be called on non-repeated fields.");
}
return fields.ContainsKey(field);
}
///
/// Clears all fields.
///
internal void Clear() {
fields.Clear();
}
///
/// See
///
///
/// If the field is not set, the behaviour when fetching this property varies by field type:
///
/// - For singular message values, null is returned.
/// - For singular non-message values, the default value of the field is returned.
/// - For repeated values, an empty immutable list is returned. This will be compatible
/// with IList[object], regardless of the type of the repeated item.
///
/// This method returns null if the field is a singular message type
/// and is not set; in this case it is up to the caller to fetch the
/// message's default instance. For repeated fields of message types,
/// an empty collection is returned. For repeated fields of non-message
/// types, null is returned.
///
/// When setting this property, any list values are copied, and each element is checked
/// to ensure it is of an appropriate type.
///
///
internal object this[FieldDescriptor field] {
get {
object result;
if (fields.TryGetValue(field, out result)) {
return result;
}
if (field.MappedType == MappedType.Message) {
if (field.IsRepeated) {
return new List();
} else {
return null;
}
}
return field.DefaultValue;
}
set {
if (field.IsRepeated) {
List list = value as List;
if (list == null) {
throw new ArgumentException("Wrong object type used with protocol message reflection.");
}
// Wrap the contents in a new list so that the caller cannot change
// the list's contents after setting it.
List newList = new List(list);
foreach (object element in newList) {
VerifyType(field, element);
}
value = newList;
}
else {
VerifyType(field, value);
}
fields[field] = value;
}
}
///
/// See
///
internal object this[FieldDescriptor field, int index] {
get {
if (!field.IsRepeated) {
throw new ArgumentException("Indexer specifying field and index can only be called on repeated fields.");
}
return ((IList) this[field])[index];
}
set {
if (!field.IsRepeated) {
throw new ArgumentException("Indexer specifying field and index can only be called on repeated fields.");
}
VerifyType(field, value);
object list;
if (!fields.TryGetValue(field, out list)) {
throw new ArgumentOutOfRangeException();
}
((IList) list)[index] = value;
}
}
///
/// See
///
internal void AddRepeatedField(FieldDescriptor field, object value) {
if (!field.IsRepeated) {
throw new ArgumentException("AddRepeatedField can only be called on repeated fields.");
}
VerifyType(field, value);
object list;
if (!fields.TryGetValue(field, out list)) {
list = new List();
fields[field] = list;
}
((IList) list).Add(value);
}
///
/// Returns an enumerator for the field map. Used to write the fields out.
///
internal IEnumerator> GetEnumerator() {
return fields.GetEnumerator();
}
///
/// See
///
///
/// Since FieldSet itself does not have any way of knowing about
/// required fields that aren't actually present in the set, it is up
/// to the caller to check for genuinely required fields. This property
/// merely checks that any messages present are themselves initialized.
///
internal bool IsInitialized {
get {
foreach (KeyValuePair entry in fields) {
FieldDescriptor field = entry.Key;
if (field.MappedType == MappedType.Message) {
if (field.IsRepeated) {
foreach(IMessage message in (IEnumerable) entry.Value) {
if (!message.IsInitialized) {
return false;
}
}
} else {
if (!((IMessage) entry.Value).IsInitialized) {
return false;
}
}
}
}
return true;
}
}
///
/// Verifies whether all the required fields in the specified message
/// descriptor are present in this field set, as well as whether
/// all the embedded messages are themselves initialized.
///
internal bool IsInitializedWithRespectTo(MessageDescriptor type) {
foreach (FieldDescriptor field in type.Fields) {
if (field.IsRequired && !HasField(field)) {
return false;
}
}
return IsInitialized;
}
///
/// See
///
public void ClearField(FieldDescriptor field) {
fields.Remove(field);
}
///
/// See
///
public int GetRepeatedFieldCount(FieldDescriptor field) {
if (!field.IsRepeated) {
throw new ArgumentException("GetRepeatedFieldCount() can only be called on repeated fields.");
}
return ((IList) this[field]).Count;
}
///
/// Implementation of both MergeFrom methods.
///
///
private void MergeFields(IEnumerable> otherFields) {
// Note: We don't attempt to verify that other's fields have valid
// types. Doing so would be a losing battle. We'd have to verify
// all sub-messages as well, and we'd have to make copies of all of
// them to insure that they don't change after verification (since
// the IMessage interface itself cannot enforce immutability of
// implementations).
// TODO(jonskeet): Provide a function somewhere called MakeDeepCopy()
// which allows people to make secure deep copies of messages.
foreach (KeyValuePair entry in otherFields) {
FieldDescriptor field = entry.Key;
object existingValue;
fields.TryGetValue(field, out existingValue);
if (field.IsRepeated) {
if (existingValue == null) {
existingValue = new List();
fields[field] = existingValue;
}
IList list = (IList) existingValue;
foreach (object otherValue in (IEnumerable) entry.Value) {
list.Add(otherValue);
}
} else if (field.MappedType == MappedType.Message && existingValue != null) {
IMessage existingMessage = (IMessage)existingValue;
IMessage merged = existingMessage.WeakCreateBuilderForType()
.WeakMergeFrom(existingMessage)
.WeakMergeFrom((IMessage) entry.Value)
.WeakBuild();
this[field] = merged;
} else {
this[field] = entry.Value;
}
}
}
///
/// See
///
public void MergeFrom(IMessage other) {
MergeFields(other.AllFields);
}
///
/// Like , but merges from another FieldSet .
///
public void MergeFrom(FieldSet other) {
MergeFields(other.fields);
}
///
/// See .
///
public void WriteTo(CodedOutputStream output) {
foreach (KeyValuePair entry in fields) {
WriteField(entry.Key, entry.Value, output);
}
}
///
/// Writes a single field to a CodedOutputStream.
///
public void WriteField(FieldDescriptor field, Object value, CodedOutputStream output) {
if (field.IsExtension && field.ContainingType.Options.MessageSetWireFormat) {
output.WriteMessageSetExtension(field.FieldNumber, (IMessage) value);
} else {
if (field.IsRepeated) {
foreach (object element in (IEnumerable) value) {
output.WriteField(field.FieldType, field.FieldNumber, element);
}
} else {
output.WriteField(field.FieldType, field.FieldNumber, value);
}
}
}
///
/// See . It's up to the caller to
/// cache the resulting size if desired.
///
public int SerializedSize {
get {
int size = 0;
foreach (KeyValuePair entry in fields) {
FieldDescriptor field = entry.Key;
object value = entry.Value;
if (field.IsExtension && field.ContainingType.Options.MessageSetWireFormat) {
size += CodedOutputStream.ComputeMessageSetExtensionSize(field.FieldNumber, (IMessage) value);
} else {
if (field.IsRepeated) {
foreach (object element in (IEnumerable) value) {
size += CodedOutputStream.ComputeFieldSize(field.FieldType, field.FieldNumber, element);
}
} else {
size += CodedOutputStream.ComputeFieldSize(field.FieldType, field.FieldNumber, value);
}
}
}
return size;
}
}
///
/// Verifies that the given object is of the correct type to be a valid
/// value for the given field.
///
///
/// For repeated fields, this checks if the object is of the right
/// element type, not whether it's a list.
///
/// The value is not of the right type.
private static void VerifyType(FieldDescriptor field, object value) {
bool isValid = false;
switch (field.MappedType) {
case MappedType.Int32: isValid = value is int; break;
case MappedType.Int64: isValid = value is long; break;
case MappedType.UInt32: isValid = value is uint; break;
case MappedType.UInt64: isValid = value is ulong; break;
case MappedType.Single: isValid = value is float; break;
case MappedType.Double: isValid = value is double; break;
case MappedType.Boolean: isValid = value is bool; break;
case MappedType.String: isValid = value is string; break;
case MappedType.ByteString: isValid = value is ByteString; break;
case MappedType.Enum:
EnumValueDescriptor enumValue = value as EnumValueDescriptor;
isValid = enumValue != null && enumValue.EnumDescriptor == field.EnumType;
break;
case MappedType.Message:
IMessage messageValue = value as IMessage;
isValid = messageValue != null && messageValue.DescriptorForType == field.MessageType;
break;
}
if (!isValid) {
// When chaining calls to SetField(), it can be hard to tell from
// the stack trace which exact call failed, since the whole chain is
// considered one line of code. So, let's make sure to include the
// field name and other useful info in the exception.
throw new ArgumentException("Wrong object type used with protocol message reflection. "
+ "Message type \"" + field.ContainingType.FullName
+ "\", field \"" + (field.IsExtension ? field.FullName : field.Name)
+ "\", value was type \"" + value.GetType().Name + "\".");
}
}
}
}