Sheldan/abstracto
1
0
Fork 0
mirror of https://github.com/Sheldan/abstracto.git synced 2026-03-24 05:39:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

[AB-303] adding scheduled configurable activity updates

Browse Source
This commit is contained in:
Sheldan
2021-07-13 00:35:15 +02:00
parent c7514a6bad
commit ac605e4791
25 changed files with 1859 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/service/StartupServiceBean.java
View File

@@ -3,6 +3,7 @@ package dev.sheldan.abstracto.core.service;
import dev.sheldan.abstracto.core.command.model.database.ACommand;
import dev.sheldan.abstracto.core.command.service.management.CommandInServerManagementService;
import dev.sheldan.abstracto.core.command.service.management.CommandManagementService;
import dev.sheldan.abstracto.core.listener.AsyncStartupListener;
import dev.sheldan.abstracto.core.models.database.AChannel;
import dev.sheldan.abstracto.core.models.database.AChannelType;
import dev.sheldan.abstracto.core.models.database.ARole;
@@ -25,6 +26,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.security.auth.login.LoginException;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
@Slf4j
@@ -37,6 +39,12 @@ public class StartupServiceBean implements Startup {
@Autowired
private List<? extends ListenerAdapter> listeners;
@Autowired(required = false)
private List<AsyncStartupListener> startupListeners;
@Autowired
private StartupServiceBean self;
@Autowired
private ServerManagementService serverManagementService;
@@ -67,9 +75,37 @@ public class StartupServiceBean implements Startup {
log.info("Synchronizing servers.");
synchronizeServers();
log.info("Done synchronizing servers");
executeStartUpListeners();
profanityService.reloadRegex();
}
private void executeStartUpListeners() {
if(startupListeners == null) {
return;
}
log.info("Executing {} startup listeners.", startupListeners.size());
startupListeners.forEach(asyncStartupListener ->
CompletableFuture.runAsync(() -> {
try {
log.info("Executing startup listener {}.", asyncStartupListener);
self.executeStartupListener(asyncStartupListener);
} catch (Exception e) {
log.error("Startup listener {} failed.", asyncStartupListener);
}
}).thenAccept(unused -> log.info("Startup listener {} finished.", asyncStartupListener))
.exceptionally(throwable -> {
log.error("Startup listener {} failed.", asyncStartupListener);
return null;
})
);
}
@Transactional
public void executeStartupListener(AsyncStartupListener startupListener) {
startupListener.execute();
}
private void synchronizeServers(){
JDA instance = service.getInstance();
List<Guild> onlineGuilds = instance.getGuilds();

5
abstracto-application/core/core-int/src/main/java/dev/sheldan/abstracto/core/listener/AsyncStartupListener.java Normal file
View File

@@ -0,0 +1,5 @@
package dev.sheldan.abstracto.core.listener;
public interface AsyncStartupListener {
void execute();
}