Archive threads of forums with no activity in 3 days

Author: Matyrobbrt

src/watcher/java/com/mcmoddev/mmdbot/watcher/TheWatcher.java

@@ -36,6 +36,7 @@
 import com.mcmoddev.mmdbot.core.util.config.ConfigurateUtils;
 import com.mcmoddev.mmdbot.core.util.config.SnowflakeValue;
 import com.mcmoddev.mmdbot.core.util.event.DismissListener;
+import com.mcmoddev.mmdbot.core.util.event.OneTimeEventListener;
 import com.mcmoddev.mmdbot.core.util.event.ThreadedEventListener;
 import com.mcmoddev.mmdbot.watcher.commands.information.InviteCommand;
 import com.mcmoddev.mmdbot.watcher.commands.moderation.BanCommand;
@@ -145,6 +146,8 @@ public Logger getLogger() {
         Executors.newFixedThreadPool(2, r -> com.mcmoddev.mmdbot.core.util.Utils.setThreadDaemon(new Thread(TheWatcher.THREAD_GROUP, r, "PunishableActions"), true))
     );
 
+    public static final OneTimeEventListener<TaskScheduler.CollectTasksEvent> ARCHIVE_FORUM_THREADS = new OneTimeEventListener<>(ForumListener::onCollectTasks);
+
     private static final Set<GatewayIntent> INTENTS = Set.of(
         GatewayIntent.DIRECT_MESSAGES,
         GatewayIntent.GUILD_BANS,
@@ -284,6 +287,8 @@ public void start() {
         MISC_LISTENER.addListener(UpdateRulesCommand::onEvent);
         MISC_LISTENER.addListeners(new EventReactionAdded(), new PersistedRolesEvents(), new ForumListener());
 
+        ARCHIVE_FORUM_THREADS.register(Events.MISC_BUS);
+
         try {
             final var builder = JDABuilder
                 .create(getToken(), INTENTS)

src/watcher/java/com/mcmoddev/mmdbot/watcher/event/ForumListener.java

@@ -20,7 +20,10 @@
  */
 package com.mcmoddev.mmdbot.watcher.event;
 
+import com.mcmoddev.mmdbot.core.util.TaskScheduler;
+import com.mcmoddev.mmdbot.watcher.TheWatcher;
 import net.dv8tion.jda.api.JDA;
+import net.dv8tion.jda.api.entities.Message;
 import net.dv8tion.jda.api.entities.channel.concrete.ThreadChannel;
 import net.dv8tion.jda.api.entities.channel.forums.ForumTag;
 import net.dv8tion.jda.api.entities.emoji.CustomEmoji;
@@ -30,8 +33,12 @@
 import net.dv8tion.jda.api.hooks.ListenerAdapter;
 import org.jetbrains.annotations.NotNull;
 
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Consumer;
 
 public class ForumListener extends ListenerAdapter {
     @Override
@@ -55,6 +62,31 @@ public void onChannelUpdateAppliedTags(@NotNull final ChannelUpdateAppliedTagsEv
         thread.sendMessage(message).queue();
     }
 
+    public static void onCollectTasks(TaskScheduler.CollectTasksEvent event) {
+        event.addTask(() -> {
+            if (TheWatcher.getInstance() == null) return;
+            final Instant _3DaysAgo = Instant.now().minus(3, ChronoUnit.DAYS);
+            TheWatcher.getInstance().getJda().getForumChannelCache()
+                .stream().flatMap(it -> it.getThreadChannels().stream()).forEach(channel -> {
+                final Consumer<Message> lastMessage = (Message last) -> {
+                    if (last.getTimeCreated().toInstant().isBefore(_3DaysAgo)) {
+                        channel.getManager().setArchived(true).reason("3 days without activity").queue();
+                    }
+                };
+                final var his = channel.getHistory().getRetrievedHistory();
+                if (his.isEmpty()) {
+                    channel.getHistory().retrievePast(1).queue(it -> {
+                        if (!it.isEmpty()) {
+                            lastMessage.accept(it.get(0));
+                        }
+                    });
+                } else {
+                    lastMessage.accept(his.get(his.size() - 1));
+                }
+            });
+        }, 1, 24, TimeUnit.HOURS);
+    }
+
     private String formatTags(List<ForumTag> tags, JDA jda) {
         return String.join(", ", tags.stream()
             .map(it -> (it.getEmoji() == null ? "" : format(it.getEmoji(), jda) + " ") + "`" + it.getName() + "`")