:construction: db listener

1 files changed, 24 insertions, 0 deletions

diff --git a/src/listener/listener.ts b/src/listener/listener.ts
new file mode 100644

index 00000000..12abaf86
--- /dev/null
+++ b/src/listener/listener.ts
@@ -0,0 +1,24 @@
+import { db, User } from "discord-server-util";
+import { ProviderCache } from "lambert-db";
+import { MongodbProviderCache } from "lambert-db/dist/Mongodb";
+import WebSocket from "../util/WebSocket";
+
+export async function setupListener(this: WebSocket) {
+	// TODO: shard guilds (only for bots)
+
+	const user: User = await db.data.users({ id: this.userid }).get();
+
+	// * MongoDB specific $in query to get all guilds of the user
+	const guildCache: MongodbProviderCache = await db.data
+		.guilds({ id: { $id: user.guilds } })
+		.cache({ onlyEvents: true })
+		.init();
+
+	guildCache.on("change", (data) => {
+		console.log(data);
+	});
+
+	this.once("close", async () => {
+		await guildCache.destroy();
+	});
+}