using System; using System.Collections.Generic; using System.Diagnostics.CodeAnalysis; using Content.Server.Power.Components; using Robust.Shared.GameObjects; using Robust.Shared.IoC; using Robust.Shared.Physics; namespace Content.Server.Power.EntitySystems { public sealed class ExtensionCableSystem : EntitySystem { public override void Initialize() { base.Initialize(); //Lifecycle events SubscribeLocalEvent(OnProviderStarted); SubscribeLocalEvent(OnProviderShutdown); SubscribeLocalEvent(OnReceiverStarted); SubscribeLocalEvent(OnReceiverShutdown); //Anchoring SubscribeLocalEvent(AnchorStateChanged); } #region Provider public void SetProviderTransferRange(EntityUid uid, int range, ExtensionCableProviderComponent? provider = null) { if (!Resolve(uid, ref provider)) return; provider.TransferRange = range; ResetReceivers(provider); } private void OnProviderStarted(EntityUid uid, ExtensionCableProviderComponent provider, ComponentStartup args) { foreach (var receiver in FindAvailableReceivers(uid, provider.TransferRange)) { receiver.Provider?.LinkedReceivers.Remove(receiver); receiver.Provider = provider; provider.LinkedReceivers.Add(receiver); RaiseLocalEvent(receiver.Owner, new ProviderConnectedEvent(provider), broadcast: false); RaiseLocalEvent(uid, new ReceiverConnectedEvent(receiver), broadcast: false); } } private void OnProviderShutdown(EntityUid uid, ExtensionCableProviderComponent provider, ComponentShutdown args) { provider.Connectable = false; ResetReceivers(provider); } private void ResetReceivers(ExtensionCableProviderComponent provider) { var receivers = provider.LinkedReceivers.ToArray(); foreach (var receiver in receivers) { receiver.Provider = null; RaiseLocalEvent(receiver.Owner, new ProviderDisconnectedEvent(provider), broadcast: false); RaiseLocalEvent(provider.Owner, new ReceiverDisconnectedEvent(receiver), broadcast: false); } foreach (var receiver in receivers) { // No point resetting what the receiver is doing if it's deleting, plus significant perf savings // in not doing needless lookups if (EntityManager.GetComponent((receiver).Owner).EntityLifeStage > EntityLifeStage.MapInitialized) continue; TryFindAndSetProvider(receiver); } } private IEnumerable FindAvailableReceivers(EntityUid owner, float range) { var nearbyEntities = IoCManager.Resolve() .GetEntitiesInRange(owner, range); foreach (var entity in nearbyEntities) { if (EntityManager.TryGetComponent(entity, out var receiver) && receiver.Connectable && receiver.Provider == null && EntityManager.GetComponent(entity).Coordinates.TryDistance(EntityManager, EntityManager.GetComponent(owner).Coordinates, out var distance) && distance < Math.Min(range, receiver.ReceptionRange)) { yield return receiver; } } } #endregion #region Receiver public void SetReceiverReceptionRange(EntityUid uid, int range, ExtensionCableReceiverComponent? receiver = null) { if (!Resolve(uid, ref receiver)) return; var provider = receiver.Provider; receiver.Provider = null; RaiseLocalEvent(uid, new ProviderDisconnectedEvent(provider), broadcast: false); if (provider != null) { RaiseLocalEvent(provider.Owner, new ReceiverDisconnectedEvent(receiver), broadcast: false); provider.LinkedReceivers.Remove(receiver); } receiver.ReceptionRange = range; TryFindAndSetProvider(receiver); } private void OnReceiverStarted(EntityUid uid, ExtensionCableReceiverComponent receiver, ComponentStartup args) { if (EntityManager.TryGetComponent(receiver.Owner, out PhysicsComponent? physicsComponent)) { receiver.Connectable = physicsComponent.BodyType == BodyType.Static; } if (receiver.Provider == null) { TryFindAndSetProvider(receiver); } } private void OnReceiverShutdown(EntityUid uid, ExtensionCableReceiverComponent receiver, ComponentShutdown args) { if (receiver.Provider == null) return; receiver.Provider.LinkedReceivers.Remove(receiver); RaiseLocalEvent(uid, new ProviderDisconnectedEvent(receiver.Provider), broadcast: false); RaiseLocalEvent(receiver.Provider.Owner, new ReceiverDisconnectedEvent(receiver), broadcast: false); } private void AnchorStateChanged(EntityUid uid, ExtensionCableReceiverComponent receiver, ref AnchorStateChangedEvent args) { if (args.Anchored) { receiver.Connectable = true; if (receiver.Provider == null) { TryFindAndSetProvider(receiver); } } else { receiver.Connectable = false; RaiseLocalEvent(uid, new ProviderDisconnectedEvent(receiver.Provider), broadcast: false); if (receiver.Provider != null) { RaiseLocalEvent(receiver.Provider.Owner, new ReceiverDisconnectedEvent(receiver), broadcast: false); receiver.Provider.LinkedReceivers.Remove(receiver); } receiver.Provider = null; } } private void TryFindAndSetProvider(ExtensionCableReceiverComponent receiver) { if (!TryFindAvailableProvider(receiver.Owner, receiver.ReceptionRange, out var provider)) return; receiver.Provider = provider; provider.LinkedReceivers.Add(receiver); RaiseLocalEvent(receiver.Owner, new ProviderConnectedEvent(provider), broadcast: false); RaiseLocalEvent(provider.Owner, new ReceiverConnectedEvent(receiver), broadcast: false); } private static bool TryFindAvailableProvider(EntityUid owner, float range, [NotNullWhen(true)] out ExtensionCableProviderComponent? foundProvider) { var nearbyEntities = IoCManager.Resolve() .GetEntitiesInRange(owner, range); foreach (var entity in nearbyEntities) { if (!EntityManager.TryGetComponent(entity, out var provider)) continue; if (!provider.Connectable) continue; if (!EntityManager.GetComponent(entity).Coordinates.TryDistance(EntityManager, EntityManager.GetComponent(owner).Coordinates, out var distance)) continue; if (!(distance < Math.Min(range, provider.TransferRange))) continue; foundProvider = provider; return true; } foundProvider = default; return false; } #endregion #region Events /// /// Sent when a connects to a /// public class ProviderConnectedEvent : EntityEventArgs { /// /// The that connected. /// public ExtensionCableProviderComponent Provider; public ProviderConnectedEvent(ExtensionCableProviderComponent provider) { Provider = provider; } } /// /// Sent when a disconnects from a /// public class ProviderDisconnectedEvent : EntityEventArgs { /// /// The that disconnected. /// public ExtensionCableProviderComponent? Provider; public ProviderDisconnectedEvent(ExtensionCableProviderComponent? provider) { Provider = provider; } } /// /// Sent when a connects to a /// public class ReceiverConnectedEvent : EntityEventArgs { /// /// The that connected. /// public ExtensionCableReceiverComponent Receiver; public ReceiverConnectedEvent(ExtensionCableReceiverComponent receiver) { Receiver = receiver; } } /// /// Sent when a disconnects from a /// public class ReceiverDisconnectedEvent : EntityEventArgs { /// /// The that disconnected. /// public ExtensionCableReceiverComponent Receiver; public ReceiverDisconnectedEvent(ExtensionCableReceiverComponent receiver) { Receiver = receiver; } } #endregion } }