Fixes admin logs and tests to not depend on IEntity caching (#5657)

Co-authored-by: Paul Ritter <ritter.paul1@googlemail.com>
This commit is contained in:
Vera Aguilera Puerto
2021-12-03 10:25:07 +01:00
committed by GitHub
parent c4c139041c
commit 3f8f4c818e
14 changed files with 58 additions and 40 deletions

View File

@@ -161,7 +161,7 @@ public class AddTests : ContentIntegrationTest
await server.WaitPost(() =>
{
var coordinates = GetMainEntityCoordinates(sMaps);
var entity = sEntities.SpawnEntity(null, coordinates);
var entity = sEntities.SpawnEntity(null, coordinates).Uid;
if (parallel)
{

View File

@@ -178,10 +178,14 @@ namespace Content.IntegrationTests.Tests.Body
var increment = 10;
for (var tick = 0; tick < 600; tick += increment)
{
await server.WaitRunTicks(increment);
Assert.False(respirator.Suffocating, $"Entity {human.Name} is suffocating on tick {tick}");
await server.WaitAssertion(() =>
{
Assert.False(respirator.Suffocating, $"Entity {human.Name} is suffocating on tick {tick}");
});
}
await server.WaitIdleAsync();

View File

@@ -144,14 +144,13 @@ namespace Content.IntegrationTests.Tests.Doors
await server.WaitIdleAsync();
// Push the human towards the airlock
Assert.That(physBody != null);
physBody.LinearVelocity = (0.5f, 0);
await server.WaitAssertion(() => Assert.That(physBody != null));
await server.WaitPost(() => physBody.LinearVelocity = (0.5f, 0));
for (var i = 0; i < 240; i += 10)
{
// Keep the airlock awake so they collide
airlock.GetComponent<IPhysBody>().WakeBody();
server.Post(() => airlock.GetComponent<IPhysBody>().WakeBody());
await server.WaitRunTicks(10);
await server.WaitIdleAsync();
@@ -164,7 +163,7 @@ namespace Content.IntegrationTests.Tests.Doors
// Assert.That(physicsDummy.Transform.MapPosition.X, Is.GreaterThan(physicsDummyStartingX));
// Blocked by the airlock
Assert.That(Math.Abs(physicsDummy.Transform.MapPosition.X - 1) > 0.01f);
await server.WaitAssertion(() => Assert.That(Math.Abs(physicsDummy.Transform.MapPosition.X - 1) > 0.01f));
}
}
}

View File

@@ -179,9 +179,6 @@ namespace Content.IntegrationTests.Tests.Fluids
// Puddle evaporation should have ticked
await server.WaitAssertion(() =>
{
// Check that the puddle is unpaused
Assert.False(puddle.Owner.Paused);
// Check that puddle has been deleted
Assert.True(puddle.Deleted);
});

View File

@@ -50,9 +50,9 @@ namespace Content.IntegrationTests.Tests.Lobby
serverConfig.SetCVar(CCVars.GameDummyTicker, false);
serverConfig.SetCVar(CCVars.GameLobbyEnabled, true);
serverTicker.RestartRound();
});
Assert.That(serverTicker.RunLevel, Is.EqualTo(GameRunLevel.PreRoundLobby));
Assert.That(serverTicker.RunLevel, Is.EqualTo(GameRunLevel.PreRoundLobby));
});
// Need to run them in sync to receive the messages.
await RunTicksSync(client, server, 1);
@@ -68,7 +68,8 @@ namespace Content.IntegrationTests.Tests.Lobby
{
clientPrefManager.SelectCharacter(0);
var clientCharacters = clientPrefManager.Preferences.Characters;
var clientCharacters = clientPrefManager.Preferences?.Characters;
Assert.That(clientCharacters, Is.Not.Null);
Assert.That(clientCharacters.Count, Is.EqualTo(1));
Assert.That(clientStateManager.CurrentState, Is.TypeOf<LobbyState>());
@@ -76,8 +77,9 @@ namespace Content.IntegrationTests.Tests.Lobby
profile = HumanoidCharacterProfile.Random();
clientPrefManager.CreateCharacter(profile);
clientCharacters = clientPrefManager.Preferences.Characters;
clientCharacters = clientPrefManager.Preferences?.Characters;
Assert.That(clientCharacters, Is.Not.Null);
Assert.That(clientCharacters.Count, Is.EqualTo(2));
Assert.That(clientCharacters[1].MemberwiseEquals(profile));
});
@@ -96,7 +98,7 @@ namespace Content.IntegrationTests.Tests.Lobby
{
clientPrefManager.DeleteCharacter(1);
var clientCharacters = clientPrefManager.Preferences.Characters.Count;
var clientCharacters = clientPrefManager.Preferences?.Characters.Count;
Assert.That(clientCharacters, Is.EqualTo(1));
});
@@ -116,8 +118,9 @@ namespace Content.IntegrationTests.Tests.Lobby
clientPrefManager.CreateCharacter(profile);
var clientCharacters = clientPrefManager.Preferences.Characters;
var clientCharacters = clientPrefManager.Preferences?.Characters;
Assert.That(clientCharacters, Is.Not.Null);
Assert.That(clientCharacters.Count, Is.EqualTo(2));
Assert.That(clientCharacters[1].MemberwiseEquals(profile));
});

View File

