using System.Collections.Generic; using System.Collections.ObjectModel; using System.Collections.Specialized; using System.Linq; namespace StardewModdingAPI.Framework.StateTracking.FieldWatchers { /// A watcher which detects changes to an observable collection. /// The value type within the collection. internal class ObservableCollectionWatcher : BaseDisposableWatcher, ICollectionWatcher { /********* ** Fields *********/ /// The field being watched. private readonly ObservableCollection Field; /// The pairs added since the last reset. private readonly List AddedImpl = new(); /// The pairs removed since the last reset. private readonly List RemovedImpl = new(); /// The previous values as of the last update. private readonly List PreviousValues = new(); /********* ** Accessors *********/ /// public bool IsChanged => this.AddedImpl.Count > 0 || this.RemovedImpl.Count > 0; /// public IEnumerable Added => this.AddedImpl; /// public IEnumerable Removed => this.RemovedImpl; /********* ** Public methods *********/ /// Construct an instance. /// The field to watch. public ObservableCollectionWatcher(ObservableCollection field) { this.Field = field; field.CollectionChanged += this.OnCollectionChanged; } /// public void Update() { this.AssertNotDisposed(); } /// public void Reset() { this.AssertNotDisposed(); this.AddedImpl.Clear(); this.RemovedImpl.Clear(); } /// public override void Dispose() { if (!this.IsDisposed) this.Field.CollectionChanged -= this.OnCollectionChanged; base.Dispose(); } /********* ** Private methods *********/ /// A callback invoked when an entry is added or removed from the collection. /// The event sender. /// The event arguments. private void OnCollectionChanged(object? sender, NotifyCollectionChangedEventArgs e) { if (e.Action == NotifyCollectionChangedAction.Reset) { this.RemovedImpl.AddRange(this.PreviousValues); this.PreviousValues.Clear(); } else { TValue[]? added = e.NewItems?.Cast().ToArray(); TValue[]? removed = e.OldItems?.Cast().ToArray(); if (removed != null) { this.RemovedImpl.AddRange(removed); this.PreviousValues.RemoveRange(e.OldStartingIndex, removed.Length); } if (added != null) { this.AddedImpl.AddRange(added); this.PreviousValues.InsertRange(e.NewStartingIndex, added); } } } } }