package com.example.tornadomod.weather; import com.example.tornadomod.networking.StormPayload; import net.fabricmc.fabric.api.networking.v1.ServerPlayNetworking; import net.minecraft.entity.LivingEntity; import net.minecraft.server.MinecraftServer; import net.minecraft.server.network.ServerPlayerEntity; import net.minecraft.server.world.ServerWorld; import net.minecraft.util.math.BlockPos; import net.minecraft.util.math.Box; import net.minecraft.util.math.Vec3d; import net.minecraft.world.Heightmap; import net.minecraft.world.World; import java.util.ArrayList; import java.util.Iterator; import java.util.List; public class StormManager { private static final List activeZones = new ArrayList<>(); private static int tickCounter = 0; private static final int CHECK_INTERVAL = 100; // every 5 seconds for weather events private static final int SYNC_INTERVAL = 40; // sync to clients every 2 seconds public static void tick(ServerWorld world) { tickCounter++; // Update existing zones Iterator it = activeZones.iterator(); while (it.hasNext()) { StormZone zone = it.next(); zone.tick(); // Apply effects applyWindPush(world, zone); applyStormEffects(world, zone); if (zone.isExpired()) { it.remove(); } } // Spawn periodic weather events if (tickCounter % CHECK_INTERVAL == 0) { trySpawnWeatherEvent(world); } // Sync to players if (tickCounter % SYNC_INTERVAL == 0) { syncToPlayers(world); } } public static void tick(MinecraftServer server) { for (ServerWorld world : server.getWorlds()) { if (world.getRegistryKey() == World.OVERWORLD) { tick(world); } } } public static void addWarning(ServerWorld world, int x, int y, int z, StormType type) { int duration = switch (type) { case TORNADO_WARNING -> 600; // 30 seconds warning before tornado spawns case HEAVY_RAIN -> 3600; // 3 minutes case SANDSTORM -> 2400; // 2 minutes case SNOWSTORM -> 2400; // 2 minutes default -> 0; }; int radius = switch (type) { case TORNADO_WARNING -> 48; // 48 block radius warning zone case HEAVY_RAIN -> 64; case SANDSTORM -> 80; case SNOWSTORM -> 80; default -> 32; }; StormZone zone = new StormZone(x, y, z, radius, duration, type); activeZones.add(zone); } private static void applyWindPush(ServerWorld world, StormZone zone) { if (zone.type == StormType.SANDSTORM || zone.type == StormType.SNOWSTORM) { Box area = new Box( zone.x - zone.radius, zone.y - 10, zone.z - zone.radius, zone.x + zone.radius, zone.y + 40, zone.z + zone.radius ); List entities = world.getEntitiesByClass(LivingEntity.class, area, e -> !e.isSpectator()); Vec3d wind = new Vec3d(zone.windDirX * zone.intensity * 0.15, 0, zone.windDirZ * zone.intensity * 0.15); for (LivingEntity e : entities) { e.addVelocity(wind.x, wind.y, wind.z); } } } private static void applyStormEffects(ServerWorld world, StormZone zone) { Box area = new Box( zone.x - zone.radius, zone.y - 10, zone.z - zone.radius, zone.x + zone.radius, zone.y + 40, zone.z + zone.radius ); if (zone.type == StormType.SNOWSTORM) { List entities = world.getEntitiesByClass(LivingEntity.class, area, e -> !e.isSpectator()); for (LivingEntity e : entities) { if (zone.age % 40 == 0) { e.setFrozenTicks(e.getFrozenTicks() + 40); } } } } private static void trySpawnWeatherEvent(ServerWorld world) { List players = world.getPlayers(); if (players.isEmpty()) return; if (world.random.nextInt(3) != 0) return; // ~33% chance every 5 seconds ServerPlayerEntity player = players.get(world.random.nextInt(players.size())); // Don't spawn if already in a storm zone for (StormZone zone : activeZones) { double dx = player.getX() - zone.x; double dz = player.getZ() - zone.z; if (dx * dx + dz * dz < zone.radius * zone.radius) return; } double angle = world.random.nextDouble() * Math.PI * 2; double distance = 40 + world.random.nextDouble() * 120; int x = (int) (player.getX() + Math.cos(angle) * distance); int z = (int) (player.getZ() + Math.sin(angle) * distance); int y = world.getTopY(Heightmap.Type.WORLD_SURFACE, x, z); StormType[] types = {StormType.HEAVY_RAIN, StormType.SANDSTORM, StormType.SNOWSTORM}; StormType type = types[world.random.nextInt(types.length)]; addWarning(world, x, y, z, type); } private static void syncToPlayers(ServerWorld world) { List players = world.getPlayers(); if (players.isEmpty() || activeZones.isEmpty()) return; // Find the nearest zone for each player for (ServerPlayerEntity player : players) { StormZone nearest = null; double nearestDist = Double.MAX_VALUE; for (StormZone zone : activeZones) { double dx = player.getX() - zone.x; double dz = player.getZ() - zone.z; double dist = dx * dx + dz * dz; if (dist < nearestDist) { nearestDist = dist; nearest = zone; } } if (nearest != null && ServerPlayNetworking.canSend(player, StormPayload.ID)) { double dist = Math.sqrt(nearestDist); float intensity = (float) Math.max(0, 1.0 - (dist / (nearest.radius * 3))); if (intensity > 0.05f) { ServerPlayNetworking.send(player, new StormPayload( nearest.type, intensity, nearest.x, nearest.z, nearest.radius )); } } } } public static List getActiveZones() { return activeZones; } public static class StormZone { public final int x, y, z; public final int radius; public final int duration; public final StormType type; public int age = 0; public float intensity; public double windDirX, windDirZ; public StormZone(int x, int y, int z, int radius, int duration, StormType type) { this.x = x; this.y = y; this.z = z; this.radius = radius; this.duration = duration; this.type = type; this.intensity = 0.0f; this.windDirX = 1.0; this.windDirZ = 0.0; } public void tick() { age++; // Ramp up intensity during first 40 ticks, ramp down in last 60 ticks if (age < 40) { intensity = (float) age / 40.0f; } else if (age > duration - 60) { intensity = (float) (duration - age) / 60.0f; } else { intensity = Math.min(1.0f, 0.5f + (float) age / (float) duration); } // Slowly rotate wind direction windDirX = Math.cos(age * 0.001); windDirZ = Math.sin(age * 0.001); } public boolean isExpired() { return age >= duration || intensity <= 0.01f; } } }