Почитай этот пост.
import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.URL;
public static boolean isPremiumByAPI(String playerName) {
try {
URL url = new URL("https://api.ashcon.app/mojang/v2/user/" + playerName);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
return (connection.getResponseCode() == HttpURLConnection.HTTP_OK);
} catch (IOException e) {
e.printStackTrace();
return false;
}
}
Так ты лишь проверишь, существует ли такой лицензионный ник в Mojang. Это вовсе не означает, что у игрока есть доступ к этому аккаунту, он вполне может входить и с пиратки с чужим ником.
Ты по своей инициативе никак не узнаешь, есть ли у игрока лицензия. Инициатива должна исходить от игрока, он должен хотя бы раз переподключиться к серверу, чтобы ты смог включить ему онлайн мод и тем самым убедиться в наличии или отсутствии у него лицензии
А нельзя ли сразу по пакетам проверять при первом входе, там вроде выше версии 1.20 какой-то новый способ есть?
А при помощи NMS есть способ какой?
https://github.com/yann1n/LizardAuth
Какой способ? С transfer пакетом?
НМС - это серверная сторона, а ограничения на стороне клиента.
На банже можно использовать метод .setOnlineMode(true)
А почему НМС тут не поможет?, там же присутствует работа с пакетами.
Ты можешь и через нмс пакеты отправлять, но зачем?
Как я буду получать или создавать Server ID и ключи шифрования дла отправки пакетов, какие у них свойства, какое шифрование применять?
import com.comphenix.protocol.PacketType;
import com.comphenix.protocol.ProtocolLibrary;
import com.comphenix.protocol.ProtocolManager;
import com.comphenix.protocol.events.ListenerPriority;
import com.comphenix.protocol.events.PacketAdapter;
import com.comphenix.protocol.events.PacketEvent;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.AsyncPlayerPreLoginEvent;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.java.JavaPlugin;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.*;
import java.security.spec.PKCS8EncodedKeySpec;
import java.security.spec.X509EncodedKeySpec;
import java.util.Arrays;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.CompletableFuture;
import javax.crypto.Cipher;
import javax.crypto.spec.SecretKeySpec;
public class LizardAuth extends JavaPlugin implements Listener {
private ProtocolManager protocolManager;
private byte[] sharedSecret;
private byte[] verifyToken;
private final Random random = new SecureRandom();
private PublicKey publicKey;
private PrivateKey privateKey;
private File privateKeyFile;
private final String keyPass = "password";
@Override
public void onEnable() {
getLogger().info("LizardAuth is enabling...");
protocolManager = ProtocolLibrary.getProtocolManager();
getServer().getPluginManager().registerEvents(this, this);
getLogger().info("LizardAuth enabled successfully");
try {
loadOrCreateKeys();
} catch (NoSuchAlgorithmException e) {
getLogger().severe("Failed to generate RSA keys: " + e.getMessage());
this.getServer().getPluginManager().disablePlugin(this);
return;
} catch (Exception e) {
getLogger().severe("Failed to load or create RSA keys: " + e.getMessage());
this.getServer().getPluginManager().disablePlugin(this);
return;
}
registerPacketListeners();
}
@Override
public void onDisable() {
getLogger().info("LizardAuth is disabling...");
protocolManager.removePacketListeners(this);
getLogger().info("LizardAuth disabled successfully");
}
private void loadOrCreateKeys() throws Exception {
privateKeyFile = new File(getDataFolder(), "private.key");
if (privateKeyFile.exists()) {
try {
loadKeys();
} catch (Exception e){
getLogger().severe("Failed to load keys, creating new one! Error: " + e.getMessage());
generateKeys();
saveKeys();
}
} else {
generateKeys();
saveKeys();
}
}
private void generateKeys() throws NoSuchAlgorithmException {
KeyPairGenerator keyGen = KeyPairGenerator.getInstance("RSA");
keyGen.initialize(2048);
KeyPair pair = keyGen.generateKeyPair();
this.publicKey = pair.getPublic();
this.privateKey = pair.getPrivate();
}
private void saveKeys() throws Exception {
if (!getDataFolder().exists()) {
getDataFolder().mkdirs();
}
PKCS8EncodedKeySpec privateKeySpec = new PKCS8EncodedKeySpec(privateKey.getEncoded());
byte[] encryptedPrivateKey = encryptPrivateKey(privateKeySpec.getEncoded(), keyPass);
FileOutputStream fos = new FileOutputStream(privateKeyFile);
fos.write(encryptedPrivateKey);
fos.close();
}
private void loadKeys() throws Exception{
byte[] encryptedPrivateKey = Files.readAllBytes(Paths.get(privateKeyFile.getPath()));
byte[] decryptedPrivateKey = decryptPrivateKey(encryptedPrivateKey, keyPass);
PKCS8EncodedKeySpec privateKeySpec = new PKCS8EncodedKeySpec(decryptedPrivateKey);
KeyFactory keyFactory = KeyFactory.getInstance("RSA");
privateKey = keyFactory.generatePrivate(privateKeySpec);
X509EncodedKeySpec publicKeySpec = new X509EncodedKeySpec(publicKey.getEncoded());
publicKey = keyFactory.generatePublic(publicKeySpec);
}
private void registerPacketListeners() {
protocolManager.addPacketListener(new PacketAdapter(
this,
ListenerPriority.NORMAL,
Arrays.asList(PacketType.Handshake.Client.SET_PROTOCOL, PacketType.Login.Client.ENCRYPTION_BEGIN)
) {
@Override
public void onPacketReceiving(PacketEvent event) {
if (event.getPacketType() == PacketType.Handshake.Client.SET_PROTOCOL) {
getLogger().info("C -> S: Handshake - Packet caught!");
// Create and send Encryption Begin
Player player = event.getPlayer();
sendEncryptionBeginPacket(player);
// Cancel handshake processing
event.setCancelled(true);
} else if (event.getPacketType() == PacketType.Login.Client.ENCRYPTION_BEGIN) {
getLogger().info("C -> S: Encryption Response - Packet caught!");
// Получение данных из пакета Encryption Response (от клиента)
sharedSecret = event.getPacket().getByteArrays().read(0);
byte[] encryptedVerifyToken = event.getPacket().getByteArrays().read(1);
try {
byte[] decryptedVerifyToken = decryptData(encryptedVerifyToken);
if (Arrays.equals(decryptedVerifyToken, verifyToken)) {
getLogger().info("Decrypted Verify Token matches");
byte[] decryptedSharedSecret = decryptData(sharedSecret);
getLogger().info("Shared Secret decrypted: " + Arrays.toString(decryptedSharedSecret));
sharedSecret = decryptedSharedSecret;
} else {
getLogger().severe("Decrypted Verify Token doesnt match");
event.setCancelled(true);
return;
}
} catch (Exception e) {
getLogger().severe("Failed to decrypt verify token: " + e.getMessage());
event.setCancelled(true);
return;
}
getLogger().info("Shared Secret: " + Arrays.toString(sharedSecret));
// event.getPlayer().kickPlayer("Debug!");
}
}
});
}
public void sendEncryptionBeginPacket(Player player) {
verifyToken = generateVerifyToken();
com.comphenix.protocol.wrappers.PacketContainer encryptionBeginPacket = new com.comphenix.protocol.wrappers.PacketContainer(PacketType.Login.Server.ENCRYPTION_BEGIN);
encryptionBeginPacket.getSpecificModifier(String.class).write(0, ""); // Server ID
encryptionBeginPacket.getByteArrays().write(0, publicKey.getEncoded()); // Public Key
encryptionBeginPacket.getByteArrays().write(1, verifyToken); // Verify Token
try {
protocolManager.sendServerPacket(player, encryptionBeginPacket);
} catch (Exception e) {
getLogger().severe("Failed to send Encryption Begin packet: " + e.getMessage());
}
getLogger().info("S -> C: Encryption Request - Packet sent!");
getLogger().info("Public key: " + Arrays.toString(publicKey.getEncoded()));
getLogger().info("Verify token: " + Arrays.toString(verifyToken));
}
@EventHandler
public void onPlayerJoin(PlayerJoinEvent event) {
getLogger().info("Player " + event.getPlayer().getName() + " has joined (PlayerJoinEvent)");
}
@EventHandler
public void onPlayerPreLogin(AsyncPlayerPreLoginEvent event) {
getLogger().info("Player " + event.getName() + " is attempting to log in (Async)");
getLogger().info("UUID: " + event.getUniqueId());
getLogger().info("IP Address: " + event.getAddress().getHostAddress());
getLogger().info("Hostname: " + event.getHostname());
CompletableFuture.runAsync(() -> {
try {
if (sharedSecret == null || verifyToken == null) {
event.disallow(AsyncPlayerPreLoginEvent.Result.KICK_OTHER, "Failed to get shared secret and verify token.");
return;
}
getLogger().info("Starting authentication process...");
String accessToken = authenticateWithMinecraft(event.getUniqueId(), event.getName(), sharedSecret, verifyToken);
if (accessToken != null) {
boolean hasLicense = checkGameOwnership(accessToken);
if (!hasLicense) {
event.disallow(AsyncPlayerPreLoginEvent.Result.KICK_OTHER, "You do not own Minecraft.");
} else {
getLogger().info("Player " + event.getName() + " has a valid license.");
}
} else {
event.disallow(AsyncPlayerPreLoginEvent.Result.KICK_OTHER, "Failed to authenticate with Minecraft.");
}
} catch (Exception e) {
getLogger().severe("An error occurred during authentication: " + e.getMessage());
event.disallow(AsyncPlayerPreLoginEvent.Result.KICK_OTHER, "Authentication error.");
}
});
}
private String authenticateWithMinecraft(UUID playerUUID, String playerName, byte[] sharedSecret, byte[] verifyToken) throws IOException, InterruptedException {
// Заглушка для будущей проверки.
return "access_token";
}
private byte[] generateVerifyToken() {
byte[] token = new byte[4];
random.nextBytes(token);
return token;
}
private boolean checkGameOwnership(String accessToken) throws IOException, InterruptedException {
// Заглушка для будущей проверки.
return true;
}
private byte[] decryptData(byte[] encryptedData) throws Exception {
Cipher cipher = Cipher.getInstance("RSA");
cipher.init(Cipher.DECRYPT_MODE, privateKey);
return cipher.doFinal(encryptedData);
}
private byte[] encryptPrivateKey(byte[] privateKeyBytes, String keyPass) throws Exception {
SecretKeySpec key = new SecretKeySpec(keyPass.getBytes(), "AES");
Cipher cipher = Cipher.getInstance("AES");
cipher.init(Cipher.ENCRYPT_MODE, key);
return cipher.doFinal(privateKeyBytes);
}
private byte[] decryptPrivateKey(byte[] encryptedPrivateKey, String keyPass) throws Exception {
SecretKeySpec key = new SecretKeySpec(keyPass.getBytes(), "AES");
Cipher cipher = Cipher.getInstance("AES");
cipher.init(Cipher.DECRYPT_MODE, key);
return cipher.doFinal(encryptedPrivateKey);
}
}
Заставить клиент войти с врубленным онлайн модом, иначе игра не переключиться в режим енкрипшен.
Я вот не понимаю как это сделать? Саморучно энкрипт пакет кидать?
И насчёт ServerID как его генерировать?
Ответы на эти вопросы есть по ссылкам, которые уже кидал выше. Нужно было лишь чуть копнуть вглубь: https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Protocol_Encryption
Либо саморучно, либо заставить ядро отправить. Но для этого придётся лезть в НМС/рефлексию. В апи Paper этого по-моему, нет. Только на банже и велосити присутствует.
Получается мне нужно залезть в НМС или ядро, найти там то как генерировать айди сервера, и как отправлять пакеты?