using System; using System.Collections.Generic; using System.Linq; using Content.Server.Administration.Logs; using Content.Server.Atmos.Components; using Content.Server.Atmos.EntitySystems; using Content.Server.Temperature.Components; using Content.Shared.Alert; using Content.Shared.Damage; using Content.Shared.Database; using Content.Shared.Inventory; using Content.Shared.Temperature; using Robust.Server.GameObjects; namespace Content.Server.Temperature.Systems { public sealed class TemperatureSystem : EntitySystem { [Dependency] private readonly TransformSystem _transformSystem = default!; [Dependency] private readonly DamageableSystem _damageableSystem = default!; [Dependency] private readonly AtmosphereSystem _atmosphereSystem = default!; [Dependency] private readonly AlertsSystem _alertsSystem = default!; [Dependency] private readonly IAdminLogManager _adminLogger = default!; /// /// All the components that will have their damage updated at the end of the tick. /// This is done because both AtmosExposed and Flammable call ChangeHeat in the same tick, meaning /// that we need some mechanism to ensure it doesn't double dip on damage for both calls. /// public HashSet ShouldUpdateDamage = new(); public float UpdateInterval = 1.0f; private float _accumulatedFrametime; public override void Initialize() { SubscribeLocalEvent(EnqueueDamage); SubscribeLocalEvent(OnAtmosExposedUpdate); SubscribeLocalEvent(ServerAlert); SubscribeLocalEvent>( OnTemperatureChangeAttempt); // Allows overriding thresholds based on the parent's thresholds. SubscribeLocalEvent(OnParentChange); SubscribeLocalEvent( OnParentThresholdStartup); SubscribeLocalEvent( OnParentThresholdShutdown); } public override void Update(float frameTime) { base.Update(frameTime); _accumulatedFrametime += frameTime; if (_accumulatedFrametime < UpdateInterval) return; _accumulatedFrametime -= UpdateInterval; if (!ShouldUpdateDamage.Any()) return; foreach (var comp in ShouldUpdateDamage) { MetaDataComponent? metaData = null; if (Deleted(comp.Owner, metaData) || Paused(comp.Owner, metaData)) continue; ChangeDamage(comp.Owner, comp); } ShouldUpdateDamage.Clear(); } public void ForceChangeTemperature(EntityUid uid, float temp, TemperatureComponent? temperature = null) { if (Resolve(uid, ref temperature)) { float lastTemp = temperature.CurrentTemperature; float delta = temperature.CurrentTemperature - temp; temperature.CurrentTemperature = temp; RaiseLocalEvent(uid, new OnTemperatureChangeEvent(temperature.CurrentTemperature, lastTemp, delta), true); } } public void ChangeHeat(EntityUid uid, float heatAmount, bool ignoreHeatResistance = false, TemperatureComponent? temperature = null) { if (Resolve(uid, ref temperature)) { if (!ignoreHeatResistance) { var ev = new ModifyChangedTemperatureEvent(heatAmount); RaiseLocalEvent(uid, ev, false); heatAmount = ev.TemperatureDelta; } float lastTemp = temperature.CurrentTemperature; temperature.CurrentTemperature += heatAmount / temperature.HeatCapacity; float delta = temperature.CurrentTemperature - lastTemp; RaiseLocalEvent(uid, new OnTemperatureChangeEvent(temperature.CurrentTemperature, lastTemp, delta), true); } } private void OnAtmosExposedUpdate(EntityUid uid, TemperatureComponent temperature, ref AtmosExposedUpdateEvent args) { var transform = args.Transform; if (transform.MapUid == null) return; var position = _transformSystem.GetGridOrMapTilePosition(uid, transform); var temperatureDelta = args.GasMixture.Temperature - temperature.CurrentTemperature; var tileHeatCapacity = _atmosphereSystem.GetTileHeatCapacity(transform.GridUid, transform.MapUid.Value, position); var heat = temperatureDelta * (tileHeatCapacity * temperature.HeatCapacity / (tileHeatCapacity + temperature.HeatCapacity)); ChangeHeat(uid, heat * temperature.AtmosTemperatureTransferEfficiency, temperature: temperature); } private void ServerAlert(EntityUid uid, AlertsComponent status, OnTemperatureChangeEvent args) { switch (args.CurrentTemperature) { // Cold strong. case <= 260: _alertsSystem.ShowAlert(uid, AlertType.Cold, 3); break; // Cold mild. case <= 280 and > 260: _alertsSystem.ShowAlert(uid, AlertType.Cold, 2); break; // Cold weak. case <= 292 and > 280: _alertsSystem.ShowAlert(uid, AlertType.Cold, 1); break; // Safe. case <= 327 and > 292: _alertsSystem.ClearAlertCategory(uid, AlertCategory.Temperature); break; // Heat weak. case <= 335 and > 327: _alertsSystem.ShowAlert(uid, AlertType.Hot, 1); break; // Heat mild. case <= 360 and > 335: _alertsSystem.ShowAlert(uid, AlertType.Hot, 2); break; // Heat strong. case > 360: _alertsSystem.ShowAlert(uid, AlertType.Hot, 3); break; } } private void EnqueueDamage(EntityUid uid, TemperatureComponent component, OnTemperatureChangeEvent args) { ShouldUpdateDamage.Add(component); } private void ChangeDamage(EntityUid uid, TemperatureComponent temperature) { if (!EntityManager.HasComponent(uid)) return; // See this link for where the scaling func comes from: // https://www.desmos.com/calculator/0vknqtdvq9 // Based on a logistic curve, which caps out at MaxDamage var heatK = 0.005; var a = 1; var y = temperature.DamageCap; var c = y * 2; var heatDamageThreshold = temperature.ParentHeatDamageThreshold ?? temperature.HeatDamageThreshold; var coldDamageThreshold = temperature.ParentColdDamageThreshold ?? temperature.ColdDamageThreshold; if (temperature.CurrentTemperature >= heatDamageThreshold) { if (!temperature.TakingDamage) { _adminLogger.Add(LogType.Temperature, $"{ToPrettyString(temperature.Owner):entity} started taking high temperature damage"); temperature.TakingDamage = true; } var diff = Math.Abs(temperature.CurrentTemperature - heatDamageThreshold); var tempDamage = c / (1 + a * Math.Pow(Math.E, -heatK * diff)) - y; _damageableSystem.TryChangeDamage(uid, temperature.HeatDamage * tempDamage, ignoreResistances: true, interruptsDoAfters: false); } else if (temperature.CurrentTemperature <= coldDamageThreshold) { if (!temperature.TakingDamage) { _adminLogger.Add(LogType.Temperature, $"{ToPrettyString(temperature.Owner):entity} started taking low temperature damage"); temperature.TakingDamage = true; } var diff = Math.Abs(temperature.CurrentTemperature - coldDamageThreshold); var tempDamage = Math.Sqrt(diff * (Math.Pow(temperature.DamageCap.Double(), 2) / coldDamageThreshold)); _damageableSystem.TryChangeDamage(uid, temperature.ColdDamage * tempDamage, ignoreResistances: true, interruptsDoAfters: false); } else if (temperature.TakingDamage) { _adminLogger.Add(LogType.Temperature, $"{ToPrettyString(temperature.Owner):entity} stopped taking temperature damage"); temperature.TakingDamage = false; } } private void OnTemperatureChangeAttempt(EntityUid uid, TemperatureProtectionComponent component, InventoryRelayedEvent args) { args.Args.TemperatureDelta *= component.Coefficient; } private void OnParentChange(EntityUid uid, TemperatureComponent component, ref EntParentChangedMessage args) { var temperatureQuery = GetEntityQuery(); var transformQuery = GetEntityQuery(); var thresholdsQuery = GetEntityQuery(); // We only need to update thresholds if the thresholds changed for the entity's ancestors. var oldThresholds = args.OldParent != null ? RecalculateParentThresholds(args.OldParent.Value, transformQuery, thresholdsQuery) : (null, null); var newThresholds = RecalculateParentThresholds(transformQuery.GetComponent(uid).ParentUid, transformQuery, thresholdsQuery); if (oldThresholds != newThresholds) { RecursiveThresholdUpdate(uid, temperatureQuery, transformQuery, thresholdsQuery); } } private void OnParentThresholdStartup(EntityUid uid, ContainerTemperatureDamageThresholdsComponent component, ComponentStartup args) { RecursiveThresholdUpdate(uid, GetEntityQuery(), GetEntityQuery(), GetEntityQuery()); } private void OnParentThresholdShutdown(EntityUid uid, ContainerTemperatureDamageThresholdsComponent component, ComponentShutdown args) { RecursiveThresholdUpdate(uid, GetEntityQuery(), GetEntityQuery(), GetEntityQuery()); } /// /// Recalculate and apply parent thresholds for the root entity and all its descendant. /// /// /// /// /// private void RecursiveThresholdUpdate(EntityUid root, EntityQuery temperatureQuery, EntityQuery transformQuery, EntityQuery tempThresholdsQuery) { RecalculateAndApplyParentThresholds(root, temperatureQuery, transformQuery, tempThresholdsQuery); foreach (var child in Transform(root).ChildEntities) { RecursiveThresholdUpdate(child, temperatureQuery, transformQuery, tempThresholdsQuery); } } /// /// Recalculate parent thresholds and apply them on the uid temperature component. /// /// /// /// /// private void RecalculateAndApplyParentThresholds(EntityUid uid, EntityQuery temperatureQuery, EntityQuery transformQuery, EntityQuery tempThresholdsQuery) { if (!temperatureQuery.TryGetComponent(uid, out var temperature)) { return; } var newThresholds = RecalculateParentThresholds(transformQuery.GetComponent(uid).ParentUid, transformQuery, tempThresholdsQuery); temperature.ParentHeatDamageThreshold = newThresholds.Item1; temperature.ParentColdDamageThreshold = newThresholds.Item2; } /// /// Recalculate Parent Heat/Cold DamageThreshold by recursively checking each ancestor and fetching the /// maximum HeatDamageThreshold and the minimum ColdDamageThreshold if any exists (aka the best value for each). /// /// /// /// private (float?, float?) RecalculateParentThresholds( EntityUid initialParentUid, EntityQuery transformQuery, EntityQuery tempThresholdsQuery) { // Recursively check parents for the best threshold available var parentUid = initialParentUid; float? newHeatThreshold = null; float? newColdThreshold = null; while (parentUid.IsValid()) { if (tempThresholdsQuery.TryGetComponent(parentUid, out var newThresholds)) { if (newThresholds.HeatDamageThreshold != null) { newHeatThreshold = Math.Max(newThresholds.HeatDamageThreshold.Value, newHeatThreshold ?? 0); } if (newThresholds.ColdDamageThreshold != null) { newColdThreshold = Math.Min(newThresholds.ColdDamageThreshold.Value, newColdThreshold ?? float.MaxValue); } } parentUid = transformQuery.GetComponent(parentUid).ParentUid; } return (newHeatThreshold, newColdThreshold); } } public sealed class OnTemperatureChangeEvent : EntityEventArgs { public float CurrentTemperature { get; } public float LastTemperature { get; } public float TemperatureDelta { get; } public OnTemperatureChangeEvent(float current, float last, float delta) { CurrentTemperature = current; LastTemperature = last; TemperatureDelta = delta; } } }