using Newtonsoft.Json.Utilities; using System; using System.Collections; using System.Collections.Generic; using System.Collections.Specialized; using System.Globalization; using System.Linq; using System.Threading; namespace Newtonsoft.Json.Linq { public abstract class JContainer : JToken, IList<JToken>, ICollection<JToken>, IEnumerable<JToken>, IList, ICollection, IEnumerable { 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 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; } } 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"); 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 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 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) { 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 (_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 (_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 (_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 (_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, new int[1] { 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 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) { int depth = reader.Depth; if (!reader.Read()) throw JsonReaderException.Create(reader, "Error reading {0} from JsonReader.".FormatWith(CultureInfo.InvariantCulture, GetType().get_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().get_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 = JValue.CreateNull(); jValue.SetLineInfo(lineInfo); jContainer.Add(jValue); break; } case JsonToken.Undefined: { JValue jValue = JValue.CreateUndefined(); 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; } 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); } 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) { JToken jToken = target[num]; JContainer jContainer = jToken as JContainer; if (jContainer != null) jContainer.Merge(item4, settings); else if (item4 != null) { JToken jToken2 = CreateFromContent(item4); if (jToken2.Type != JTokenType.Null) target[num] = jToken2; } } else target.Add(item4); num++; } break; } default: throw new ArgumentOutOfRangeException("settings", "Unexpected merge array handling when merging JSON."); } } } }