package net.minecraft.util.debug;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import net.minecraft.SharedConstants;
import net.minecraft.network.protocol.Packet;
import net.minecraft.server.MinecraftServer;
import net.minecraft.server.level.ServerPlayer;
import net.minecraft.server.players.NameAndId;

public class ServerDebugSubscribers {
	private final MinecraftServer server;
	private final Map<DebugSubscription<?>, List<ServerPlayer>> enabledSubscriptions = new HashMap();

	public ServerDebugSubscribers(final MinecraftServer server) {
		this.server = server;
	}

	private List<ServerPlayer> getSubscribersFor(final DebugSubscription<?> subscription) {
		return (List<ServerPlayer>)this.enabledSubscriptions.getOrDefault(subscription, List.of());
	}

	public void tick() {
		this.enabledSubscriptions.values().forEach(List::clear);

		for (ServerPlayer player : this.server.getPlayerList().getPlayers()) {
			for (DebugSubscription<?> subscription : player.debugSubscriptions()) {
				((List)this.enabledSubscriptions.computeIfAbsent(subscription, s -> new ArrayList())).add(player);
			}
		}

		this.enabledSubscriptions.values().removeIf(List::isEmpty);
	}

	public void broadcastToAll(final DebugSubscription<?> subscription, final Packet<?> packet) {
		for (ServerPlayer player : this.getSubscribersFor(subscription)) {
			player.connection.send(packet);
		}
	}

	public Set<DebugSubscription<?>> enabledSubscriptions() {
		return Set.copyOf(this.enabledSubscriptions.keySet());
	}

	public boolean hasAnySubscriberFor(final DebugSubscription<?> subscription) {
		return !this.getSubscribersFor(subscription).isEmpty();
	}

	public boolean hasRequiredPermissions(final ServerPlayer player) {
		NameAndId nameAndId = player.nameAndId();
		return SharedConstants.IS_RUNNING_IN_IDE && this.server.isSingleplayerOwner(nameAndId) ? true : this.server.getPlayerList().isOp(nameAndId);
	}
}