FluidSection.java

package com.hypixel.hytale.server.core.universe.world.chunk.section;

import com.hypixel.hytale.assetstore.map.IndexedLookupTableAssetMap;
import com.hypixel.hytale.codec.Codec;
import com.hypixel.hytale.codec.ExtraInfo;
import com.hypixel.hytale.codec.KeyedCodec;
import com.hypixel.hytale.codec.builder.BuilderCodec;
import com.hypixel.hytale.component.Component;
import com.hypixel.hytale.component.ComponentType;
import com.hypixel.hytale.math.util.ChunkUtil;
import com.hypixel.hytale.protocol.CachedPacket;
import com.hypixel.hytale.protocol.packets.world.SetFluids;
import com.hypixel.hytale.server.core.asset.type.fluid.Fluid;
import com.hypixel.hytale.server.core.modules.LegacyModule;
import com.hypixel.hytale.server.core.universe.world.chunk.section.palette.EmptySectionPalette;
import com.hypixel.hytale.server.core.universe.world.chunk.section.palette.ISectionPalette;
import com.hypixel.hytale.server.core.universe.world.chunk.section.palette.PaletteTypeEnum;
import com.hypixel.hytale.server.core.universe.world.storage.ChunkStore;
import com.hypixel.hytale.server.core.util.io.ByteBufUtil;
import com.hypixel.hytale.sneakythrow.SneakyThrow;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.Unpooled;
import it.unimi.dsi.fastutil.ints.IntOpenHashSet;
import java.lang.ref.SoftReference;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.locks.StampedLock;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;

public class FluidSection implements Component<ChunkStore> {
   public static final int LEVEL_DATA_SIZE = 16384;
   public static final int VERSION = 0;
   public static final BuilderCodec<FluidSection> CODEC;
   private final StampedLock lock = new StampedLock();
   private int x;
   private int y;
   private int z;
   private boolean loaded = false;
   private ISectionPalette typePalette;
   @Nullable
   private byte[] levelData;
   private int nonZeroLevels;
   @Nonnull
   private IntOpenHashSet changedPositions;
   @Nonnull
   private IntOpenHashSet swapChangedPositions;
   @Nullable
   private transient SoftReference<CompletableFuture<CachedPacket<SetFluids>>> cachedPacket;

   public FluidSection() {
      this.typePalette = EmptySectionPalette.INSTANCE;
      this.levelData = null;
      this.nonZeroLevels = 0;
      this.changedPositions = new IntOpenHashSet(0);
      this.swapChangedPositions = new IntOpenHashSet(0);
      this.cachedPacket = null;
   }

   public static ComponentType<ChunkStore, FluidSection> getComponentType() {
      return LegacyModule.get().getFluidSectionComponentType();
   }

   public void preload(int x, int y, int z) {
      this.x = x;
      this.y = y;
      this.z = z;
   }

   public void load(int x, int y, int z) {
      this.x = x;
      this.y = y;
      this.z = z;
      this.loaded = true;
   }

   private boolean setFluidRaw(int x, int y, int z, int fluidId) {
      return this.setFluidRaw(ChunkUtil.indexBlock(x, y, z), fluidId);
   }

   private boolean setFluidRaw(int index, int fluidId) {
      ISectionPalette.SetResult result = this.typePalette.set(index, fluidId);
      if (result == ISectionPalette.SetResult.REQUIRES_PROMOTE) {
         this.typePalette = this.typePalette.promote();
         result = this.typePalette.set(index, fluidId);
         if (result != ISectionPalette.SetResult.ADDED_OR_REMOVED) {
            throw new IllegalStateException("Promoted fluid section failed to correctly add the new fluid");
         }
      } else if (this.typePalette.shouldDemote()) {
         this.typePalette = this.typePalette.demote();
      }

      return result != ISectionPalette.SetResult.UNCHANGED;
   }

   public boolean setFluid(int x, int y, int z, @Nonnull Fluid fluid, byte level) {
      return this.setFluid(ChunkUtil.indexBlock(x, y, z), Fluid.getAssetMap().getIndex(fluid.getId()), level);
   }

   public boolean setFluid(int x, int y, int z, int fluidId, byte level) {
      return this.setFluid(ChunkUtil.indexBlock(x, y, z), fluidId, level);
   }

