package net.minecraft.client.multiplayer;

import com.google.common.collect.Lists;
import com.mojang.authlib.GameProfile;
import com.mojang.logging.LogUtils;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelException;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Optional;
import net.fabricmc.api.EnvType;
import net.fabricmc.api.Environment;
import net.minecraft.ChatFormatting;
import net.minecraft.Util;
import net.minecraft.client.gui.screens.ConnectScreen;
import net.minecraft.client.multiplayer.resolver.ResolvedServerAddress;
import net.minecraft.client.multiplayer.resolver.ServerAddress;
import net.minecraft.client.multiplayer.resolver.ServerNameResolver;
import net.minecraft.network.Connection;
import net.minecraft.network.DisconnectionDetails;
import net.minecraft.network.chat.CommonComponents;
import net.minecraft.network.chat.Component;
import net.minecraft.network.protocol.ping.ClientboundPongResponsePacket;
import net.minecraft.network.protocol.ping.ServerboundPingRequestPacket;
import net.minecraft.network.protocol.status.ClientStatusPacketListener;
import net.minecraft.network.protocol.status.ClientboundStatusResponsePacket;
import net.minecraft.network.protocol.status.ServerStatus;
import net.minecraft.network.protocol.status.ServerboundStatusRequestPacket;
import org.slf4j.Logger;

@Environment(EnvType.CLIENT)
public class ServerStatusPinger {
	private static final Logger LOGGER = LogUtils.getLogger();
	private static final Component CANT_CONNECT_MESSAGE = Component.translatable("multiplayer.status.cannot_connect").withColor(-65536);
	/**
	 * A list of NetworkManagers that have pending pings
	 */
	private final List<Connection> connections = Collections.synchronizedList(Lists.newArrayList());

	public void pingServer(ServerData serverData, Runnable serverListUpdater, Runnable stateUpdater) throws UnknownHostException {
		final ServerAddress serverAddress = ServerAddress.parseString(serverData.ip);
		Optional<InetSocketAddress> optional = ServerNameResolver.DEFAULT.resolveAddress(serverAddress).map(ResolvedServerAddress::asInetSocketAddress);
		if (optional.isEmpty()) {
			this.onPingFailed(ConnectScreen.UNKNOWN_HOST_MESSAGE, serverData);
		} else {
			final InetSocketAddress inetSocketAddress = (InetSocketAddress)optional.get();
			final Connection connection = Connection.connectToServer(inetSocketAddress, false, null);
			this.connections.add(connection);
			serverData.motd = Component.translatable("multiplayer.status.pinging");
			serverData.playerList = Collections.emptyList();
			ClientStatusPacketListener clientStatusPacketListener = new ClientStatusPacketListener() {
				private boolean success;
				private boolean receivedPing;
				private long pingStart;

				@Override
				public void handleStatusResponse(ClientboundStatusResponsePacket packet) {
					if (this.receivedPing) {
						connection.disconnect(Component.translatable("multiplayer.status.unrequested"));
					} else {
						this.receivedPing = true;
						ServerStatus serverStatus = packet.status();
						serverData.motd = serverStatus.description();
						serverStatus.version().ifPresentOrElse(version -> {
							serverData.version = Component.literal(version.name());
							serverData.protocol = version.protocol();
						}, () -> {
							serverData.version = Component.translatable("multiplayer.status.old");
							serverData.protocol = 0;
						});
						serverStatus.players().ifPresentOrElse(players -> {
							serverData.status = ServerStatusPinger.formatPlayerCount(players.online(), players.max());
							serverData.players = players;
							if (!players.sample().isEmpty()) {
								List<Component> list = new ArrayList(players.sample().size());

								for (GameProfile gameProfile : players.sample()) {
									list.add(Component.literal(gameProfile.getName()));
								}

								if (players.sample().size() < players.online()) {
									list.add(Component.translatable("multiplayer.status.and_more", players.online() - players.sample().size()));
								}

								serverData.playerList = list;
							} else {
								serverData.playerList = List.of();
							}
						}, () -> serverData.status = Component.translatable("multiplayer.status.unknown").withStyle(ChatFormatting.DARK_GRAY));
						serverStatus.favicon().ifPresent(favicon -> {
							if (!Arrays.equals(favicon.iconBytes(), serverData.getIconBytes())) {
								serverData.setIconBytes(ServerData.validateIcon(favicon.iconBytes()));
								serverListUpdater.run();
							}
						});
						this.pingStart = Util.getMillis();
						connection.send(new ServerboundPingRequestPacket(this.pingStart));
						this.success = true;
					}
				}

				@Override
				public void handlePongResponse(ClientboundPongResponsePacket packet) {
					long l = this.pingStart;
					long m = Util.getMillis();
					serverData.ping = m - l;
					connection.disconnect(Component.translatable("multiplayer.status.finished"));
					stateUpdater.run();
				}

				@Override
				public void onDisconnect(DisconnectionDetails details) {
					if (!this.success) {
						ServerStatusPinger.this.onPingFailed(details.reason(), serverData);
						ServerStatusPinger.this.pingLegacyServer(inetSocketAddress, serverAddress, serverData);
					}
				}

				@Override
				public boolean isAcceptingMessages() {
					return connection.isConnected();
				}
			};

			try {
				connection.initiateServerboundStatusConnection(serverAddress.getHost(), serverAddress.getPort(), clientStatusPacketListener);
				connection.send(ServerboundStatusRequestPacket.INSTANCE);
			} catch (Throwable var10) {
				LOGGER.error("Failed to ping server {}", serverAddress, var10);
			}
		}
	}

