added database

Author: java-coding-prodigy

application/src/main/java/org/togetherjava/tjbot/features/Features.java

@@ -1,6 +1,7 @@
 package org.togetherjava.tjbot.features;
 
 import net.dv8tion.jda.api.JDA;
+
 import org.togetherjava.tjbot.config.Config;
 import org.togetherjava.tjbot.db.Database;
 import org.togetherjava.tjbot.features.basic.PingCommand;
@@ -139,7 +140,7 @@ public static Collection<Feature> createFeatures(JDA jda, Database database, Con
         features.add(new GuildLeaveCloseThreadListener(config));
         features.add(new LeftoverBookmarksListener(bookmarksSystem));
         features.add(new HelpThreadCreatedListener(helpSystemHelper));
-        features.add(new Starboard(config));
+        features.add(new Starboard(config, database));
 
         // Message context commands
 

application/src/main/java/org/togetherjava/tjbot/features/basic/Starboard.java

@@ -16,17 +16,22 @@
 
 import org.togetherjava.tjbot.config.Config;
 import org.togetherjava.tjbot.config.StarboardConfig;
+import org.togetherjava.tjbot.db.Database;
 import org.togetherjava.tjbot.features.EventReceiver;
 
 import java.util.Optional;
 
+import static org.togetherjava.tjbot.db.generated.tables.StarboardMessages.STARBOARD_MESSAGES;
+
 public class Starboard extends ListenerAdapter implements EventReceiver {
 
     private static final Logger logger = LoggerFactory.getLogger(Starboard.class);
     private final StarboardConfig config;
+    private final Database database;
 
-    public Starboard(Config config) {
+    public Starboard(Config config, Database database) {
         this.config = config.getStarboard();
+        this.database = database;
     }
 
     @Override
@@ -42,6 +47,12 @@ public void onMessageReactionAdd(@NotNull MessageReactionAddEvent event) {
                     config.getChannelName());
             return;
         }
+        if (database.read(context -> context.selectFrom(STARBOARD_MESSAGES)
+            .fetch("message_id")
+            .contains(event.getMessageIdLong()))) {
+            database.write(context -> context.newRecord(STARBOARD_MESSAGES)
+                .setMessageId(event.getMessageIdLong()));
+        }
         event.retrieveMessage()
             .flatMap(
                     message -> starboardChannel.orElseThrow().sendMessageEmbeds(formEmbed(message)))

application/src/main/resources/db/V14__Add_Starboard.sql

@@ -0,0 +1,3 @@
+CREATE TABLE starboard_messages
+(message_id BIGINT NOT NULL PRIMARY KEY
+)