Removed Old PlayerSession Functions (#5404)

Co-authored-by: metalgearsloth <comedian_vs_clown@hotmail.com>
This commit is contained in:
Acruid
2021-11-22 23:11:48 -08:00
committed by GitHub
parent 7910928679
commit 6e54e740c7
26 changed files with 97 additions and 94 deletions

View File

@@ -1,4 +1,4 @@
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Content.Server.Buckle.Components; using Content.Server.Buckle.Components;
using Content.Server.Hands.Components; using Content.Server.Hands.Components;
@@ -98,7 +98,7 @@ namespace Content.IntegrationTests.Tests.Buckle
Assert.NotNull(buckle.BuckledTo); Assert.NotNull(buckle.BuckledTo);
Assert.True(buckle.Buckled); Assert.True(buckle.Buckled);
var player = IoCManager.Resolve<IPlayerManager>().GetAllPlayers().Single(); var player = IoCManager.Resolve<IPlayerManager>().Sessions.Single();
Assert.True(((BuckleComponentState) buckle.GetComponentState(player)).Buckled); Assert.True(((BuckleComponentState) buckle.GetComponentState(player)).Buckled);
Assert.False(actionBlocker.CanMove(human.Uid)); Assert.False(actionBlocker.CanMove(human.Uid));
Assert.False(actionBlocker.CanChangeDirection(human.Uid)); Assert.False(actionBlocker.CanChangeDirection(human.Uid));

View File

@@ -1,4 +1,5 @@
using System; using System;
using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Content.Server.Database; using Content.Server.Database;
@@ -27,7 +28,7 @@ namespace Content.IntegrationTests.Tests.Commands
await server.WaitAssertion(async () => await server.WaitAssertion(async () =>
{ {
var clientSession = sPlayerManager.GetAllPlayers().Single(); var clientSession = sPlayerManager.Sessions.Single();
var clientId = clientSession.UserId; var clientId = clientSession.UserId;
// No bans on record // No bans on record

View File

@@ -59,10 +59,7 @@ namespace Content.IntegrationTests.Tests
s.Post(() => s.Post(() =>
{ {
IoCManager.Resolve<IPlayerManager>() IoCManager.Resolve<IPlayerManager>().ServerSessions.Single().JoinGame();
.GetAllPlayers()
.Single()
.JoinGame();
var mapMan = IoCManager.Resolve<IMapManager>(); var mapMan = IoCManager.Resolve<IMapManager>();

View File

@@ -70,8 +70,7 @@ namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
var player = serverPlayerManager.GetAllPlayers().Single(); var playerEnt = serverPlayerManager.Sessions.Single().AttachedEntity;
var playerEnt = player.AttachedEntity;
var actionsComponent = playerEnt!.GetComponent<ServerActionsComponent>(); var actionsComponent = playerEnt!.GetComponent<ServerActionsComponent>();
// player should begin with their innate actions granted // player should begin with their innate actions granted
@@ -153,8 +152,7 @@ namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
// now revoke the action and check that the client sees it as revoked // now revoke the action and check that the client sees it as revoked
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
var player = serverPlayerManager.GetAllPlayers().Single(); var playerEnt = serverPlayerManager.Sessions.Single().AttachedEntity;
var playerEnt = player.AttachedEntity;
var actionsComponent = playerEnt!.GetComponent<ServerActionsComponent>(); var actionsComponent = playerEnt!.GetComponent<ServerActionsComponent>();
actionsComponent.Revoke(ActionType.DebugInstant); actionsComponent.Revoke(ActionType.DebugInstant);
}); });
@@ -246,7 +244,7 @@ namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
serverPlayerEnt = serverPlayerManager.GetAllPlayers().Single().AttachedEntity; serverPlayerEnt = serverPlayerManager.Sessions.Single().AttachedEntity;
serverActionsComponent = serverPlayerEnt!.GetComponent<ServerActionsComponent>(); serverActionsComponent = serverPlayerEnt!.GetComponent<ServerActionsComponent>();
// spawn and give them an item that has actions // spawn and give them an item that has actions

View File

@@ -2,12 +2,11 @@ using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Content.Client.Alerts; using Content.Client.Alerts;
using Content.Client.Alerts.UI; using Content.Client.Alerts.UI;
using Content.Client.UserInterface;
using Content.Server.Alert; using Content.Server.Alert;
using Content.Shared.Alert; using Content.Shared.Alert;
using NUnit.Framework; using NUnit.Framework;
using Robust.Client.UserInterface; using Robust.Client.UserInterface;
using IPlayerManager = Robust.Server.Player.IPlayerManager; using Robust.Server.Player;
namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
{ {
@@ -28,8 +27,7 @@ namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
var player = serverPlayerManager.GetAllPlayers().Single(); var playerEnt = serverPlayerManager.Sessions.Single().AttachedEntity;
var playerEnt = player.AttachedEntity;
Assert.NotNull(playerEnt); Assert.NotNull(playerEnt);
var alertsComponent = playerEnt.GetComponent<ServerAlertsComponent>(); var alertsComponent = playerEnt.GetComponent<ServerAlertsComponent>();
Assert.NotNull(alertsComponent); Assert.NotNull(alertsComponent);
@@ -69,8 +67,7 @@ namespace Content.IntegrationTests.Tests.GameObjects.Components.Mobs
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
var player = serverPlayerManager.GetAllPlayers().Single(); var playerEnt = serverPlayerManager.Sessions.Single().AttachedEntity;
var playerEnt = player.AttachedEntity;
Assert.NotNull(playerEnt); Assert.NotNull(playerEnt);
var alertsComponent = playerEnt.GetComponent<ServerAlertsComponent>(); var alertsComponent = playerEnt.GetComponent<ServerAlertsComponent>();
Assert.NotNull(alertsComponent); Assert.NotNull(alertsComponent);

View File

@@ -1,7 +1,6 @@
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Content.Server.Mind; using Content.Server.Mind;
using Content.Server.Players;
using Content.Shared.Coordinates; using Content.Shared.Coordinates;
using NUnit.Framework; using NUnit.Framework;
using Robust.Server.GameObjects; using Robust.Server.GameObjects;
@@ -26,7 +25,7 @@ namespace Content.IntegrationTests.Tests
Mind mind = null; Mind mind = null;
server.Assert(() => server.Assert(() =>
{ {
var player = IoCManager.Resolve<IPlayerManager>().GetAllPlayers().Single(); var player = IoCManager.Resolve<IPlayerManager>().ServerSessions.Single();
var mapMan = IoCManager.Resolve<IMapManager>(); var mapMan = IoCManager.Resolve<IMapManager>();
var entMgr = IoCManager.Resolve<IServerEntityManager>(); var entMgr = IoCManager.Resolve<IServerEntityManager>();
@@ -71,7 +70,7 @@ namespace Content.IntegrationTests.Tests
Mind mind = null; Mind mind = null;
server.Assert(() => server.Assert(() =>
{ {
var player = IoCManager.Resolve<IPlayerManager>().GetAllPlayers().Single(); var player = IoCManager.Resolve<IPlayerManager>().ServerSessions.Single();
var mapMan = IoCManager.Resolve<IMapManager>(); var mapMan = IoCManager.Resolve<IMapManager>();
var entMgr = IoCManager.Resolve<IServerEntityManager>(); var entMgr = IoCManager.Resolve<IServerEntityManager>();
@@ -116,7 +115,7 @@ namespace Content.IntegrationTests.Tests
MapId map = default; MapId map = default;
server.Assert(() => server.Assert(() =>
{ {
var player = IoCManager.Resolve<IPlayerManager>().GetAllPlayers().Single(); var player = IoCManager.Resolve<IPlayerManager>().ServerSessions.Single();
var mapMan = IoCManager.Resolve<IMapManager>(); var mapMan = IoCManager.Resolve<IMapManager>();

View File

@@ -50,7 +50,7 @@ namespace Content.IntegrationTests.Tests.Networking
var playerManager = server.ResolveDependency<IPlayerManager>(); var playerManager = server.ResolveDependency<IPlayerManager>();
Assert.That(playerManager.PlayerCount, Is.EqualTo(1)); Assert.That(playerManager.PlayerCount, Is.EqualTo(1));
Assert.That(playerManager.GetAllPlayers().First().Status, Is.EqualTo(SessionStatus.InGame)); Assert.That(playerManager.Sessions.First().Status, Is.EqualTo(SessionStatus.InGame));
var clEntityManager = client.ResolveDependency<IEntityManager>(); var clEntityManager = client.ResolveDependency<IEntityManager>();
var svEntityManager = server.ResolveDependency<IEntityManager>(); var svEntityManager = server.ResolveDependency<IEntityManager>();

View File

@@ -90,7 +90,7 @@ namespace Content.IntegrationTests.Tests.Networking
{ {
// Spawn dummy component entity. // Spawn dummy component entity.
var map = sMapManager.CreateMap(); var map = sMapManager.CreateMap();
var player = sPlayerManager.GetAllPlayers().Single(); var player = sPlayerManager.ServerSessions.Single();
serverEnt = sEntityManager.SpawnEntity(null, new MapCoordinates((0, 0), map)); serverEnt = sEntityManager.SpawnEntity(null, new MapCoordinates((0, 0), map));
serverComponent = serverEnt.AddComponent<PredictionTestComponent>(); serverComponent = serverEnt.AddComponent<PredictionTestComponent>();

View File

@@ -1,4 +1,4 @@
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Content.Server.Access.Components; using Content.Server.Access.Components;
using Content.Server.Hands.Components; using Content.Server.Hands.Components;
@@ -59,7 +59,7 @@ namespace Content.IntegrationTests.Tests.PDA
await server.WaitAssertion(() => await server.WaitAssertion(() =>
{ {
var player = sPlayerManager.GetAllPlayers().Single().AttachedEntity; var player = sPlayerManager.Sessions.Single().AttachedEntity;
Assert.NotNull(player); Assert.NotNull(player);

View File

@@ -1,10 +1,13 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using Content.Server.AI.Components; using Content.Server.AI.Components;
using Content.Shared.Damage; using Content.Shared.Damage;
using JetBrains.Annotations; using JetBrains.Annotations;
using Robust.Server.Player; using Robust.Server.Player;
using Robust.Shared.GameObjects; using Robust.Shared.GameObjects;
using Robust.Shared.IoC; using Robust.Shared.IoC;
using Robust.Shared.Map;
using Robust.Shared.Player;
namespace Content.Server.AI.WorldState.States.Mobs namespace Content.Server.AI.WorldState.States.Mobs
{ {
@@ -22,8 +25,9 @@ namespace Content.Server.AI.WorldState.States.Mobs
return result; return result;
} }
var playerManager = IoCManager.Resolve<IPlayerManager>(); var nearbyPlayers = Filter.Empty()
var nearbyPlayers = playerManager.GetPlayersInRange(Owner.Transform.Coordinates, (int) controller.VisionRadius); .AddInRange(Owner.Transform.MapPosition, controller.VisionRadius)
.Recipients;
foreach (var player in nearbyPlayers) foreach (var player in nearbyPlayers)
{ {

View File

@@ -2,7 +2,6 @@ using System.Linq;
using Content.Server.Administration.Managers; using Content.Server.Administration.Managers;
using Content.Server.Players; using Content.Server.Players;
using Content.Server.Roles; using Content.Server.Roles;
using Content.Server.Traitor;
using Content.Shared.Administration; using Content.Shared.Administration;
using Content.Shared.Administration.Events; using Content.Shared.Administration.Events;
using Robust.Server.GameObjects; using Robust.Server.GameObjects;
@@ -113,7 +112,7 @@ namespace Content.Server.Administration
{ {
var ev = new FullPlayerListEvent(); var ev = new FullPlayerListEvent();
ev.PlayersInfo.Clear(); ev.PlayersInfo.Clear();
foreach (var session in _playerManager.GetAllPlayers()) foreach (var session in _playerManager.ServerSessions)
{ {
ev.PlayersInfo.Add(GetPlayerInfo(session)); ev.PlayersInfo.Add(GetPlayerInfo(session));
} }

View File

@@ -147,7 +147,7 @@ namespace Content.Server.Chat.Managers
var clients = new List<INetChannel>(); var clients = new List<INetChannel>();
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.Sessions)
{ {
if (player.AttachedEntity == null) continue; if (player.AttachedEntity == null) continue;
var transform = player.AttachedEntity.Transform; var transform = player.AttachedEntity.Transform;
@@ -222,15 +222,18 @@ namespace Content.Server.Chat.Managers
action = FormattedMessage.EscapeText(action); action = FormattedMessage.EscapeText(action);
var pos = source.Transform.Coordinates; var clients = Filter.Empty()
var clients = _playerManager.GetPlayersInRange(pos, VoiceRange).Select(p => p.ConnectedClient); .AddInRange(source.Transform.MapPosition, VoiceRange)
.Recipients
.Select(p => p.ConnectedClient)
.ToList();
var msg = _netManager.CreateNetMessage<MsgChatMessage>(); var msg = _netManager.CreateNetMessage<MsgChatMessage>();
msg.Channel = ChatChannel.Emotes; msg.Channel = ChatChannel.Emotes;
msg.Message = action; msg.Message = action;
msg.MessageWrap = Loc.GetString("chat-manager-entity-me-wrap-message", ("entityName",source.Name)); msg.MessageWrap = Loc.GetString("chat-manager-entity-me-wrap-message", ("entityName",source.Name));
msg.SenderEntity = source.Uid; msg.SenderEntity = source.Uid;
_netManager.ServerSendToMany(msg, clients.ToList()); _netManager.ServerSendToMany(msg, clients);
} }
public void SendOOC(IPlayerSession player, string message) public void SendOOC(IPlayerSession player, string message)
@@ -324,10 +327,11 @@ namespace Content.Server.Chat.Managers
private IEnumerable<INetChannel> GetDeadChatClients() private IEnumerable<INetChannel> GetDeadChatClients()
{ {
return _playerManager return Filter.Empty()
.GetPlayersBy(x => x.AttachedEntity != null && x.AttachedEntity.HasComponent<GhostComponent>()) .AddWhereAttachedEntity(uid => _entManager.HasComponent<GhostComponent>(uid))
.Select(p => p.ConnectedClient) .Recipients
.Union(_adminManager.ActiveAdmins.Select(p => p.ConnectedClient)); .Union(_adminManager.ActiveAdmins)
.Select(p => p.ConnectedClient);
} }
public void SendAdminChat(IPlayerSession player, string message) public void SendAdminChat(IPlayerSession player, string message)

View File

@@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Content.Server.Camera; using Content.Server.Camera;
@@ -10,7 +10,6 @@ using Content.Shared.Physics;
using Content.Shared.Sound; using Content.Shared.Sound;
using Content.Shared.Tag; using Content.Shared.Tag;
using Robust.Server.GameObjects; using Robust.Server.GameObjects;
using Robust.Server.Player;
using Robust.Shared.Audio; using Robust.Shared.Audio;
using Robust.Shared.Containers; using Robust.Shared.Containers;
using Robust.Shared.GameObjects; using Robust.Shared.GameObjects;
@@ -43,7 +42,6 @@ namespace Content.Server.Explosion.EntitySystems
[Dependency] private readonly IEntityLookup _entityLookup = default!; [Dependency] private readonly IEntityLookup _entityLookup = default!;
[Dependency] private readonly IGameTiming _timing = default!; [Dependency] private readonly IGameTiming _timing = default!;
[Dependency] private readonly IMapManager _maps = default!; [Dependency] private readonly IMapManager _maps = default!;
[Dependency] private readonly IPlayerManager _players = default!;
[Dependency] private readonly IRobustRandom _random = default!; [Dependency] private readonly IRobustRandom _random = default!;
[Dependency] private readonly ITileDefinitionManager _tiles = default!; [Dependency] private readonly ITileDefinitionManager _tiles = default!;
@@ -74,7 +72,9 @@ namespace Content.Server.Explosion.EntitySystems
private void CameraShakeInRange(EntityCoordinates epicenter, float maxRange) private void CameraShakeInRange(EntityCoordinates epicenter, float maxRange)
{ {
var players = _players.GetPlayersInRange(epicenter, (int) Math.Ceiling(maxRange)); var players = Filter.Empty()
.AddInRange(epicenter.ToMap(EntityManager), MathF.Ceiling(maxRange))
.Recipients;
foreach (var player in players) foreach (var player in players)
{ {

View File

@@ -37,7 +37,7 @@ namespace Content.Server.GameTicking
// Can't simple check the current connected player count since that doesn't update // Can't simple check the current connected player count since that doesn't update
// before PlayerStatusChanged gets fired. // before PlayerStatusChanged gets fired.
// So in the disconnect handler we'd still see a single player otherwise. // So in the disconnect handler we'd still see a single player otherwise.
var playersOnline = _playerManager.GetAllPlayers().Any(p => p.Status != SessionStatus.Disconnected); var playersOnline = _playerManager.Sessions.Any(p => p.Status != SessionStatus.Disconnected);
if (playersOnline || !_updateOnRoundEnd) if (playersOnline || !_updateOnRoundEnd)
{ {
// Still somebody online. // Still somebody online.

View File

@@ -143,7 +143,7 @@ namespace Content.Server.GameTicking.Presets
{ {
// Collate people to avoid... // Collate people to avoid...
var existingPlayerPoints = new List<EntityCoordinates>(); var existingPlayerPoints = new List<EntityCoordinates>();
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.ServerSessions)
{ {
var avoidMeMind = player.Data.ContentData()?.Mind; var avoidMeMind = player.Data.ContentData()?.Mind;
if ((avoidMeMind == null) || (avoidMeMind == ignoreMe)) if ((avoidMeMind == null) || (avoidMeMind == ignoreMe))

View File

@@ -1,4 +1,6 @@
using System; using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading; using System.Threading;
using Content.Server.Chat.Managers; using Content.Server.Chat.Managers;
using Content.Shared.CCVar; using Content.Shared.CCVar;
@@ -58,7 +60,7 @@ namespace Content.Server.GameTicking.Rules
return; return;
IPlayerSession? winner = null; IPlayerSession? winner = null;
foreach (var playerSession in _playerManager.GetAllPlayers()) foreach (var playerSession in _playerManager.ServerSessions)
{ {
var playerEntity = playerSession.AttachedEntity; var playerEntity = playerSession.AttachedEntity;
if (playerEntity == null if (playerEntity == null

View File

@@ -1,4 +1,6 @@
using System; using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading; using System.Threading;
using Content.Server.Chat.Managers; using Content.Server.Chat.Managers;
using Content.Server.Doors; using Content.Server.Doors;
@@ -25,7 +27,7 @@ namespace Content.Server.GameTicking.Rules
/// <summary> /// <summary>
/// Simple GameRule that will do a TTT-like gamemode with traitors. /// Simple GameRule that will do a TTT-like gamemode with traitors.
/// </summary> /// </summary>
public sealed class RuleSuspicion : GameRule, IEntityEventSubscriber public sealed class RuleSuspicion : GameRule
{ {
private static readonly TimeSpan DeadCheckDelay = TimeSpan.FromSeconds(1); private static readonly TimeSpan DeadCheckDelay = TimeSpan.FromSeconds(1);
@@ -86,7 +88,7 @@ namespace Content.Server.GameTicking.Rules
var traitorsAlive = 0; var traitorsAlive = 0;
var innocentsAlive = 0; var innocentsAlive = 0;
foreach (var playerSession in _playerManager.GetAllPlayers()) foreach (var playerSession in _playerManager.ServerSessions)
{ {
if (playerSession.AttachedEntity == null if (playerSession.AttachedEntity == null
|| !playerSession.AttachedEntity.TryGetComponent(out MobStateComponent? mobState) || !playerSession.AttachedEntity.TryGetComponent(out MobStateComponent? mobState)

View File

@@ -218,7 +218,7 @@ namespace Content.Server.Ghost
{ {
var players = new Dictionary<EntityUid, string>(); var players = new Dictionary<EntityUid, string>();
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.Sessions)
{ {
if (player.AttachedEntity != null) if (player.AttachedEntity != null)
{ {

View File

@@ -24,9 +24,9 @@ namespace Content.Server.Ghost.Roles
public class GhostRoleSystem : EntitySystem public class GhostRoleSystem : EntitySystem
{ {
[Dependency] private readonly EuiManager _euiManager = default!; [Dependency] private readonly EuiManager _euiManager = default!;
[Dependency] private IPlayerManager _playerManager = default!; [Dependency] private readonly IPlayerManager _playerManager = default!;
private uint _nextRoleIdentifier = 0; private uint _nextRoleIdentifier;
private bool _needsUpdateGhostRoleCount = true; private bool _needsUpdateGhostRoleCount = true;
private readonly Dictionary<uint, GhostRoleComponent> _ghostRoles = new(); private readonly Dictionary<uint, GhostRoleComponent> _ghostRoles = new();
private readonly Dictionary<IPlayerSession, GhostRolesEui> _openUis = new(); private readonly Dictionary<IPlayerSession, GhostRolesEui> _openUis = new();
@@ -96,7 +96,7 @@ namespace Content.Server.Ghost.Roles
{ {
if (_openMakeGhostRoleUis.Remove(session, out var eui)) if (_openMakeGhostRoleUis.Remove(session, out var eui))
{ {
eui?.Close(); eui.Close();
} }
} }
@@ -119,10 +119,12 @@ namespace Content.Server.Ghost.Roles
{ {
_needsUpdateGhostRoleCount = false; _needsUpdateGhostRoleCount = false;
var response = new GhostUpdateGhostRoleCountEvent(_ghostRoles.Count); var response = new GhostUpdateGhostRoleCountEvent(_ghostRoles.Count);
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.Sessions)
{
RaiseNetworkEvent(response, player.ConnectedClient); RaiseNetworkEvent(response, player.ConnectedClient);
} }
} }
}
private void PlayerStatusChanged(object? blah, SessionStatusEventArgs args) private void PlayerStatusChanged(object? blah, SessionStatusEventArgs args)
{ {

View File

@@ -1,4 +1,4 @@
using System.Collections.Generic; using System.Collections.Generic;
using Content.Server.Camera; using Content.Server.Camera;
using Content.Shared.Gravity; using Content.Shared.Gravity;
using Robust.Server.Player; using Robust.Server.Player;
@@ -25,7 +25,7 @@ namespace Content.Server.Gravity.EntitySystems
private const float GravityKick = 100.0f; private const float GravityKick = 100.0f;
private const uint ShakeTimes = 10; private const uint ShakeTimes = 10;
private float _internalTimer = 0.0f; private float _internalTimer;
public override void Update(float frameTime) public override void Update(float frameTime)
{ {
@@ -77,7 +77,7 @@ namespace Content.Server.Gravity.EntitySystems
private void ShakeGrid(GridId gridId) private void ShakeGrid(GridId gridId)
{ {
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.Sessions)
{ {
if (player.AttachedEntity == null if (player.AttachedEntity == null
|| player.AttachedEntity.Transform.GridID != gridId || player.AttachedEntity.Transform.GridID != gridId

View File

@@ -1,5 +1,6 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using Content.Server.Ghost.Components; using Content.Server.Ghost.Components;
using Content.Server.Players; using Content.Server.Players;
using Content.Server.Pointing.Components; using Content.Server.Pointing.Components;
@@ -20,6 +21,7 @@ using Robust.Shared.IoC;
using Robust.Shared.Localization; using Robust.Shared.Localization;
using Robust.Shared.Map; using Robust.Shared.Map;
using Robust.Shared.Maths; using Robust.Shared.Maths;
using Robust.Shared.Player;
using Robust.Shared.Players; using Robust.Shared.Players;
using Robust.Shared.Timing; using Robust.Shared.Timing;
@@ -55,7 +57,7 @@ namespace Content.Server.Pointing.EntitySystems
} }
// TODO: FOV // TODO: FOV
private void SendMessage(IEntity source, IList<IPlayerSession> viewers, IEntity? pointed, string selfMessage, private void SendMessage(IEntity source, IEnumerable<ICommonSession> viewers, IEntity? pointed, string selfMessage,
string viewerMessage, string? viewerPointedAtMessage = null) string viewerMessage, string? viewerPointedAtMessage = null)
{ {
foreach (var viewer in viewers) foreach (var viewer in viewers)
@@ -127,15 +129,18 @@ namespace Content.Server.Pointing.EntitySystems
} }
// Get players that are in range and whose visibility layer matches the arrow's. // Get players that are in range and whose visibility layer matches the arrow's.
var viewers = _playerManager.GetPlayersBy((playerSession) => bool ViewerPredicate(IPlayerSession playerSession)
{ {
var ent = playerSession.ContentData()?.Mind?.CurrentEntity; var ent = playerSession.ContentData()?.Mind?.CurrentEntity;
if (ent is null || (!ent.TryGetComponent<EyeComponent>(out var eyeComp) || (eyeComp.VisibilityMask & layer) == 0)) if (ent is null || (!ent.TryGetComponent<EyeComponent>(out var eyeComp) || (eyeComp.VisibilityMask & layer) == 0)) return false;
return false;
return ent.Transform.MapPosition.InRange(player.Transform.MapPosition, PointingRange); return ent.Transform.MapPosition.InRange(player.Transform.MapPosition, PointingRange);
}); }
var viewers = Filter.Empty()
.AddWhere(session1 => ViewerPredicate((IPlayerSession) session1))
.Recipients;
string selfMessage; string selfMessage;
string viewerMessage; string viewerMessage;

View File

@@ -1,11 +1,10 @@
using System.Linq; using System.Linq;
using Content.Server.Explosion.EntitySystems; using Content.Server.Explosion.EntitySystems;
using Content.Server.Pointing.Components; using Content.Server.Pointing.Components;
using Content.Shared.MobState.Components; using Content.Shared.MobState.Components;
using Content.Shared.Pointing.Components; using Content.Shared.Pointing.Components;
using JetBrains.Annotations; using JetBrains.Annotations;
using Robust.Server.GameObjects; using Robust.Server.GameObjects;
using Robust.Server.Player;
using Robust.Shared.Audio; using Robust.Shared.Audio;
using Robust.Shared.GameObjects; using Robust.Shared.GameObjects;
using Robust.Shared.IoC; using Robust.Shared.IoC;
@@ -19,7 +18,6 @@ namespace Content.Server.Pointing.EntitySystems
[UsedImplicitly] [UsedImplicitly]
internal sealed class RoguePointingSystem : EntitySystem internal sealed class RoguePointingSystem : EntitySystem
{ {
[Dependency] private readonly IPlayerManager _playerManager = default!;
[Dependency] private readonly IRobustRandom _random = default!; [Dependency] private readonly IRobustRandom _random = default!;
[Dependency] private readonly ExplosionSystem _explosions = default!; [Dependency] private readonly ExplosionSystem _explosions = default!;
@@ -44,17 +42,15 @@ namespace Content.Server.Pointing.EntitySystems
if (!Resolve(uid, ref component, ref transform)) if (!Resolve(uid, ref component, ref transform))
return null; return null;
var players = _playerManager var players = Filter.Empty()
.GetPlayersInRange(transform.Coordinates, 15) .AddPlayersByPvs(transform.MapPosition)
.Where(player => player.AttachedEntity != null && player.AttachedEntity.TryGetComponent(out MobStateComponent? mobStateComponent) && !mobStateComponent.IsDead()) .RemoveWhereAttachedEntity(euid => !EntityManager.TryGetComponent(euid, out MobStateComponent? mobStateComponent) || mobStateComponent.IsDead())
.Recipients
.ToArray(); .ToArray();
if (players.Length == 0) return players.Length != 0
{ ? _random.Pick(players).AttachedEntity
return null; : null;
}
return _random.Pick(players).AttachedEntity;
} }
private void UpdateAppearance(EntityUid uid, RoguePointingArrowComponent? component = null, TransformComponent? transform = null, AppearanceComponent? appearance = null) private void UpdateAppearance(EntityUid uid, RoguePointingArrowComponent? component = null, TransformComponent? transform = null, AppearanceComponent? appearance = null)

View File

@@ -1,7 +1,11 @@
using Content.Shared.Popups; using System.Collections.Generic;
using System.Linq;
using Content.Shared.Popups;
using Robust.Server.Player; using Robust.Server.Player;
using Robust.Shared.GameObjects; using Robust.Shared.GameObjects;
using Robust.Shared.IoC; using Robust.Shared.IoC;
using Robust.Shared.Map;
using Robust.Shared.Player;
namespace Content.Server.Popups namespace Content.Server.Popups
{ {
@@ -13,18 +17,11 @@ namespace Content.Server.Popups
/// </summary> /// </summary>
/// <param name="source">The entity on which to popup the message.</param> /// <param name="source">The entity on which to popup the message.</param>
/// <param name="message">The message to show.</param> /// <param name="message">The message to show.</param>
/// <param name="playerManager"> public static void PopupMessageOtherClients(this IEntity source, string message)
/// The instance of player manager to use, will be resolved automatically
/// if null.
/// </param>
/// <param name="range">
/// The range in which to search for players, defaulting to one screen.
/// </param>
public static void PopupMessageOtherClients(this IEntity source, string message, IPlayerManager? playerManager = null, int range = 15)
{ {
playerManager ??= IoCManager.Resolve<IPlayerManager>(); var viewers = Filter.Empty()
.AddPlayersByPvs(source)
var viewers = playerManager.GetPlayersInRange(source.Transform.Coordinates, range); .Recipients;
foreach (var viewer in viewers) foreach (var viewer in viewers)
{ {
@@ -55,7 +52,7 @@ namespace Content.Server.Popups
public static void PopupMessageEveryone(this IEntity source, string message, IPlayerManager? playerManager = null, int range = 15) public static void PopupMessageEveryone(this IEntity source, string message, IPlayerManager? playerManager = null, int range = 15)
{ {
source.PopupMessage(message); source.PopupMessage(message);
source.PopupMessageOtherClients(message, playerManager, range); source.PopupMessageOtherClients(message);
} }
} }
} }

View File

@@ -1,4 +1,4 @@
using System; using System;
using System.Linq; using System.Linq;
using Content.Shared.GameTicking; using Content.Shared.GameTicking;
using Content.Shared.Suspicion; using Content.Shared.Suspicion;
@@ -54,7 +54,7 @@ namespace Content.Server.Suspicion.EntitySystems
private void SendUpdateToAll() private void SendUpdateToAll()
{ {
foreach (var player in _playerManager.GetAllPlayers().Where(p => p.Status == SessionStatus.InGame)) foreach (var player in _playerManager.ServerSessions.Where(p => p.Status == SessionStatus.InGame))
{ {
SendUpdateTimerMessage(player); SendUpdateTimerMessage(player);
} }

View File

@@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Content.Server.GameTicking; using Content.Server.GameTicking;
@@ -85,7 +85,7 @@ namespace Content.Server.Voting.Managers
vote.CastVote(initiator, 0); vote.CastVote(initiator, 0);
} }
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.ServerSessions)
{ {
if (player != initiator && !_afkManager.IsAfk(player)) if (player != initiator && !_afkManager.IsAfk(player))
{ {

View File

@@ -1,4 +1,4 @@
using System; using System;
using System.Collections; using System.Collections;
using System.Collections.Generic; using System.Collections.Generic;
using System.Collections.Immutable; using System.Collections.Immutable;
@@ -204,7 +204,7 @@ namespace Content.Server.Voting.Managers
private void SendUpdates(VoteReg v) private void SendUpdates(VoteReg v)
{ {
foreach (var player in _playerManager.GetAllPlayers()) foreach (var player in _playerManager.ServerSessions)
{ {
SendSingleUpdate(v, player); SendSingleUpdate(v, player);
} }
@@ -253,7 +253,7 @@ namespace Content.Server.Voting.Managers
private void DirtyCanCallVoteAll() private void DirtyCanCallVoteAll()
{ {
_playerCanCallVoteDirty.UnionWith(_playerManager.GetAllPlayers()); _playerCanCallVoteDirty.UnionWith(_playerManager.ServerSessions);
} }
private void SendUpdateCanCallVote(IPlayerSession player) private void SendUpdateCanCallVote(IPlayerSession player)