   public boolean setFluid(int index, @Nonnull Fluid fluid, byte level) {
      return this.setFluid(index, Fluid.getAssetMap().getIndex(fluid.getId()), level);
   }

   public boolean setFluid(int index, int fluidId, byte level) {
      level = (byte)(level & 15);
      if (level == 0) {
         fluidId = 0;
      }

      if (fluidId == 0) {
         level = 0;
      }

      long stamp = this.lock.writeLock();

      boolean var7;
      try {
         boolean changed = this.setFluidRaw(index, fluidId);
         changed |= this.setFluidLevel(index, level);
         if (changed && this.loaded) {
            this.cachedPacket = null;
            this.changedPositions.add(index);
         }

         var7 = changed;
      } finally {
         this.lock.unlockWrite(stamp);
      }

      return var7;
   }

   private boolean setFluidRaw(int x, int y, int z, @Nonnull Fluid fluid) {
      return this.setFluidRaw(ChunkUtil.indexBlock(x, y, z), fluid);
   }

   private boolean setFluidRaw(int index, @Nonnull Fluid fluid) {
      IndexedLookupTableAssetMap<String, Fluid> assetMap = Fluid.getAssetMap();
      return this.setFluidRaw(index, assetMap.getIndex(fluid.getId()));
   }

   public int getFluidId(int x, int y, int z) {
      return this.getFluidId(ChunkUtil.indexBlock(x, y, z));
   }

   public int getFluidId(int index) {
      long stamp = this.lock.tryOptimisticRead();
      int currentId = this.typePalette.get(index);
      if (!this.lock.validate(stamp)) {
         stamp = this.lock.readLock();

         try {
            currentId = this.typePalette.get(index);
         } finally {
            this.lock.unlockRead(stamp);
         }
      }

      return currentId;
   }

   @Nullable
   public Fluid getFluid(int x, int y, int z) {
      return this.getFluid(ChunkUtil.indexBlock(x, y, z));
   }

   @Nullable
   public Fluid getFluid(int index) {
      IndexedLookupTableAssetMap<String, Fluid> assetMap = Fluid.getAssetMap();
      return assetMap.getAsset(this.getFluidId(index));
   }

   private boolean setFluidLevel(int x, int y, int z, byte level) {
      return this.setFluidLevel(ChunkUtil.indexBlock(x, y, z), level);
   }

   private boolean setFluidLevel(int index, byte level) {
      level = (byte)(level & 15);
      if (this.levelData == null) {
         if (level == 0) {
            return false;
         }

         this.levelData = new byte[16384];
      }

      int byteIndex = index >> 1;
      byte byteValue = this.levelData[byteIndex];
      int value = byteValue >> (index & 1) * 4 & 15;
      if (value == level) {
         return false;
      } else {
         if (value == 0) {
            ++this.nonZeroLevels;
         } else if (level == 0) {
            --this.nonZeroLevels;
            if (this.nonZeroLevels <= 0) {
               this.levelData = null;
               return true;
            }
         }

         if ((index & 1) == 0) {
            this.levelData[byteIndex] = (byte)(byteValue & 240 | level);
         } else {
            this.levelData[byteIndex] = (byte)(byteValue & 15 | level << 4);
         }

         return true;
      }
   }

   public byte getFluidLevel(int x, int y, int z) {
      return this.getFluidLevel(ChunkUtil.indexBlock(x, y, z));
   }

   public byte getFluidLevel(int index) {
      long stamp = this.lock.tryOptimisticRead();
      byte[] localData = this.levelData;
      byte result = 0;
      if (localData != null) {
         int byteIndex = index >> 1;
         byte byteValue = localData[byteIndex];
         result = (byte)(byteValue >> (index & 1) * 4 & 15);
      }

      if (!this.lock.validate(stamp)) {
         stamp = this.lock.readLock();

         int byteIndex;
         try {
            if (this.levelData != null) {
               byteIndex = index >> 1;
               byte byteValue = this.levelData[byteIndex];
               byte var8 = (byte)(byteValue >> (index & 1) * 4 & 15);
               return var8;
            }

            byteIndex = 0;
         } finally {
            this.lock.unlockRead(stamp);
         }

         return (byte)byteIndex;
      } else {
         return result;
      }
   }

