GH-75 Add Discord Integration

build.gradle.kts

@@ -19,6 +19,7 @@ repositories {
     maven("https://repo.papermc.io/repository/maven-public/")
     maven("https://repo.eternalcode.pl/releases")
     maven("https://storehouse.okaeri.eu/repository/maven-public/")
+    maven("https://nexus.scarsz.me/content/groups/public/") // DiscordSRV
 }
 
 dependencies {
@@ -78,6 +79,12 @@ dependencies {
     // vault
     compileOnly("com.github.MilkBowl:VaultAPI:1.7.1")
 
+    // discord integration library
+    paperLibrary("com.discord4j:discord4j-core:3.3.0")
+
+    // discordsrv (optional integration)
+    compileOnly("com.discordsrv:discordsrv:1.30.4")
+
     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")
@@ -108,6 +115,10 @@ paper {
             required = true
             load = PaperPluginDescription.RelativeLoadOrder.BEFORE
         }
+        register("DiscordSRV") {
+            required = false
+            load = PaperPluginDescription.RelativeLoadOrder.BEFORE
+        }
     }
 }
 
@@ -124,6 +135,7 @@ tasks {
         downloadPlugins.modrinth("luckperms", "v5.5.17-bukkit")
         downloadPlugins.modrinth("vaultunlocked", "2.17.0")
         downloadPlugins.modrinth("essentialsx", "2.21.2")
+        downloadPlugins.modrinth("discordsrv", "1.30.4")
     }
 
     test {

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

@@ -10,12 +10,30 @@
 import com.eternalcode.parcellockers.configuration.ConfigService;
 import com.eternalcode.parcellockers.configuration.implementation.MessageConfig;
 import com.eternalcode.parcellockers.configuration.implementation.PluginConfig;
+import com.eternalcode.parcellockers.configuration.implementation.PluginConfig.DiscordSettings;
 import com.eternalcode.parcellockers.content.ParcelContentManager;
 import com.eternalcode.parcellockers.content.repository.ParcelContentRepository;
 import com.eternalcode.parcellockers.content.repository.ParcelContentRepositoryOrmLite;
 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.DiscordFallbackLinkService;
+import com.eternalcode.parcellockers.discord.DiscordLinkService;
+import com.eternalcode.parcellockers.discord.DiscordSrvLinkService;
+import com.eternalcode.parcellockers.discord.argument.SnowflakeArgument;
+import com.eternalcode.parcellockers.discord.command.DiscordLinkCommand;
+import com.eternalcode.parcellockers.discord.command.DiscordSrvLinkCommand;
+import com.eternalcode.parcellockers.discord.command.DiscordSrvUnlinkCommand;
+import com.eternalcode.parcellockers.discord.command.DiscordUnlinkCommand;
+import com.eternalcode.parcellockers.discord.controller.DiscordDeliverNotificationController;
+import com.eternalcode.parcellockers.discord.notification.Discord4JNotificationService;
+import com.eternalcode.parcellockers.discord.notification.DiscordNotificationService;
+import com.eternalcode.parcellockers.discord.notification.DiscordSrvNotificationService;
+import com.eternalcode.parcellockers.discord.repository.DiscordLinkRepository;
+import com.eternalcode.parcellockers.discord.repository.DiscordLinkRepositoryOrmLite;
+import com.eternalcode.parcellockers.discord.verification.DiscordLinkValidationService;
+import com.eternalcode.parcellockers.discord.verification.DiscordVerificationService;
 import com.eternalcode.parcellockers.gui.GuiManager;
 import com.eternalcode.parcellockers.gui.implementation.locker.LockerGui;
 import com.eternalcode.parcellockers.gui.implementation.remote.MainGui;
@@ -54,6 +72,7 @@
 import dev.rollczi.liteskullapi.LiteSkullFactory;
 import dev.rollczi.liteskullapi.SkullAPI;
 import dev.triumphteam.gui.TriumphGui;
+import discord4j.common.util.Snowflake;
 import java.io.File;
 import java.sql.SQLException;
 import java.time.Duration;
@@ -72,6 +91,7 @@ public final class ParcelLockers extends JavaPlugin {
     private SkullAPI skullAPI;
     private DatabaseManager databaseManager;
     private Economy economy;
+    private DiscordClientManager discordClientManager;
 
     @Override
     public void onEnable() {
@@ -82,7 +102,8 @@ public void onEnable() {
 
         ConfigService configService = new ConfigService();
         PluginConfig config = configService.create(PluginConfig.class, new File(this.getDataFolder(), "config.yml"));
-        MessageConfig messageConfig = configService.create(MessageConfig.class, new File(this.getDataFolder(), "messages.yml"));
+        MessageConfig messageConfig =
+            configService.create(MessageConfig.class, new File(this.getDataFolder(), "messages.yml"));
         Server server = this.getServer();
         NoticeService noticeService = new NoticeService(messageConfig, miniMessage);
         Scheduler scheduler = new BukkitSchedulerImpl(this);
@@ -113,7 +134,8 @@ public void onEnable() {
         // database repositories
         ParcelRepositoryOrmLite parcelRepository = new ParcelRepositoryOrmLite(databaseManager, scheduler);
         LockerRepositoryOrmLite lockerRepository = new LockerRepositoryOrmLite(databaseManager, scheduler);
-        ParcelContentRepository parcelContentRepository = new ParcelContentRepositoryOrmLite(databaseManager, scheduler);
+        ParcelContentRepository parcelContentRepository =
+            new ParcelContentRepositoryOrmLite(databaseManager, scheduler);
         DeliveryRepositoryOrmLite deliveryRepository = new DeliveryRepositoryOrmLite(databaseManager, scheduler);
         ItemStorageRepository itemStorageRepository = new ItemStorageRepositoryOrmLite(databaseManager, scheduler);
         UserRepository userRepository = new UserRepositoryOrmLite(databaseManager, scheduler);
@@ -132,7 +154,8 @@ public void onEnable() {
         UserValidationService userValidationService = new UserValidator();
         UserManager userManager = new UserManagerImpl(userRepository, userValidationService, server);
         LockerValidationService lockerValidationService = new LockerValidator();
-        LockerManager lockerManager = new LockerManager(config, lockerRepository, lockerValidationService, parcelRepository, server);
+        LockerManager lockerManager =
+            new LockerManager(config, lockerRepository, lockerValidationService, parcelRepository, server);
         ParcelContentManager parcelContentManager = new ParcelContentManager(parcelContentRepository);
         ItemStorageManager itemStorageManager = new ItemStorageManager(itemStorageRepository, server);
         DeliveryManager deliveryManager = new DeliveryManager(deliveryRepository);
@@ -175,19 +198,92 @@ public void onEnable() {
             this.skullAPI
         );
 
-        this.liteCommands = LiteBukkitFactory.builder(this.getName(), this)
+        var liteCommandsBuilder = LiteBukkitFactory.builder(this.getName(), this)
             .extension(new LiteAdventureExtension<>())
+            .argument(Snowflake.class, new SnowflakeArgument())
             .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));
+
+        DiscordSettings discordSettings = config.discord;
+        if (discordSettings.enabled) {
+            DiscordNotificationService notificationService;
+            DiscordLinkService activeLinkService;
+
+            if (server.getPluginManager().isPluginEnabled("DiscordSRV")) {
+                this.getLogger().info("DiscordSRV detected! Using DiscordSRV for account linking.");
+                DiscordSrvLinkService discordSrvLinkService = new DiscordSrvLinkService(this.getLogger());
+                activeLinkService = discordSrvLinkService;
+                notificationService = new DiscordSrvNotificationService(this.getLogger());
+
+                liteCommandsBuilder.commands(
+                    new DiscordSrvLinkCommand(discordSrvLinkService, noticeService),
+                    new DiscordSrvUnlinkCommand(discordSrvLinkService, noticeService)
+                );
+            } else {
+                if (config.discord.botToken == null || config.discord.botToken.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(
+                    discordSettings.botToken,
+                    this.getLogger()
+                );
+                this.discordClientManager.initialize();
+
+                DiscordLinkRepository discordLinkRepository =
+                    new DiscordLinkRepositoryOrmLite(databaseManager, scheduler);
+                activeLinkService = new DiscordFallbackLinkService(discordLinkRepository);
+                notificationService = new Discord4JNotificationService(
+                    this.discordClientManager.getClient(),
+                    this.getLogger()
+                );
+
+                DiscordLinkValidationService validationService = new DiscordLinkValidationService(
+                    activeLinkService,
+                    this.discordClientManager.getClient()
+                );
+
+                DiscordVerificationService verificationService = DiscordVerificationService.create(
+                    activeLinkService,
+                    noticeService,
+                    messageConfig,
+                    miniMessage
+                );
+
+                liteCommandsBuilder.commands(
+                    new DiscordLinkCommand(
+                        activeLinkService,
+                        validationService,
+                        verificationService,
+                        noticeService),
+                    new DiscordUnlinkCommand(activeLinkService, noticeService)
+                );
+            }
+
+            server.getPluginManager().registerEvents(
+                new DiscordDeliverNotificationController(
+                    notificationService,
+                    activeLinkService,
+                    userManager,
+                    messageConfig
+                ),
+                this
+            );
+        }
+
+        this.liteCommands = liteCommandsBuilder.build();
 
         Stream.of(
             new LockerInteractionController(lockerManager, lockerGUI, scheduler),
@@ -197,16 +293,18 @@ 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()
             .filter(parcel -> parcel.status() != ParcelStatus.DELIVERED)
             .forEach(parcel -> deliveryRepository.find(parcel.uuid()).thenAccept(optionalDelivery ->
                 optionalDelivery.ifPresent(delivery -> {
                     long delay = Math.max(0, delivery.deliveryTimestamp().toEpochMilli() - System.currentTimeMillis());
-                    scheduler.runLaterAsync(new ParcelSendTask(parcel, parcelService, deliveryManager), Duration.ofMillis(delay));
+                    scheduler.runLaterAsync(
+                        new ParcelSendTask(parcel, parcelService, deliveryManager),
+                        Duration.ofMillis(delay));
                 })
             )));
     }
@@ -224,6 +322,10 @@ public void onDisable() {
         if (this.skullAPI != null) {
             this.skullAPI.shutdown();
         }
+
+        if (this.discordClientManager != null) {
+            this.discordClientManager.shutdown();
+        }
     }
 
     private boolean setupEconomy() {