Issue 25 help thread system (#28)

* Create AskCommand.java

* Almost done with ask command

* done with the main command

Need to add a command which shows active threads

* Fixed a quick bug

* spotlessApply

* fixed some mistakes

* Create AskCommand.java

* Almost done with ask command

* done with the main command

Need to add a command which shows active threads

* Fixed a quick bug

* spotlessApply

* fixed some mistakes

* save

* need to think about the active question will work

* Finished with ask command

* Got some issue but system overall working

* channel is removed when archived

* Almost done

* pretty much finished

* some minor fixess

* edit system sill broken

* edit command works now

* made requested changes

Co-authored-by: Haleloch <[email protected]>

Author: RealYusufIsmail

.github/PULL_REQUEST_TEMPLATE.md

@@ -17,7 +17,7 @@ It helps make it maintainable for us, and will save you from possibly recoding e
 If there's no relating issue, keep it NaN
 -->
 
-Closes Issue: NaN
+Closes : NaN
 
 ## Description
 

README.md

@@ -45,6 +45,12 @@ DB_PASSWORD=
 DB_URL=
 PORT_NUMBER=
 SERVER_NAME=
+//used for creating questions
+HELP_CHANNEL_ID=
+//Used to post the thread channels which are open
+ACTIVE_QUESTION_CHANNEL_ID=
+//the max amount of help threads that can be created in a day, default is 2
+ASK_LIMIT=
 ```
 
 ### Part 3

src/main/java/io/github/org/programming/backend/handler/BaseHandler.java

@@ -30,9 +30,9 @@ public abstract class BaseHandler extends ListenerAdapter {
     protected abstract long botOwnerId();
 
 
-    public static void checkIfBuildIsNull(Object build) {
+    public static void checkIfBuildIsNull(Object build, String className) {
         if (Objects.isNull(build)) {
-            throw new IllegalArgumentException("Build is null");
+            throw new IllegalArgumentException("Build is null for class: " + className);
         }
     }
 }

src/main/java/io/github/org/programming/backend/handler/MessageCommandHandler.java

@@ -69,7 +69,7 @@ protected MessageCommandHandler(@NotNull JDA jda, @NotNull Guild guild) {
     @SuppressWarnings("ResultOfMethodCallIgnored")
     private void addMessageCommand(@NotNull MessageCommandExtender command) {
 
-        BaseHandler.checkIfBuildIsNull(command.build());
+        BaseHandler.checkIfBuildIsNull(command.build(), command.getClass().getSimpleName());
 
         messageCommand.put(command.build().getCommandData().getName(), command);
         if (command.build().isGuildOnly()) {

src/main/java/io/github/org/programming/backend/handler/SlashCommandHandler.java

@@ -90,8 +90,7 @@ protected SlashCommandHandler(@NotNull JDA jda, @NotNull Guild guild) {
      */
     @SuppressWarnings("ResultOfMethodCallIgnored")
     private void addSlashCommand(@NotNull SlashCommandExtender command) {
-
-        BaseHandler.checkIfBuildIsNull(command.build());
+        BaseHandler.checkIfBuildIsNull(command.build(), command.getClass().getSimpleName());
 
         slashCommand.put(command.build().getSlashCommandData().getName(), command);
         if (command.build().isGuildOnly()) {

src/main/java/io/github/org/programming/backend/handler/UserCommandHandler.java

@@ -70,7 +70,7 @@ protected UserCommandHandler(@NotNull JDA jda, @NotNull Guild guild) {
     @SuppressWarnings("ResultOfMethodCallIgnored")
     private void addUserCommand(@NotNull UserCommandExtender command) {
 
-        BaseHandler.checkIfBuildIsNull(command.build());
+        BaseHandler.checkIfBuildIsNull(command.build(), command.getClass().getSimpleName());
 
         userCommand.put(command.build().getCommandData().getName(), command);
         if (command.build().isGuildOnly()) {

src/main/java/io/github/org/programming/bot/ProgrammingBot.java

@@ -18,28 +18,36 @@
  */ 
 package io.github.org.programming.bot;
 
+import io.github.org.programming.bot.commands.thread.ActiveQuestionsHandler;
+import io.github.org.programming.bot.commands.thread.AskThreadStatus;
 import io.github.org.programming.bot.config.BotConfig;
 import io.github.org.programming.database.Database;
 import net.dv8tion.jda.api.JDA;
 import net.dv8tion.jda.api.JDABuilder;
 import net.dv8tion.jda.api.OnlineStatus;
-import net.dv8tion.jda.api.entities.Activity;
-import net.dv8tion.jda.api.entities.Guild;
-import net.dv8tion.jda.api.events.ReadyEvent;
+import net.dv8tion.jda.api.entities.*;
 import net.dv8tion.jda.api.hooks.ListenerAdapter;
 import net.dv8tion.jda.api.requests.GatewayIntent;
-import net.dv8tion.jda.api.utils.MemberCachePolicy;
+import net.dv8tion.jda.api.requests.restaction.pagination.ThreadChannelPaginationAction;
 import net.dv8tion.jda.api.utils.cache.CacheFlag;
-import org.jetbrains.annotations.NotNull;
 import org.jooq.DSLContext;
 import org.jooq.SQLDialect;
 import org.jooq.impl.DSL;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.time.Instant;
+import java.util.List;
+import java.util.Objects;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+import static io.github.org.programming.bot.commands.thread.ActiveQuestionsHandler.*;
+import static io.github.org.programming.bot.commands.thread.util.SupportedCategories.messageToSend;
+import static io.github.org.programming.database.thread.AskDatabase.deleteAskDatabaseWithTime;
+import static io.github.org.programming.database.thread.AskDatabase.getAskTimeStamps;
 
 public class ProgrammingBot extends ListenerAdapter {
     private final Logger logger = LoggerFactory.getLogger(ProgrammingBot.class);
@@ -67,20 +75,63 @@ public ProgrammingBot(String[] args) throws Exception {
 
         Guild guild = jda.awaitReady().getGuildById(BotConfig.getGuildId());
 
-        jda.awaitReady().addEventListener(new SlashCommandReg(jda, guild), this);
+        jda.awaitReady().addEventListener(new RegisterSlashCommands(jda, guild), this);
 
         logger.info("Bot is ready in guild {}", guild.getName());
 
-        if (Database.isConnected())
-            logger.info("Database is connected");
-        else
-            logger.error("Database is not connected");
+        scheduledExecutor.scheduleAtFixedRate(() -> {
+            checkIfAskActiveQuestionMessageExists(guild);
+        }, 0, 1, TimeUnit.DAYS);
+
+        // need to check this every minute
+        scheduledExecutor.scheduleAtFixedRate(() -> {
+            checkIfAskThreadTimeNeedsToBeRest(jda);
+        }, 0, 1, TimeUnit.SECONDS);
+
+        scheduledExecutor.scheduleAtFixedRate(() -> {
+            checkIfAskHelpThreadArchived(guild);
+        }, 0, 1, TimeUnit.SECONDS);
+    }
+
+    public synchronized void checkIfAskActiveQuestionMessageExists(Guild guild) {
+        TextChannel activeQuestionsChannel =
+                guild.getTextChannelById(BotConfig.getActiveQuestionChannelId());
+
+        if (activeQuestionsChannel == null) {
+            throw new IllegalStateException("Active questions channel not found");
+        }
+
+        String messageId = getActiveQuestionMessage(guild.getId());
+
+        if (messageId == null) {
+            Message message = activeQuestionsChannel.sendMessage(messageToSend()).complete();
+            updateActiveQuestionMessage(guild.getId(), message.getId());
+            ActiveQuestionsHandler.setMessage(message);
+        } else {
+            activeQuestionsChannel.retrieveMessageById(messageId)
+                .queue(this::dealWithSuccess,
+                        e -> dealWithError(e, guild, messageId, activeQuestionsChannel));
+        }
+    }
+
+    private void dealWithError(Throwable error, Guild guild, String messageId,
+            TextChannel activeQuestionsChannel) {
+        if (Objects.equals(error.getMessage(), "10008: Unknown Message")) {
+            deleteActiveQuestionMessageId(guild.getId(), messageId);
+            activeQuestionsChannel.sendMessage(messageToSend()).queue(success -> {
+                updateActiveQuestionMessage(guild.getId(), success.getId());
+                ActiveQuestionsHandler.setMessage(success);
+            });
+        }
+    }
+
+    private void dealWithSuccess(Message message) {
+        ActiveQuestionsHandler.setMessage(message);
     }
 
     public void onDatabase() {
         context = DSL.using(Database.getConnection(), SQLDialect.POSTGRES);
 
-
         if (Database.isConnected()) {
             logger.info("Connected to database");
         } else {
@@ -95,10 +146,40 @@ public void onDatabase() {
                 logger.error("Failed to close database", e);
             }
         }));
-
     }
 
     public static DSLContext getContext() {
         return context;
     }
+
+    public synchronized void checkIfAskThreadTimeNeedsToBeRest(JDA jda) {
+        jda.getGuilds().forEach(c -> {
+            List<Instant> oldTimeInstant = getAskTimeStamps(c.getId());
+            // need to check if between 24 hours since last time asked
+            oldTimeInstant.forEach(i -> {
+                if (i.isAfter(Instant.now().minusSeconds(86400))) {
+                    deleteAskDatabaseWithTime(i, c.getId());
+                }
+            });
+        });
+    }
+
+    public synchronized void checkIfAskHelpThreadArchived(Guild guild) {
+        TextChannel channel = guild.getTextChannelById(BotConfig.getActiveQuestionChannelId());
+        ThreadChannelPaginationAction threadChannelPaginationAction =
+                channel != null ? channel.retrieveArchivedPublicThreadChannels() : null;
+
+        if (threadChannelPaginationAction == null) {
+            logger.debug("No archived thread channels found");
+            return;
+        }
+
+        List<ThreadChannel> archivedThreadChannels = threadChannelPaginationAction.complete();
+
+        for (ThreadChannel c : archivedThreadChannels) {
+            String name = c.getName();
+            String category = name.substring(1, name.indexOf("]")).toLowerCase();
+            updateActiveQuestions(c, AskThreadStatus.CLOSED, category);
+        }
+    }
 }

src/main/java/io/github/org/programming/bot/SlashCommandReg.java renamed to src/main/java/io/github/org/programming/bot/RegisterSlashCommands.java

@@ -24,6 +24,9 @@
 import io.github.org.programming.bot.commands.moderation.BanCommand;
 import io.github.org.programming.bot.commands.moderation.KickCommand;
 import io.github.org.programming.bot.commands.moderation.UnBanCommand;
+import io.github.org.programming.bot.commands.thread.AskCommand;
+import io.github.org.programming.bot.commands.thread.CloseAskThread;
+import io.github.org.programming.bot.commands.thread.EditAskThread;
 import io.github.org.programming.bot.config.BotConfig;
 import net.dv8tion.jda.api.JDA;
 import net.dv8tion.jda.api.entities.Guild;
@@ -33,8 +36,8 @@
 import java.util.List;
 
 
-public class SlashCommandReg extends SlashCommandHandler {
-    protected SlashCommandReg(@NotNull JDA jda, @NotNull Guild guild) {
+public class RegisterSlashCommands extends SlashCommandHandler {
+    protected RegisterSlashCommands(@NotNull JDA jda, @NotNull Guild guild) {
         super(jda, guild);
 
         List<SlashCommandExtender> extenders = new ArrayList<>();
@@ -43,6 +46,9 @@ protected SlashCommandReg(@NotNull JDA jda, @NotNull Guild guild) {
         extenders.add(new KickCommand());
         extenders.add(new BanCommand());
         extenders.add(new UnBanCommand());
+        extenders.add(new AskCommand());
+        extenders.add(new CloseAskThread());
+        extenders.add(new EditAskThread());
 
         queueAndRegisterSlashCommands(extenders);
     }

src/main/java/io/github/org/programming/bot/commands/moderation/UnBanCommand.java

@@ -19,40 +19,44 @@
 package io.github.org.programming.bot.commands.moderation;
 
 import io.github.org.programming.backend.builder.slash.SlashCommand;
+import io.github.org.programming.backend.builder.slash.SlashCommandBuilder;
 import io.github.org.programming.backend.extension.SlashCommandExtender;
 import io.github.org.programming.bot.config.BotConfig;
 import io.github.org.programming.database.moderation.ModerationDatabase;
 import net.dv8tion.jda.api.EmbedBuilder;
+import net.dv8tion.jda.api.Permission;
 import net.dv8tion.jda.api.entities.Member;
 import net.dv8tion.jda.api.entities.MessageEmbed;
 import net.dv8tion.jda.api.entities.TextChannel;
+import net.dv8tion.jda.api.entities.User;
 import net.dv8tion.jda.api.events.interaction.command.SlashCommandInteractionEvent;
 import net.dv8tion.jda.api.interactions.commands.OptionMapping;
+import net.dv8tion.jda.api.interactions.commands.OptionType;
 import org.jetbrains.annotations.NotNull;
 
 
 public class UnBanCommand implements SlashCommandExtender {
     @Override
     public void onSlashCommandInteraction(@NotNull SlashCommandInteractionEvent event) {
-        Member member = event.getOption("member", OptionMapping::getAsMember);
+        User user = event.getOption("member", OptionMapping::getAsUser);
         Member moderator = event.getMember();
         String reason = event.getOption("reason", OptionMapping::getAsString);
 
-        int id = ModerationDatabase.updateModerationDataBase(event.getGuild().getId(),
-                member.getId(), moderator.getId(), reason, "unban");
+        int id = ModerationDatabase.updateModerationDataBase(event.getGuild().getId(), user.getId(),
+                moderator.getId(), reason, "unban");
 
         event.getGuild()
-            .unban(member.getUser())
+            .unban(user)
             .flatMap(channel -> event.getGuild()
                 .getChannelById(TextChannel.class, BotConfig.getAuditLogChannelId())
-                .sendMessageEmbeds(unbanEmbed(member, moderator, reason, id)))
-            .flatMap(message -> event.reply("Unbanned " + member.getAsMention() + " for " + reason))
+                .sendMessageEmbeds(unbanEmbed(user, moderator, reason, id)))
+            .flatMap(message -> event.reply("Unbanned " + user.getAsMention() + " for " + reason))
             .queue();
 
     }
 
-    private MessageEmbed unbanEmbed(Member member, @NotNull Member moderator,
-            @NotNull String reason, int caseId) {
+    private MessageEmbed unbanEmbed(User member, @NotNull Member moderator, @NotNull String reason,
+            int caseId) {
         return new EmbedBuilder()
             .setTitle("The member + " + member.getAsMention() + " has been unbanned")
             .setDescription("The member has been unbanned by " + moderator.getAsMention() + " for "
@@ -65,6 +69,11 @@ private MessageEmbed unbanEmbed(Member member, @NotNull Member moderator,
 
     @Override
     public SlashCommand build() {
-        return null;
+        return new SlashCommandBuilder("unban", "The user to unban")
+            .addOption(OptionType.USER, "member", "The user to unban", true)
+            .addOption(OptionType.STRING, "reason", "The reason for the unban", true)
+            .build()
+            .setBotPerms(Permission.BAN_MEMBERS)
+            .setUserPerms(Permission.BAN_MEMBERS);
     }
 }