using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Content.Shared.CCVar; using Content.Shared.Coordinates; using NUnit.Framework; using Robust.Shared.GameObjects; using Robust.Shared.IoC; using Robust.Shared.Log; using Robust.Shared.Map; using Robust.Shared.Maths; using Robust.Shared.Prototypes; namespace Content.IntegrationTests.Tests { [TestFixture] [TestOf(typeof(EntityUid))] public sealed class EntityTest { [Test] public async Task SpawnAndDeleteAllEntitiesOnDifferentMaps() { await using var pairTracker = await PoolManager.GetServerClient(new PoolSettings{NoClient = true, Destructive = true}); var server = pairTracker.Pair.Server; IEntityManager entityMan = null; await server.WaitPost(() => { entityMan = IoCManager.Resolve(); var mapManager = IoCManager.Resolve(); var prototypeMan = IoCManager.Resolve(); var protoIds = prototypeMan .EnumeratePrototypes() .Where(p=>!p.Abstract) .Select(p => p.ID) .ToList(); foreach (var protoId in protoIds) { var mapId = mapManager.CreateMap(); var grid = mapManager.CreateGrid(mapId); var coord = new EntityCoordinates(grid.GridEntityId, 0, 0); entityMan.SpawnEntity(protoId, coord); } }); await server.WaitRunTicks(5); await server.WaitPost(() => { var entityMetas = entityMan.EntityQuery().ToList(); foreach (var meta in entityMetas) { if(!entityMan.Deleted(meta.Owner)) entityMan.DeleteEntity(meta.Owner); } Assert.That(entityMan.EntityCount, Is.Zero); }); await pairTracker.CleanReturnAsync(); } [Test] public async Task SpawnAndDeleteAllEntitiesInTheSameSpot() { await using var pairTracker = await PoolManager.GetServerClient(new PoolSettings{NoClient = true, Destructive = true}); var server = pairTracker.Pair.Server; IEntityManager entityMan = null; await server.WaitPost(() => { entityMan = IoCManager.Resolve(); var mapManager = IoCManager.Resolve(); var prototypeMan = IoCManager.Resolve(); var protoIds = prototypeMan .EnumeratePrototypes() .Where(p=>!p.Abstract) .Select(p => p.ID) .ToList(); var mapId = mapManager.CreateMap(); var grid = mapManager.CreateGrid(mapId); var coord = new EntityCoordinates(grid.GridEntityId, 0, 0); foreach (var protoId in protoIds) { entityMan.SpawnEntity(protoId, coord); } }); await server.WaitRunTicks(5); await server.WaitPost(() => { var entityMetas = entityMan.EntityQuery().ToList(); foreach (var meta in entityMetas) { if(!entityMan.Deleted(meta.Owner)) entityMan.DeleteEntity(meta.Owner); } Assert.That(entityMan.EntityCount, Is.Zero); }); await pairTracker.CleanReturnAsync(); } [Test] public async Task AllComponentsOneToOneDeleteTest() { var skipComponents = new[] { "DebugExceptionOnAdd", // Debug components that explicitly throw exceptions "DebugExceptionExposeData", "DebugExceptionInitialize", "DebugExceptionStartup", "Map", // We aren't testing a map entity in this test "MapGrid", "StationData", // errors when removed mid-round "Actor", // We aren't testing actor components, those need their player session set. }; var testEntity = @" - type: entity id: AllComponentsOneToOneDeleteTestEntity"; await using var pairTracker = await PoolManager.GetServerClient(new PoolSettings{NoClient = true, ExtraPrototypes = testEntity}); var server = pairTracker.Pair.Server; var mapManager = server.ResolveDependency(); var entityManager = server.ResolveDependency(); var componentFactory = server.ResolveDependency(); var tileDefinitionManager = server.ResolveDependency(); IMapGrid grid = default; await server.WaitPost(() => { // Create a one tile grid to stave off the grid 0 monsters var mapId = mapManager.CreateMap(); mapManager.AddUninitializedMap(mapId); grid = mapManager.CreateGrid(mapId); var tileDefinition = tileDefinitionManager["UnderPlating"]; var tile = new Tile(tileDefinition.TileId); var coordinates = grid.ToCoordinates(); grid.SetTile(coordinates, tile); mapManager.DoMapInitialize(mapId); }); await server.WaitRunTicks(5); await server.WaitAssertion(() => { Assert.Multiple(() => { var testLocation = grid.ToCoordinates(); foreach (var type in componentFactory.AllRegisteredTypes) { var component = (Component) componentFactory.GetComponent(type); var name = componentFactory.GetComponentName(type); // If this component is ignored if (skipComponents.Contains(name)) { continue; } var entity = entityManager.SpawnEntity("AllComponentsOneToOneDeleteTestEntity", testLocation); Assert.That(entityManager.GetComponent(entity).EntityInitialized); // The component may already exist if it is a mandatory component // such as MetaData or Transform if (entityManager.HasComponent(entity, type)) { continue; } component.Owner = entity; Logger.LogS(LogLevel.Debug, "EntityTest", $"Adding component: {name}"); Assert.DoesNotThrow(() => { entityManager.AddComponent(entity, component); }, "Component '{0}' threw an exception.", name); entityManager.DeleteEntity(entity); } }); }); await pairTracker.CleanReturnAsync(); } [Test] public async Task AllComponentsOneEntityDeleteTest() { var skipComponents = new[] { "DebugExceptionOnAdd", // Debug components that explicitly throw exceptions "DebugExceptionExposeData", "DebugExceptionInitialize", "DebugExceptionStartup", "Map", // We aren't testing a map entity in this test "MapGrid", "StationData", // errors when deleted mid-round "Actor", // We aren't testing actor components, those need their player session set. }; var testEntity = @" - type: entity id: AllComponentsOneEntityDeleteTestEntity"; await using var pairTracker = await PoolManager.GetServerClient(new PoolSettings{NoClient = true, ExtraPrototypes = testEntity}); var server = pairTracker.Pair.Server; var mapManager = server.ResolveDependency(); var entityManager = server.ResolveDependency(); var componentFactory = server.ResolveDependency(); var tileDefinitionManager = server.ResolveDependency(); IMapGrid grid = default; await server.WaitPost(() => { // Create a one tile grid to stave off the grid 0 monsters var mapId = mapManager.CreateMap(); mapManager.AddUninitializedMap(mapId); grid = mapManager.CreateGrid(mapId); var tileDefinition = tileDefinitionManager["UnderPlating"]; var tile = new Tile(tileDefinition.TileId); grid.SetTile(Vector2i.Zero, tile); mapManager.DoMapInitialize(mapId); }); await server.WaitRunTicks(5); var distinctComponents = new List<(List components, List references)> { (new List(), new List()) }; // Split components into groups, ensuring that their references don't conflict foreach (var type in componentFactory.AllRegisteredTypes) { var registration = componentFactory.GetRegistration(type); for (var i = 0; i < distinctComponents.Count; i++) { var distinct = distinctComponents[i]; if (distinct.references.Intersect(registration.References).Any()) { // Ensure the next list if this one has conflicting references if (i + 1 >= distinctComponents.Count) { distinctComponents.Add((new List(), new List())); } continue; } // Add the component and its references if no conflicting references were found distinct.components.Add(registration.Idx); distinct.references.AddRange(registration.References); } } // Sanity check Assert.That(distinctComponents, Is.Not.Empty); await server.WaitAssertion(() => { Assert.Multiple(() => { foreach (var distinct in distinctComponents) { var testLocation = grid.ToCoordinates(); var entity = entityManager.SpawnEntity("AllComponentsOneEntityDeleteTestEntity", testLocation); Assert.That(entityManager.GetComponent(entity).EntityInitialized); foreach (var type in distinct.components) { var component = (Component) componentFactory.GetComponent(type); // If the entity already has this component, if it was ensured or added by another if (entityManager.HasComponent(entity, component.GetType())) { continue; } var name = componentFactory.GetComponentName(component.GetType()); // If this component is ignored if (skipComponents.Contains(name)) continue; component.Owner = entity; Logger.LogS(LogLevel.Debug, "EntityTest", $"Adding component: {name}"); // Note for the future coder: if an exception occurs where a component reference // was already occupied it might be because some component is ensuring another // initialize. // If so, search for cases of EnsureComponent, EnsureComponentWarn // and all others variations (out parameter) Assert.DoesNotThrow(() => { entityManager.AddComponent(entity, component); }, "Component '{0}' threw an exception.", name); } entityManager.DeleteEntity(entity); } }); }); await pairTracker.CleanReturnAsync(); } } }