Fixed Message Cache Primary Key Violation

Author: jasonlessenich

src/main/java/net/javadiscord/javabot/data/h2db/message_cache/dao/MessageCacheRepository.java

@@ -2,6 +2,7 @@
 
 import lombok.RequiredArgsConstructor;
 import net.javadiscord.javabot.data.h2db.message_cache.model.CachedMessage;
+import org.jetbrains.annotations.NotNull;
 
 import java.sql.*;
 import java.util.ArrayList;
@@ -39,11 +40,12 @@ public boolean insert(CachedMessage message) throws SQLException {
 	 * @param messages The List to insert.
 	 * @throws SQLException If an error occurs.
 	 */
-	public void insertList(List<CachedMessage> messages) throws SQLException {
+	public void insertList(@NotNull List<CachedMessage> messages) throws SQLException {
+		List<CachedMessage> all = getAll();
 		try (PreparedStatement stmt = con.prepareStatement("INSERT INTO message_cache (message_id, author_id, message_content) VALUES (?, ?, ?)",
 				Statement.RETURN_GENERATED_KEYS
 		)) {
-			for (CachedMessage msg : messages) {
+			for (CachedMessage msg : messages.stream().filter(s -> !all.contains(s)).toList()) {
 				stmt.setLong(1, msg.getMessageId());
 				stmt.setLong(2, msg.getAuthorId());
 				stmt.setString(3, msg.getMessageContent());
@@ -59,7 +61,7 @@ public void insertList(List<CachedMessage> messages) throws SQLException {
 	 * @return Whether there were rows affected by this process.
 	 * @throws SQLException If an error occurs.
 	 */
-	public boolean update(CachedMessage message) throws SQLException {
+	public boolean update(@NotNull CachedMessage message) throws SQLException {
 		try (PreparedStatement stmt = con.prepareStatement("UPDATE message_cache SET message_content = ? WHERE message_id = ?",
 				Statement.RETURN_GENERATED_KEYS
 		)) {