using Content.Server.Chemistry.EntitySystems; using Content.Server.Fluids.Components; using Content.Shared.Examine; using Content.Shared.FixedPoint; using Content.Shared.Fluids; using Content.Shared.StepTrigger.Components; using Content.Shared.StepTrigger.Systems; using JetBrains.Annotations; using Robust.Shared.Audio; using Robust.Shared.Map; using Robust.Shared.Player; using Solution = Content.Shared.Chemistry.Components.Solution; namespace Content.Server.Fluids.EntitySystems { [UsedImplicitly] public sealed class PuddleSystem : EntitySystem { [Dependency] private readonly SolutionContainerSystem _solutionContainerSystem = default!; [Dependency] private readonly FluidSpreaderSystem _fluidSpreaderSystem = default!; [Dependency] private readonly StepTriggerSystem _stepTrigger = default!; // Using local deletion queue instead of the standard queue so that we can easily "undelete" if a puddle // loses & then gains reagents in a single tick. private HashSet _deletionQueue = new(); public override void Initialize() { base.Initialize(); // Shouldn't need re-anchoring. SubscribeLocalEvent(OnAnchorChanged); SubscribeLocalEvent(HandlePuddleExamined); SubscribeLocalEvent(OnSolutionUpdate); SubscribeLocalEvent(OnPuddleInit); } public override void Update(float frameTime) { base.Update(frameTime); foreach (var ent in _deletionQueue) { Del(ent); } _deletionQueue.Clear(); } private void OnPuddleInit(EntityUid uid, PuddleComponent component, ComponentInit args) { var solution = _solutionContainerSystem.EnsureSolution(uid, component.SolutionName); solution.MaxVolume = FixedPoint2.New(1000); } private void OnSolutionUpdate(EntityUid uid, PuddleComponent component, SolutionChangedEvent args) { if (args.Solution.Name != component.SolutionName) return; if (args.Solution.CurrentVolume <= 0) { _deletionQueue.Add(uid); return; } _deletionQueue.Remove(uid); UpdateSlip(uid, component); UpdateAppearance(uid, component); } private void UpdateAppearance(EntityUid uid, PuddleComponent? puddleComponent = null, AppearanceComponent? appearance = null) { if (!Resolve(uid, ref puddleComponent, ref appearance, false) || EmptyHolder(uid, puddleComponent)) { return; } // Opacity based on level of fullness to overflow // Hard-cap lower bound for visibility reasons var volumeScale = CurrentVolume(puddleComponent.Owner, puddleComponent).Float() / puddleComponent.OverflowVolume.Float() * puddleComponent.OpacityModifier; var puddleSolution = _solutionContainerSystem.EnsureSolution(uid, puddleComponent.SolutionName); bool isEvaporating; if (TryComp(uid, out EvaporationComponent? evaporation) && evaporation.EvaporationToggle)// if puddle is evaporating. { isEvaporating = true; } else isEvaporating = false; appearance.SetData(PuddleVisuals.VolumeScale, volumeScale); appearance.SetData(PuddleVisuals.CurrentVolume, puddleComponent.CurrentVolume); appearance.SetData(PuddleVisuals.SolutionColor, puddleSolution.Color); appearance.SetData(PuddleVisuals.IsEvaporatingVisual, isEvaporating); } private void UpdateSlip(EntityUid entityUid, PuddleComponent puddleComponent) { if ((puddleComponent.SlipThreshold == FixedPoint2.New(-1) || CurrentVolume(puddleComponent.Owner, puddleComponent) < puddleComponent.SlipThreshold) && TryComp(entityUid, out StepTriggerComponent? stepTrigger)) { _stepTrigger.SetActive(entityUid, false, stepTrigger); } else if (CurrentVolume(puddleComponent.Owner, puddleComponent) >= puddleComponent.SlipThreshold) { var comp = EnsureComp(entityUid); _stepTrigger.SetActive(entityUid, true, comp); } } private void HandlePuddleExamined(EntityUid uid, PuddleComponent component, ExaminedEvent args) { if (TryComp(uid, out var slippery) && slippery.Active) { args.PushText(Loc.GetString("puddle-component-examine-is-slipper-text")); } } private void OnAnchorChanged(EntityUid uid, PuddleComponent puddle, ref AnchorStateChangedEvent args) { if (!args.Anchored) QueueDel(uid); } public bool EmptyHolder(EntityUid uid, PuddleComponent? puddleComponent = null) { if (!Resolve(uid, ref puddleComponent)) return true; return !_solutionContainerSystem.TryGetSolution(puddleComponent.Owner, puddleComponent.SolutionName, out var solution) || solution.Contents.Count == 0; } public FixedPoint2 CurrentVolume(EntityUid uid, PuddleComponent? puddleComponent = null) { if (!Resolve(uid, ref puddleComponent)) return FixedPoint2.Zero; return _solutionContainerSystem.TryGetSolution(puddleComponent.Owner, puddleComponent.SolutionName, out var solution) ? solution.CurrentVolume : FixedPoint2.Zero; } /// /// Try to add solution to . /// /// Puddle to which we add /// Solution that is added to puddleComponent /// Play sound on overflow /// Overflow on encountered values /// Optional resolved PuddleComponent /// public bool TryAddSolution(EntityUid puddleUid, Solution addedSolution, bool sound = true, bool checkForOverflow = true, PuddleComponent? puddleComponent = null) { if (!Resolve(puddleUid, ref puddleComponent)) return false; if (addedSolution.TotalVolume == 0 || !_solutionContainerSystem.TryGetSolution(puddleComponent.Owner, puddleComponent.SolutionName, out var solution)) { return false; } solution.AddSolution(addedSolution); _solutionContainerSystem.UpdateChemicals(puddleUid, solution, true); if (checkForOverflow && IsOverflowing(puddleUid, puddleComponent)) { _fluidSpreaderSystem.AddOverflowingPuddle(puddleComponent.Owner, puddleComponent); } if (!sound) { return true; } SoundSystem.Play(puddleComponent.SpillSound.GetSound(), Filter.Pvs(puddleComponent.Owner), puddleComponent.Owner); return true; } /// /// Given a large srcPuddle and smaller destination puddles, this method will equalize their /// /// puddle that donates liquids to other puddles /// List of puddles that we want to equalize, their puddle should be less than sourcePuddleComponent /// Total volume of src and destination puddle /// optional parameter, that after equalization adds all still overflowing puddles. /// puddleComponent for public void EqualizePuddles(EntityUid srcPuddle, List destinationPuddles, FixedPoint2 totalVolume, HashSet? stillOverflowing = null, PuddleComponent? sourcePuddleComponent = null) { if (!Resolve(srcPuddle, ref sourcePuddleComponent) || !_solutionContainerSystem.TryGetSolution(srcPuddle, sourcePuddleComponent.SolutionName, out var srcSolution)) return; var dividedVolume = totalVolume / (destinationPuddles.Count + 1); foreach (var destPuddle in destinationPuddles) { if (!_solutionContainerSystem.TryGetSolution(destPuddle.Owner, destPuddle.SolutionName, out var destSolution)) continue; var takeAmount = FixedPoint2.Max(0, dividedVolume - destSolution.CurrentVolume); TryAddSolution(destPuddle.Owner, srcSolution.SplitSolution(takeAmount), false, false, destPuddle); if (stillOverflowing != null && IsOverflowing(destPuddle.Owner, destPuddle)) { stillOverflowing.Add(destPuddle.Owner); } } if (stillOverflowing != null && srcSolution.CurrentVolume > sourcePuddleComponent.OverflowVolume) { stillOverflowing.Add(srcPuddle); } } /// /// Whether adding this solution to this puddle would overflow. /// /// Uid of owning entity /// Puddle to which we are adding solution /// Solution we intend to add /// public bool WouldOverflow(EntityUid uid, Solution solution, PuddleComponent? puddle = null) { if (!Resolve(uid, ref puddle)) return false; return CurrentVolume(uid, puddle) + solution.TotalVolume > puddle.OverflowVolume; } /// /// Whether adding this solution to this puddle would overflow. /// /// Uid of owning entity /// Puddle ref param /// private bool IsOverflowing(EntityUid uid, PuddleComponent? puddle = null) { if (!Resolve(uid, ref puddle)) return false; return CurrentVolume(uid, puddle) > puddle.OverflowVolume; } public PuddleComponent SpawnPuddle(EntityUid srcUid, EntityCoordinates pos, PuddleComponent? srcPuddleComponent = null) { MetaDataComponent? metadata = null; Resolve(srcUid, ref srcPuddleComponent, ref metadata); var prototype = metadata?.EntityPrototype?.ID ?? "PuddleSmear"; // TODO Spawn a entity based on another entity var destUid = EntityManager.SpawnEntity(prototype, pos); var destPuddle = EntityManager.EnsureComponent(destUid); return destPuddle; } } }