#nullable disable
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using StardewModdingAPI.Framework.StateTracking.Comparers;
using StardewModdingAPI.Framework.StateTracking.FieldWatchers;
using StardewValley;
using StardewValley.Buildings;
using StardewValley.Locations;
namespace StardewModdingAPI.Framework.StateTracking
{
/// Detects changes to the game's locations.
internal class WorldLocationsTracker : IWatcher
{
/*********
** Fields
*********/
/// Tracks changes to the location list.
private readonly ICollectionWatcher LocationListWatcher;
/// Tracks changes to the list of active mine locations.
private readonly ICollectionWatcher MineLocationListWatcher;
/// Tracks changes to the list of active volcano locations.
private readonly ICollectionWatcher VolcanoLocationListWatcher;
/// A lookup of the tracked locations.
private IDictionary LocationDict { get; } = new Dictionary(new ObjectReferenceComparer());
/// A lookup of registered buildings and their indoor location.
private readonly IDictionary BuildingIndoors = new Dictionary(new ObjectReferenceComparer());
/*********
** Accessors
*********/
/// Whether locations were added or removed since the last reset.
public bool IsLocationListChanged => this.Added.Any() || this.Removed.Any();
/// Whether any tracked location data changed since the last reset.
public bool IsChanged => this.IsLocationListChanged || this.Locations.Any(p => p.IsChanged);
/// The tracked locations.
public IEnumerable Locations => this.LocationDict.Values;
/// The locations removed since the last update.
public ICollection Added { get; } = new HashSet(new ObjectReferenceComparer());
/// The locations added since the last update.
public ICollection Removed { get; } = new HashSet(new ObjectReferenceComparer());
/*********
** Public methods
*********/
/// Construct an instance.
/// The game's list of locations.
/// The game's list of active mine locations.
/// The game's list of active volcano locations.
public WorldLocationsTracker(ObservableCollection locations, IList activeMineLocations, IList activeVolcanoLocations)
{
this.LocationListWatcher = WatcherFactory.ForObservableCollection(locations);
this.MineLocationListWatcher = WatcherFactory.ForReferenceList(activeMineLocations);
this.VolcanoLocationListWatcher = WatcherFactory.ForReferenceList(activeVolcanoLocations);
}
/// Update the current value if needed.
public void Update()
{
// update watchers
this.LocationListWatcher.Update();
this.MineLocationListWatcher.Update();
this.VolcanoLocationListWatcher.Update();
foreach (LocationTracker watcher in this.Locations)
watcher.Update();
// detect added/removed locations
if (this.LocationListWatcher.IsChanged)
{
this.Remove(this.LocationListWatcher.Removed);
this.Add(this.LocationListWatcher.Added);
}
if (this.MineLocationListWatcher.IsChanged)
{
this.Remove(this.MineLocationListWatcher.Removed);
this.Add(this.MineLocationListWatcher.Added);
}
if (this.VolcanoLocationListWatcher.IsChanged)
{
this.Remove(this.VolcanoLocationListWatcher.Removed);
this.Add(this.VolcanoLocationListWatcher.Added);
}
// detect building changed
foreach (LocationTracker watcher in this.Locations.Where(p => p.BuildingsWatcher.IsChanged).ToArray())
{
this.Remove(watcher.BuildingsWatcher.Removed);
this.Add(watcher.BuildingsWatcher.Added);
}
// detect building interiors changed (e.g. construction completed)
foreach (KeyValuePair pair in this.BuildingIndoors.Where(p => !object.Equals(p.Key.indoors.Value, p.Value)))
{
GameLocation oldIndoors = pair.Value;
GameLocation newIndoors = pair.Key.indoors.Value;
if (oldIndoors != null)
this.Added.Add(oldIndoors);
if (newIndoors != null)
this.Removed.Add(newIndoors);
}
}
/// Set the current location list as the baseline.
public void ResetLocationList()
{
this.Removed.Clear();
this.Added.Clear();
this.LocationListWatcher.Reset();
this.MineLocationListWatcher.Reset();
this.VolcanoLocationListWatcher.Reset();
}
/// Set the current value as the baseline.
public void Reset()
{
this.ResetLocationList();
foreach (IWatcher watcher in this.GetWatchers())
watcher.Reset();
}
/// Get whether the given location is tracked.
/// The location to check.
public bool HasLocationTracker(GameLocation location)
{
return this.LocationDict.ContainsKey(location);
}
/// Stop watching the player fields and release all references.
public void Dispose()
{
foreach (IWatcher watcher in this.GetWatchers())
watcher.Dispose();
}
/*********
** Private methods
*********/
/****
** Enumerable wrappers
****/
/// Add the given buildings.
/// The buildings to add.
public void Add(IEnumerable buildings)
{
foreach (Building building in buildings)
this.Add(building);
}
/// Add the given locations.
/// The locations to add.
public void Add(IEnumerable locations)
{
foreach (GameLocation location in locations)
this.Add(location);
}
/// Remove the given buildings.
/// The buildings to remove.
public void Remove(IEnumerable buildings)
{
foreach (Building building in buildings)
this.Remove(building);
}
/// Remove the given locations.
/// The locations to remove.
public void Remove(IEnumerable locations)
{
foreach (GameLocation location in locations)
this.Remove(location);
}
/****
** Main add/remove logic
****/
/// Add the given building.
/// The building to add.
public void Add(Building building)
{
if (building == null)
return;
GameLocation indoors = building.indoors.Value;
this.BuildingIndoors[building] = indoors;
this.Add(indoors);
}
/// Add the given location.
/// The location to add.
public void Add(GameLocation location)
{
if (location == null)
return;
// remove old location if needed
this.Remove(location);
// add location
this.Added.Add(location);
this.LocationDict[location] = new LocationTracker(location);
// add buildings
if (location is BuildableGameLocation buildableLocation)
this.Add(buildableLocation.buildings);
}
/// Remove the given building.
/// The building to remove.
public void Remove(Building building)
{
if (building == null)
return;
this.BuildingIndoors.Remove(building);
this.Remove(building.indoors.Value);
}
/// Remove the given location.
/// The location to remove.
public void Remove(GameLocation location)
{
if (location == null)
return;
if (this.LocationDict.TryGetValue(location, out LocationTracker watcher))
{
// track change
this.Removed.Add(location);
// remove
this.LocationDict.Remove(location);
watcher.Dispose();
if (location is BuildableGameLocation buildableLocation)
this.Remove(buildableLocation.buildings);
}
}
/****
** Helpers
****/
/// The underlying watchers.
private IEnumerable GetWatchers()
{
yield return this.LocationListWatcher;
yield return this.MineLocationListWatcher;
yield return this.VolcanoLocationListWatcher;
foreach (LocationTracker watcher in this.Locations)
yield return watcher;
}
}
}