[AB-xxx] refactoring to use a separate updated column for the auto closing

wrapping modmail thread actions into a separate transaction

.env

@@ -1,2 +1,2 @@
 REGISTRY_PREFIX=harbor.sheldan.dev/abstracto/
-VERSION=1.6.18
+VERSION=1.6.22

abstracto-application/abstracto-modules/anti-raid/anti-raid-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>anti-raid</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/anti-raid/anti-raid-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>anti-raid</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/anti-raid/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/assignable-roles/assignable-roles-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>assignable-roles</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/assignable-roles/assignable-roles-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>assignable-roles</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>assignable-roles-int</artifactId>

abstracto-application/abstracto-modules/assignable-roles/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/custom-command/custom-command-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>custom-command</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/custom-command/custom-command-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>custom-command</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/custom-command/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/dynamic-activity/dynamic-activity-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>dynamic-activity</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/dynamic-activity/dynamic-activity-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>dynamic-activity</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/dynamic-activity/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/entertainment/entertainment-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>entertainment</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/entertainment/entertainment-impl/src/main/java/dev/sheldan/abstracto/entertainment/command/economy/TransferCredits.java

@@ -74,7 +74,6 @@ public class TransferCredits extends AbstractConditionableCommand {
                 .name(MEMBER_PARAMETER)
                 .templated(true)
                 .type(Member.class)
-                .optional(true)
                 .build();
 
         Parameter amountParameter = Parameter
@@ -82,7 +81,6 @@ public class TransferCredits extends AbstractConditionableCommand {
                 .name(AMOUNT_PARAMETER)
                 .templated(true)
                 .type(Integer.class)
-                .optional(true)
                 .build();
 
         List<Parameter> parameters = Arrays.asList(memberParameter, amountParameter);

abstracto-application/abstracto-modules/entertainment/entertainment-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>entertainment</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/entertainment/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>experience-tracking</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/main/java/dev/sheldan/abstracto/experience/service/AUserExperienceServiceBean.java

@@ -313,107 +313,107 @@ public class AUserExperienceServiceBean implements AUserExperienceService {
         Long userInServerId = userInAServer.getUserInServerId();
         Optional<AUserExperience> aUserExperienceOptional = userExperienceManagementService.findByUserInServerIdOptional(userInAServer.getUserInServerId());
         AUserExperience aUserExperience = aUserExperienceOptional.orElseGet(() -> userExperienceManagementService.createUserInServer(userInAServer));
-        if(Boolean.FALSE.equals(aUserExperience.getExperienceGainDisabled())) {
-            List<AExperienceLevel> levels = experienceLevelManagementService.getLevelConfig();
-            levels.sort(Comparator.comparing(AExperienceLevel::getExperienceNeeded));
-
-            Long minExp = configService.getLongValueOrConfigDefault(ExperienceFeatureConfig.MIN_EXP_KEY, serverId);
-            Long maxExp = configService.getLongValueOrConfigDefault(ExperienceFeatureConfig.MAX_EXP_KEY, serverId);
-            Double multiplier = configService.getDoubleValueOrConfigDefault(ExperienceFeatureConfig.EXP_MULTIPLIER_KEY, serverId);
-            Long experienceRange = maxExp - minExp + 1;
-            Long gainedExperience = (secureRandom.nextInt(experienceRange.intValue()) + minExp);
-            gainedExperience = (long) Math.floor(gainedExperience * multiplier);
-
-            List<AExperienceRole> roles = experienceRoleManagementService.getExperienceRolesForServer(server);
-            roles.sort(Comparator.comparing(role -> role.getLevel().getLevel()));
-
-            log.debug("Handling {}. The user gains {}.", userInServerId, gainedExperience);
-
-            Long oldExperience = aUserExperience.getExperience();
-            Long newExperienceCount = oldExperience + gainedExperience;
-            aUserExperience.setExperience(newExperienceCount);
-            AExperienceLevel newLevel = calculateLevel(levels, newExperienceCount);
-            RoleCalculationResult result = RoleCalculationResult
-                    .builder()
-                    .build();
-            boolean userChangesLevel = !Objects.equals(newLevel.getLevel(), aUserExperience.getCurrentLevel().getLevel());
-            Integer oldLevel = aUserExperience.getCurrentLevel() != null ? aUserExperience.getCurrentLevel().getLevel() : 0;
-            if(userChangesLevel) {
-                log.info("User {} in server {} changed level. New {}, Old {}.", member.getIdLong(),
-                        member.getGuild().getIdLong(), newLevel.getLevel(),
-                        oldLevel);
-                aUserExperience.setCurrentLevel(newLevel);
-                AExperienceRole calculatedNewRole = experienceRoleService.calculateRole(roles, newLevel.getLevel());
-                Long oldRoleId = aUserExperience.getCurrentExperienceRole() != null && aUserExperience.getCurrentExperienceRole().getRole() != null ? aUserExperience.getCurrentExperienceRole().getRole().getId() : null;
-                Long newRoleId = calculatedNewRole != null && calculatedNewRole.getRole() != null ? calculatedNewRole.getRole().getId() : null;
-                result.setOldRoleId(oldRoleId);
-                result.setNewRoleId(newRoleId);
-                if(message != null
-                        && aUserExperience.getLevelUpNotification()
-                        && featureModeService.featureModeActive(ExperienceFeatureDefinition.EXPERIENCE, serverId, ExperienceFeatureMode.LEVEL_UP_NOTIFICATION)) {
-                    LevelUpNotificationModel model = LevelUpNotificationModel
-                            .builder()
-                            .memberDisplay(MemberDisplay.fromMember(member))
-                            .oldExperience(oldExperience)
-                            .newExperience(newExperienceCount)
-                            .newLevel(newLevel.getLevel())
-                            .oldLevel(oldLevel)
-                            .newRole(oldRoleId != null ? RoleDisplay.fromRole(oldRoleId) : null)
-                            .newRole(newRoleId != null ? RoleDisplay.fromRole(newRoleId) : null)
-                            .build();
-                    MessageToSend messageToSend = templateService.renderEmbedTemplate("experience_level_up_notification", model, serverId);
-                    FutureUtils.toSingleFutureGeneric(channelService.sendMessageToSendToChannel(messageToSend, message.getChannel())).thenAccept(unused -> {
-                        log.info("Sent level up notification to user {} in server {} in channel {}.", member.getIdLong(), serverId, message.getChannel().getIdLong());
-                    }).exceptionally(throwable -> {
-                        log.warn("Failed to send level up notification to user {} in server {} in channel {}.", member.getIdLong(), serverId, message.getChannel().getIdLong());
-                        return null;
-                    });
-                }
-                aUserExperience.setCurrentExperienceRole(calculatedNewRole);
-            }
-            aUserExperience.setMessageCount(aUserExperience.getMessageCount() + 1L);
-            if(userChangesLevel && featureModeService.featureModeActive(ExperienceFeatureDefinition.EXPERIENCE, server, ExperienceFeatureMode.LEVEL_ACTION)) {
-                levelActionService.applyLevelActionsToUser(aUserExperience, oldLevel)
-                    .thenAccept(unused -> {
-                        log.info("Executed level actions for user {}.", userInServerId);
-                    })
-                    .exceptionally(throwable -> {
-                        log.warn("Failed to execute level actions for user {}.", userInServerId, throwable);
-                        return null;
-                    });
-            }
-            if(aUserExperienceOptional.isEmpty()) {
-                userExperienceManagementService.saveUser(aUserExperience);
-            }
-            if(!Objects.equals(result.getOldRoleId(), result.getNewRoleId())) {
-                if(result.getOldRoleId() != null && result.getNewRoleId() != null) {
-                    roleService.updateRolesIds(member, Arrays.asList(result.getOldRoleId()), Arrays.asList(result.getNewRoleId())).thenAccept(unused -> {
-                        log.debug("Removed role {} from and added role {} to member {} in server {}.", result.getOldRoleId(), result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong());
-                    }).exceptionally(throwable -> {
-                        log.warn("Failed to remove role {} from and add role {} to  member {} in server {}.", result.getOldRoleId(), result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
-                        return null;
-                    });
-                } else {
-                    if(result.getOldRoleId() != null) {
-                        roleService.removeRoleFromMemberAsync(member, result.getOldRoleId()).thenAccept(unused -> {
-                            log.debug("Removed role {} from member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong());
-                        }).exceptionally(throwable -> {
-                            log.warn("Failed to remove role {} from member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
-                            return null;
-                        });
-                    }
-                    if(result.getNewRoleId() != null) {
-                        roleService.addRoleToMemberAsync(member, result.getNewRoleId()).thenAccept(unused -> {
-                            log.debug("Added role {} to member {} in server {}.", result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong());
-                        }).exceptionally(throwable -> {
-                            log.warn("Failed to add role {} to member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
-                            return null;
-                        });
-                    }
-                }
-            }
-        } else {
+        if (aUserExperience.getExperienceGainDisabled().equals(Boolean.TRUE)) {
             log.debug("Experience gain was disabled. User did not gain any experience.");
+            return;
+        }
+        List<AExperienceLevel> levels = experienceLevelManagementService.getLevelConfig();
+        levels.sort(Comparator.comparing(AExperienceLevel::getExperienceNeeded));
+
+        Long minExp = configService.getLongValueOrConfigDefault(ExperienceFeatureConfig.MIN_EXP_KEY, serverId);
+        Long maxExp = configService.getLongValueOrConfigDefault(ExperienceFeatureConfig.MAX_EXP_KEY, serverId);
+        Double multiplier = configService.getDoubleValueOrConfigDefault(ExperienceFeatureConfig.EXP_MULTIPLIER_KEY, serverId);
+        Long experienceRange = maxExp - minExp + 1;
+        Long gainedExperience = (secureRandom.nextInt(experienceRange.intValue()) + minExp);
+        gainedExperience = (long) Math.floor(gainedExperience * multiplier);
+
+        List<AExperienceRole> roles = experienceRoleManagementService.getExperienceRolesForServer(server);
+        roles.sort(Comparator.comparing(role -> role.getLevel().getLevel()));
+
+        log.debug("Handling {}. The user gains {}.", userInServerId, gainedExperience);
+
+        Long oldExperience = aUserExperience.getExperience();
+        Long newExperienceCount = oldExperience + gainedExperience;
+        aUserExperience.setExperience(newExperienceCount);
+        AExperienceLevel newLevel = calculateLevel(levels, newExperienceCount);
+        RoleCalculationResult result = RoleCalculationResult
+                .builder()
+                .build();
+        boolean userChangesLevel = !Objects.equals(newLevel.getLevel(), aUserExperience.getCurrentLevel().getLevel());
+        Integer oldLevel = aUserExperience.getCurrentLevel() != null ? aUserExperience.getCurrentLevel().getLevel() : 0;
+        if(userChangesLevel) {
+            log.info("User {} in server {} changed level. New {}, Old {}.", member.getIdLong(),
+                    member.getGuild().getIdLong(), newLevel.getLevel(),
+                    oldLevel);
+            aUserExperience.setCurrentLevel(newLevel);
+            AExperienceRole calculatedNewRole = experienceRoleService.calculateRole(roles, newLevel.getLevel());
+            Long oldRoleId = aUserExperience.getCurrentExperienceRole() != null && aUserExperience.getCurrentExperienceRole().getRole() != null ? aUserExperience.getCurrentExperienceRole().getRole().getId() : null;
+            Long newRoleId = calculatedNewRole != null && calculatedNewRole.getRole() != null ? calculatedNewRole.getRole().getId() : null;
+            result.setOldRoleId(oldRoleId);
+            result.setNewRoleId(newRoleId);
+            if(message != null
+                    && aUserExperience.getLevelUpNotification()
+                    && featureModeService.featureModeActive(ExperienceFeatureDefinition.EXPERIENCE, serverId, ExperienceFeatureMode.LEVEL_UP_NOTIFICATION)) {
+                LevelUpNotificationModel model = LevelUpNotificationModel
+                        .builder()
+                        .memberDisplay(MemberDisplay.fromMember(member))
+                        .oldExperience(oldExperience)
+                        .newExperience(newExperienceCount)
+                        .newLevel(newLevel.getLevel())
+                        .oldLevel(oldLevel)
+                        .newRole(oldRoleId != null ? RoleDisplay.fromRole(oldRoleId) : null)
+                        .newRole(newRoleId != null ? RoleDisplay.fromRole(newRoleId) : null)
+                        .build();
+                MessageToSend messageToSend = templateService.renderEmbedTemplate("experience_level_up_notification", model, serverId);
+                FutureUtils.toSingleFutureGeneric(channelService.sendMessageToSendToChannel(messageToSend, message.getChannel())).thenAccept(unused -> {
+                    log.info("Sent level up notification to user {} in server {} in channel {}.", member.getIdLong(), serverId, message.getChannel().getIdLong());
+                }).exceptionally(throwable -> {
+                    log.warn("Failed to send level up notification to user {} in server {} in channel {}.", member.getIdLong(), serverId, message.getChannel().getIdLong());
+                    return null;
+                });
+            }
+            aUserExperience.setCurrentExperienceRole(calculatedNewRole);
+        }
+        aUserExperience.setMessageCount(aUserExperience.getMessageCount() + 1L);
+        if(userChangesLevel && featureModeService.featureModeActive(ExperienceFeatureDefinition.EXPERIENCE, server, ExperienceFeatureMode.LEVEL_ACTION)) {
+            levelActionService.applyLevelActionsToUser(aUserExperience, oldLevel)
+                .thenAccept(unused -> {
+                    log.info("Executed level actions for user {}.", userInServerId);
+                })
+                .exceptionally(throwable -> {
+                    log.warn("Failed to execute level actions for user {}.", userInServerId, throwable);
+                    return null;
+                });
+        }
+        if(aUserExperienceOptional.isEmpty()) {
+            userExperienceManagementService.saveUser(aUserExperience);
+        }
+        if(!Objects.equals(result.getOldRoleId(), result.getNewRoleId())) {
+            if(result.getOldRoleId() != null && result.getNewRoleId() != null) {
+                roleService.updateRolesIds(member, List.of(result.getOldRoleId()), List.of(result.getNewRoleId())).thenAccept(unused -> {
+                    log.debug("Removed role {} from and added role {} to member {} in server {}.", result.getOldRoleId(), result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong());
+                }).exceptionally(throwable -> {
+                    log.warn("Failed to remove role {} from and add role {} to  member {} in server {}.", result.getOldRoleId(), result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
+                    return null;
+                });
+            } else {
+                if(result.getOldRoleId() != null) {
+                    roleService.removeRoleFromMemberAsync(member, result.getOldRoleId()).thenAccept(unused -> {
+                        log.debug("Removed role {} from member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong());
+                    }).exceptionally(throwable -> {
+                        log.warn("Failed to remove role {} from member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
+                        return null;
+                    });
+                }
+                if(result.getNewRoleId() != null) {
+                    roleService.addRoleToMemberAsync(member, result.getNewRoleId()).thenAccept(unused -> {
+                        log.debug("Added role {} to member {} in server {}.", result.getNewRoleId(), member.getIdLong(), member.getGuild().getIdLong());
+                    }).exceptionally(throwable -> {
+                        log.warn("Failed to add role {} to member {} in server {}.", result.getOldRoleId(), member.getIdLong(), member.getGuild().getIdLong(), throwable);
+                        return null;
+                    });
+                }
+            }
         }
     }
 
@@ -521,7 +521,7 @@ public class AUserExperienceServiceBean implements AUserExperienceService {
     public LeaderBoardEntry getRankOfUserInServer(AUserInAServer userInAServer) {
         log.debug("Retrieving rank for {}", userInAServer.getUserReference().getId());
         Optional<AUserExperience> aUserExperienceOptional = userExperienceManagementService.findByUserInServerIdOptional(userInAServer.getUserInServerId());
-        if(!aUserExperienceOptional.isPresent()) {
+        if(aUserExperienceOptional.isEmpty()) {
             throw new NoExperienceTrackedException();
         }
         Integer rank = 0;

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/main/java/dev/sheldan/abstracto/experience/service/ExperienceLevelServiceBean.java

@@ -52,7 +52,7 @@ public class ExperienceLevelServiceBean implements ExperienceLevelService {
         if(level < 0) {
             throw new IllegalArgumentException("Level should not be less to 0.");
         }
-        return 5L * (level * level) + 50 * level + 100;
+        return 5L * ((long) level * level) + 50L * level + 100;
     }
 
     @Override

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/main/java/dev/sheldan/abstracto/experience/service/ExperienceRoleServiceBean.java

@@ -88,7 +88,7 @@ public class ExperienceRoleServiceBean implements ExperienceRoleService {
     @Override
     public CompletableFuture<Void> unsetRoles(List<ARole> rolesToUnset, GuildMessageChannel messageChannel) {
         List<AExperienceRole> rolesInServer = experienceRoleManagementService.getRolesInServer(rolesToUnset);
-        Integer totalCount = 0;
+        int totalCount = 0;
         for (AExperienceRole aExperienceRole : rolesInServer) {
             totalCount += aExperienceRole.getUsers().size();
         }

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/main/java/dev/sheldan/abstracto/experience/service/RunTimeExperienceService.java

@@ -1,5 +1,8 @@
 package dev.sheldan.abstracto.experience.service;
 
+import java.util.HashSet;
+import java.util.Set;
+import lombok.Getter;
 import org.springframework.stereotype.Component;
 
 import java.time.Instant;
@@ -17,11 +20,9 @@ import java.util.concurrent.locks.ReentrantLock;
 @Component
 public class RunTimeExperienceService {
 
-    private Map<Long,Map<Long, Instant>> runtimeExperience = new HashMap<>();
+    @Getter
+    private final Map<Long,Map<Long, Instant>> runtimeExperience = new HashMap<>();
     private static final Lock lock = new ReentrantLock();
-    public Map<Long, Map<Long, Instant>> getRuntimeExperience() {
-        return runtimeExperience;
-    }
 
     /**
      * Acquires the lock of the runtime experience data structure. Operations on it should only be done, while holding the lock
@@ -39,6 +40,7 @@ public class RunTimeExperienceService {
 
     public void cleanupRunTimeStorage() {
         Instant now = Instant.now();
+        Set<Long> serverIdsToRemove = new HashSet<>();
         runtimeExperience.forEach((serverId, userInstantMap) -> {
             List<Long> userIdsToRemove = new ArrayList<>();
             userInstantMap.forEach((userId, instant) -> {
@@ -47,6 +49,10 @@ public class RunTimeExperienceService {
                 }
             });
             userIdsToRemove.forEach(userInstantMap::remove);
+            if(userInstantMap.isEmpty()) {
+                serverIdsToRemove.add(serverId);
+            }
         });
+        serverIdsToRemove.forEach(runtimeExperience::remove);
     }
 }

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-impl/src/test/java/dev/sheldan/abstracto/experience/service/RuntimeExperienceServiceTest.java

@@ -0,0 +1,32 @@
+package dev.sheldan.abstracto.experience.service;
+
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.time.Instant;
+import java.util.HashMap;
+import java.util.Map;
+import org.junit.Test;
+
+public class RuntimeExperienceServiceTest {
+
+    @Test
+    public void shouldCleanExpiredExperience() {
+        RunTimeExperienceService experienceService = new RunTimeExperienceService();
+        Map<Long, Instant> mapValue = new HashMap<>(Map.of(2L, Instant.now().minusSeconds(5)));
+        experienceService.getRuntimeExperience().put(1L, mapValue);
+        experienceService.cleanupRunTimeStorage();
+        assertThat(experienceService.getRuntimeExperience()).isEmpty();
+    }
+
+    @Test
+    public void shouldLeaveExperienceIfNotYetExpired() {
+        RunTimeExperienceService experienceService = new RunTimeExperienceService();
+        Map<Long, Instant> mapValue2 = new HashMap<>(Map.of(3L, Instant.now().plusSeconds(5)));
+        experienceService.getRuntimeExperience().put(2L, mapValue2);
+        experienceService.cleanupRunTimeStorage();
+        assertThat(experienceService.getRuntimeExperience().get(2L)).containsKey(3L);
+        assertThat(experienceService.getRuntimeExperience()).hasSize(1);
+    }
+
+}

abstracto-application/abstracto-modules/experience-tracking/experience-tracking-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>experience-tracking</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/experience-tracking/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/giveaway/giveaway-impl/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>giveaway</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>giveaway-impl</artifactId>

abstracto-application/abstracto-modules/giveaway/giveaway-int/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>giveaway</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>giveaway-int</artifactId>

abstracto-application/abstracto-modules/giveaway/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>giveaway</artifactId>

abstracto-application/abstracto-modules/image-generation/image-generation-impl/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <artifactId>image-generation</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>image-generation-impl</artifactId>

abstracto-application/abstracto-modules/image-generation/image-generation-int/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <artifactId>image-generation</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>image-generation-int</artifactId>

abstracto-application/abstracto-modules/image-generation/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
 
     <artifactId>image-generation</artifactId>

abstracto-application/abstracto-modules/invite-filter/invite-filter-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>invite-filter</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/invite-filter/invite-filter-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>invite-filter</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -18,7 +18,7 @@
         <dependency>
             <groupId>dev.sheldan.abstracto.modules</groupId>
             <artifactId>moderation-int</artifactId>
-            <version>1.6.19-SNAPSHOT</version>
+            <version>1.6.23-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
     </dependencies>

abstracto-application/abstracto-modules/invite-filter/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/link-embed/link-embed-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>link-embed</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/link-embed/link-embed-impl/src/main/java/dev/sheldan/abstracto/linkembed/listener/MessageEmbedListener.java

@@ -13,9 +13,13 @@ import dev.sheldan.abstracto.core.models.listener.MessageReceivedModel;
 import dev.sheldan.abstracto.core.service.MessageCache;
 import dev.sheldan.abstracto.core.service.MessageService;
 import dev.sheldan.abstracto.core.service.management.UserInServerManagementService;
+import dev.sheldan.abstracto.core.utils.CompletableFutureList;
 import dev.sheldan.abstracto.linkembed.config.LinkEmbedFeatureDefinition;
 import dev.sheldan.abstracto.linkembed.model.MessageEmbedLink;
 import dev.sheldan.abstracto.linkembed.service.MessageEmbedService;
+import java.util.ArrayList;
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Function;
 import lombok.extern.slf4j.Slf4j;
 import net.dv8tion.jda.api.entities.Message;
 import net.dv8tion.jda.api.events.Event;
@@ -27,7 +31,6 @@ import org.springframework.transaction.annotation.Transactional;
 import javax.annotation.PostConstruct;
 import java.util.Arrays;
 import java.util.List;
-import java.util.function.Consumer;
 
 @Component
 @Slf4j
@@ -67,37 +70,51 @@ public class MessageEmbedListener implements MessageReceivedListener {
         }
         String messageRaw = message.getContentRaw();
         List<MessageEmbedLink> links = messageEmbedService.getLinksInMessage(messageRaw);
+        for (MessageEmbedLink messageEmbedLink : links) {
+            messageRaw = messageRaw.replace(messageEmbedLink.getWholeUrl(), "");
+        }
+        boolean deleteMessage = StringUtils.isBlank(messageRaw) && !links.isEmpty() && message.getAttachments().isEmpty();
         if(!links.isEmpty()) {
+            Long messageId = message.getIdLong();
+            Long channelId = message.getChannelIdLong();
+            Long serverId = message.getGuildIdLong();
             log.debug("We found {} links to embed in message {} in channel {} in guild {}.", links.size(), message.getId(), message.getChannel().getId(), message.getGuild().getId());
             Long userEmbeddingUserInServerId = userInServerManagementService.loadOrCreateUser(message.getMember()).getUserInServerId();
+            List<CompletableFuture<Void>> futures = new ArrayList<>();
             for (MessageEmbedLink messageEmbedLink : links) {
-                // potentially support foreign linked servers
+                // potentially support foreign linked servers?
                 if(!messageEmbedLink.getServerId().equals(message.getGuild().getIdLong())) {
                     log.info("Link for message {} was from a foreign server {}. Do not embed.", messageEmbedLink.getMessageId(), messageEmbedLink.getServerId());
                     continue;
                 }
-                messageRaw = messageRaw.replace(messageEmbedLink.getWholeUrl(), "");
-                Consumer<CachedMessage> cachedMessageConsumer = cachedMessage -> self.embedSingleLink(message, userEmbeddingUserInServerId, cachedMessage);
-                messageCache.getMessageFromCache(messageEmbedLink.getServerId(), messageEmbedLink.getChannelId(), messageEmbedLink.getMessageId())
-                        .thenAccept(cachedMessageConsumer)
-                        .exceptionally(throwable -> {
-                            log.error("Error when embedding link for message {}", message.getId(), throwable);
-                            return null;
-                        });
+                Function<CachedMessage, CompletableFuture<Void>> cachedMessageConsumer = cachedMessage -> self.embedSingleLink(message, userEmbeddingUserInServerId, cachedMessage);
+                futures.add(messageCache.getMessageFromCache(messageEmbedLink.getServerId(), messageEmbedLink.getChannelId(), messageEmbedLink.getMessageId())
+                        .thenCompose(cachedMessageConsumer));
+            }
+            if(!futures.isEmpty()) {
+                // only delete the message if all futures go through
+                new CompletableFutureList<>(futures).getMainFuture().thenAccept(unused -> {
+                    if(deleteMessage) {
+                        messageService.deleteMessageInChannelInServer(serverId, channelId, messageId);
+                    }
+                }).thenAccept(unused -> {
+                    log.info("Deleted embedding message server {} channel {} message {}.", serverId, channelId, messageId);
+                }).exceptionally(throwable -> {
+                    log.info("Failed to delete embedding message or to embed message server {} channel {} message {}.", serverId, channelId, messageId, throwable);
+                    return null;
+                });
             }
         }
-        if(StringUtils.isBlank(messageRaw) && !links.isEmpty() && message.getAttachments().isEmpty()) {
-            messageService.deleteMessage(message);
+        if(deleteMessage) {
             return ConsumableListenerResult.DELETED;
-        }
-        if(!links.isEmpty()) {
+        } else if(!links.isEmpty()) {
             return ConsumableListenerResult.PROCESSED;
         }
         return ConsumableListenerResult.IGNORED;
     }
 
     @Transactional
-    public void embedSingleLink(Message message, Long cause, CachedMessage cachedMessage) {
+    public CompletableFuture<Void> embedSingleLink(Message message, Long cause, CachedMessage cachedMessage) {
         GuildMemberMessageChannel context = GuildMemberMessageChannel
                 .builder()
                 .guildChannel(message.getGuildChannel())
@@ -107,7 +124,7 @@ public class MessageEmbedListener implements MessageReceivedListener {
                 .build();
         log.info("Embedding link to message {} in channel {} in server {} to channel {} and server {}.",
                 cachedMessage.getMessageId(), cachedMessage.getChannelId(), cachedMessage.getServerId(), message.getChannel().getId(), message.getGuild().getId());
-        messageEmbedService.embedLink(cachedMessage, message.getGuildChannel(), cause , context).thenAccept(unused ->
+        return messageEmbedService.embedLink(cachedMessage, message.getGuildChannel(), cause , context).thenAccept(unused ->
             metricService.incrementCounter(MESSAGE_EMBED_CREATED)
         ).exceptionally(throwable -> {
             log.error("Failed to embed link towards message {} in channel {} in sever {} linked from message {} in channel {} in server {}.", cachedMessage.getMessageId(), cachedMessage.getChannelId(), cachedMessage.getServerId(),

abstracto-application/abstracto-modules/link-embed/link-embed-impl/src/main/java/dev/sheldan/abstracto/linkembed/listener/interaction/MessageEmbedContextCommandListener.java

@@ -12,6 +12,7 @@ import dev.sheldan.abstracto.core.service.MessageCache;
 import dev.sheldan.abstracto.core.service.management.UserInServerManagementService;
 import dev.sheldan.abstracto.linkembed.config.LinkEmbedFeatureDefinition;
 import dev.sheldan.abstracto.linkembed.service.MessageEmbedService;
+import java.util.concurrent.CompletableFuture;
 import lombok.extern.slf4j.Slf4j;
 import net.dv8tion.jda.api.entities.Member;
 import net.dv8tion.jda.api.entities.Message;
@@ -46,13 +47,27 @@ public class MessageEmbedContextCommandListener implements MessageContextCommand
         Message targetMessage = event.getInteraction().getTarget();
         Member actor = model.getEvent().getMember();
 
+        Long messageId = targetMessage.getIdLong();
         messageCache.getMessageFromCache(targetMessage)
-                .thenAccept(cachedMessage -> self.embedMessage(model, actor, cachedMessage));
+                .thenCompose(cachedMessage -> {
+                    try {
+                        return self.embedMessage(model, actor, cachedMessage);
+                    } catch (Exception ex) {
+                        return CompletableFuture.failedFuture(ex);
+                    }
+                })
+            .thenAccept(unused -> {
+                log.info("Finished embedding message {}.", messageId);
+            })
+            .exceptionally(throwable ->  {
+                log.error("Failed to embed message {}.", messageId, throwable);
+                return null;
+            });
         return DefaultListenerResult.PROCESSED;
     }
 
     @Transactional
-    public void embedMessage(MessageContextInteractionModel model, Member actor, CachedMessage cachedMessage) {
+    public CompletableFuture<Void> embedMessage(MessageContextInteractionModel model, Member actor, CachedMessage cachedMessage) {
         Long userEmbeddingUserInServerId = userInServerManagementService.loadOrCreateUser(actor).getUserInServerId();
         GuildMemberMessageChannel context = GuildMemberMessageChannel
                 .builder()
@@ -61,7 +76,7 @@ public class MessageEmbedContextCommandListener implements MessageContextCommand
                 .member(actor)
                 .guildChannel(model.getEvent().getGuildChannel())
                 .build();
-        messageEmbedService.embedLink(cachedMessage, model.getEvent().getGuildChannel(), userEmbeddingUserInServerId, context, model.getEvent().getInteraction());
+        return messageEmbedService.embedLink(cachedMessage, model.getEvent().getGuildChannel(), userEmbeddingUserInServerId, context, model.getEvent().getInteraction());
     }
 
     @Override

abstracto-application/abstracto-modules/link-embed/link-embed-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>link-embed</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/link-embed/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/logging/logging-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>logging</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/logging/logging-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>logging</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/logging/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/moderation/moderation-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>moderation</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/java/dev/sheldan/abstracto/moderation/command/HoneyPotBan.java

@@ -0,0 +1,153 @@
+package dev.sheldan.abstracto.moderation.command;
+
+import dev.sheldan.abstracto.core.command.condition.AbstractConditionableCommand;
+import dev.sheldan.abstracto.core.command.config.CommandConfiguration;
+import dev.sheldan.abstracto.core.command.config.HelpInfo;
+import dev.sheldan.abstracto.core.command.config.Parameter;
+import dev.sheldan.abstracto.core.command.execution.CommandResult;
+import dev.sheldan.abstracto.core.config.FeatureDefinition;
+import dev.sheldan.abstracto.core.interaction.InteractionService;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandConfig;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandPrivilegeLevels;
+import dev.sheldan.abstracto.core.interaction.slash.parameter.SlashCommandParameterService;
+import dev.sheldan.abstracto.core.service.ConfigService;
+import dev.sheldan.abstracto.core.utils.CompletableFutureList;
+import dev.sheldan.abstracto.core.utils.FutureUtils;
+import dev.sheldan.abstracto.core.utils.ParseUtils;
+import dev.sheldan.abstracto.moderation.config.ModerationModuleDefinition;
+import dev.sheldan.abstracto.moderation.config.ModerationSlashCommandNames;
+import dev.sheldan.abstracto.moderation.config.feature.HoneyPotFeatureConfig;
+import dev.sheldan.abstracto.moderation.config.feature.ModerationFeatureDefinition;
+import dev.sheldan.abstracto.moderation.listener.HoneyPotServiceBean;
+import dev.sheldan.abstracto.moderation.model.template.command.HoneyPotBanResponseModel;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import net.dv8tion.jda.api.entities.Guild;
+import net.dv8tion.jda.api.entities.Member;
+import net.dv8tion.jda.api.entities.Role;
+import net.dv8tion.jda.api.events.interaction.command.SlashCommandInteractionEvent;
+import net.dv8tion.jda.api.interactions.InteractionHook;
+import org.apache.commons.lang3.tuple.Pair;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+
+@Component
+public class HoneyPotBan extends AbstractConditionableCommand {
+
+    private static final String DURATION_PARAMETER = "duration";
+    private static final String HONEYPOT_BAN_RESPONSE = "honeypotBan_response";
+    private static final String HONEYPOT_BAN_COMMAND = "honeypotBan";
+
+    @Autowired
+    private HoneyPotBan self;
+
+    @Autowired
+    private SlashCommandParameterService slashCommandParameterService;
+
+    @Autowired
+    private HoneyPotServiceBean honeyPotServiceBean;
+
+    @Autowired
+    private InteractionService interactionService;
+
+    @Autowired
+    private ConfigService configService;
+
+    @Override
+    public CompletableFuture<CommandResult> executeSlash(SlashCommandInteractionEvent event) {
+        Duration duration;
+        if(slashCommandParameterService.hasCommandOption(DURATION_PARAMETER, event)) {
+            String durationStr = slashCommandParameterService.getCommandOption(DURATION_PARAMETER, event, Duration.class, String.class);
+            duration = ParseUtils.parseDuration(durationStr);
+        } else {
+            Long ignoredSeconds =
+                configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_IGNORED_JOIN_DURATION_SECONDS, event.getGuild().getIdLong());
+            duration = Duration.ofSeconds(ignoredSeconds);
+        }
+
+        return event.deferReply(false).submit()
+            .thenCompose(hook -> self.banEveryHoneypotMember(hook, event.getGuild(), duration))
+            .thenCompose(banResponse -> self.sendResponse(banResponse))
+            .thenApply(interactionHook -> CommandResult.fromSuccess());
+    }
+
+    @Transactional
+    public CompletableFuture<Void> sendResponse(Pair<InteractionHook, Integer> banResponse) {
+        HoneyPotBanResponseModel responseModel = HoneyPotBanResponseModel
+            .builder()
+            .bannedMemberCount(banResponse.getRight())
+            .build();
+        return FutureUtils.toSingleFutureGeneric(interactionService.sendMessageToInteraction(HONEYPOT_BAN_RESPONSE, responseModel, banResponse.getLeft()));
+    }
+
+    @Transactional
+    public CompletableFuture<Pair<InteractionHook, Integer>> banEveryHoneypotMember(InteractionHook hook, Guild guild, Duration duration) {
+        Instant maxJoinAge;
+        if(duration != null) {
+            maxJoinAge = Instant.now().minus(duration);
+        } else {
+            maxJoinAge = Instant.now();
+        }
+        List<Member> currentMembersWithHoneypotRole = honeyPotServiceBean.getCurrentMembersWithHoneypotRole(guild)
+            .stream().filter(member -> member.getTimeJoined().toInstant().isBefore(maxJoinAge))
+            .toList();
+        Role honeyPotRole = guild.getRoleById(honeyPotServiceBean.getHoneyPotRoleId(guild.getIdLong()));
+        List<CompletableFuture<Void>> futures = currentMembersWithHoneypotRole.stream().map(member ->
+            honeyPotServiceBean.banForHoneyPot(member, honeyPotRole)
+        ).toList();
+        Integer memberCount = currentMembersWithHoneypotRole.size();
+        CompletableFutureList<Void> futureList = new CompletableFutureList<>(futures);
+        return futureList.getMainFuture()
+            .thenApply(unused -> Pair.of(hook, memberCount));
+    }
+
+    @Override
+    public CommandConfiguration getConfiguration() {
+
+        Parameter durationParameter = Parameter
+            .builder()
+            .name(DURATION_PARAMETER)
+            .templated(true)
+            .type(String.class)
+            .optional(true)
+            .build();
+
+
+        List<Parameter> parameters = Arrays.asList(durationParameter);
+        HelpInfo helpInfo = HelpInfo
+            .builder()
+            .templated(true)
+            .hasExample(true)
+            .build();
+
+        SlashCommandConfig slashCommandConfig = SlashCommandConfig
+            .builder()
+            .enabled(true)
+            .rootCommandName(ModerationSlashCommandNames.MODERATION)
+            .defaultPrivilege(SlashCommandPrivilegeLevels.INVITER)
+            .commandName("honeypotban")
+            .build();
+
+        return CommandConfiguration.builder()
+            .name(HONEYPOT_BAN_COMMAND)
+            .module(ModerationModuleDefinition.MODERATION)
+            .templated(true)
+            .async(true)
+            .slashCommandConfig(slashCommandConfig)
+            .slashCommandOnly(true)
+            .supportsEmbedException(true)
+            .parameters(parameters)
+            .help(helpInfo)
+            .build();
+    }
+
+    @Override
+    public FeatureDefinition getFeature() {
+        return ModerationFeatureDefinition.HONEYPOT;
+    }
+}

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/java/dev/sheldan/abstracto/moderation/listener/HoneyPotRoleAddedListener.java

@@ -4,97 +4,44 @@ import dev.sheldan.abstracto.core.config.FeatureDefinition;
 import dev.sheldan.abstracto.core.config.ListenerPriority;
 import dev.sheldan.abstracto.core.listener.DefaultListenerResult;
 import dev.sheldan.abstracto.core.listener.sync.jda.RoleAddedListener;
-import dev.sheldan.abstracto.core.models.ConditionContextInstance;
-import dev.sheldan.abstracto.core.models.ServerUser;
-import dev.sheldan.abstracto.core.models.database.AUserInAServer;
 import dev.sheldan.abstracto.core.models.listener.RoleAddedModel;
-import dev.sheldan.abstracto.core.models.template.display.MemberDisplay;
-import dev.sheldan.abstracto.core.models.template.display.RoleDisplay;
-import dev.sheldan.abstracto.core.service.ConditionService;
-import dev.sheldan.abstracto.core.service.ConfigService;
 import dev.sheldan.abstracto.core.service.RoleService;
-import dev.sheldan.abstracto.core.service.SystemCondition;
-import dev.sheldan.abstracto.core.service.management.UserInServerManagementService;
-import dev.sheldan.abstracto.core.templating.service.TemplateService;
-import dev.sheldan.abstracto.moderation.config.feature.HoneyPotFeatureConfig;
 import dev.sheldan.abstracto.moderation.config.feature.ModerationFeatureDefinition;
-import dev.sheldan.abstracto.moderation.model.listener.HoneyPotReasonModel;
-import dev.sheldan.abstracto.moderation.service.BanService;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 import lombok.extern.slf4j.Slf4j;
 import net.dv8tion.jda.api.entities.ISnowflake;
-import net.dv8tion.jda.api.entities.Member;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.time.Duration;
-import java.time.Instant;
-import java.time.temporal.ChronoUnit;
-import java.util.HashMap;
-import java.util.Map;
 
 @Component
 @Slf4j
 public class HoneyPotRoleAddedListener implements RoleAddedListener {
 
-    @Autowired
-    private ConfigService configService;
-
-    @Autowired
-    private BanService banService;
-
-    @Autowired
-    private TemplateService templateService;
-
-    @Autowired
-    private ConditionService conditionService;
-
-    @Autowired
-    private UserInServerManagementService userInServerManagementService;
-
     @Autowired
     private RoleService roleService;
 
-    private static final String HONEYPOT_BAN_REASON_TEMPLATE = "honeypot_ban_reason";
-
-    private static final String LEVEL_CONDITION_USER_ID_PARAMETER = "userId";
-    private static final String LEVEL_CONDITION_LEVEL_PARAMETER = "level";
-    private static final String LEVEL_CONDITION_SERVER_PARAMETER = "serverId";
-
-    private static final String LEVEL_CONDITION_NAME = "HAS_LEVEL";
+    @Autowired
+    private HoneyPotServiceBean honeyPotServiceBean;
 
     @Override
     public DefaultListenerResult execute(RoleAddedModel model) {
-        Long honeyPotRoleId = configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_ROLE_ID, model.getServerId());
+        Long honeyPotRoleId = honeyPotServiceBean.getHoneyPotRoleId(model.getServerId());
         if(honeyPotRoleId == 0) {
             log.info("Server {} has honeypot feature enabled, but still default honeypot role config - Ignoring.", model.getServerId());
             return DefaultListenerResult.IGNORED;
         }
         if(honeyPotRoleId.equals(model.getRoleId())) {
-            Integer levelToSkipBan = configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_IGNORED_LEVEL, model.getServerId()).intValue();
-            Long amountOfSecondsToIgnore = configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_IGNORED_JOIN_DURATION_SECONDS, model.getServerId());
-            boolean allowed = userHasLevel(model.getTargetMember(), levelToSkipBan) || userJoinedLongerThanSeconds(model.getTargetMember(), amountOfSecondsToIgnore);
-            if(allowed) {
-                log.info("User {} in server {} has at least level {} or joined more than {} seconds ago and will not get banned by honeypot. All existing roles besides {} will be removed.",
-                        model.getTargetUser().getUserId(), model.getTargetUser().getServerId(), levelToSkipBan, amountOfSecondsToIgnore, honeyPotRoleId);
-                cleanupRolesBesidesHoneyPot(model, honeyPotRoleId);
-            } else  {
+            boolean fellIntoHoneyPot = honeyPotServiceBean.fellIntoHoneyPot(model.getServerId(), model.getTargetMember());
+            if (fellIntoHoneyPot) {
                 log.info("Banning user {} in guild {} due to role {}.", model.getTargetUser().getUserId(), model.getTargetUser().getServerId(), model.getRoleId());
-                HoneyPotReasonModel reasonModel = HoneyPotReasonModel
-                        .builder()
-                        .memberDisplay(MemberDisplay.fromMember(model.getTargetMember()))
-                        .roleDisplay(RoleDisplay.fromRole(model.getRole()))
-                        .build();
-                String banReason = templateService.renderTemplate(HONEYPOT_BAN_REASON_TEMPLATE, reasonModel, model.getServerId());
-                banService.banUserWithNotification(model.getTargetUser(), banReason, ServerUser.fromMember(model.getTargetMember().getGuild().getSelfMember()),
-                        model.getTargetMember().getGuild(), Duration.ofDays(7)).thenAccept(banResult -> {
-                    log.info("Banned user {} in guild {} due to role {}.", model.getTargetUser().getUserId(), model.getTargetUser().getServerId(), model.getRoleId());
-                }).exceptionally(throwable -> {
-                    log.error("Failed to ban user {} in guild {} due to role {}.", model.getTargetUser().getUserId(), model.getTargetUser().getServerId(), model.getRoleId(), throwable);
-                    return null;
-                });
+                honeyPotServiceBean.banForHoneyPot(model.getTargetMember(), model.getRole());
+            } else {
+                log.info("User {} in server {}  will not get banned by honeypot. All existing roles besides {} will be removed.",
+                        model.getTargetUser().getUserId(), model.getTargetUser().getServerId(), honeyPotRoleId);
+                cleanupRolesBesidesHoneyPot(model, honeyPotRoleId);
             }
             return DefaultListenerResult.PROCESSED;
         } else {
@@ -126,28 +73,6 @@ public class HoneyPotRoleAddedListener implements RoleAddedListener {
         }
     }
 
-    private boolean userHasLevel(Member member, Integer level) {
-        log.info("Checking if member {} is ignored to click on the honeypot in server {}.", member.getIdLong(),member.getGuild().getIdLong());
-        Map<String, Object> parameters = new HashMap<>();
-        AUserInAServer userInAServer = userInServerManagementService.loadOrCreateUser(member);
-        parameters.put(LEVEL_CONDITION_USER_ID_PARAMETER, userInAServer.getUserInServerId());
-        parameters.put(LEVEL_CONDITION_LEVEL_PARAMETER, level);
-        parameters.put(LEVEL_CONDITION_SERVER_PARAMETER, member.getGuild().getIdLong());
-        ConditionContextInstance contextInstance = ConditionContextInstance
-                .builder()
-                .conditionName(LEVEL_CONDITION_NAME)
-                .parameters(parameters)
-                .build();
-        SystemCondition.Result result = conditionService.checkConditions(contextInstance);
-        return SystemCondition.Result.isSuccessful(result);
-    }
-
-    private boolean userJoinedLongerThanSeconds(Member member, Long seconds) {
-        log.info("Checking if member {} joined the server more than {} seconds ago.", member.getIdLong(), seconds);
-        // the incorrectness of timejoined should not matter, we chunk anyway
-        return member.getTimeJoined().toInstant().isBefore(Instant.now().minus(seconds, ChronoUnit.SECONDS));
-    }
-
     @Override
     public FeatureDefinition getFeature() {
         return ModerationFeatureDefinition.HONEYPOT;

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/java/dev/sheldan/abstracto/moderation/listener/HoneyPotServiceBean.java

@@ -0,0 +1,115 @@
+package dev.sheldan.abstracto.moderation.listener;
+
+import dev.sheldan.abstracto.core.models.ConditionContextInstance;
+import dev.sheldan.abstracto.core.models.ServerUser;
+import dev.sheldan.abstracto.core.models.database.AUserInAServer;
+import dev.sheldan.abstracto.core.models.template.display.MemberDisplay;
+import dev.sheldan.abstracto.core.models.template.display.RoleDisplay;
+import dev.sheldan.abstracto.core.service.ConditionService;
+import dev.sheldan.abstracto.core.service.ConfigService;
+import dev.sheldan.abstracto.core.service.MemberService;
+import dev.sheldan.abstracto.core.service.SystemCondition;
+import dev.sheldan.abstracto.core.service.management.UserInServerManagementService;
+import dev.sheldan.abstracto.core.templating.service.TemplateService;
+import dev.sheldan.abstracto.moderation.config.feature.HoneyPotFeatureConfig;
+import dev.sheldan.abstracto.moderation.model.listener.HoneyPotReasonModel;
+import dev.sheldan.abstracto.moderation.service.BanService;
+import java.time.Duration;
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import lombok.extern.slf4j.Slf4j;
+import net.dv8tion.jda.api.entities.Guild;
+import net.dv8tion.jda.api.entities.Member;
+import net.dv8tion.jda.api.entities.Role;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class HoneyPotServiceBean {
+
+    @Autowired
+    private ConfigService configService;
+
+    @Autowired
+    private UserInServerManagementService userInServerManagementService;
+
+    @Autowired
+    private ConditionService conditionService;
+
+    @Autowired
+    private TemplateService templateService;
+
+    @Autowired
+    private BanService banService;
+
+    @Autowired
+    private MemberService memberService;
+
+    private static final String LEVEL_CONDITION_USER_ID_PARAMETER = "userId";
+    private static final String LEVEL_CONDITION_LEVEL_PARAMETER = "level";
+    private static final String LEVEL_CONDITION_SERVER_PARAMETER = "serverId";
+    private static final String LEVEL_CONDITION_NAME = "HAS_LEVEL";
+    private static final String HONEYPOT_BAN_REASON_TEMPLATE = "honeypot_ban_reason";
+
+
+    public Long getHoneyPotRoleId(Long serverId) {
+        return configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_ROLE_ID, serverId);
+    }
+
+    public boolean fellIntoHoneyPot(Long serverId, Member member) {
+        Integer levelToSkipBan = configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_IGNORED_LEVEL, serverId).intValue();
+        Long amountOfSecondsToIgnore = configService.getLongValueOrConfigDefault(HoneyPotFeatureConfig.HONEYPOT_IGNORED_JOIN_DURATION_SECONDS, serverId);
+        boolean allowed =  userHasLevel(member, levelToSkipBan) || userJoinedLongerThanSeconds(member, amountOfSecondsToIgnore);
+        return !allowed;
+    }
+
+    public List<Member> getCurrentMembersWithHoneypotRole(Guild guild) {
+        return memberService.getMembersWithRole(guild.getIdLong(), getHoneyPotRoleId(guild.getIdLong()));
+    }
+
+    public CompletableFuture<Void> banForHoneyPot(Member targetMember, Role role) {
+        HoneyPotReasonModel reasonModel = HoneyPotReasonModel
+            .builder()
+            .memberDisplay(MemberDisplay.fromMember(targetMember))
+            .roleDisplay(RoleDisplay.fromRole(role))
+            .build();
+        ServerUser bannedUser = ServerUser.fromMember(targetMember);
+        String banReason = templateService.renderTemplate(HONEYPOT_BAN_REASON_TEMPLATE, reasonModel, bannedUser.getServerId());
+        long roleId = role.getIdLong();
+        return banService.banUserWithNotification(bannedUser, banReason, ServerUser.fromMember(targetMember.getGuild().getSelfMember()),
+            targetMember.getGuild(), Duration.ofDays(7)).thenAccept(banResult -> {
+            log.info("Banned user {} in guild {} due to role {}.", bannedUser.getUserId(), bannedUser.getServerId(), roleId);
+        }).exceptionally(throwable -> {
+            log.error("Failed to ban user {} in guild {} due to role {}.", bannedUser.getUserId(), bannedUser.getServerId(), roleId, throwable);
+            return null;
+        });
+    }
+
+    private boolean userHasLevel(Member member, Integer level) {
+        log.info("Checking if member {} is ignored to click on the honeypot in server {}.", member.getIdLong(),member.getGuild().getIdLong());
+        Map<String, Object> parameters = new HashMap<>();
+        AUserInAServer userInAServer = userInServerManagementService.loadOrCreateUser(member);
+        parameters.put(LEVEL_CONDITION_USER_ID_PARAMETER, userInAServer.getUserInServerId());
+        parameters.put(LEVEL_CONDITION_LEVEL_PARAMETER, level);
+        parameters.put(LEVEL_CONDITION_SERVER_PARAMETER, member.getGuild().getIdLong());
+        ConditionContextInstance contextInstance = ConditionContextInstance
+            .builder()
+            .conditionName(LEVEL_CONDITION_NAME)
+            .parameters(parameters)
+            .build();
+        SystemCondition.Result result = conditionService.checkConditions(contextInstance);
+        return SystemCondition.Result.isSuccessful(result);
+    }
+
+    private boolean userJoinedLongerThanSeconds(Member member, Long seconds) {
+        log.info("Checking if member {} joined the server more than {} seconds ago.", member.getIdLong(), seconds);
+        // the incorrectness of timejoined should not matter, we chunk anyway
+        return member.getTimeJoined().toInstant().isBefore(Instant.now().minus(seconds, ChronoUnit.SECONDS));
+    }
+
+}

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/resources/migrations/1.6.21/collection.xml

@@ -0,0 +1,6 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="seedData/data.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/resources/migrations/1.6.21/seedData/command.xml

@@ -0,0 +1,16 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <property name="moderationModule" value="(SELECT id FROM module WHERE name = 'moderation')"/>
+    <property name="honeypotFeature" value="(SELECT id FROM feature WHERE key = 'honeypot')"/>
+
+    <changeSet author="Sheldan" id="honeypotBan-command">
+        <insert tableName="command">
+            <column name="name" value="honeypotBan"/>
+            <column name="module_id" valueComputed="${moderationModule}"/>
+            <column name="feature_id" valueComputed="${honeypotFeature}"/>
+        </insert>
+    </changeSet>
+
+</databaseChangeLog>

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/resources/migrations/1.6.21/seedData/data.xml

@@ -0,0 +1,6 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="command.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/moderation/moderation-impl/src/main/resources/migrations/moderation-changeLog.xml

@@ -13,4 +13,5 @@
     <include file="1.4.3/collection.xml" relativeToChangelogFile="true"/>
     <include file="1.5.10/collection.xml" relativeToChangelogFile="true"/>
     <include file="1.5.23/collection.xml" relativeToChangelogFile="true"/>
+    <include file="1.6.21/collection.xml" relativeToChangelogFile="true"/>
 </databaseChangeLog>

abstracto-application/abstracto-modules/moderation/moderation-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>moderation</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/moderation/moderation-int/src/main/java/dev/sheldan/abstracto/moderation/model/template/command/HoneyPotBanResponseModel.java

@@ -0,0 +1,10 @@
+package dev.sheldan.abstracto.moderation.model.template.command;
+
+import lombok.Builder;
+import lombok.Getter;
+
+@Builder
+@Getter
+public class HoneyPotBanResponseModel {
+    private Integer bannedMemberCount;
+}

abstracto-application/abstracto-modules/moderation/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/modmail/modmail-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>modmail</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -44,6 +44,12 @@
             <version>${project.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>dev.sheldan.abstracto.scheduling</groupId>
+            <artifactId>scheduling-int</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>dev.sheldan.abstracto.core</groupId>
             <artifactId>metrics-int</artifactId>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/command/SetThreadPause.java

@@ -0,0 +1,112 @@
+package dev.sheldan.abstracto.modmail.command;
+
+import dev.sheldan.abstracto.core.command.condition.AbstractConditionableCommand;
+import dev.sheldan.abstracto.core.command.condition.CommandCondition;
+import dev.sheldan.abstracto.core.command.config.CommandConfiguration;
+import dev.sheldan.abstracto.core.command.config.HelpInfo;
+import dev.sheldan.abstracto.core.command.config.Parameter;
+import dev.sheldan.abstracto.core.command.execution.CommandResult;
+import dev.sheldan.abstracto.core.config.FeatureDefinition;
+import dev.sheldan.abstracto.core.interaction.InteractionService;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandConfig;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandPrivilegeLevels;
+import dev.sheldan.abstracto.core.interaction.slash.parameter.SlashCommandParameterService;
+import dev.sheldan.abstracto.modmail.condition.ModMailContextCondition;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureDefinition;
+import dev.sheldan.abstracto.modmail.config.ModMailSlashCommandNames;
+import dev.sheldan.abstracto.modmail.exception.ModMailThreadClosedException;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThreadState;
+import dev.sheldan.abstracto.modmail.service.ModMailThreadService;
+import dev.sheldan.abstracto.modmail.service.management.ModMailThreadManagementService;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import net.dv8tion.jda.api.events.interaction.command.SlashCommandInteractionEvent;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+
+@Component
+public class SetThreadPause extends AbstractConditionableCommand {
+
+    private static final String SET_THREAD_PAUSE_COMMAND = "setThreadPause";
+    private static final String SET_THREAD_PAUSE_RESPONSE = "setThreadPause_response";
+    private static final String PAUSED_PARAMETER = "paused";
+
+    @Autowired
+    private ModMailContextCondition requiresModMailCondition;
+
+    @Autowired
+    private ModMailThreadManagementService modMailThreadManagementService;
+
+    @Autowired
+    private ModMailThreadService modMailThreadService;
+
+    @Autowired
+    private InteractionService interactionService;
+
+    @Autowired
+    private SlashCommandParameterService slashCommandParameterService;
+
+    @Override
+    public CompletableFuture<CommandResult> executeSlash(SlashCommandInteractionEvent event) {
+        ModMailThread modMailThread = modMailThreadManagementService.getByChannelId(event.getChannel().getIdLong());
+        if(ModMailThreadState.CLOSED.equals(modMailThread.getState()) || ModMailThreadState.CLOSING.equals(modMailThread.getState())) {
+            throw new ModMailThreadClosedException();
+        }
+        Boolean paused = slashCommandParameterService.getCommandOption(PAUSED_PARAMETER, event, Boolean.class);
+        modMailThreadService.setPauseOfThreadTo(modMailThread, paused);
+        return interactionService.replyEmbed(SET_THREAD_PAUSE_RESPONSE, event)
+                .thenApply(interactionHook -> CommandResult.fromSuccess());
+    }
+
+    @Override
+    public CommandConfiguration getConfiguration() {
+        HelpInfo helpInfo = HelpInfo
+                .builder()
+                .templated(true)
+                .build();
+
+        Parameter newStateParameter = Parameter
+            .builder()
+            .name(PAUSED_PARAMETER)
+            .type(Boolean.class)
+            .templated(true)
+            .build();
+
+        List<Parameter> parameters = Arrays.asList(newStateParameter);
+
+        SlashCommandConfig slashCommandConfig = SlashCommandConfig
+                .builder()
+                .enabled(true)
+                .rootCommandName(ModMailSlashCommandNames.MODMAIL)
+                .defaultPrivilege(SlashCommandPrivilegeLevels.INVITER)
+                .commandName(SET_THREAD_PAUSE_COMMAND)
+                .build();
+
+        return CommandConfiguration.builder()
+                .name(SET_THREAD_PAUSE_COMMAND)
+                .slashCommandConfig(slashCommandConfig)
+                .module(ModMailModuleDefinition.MODMAIL)
+                .help(helpInfo)
+                .slashCommandOnly(true)
+                .supportsEmbedException(true)
+                .templated(true)
+                .parameters(parameters)
+                .causesReaction(true)
+                .build();
+    }
+
+    @Override
+    public FeatureDefinition getFeature() {
+        return ModMailFeatureDefinition.MOD_MAIL;
+    }
+
+    @Override
+    public List<CommandCondition> getConditions() {
+        List<CommandCondition> conditions = super.getConditions();
+        conditions.add(requiresModMailCondition);
+        return conditions;
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/command/SnoozeThreadReminder.java

@@ -0,0 +1,115 @@
+package dev.sheldan.abstracto.modmail.command;
+
+import dev.sheldan.abstracto.core.command.condition.AbstractConditionableCommand;
+import dev.sheldan.abstracto.core.command.condition.CommandCondition;
+import dev.sheldan.abstracto.core.command.config.CommandConfiguration;
+import dev.sheldan.abstracto.core.command.config.HelpInfo;
+import dev.sheldan.abstracto.core.command.config.Parameter;
+import dev.sheldan.abstracto.core.command.execution.CommandResult;
+import dev.sheldan.abstracto.core.config.FeatureDefinition;
+import dev.sheldan.abstracto.core.interaction.InteractionService;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandConfig;
+import dev.sheldan.abstracto.core.interaction.slash.SlashCommandPrivilegeLevels;
+import dev.sheldan.abstracto.core.interaction.slash.parameter.SlashCommandParameterService;
+import dev.sheldan.abstracto.core.utils.ParseUtils;
+import dev.sheldan.abstracto.modmail.condition.ModMailContextCondition;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureDefinition;
+import dev.sheldan.abstracto.modmail.config.ModMailSlashCommandNames;
+import dev.sheldan.abstracto.modmail.exception.ModMailThreadClosedException;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThreadState;
+import dev.sheldan.abstracto.modmail.service.ModMailThreadService;
+import dev.sheldan.abstracto.modmail.service.management.ModMailThreadManagementService;
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import net.dv8tion.jda.api.events.interaction.command.SlashCommandInteractionEvent;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+
+@Component
+public class SnoozeThreadReminder extends AbstractConditionableCommand {
+
+    private static final String SNOOZE_THREAD_REMINDER_COMMAND = "snoozeThreadReminder";
+    private static final String SNOOZE_THREAD_REMINDER_RESPONSE = "snoozeThreadReminder_response";
+    private static final String DURATION_PARAMETER = "duration";
+
+    @Autowired
+    private ModMailContextCondition requiresModMailCondition;
+
+    @Autowired
+    private ModMailThreadManagementService modMailThreadManagementService;
+
+    @Autowired
+    private ModMailThreadService modMailThreadService;
+
+    @Autowired
+    private InteractionService interactionService;
+
+    @Autowired
+    private SlashCommandParameterService slashCommandParameterService;
+
+    @Override
+    public CompletableFuture<CommandResult> executeSlash(SlashCommandInteractionEvent event) {
+        ModMailThread modMailThread = modMailThreadManagementService.getByChannelId(event.getChannel().getIdLong());
+        if(ModMailThreadState.CLOSED.equals(modMailThread.getState()) || ModMailThreadState.CLOSING.equals(modMailThread.getState())) {
+            throw new ModMailThreadClosedException();
+        }
+        String durationString = slashCommandParameterService.getCommandOption(DURATION_PARAMETER, event, Duration.class, String.class);
+        Duration duration = ParseUtils.parseDuration(durationString);
+        modMailThreadService.snoozeThreadReminder(modMailThread, duration);
+        return interactionService.replyEmbed(SNOOZE_THREAD_REMINDER_RESPONSE, event)
+                .thenApply(interactionHook -> CommandResult.fromSuccess());
+    }
+
+    @Override
+    public CommandConfiguration getConfiguration() {
+        HelpInfo helpInfo = HelpInfo
+                .builder()
+                .templated(true)
+                .build();
+
+        Parameter durationParameter = Parameter
+            .builder()
+            .name(DURATION_PARAMETER)
+            .type(Duration.class)
+            .templated(true)
+            .build();
+
+        List<Parameter> parameters = Arrays.asList(durationParameter);
+
+        SlashCommandConfig slashCommandConfig = SlashCommandConfig
+                .builder()
+                .enabled(true)
+                .rootCommandName(ModMailSlashCommandNames.MODMAIL)
+                .defaultPrivilege(SlashCommandPrivilegeLevels.INVITER)
+                .commandName(SNOOZE_THREAD_REMINDER_COMMAND)
+                .build();
+
+        return CommandConfiguration.builder()
+                .name(SNOOZE_THREAD_REMINDER_COMMAND)
+                .slashCommandConfig(slashCommandConfig)
+                .module(ModMailModuleDefinition.MODMAIL)
+                .help(helpInfo)
+                .slashCommandOnly(true)
+                .supportsEmbedException(true)
+                .templated(true)
+                .parameters(parameters)
+                .causesReaction(true)
+                .build();
+    }
+
+    @Override
+    public FeatureDefinition getFeature() {
+        return ModMailFeatureDefinition.MOD_MAIL;
+    }
+
+    @Override
+    public List<CommandCondition> getConditions() {
+        List<CommandCondition> conditions = super.getConditions();
+        conditions.add(requiresModMailCondition);
+        return conditions;
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/job/ModmailThreadActionJob.java

@@ -0,0 +1,32 @@
+package dev.sheldan.abstracto.modmail.job;
+
+import dev.sheldan.abstracto.modmail.service.ModMailThreadServiceBean;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.DisallowConcurrentExecution;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.PersistJobDataAfterExecution;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@DisallowConcurrentExecution
+@Component
+@PersistJobDataAfterExecution
+public class ModmailThreadActionJob extends QuartzJobBean {
+
+    @Autowired
+    private ModMailThreadServiceBean modMailThreadServiceBean;
+
+    @Override
+    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
+        try {
+            log.info("Check modmail threads to perform action for.");
+            modMailThreadServiceBean.checkModmailActionsForNeededActions();
+        } catch (Exception exception) {
+            log.error("Modmail thread action job failed.", exception);
+        }
+
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/listener/ModmailAutoCloseListener.java

@@ -0,0 +1,117 @@
+package dev.sheldan.abstracto.modmail.listener;
+
+import dev.sheldan.abstracto.core.config.ListenerPriority;
+import dev.sheldan.abstracto.core.service.ConfigService;
+import dev.sheldan.abstracto.core.service.FeatureModeService;
+import dev.sheldan.abstracto.core.service.GuildService;
+import dev.sheldan.abstracto.core.templating.service.TemplateService;
+import dev.sheldan.abstracto.core.utils.ParseUtils;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureConfig;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureDefinition;
+import dev.sheldan.abstracto.modmail.config.ModMailMode;
+import dev.sheldan.abstracto.modmail.model.ClosingContext;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThreadState;
+import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadActionListenerModel;
+import dev.sheldan.abstracto.modmail.service.ModMailThreadService;
+import dev.sheldan.abstracto.modmail.service.management.ModMailThreadManagementService;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.ArrayList;
+import java.util.concurrent.CompletableFuture;
+import lombok.extern.slf4j.Slf4j;
+import net.dv8tion.jda.api.entities.Guild;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class ModmailAutoCloseListener implements ModmailThreadActionListener {
+
+    @Autowired
+    private ModMailThreadManagementService modMailThreadManagementService;
+
+    @Autowired
+    private ConfigService configService;
+
+    @Autowired
+    private FeatureModeService featureModeService;
+
+    @Autowired
+    private ModMailThreadService modMailThreadService;
+
+    @Autowired
+    private ModmailReminderListener self;
+
+    @Autowired
+    private GuildService guildService;
+
+    @Autowired
+    private TemplateService templateService;
+
+    private static final String AUTO_CLOSE_NOTE_TEMPLATE_KEY = "modmail_auto_closing_note_text";
+
+    @Override
+    public Integer getPriority() {
+        return ListenerPriority.HIGH;
+    }
+
+    @Override
+    public ModmailThreadActionListenerResult execute(ModmailThreadActionListenerModel model) {
+        ModmailThreadActionListenerResult result;
+        if(!featureModeService.featureModeActive(ModMailFeatureDefinition.MOD_MAIL, model.getServerId(), ModMailMode.THREAD_AUTO_CLOSE)) {
+            result = ModmailThreadActionListenerResult.IGNORED;
+        } else {
+            String closeDuration = configService.getStringValueOrConfigDefault(ModMailFeatureConfig.MOD_MAIL_AUTO_CLOSE_DURATION, model.getServerId());
+            Duration duration = ParseUtils.parseDuration(closeDuration);
+            Instant timeInPastDuration = Instant.now().minus(duration);
+            ModMailThread thread = modMailThreadManagementService.getById(model.getThreadId());
+            if(thread.getState() == ModMailThreadState.PAUSED) {
+                log.info("Thread {} is paused - not closing.", thread.getId());
+                return ModmailThreadActionListenerResult.IGNORED;
+            }
+            Instant timeStampToConsider = getTimeStampToConsider(thread);
+            boolean mustBeClosed = timeInPastDuration.isAfter(timeStampToConsider);
+            if (mustBeClosed) {
+                closeThread(thread)
+                    .thenAccept(unused -> {
+                        self.updateSnoozeTimer(model.getThreadId(), duration);
+                        log.info("Automatically closed thread {}", model.getThreadId());
+                    })
+                    .exceptionally(throwable -> {
+                        log.warn("Failed to automatically close thread {}.", model.getThreadId(), throwable);
+                        return null;
+                    });
+                result = ModmailThreadActionListenerResult.FINAL;
+            } else {
+                result = ModmailThreadActionListenerResult.IGNORED;
+            }
+        }
+
+        return result;
+    }
+
+    private static Instant getTimeStampToConsider(ModMailThread thread) {
+        if(thread.getLastUpdated() != null) {
+            return thread.getLastUpdated();
+        }
+        return thread.getCreated();
+    }
+
+    private CompletableFuture<Void> closeThread(ModMailThread modMailThread) {
+        Guild guild = guildService.getGuildById(modMailThread.getServer().getId());
+        if(guild != null) {
+            String closingNote = templateService.renderTemplate(AUTO_CLOSE_NOTE_TEMPLATE_KEY, new Object(), modMailThread.getServer().getId());
+            ClosingContext closingContext = ClosingContext
+                .builder()
+                .notifyUser(true)
+                .log(true)
+                .closingMember(guild.getSelfMember())
+                .note(closingNote)
+                .build();
+            return modMailThreadService.closeModMailThreadEvaluateLogging(modMailThread, closingContext, new ArrayList<>());
+        } else {
+            return CompletableFuture.completedFuture(null);
+        }
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/listener/ModmailReminderListener.java

@@ -0,0 +1,144 @@
+package dev.sheldan.abstracto.modmail.listener;
+
+import dev.sheldan.abstracto.core.config.ListenerPriority;
+import dev.sheldan.abstracto.core.models.template.display.MemberDisplay;
+import dev.sheldan.abstracto.core.models.template.display.RoleDisplay;
+import dev.sheldan.abstracto.core.service.ChannelService;
+import dev.sheldan.abstracto.core.service.ConfigService;
+import dev.sheldan.abstracto.core.service.FeatureModeService;
+import dev.sheldan.abstracto.core.templating.model.MessageToSend;
+import dev.sheldan.abstracto.core.templating.service.TemplateService;
+import dev.sheldan.abstracto.core.utils.FutureUtils;
+import dev.sheldan.abstracto.core.utils.ParseUtils;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureConfig;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureDefinition;
+import dev.sheldan.abstracto.modmail.config.ModMailMode;
+import dev.sheldan.abstracto.modmail.model.database.ModMailRole;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThreadState;
+import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadActionListenerModel;
+import dev.sheldan.abstracto.modmail.model.template.ModmailThreadReminderModel;
+import dev.sheldan.abstracto.modmail.service.management.ModMailRoleManagementService;
+import dev.sheldan.abstracto.modmail.service.management.ModMailThreadManagementService;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+@Slf4j
+public class ModmailReminderListener implements ModmailThreadActionListener {
+
+    @Autowired
+    private ChannelService channelService;
+
+    @Autowired
+    private TemplateService templateService;
+
+    @Autowired
+    private ModMailThreadManagementService modMailThreadManagementService;
+
+    @Autowired
+    private ConfigService configService;
+
+    @Autowired
+    private FeatureModeService featureModeService;
+
+    @Autowired
+    private ModMailRoleManagementService modMailRoleManagementService;
+
+    @Autowired
+    private ModmailReminderListener self;
+
+    private static final String MODMAIL_THREAD_REMINDER_TEMPLATE_KEY = "modmail_thread_reminder_notification";
+
+    @Override
+    public Integer getPriority() {
+        return ListenerPriority.MEDIUM;
+    }
+
+    @Override
+    public ModmailThreadActionListenerResult execute(ModmailThreadActionListenerModel model) {
+        ModmailThreadActionListenerResult result;
+        if(!featureModeService.featureModeActive(ModMailFeatureDefinition.MOD_MAIL, model.getServerId(), ModMailMode.THREAD_REMINDER)) {
+            result = ModmailThreadActionListenerResult.IGNORED;
+        } else {
+            String reminderDurationString = configService.getStringValueOrConfigDefault(ModMailFeatureConfig.MOD_MAIL_REMINDER_DURATION, model.getServerId());
+            Duration duration = ParseUtils.parseDuration(reminderDurationString);
+            Instant timeInPastDuration = Instant.now().minus(duration);
+            ModMailThread thread = modMailThreadManagementService.getById(model.getThreadId());
+            if(List.of(ModMailThreadState.CLOSED, ModMailThreadState.CLOSING).contains(thread.getState())) {
+                log.debug("Thread {} is closed - ignoring.", model.getThreadId());
+                return ModmailThreadActionListenerResult.IGNORED;
+            }
+            Instant timeStampToConsider = getTimestampToUse(thread);
+            boolean mustBeReminded = timeInPastDuration.isAfter(timeStampToConsider);
+            if (mustBeReminded) {
+                    sendReminder(thread)
+                        .thenAccept(unused -> {
+                            self.updateSnoozeTimer(model.getThreadId(), duration);
+                            log.info("Sent reminder about thread {}", model.getThreadId());
+                        })
+                    .exceptionally(throwable -> {
+                        log.warn("Failed to send reminder about thread {}.", model.getThreadId(), throwable);
+                        return null;
+                    });
+                    result = ModmailThreadActionListenerResult.PROCESSED;
+                } else {
+                    result = ModmailThreadActionListenerResult.IGNORED;
+                }
+        }
+
+        return result;
+    }
+
+
+    private static Instant getTimestampToUse(ModMailThread thread) {
+        if (thread.getRemindersSnoozedUntil() != null) {
+            return thread.getRemindersSnoozedUntil();
+        }
+        return getUpdatedOrCrated(thread);
+    }
+
+    private static Instant getUpdatedOrCrated(ModMailThread thread) {
+        if(thread.getUpdated() != null) {
+            return thread.getUpdated();
+        }
+        return thread.getCreated();
+    }
+
+    private CompletableFuture<Void> sendReminder(ModMailThread modMailThread) {
+        List<ModMailRole> modmailRolesToPing = modMailRoleManagementService.getRolesForServer(modMailThread.getServer());
+        List<RoleDisplay> rolesToDisplay = modmailRolesToPing.stream().map(role -> RoleDisplay.fromARole(role.getRole())).toList();
+        Instant autoCloseInstant;
+        if(featureModeService.featureModeActive(ModMailFeatureDefinition.MOD_MAIL, modMailThread.getServer().getId(), ModMailMode.THREAD_AUTO_CLOSE)
+            && !modMailThread.getState().equals(ModMailThreadState.PAUSED)) {
+            String closeDurationString = configService.getStringValueOrConfigDefault(ModMailFeatureConfig.MOD_MAIL_AUTO_CLOSE_DURATION, modMailThread.getServer().getId());
+            Duration autoCloseDuration = ParseUtils.parseDuration(closeDurationString);
+            autoCloseInstant = getUpdatedOrCrated(modMailThread).plus(autoCloseDuration);
+        } else {
+            autoCloseInstant = null;
+        }
+        ModmailThreadReminderModel model = ModmailThreadReminderModel
+            .builder()
+            .updated(getUpdatedOrCrated(modMailThread))
+            .created(modMailThread.getCreated())
+            .paused(modMailThread.getState().equals(ModMailThreadState.PAUSED))
+            .autoCloseInstant(autoCloseInstant)
+            .pingRoles(rolesToDisplay)
+            .memberDisplay(MemberDisplay.fromAUserInAServer(modMailThread.getUser()))
+            .build();
+        MessageToSend messageToSend = templateService.renderEmbedTemplate(MODMAIL_THREAD_REMINDER_TEMPLATE_KEY, model, modMailThread.getServer().getId());
+        return FutureUtils.toSingleFutureGeneric(channelService.sendMessageEmbedToSendToAChannel(messageToSend, modMailThread.getChannel()));
+    }
+
+    @Transactional
+    public void updateSnoozeTimer(long modmailThreadId, Duration duration) {
+        ModMailThread thread = modMailThreadManagementService.getById(modmailThreadId);
+        thread.setRemindersSnoozedUntil(Instant.now().plus(duration));
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/repository/ModMailThreadRepository.java

@@ -36,6 +36,7 @@ public interface ModMailThreadRepository extends JpaRepository<ModMailThread, Lo
     boolean existsByUserAndStateNot(AUserInAServer userInAServer, ModMailThreadState state);
 
     List<ModMailThread> findByUserAndState(AUserInAServer userInAServer, ModMailThreadState state);
+    List<ModMailThread> findByStateNot(ModMailThreadState state);
 
     @Override
     Optional<ModMailThread> findById(@NonNull Long aLong);

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/service/ModMailThreadServiceBean.java

@@ -15,6 +15,7 @@ import dev.sheldan.abstracto.core.service.*;
 import dev.sheldan.abstracto.core.service.management.ChannelManagementService;
 import dev.sheldan.abstracto.core.service.management.ServerManagementService;
 import dev.sheldan.abstracto.core.service.management.UserInServerManagementService;
+import dev.sheldan.abstracto.core.utils.BeanUtils;
 import dev.sheldan.abstracto.core.utils.CompletableFutureList;
 import dev.sheldan.abstracto.core.utils.FutureUtils;
 import dev.sheldan.abstracto.core.utils.SnowflakeUtils;
@@ -26,9 +27,11 @@ import dev.sheldan.abstracto.modmail.config.ModMailPostTargets;
 import dev.sheldan.abstracto.modmail.exception.ModMailCategoryIdException;
 import dev.sheldan.abstracto.modmail.exception.ModMailThreadChannelNotFound;
 import dev.sheldan.abstracto.modmail.exception.ModMailThreadNotFoundException;
+import dev.sheldan.abstracto.modmail.listener.ModmailThreadActionListener;
 import dev.sheldan.abstracto.modmail.model.ClosingContext;
 import dev.sheldan.abstracto.modmail.model.dto.ServiceChoicesPayload;
 import dev.sheldan.abstracto.modmail.model.database.*;
+import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadActionListenerModel;
 import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadCreatedSendMessageModel;
 import dev.sheldan.abstracto.modmail.model.template.*;
 import dev.sheldan.abstracto.modmail.service.management.ModMailMessageManagementService;
@@ -50,6 +53,7 @@ import org.apache.commons.lang3.RandomStringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.PostConstruct;
@@ -166,6 +170,9 @@ public class ModMailThreadServiceBean implements ModMailThreadService {
     @Autowired
     private ApplicationEventPublisher eventPublisher;
 
+    @Autowired
+    private List<ModmailThreadActionListener> threadActionListeners;
+
     public static final String MODMAIL_THREAD_METRIC = "modmail.threads";
     public static final String MODMAIL_MESSAGE_METRIC = "modmail.messges";
     public static final String ACTION = "action";
@@ -269,6 +276,45 @@ public class ModMailThreadServiceBean implements ModMailThreadService {
         return FutureUtils.toSingleFutureGeneric(interactionService.sendMessageToInteraction(MODMAIL_THREAD_CREATED_TEMPLATE_KEY, model, interactionHook));
     }
 
+    @Transactional
+    public void checkModmailActionsForNeededActions() {
+        List<ModMailThread> allOpenThreads = modMailThreadManagementService.getAllOpenThreads();
+        allOpenThreads.forEach(thread -> {
+            ModmailThreadActionListenerModel model = ModmailThreadActionListenerModel
+                .builder()
+                .threadId(thread.getId())
+                .state(thread.getState())
+                .appeal(thread.getAppeal())
+                .serverId(thread.getServer().getId())
+                .serverUser(ServerUser.fromAUserInAServer(thread.getUser()))
+                .messageCount(thread.getMessages() != null ? thread.getMessages().size() : 0)
+                .updated(thread.getLastUpdated())
+                .created(thread.getCreated())
+                .subscriberCount(thread.getSubscribers() != null ? thread.getSubscribers().size() : 0)
+                .build();
+            for (ModmailThreadActionListener modmailThreadActionListener : threadActionListeners) {
+                try {
+                    log.info("Executing action {} for thread {}.", modmailThreadActionListener.getClass().getSimpleName(), model.getThreadId());
+                    ModmailThreadActionListener.ModmailThreadActionListenerResult result =
+                        self.executeThreadAction(modmailThreadActionListener, model);
+                    if(ModmailThreadActionListener.ModmailThreadActionListenerResult.FINAL == result) {
+                        log.info("Listener {} terminated for thread {}.", modmailThreadActionListener.getClass().getSimpleName(), model.getThreadId());
+                        break;
+                    }
+                } catch (Exception exception) {
+                    log.error("Action failed to execute for thread {}.", thread.getId(), exception);
+                }
+
+            }
+        });
+    }
+
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public ModmailThreadActionListener.ModmailThreadActionListenerResult executeThreadAction(
+        ModmailThreadActionListener modmailThreadActionListener, ModmailThreadActionListenerModel model) {
+        return modmailThreadActionListener.execute(model);
+    }
+
     /**
      * This method is responsible for creating the instance in the database, sending the header in the newly created text channel and forwarding the initial message
      * by the user (if any), after this is complete, this method executes the method to perform the mod mail notification.
@@ -808,6 +854,27 @@ public class ModMailThreadServiceBean implements ModMailThreadService {
         return isModMailThread(channel);
     }
 
+    @Override
+    public void snoozeThreadReminder(ModMailThread thread, Duration snoozeDuration) {
+        Instant snoozeTargetDate = Instant.now().plus(snoozeDuration);
+        log.info("Snoozing Thread {} until {}.", thread.getId(), snoozeTargetDate);
+        thread.setRemindersSnoozedUntil(snoozeTargetDate);
+    }
+
+    @Override
+    public void setPauseOfThreadTo(ModMailThread thread, boolean paused) {
+        if(thread.getState().equals(ModMailThreadState.PAUSED) && !paused) {
+            thread.setState(thread.getPreviousState());
+            thread.setPreviousState(null);
+        }
+        if(!thread.getState().equals(ModMailThreadState.PAUSED) && paused) {
+            thread.setPreviousState(thread.getState());
+            thread.setState(ModMailThreadState.PAUSED);
+        }
+
+        log.info("Thread {} has state {} and previous state {}.", thread.getId(), thread.getState(), thread.getPreviousState());
+    }
+
     /**
      * This method takes the actively loaded futures, calls the method responsible for logging the messages, and calls the method
      * after the logging has been done.
@@ -1127,5 +1194,6 @@ public class ModMailThreadServiceBean implements ModMailThreadService {
         metricService.registerCounter(MODMAIL_THREAD_CLOSED_COUNTER, "Mod mail threads closed");
         metricService.registerCounter(MDOMAIL_THREAD_MESSAGE_RECEIVED, "Mod mail messages received");
         metricService.registerCounter(MDOMAIL_THREAD_MESSAGE_SENT, "Mod mail messages sent");
+        BeanUtils.sortPrioritizedListeners(threadActionListeners);
     }
 }

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/java/dev/sheldan/abstracto/modmail/service/management/ModMailThreadManagementServiceBean.java

@@ -89,6 +89,11 @@ public class ModMailThreadManagementServiceBean implements ModMailThreadManageme
         return modMailThreadRepository.findByUser(aUserInAServer);
     }
 
+    @Override
+    public List<ModMailThread> getAllOpenThreads() {
+        return modMailThreadRepository.findByStateNot(ModMailThreadState.CLOSED);
+    }
+
     @Override
     public ModMailThread getLatestModMailThread(AUserInAServer aUserInAServer) {
         return modMailThreadRepository.findTopByUserOrderByClosedDesc(aUserInAServer);
@@ -111,6 +116,7 @@ public class ModMailThreadManagementServiceBean implements ModMailThreadManageme
                 .user(userInAServer)
                 .server(userInAServer.getServerReference())
                 .state(ModMailThreadState.INITIAL)
+                .lastUpdated(Instant.now())
                 .updated(Instant.now())
                 .appeal(appeal)
                 .build();
@@ -123,7 +129,12 @@ public class ModMailThreadManagementServiceBean implements ModMailThreadManageme
 
     @Override
     public void setModMailThreadState(ModMailThread modMailThread, ModMailThreadState newState) {
-        modMailThread.setState(newState);
+        if(modMailThread.getState().equals(ModMailThreadState.PAUSED)) {
+            modMailThread.setPreviousState(newState);
+        } else {
+            modMailThread.setState(newState);
+        }
+        modMailThread.setLastUpdated(Instant.now());
         modMailThread.setUpdated(Instant.now());
         modMailThreadRepository.save(modMailThread);
     }

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/collection.xml

@@ -0,0 +1,7 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="tables/tables.xml" relativeToChangelogFile="true"/>
+    <include file="seedData/data.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/seedData/command.xml

@@ -0,0 +1,21 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <property name="modmailModule" value="(SELECT id FROM module WHERE name = 'modmail')"/>
+    <property name="modmailFeature" value="(SELECT id FROM feature WHERE key = 'modmail')"/>
+
+    <changeSet author="Sheldan" id="modmail_thread_action_commands">
+        <insert tableName="command">
+            <column name="name" value="snoozeThreadReminder"/>
+            <column name="module_id" valueComputed="${modmailModule}"/>
+            <column name="feature_id" valueComputed="${modmailFeature}"/>
+        </insert>
+        <insert tableName="command">
+            <column name="name" value="setThreadPause"/>
+            <column name="module_id" valueComputed="${modmailModule}"/>
+            <column name="feature_id" valueComputed="${modmailFeature}"/>
+        </insert>
+    </changeSet>
+
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/seedData/data.xml

@@ -0,0 +1,7 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="modmail_action_job.xml" relativeToChangelogFile="true"/>
+    <include file="command.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/seedData/modmail_action_job.xml

@@ -0,0 +1,15 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <changeSet  author="Sheldan"  id="modmail_action_job-insert">
+        <insert tableName="scheduler_job">
+            <column name="name" value="modmailActionJob"/>
+            <column name="group_name" value="modmail"/>
+            <column name="clazz" value="dev.sheldan.abstracto.modmail.job.ModmailThreadActionJob"/>
+            <column name="active" value="true"/>
+            <column name="cron_expression" value="0 0 0 * * ?"/>
+            <column name="recovery" value="false"/>
+        </insert>
+    </changeSet>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/tables/modmail_thread.xml

@@ -0,0 +1,15 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <changeSet author="Sheldan" id="mod_mail_thread-add_columns_for_modmail_thread_actions">
+        <addColumn tableName="mod_mail_thread">
+            <column name="reminders_snoozed_until" type="TIMESTAMP WITHOUT TIME ZONE" defaultValueComputed="CURRENT_TIMESTAMP">
+                <constraints nullable="true" />
+            </column>
+            <column name="previous_state" type="VARCHAR(255)">
+                <constraints nullable="true"/>
+            </column>
+        </addColumn>
+    </changeSet>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.22/tables/tables.xml

@@ -0,0 +1,6 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="modmail_thread.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.23/collection.xml

@@ -0,0 +1,6 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="tables/tables.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.23/tables/modmail_thread.xml

@@ -0,0 +1,12 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <changeSet author="Sheldan" id="mod_mail_thread-add_last_updated_column">
+        <addColumn tableName="mod_mail_thread">
+            <column name="last_updated" type="TIMESTAMP WITHOUT TIME ZONE" defaultValueComputed="CURRENT_TIMESTAMP">
+                <constraints nullable="true" />
+            </column>
+        </addColumn>
+    </changeSet>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/1.6.23/tables/tables.xml

@@ -0,0 +1,6 @@
+<?xml version="1.1" encoding="UTF-8" standalone="no"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                     xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog https://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.26.xsd" >
+    <include file="modmail_thread.xml" relativeToChangelogFile="true"/>
+</databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/migrations/modMail-changeLog.xml

@@ -5,4 +5,6 @@
     <include file="1.0-modmail/collection.xml" relativeToChangelogFile="true"/>
     <include file="1.5.37/collection.xml" relativeToChangelogFile="true"/>
     <include file="1.5.51/collection.xml" relativeToChangelogFile="true"/>
+    <include file="1.6.22/collection.xml" relativeToChangelogFile="true"/>
+    <include file="1.6.23/collection.xml" relativeToChangelogFile="true"/>
 </databaseChangeLog>

abstracto-application/abstracto-modules/modmail/modmail-impl/src/main/resources/modmail-config.properties

@@ -4,6 +4,12 @@ abstracto.systemConfigs.modMailClosingText.stringValue=Thread has been closed.
 abstracto.systemConfigs.modmailCategory.name=modmailCategory
 abstracto.systemConfigs.modmailCategory.longValue=0
 
+abstracto.systemConfigs.modMailReminderDuration.name=modMailReminderDuration
+abstracto.systemConfigs.modMailReminderDuration.stringValue=3d
+
+abstracto.systemConfigs.modMailAutoCloseDuration.name=modMailAutoCloseDuration
+abstracto.systemConfigs.modMailAutoCloseDuration.stringValue=14d
+
 abstracto.featureFlags.modmail.featureName=modmail
 abstracto.featureFlags.modmail.enabled=false
 
@@ -28,4 +34,12 @@ abstracto.featureModes.modMailAppeals.mode=modMailAppeals
 abstracto.featureModes.modMailAppeals.enabled=false
 
 abstracto.systemConfigs.modMailAppealServer.name=modMailAppealServer
-abstracto.systemConfigs.modMailAppealServer.longValue=0
+abstracto.systemConfigs.modMailAppealServer.longValue=0
+
+abstracto.featureModes.threadReminder.featureName=modmail
+abstracto.featureModes.threadReminder.mode=threadReminder
+abstracto.featureModes.threadReminder.enabled=false
+
+abstracto.featureModes.threadAutoClose.featureName=modmail
+abstracto.featureModes.threadAutoClose.mode=threadAutoClose
+abstracto.featureModes.threadAutoClose.enabled=false

abstracto-application/abstracto-modules/modmail/modmail-impl/src/test/java/dev/sheldan/abstracto/modmail/listener/ModmailReminderListenerTest.java

@@ -0,0 +1,134 @@
+package dev.sheldan.abstracto.modmail.listener;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import dev.sheldan.abstracto.core.models.database.AServer;
+import dev.sheldan.abstracto.core.models.database.AUser;
+import dev.sheldan.abstracto.core.models.database.AUserInAServer;
+import dev.sheldan.abstracto.core.service.ChannelService;
+import dev.sheldan.abstracto.core.service.ConfigService;
+import dev.sheldan.abstracto.core.service.FeatureModeService;
+import dev.sheldan.abstracto.core.templating.model.MessageToSend;
+import dev.sheldan.abstracto.core.templating.service.TemplateService;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureConfig;
+import dev.sheldan.abstracto.modmail.config.ModMailFeatureDefinition;
+import dev.sheldan.abstracto.modmail.config.ModMailMode;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadActionListenerModel;
+import dev.sheldan.abstracto.modmail.service.management.ModMailRoleManagementService;
+import dev.sheldan.abstracto.modmail.service.management.ModMailThreadManagementService;
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
+import java.util.List;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.junit.MockitoJUnitRunner;
+
+@RunWith(MockitoJUnitRunner.class)
+public class ModmailReminderListenerTest {
+    @InjectMocks
+    private ModmailReminderListener unitUnderTest;
+
+    @Mock
+    private ChannelService channelService;
+
+    @Mock
+    private TemplateService templateService;
+
+    @Mock
+    private ModMailThreadManagementService modMailThreadManagementService;
+
+    @Mock
+    private ConfigService configService;
+
+    @Mock
+    private FeatureModeService featureModeService;
+
+    @Mock
+    private ModMailRoleManagementService modMailRoleManagementService;
+
+    private static final long SERVER_ID = 1L;
+    private static final long THREAD_ID = 2L;
+    private static final long USER_ID = 3L;
+
+    @Before
+    public void setup() {
+        when(featureModeService.featureModeActive(ModMailFeatureDefinition.MOD_MAIL, SERVER_ID, ModMailMode.THREAD_REMINDER)).thenReturn(true);
+        when(configService.getStringValueOrConfigDefault(ModMailFeatureConfig.MOD_MAIL_REMINDER_DURATION, SERVER_ID)).thenReturn("5m");
+        MessageToSend messageToSend = MessageToSend
+            .builder()
+            .build();
+        when(templateService.renderEmbedTemplate(anyString(), any(), any())).thenReturn(messageToSend);
+        when(modMailRoleManagementService.getRolesForServer(any())).thenReturn(List.of());
+    }
+
+    @Test
+    public void executeInitialReminder() {
+        Instant updatedTimeStamp = Instant.now().minus(10, ChronoUnit.MINUTES);
+        Instant snoozedUntil = Instant.now().minus(1, ChronoUnit.SECONDS);
+        executeTest(updatedTimeStamp, snoozedUntil, true);
+    }
+
+    @Test
+    public void shouldNotExecuteAfterSnoozing() {
+        Instant updatedTimeStamp = Instant.now().minus(10, ChronoUnit.MINUTES);
+        Instant snoozedUntil = Instant.now().plus(5, ChronoUnit.MINUTES);
+        executeTest(updatedTimeStamp, snoozedUntil, false);
+    }
+
+    @Test
+    public void shouldExecuteAfterSnoozingButSnoozingHasPassed() {
+        Instant updatedTimeStamp = Instant.now().minus(25, ChronoUnit.MINUTES);
+        Instant snoozedUntil = Instant.now().minus(2, ChronoUnit.MINUTES);
+        executeTest(updatedTimeStamp, snoozedUntil, true);
+    }
+
+    private void executeTest(Instant updatedTimeStamp, Instant snoozedUntil, boolean shouldExecute) {
+        ModMailThread thread = Mockito.mock(ModMailThread.class);
+        when(thread.getUpdated()).thenReturn(updatedTimeStamp);
+        when(thread.getRemindersSnoozedUntil()).thenReturn(snoozedUntil);
+        AUser user = AUser
+            .builder()
+            .id(USER_ID)
+            .build();
+        AServer server = AServer
+            .builder()
+            .id(SERVER_ID)
+            .build();
+        AUserInAServer aUserInAServer = AUserInAServer
+            .builder()
+            .serverReference(server)
+            .userReference(user)
+            .userInServerId(USER_ID)
+            .build();
+        when(thread.getServer()).thenReturn(server);
+        when(thread.getUser()).thenReturn(aUserInAServer);
+        when(modMailThreadManagementService.getById(THREAD_ID)).thenReturn(thread);
+
+        ModmailThreadActionListenerModel model = getModel();
+
+        unitUnderTest.execute(model);
+        if(shouldExecute) {
+            verify(channelService).sendMessageEmbedToSendToAChannel(any(), any());
+        } else {
+            verify(channelService, times(0)).sendMessageEmbedToSendToAChannel(any(), any());
+        }
+    }
+
+    private static ModmailThreadActionListenerModel getModel() {
+        return ModmailThreadActionListenerModel
+            .builder()
+            .serverId(SERVER_ID)
+            .threadId(THREAD_ID)
+            .build();
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>modmail</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/config/ModMailFeatureConfig.java

@@ -22,6 +22,8 @@ public class ModMailFeatureConfig implements FeatureConfig {
 
     public static final String MOD_MAIL_CLOSING_TEXT_SYSTEM_CONFIG_KEY = "modMailClosingText";
     public static final String MOD_MAIL_APPEAL_SERVER = "modMailAppealServer";
+    public static final String MOD_MAIL_REMINDER_DURATION = "modMailReminderDuration";
+    public static final String MOD_MAIL_AUTO_CLOSE_DURATION = "modMailAutoCloseDuration";
     @Autowired
     private ModMailFeatureValidator modMailFeatureValidator;
 
@@ -55,13 +57,18 @@ public class ModMailFeatureConfig implements FeatureConfig {
         return List.of(ModMailMode.LOGGING,
                 ModMailMode.SEPARATE_MESSAGE,
                 ModMailMode.THREAD_CONTAINER,
-                ModMailMode.MOD_MAIL_APPEALS
+                ModMailMode.MOD_MAIL_APPEALS,
+                ModMailMode.THREAD_AUTO_CLOSE,
+                ModMailMode.THREAD_REMINDER
         );
     }
 
     @Override
     public List<String> getRequiredSystemConfigKeys() {
-        return List.of(MOD_MAIL_CLOSING_TEXT_SYSTEM_CONFIG_KEY, MOD_MAIL_APPEAL_SERVER);
+        return List.of(MOD_MAIL_CLOSING_TEXT_SYSTEM_CONFIG_KEY,
+            MOD_MAIL_APPEAL_SERVER,
+            MOD_MAIL_REMINDER_DURATION,
+            MOD_MAIL_AUTO_CLOSE_DURATION);
     }
 
     @Override

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/config/ModMailMode.java

@@ -12,6 +12,8 @@ public enum  ModMailMode implements FeatureMode {
     LOGGING("log"),
     SEPARATE_MESSAGE("threadMessage"),
     THREAD_CONTAINER("threadContainer"),
+    THREAD_REMINDER("threadReminder"),
+    THREAD_AUTO_CLOSE("threadAutoClose"),
     MOD_MAIL_APPEALS("modMailAppeals");
 
     private final String key;

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/listener/ModmailThreadActionListener.java

@@ -0,0 +1,14 @@
+package dev.sheldan.abstracto.modmail.listener;
+
+import dev.sheldan.abstracto.core.Prioritized;
+import dev.sheldan.abstracto.core.listener.AbstractoListener;
+import dev.sheldan.abstracto.core.listener.ListenerExecutionResult;
+import dev.sheldan.abstracto.modmail.model.listener.ModmailThreadActionListenerModel;
+
+public interface ModmailThreadActionListener extends
+    AbstractoListener<ModmailThreadActionListenerModel, ModmailThreadActionListener.ModmailThreadActionListenerResult>, Prioritized {
+
+    enum ModmailThreadActionListenerResult implements ListenerExecutionResult {
+        FINAL, IGNORED, PROCESSED
+    }
+}

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/model/database/ModMailThread.java

@@ -56,9 +56,15 @@ public class ModMailThread implements Serializable {
     @Column(name = "updated", insertable = false, updatable = false)
     private Instant updated;
 
+    @Column(name = "last_updated")
+    private Instant lastUpdated;
+
     @Column(name = "closed")
     private Instant closed;
 
+    @Column(name = "reminders_snoozed_until")
+    private Instant remindersSnoozedUntil;
+
     @Column(name = "appeal", nullable = false)
     private Boolean appeal;
 
@@ -92,4 +98,8 @@ public class ModMailThread implements Serializable {
     @Column(name = "state")
     private ModMailThreadState state;
 
+    @Enumerated(EnumType.STRING)
+    @Column(name = "previous_state")
+    private ModMailThreadState previousState;
+
 }

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/model/database/ModMailThreadState.java

@@ -13,6 +13,10 @@ public enum ModMailThreadState {
      * Staff member responded to the mod mail thread
      */
     MOD_REPLIED,
+    /**
+     * Staff member paused the thread to not be closed
+     */
+    PAUSED,
     /**
      * The thread was closed by a staff member and the channel was removed
      */

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/model/listener/ModmailThreadActionListenerModel.java

@@ -0,0 +1,27 @@
+package dev.sheldan.abstracto.modmail.model.listener;
+
+import dev.sheldan.abstracto.core.listener.ListenerModel;
+import dev.sheldan.abstracto.core.models.ServerUser;
+import dev.sheldan.abstracto.modmail.model.database.ModMailThreadState;
+import java.time.Instant;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Builder
+public class ModmailThreadActionListenerModel implements ListenerModel {
+    private long threadId;
+    private ServerUser serverUser;
+    private long serverId;
+    private ModMailThreadState state;
+    private Boolean appeal;
+    private Instant created;
+    private Instant updated;
+    private long messageCount;
+    private long subscriberCount;
+    private long channelId;
+
+
+}

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/model/template/ModmailThreadReminderModel.java

@@ -0,0 +1,21 @@
+package dev.sheldan.abstracto.modmail.model.template;
+
+import dev.sheldan.abstracto.core.models.template.display.MemberDisplay;
+import dev.sheldan.abstracto.core.models.template.display.RoleDisplay;
+import java.time.Instant;
+import java.util.List;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Builder
+public class ModmailThreadReminderModel {
+    private List<RoleDisplay> pingRoles;
+    private MemberDisplay memberDisplay;
+    private Instant autoCloseInstant;
+    private boolean paused;
+    private Instant created;
+    private Instant updated;
+}

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/service/ModMailThreadService.java

@@ -8,6 +8,7 @@ import dev.sheldan.abstracto.core.models.database.AUserInAServer;
 import dev.sheldan.abstracto.core.templating.model.MessageToSend;
 import dev.sheldan.abstracto.modmail.model.ClosingContext;
 import dev.sheldan.abstracto.modmail.model.database.ModMailThread;
+import java.time.Duration;
 import net.dv8tion.jda.api.entities.*;
 import net.dv8tion.jda.api.entities.channel.middleman.MessageChannel;
 import net.dv8tion.jda.api.interactions.InteractionHook;
@@ -103,6 +104,8 @@ public interface ModMailThreadService {
 
     boolean isModMailThread(AChannel channel);
     boolean isModMailThread(Long channelId);
+    void snoozeThreadReminder(ModMailThread thread, Duration snoozeDuration);
+    void setPauseOfThreadTo(ModMailThread thread, boolean paused);
 
     CompletableFuture<Void> rejectAppeal(ModMailThread modMailThread, String reason, Member memberPerforming);
 }

abstracto-application/abstracto-modules/modmail/modmail-int/src/main/java/dev/sheldan/abstracto/modmail/service/management/ModMailThreadManagementService.java

@@ -91,6 +91,7 @@ public interface ModMailThreadManagementService {
      * @return A list of {@link ModMailThread} which contains all the current mod mail threads for the member, should be at most one
      */
     List<ModMailThread> getModMailThreadForUser(AUserInAServer aUserInAServer);
+    List<ModMailThread> getAllOpenThreads();
 
     /**
      * Retrieves the *latest* {@link ModMailThread} of the {@link AUserInAServer}, which means, the latest thread which is in the state

abstracto-application/abstracto-modules/modmail/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto</groupId>
         <artifactId>abstracto-application</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/profanity-filter/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/profanity-filter/profanity-filter-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>profanity-filter</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/profanity-filter/profanity-filter-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>profanity-filter</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/remind/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/remind/remind-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>remind</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/remind/remind-impl/src/main/java/dev/sheldan/abstracto/remind/service/RemindServiceBean.java

@@ -130,13 +130,14 @@ public class RemindServiceBean implements ReminderService {
         if(remindIn.getSeconds() < 60) {
             reminder.setJobTriggerKey(null);
             log.info("Directly scheduling unremind for reminder {}, because it was below the threshold.", reminder.getId());
+            long nanos = Math.max(remindIn.toNanos(), Duration.ofSeconds(5).toNanos()); // should be good enough, if its too small, it doesnt find the reminder
             instantReminderScheduler.schedule(() -> {
                 try {
                     self.executeReminder(reminder.getId());
                 } catch (Exception exception) {
                     log.error("Failed to remind immediately.", exception);
                 }
-            }, remindIn.toNanos(), TimeUnit.NANOSECONDS);
+            }, nanos, TimeUnit.NANOSECONDS);
         } else {
             HashMap<Object, Object> parameters = new HashMap<>();
             parameters.put("reminderId", reminder.getId().toString());

abstracto-application/abstracto-modules/remind/remind-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>remind</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/repost-detection/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/repost-detection/repost-detection-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>repost-detection</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/repost-detection/repost-detection-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>repost-detection</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/starboard/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>abstracto-modules</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/starboard/starboard-impl/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>starboard</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/starboard/starboard-int/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <artifactId>starboard</artifactId>
         <groupId>dev.sheldan.abstracto.modules</groupId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

abstracto-application/abstracto-modules/statistic/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>dev.sheldan.abstracto.modules</groupId>
         <artifactId>abstracto-modules</artifactId>
-        <version>1.6.19-SNAPSHOT</version>
+        <version>1.6.23-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>