	void onPingFailed(Component reason, ServerData serverData) {
		LOGGER.error("Can't ping {}: {}", serverData.ip, reason.getString());
		serverData.motd = CANT_CONNECT_MESSAGE;
		serverData.status = CommonComponents.EMPTY;
	}

	void pingLegacyServer(InetSocketAddress resolvedServerAddress, ServerAddress serverAddress, ServerData serverData) {
		new Bootstrap().group((EventLoopGroup)Connection.NETWORK_WORKER_GROUP.get()).handler(new ChannelInitializer<Channel>() {
			@Override
			protected void initChannel(Channel channel) {
				try {
					channel.config().setOption(ChannelOption.TCP_NODELAY, true);
				} catch (ChannelException var3) {
				}

				channel.pipeline().addLast(new LegacyServerPinger(serverAddress, (i, string, string2, j, k) -> {
					serverData.setState(ServerData.State.INCOMPATIBLE);
					serverData.version = Component.literal(string);
					serverData.motd = Component.literal(string2);
					serverData.status = ServerStatusPinger.formatPlayerCount(j, k);
					serverData.players = new ServerStatus.Players(k, j, List.of());
				}));
			}
		}).channel(NioSocketChannel.class).connect(resolvedServerAddress.getAddress(), resolvedServerAddress.getPort());
	}

	public static Component formatPlayerCount(int players, int capacity) {
		Component component = Component.literal(Integer.toString(players)).withStyle(ChatFormatting.GRAY);
		Component component2 = Component.literal(Integer.toString(capacity)).withStyle(ChatFormatting.GRAY);
		return Component.translatable("multiplayer.status.player_count", component, component2).withStyle(ChatFormatting.DARK_GRAY);
	}

	public void tick() {
		synchronized (this.connections) {
			Iterator<Connection> iterator = this.connections.iterator();

			while (iterator.hasNext()) {
				Connection connection = (Connection)iterator.next();
				if (connection.isConnected()) {
					connection.tick();
				} else {
					iterator.remove();
					connection.handleDisconnection();
				}
			}
		}
	}

	public void removeAll() {
		synchronized (this.connections) {
			Iterator<Connection> iterator = this.connections.iterator();

			while (iterator.hasNext()) {
				Connection connection = (Connection)iterator.next();
				if (connection.isConnected()) {
					iterator.remove();
					connection.disconnect(Component.translatable("multiplayer.status.cancelled"));
				}
			}
		}
	}
}