using Newtonsoft.Json.Utilities; using System; using System.Collections; using System.Collections.Generic; using System.Collections.Specialized; using System.ComponentModel; using System.Globalization; using System.Threading; namespace Newtonsoft.Json.Linq { public abstract class JContainer : JToken, IList<JToken>, ICollection<JToken>, IEnumerable<JToken>, IEnumerable, ITypedList, IBindingList, IList, ICollection, INotifyCollectionChanged { private class JTokenReferenceEqualityComparer : IEqualityComparer<JToken> { public static readonly JTokenReferenceEqualityComparer Instance = new JTokenReferenceEqualityComparer(); public bool Equals(JToken x, JToken y) { return x == y; } public int GetHashCode(JToken obj) { return obj?.GetHashCode() ?? 0; } } internal ListChangedEventHandler _listChanged; internal AddingNewEventHandler _addingNew; internal NotifyCollectionChangedEventHandler _collectionChanged; private object _syncRoot; private bool _busy; protected abstract IList<JToken> ChildrenTokens { get; } public override bool HasValues => ChildrenTokens.Count > 0; public override JToken First { get { IList<JToken> childrenTokens = ChildrenTokens; if (childrenTokens.Count <= 0) return null; return childrenTokens[0]; } } public override JToken Last { get { IList<JToken> childrenTokens = ChildrenTokens; int count = childrenTokens.Count; if (count <= 0) return null; return childrenTokens[count - 1]; } } JToken IList<JToken>.this[int index] { get { return GetItem(index); } set { SetItem(index, value); } } bool ICollection<JToken>.IsReadOnly { get { return false; } } bool IList.IsFixedSize { get { return false; } } bool IList.IsReadOnly { get { return false; } } object IList.this[int index] { get { return GetItem(index); } set { SetItem(index, EnsureValue(value)); } } public int Count => ChildrenTokens.Count; bool ICollection.IsSynchronized { get { return false; } } object ICollection.SyncRoot { get { if (_syncRoot == null) Interlocked.CompareExchange(ref _syncRoot, new object(), null); return _syncRoot; } } bool IBindingList.AllowEdit { get { return true; } } bool IBindingList.AllowNew { get { return true; } } bool IBindingList.AllowRemove { get { return true; } } bool IBindingList.IsSorted { get { return false; } } ListSortDirection IBindingList.SortDirection { get { return ListSortDirection.Ascending; } } PropertyDescriptor IBindingList.SortProperty { get { return null; } } bool IBindingList.SupportsChangeNotification { get { return true; } } bool IBindingList.SupportsSearching { get { return false; } } bool IBindingList.SupportsSorting { get { return false; } } public event ListChangedEventHandler ListChanged { add { _listChanged = (ListChangedEventHandler)Delegate.Combine(_listChanged, value); } remove { _listChanged = (ListChangedEventHandler)Delegate.Remove(_listChanged, value); } } public event AddingNewEventHandler AddingNew { add { _addingNew = (AddingNewEventHandler)Delegate.Combine(_addingNew, value); } remove { _addingNew = (AddingNewEventHandler)Delegate.Remove(_addingNew, value); } } public event NotifyCollectionChangedEventHandler CollectionChanged { add { _collectionChanged = (NotifyCollectionChangedEventHandler)Delegate.Combine(_collectionChanged, value); } remove { _collectionChanged = (NotifyCollectionChangedEventHandler)Delegate.Remove(_collectionChanged, value); } } internal JContainer() { } internal JContainer(JContainer other) : this() { ValidationUtils.ArgumentNotNull(other, "other"); int num = 0; foreach (JToken item in (IEnumerable<JToken>)other) { AddInternal(num, item, false); num++; } } internal void CheckReentrancy() { if (_busy) throw new InvalidOperationException("Cannot change {0} during a collection change event.".FormatWith(CultureInfo.InvariantCulture, GetType())); } internal virtual IList<JToken> CreateChildrenCollection() { return new List<JToken>(); } protected virtual void OnAddingNew(AddingNewEventArgs e) { _addingNew?.Invoke(this, e); } protected virtual void OnListChanged(ListChangedEventArgs e) { ListChangedEventHandler listChanged = _listChanged; if (listChanged != null) { _busy = true; try { listChanged(this, e); } finally { _busy = false; } } } protected virtual void OnCollectionChanged(NotifyCollectionChangedEventArgs e) { NotifyCollectionChangedEventHandler collectionChanged = _collectionChanged; if (collectionChanged != null) { _busy = true; try { collectionChanged(this, e); } finally { _busy = false; } } } internal bool ContentsEqual(JContainer container) { if (container == this) return true; IList<JToken> childrenTokens = ChildrenTokens; IList<JToken> childrenTokens2 = container.ChildrenTokens; if (childrenTokens.Count != childrenTokens2.Count) return false; for (int i = 0; i < childrenTokens.Count; i++) { if (!childrenTokens[i].DeepEquals(childrenTokens2[i])) return false; } return true; } public override JEnumerable<JToken> Children() { return new JEnumerable<JToken>(ChildrenTokens); } public override IEnumerable<T> Values<T>() { return ChildrenTokens.Convert<JToken, T>(); } public IEnumerable<JToken> Descendants() { return GetDescendants(false); } public IEnumerable<JToken> DescendantsAndSelf() { return GetDescendants(true); } internal IEnumerable<JToken> GetDescendants(bool self) { if (self) yield return (JToken)this; foreach (JToken childrenToken in ChildrenTokens) { yield return childrenToken; JContainer jContainer = childrenToken as JContainer; if (jContainer != null) { foreach (JToken item in jContainer.Descendants()) { yield return item; } } } } internal bool IsMultiContent(object content) { if (content is IEnumerable && !(content is string) && !(content is JToken)) return !(content is byte[]); return false; } internal JToken EnsureParentToken(JToken item, bool skipParentCheck) { if (item == null) return JValue.CreateNull(); if (skipParentCheck) return item; if (item.Parent != null || item == this || (item.HasValues && base.Root == item)) item = item.CloneToken(); return item; } internal int IndexOfItem(JToken item) { return ChildrenTokens.IndexOf(item, JTokenReferenceEqualityComparer.Instance); } internal virtual void InsertItem(int index, JToken item, bool skipParentCheck) { IList<JToken> childrenTokens = ChildrenTokens; if (index > childrenTokens.Count) throw new ArgumentOutOfRangeException("index", "Index must be within the bounds of the List."); CheckReentrancy(); item = EnsureParentToken(item, skipParentCheck); JToken jToken = (index == 0) ? null : childrenTokens[index - 1]; JToken jToken2 = (index == childrenTokens.Count) ? null : childrenTokens[index]; ValidateToken(item, null); item.Parent = this; item.Previous = jToken; if (jToken != null) jToken.Next = item; item.Next = jToken2; if (jToken2 != null) jToken2.Previous = item; childrenTokens.Insert(index, item); if (_listChanged != null) OnListChanged(new ListChangedEventArgs(ListChangedType.ItemAdded, index)); if (_collectionChanged != null) OnCollectionChanged(new NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Add, item, index)); } internal virtual void RemoveItemAt(int index) { IList<JToken> childrenTokens = ChildrenTokens; if (index < 0) throw new ArgumentOutOfRangeException("index", "Index is less than 0."); if (index >= childrenTokens.Count) throw new ArgumentOutOfRangeException("index", "Index is equal to or greater than Count."); CheckReentrancy(); JToken jToken = childrenTokens[index]; JToken jToken2 = (index == 0) ? null : childrenTokens[index - 1]; JToken jToken3 = (index == childrenTokens.Count - 1) ? null : childrenTokens[index + 1]; if (jToken2 != null) jToken2.Next = jToken3; if (jToken3 != null) jToken3.Previous = jToken2; jToken.Parent = null; jToken.Previous = null; jToken.Next = null; childrenTokens.RemoveAt(index); if (_listChanged != null) OnListChanged(new ListChangedEventArgs(ListChangedType.ItemDeleted, index)); if (_collectionChanged != null) OnCollectionChanged(new NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Remove, jToken, index)); } internal virtual bool RemoveItem(JToken item) { int num = IndexOfItem(item); if (num >= 0) { RemoveItemAt(num); return true; } return false; } internal virtual JToken GetItem(int index) { return ChildrenTokens[index]; } internal virtual void SetItem(int index, JToken item) { IList<JToken> childrenTokens = ChildrenTokens; if (index < 0) throw new ArgumentOutOfRangeException("index", "Index is less than 0."); if (index >= childrenTokens.Count) throw new ArgumentOutOfRangeException("index", "Index is equal to or greater than Count."); JToken jToken = childrenTokens[index]; if (!IsTokenUnchanged(jToken, item)) { CheckReentrancy(); item = EnsureParentToken(item, false); ValidateToken(item, jToken); JToken jToken2 = (index == 0) ? null : childrenTokens[index - 1]; JToken jToken3 = (index == childrenTokens.Count - 1) ? null : childrenTokens[index + 1]; item.Parent = this; item.Previous = jToken2; if (jToken2 != null) jToken2.Next = item; item.Next = jToken3; if (jToken3 != null) jToken3.Previous = item; childrenTokens[index] = item; jToken.Parent = null; jToken.Previous = null; jToken.Next = null; if (_listChanged != null) OnListChanged(new ListChangedEventArgs(ListChangedType.ItemChanged, index)); if (_collectionChanged != null) OnCollectionChanged(new NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Replace, item, jToken, index)); } } internal virtual void ClearItems() { CheckReentrancy(); IList<JToken> childrenTokens = ChildrenTokens; foreach (JToken item in childrenTokens) { item.Parent = null; item.Previous = null; item.Next = null; } childrenTokens.Clear(); if (_listChanged != null) OnListChanged(new ListChangedEventArgs(ListChangedType.Reset, -1)); if (_collectionChanged != null) OnCollectionChanged(new NotifyCollectionChangedEventArgs(NotifyCollectionChangedAction.Reset)); } internal virtual void ReplaceItem(JToken existing, JToken replacement) { if (existing != null && existing.Parent == this) { int index = IndexOfItem(existing); SetItem(index, replacement); } } internal virtual bool ContainsItem(JToken item) { return IndexOfItem(item) != -1; } internal virtual void CopyItemsTo(Array array, int arrayIndex) { if (array == null) throw new ArgumentNullException("array"); if (arrayIndex < 0) throw new ArgumentOutOfRangeException("arrayIndex", "arrayIndex is less than 0."); if (arrayIndex >= array.Length && arrayIndex != 0) throw new ArgumentException("arrayIndex is equal to or greater than the length of array."); if (Count > array.Length - arrayIndex) throw new ArgumentException("The number of elements in the source JObject is greater than the available space from arrayIndex to the end of the destination array."); int num = 0; foreach (JToken childrenToken in ChildrenTokens) { array.SetValue(childrenToken, arrayIndex + num); num++; } } internal static bool IsTokenUnchanged(JToken currentValue, JToken newValue) { JValue jValue = currentValue as JValue; if (jValue != null) { if (jValue.Type == JTokenType.Null && newValue == null) return true; return jValue.Equals(newValue); } return false; } internal virtual void ValidateToken(JToken o, JToken existing) { ValidationUtils.ArgumentNotNull(o, "o"); if (o.Type == JTokenType.Property) throw new ArgumentException("Can not add {0} to {1}.".FormatWith(CultureInfo.InvariantCulture, o.GetType(), GetType())); } public virtual void Add(object content) { AddInternal(ChildrenTokens.Count, content, false); } internal void AddAndSkipParentCheck(JToken token) { AddInternal(ChildrenTokens.Count, token, true); } public void AddFirst(object content) { AddInternal(0, content, false); } internal void AddInternal(int index, object content, bool skipParentCheck) { if (IsMultiContent(content)) { IEnumerable obj = (IEnumerable)content; int num = index; foreach (object item2 in obj) { AddInternal(num, item2, skipParentCheck); num++; } } else { JToken item = CreateFromContent(content); InsertItem(index, item, skipParentCheck); } } internal static JToken CreateFromContent(object content) { if (content is JToken) return (JToken)content; return new JValue(content); } public JsonWriter CreateWriter() { return new JTokenWriter(this); } public void ReplaceAll(object content) { ClearItems(); Add(content); } public void RemoveAll() { ClearItems(); } internal abstract void MergeItem(object content, JsonMergeSettings settings); public void Merge(object content) { MergeItem(content, new JsonMergeSettings()); } public void Merge(object content, JsonMergeSettings settings) { MergeItem(content, settings); } internal void ReadTokenFrom(JsonReader reader, JsonLoadSettings options) { int depth = reader.Depth; if (!reader.Read()) throw JsonReaderException.Create(reader, "Error reading {0} from JsonReader.".FormatWith(CultureInfo.InvariantCulture, GetType().Name)); ReadContentFrom(reader, options); if (reader.Depth > depth) throw JsonReaderException.Create(reader, "Unexpected end of content while loading {0}.".FormatWith(CultureInfo.InvariantCulture, GetType().Name)); } internal void ReadContentFrom(JsonReader r, JsonLoadSettings settings) { ValidationUtils.ArgumentNotNull(r, "r"); IJsonLineInfo lineInfo = r as IJsonLineInfo; JContainer jContainer = this; do { if (jContainer is JProperty && ((JProperty)jContainer).Value != null) { if (jContainer == this) break; jContainer = jContainer.Parent; } switch (r.TokenType) { case JsonToken.StartArray: { JArray jArray = new JArray(); jArray.SetLineInfo(lineInfo, settings); jContainer.Add(jArray); jContainer = jArray; break; } case JsonToken.EndArray: if (jContainer == this) return; jContainer = jContainer.Parent; break; case JsonToken.StartObject: { JObject jObject = new JObject(); jObject.SetLineInfo(lineInfo, settings); jContainer.Add(jObject); jContainer = jObject; break; } case JsonToken.EndObject: if (jContainer == this) return; jContainer = jContainer.Parent; break; case JsonToken.StartConstructor: { JConstructor jConstructor = new JConstructor(r.Value.ToString()); jConstructor.SetLineInfo(lineInfo, settings); jContainer.Add(jConstructor); jContainer = jConstructor; break; } case JsonToken.EndConstructor: if (jContainer == this) return; jContainer = jContainer.Parent; break; case JsonToken.Integer: case JsonToken.Float: case JsonToken.String: case JsonToken.Boolean: case JsonToken.Date: case JsonToken.Bytes: { JValue jValue = new JValue(r.Value); jValue.SetLineInfo(lineInfo, settings); jContainer.Add(jValue); break; } case JsonToken.Comment: if (settings != null && settings.CommentHandling == CommentHandling.Load) { JValue jValue = JValue.CreateComment(r.Value.ToString()); jValue.SetLineInfo(lineInfo, settings); jContainer.Add(jValue); } break; case JsonToken.Null: { JValue jValue = JValue.CreateNull(); jValue.SetLineInfo(lineInfo, settings); jContainer.Add(jValue); break; } case JsonToken.Undefined: { JValue jValue = JValue.CreateUndefined(); jValue.SetLineInfo(lineInfo, settings); jContainer.Add(jValue); break; } case JsonToken.PropertyName: { string name = r.Value.ToString(); JProperty jProperty = new JProperty(name); jProperty.SetLineInfo(lineInfo, settings); JProperty jProperty2 = ((JObject)jContainer).Property(name); if (jProperty2 == null) jContainer.Add(jProperty); else jProperty2.Replace(jProperty); jContainer = jProperty; break; } default: throw new InvalidOperationException("The JsonReader should not be on a token of type {0}.".FormatWith(CultureInfo.InvariantCulture, r.TokenType)); case JsonToken.None: break; } } while (r.Read()); } internal int ContentsHashCode() { int num = 0; foreach (JToken childrenToken in ChildrenTokens) { num ^= childrenToken.GetDeepHashCode(); } return num; } string ITypedList.GetListName(PropertyDescriptor[] listAccessors) { return string.Empty; } PropertyDescriptorCollection ITypedList.GetItemProperties(PropertyDescriptor[] listAccessors) { return (First as ICustomTypeDescriptor)?.GetProperties(); } int IList<JToken>.IndexOf(JToken item) { return IndexOfItem(item); } void IList<JToken>.Insert(int index, JToken item) { InsertItem(index, item, false); } void IList<JToken>.RemoveAt(int index) { RemoveItemAt(index); } void ICollection<JToken>.Add(JToken item) { Add(item); } void ICollection<JToken>.Clear() { ClearItems(); } bool ICollection<JToken>.Contains(JToken item) { return ContainsItem(item); } void ICollection<JToken>.CopyTo(JToken[] array, int arrayIndex) { CopyItemsTo(array, arrayIndex); } bool ICollection<JToken>.Remove(JToken item) { return RemoveItem(item); } private JToken EnsureValue(object value) { if (value == null) return null; if (value is JToken) return (JToken)value; throw new ArgumentException("Argument is not a JToken."); } int IList.Add(object value) { Add(EnsureValue(value)); return Count - 1; } void IList.Clear() { ClearItems(); } bool IList.Contains(object value) { return ContainsItem(EnsureValue(value)); } int IList.IndexOf(object value) { return IndexOfItem(EnsureValue(value)); } void IList.Insert(int index, object value) { InsertItem(index, EnsureValue(value), false); } void IList.Remove(object value) { RemoveItem(EnsureValue(value)); } void IList.RemoveAt(int index) { RemoveItemAt(index); } void ICollection.CopyTo(Array array, int index) { CopyItemsTo(array, index); } void IBindingList.AddIndex(PropertyDescriptor property) { } object IBindingList.AddNew() { AddingNewEventArgs addingNewEventArgs = new AddingNewEventArgs(); OnAddingNew(addingNewEventArgs); if (addingNewEventArgs.NewObject == null) throw new JsonException("Could not determine new value to add to '{0}'.".FormatWith(CultureInfo.InvariantCulture, GetType())); if (!(addingNewEventArgs.NewObject is JToken)) throw new JsonException("New item to be added to collection must be compatible with {0}.".FormatWith(CultureInfo.InvariantCulture, typeof(JToken))); JToken jToken = (JToken)addingNewEventArgs.NewObject; Add(jToken); return jToken; } void IBindingList.ApplySort(PropertyDescriptor property, ListSortDirection direction) { throw new NotSupportedException(); } int IBindingList.Find(PropertyDescriptor property, object key) { throw new NotSupportedException(); } void IBindingList.RemoveIndex(PropertyDescriptor property) { } void IBindingList.RemoveSort() { throw new NotSupportedException(); } internal static void MergeEnumerableContent(JContainer target, IEnumerable content, JsonMergeSettings settings) { switch (settings.MergeArrayHandling) { case MergeArrayHandling.Concat: foreach (JToken item in content) { target.Add(item); } break; case MergeArrayHandling.Union: { HashSet<JToken> hashSet = new HashSet<JToken>(target, JToken.EqualityComparer); foreach (JToken item2 in content) { if (hashSet.Add(item2)) target.Add(item2); } break; } case MergeArrayHandling.Replace: target.ClearItems(); foreach (JToken item3 in content) { target.Add(item3); } break; case MergeArrayHandling.Merge: { int num = 0; foreach (object item4 in content) { if (num < target.Count) { JContainer jContainer = target[num] as JContainer; if (jContainer != null) jContainer.Merge(item4, settings); else if (item4 != null) { JToken jToken = CreateFromContent(item4); if (jToken.Type != JTokenType.Null) target[num] = jToken; } } else target.Add(item4); num++; } break; } default: throw new ArgumentOutOfRangeException("settings", "Unexpected merge array handling when merging JSON."); } } } }