@@ -55,10 +55,10 @@ namespace Content.IntegrationTests.Tests.Networking
var clEntityManager = client.ResolveDependency<IEntityManager>();
var svEntityManager = server.ResolveDependency<IEntityManager>();
var lastSvEntity = svEntityManager.GetEntities().Last();
var lastClEntity = clEntityManager.GetEntity(lastSvEntity.Uid);
var lastSvEntity = svEntityManager.GetEntities().Last().Uid;
Assert.That(lastClEntity.Transform.Coordinates, Is.EqualTo(lastSvEntity.Transform.Coordinates));
Assert.That(clEntityManager.GetComponent<TransformComponent>(lastSvEntity).Coordinates,
Is.EqualTo(svEntityManager.GetComponent<TransformComponent>(lastSvEntity).Coordinates));
}
}
}

View File

@@ -60,21 +60,24 @@ namespace Content.IntegrationTests.Tests
mapLoader.LoadMap(new MapId(10), mapPath);
});
await server.WaitIdleAsync();
await server.WaitAssertion(() =>
{
if(!mapManager.TryFindGridAt(new MapId(10), new Vector2(10,10), out var mapGrid))
Assert.Fail();
{
if (!mapManager.TryFindGridAt(new MapId(10), new Vector2(10, 10), out var mapGrid))
Assert.Fail();
Assert.That(mapGrid.WorldPosition, Is.EqualTo(new Vector2(10, 10)));
Assert.That(mapGrid.GetTileRef(new Vector2i(0, 0)).Tile, Is.EqualTo(new Tile(1, 512)));
}
{
if (!mapManager.TryFindGridAt(new MapId(10), new Vector2(-8, -8), out var mapGrid))
Assert.Fail();
Assert.That(mapGrid.WorldPosition, Is.EqualTo(new Vector2(10, 10)));
Assert.That(mapGrid.WorldPosition, Is.EqualTo(new Vector2(-8, -8)));
Assert.That(mapGrid.GetTileRef(new Vector2i(0, 0)).Tile, Is.EqualTo(new Tile(2, 511)));
}
Assert.That(mapGrid.GetTileRef(new Vector2i(0, 0)).Tile, Is.EqualTo(new Tile(1, 512)));
}
{
if (!mapManager.TryFindGridAt(new MapId(10), new Vector2(-8, -8), out var mapGrid))
Assert.Fail();
Assert.That(mapGrid.WorldPosition, Is.EqualTo(new Vector2(-8, -8)));
Assert.That(mapGrid.GetTileRef(new Vector2i(0, 0)).Tile, Is.EqualTo(new Tile(2, 511)));
}
});
}
}

View File

@@ -91,14 +91,15 @@ namespace Content.Server.AI.EntitySystems
foreach (var npc in _awakeAi)
{
if (npc.Paused) continue;
if (npc.Deleted)
{
toRemove.Add(npc);
continue;
}
if (npc.Paused)
continue;
if (count >= maxUpdates)
{
break;

View File

@@ -68,8 +68,8 @@ public partial class AdminLogSystem
continue;
}
var entityName = _entityManager.TryGetEntity(uid, out var resolvedEntity)
? resolvedEntity.Name
var entityName = _entityManager.TryGetComponent(uid, out MetaDataComponent? metadata)
? metadata.EntityName
: null;
if (entities.Any(e => e.id == (int) uid)) continue;

View File

@@ -16,9 +16,9 @@ public class EntityUidConverter : AdminLogConverter<EntityUid>
writer.WriteNumber("id", (int) value);
if (entities.TryGetEntity(value, out var entity))
if (entities.TryGetComponent(value, out MetaDataComponent metaData))
{
writer.WriteString("name", entity.Name);
writer.WriteString("name", metaData.EntityName);
}
if (entities.TryGetComponent(value, out ActorComponent? actor))

View File

@@ -347,7 +347,7 @@ namespace Content.Server.Atmos.EntitySystems
{
var atmosphere = _currentRunAtmosphere[_currentRunAtmosphereIndex];
if (atmosphere.Paused || !atmosphere.Simulated || atmosphere.LifeStage >= ComponentLifeStage.Stopping)
if (atmosphere.LifeStage >= ComponentLifeStage.Stopping || atmosphere.Paused || !atmosphere.Simulated)
continue;
atmosphere.Timer += frameTime;

View File

@@ -262,6 +262,9 @@ namespace Content.Server.Disposal.Unit.EntitySystems
private void HandlePowerChange(EntityUid uid, DisposalUnitComponent component, PowerChangedEvent args)
{
if (!component.Running)
return;
// TODO: Need to check the other stuff.
if (!args.Powered)
{

View File

@@ -30,7 +30,12 @@ public class SpreaderSystem : EntitySystem
public override void Initialize()
{
SubscribeLocalEvent<SpreaderComponent, ComponentAdd>(SpreaderAddHandler);
SubscribeLocalEvent<AirtightChanged>(e => UpdateNearbySpreaders(e.Airtight.OwnerUid, e.Airtight));
SubscribeLocalEvent<AirtightChanged>(OnAirtightChanged);
}
private void OnAirtightChanged(AirtightChanged e)
{
UpdateNearbySpreaders(e.Airtight.OwnerUid, e.Airtight);
}
private void SpreaderAddHandler(EntityUid uid, SpreaderComponent component, ComponentAdd args)

View File

@@ -240,9 +240,12 @@ namespace Content.Server.Light.EntitySystems
ApcPowerReceiverComponent? powerReceiver = null,
AppearanceComponent? appearance = null)
{
if (!Resolve(uid, ref light, ref powerReceiver, ref appearance))
if (!Resolve(uid, ref light, ref powerReceiver))
return;
// Optional component.
Resolve(uid, ref appearance, false);
// check if light has bulb
var bulbUid = GetBulb(uid, light);
if (bulbUid == null || !EntityManager.TryGetComponent(bulbUid.Value, out LightBulbComponent? lightBulb))