using System.Collections.Generic; using System.Linq; using Content.Shared.Coordinates; using Robust.Shared; using Robust.Shared.Configuration; using Robust.Shared.GameObjects; using Robust.Shared.Log; using Robust.Shared.Map; using Robust.Shared.Map.Components; 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() { // This test dirties the pair as it simply deletes ALL entities when done. Overhead of restarting the round // is minimal relative to the rest of the test. var settings = new PoolSettings { Dirty = true }; await using var pair = await PoolManager.GetServerClient(settings); var server = pair.Server; var entityMan = server.ResolveDependency(); var mapManager = server.ResolveDependency(); var prototypeMan = server.ResolveDependency(); await server.WaitPost(() => { var protoIds = prototypeMan .EnumeratePrototypes() .Where(p => !p.Abstract) .Where(p => !pair.IsTestPrototype(p)) .Where(p => !p.Components.ContainsKey("MapGrid")) // This will smash stuff otherwise. .Select(p => p.ID) .ToList(); foreach (var protoId in protoIds) { var mapId = mapManager.CreateMap(); var grid = mapManager.CreateGrid(mapId); // TODO: Fix this better in engine. grid.SetTile(Vector2i.Zero, new Tile(1)); var coord = new EntityCoordinates(grid.Owner, 0, 0); entityMan.SpawnEntity(protoId, coord); } }); await server.WaitRunTicks(15); await server.WaitPost(() => { static IEnumerable<(EntityUid, TComp)> Query(IEntityManager entityMan) where TComp : Component { var query = entityMan.AllEntityQueryEnumerator(); while (query.MoveNext(out var uid, out var meta)) yield return (uid, meta); } var entityMetas = Query(entityMan).ToList(); foreach (var (uid, meta) in entityMetas) { if (!meta.EntityDeleted) entityMan.DeleteEntity(uid); } Assert.That(entityMan.EntityCount, Is.Zero); }); await pair.CleanReturnAsync(); } [Test] public async Task SpawnAndDeleteAllEntitiesInTheSameSpot() { // This test dirties the pair as it simply deletes ALL entities when done. Overhead of restarting the round // is minimal relative to the rest of the test. var settings = new PoolSettings { Dirty = true }; await using var pair = await PoolManager.GetServerClient(settings); var server = pair.Server; var map = await pair.CreateTestMap(); var entityMan = server.ResolveDependency(); var prototypeMan = server.ResolveDependency(); await server.WaitPost(() => { var protoIds = prototypeMan .EnumeratePrototypes() .Where(p => !p.Abstract) .Where(p => !pair.IsTestPrototype(p)) .Where(p => !p.Components.ContainsKey("MapGrid")) // This will smash stuff otherwise. .Select(p => p.ID) .ToList(); foreach (var protoId in protoIds) { entityMan.SpawnEntity(protoId, map.GridCoords); } }); await server.WaitRunTicks(15); await server.WaitPost(() => { static IEnumerable<(EntityUid, TComp)> Query(IEntityManager entityMan) where TComp : Component { var query = entityMan.AllEntityQueryEnumerator(); while (query.MoveNext(out var uid, out var meta)) yield return (uid, meta); }; var entityMetas = Query(entityMan).ToList(); foreach (var (uid, meta) in entityMetas) { if (!meta.EntityDeleted) entityMan.DeleteEntity(uid); } Assert.That(entityMan.EntityCount, Is.Zero); }); await pair.CleanReturnAsync(); } /// /// Variant of that also launches a client and dirties /// all components on every entity. /// [Test] public async Task SpawnAndDirtyAllEntities() { // This test dirties the pair as it simply deletes ALL entities when done. Overhead of restarting the round // is minimal relative to the rest of the test. var settings = new PoolSettings { Connected = true, Dirty = true }; await using var pair = await PoolManager.GetServerClient(settings); var server = pair.Server; var client = pair.Client; var cfg = server.ResolveDependency(); var prototypeMan = server.ResolveDependency(); var mapManager = server.ResolveDependency(); var sEntMan = server.ResolveDependency(); Assert.That(cfg.GetCVar(CVars.NetPVS), Is.False); var protoIds = prototypeMan .EnumeratePrototypes() .Where(p => !p.Abstract) .Where(p => !pair.IsTestPrototype(p)) .Where(p => !p.Components.ContainsKey("MapGrid")) // This will smash stuff otherwise. .Select(p => p.ID) .ToList(); await server.WaitPost(() => { foreach (var protoId in protoIds) { var mapId = mapManager.CreateMap(); var grid = mapManager.CreateGrid(mapId); var ent = sEntMan.SpawnEntity(protoId, new EntityCoordinates(grid.Owner, 0.5f, 0.5f)); foreach (var (_, component) in sEntMan.GetNetComponents(ent)) { sEntMan.Dirty(component); } } }); await pair.RunTicksSync(15); // Make sure the client actually received the entities // 500 is completely arbitrary. Note that the client & sever entity counts aren't expected to match. Assert.That(client.ResolveDependency().EntityCount, Is.GreaterThan(500)); await server.WaitPost(() => { static IEnumerable<(EntityUid, TComp)> Query(IEntityManager entityMan) where TComp : Component { var query = entityMan.AllEntityQueryEnumerator(); while (query.MoveNext(out var uid, out var meta)) yield return (uid, meta); }; var entityMetas = Query(sEntMan).ToList(); foreach (var (uid, meta) in entityMetas) { if (!meta.EntityDeleted) sEntMan.DeleteEntity(uid); } Assert.That(sEntMan.EntityCount, Is.Zero); }); await pair.CleanReturnAsync(); } [Test] public async Task AllComponentsOneToOneDeleteTest() { var skipComponents = new[] { "DebugExceptionOnAdd", // Debug components that explicitly throw exceptions "DebugExceptionExposeData", "DebugExceptionInitialize", "DebugExceptionStartup", "GridFillComponent", "Map", // We aren't testing a map entity in this test "MapGrid", "Broadphase", "StationData", // errors when removed mid-round "Actor", // We aren't testing actor components, those need their player session set. "BlobFloorPlanBuilder", // Implodes if unconfigured. "DebrisFeaturePlacerController", // Above. "LoadedChunk", // Worldgen chunk loading malding. "BiomeSelection", // Whaddya know, requires config. }; await using var pair = await PoolManager.GetServerClient(); var server = pair.Server; var mapManager = server.ResolveDependency(); var entityManager = server.ResolveDependency(); var componentFactory = server.ResolveDependency(); var tileDefinitionManager = server.ResolveDependency(); var logmill = server.ResolveDependency().GetSawmill("EntityTest"); MapGridComponent 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["Plating"]; 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(null, 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)) { entityManager.DeleteEntity(entity); continue; } component.Owner = entity; logmill.Debug($"Adding component: {name}"); Assert.DoesNotThrow(() => { entityManager.AddComponent(entity, component); }, "Component '{0}' threw an exception.", name); entityManager.DeleteEntity(entity); } }); }); await pair.CleanReturnAsync(); } } }