[Update] added prefixRepository fucntion which has database methods

index.js

@@ -1,6 +1,7 @@
 const { Client, Collection, Intents } = require("discord.js");
 const { logger } = require("./modules/logger.js");
 const { token, mongourl } = require("./config.json");
+const { Database } = require("quickmongo");
 const { connectDatabase } = require("./modules/DatabaseConnection");
 const { commandsHelper } = require("./modules/commandsHelper");
 
@@ -20,6 +21,7 @@ const player = new Player(client);
 client.player = player;
 client.commands = new Collection();
 client.logger = logger;
+client.db = new Database(mongourl)
 
 // Register everything...
 commandsHelper.registerAllCommands(__dirname + "/commands", client);

package.json

@@ -26,6 +26,7 @@
     "discord.js": "^13.1.0",
     "ffmpeg-static": "^4.4.0",
     "moment": "^2.29.1",
+    "mongodb": "^4.1.2",
     "mongoose": "^6.0.8",
     "node-fetch": "^2.6.1",
     "play-dl": "^1.0.3",

repositories/PrefixRepository.js

@@ -0,0 +1,61 @@
+/***
+ * PrefixRepository
+ *
+ * We want to enable our bot to be able to remember custom prefixes for the 
+ * prefixed commands using mongodb.
+ */
+const { Collection: MongoCollection, MongoClient } = require("mongodb");
+const { Collection, Fields } = require("quickmongo");
+
+let prefixRepository = function (connectionString) {
+    let api = {};
+
+    api._connectionString = connectionString;
+
+    const schema = new Fields.ObjectField({
+        prefixe: new Fields.ArrayField(new Fields.StringField())
+    });
+
+    async function execute(callback) {
+        api._mongo = new MongoClient(api._connectionString);
+        api._mongo.connect().then(async() => {
+            console.log("Connected to the database!");
+            try {
+                 await callback();
+            } catch (error) {
+                console.log(error);
+            } finally {
+                await api._mongo.close();
+            }
+        });
+    }
+
+    api.getPrefixes = async function() {
+
+        return await execute( async() => {
+            const mongoCollection = api._mongo.db().collection("JSON");
+            const db = new Collection(mongoCollection, schema);
+
+            api.fetchedPrefixes = await db.get("prefixes");
+            return api.fetchedPrefixes
+        });
+
+    }
+
+    api.setPrefixes = async function(prefixes) {
+        await execute( async() => {
+            console.log("setting prefixes to " + prefixes);
+
+            const mongoCollection = api._mongo.db().collection("JSON");
+            const db = new Collection(mongoCollection, schema);
+
+            await db.set("prefixes", prefixes); 
+            console.log("complete");
+            return;
+        });
+    }
+
+    return api;
+};
+
+module.exports = prefixRepository;