added logging to several places concerning futures

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

@@ -41,7 +41,7 @@ public class MessageEmbedListener implements MessageReceivedListener {
             Consumer<CachedMessage> cachedMessageConsumer = cachedMessage -> messageEmbedService.embedLink(cachedMessage, message.getTextChannel(), cause, message);
             messageCache.getMessageFromCache(messageEmbedLink.getServerId(), messageEmbedLink.getChannelId(), messageEmbedLink.getMessageId()).thenAccept(cachedMessageConsumer)
                     .exceptionally(throwable -> {
-                        log.error("Error when embedding link.", throwable);
+                        log.error("Error when embedding link for message {}", message.getId(), throwable);
                         return null;
                     });
         }

abstracto-application/abstracto-modules/utility/utility-impl/src/main/java/dev/sheldan/abstracto/utility/service/MessageEmbedServiceBean.java

@@ -101,7 +101,10 @@ public class MessageEmbedServiceBean implements MessageEmbedService {
             messageCache.getMessageFromCache(messageEmbedLink.getServerId(), messageEmbedLink.getChannelId(), messageEmbedLink.getMessageId())
                     .thenAccept(cachedMessage ->
                         self.embedLink(cachedMessage, target, reason, embeddingMessage)
-                    )
+                    ).exceptionally(throwable -> {
+                log.error("Message retrieval from cache failed for message {}.", messageEmbedLink.getMessageId(), throwable);
+                return null;
+            })
         );
     }
 
@@ -121,6 +124,10 @@ public class MessageEmbedServiceBean implements MessageEmbedService {
             } catch (InterruptedException | ExecutionException e) {
                 log.error("Failed to post message embed.", e);
             }
+        }).exceptionally(throwable -> {
+            log.error("Failed to send message for embedding the link for message {} in channel {} in server {}",
+                    cachedMessage.getMessageId(), cachedMessage.getChannelId(), cachedMessage.getServerId(), throwable);
+            return null;
         });
 
     }

abstracto-application/abstracto-modules/utility/utility-impl/src/main/java/dev/sheldan/abstracto/utility/service/StarboardServiceBean.java

@@ -87,6 +87,9 @@ public class StarboardServiceBean implements StarboardService {
             } catch (InterruptedException | ExecutionException e) {
                 log.error("Failed to post messages.", e);
             }
+        }) .exceptionally(throwable -> {
+            log.error("Failed to create starboard post for message {} in channel {} in server {}", message.getMessageId(), message.getChannelId(), message.getServerId(), throwable);
+            return null;
         });
 
     }
@@ -125,6 +128,9 @@ public class StarboardServiceBean implements StarboardService {
             } catch (InterruptedException | ExecutionException e) {
                 log.error("Failed to post starboard post.", e);
             }
+        }).exceptionally(throwable -> {
+            log.error("Failed to update starboard post {}.", post.getId(), throwable);
+            return null;
         });
     }
 

abstracto-application/abstracto-modules/utility/utility-impl/src/main/java/dev/sheldan/abstracto/utility/service/SuggestionServiceBean.java

@@ -71,6 +71,9 @@ public class SuggestionServiceBean implements SuggestionService {
                 } catch (InterruptedException | ExecutionException e) {
                     log.warn("Failed to post suggestion", e);
                 }
+            }) .exceptionally(throwable -> {
+                log.error("Failed to post suggestion {}", suggestion.getId(), throwable);
+                return null;
             });
         } else {
             log.warn("Guild {} or member {} was not found when creating suggestion.", member.getGuild().getIdLong(), member.getIdLong());

abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/listener/MessageDeletedListenerBean.java

@@ -35,7 +35,12 @@ public class MessageDeletedListenerBean extends ListenerAdapter {
     @Transactional
     public void onGuildMessageDelete(@Nonnull GuildMessageDeleteEvent event) {
         Consumer<CachedMessage> cachedMessageConsumer = cachedMessage -> self.executeListener(cachedMessage);
-        messageCache.getMessageFromCache(event.getGuild().getIdLong(), event.getChannel().getIdLong(), event.getMessageIdLong()).thenAccept(cachedMessageConsumer);
+        messageCache.getMessageFromCache(event.getGuild().getIdLong(), event.getChannel().getIdLong(), event.getMessageIdLong())
+                .thenAccept(cachedMessageConsumer)
+                .exceptionally(throwable -> {
+                    log.error("Message retrieval {} from cache failed. ", event.getMessageIdLong(), throwable);
+                    return null;
+                });
     }
 
     @Transactional

abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/listener/MessageUpdatedListener.java

@@ -38,6 +38,9 @@ public class MessageUpdatedListener extends ListenerAdapter {
         messageCache.getMessageFromCache(message.getGuild().getIdLong(), message.getTextChannel().getIdLong(), event.getMessageIdLong()).thenAccept(cachedMessage -> {
             self.executeListener(message, cachedMessage);
             messageCache.putMessageInCache(message);
+        }).exceptionally(throwable -> {
+            log.error("Message retrieval {} from cache failed. ", event.getMessage().getId(), throwable);
+            return null;
         });
 
     }

abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/listener/ReactionUpdatedListener.java

@@ -63,7 +63,13 @@ public class ReactionUpdatedListener extends ListenerAdapter {
             future.thenAccept(reaction -> {
                 self.callAddedListeners(event, cachedMessage, reaction);
                 messageCache.putMessageInCache(cachedMessage);
+            }).exceptionally(throwable -> {
+                log.error("Failed to add reaction to message {} ", event.getMessageIdLong(), throwable);
+                return null;
             });
+        }).exceptionally(throwable -> {
+            log.error("Message retrieval {} from cache failed. ", event.getMessageIdLong(), throwable);
+            return null;
         });
     }
 
