mongodb index creation

src/lib/jobs/refresh-conversation-stats.ts

@@ -33,7 +33,9 @@ async function computeStats(params: {
 	span: ConversationStats["date"]["span"];
 	type: ConversationStats["type"];
 }) {
-	if (!(await collections.conversations.estimatedDocumentCount())) {
+	const indexes = await collections.semaphores.listIndexes().toArray();
+	if (indexes.length <= 2) {
+		logger.info("Indexes not created, skipping stats computation");
 		return;
 	}
 

src/lib/server/database.ts

@@ -66,9 +66,11 @@ export class Database {
 		}
 
 		try {
+			logger.info("Connecting to database");
 			await this.client.connect();
+			logger.info("Connected to database");
 			this.client.db(config.MONGODB_DB_NAME + (import.meta.env.MODE === "test" ? "-test" : ""));
-			this.client.on("open", () => this.initDatabase());
+			await this.initDatabase();
 		} catch (err) {
 			logger.error(err, "Connection error");
 			process.exit(1);