Add Discord Integration

build.gradle.kts

@@ -78,6 +78,9 @@ dependencies {
     // vault
     compileOnly("com.github.MilkBowl:VaultAPI:1.7.1")
 
+    // discord integration library
+    paperLibrary("com.discord4j:discord4j-core:3.3.0")
+
     testImplementation("org.junit.jupiter:junit-jupiter-api:6.0.2")
     testImplementation("org.junit.jupiter:junit-jupiter-params:6.0.2")
     testRuntimeOnly("org.junit.jupiter:junit-jupiter-engine:6.0.2")

src/main/java/com/eternalcode/parcellockers/ParcelLockers.java

@@ -16,6 +16,11 @@
 import com.eternalcode.parcellockers.database.DatabaseManager;
 import com.eternalcode.parcellockers.delivery.DeliveryManager;
 import com.eternalcode.parcellockers.delivery.repository.DeliveryRepositoryOrmLite;
+import com.eternalcode.parcellockers.discord.DiscordClientManager;
+import com.eternalcode.parcellockers.discord.command.DiscordLinkCommand;
+import com.eternalcode.parcellockers.discord.command.DiscordUnlinkCommand;
+import com.eternalcode.parcellockers.discord.repository.DiscordLinkRepository;
+import com.eternalcode.parcellockers.discord.repository.DiscordLinkRepositoryOrmLite;
 import com.eternalcode.parcellockers.gui.GuiManager;
 import com.eternalcode.parcellockers.gui.implementation.locker.LockerGui;
 import com.eternalcode.parcellockers.gui.implementation.remote.MainGui;
@@ -72,6 +77,7 @@ public final class ParcelLockers extends JavaPlugin {
     private SkullAPI skullAPI;
     private DatabaseManager databaseManager;
     private Economy economy;
+    private DiscordClientManager discordClientManager;
 
     @Override
     public void onEnable() {
@@ -176,19 +182,51 @@ public void onEnable() {
             this.skullAPI
         );
 
-        this.liteCommands = LiteBukkitFactory.builder(this.getName(), this)
+        var liteCommandsBuilder = LiteBukkitFactory.builder(this.getName(), this)
             .extension(new LiteAdventureExtension<>())
             .message(LiteBukkitMessages.PLAYER_ONLY, messageConfig.playerOnlyCommand)
             .message(LiteBukkitMessages.PLAYER_NOT_FOUND, messageConfig.playerNotFound)
             .commands(LiteCommandsAnnotations.of(
                 new ParcelCommand(mainGUI),
                 new ParcelLockersCommand(configService, config, noticeService),
-                new DebugCommand(parcelService, lockerManager, itemStorageManager, parcelContentManager,
+                new DebugCommand(
+                    parcelService, lockerManager, itemStorageManager, parcelContentManager,
                     noticeService, deliveryManager)
             ))
             .invalidUsage(new InvalidUsageHandlerImpl(noticeService))
-            .missingPermission(new MissingPermissionsHandlerImpl(noticeService))
-            .build();
+            .missingPermission(new MissingPermissionsHandlerImpl(noticeService));
+
+        DiscordLinkRepository discordLinkRepository = new DiscordLinkRepositoryOrmLite(databaseManager, scheduler);
+
+        if (config.discord.enabled) {
+            if (config.discord.botToken.isBlank() ||
+                config.discord.serverId.isBlank() ||
+                config.discord.channelId.isBlank() ||
+                config.discord.botAdminRoleId.isBlank()
+            ) {
+                this.getLogger().severe("Discord integration is enabled but some of the properties are not set! Disabling...");
+                server.getPluginManager().disablePlugin(this);
+                return;
+            }
+
+            this.discordClientManager = new DiscordClientManager(
+                config.discord.botToken,
+                this.getLogger()
+            );
+            this.discordClientManager.initialize();
+
+            liteCommandsBuilder.commands(
+                new DiscordLinkCommand(
+                    this.discordClientManager.getClient(),
+                    discordLinkRepository,
+                    noticeService,
+                    miniMessage,
+                    messageConfig),
+                new DiscordUnlinkCommand(discordLinkRepository, noticeService)
+            );
+        }
+
+        this.liteCommands = liteCommandsBuilder.build();
 
         Stream.of(
             new LockerInteractionController(lockerManager, lockerGUI, scheduler),
@@ -198,8 +236,8 @@ public void onEnable() {
             new LoadUserController(userManager, server)
         ).forEach(controller -> server.getPluginManager().registerEvents(controller, this));
 
-        new Metrics(this, 17677);
-        new UpdaterService(this.getPluginMeta().getVersion());
+        Metrics metrics = new Metrics(this, 17677);
+        UpdaterService updaterService = new UpdaterService(this.getPluginMeta().getVersion());
 
         parcelRepository.findAll().thenAccept(optionalParcels -> optionalParcels
             .stream()
@@ -225,6 +263,10 @@ public void onDisable() {
         if (this.skullAPI != null) {
             this.skullAPI.shutdown();
         }
+
+        if (this.discordClientManager != null) {
+            this.discordClientManager.shutdown();
+        }
     }
 
     private boolean setupEconomy() {

src/main/java/com/eternalcode/parcellockers/configuration/implementation/MessageConfig.java

@@ -37,6 +37,10 @@ public class MessageConfig extends OkaeriConfig {
     @Comment("# These messages are used for administrative actions such as deleting all lockers or parcels.")
     public AdminMessages admin = new AdminMessages();
 
+    @Comment({"", "# Messages related to Discord integration can be configured here." })
+    @Comment("# These messages are used for linking Discord accounts with Minecraft accounts.")
+    public DiscordMessages discord = new DiscordMessages();
+
     public static class ParcelMessages extends OkaeriConfig {
         public Notice sent = Notice.builder()
             .chat("&2✔ &aParcel sent successfully.")
@@ -178,4 +182,79 @@ public static class AdminMessages extends OkaeriConfig {
         public Notice deletedContents = Notice.chat("&4⚠ &cAll ({COUNT}) parcel contents have been deleted!");
         public Notice deletedDeliveries = Notice.chat("&4⚠ &cAll ({COUNT}) deliveries have been deleted!");
     }
+
+    public static class DiscordMessages extends OkaeriConfig {
+        public Notice verificationAlreadyPending = Notice.builder()
+            .chat("&4✘ &cYou already have a pending verification. Please complete it or wait for it to expire.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice alreadyLinked = Notice.builder()
+            .chat("&4✘ &cYour Minecraft account is already linked to a Discord account!")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice discordAlreadyLinked = Notice.builder()
+            .chat("&4✘ &cThis Discord account is already linked to another Minecraft account!")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice userNotFound = Notice.builder()
+            .chat("&4✘ &cCould not find a Discord user with that ID!")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice verificationCodeSent = Notice.builder()
+            .chat("&2✔ &aA verification code has been sent to your Discord DM. Please check your messages.")
+            .sound(SoundEventKeys.ENTITY_EXPERIENCE_ORB_PICKUP)
+            .build();
+        public Notice cannotSendDm = Notice.builder()
+            .chat("&4✘ &cCould not send a DM to your Discord account. Please make sure your DMs are open.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice verificationExpired = Notice.builder()
+            .chat("&4✘ &cYour verification code has expired. Please run the command again.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice invalidCode = Notice.builder()
+            .chat("&4✘ &cInvalid verification code. Please try again in 2 minutes.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice linkSuccess = Notice.builder()
+            .chat("&2✔ &aYour Discord account has been successfully linked!")
+            .sound(SoundEventKeys.ENTITY_PLAYER_LEVELUP)
+            .build();
+        public Notice linkFailed = Notice.builder()
+            .chat("&4✘ &cFailed to link your Discord account. Please try again later.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice verificationCancelled = Notice.builder()
+            .chat("&6⚠ &eVerification cancelled.")
+            .sound(SoundEventKeys.BLOCK_NOTE_BLOCK_BASS)
+            .build();
+        public Notice playerAlreadyLinked = Notice.chat("&4✘ &cThis player already has a linked Discord account!");
+        public Notice adminLinkSuccess = Notice.chat("&2✔ &aSuccessfully linked the Discord account to the player.");
+
+        @Comment({"", "# Unlink messages" })
+        public Notice notLinked = Notice.builder()
+            .chat("&4✘ &cYour Minecraft account is not linked to any Discord account!")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice unlinkSuccess = Notice.builder()
+            .chat("&2✔ &aYour Discord account has been successfully unlinked!")
+            .sound(SoundEventKeys.ENTITY_EXPERIENCE_ORB_PICKUP)
+            .build();
+        public Notice unlinkFailed = Notice.builder()
+            .chat("&4✘ &cFailed to unlink the Discord account. Please try again later.")
+            .sound(SoundEventKeys.ENTITY_VILLAGER_NO)
+            .build();
+        public Notice playerNotLinked = Notice.chat("&4✘ &cThis player does not have a linked Discord account!");
+        public Notice adminUnlinkSuccess = Notice.chat("&2✔ &aSuccessfully unlinked the Discord account from the player.");
+        public Notice discordNotLinked = Notice.chat("&4✘ &cNo Minecraft account is linked to this Discord ID!");
+        public Notice adminUnlinkByDiscordSuccess = Notice.chat("&2✔ &aSuccessfully unlinked the Minecraft account from the Discord ID.");
+
+        @Comment({"", "# Dialog configuration for verification" })
+        public String verificationDialogTitle = "&6Enter your Discord verification code:";
+        public String verificationDialogPlaceholder = "&7Enter 4-digit code";
+
+        @Comment({"", "# The message sent to the Discord user via DM" })
+        @Comment("# Placeholders: {CODE} - the verification code, {PLAYER} - the Minecraft player name")
+        public String discordDmVerificationMessage = "**📦 ParcelLockers Verification**\n\nPlayer **{PLAYER}** is trying to link their Minecraft account to your Discord account.\n\nYour verification code is: **{CODE}**\n\nThis code will expire in 2 minutes.";
+    }
 }

src/main/java/com/eternalcode/parcellockers/configuration/implementation/PluginConfig.java

@@ -24,6 +24,9 @@ public class PluginConfig extends OkaeriConfig {
     @Comment({ "", "# The plugin GUI settings." })
     public GuiSettings guiSettings = new GuiSettings();
 
+    @Comment({ "", "# The plugin Discord integration settings." })
+    public DiscordSettings discord = new DiscordSettings();
+
     public static class Settings extends OkaeriConfig {
 
         @Comment("# Whether the player after entering the server should receive information about the new version of the plugin?")
@@ -357,4 +360,22 @@ public static class GuiSettings extends OkaeriConfig {
         @Comment({ "", "# The lore line showing when the parcel has arrived. Placeholders: {DATE} - arrival date" })
         public String parcelArrivedLine = "&aArrived on: &2{DATE}";
     }
+
+    public static class DiscordSettings extends OkaeriConfig {
+
+        @Comment("# Whether Discord integration is enabled.")
+        public boolean enabled = true;
+
+        @Comment("# The Discord bot token.")
+        public String botToken = System.getenv("DISCORD_BOT_TOKEN");
+
+        @Comment("# The Discord server ID.")
+        public String serverId = "1179117429301977251";
+
+        @Comment("# The Discord channel ID for parcel notifications.")
+        public String channelId = "1317827115147853834";
+
+        @Comment("# The Discord role ID for bot administrators.")
+        public String botAdminRoleId = "1317589501169893427";
+    }
 }

src/main/java/com/eternalcode/parcellockers/discord/DiscordClientManager.java

@@ -0,0 +1,46 @@
+package com.eternalcode.parcellockers.discord;
+
+import discord4j.core.DiscordClient;
+import discord4j.core.GatewayDiscordClient;
+import java.util.logging.Logger;
+import reactor.core.scheduler.Schedulers;
+
+public class DiscordClientManager {
+
+    private final String token;
+    private final Logger logger;
+
+    private GatewayDiscordClient client;
+
+    public DiscordClientManager(String token, Logger logger) {
+        this.token = token;
+        this.logger = logger;
+    }
+
+    public void initialize() {
+        this.logger.info("Discord integration is enabled. Logging in to Discord...");
+        DiscordClient.create(this.token)
+            .login()
+            .subscribeOn(Schedulers.boundedElastic())
+            .doOnSuccess(client -> {
+                this.client = client;
+                this.logger.info("Successfully logged in to Discord.");
+            })
+            .doOnError(error -> {
+                this.logger.severe("Failed to log in to Discord: " + error.getMessage());
+                error.printStackTrace();
+            })
+            .subscribe();
+    }
+
+    public void shutdown() {
+        this.logger.info("Shutting down Discord client...");
+        if (this.client != null) {
+            this.client.logout().block();
+        }
+    }
+
+    public GatewayDiscordClient getClient() {
+        return this.client;
+    }
+}

src/main/java/com/eternalcode/parcellockers/discord/DiscordLink.java

@@ -0,0 +1,6 @@
+package com.eternalcode.parcellockers.discord;
+
+import java.util.UUID;
+
+public record DiscordLink(UUID minecraftUuid, String discordId) {
+}

src/main/java/com/eternalcode/parcellockers/discord/DiscordNotificationType.java

@@ -0,0 +1,7 @@
+package com.eternalcode.parcellockers.discord;
+
+public enum DiscordNotificationType {
+    SERVER,
+    DM,
+    BOTH
+}