Sheldan/abstracto
1
0
Fork 0
mirror of https://github.com/Sheldan/abstracto.git synced 2026-04-16 04:21:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

[AB-243] when loading messages we ignore embed links part of a channel/guild which are not available anymore

Browse Source
This commit is contained in:
Sheldan
2021-05-01 12:31:27 +02:00
parent 5a6fac640e
commit fa864f85dd
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/service/MessageServiceBean.java
View File

@@ -126,14 +126,20 @@ public class MessageServiceBean implements MessageService {
.collect(Collectors.groupingBy(ServerChannelMessage::getServerId)); .collect(Collectors.groupingBy(ServerChannelMessage::getServerId));
serverMessages.forEach((serverId, channelMessagesNonGrouped) -> { serverMessages.forEach((serverId, channelMessagesNonGrouped) -> {
Guild guild = guildService.getGuildById(serverId); Guild guild = guildService.getGuildById(serverId);
// in case the gild is not available anymore, this would cause the job to fail
if(guild != null) {
Map<Long, List<ServerChannelMessage>> channelMessages = channelMessagesNonGrouped Map<Long, List<ServerChannelMessage>> channelMessages = channelMessagesNonGrouped
.stream() .stream()
.collect(Collectors.groupingBy(ServerChannelMessage::getChannelId)); .collect(Collectors.groupingBy(ServerChannelMessage::getChannelId));
channelMessages.forEach((channelId, serverChannelMessages) -> { channelMessages.forEach((channelId, serverChannelMessages) -> {
MessageChannel channel = guild.getTextChannelById(channelId); MessageChannel channel = guild.getTextChannelById(channelId);
// in case the channel was deleted, this would cause the job to fail
if(channel != null) {
serverChannelMessages.forEach(serverChannelMessage -> serverChannelMessages.forEach(serverChannelMessage ->
messageFutures.add(channelService.retrieveMessageInChannel(channel, serverChannelMessage.getMessageId()))); messageFutures.add(channelService.retrieveMessageInChannel(channel, serverChannelMessage.getMessageId())));
}
}); });
}
}); });
return messageFutures; return messageFutures;
} }