feat: working test example

packages/gil/__tests__/bot_mongo/db/Server.ts

@@ -0,0 +1,21 @@
+import mongoose, { Schema, Document } from "mongoose";
+
+// This is for typescript
+export interface IServer extends Document {
+	server_id: string;
+	prefix: string;
+	premium_level: string;
+	staff_roles: string[];
+}
+
+// This is for mongodb to know what we are storing
+const ServerSchema: Schema = new Schema({
+	server_id: { type: String, required: true },
+	prefix: { type: String, required: false },
+	premium_level: { type: String, required: false, default: null },
+	staff_roles: { type: Array, required: false, default: [] },
+});
+
+const Server = mongoose.model<IServer>("Server", ServerSchema);
+
+export default Server;

packages/gil/__tests__/bot_mongo/docker-compose.yaml

@@ -0,0 +1,15 @@
+version: '3'
+services:
+  mongo:
+    image: mongo:4.2.5
+    ports:
+      - '27017:27017'
+    environment:
+      MONGO_INITDB_ROOT_USERNAME: guildedjs
+      MONGO_INITDB_ROOT_PASSWORD: testpass
+      MONGO_INITDB_DATABASE: guildedjs
+    volumes:
+      - mongo-vol:/data/db
+
+volumes:
+  mongo-vol:

packages/gil/__tests__/bot_mongo/index.ts

@@ -0,0 +1,28 @@
+import { join } from "path";
+import "dotenv/config";
+import { GilClient } from "../../lib/GilClient";
+import { MongoAdapter } from "../../lib/adapters/db/MongoAdapter";
+
+import mongoose from "mongoose";
+import Server from "./db/Server";
+
+mongoose.connect("mongodb://guildedjs:testpass@localhost:27017/", {
+	connectTimeoutMS: 5000,
+	retryWrites: true,
+	retryReads: true,
+	waitQueueTimeoutMS: 5000,
+	socketTimeoutMS: 5000,
+});
+
+const YokiBot = new GilClient({
+	token: process.env.TOKEN!,
+	commandDirectory: join(__dirname, "commands"),
+	listenerDirectory: join(__dirname, "listeners"),
+	databaseAdapter: new MongoAdapter({
+		serverModel: Server,
+		serverIdKey: "server_id",
+		serverStaffRolesKey: "staff_roles",
+	}),
+});
+
+YokiBot.start();

packages/gil/lib/adapters/db/DatabaseAdapter.ts

@@ -1,5 +1,6 @@
 export abstract class DatabaseAdapter {
 	public abstract getServer(serverId: string): Promise<StoredServer | null>;
+	public abstract createServer(serverId: string): Promise<StoredServer>;
 	public abstract getRoles(serverId: string): Promise<StoredRole[]>;
 }
 

packages/gil/lib/adapters/db/MongoAdapter.ts

@@ -3,41 +3,45 @@ import type mongoose from "mongoose";
 import { DatabaseAdapter, StoredRole, StoredServer } from "./DatabaseAdapter";
 
 export class MongoAdapter extends DatabaseAdapter {
-	serverModel: mongoose.Document;
-	serverIdKey: string;
-	serverStaffRolesKey: string;
-
-	public constructor(options: {
-		serverModel: mongoose.Document;
-		serverIdKey: string;
-		serverStaffRolesKey: string;
-	}) {
+	public constructor(
+		readonly options: {
+			serverModel: typeof mongoose.Model<mongoose.Document>;
+			serverIdKey: string;
+			serverStaffRolesKey: string;
+		},
+	) {
 		super();
-
-		this.serverModel = options.serverModel;
-		this.serverIdKey = options.serverIdKey;
-		this.serverStaffRolesKey = options.serverStaffRolesKey;
 	}
 
 	public async getServer(serverId: string): Promise<StoredServer | null> {
-		const server = await this.serverModel.findOne({
-			[this.serverIdKey]: serverId,
+		const server = await this.options.serverModel.findOne({
+			[this.options.serverIdKey]: serverId,
 		});
 		if (!server) return null;
 
 		return {
-			server_id: server[this.serverIdKey],
+			server_id: server[this.options.serverIdKey],
 			prefix: server.prefix,
 			premium_level: server.premium_level,
 		};
 	}
 
+	public async createServer(serverId: string): Promise<StoredServer> {
+		const server = await this.options.serverModel.create({
+			[this.options.serverIdKey]: serverId,
+			prefix: null,
+			premium_level: null,
+		});
+
+		return server;
+	}
+
 	public async getRoles(serverId: string): Promise<StoredRole[]> {
-		const server = await this.serverModel.findOne({ [this.serverIdKey]: serverId });
+		const server = await this.options.serverModel.findOne({ [this.options.serverIdKey]: serverId });
 		if (!server) return [];
 
-		if (!(this.serverStaffRolesKey in server)) return [];
-		const roles = server[this.serverStaffRolesKey as keyof typeof server] as StoredRole[];
+		if (!(this.options.serverStaffRolesKey in server)) return [];
+		const roles = server[this.options.serverStaffRolesKey as keyof typeof server] as StoredRole[];
 
 		return roles;
 	}

packages/gil/lib/defaults/MessageListener.ts

@@ -25,10 +25,10 @@ export default class MessageListener extends Listener {
 			return;
 		}
 
-		const server = await this.gil.db.getServer(message.serverId);
+		let server = await this.gil.db.getServer(message.serverId);
 		if (!server) {
-			this.gil.logger.debug("Server was not found", message.id);
-			return;
+			this.gil.logger.debug("Server was not found, creating...", message.id);
+			server = await this.gil.db.createServer(message.serverId);
 		}
 
 		const member = await this.gil.client.members.fetch(message.serverId, message.authorId);

packages/gil/lib/index.ts

@@ -5,5 +5,7 @@ export * from "./structures/Task";
 export * from "./structures/Manager";
 export * from "./adapters/logging/ConsoleAdapter";
 export * from "./adapters/logging/LoggerAdapter";
+export * from "./adapters/db/DatabaseAdapter";
+export * from "./adapters/db/MongoAdapter";
 // export * from "./adapters/logging/WinstonAdapter";
 // export * from "./adapters/logging/PinoAdapter";

packages/gil/package.json

@@ -14,7 +14,9 @@
     "release": "npm publish"
   },
   "devDependencies": {
+    "@types/mongoose": "^5.11.97",
     "dotenv": "^16.0.3",
+    "mongoose": "^8.2.3",
     "typescript": "5.0.4"
   },
   "dependencies": {
@@ -25,9 +27,6 @@
     "lexure": "^0.17.0",
     "typed-emitter": "^2.1.0"
   },
-  "peerDependencies": {
-    "mongoose": "8.2.3"
-  },
   "contributors": [
     {
       "name": "Zaid \"Nico\"",