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.Linq; using System.Threading; namespace Newtonsoft.Json.Linq { public abstract class JContainer : JToken, IList<JToken>, ICollection<JToken>, IEnumerable<JToken>, ITypedList, IBindingList, IList, ICollection, IEnumerable, INotifyCollectionChanged { private class JTokenReferenceEqualityComparer : IEqualityComparer<JToken> { public static readonly JTokenReferenceEqualityComparer Instance = new JTokenReferenceEqualityComparer(); public bool Equals(JToken x, JToken y) { return object.ReferenceEquals(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 => ChildrenTokens.FirstOrDefault(); public override JToken Last => ChildrenTokens.LastOrDefault(); 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, "c"); foreach (JToken item in (IEnumerable<JToken>)other) { Add(item); } } 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() { foreach (JToken childrenToken in ChildrenTokens) { yield return childrenToken; JContainer c = childrenToken as JContainer; if (c != null) { foreach (JToken item in c.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 new JValue((object)null); 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) { 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) { 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) { 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(); foreach (JToken childrenToken in ChildrenTokens) { childrenToken.Parent = null; childrenToken.Previous = null; childrenToken.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 enumerable = (IEnumerable)content; int num = index; foreach (object item2 in enumerable) { AddInternal(num, item2, skipParentCheck); num++; } } else { JToken item = CreateFromContent(content); InsertItem(index, item, skipParentCheck); } } internal 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 void ReadTokenFrom(JsonReader reader) { int depth = reader.Depth; if (!reader.Read()) throw JsonReaderException.Create(reader, "Error reading {0} from JsonReader.".FormatWith(CultureInfo.InvariantCulture, GetType().Name)); ReadContentFrom(reader); int depth2 = reader.Depth; if (depth2 > depth) throw JsonReaderException.Create(reader, "Unexpected end of content while loading {0}.".FormatWith(CultureInfo.InvariantCulture, GetType().Name)); } internal void ReadContentFrom(JsonReader r) { 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); jContainer.Add(jArray); jContainer = jArray; break; } case JsonToken.EndArray: if (jContainer == this) return; jContainer = jContainer.Parent; break; case JsonToken.StartObject: { JObject jObject2 = new JObject(); jObject2.SetLineInfo(lineInfo); jContainer.Add(jObject2); jContainer = jObject2; 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); 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); jContainer.Add(jValue); break; } case JsonToken.Comment: { JValue jValue = JValue.CreateComment(r.Value.ToString()); jValue.SetLineInfo(lineInfo); jContainer.Add(jValue); break; } case JsonToken.Null: { JValue jValue = new JValue(null, JTokenType.Null); jValue.SetLineInfo(lineInfo); jContainer.Add(jValue); break; } case JsonToken.Undefined: { JValue jValue = new JValue(null, JTokenType.Undefined); jValue.SetLineInfo(lineInfo); jContainer.Add(jValue); break; } case JsonToken.PropertyName: { string name = r.Value.ToString(); JProperty jProperty = new JProperty(name); jProperty.SetLineInfo(lineInfo); JObject jObject = (JObject)jContainer; JProperty jProperty2 = jObject.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(StringUtils.FormatWith("New item to be added to collection must be compatible with {0}.", 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(); } } }