   public int getX() {
      return this.x;
   }

   public int getY() {
      return this.y;
   }

   public int getZ() {
      return this.z;
   }

   @Nonnull
   public IntOpenHashSet getAndClearChangedPositions() {
      long stamp = this.lock.writeLock();

      IntOpenHashSet var4;
      try {
         this.swapChangedPositions.clear();
         IntOpenHashSet tmp = this.changedPositions;
         this.changedPositions = this.swapChangedPositions;
         this.swapChangedPositions = tmp;
         var4 = tmp;
      } finally {
         this.lock.unlockWrite(stamp);
      }

      return var4;
   }

   @Nonnull
   public Component<ChunkStore> clone() {
      return this;
   }

   private void serializeForPacket(@Nonnull ByteBuf buf) {
      long stamp = this.lock.readLock();

      try {
         buf.writeByte(this.typePalette.getPaletteType().ordinal());
         this.typePalette.serializeForPacket(buf);
         if (this.levelData != null) {
            buf.writeBoolean(true);
            buf.writeBytes(this.levelData);
         } else {
            buf.writeBoolean(false);
         }
      } finally {
         this.lock.unlockRead(stamp);
      }

   }

   private byte[] serialize(ExtraInfo extraInfo) {
      ByteBuf buf = ByteBufAllocator.DEFAULT.buffer();
      long stamp = this.lock.readLock();

      byte[] var5;
      try {
         buf.writeByte(this.typePalette.getPaletteType().ordinal());
         this.typePalette.serialize(Fluid.KEY_SERIALIZER, buf);
         if (this.levelData != null) {
            buf.writeBoolean(true);
            buf.writeBytes(this.levelData);
         } else {
            buf.writeBoolean(false);
         }

         var5 = ByteBufUtil.getBytesRelease(buf);
      } catch (Throwable e) {
         buf.release();
         throw SneakyThrow.sneakyThrow(e);
      } finally {
         this.lock.unlockRead(stamp);
      }

      return var5;
   }

   private void deserialize(@Nonnull byte[] bytes, ExtraInfo extraInfo) {
      ByteBuf buf = Unpooled.wrappedBuffer(bytes);
      PaletteTypeEnum type = PaletteTypeEnum.get(buf.readByte());
      this.typePalette = (ISectionPalette)type.getConstructor().get();
      this.typePalette.deserialize(Fluid.KEY_DESERIALIZER, buf, 0);
      if (buf.readBoolean()) {
         this.levelData = new byte[16384];
         buf.readBytes(this.levelData);
         this.nonZeroLevels = 0;

         for(int i = 0; i < 16384; ++i) {
            byte v = this.levelData[i];
            if ((v & 15) != 0) {
               ++this.nonZeroLevels;
            }

            if ((v & 240) != 0) {
               ++this.nonZeroLevels;
            }
         }
      } else {
         this.levelData = null;
      }

   }

   @Nonnull
   public CompletableFuture<CachedPacket<SetFluids>> getCachedPacket() {
      SoftReference<CompletableFuture<CachedPacket<SetFluids>>> ref = this.cachedPacket;
      CompletableFuture<CachedPacket<SetFluids>> future = ref != null ? (CompletableFuture)ref.get() : null;
      if (future != null) {
         return future;
      } else {
         future = CompletableFuture.supplyAsync(() -> {
            ByteBuf buf = Unpooled.buffer(65536);
            this.serializeForPacket(buf);
            byte[] data = ByteBufUtil.getBytesRelease(buf);
            SetFluids packet = new SetFluids(this.x, this.y, this.z, data);
            return CachedPacket.cache(packet);
         });
         this.cachedPacket = new SoftReference(future);
         return future;
      }
   }

   public boolean isEmpty() {
      return this.typePalette.isSolid(0) && this.nonZeroLevels == 0;
   }

   static {
      CODEC = ((BuilderCodec.Builder)((BuilderCodec.Builder)((BuilderCodec.Builder)BuilderCodec.builder(FluidSection.class, FluidSection::new).versioned()).codecVersion(0)).append(new KeyedCodec("Data", Codec.BYTE_ARRAY), FluidSection::deserialize, FluidSection::serialize).add()).build();
   }
}