package gq.malwarefight.tokenapp;

import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.mojang.authlib.GameProfile;
import com.mojang.authlib.yggdrasil.YggdrasilAuthenticationService;
import com.mojang.authlib.yggdrasil.YggdrasilMinecraftSessionService;
import gq.malwarefight.nosession.utils.Utils;
import org.apache.commons.lang3.exception.ExceptionUtils;

import javax.net.ssl.HttpsURLConnection;
import java.io.IOException;
import java.net.*;
import java.util.UUID;

public class Main {

    public static final int BASE_PORT = 47777;
    public static YggdrasilMinecraftSessionService sessionService = null;
    public static YggdrasilAuthenticationService authenticationService = null;
    public static GameProfile gameProfile = null;

    public static void setup() throws IOException {
        String token = Utils.readString(System.in, '\n');
        YggdrasilAuthenticationService yas = new YggdrasilAuthenticationService(Proxy.NO_PROXY,
            token);
        authenticationService = yas;
        sessionService = (YggdrasilMinecraftSessionService) yas.createMinecraftSessionService();
        HttpsURLConnection httpsURLConnection = (HttpsURLConnection) (new URL(
            "https://api.minecraftservices.com/minecraft/profile").openConnection());
        System.out.println("CHILD PROCESS: " + token);
        httpsURLConnection.setRequestProperty("Authorization", "Bearer " + token);
        String response = Utils.readString(httpsURLConnection.getInputStream(), null);
        JsonObject jsonObject = new JsonParser().parse(response).getAsJsonObject();
        UUID id = UUID.fromString(
            Utils.normalizeUUID(jsonObject.get("id").getAsString())
        );
        String name = jsonObject.get("name").getAsString();
        gameProfile = new GameProfile(id, name);
        System.setProperty("java.net.preferIPv4Stack", "true");
    }

    public static void main(String[] args) {
        try {
            setup();
        } catch (Exception e) {
            System.err.println("Could not setup the server\n" + ExceptionUtils.getStackTrace(e));
            System.exit(1);
        }
        ServerSocket sock = null;
        for (int i = BASE_PORT; i < BASE_PORT + 10; i++) {
            try {
                //noinspection resource
                sock = new ServerSocket(i, 50, InetAddress.getLoopbackAddress());
                break;
            } catch (Exception ignored) {
              // we couldn't bind to the port, try the next one
            }
        }
        if (sock == null) {
            System.err.println("Could not bind to any valid port");
            System.exit(1);
        }
        while (true) {
            try {
                Socket connection = sock.accept();
                Thread t = new SocketThread(connection);
                t.start();
            } catch (IOException exception) {
                System.exit(0);
            }
        }
    }
}