class="kw">package com.hypixel.hytale.server.core.command.system.basecommands;

class="kw">import com.hypixel.hytale.component.Ref;
class="kw">import com.hypixel.hytale.component.Store;
class="kw">import com.hypixel.hytale.server.core.Message;
class="kw">import com.hypixel.hytale.server.core.command.system.CommandContext;
class="kw">import com.hypixel.hytale.server.core.command.system.CommandUtil;
class="kw">import com.hypixel.hytale.server.core.command.system.arguments.system.OptionalArg;
class="kw">import com.hypixel.hytale.server.core.command.system.arguments.types.ArgTypes;
class="kw">import com.hypixel.hytale.server.core.command.system.exceptions.GeneralCommandException;
class="kw">import com.hypixel.hytale.server.core.permissions.PermissionQuery;
class="kw">import com.hypixel.hytale.server.core.universe.PlayerRef;
class="kw">import com.hypixel.hytale.server.core.universe.world.World;
class="kw">import com.hypixel.hytale.server.core.universe.world.storage.EntityStore;
class="kw">import java.util.ArrayList;
class="kw">import java.util.List;
class="kw">import java.util.concurrent.CompletableFuture;
class="kw">import javax.annotation.Nonnull;
class="kw">import javax.annotation.Nullable;

class="kw">public class="kw">abstract class AbstractTargetPlayersCommand class="kw">extends AbstractAsyncCommand {
   @Nonnull
   class="kw">private class="kw">final OptionalArg<PlayerRef> playerArg = this.withOptionalArg("player", "server.commands.argtype.player.desc", ArgTypes.PLAYER_REF);
   @Nonnull
   class="kw">private class="kw">final OptionalArg<Boolean> allArg = this.withOptionalArg("all", "server.commands.argtype.all.desc", ArgTypes.BOOLEAN);
   @Nullable
   class="kw">private PermissionQuery allPermission;
   @Nullable
   class="kw">private PermissionQuery otherPermission;

   class="kw">public AbstractTargetPlayersCommand(@Nonnull String var1, @Nonnull String var2) {
      super(var1, var2);
   }

   class="kw">public AbstractTargetPlayersCommand(@Nonnull String var1, @Nonnull String var2, boolean var3) {
      super(var1, var2, var3);
   }

   class="kw">public AbstractTargetPlayersCommand(@Nonnull String var1) {
      super(var1);
   }

   @Nonnull
   @Override
   class="kw">protected class="kw">final CompletableFuture<Void> executeAsync(@Nonnull CommandContext var1) {
      boolean var2 = this.allArg.provided(var1) && Boolean.TRUE.equals(this.allArg.get(var1));
      boolean var3 = this.playerArg.provided(var1);
      if (var2 && var3) {
         var1.sendMessage(Message.translation("server.commands.errors.targetConflict"));
         class="kw">return CompletableFuture.completedFuture(null);
      }

      if (var2) {
         if (this.allPermission != null) {
            CommandUtil.requirePermission(var1.sender(), this.allPermission);
         }

         class="kw">return this.runOnWorld(var1);
      } else if (var3) {
         if (this.otherPermission != null) {
            CommandUtil.requirePermission(var1.sender(), this.otherPermission);
         }

         class="kw">return this.runOnRef(var1, this.playerArg.get(var1).getReference());
      } else if (!var1.isPlayer()) {
         var1.sendMessage(Message.translation("server.commands.errors.playerOrArg").param("option", "player"));
         class="kw">return CompletableFuture.completedFuture(null);
      } else {
         class="kw">return this.runOnRef(var1, var1.senderAsPlayerRef());
      }
   }

   @Nonnull
   class="kw">private CompletableFuture<Void> runOnRef(@Nonnull CommandContext var1, @Nullable Ref<EntityStore> var2) {
      if (var2 != null && var2.isValid()) {
         Store var3 = var2.getStore();
         World var4 = var3.getExternalData().getWorld();
         class="kw">return this.runAsync(var1, () -> this.execute(var1, var4, var3, List.of(var2)), var4);
      } else {
         var1.sendMessage(Message.translation("server.commands.errors.playerNotInWorld"));
         class="kw">return CompletableFuture.completedFuture(null);
      }
   }

   @Nonnull
   class="kw">private CompletableFuture<Void> runOnWorld(@Nonnull CommandContext var1) {
      Ref var2 = var1.isPlayer() ? var1.senderAsPlayerRef() : null;
      if (var2 == null) {
         var1.sendMessage(Message.translation("server.commands.errors.noWorld"));
         class="kw">return CompletableFuture.completedFuture(null);
      } else {
         Store var3 = var2.getStore();
         World var4 = var3.getExternalData().getWorld();
         class="kw">return this.runAsync(var1, () -> {
            ArrayList var4 = new ArrayList<>();

            for (PlayerRef var6 : var4.getPlayerRefs()) {
               Ref var7 = var6.getReference();
               if (var7 != null && var7.isValid()) {
                  var4.add(var7);
               }
            }

            this.execute(var1, var4, var3, var4);
         }, var4);
      }
   }

   class="kw">protected class="kw">abstract void execute(@Nonnull CommandContext var1, @Nonnull World var2, @Nonnull Store<EntityStore> var3, @Nonnull List<Ref<EntityStore>> var4);

   @Override
   class="kw">public void completeRegistration() class="kw">throws GeneralCommandException {
      super.completeRegistration();
      this.allPermission = this.registerExtendedPermission("all");
      this.otherPermission = this.registerExtendedPermission("other");
   }
}