listener that updates meta data based on thread status

Author: ankitsmt211

application/src/main/java/org/togetherjava/tjbot/features/Features.java

@@ -125,6 +125,7 @@ public static Collection<Feature> createFeatures(JDA jda, Database database, Con
         features.add(new GuildLeaveCloseThreadListener(config));
         features.add(new LeftoverBookmarksListener(bookmarksSystem));
         features.add(new HelpThreadCreatedListener(helpSystemHelper));
+        features.add(new HelpThreadArchivedListener(helpSystemHelper, database));
 
         // Message context commands
         features.add(new TransferQuestionCommand(config));

application/src/main/java/org/togetherjava/tjbot/features/help/HelpSystemHelper.java

@@ -367,7 +367,7 @@ enum TicketStatus {
         ARCHIVED(0),
         ACTIVE(1);
 
-        private final int val;
+        final int val;
 
         TicketStatus(int val) {
             this.val = val;

application/src/main/java/org/togetherjava/tjbot/features/help/HelpThreadArchivedListener.java

@@ -0,0 +1,80 @@
+package org.togetherjava.tjbot.features.help;
+
+import net.dv8tion.jda.api.entities.channel.concrete.ThreadChannel;
+import net.dv8tion.jda.api.events.channel.update.ChannelUpdateArchivedEvent;
+import net.dv8tion.jda.api.hooks.ListenerAdapter;
+import org.jetbrains.annotations.NotNull;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.togetherjava.tjbot.db.Database;
+import org.togetherjava.tjbot.features.EventReceiver;
+
+import java.time.Instant;
+
+import static org.togetherjava.tjbot.db.generated.tables.HelpThreads.HELP_THREADS;
+
+public final class HelpThreadArchivedListener extends ListenerAdapter implements EventReceiver {
+
+    private final HelpSystemHelper helper;
+    private final Logger logger = LoggerFactory.getLogger(HelpThreadArchivedListener.class);
+    private final Database database;
+
+    /**
+     * Creates a new instance.
+     *
+     * @param helper to work with the help threads
+     */
+    public HelpThreadArchivedListener(HelpSystemHelper helper, Database database) {
+        this.helper = helper;
+        this.database = database;
+    }
+
+    @Override
+    public void onChannelUpdateArchived(@NotNull ChannelUpdateArchivedEvent event) {
+        if (!event.getChannelType().isThread()) {
+            return;
+        }
+        ThreadChannel threadChannel = event.getChannel().asThreadChannel();
+
+
+        if (!helper.isHelpForumName(threadChannel.getParentChannel().getName())) {
+            return;
+        }
+        handleThreadStatus(threadChannel);
+    }
+
+    private void handleThreadStatus(ThreadChannel threadChannel) {
+        long threadId = threadChannel.getIdLong();
+        Instant closedAt = Instant.now();
+
+        int status = database.read(context -> context.selectFrom(HELP_THREADS)
+            .where(HELP_THREADS.CHANNEL_ID.eq(threadId))
+            .fetchOne(HELP_THREADS.TICKET_STATUS));
+
+        if (status == HelpSystemHelper.TicketStatus.ACTIVE.val) {
+            changeStatusToArchive(closedAt, threadId);
+        }
+
+        changeStatusToActive(threadId);
+    }
+
+    private void changeStatusToArchive(Instant closedAt, long threadId) {
+        database.write(context -> context.update(HELP_THREADS)
+            .set(HELP_THREADS.CLOSED_AT, closedAt)
+            .set(HELP_THREADS.TICKET_STATUS, HelpSystemHelper.TicketStatus.ARCHIVED.val)
+            .where(HELP_THREADS.CHANNEL_ID.eq(threadId))
+            .execute());
+
+        logger.info("Thread with id: {}, updated to active in database", threadId);
+    }
+
+    private void changeStatusToActive(long threadId) {
+        database.write(context -> context.update(HELP_THREADS)
+            .set(HELP_THREADS.TICKET_STATUS, HelpSystemHelper.TicketStatus.ACTIVE.val)
+            .where(HELP_THREADS.CHANNEL_ID.eq(threadId))
+            .execute());
+
+        logger.info("Thread with id: {}, updated to archive status in database", threadId);
+    }
+}