@@ -122,9 +128,15 @@ public class ReactionUpdatedListener extends ListenerAdapter {
             messageCache.getCachedReactionFromReaction(future, event.getReaction());
             future.thenAccept(reaction ->
                 self.callRemoveListeners(event, cachedMessage, reaction)
-            );
+            ) .exceptionally(throwable -> {
+                log.error("Failed to retrieve cached reaction for message {} ", event.getMessageIdLong(), throwable);
+                return null;
+            });
 
             messageCache.putMessageInCache(cachedMessage);
+        }).exceptionally(throwable -> {
+            log.error("Message retrieval {} from cache failed. ", event.getMessageIdLong(), throwable);
+            return null;
         });
     }
 
@@ -152,6 +164,9 @@ public class ReactionUpdatedListener extends ListenerAdapter {
         asyncMessageFromCache.thenAccept(cachedMessage -> {
             cachedMessage.getReactions().clear();
             messageCache.putMessageInCache(cachedMessage);
+        }) .exceptionally(throwable -> {
+            log.error("Message retrieval from cache failed for message {}", event.getMessageIdLong(), throwable);
+            return null;
         });
     }
 

abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/service/MessageCacheBean.java

@@ -127,7 +127,10 @@ public class MessageCacheBean implements MessageCache {
                     .timeCreated(Instant.from(message.getTimeCreated()))
                     .attachmentUrls(attachmentUrls)
                     .build())
-        );
+        ).exceptionally(throwable -> {
+            log.error("Failed to load reactions for message {}. ", message.getId(), throwable);
+            return null;
+        });
     }
 
     private List<CachedReaction> getFutures(List<CompletableFuture<CachedReaction>> futures) {
@@ -153,7 +156,11 @@ public class MessageCacheBean implements MessageCache {
         users.forEachAsync(user -> {
             ausers.add(AUser.builder().id(user.getIdLong()).build());
             return false;
-        }).thenAccept(o -> future.complete(builder.build()));
+        }).thenAccept(o -> future.complete(builder.build()))
+        .exceptionally(throwable -> {
+            log.error("Failed to load reaction users.", throwable);
+            return null;
+        });
         builder.users(ausers);
         builder.emote(emoteService.buildAEmoteFromReaction(reaction.getReactionEmote()));
     }

abstracto-application/core/core-impl/src/main/java/dev/sheldan/abstracto/core/service/PostTargetServiceBean.java

@@ -118,10 +118,16 @@ public class PostTargetServiceBean implements PostTargetService {
                     .queue(
                             existingMessage -> existingMessage
                                     .editMessage(messageToSend.getEmbeds().get(0))
-                                    .submit().thenAccept(message -> future.get(0).complete(message)),
+                                    .submit().thenAccept(message -> future.get(0).complete(message)).exceptionally(throwable -> {
+                                        log.error("Failed to edit message {}.", messageId, throwable);
+                                        return null;
+                                    }),
                             throwable ->
                                 sendEmbedInPostTarget(messageToSend, target).get(0)
-                                            .thenAccept(message -> future.get(0).complete(message))
+                                            .thenAccept(message -> future.get(0).complete(message)) .exceptionally(innerThrowable -> {
+                                    log.error("Failed to send message to create a message.", innerThrowable);
+                                    return null;
+                                })
                             );
         } else {
             textChannelForPostTarget
@@ -130,10 +136,16 @@ public class PostTargetServiceBean implements PostTargetService {
                             existingMessage -> existingMessage
                                     .editMessage(messageToSend.getMessage())
                                     .embed(messageToSend.getEmbeds().get(0))
-                                    .submit().thenAccept(message -> future.get(0).complete(message)),
+                                    .submit().thenAccept(message -> future.get(0).complete(message)).exceptionally(throwable -> {
+                                        log.error("Failed to edit message {}", messageId, throwable);
+                                        return null;
+                                    }),
                             throwable ->
                                 sendEmbedInPostTarget(messageToSend, target).get(0)
-                                            .thenAccept(message -> future.get(0).complete(message))
+                                            .thenAccept(message -> future.get(0).complete(message)).exceptionally(innerThrowable -> {
+                                    log.error("Failed to send message to create a message.", innerThrowable);
+                                    return null;
+                                })
                             );
         }
     }