package net.minecraft.world.level; import com.mojang.logging.LogUtils; import java.util.Optional; import net.minecraft.core.BlockPos; import net.minecraft.core.particles.ParticleTypes; import net.minecraft.core.registries.BuiltInRegistries; import net.minecraft.nbt.CompoundTag; import net.minecraft.server.level.ServerLevel; import net.minecraft.util.ProblemReporter; import net.minecraft.util.RandomSource; import net.minecraft.util.random.WeightedList; import net.minecraft.world.Difficulty; import net.minecraft.world.entity.Entity; import net.minecraft.world.entity.EntityProcessor; import net.minecraft.world.entity.EntitySelector; import net.minecraft.world.entity.EntitySpawnReason; import net.minecraft.world.entity.EntityType; import net.minecraft.world.entity.Mob; import net.minecraft.world.entity.SpawnPlacements; import net.minecraft.world.level.entity.EntityTypeTest; import net.minecraft.world.level.gameevent.GameEvent; import net.minecraft.world.level.storage.TagValueInput; import net.minecraft.world.level.storage.ValueInput; import net.minecraft.world.level.storage.ValueOutput; import net.minecraft.world.phys.AABB; import net.minecraft.world.phys.Vec3; import org.jspecify.annotations.Nullable; import org.slf4j.Logger; public abstract class BaseSpawner { private static final Logger LOGGER = LogUtils.getLogger(); public static final String SPAWN_DATA_TAG = "SpawnData"; private static final int EVENT_SPAWN = 1; private static final int DEFAULT_SPAWN_DELAY = 20; private static final int DEFAULT_MIN_SPAWN_DELAY = 200; private static final int DEFAULT_MAX_SPAWN_DELAY = 800; private static final int DEFAULT_SPAWN_COUNT = 4; private static final int DEFAULT_MAX_NEARBY_ENTITIES = 6; private static final int DEFAULT_REQUIRED_PLAYER_RANGE = 16; private static final int DEFAULT_SPAWN_RANGE = 4; private int spawnDelay = 20; private WeightedList spawnPotentials = WeightedList.of(); @Nullable private SpawnData nextSpawnData; private double spin; private double oSpin; private int minSpawnDelay = 200; private int maxSpawnDelay = 800; private int spawnCount = 4; @Nullable private Entity displayEntity; private int maxNearbyEntities = 6; private int requiredPlayerRange = 16; private int spawnRange = 4; public void setEntityId(final EntityType type, @Nullable final Level level, final RandomSource random, final BlockPos pos) { this.getOrCreateNextSpawnData(level, random, pos).getEntityToSpawn().putString("id", BuiltInRegistries.ENTITY_TYPE.getKey(type).toString()); } private boolean isNearPlayer(final Level level, final BlockPos pos) { return level.hasNearbyAlivePlayer(pos.getX() + 0.5, pos.getY() + 0.5, pos.getZ() + 0.5, this.requiredPlayerRange); } public void clientTick(final Level level, final BlockPos pos) { if (!this.isNearPlayer(level, pos)) { this.oSpin = this.spin; } else if (this.displayEntity != null) { RandomSource random = level.getRandom(); double xP = pos.getX() + random.nextDouble(); double yP = pos.getY() + random.nextDouble(); double zP = pos.getZ() + random.nextDouble(); level.addParticle(ParticleTypes.SMOKE, xP, yP, zP, 0.0, 0.0, 0.0); level.addParticle(ParticleTypes.FLAME, xP, yP, zP, 0.0, 0.0, 0.0); if (this.spawnDelay > 0) { this.spawnDelay--; } this.oSpin = this.spin; this.spin = (this.spin + 1000.0F / (this.spawnDelay + 200.0F)) % 360.0; } } public void serverTick(final ServerLevel level, final BlockPos pos) { if (this.isNearPlayer(level, pos) && level.isSpawnerBlockEnabled()) { if (this.spawnDelay == -1) { this.delay(level, pos); } if (this.spawnDelay > 0) { this.spawnDelay--; } else { boolean delay = false; RandomSource random = level.getRandom(); SpawnData nextSpawnData = this.getOrCreateNextSpawnData(level, random, pos); for (int c = 0; c < this.spawnCount; c++) { try (ProblemReporter.ScopedCollector reporter = new ProblemReporter.ScopedCollector(this::toString, LOGGER)) { ValueInput input = TagValueInput.create(reporter, level.registryAccess(), nextSpawnData.getEntityToSpawn()); Optional> entityType = EntityType.by(input); if (entityType.isEmpty()) { this.delay(level, pos); return; } Vec3 spawnPos = (Vec3)input.read("Pos", Vec3.CODEC) .orElseGet( () -> new Vec3( pos.getX() + (random.nextDouble() - random.nextDouble()) * this.spawnRange + 0.5, pos.getY() + random.nextInt(3) - 1, pos.getZ() + (random.nextDouble() - random.nextDouble()) * this.spawnRange + 0.5 ) ); if (level.noCollision(((EntityType)entityType.get()).getSpawnAABB(spawnPos.x, spawnPos.y, spawnPos.z))) { BlockPos spawnBlockPos = BlockPos.containing(spawnPos); if (nextSpawnData.getCustomSpawnRules().isPresent()) { if (!((EntityType)entityType.get()).getCategory().isFriendly() && level.getDifficulty() == Difficulty.PEACEFUL) { continue; } SpawnData.CustomSpawnRules customSpawnRules = (SpawnData.CustomSpawnRules)nextSpawnData.getCustomSpawnRules().get(); if (!customSpawnRules.isValidPosition(spawnBlockPos, level)) { continue; } } else if (!SpawnPlacements.checkSpawnRules((EntityType)entityType.get(), level, EntitySpawnReason.SPAWNER, spawnBlockPos, level.getRandom())) { continue; } Entity entity = EntityType.loadEntityRecursive(input, level, EntitySpawnReason.SPAWNER, e -> { e.snapTo(spawnPos.x, spawnPos.y, spawnPos.z, e.getYRot(), e.getXRot()); return e; }); if (entity == null) { this.delay(level, pos); return; } int nearBy = level.getEntities( EntityTypeTest.forExactClass(entity.getClass()), new AABB(pos.getX(), pos.getY(), pos.getZ(), pos.getX() + 1, pos.getY() + 1, pos.getZ() + 1).inflate(this.spawnRange), EntitySelector.NO_SPECTATORS ) .size(); if (nearBy >= this.maxNearbyEntities) { this.delay(level, pos); return; } entity.snapTo(entity.getX(), entity.getY(), entity.getZ(), random.nextFloat() * 360.0F, 0.0F); if (entity instanceof Mob mob) { if (nextSpawnData.getCustomSpawnRules().isEmpty() && !mob.checkSpawnRules(level, EntitySpawnReason.SPAWNER) || !mob.checkSpawnObstruction(level)) { continue; } boolean hasNoConfiguration = nextSpawnData.getEntityToSpawn().size() == 1 && nextSpawnData.getEntityToSpawn().getString("id").isPresent(); if (hasNoConfiguration) { ((Mob)entity).finalizeSpawn(level, level.getCurrentDifficultyAt(entity.blockPosition()), EntitySpawnReason.SPAWNER, null); } nextSpawnData.getEquipment().ifPresent(mob::equip); } if (!level.tryAddFreshEntityWithPassengers(entity)) { this.delay(level, pos); return; } level.levelEvent(2004, pos, 0); level.gameEvent(entity, GameEvent.ENTITY_PLACE, spawnBlockPos); if (entity instanceof Mob mob) { mob.spawnAnim(); } delay = true; } } } if (delay) { this.delay(level, pos); } return; } } } private void delay(final Level level, final BlockPos pos) { RandomSource random = level.random; if (this.maxSpawnDelay <= this.minSpawnDelay) { this.spawnDelay = this.minSpawnDelay; } else { this.spawnDelay = this.minSpawnDelay + random.nextInt(this.maxSpawnDelay - this.minSpawnDelay); } this.spawnPotentials.getRandom(random).ifPresent(entry -> this.setNextSpawnData(level, pos, entry)); this.broadcastEvent(level, pos, 1); } public void load(@Nullable final Level level, final BlockPos pos, final ValueInput input) { this.spawnDelay = input.getShortOr("Delay", (short)20); input.read("SpawnData", SpawnData.CODEC).ifPresent(nextSpawnData -> this.setNextSpawnData(level, pos, nextSpawnData)); this.spawnPotentials = (WeightedList)input.read("SpawnPotentials", SpawnData.LIST_CODEC) .orElseGet(() -> WeightedList.of(this.nextSpawnData != null ? this.nextSpawnData : new SpawnData())); this.minSpawnDelay = input.getIntOr("MinSpawnDelay", 200); this.maxSpawnDelay = input.getIntOr("MaxSpawnDelay", 800); this.spawnCount = input.getIntOr("SpawnCount", 4); this.maxNearbyEntities = input.getIntOr("MaxNearbyEntities", 6); this.requiredPlayerRange = input.getIntOr("RequiredPlayerRange", 16); this.spawnRange = input.getIntOr("SpawnRange", 4); this.displayEntity = null; } public void save(final ValueOutput output) { output.putShort("Delay", (short)this.spawnDelay); output.putShort("MinSpawnDelay", (short)this.minSpawnDelay); output.putShort("MaxSpawnDelay", (short)this.maxSpawnDelay); output.putShort("SpawnCount", (short)this.spawnCount); output.putShort("MaxNearbyEntities", (short)this.maxNearbyEntities); output.putShort("RequiredPlayerRange", (short)this.requiredPlayerRange); output.putShort("SpawnRange", (short)this.spawnRange); output.storeNullable("SpawnData", SpawnData.CODEC, this.nextSpawnData); output.store("SpawnPotentials", SpawnData.LIST_CODEC, this.spawnPotentials); } @Nullable public Entity getOrCreateDisplayEntity(final Level level, final BlockPos pos) { if (this.displayEntity == null) { CompoundTag entityToSpawn = this.getOrCreateNextSpawnData(level, level.getRandom(), pos).getEntityToSpawn(); if (entityToSpawn.getString("id").isEmpty()) { return null; } this.displayEntity = EntityType.loadEntityRecursive(entityToSpawn, level, EntitySpawnReason.SPAWNER, EntityProcessor.NOP); if (entityToSpawn.size() == 1 && this.displayEntity instanceof Mob) { } } return this.displayEntity; } public boolean onEventTriggered(final Level level, final int id) { if (id == 1) { if (level.isClientSide()) { this.spawnDelay = this.minSpawnDelay; } return true; } else { return false; } } protected void setNextSpawnData(@Nullable final Level level, final BlockPos pos, final SpawnData nextSpawnData) { this.nextSpawnData = nextSpawnData; } private SpawnData getOrCreateNextSpawnData(@Nullable final Level level, final RandomSource random, final BlockPos pos) { if (this.nextSpawnData != null) { return this.nextSpawnData; } else { this.setNextSpawnData(level, pos, (SpawnData)this.spawnPotentials.getRandom(random).orElseGet(SpawnData::new)); return this.nextSpawnData; } } public abstract void broadcastEvent(final Level level, final BlockPos pos, int id); public double getSpin() { return this.spin; } public double getOSpin() { return this.oSpin; } }