DonationAlerts.java

public class DonationAlerts {

    private final Socket socket;

    public DonationAlerts(String apiLink) throws URISyntaxException {

        URI url = new URI(apiLink);
        socket = IO.socket(url);

        Listener connectListener = arg0 -> logToConsole("Произведено успешное подключение!");

        Listener disconnectListener = arg0 -> logToConsole("Соединение разорвано!");

        Listener donationListener = arg0 -> {

            JSONObject json = new JSONObject((String) arg0[0]);
            new BukkitRunnable() {
                @Override
                public void run() {

                    if ((json.isNull("username")) || (json.isNull("amount_formatted"))) {
                        return;
                    }

                    if ((json.getString("amount_formatted")).length() <= 1) {
                        return;
                    }

                    DonationExecutor.getInstance().listOfStreamerPlayers
                            .addToDonationsQueue(new Donation(Bukkit.getConsoleSender(),
                                    json.getString("username"),
                                    json.getString("amount_formatted"),
                                    json.getString("message")));

                }
            }.runTask(Objects.requireNonNull(Bukkit.getPluginManager().getPlugin("DonationExecutor")));

        };

        Listener errorListener = arg0 -> logToConsole("Произошла ошибка подключения к Donation Alerts!");

        socket.on(Socket.EVENT_CONNECT, connectListener)
                .on(Socket.EVENT_DISCONNECT, disconnectListener)
                .on(Socket.EVENT_CONNECT_ERROR, errorListener)
                .on("donation", donationListener);
    }

    public void connect(String token) throws JSONException {
        socket.connect();
        socket.emit("add-user", new JSONObject()
                .put("token", token)
                .put("type", "minor"));
    }

    public void disconnect() throws JSONException {
        socket.disconnect();
    }

    @Suppress(names = "UNUSED")
    public boolean getConnected() {
        return socket.connected();
    }
}