class="kw">package com.hypixel.hytale.server.core.modules.interaction.interaction.config.none;

class="kw">import com.hypixel.hytale.assetstore.map.IndexedLookupTableAssetMap;
class="kw">import com.hypixel.hytale.codec.KeyedCodec;
class="kw">import com.hypixel.hytale.codec.builder.BuilderCodec;
class="kw">import com.hypixel.hytale.codec.codecs.array.ArrayCodec;
class="kw">import com.hypixel.hytale.codec.validation.Validators;
class="kw">import com.hypixel.hytale.protocol.InteractionState;
class="kw">import com.hypixel.hytale.protocol.InteractionType;
class="kw">import com.hypixel.hytale.protocol.WaitForDataFrom;
class="kw">import com.hypixel.hytale.server.core.entity.InteractionContext;
class="kw">import com.hypixel.hytale.server.core.entity.InteractionManager;
class="kw">import com.hypixel.hytale.server.core.modules.interaction.interaction.CooldownHandler;
class="kw">import com.hypixel.hytale.server.core.modules.interaction.interaction.config.Interaction;
class="kw">import com.hypixel.hytale.server.core.modules.interaction.interaction.config.RootInteraction;
class="kw">import com.hypixel.hytale.server.core.modules.interaction.interaction.config.data.Collector;
class="kw">import com.hypixel.hytale.server.core.modules.interaction.interaction.config.data.CollectorTag;
class="kw">import java.util.Arrays;
class="kw">import javax.annotation.Nonnull;
class="kw">import javax.annotation.Nullable;

class="kw">public class ParallelInteraction class="kw">extends Interaction {
   class="kw">public class="kw">static class="kw">final BuilderCodec<ParallelInteraction> CODEC = BuilderCodec.builder(
         ParallelInteraction.class, ParallelInteraction::new, Interaction.ABSTRACT_CODEC
      )
      .documentation("Runs the provided interactions in parallel to this interaction chain.")
      .<String[]>appendInherited(
         new KeyedCodec<>("Interactions", new ArrayCodec<>(RootInteraction.CHILD_ASSET_CODEC, String[]::new)),
         (var0, var1) -> var0.interactions = var1,
         var0 -> var0.interactions,
         (var0, var1) -> var0.interactions = var1.interactions
      )
      .documentation("The collection of interaction roots to run in parallel via forks.")
      .addValidator(Validators.nonNull())
      .addValidatorLate(() -> RootInteraction.VALIDATOR_CACHE.getArrayValidator().late())
      .addValidator(Validators.arraySizeRange(2, Integer.MAX_VALUE))
      .add()
      .build();
   class="kw">protected String[] interactions;

   class="kw">public ParallelInteraction() {
   }

   @Nonnull
   @Override
   class="kw">public WaitForDataFrom getWaitForDataFrom() {
      class="kw">return WaitForDataFrom.None;
   }

   @Override
   class="kw">protected void tick0(boolean var1, float var2, @Nonnull InteractionType var3, @Nonnull InteractionContext var4, @Nonnull CooldownHandler var5) {
      IndexedLookupTableAssetMap var6 = RootInteraction.getAssetMap();
      var4.execute(RootInteraction.getRootInteractionOrUnknown(this.interactions[0]));

      for (int var7 = 1; var7 < this.interactions.length; var7++) {
         String var8 = this.interactions[var7];
         var4.fork(var4.duplicate(), RootInteraction.getRootInteractionOrUnknown(var8), true);
      }

      var4.getState().state = InteractionState.Finished;
   }

   @Override
   class="kw">protected void simulateTick0(boolean var1, float var2, @Nonnull InteractionType var3, @Nonnull InteractionContext var4, @Nonnull CooldownHandler var5) {
      IndexedLookupTableAssetMap var6 = RootInteraction.getAssetMap();
      var4.execute(RootInteraction.getRootInteractionOrUnknown(this.interactions[0]));
      var4.getState().state = InteractionState.Finished;
   }

   @Override
   class="kw">public boolean walk(@Nonnull Collector var1, @Nonnull InteractionContext var2) {
      for (int var3 = 0; var3 < this.interactions.length; var3++) {
         String var4 = this.interactions[var3];
         if (InteractionManager.walkInteractions(
            var1, var2, ParallelInteraction.ParallelTag.of(var3), RootInteraction.getRootInteractionOrUnknown(var4).getInteractionIds()
         )) {
            class="kw">return true;
         }
      }

      class="kw">return false;
   }

   @Override
   class="kw">public boolean needsRemoteSync() {
      class="kw">return true;
   }

   @Nonnull
   @Override
   class="kw">protected com.hypixel.hytale.protocol.Interaction generatePacket() {
      class="kw">return new com.hypixel.hytale.protocol.ParallelInteraction();
   }

   @Override
   class="kw">protected void configurePacket(com.hypixel.hytale.protocol.Interaction var1) {
      super.configurePacket(var1);
      com.hypixel.hytale.protocol.ParallelInteraction var2 = (com.hypixel.hytale.protocol.ParallelInteraction)var1;
      int[] var3 = var2.next = new int[this.interactions.length];

      for (int var4 = 0; var4 < this.interactions.length; var4++) {
         var3[var4] = RootInteraction.getRootInteractionIdOrUnknown(this.interactions[var4]);
      }
   }

   @Nonnull
   @Override
   class="kw">public String toString() {
      class="kw">return "ParallelInteraction{interactions=" + Arrays.toString(this.interactions) + "} " + super.toString();
   }

   class="kw">private class="kw">static class ParallelTag class="kw">implements CollectorTag {
      class="kw">private class="kw">final int index;

      class="kw">private ParallelTag(int var1) {
         this.index = var1;
      }

      class="kw">public int getIndex() {
         class="kw">return this.index;
      }

      @Override
      class="kw">public boolean equals(@Nullable Object var1) {
         if (this == var1) {
            class="kw">return true;
         } else if (var1 != null && this.getClass() == var1.getClass()) {
            ParallelInteraction.ParallelTag var2 = (ParallelInteraction.ParallelTag)var1;
            class="kw">return this.index == var2.index;
         } else {
            class="kw">return false;
         }
      }

      @Override
      class="kw">public int hashCode() {
         class="kw">return this.index;
      }

      @Nonnull
      @Override
      class="kw">public String toString() {
         class="kw">return "ParallelTag{index=" + this.index + "}";
      }

      @Nonnull
      class="kw">public class="kw">static ParallelInteraction.ParallelTag of(int var0) {
         class="kw">return new ParallelInteraction.ParallelTag(var0);
      }
   }
}