chore: add migration script to add module names

Author: Behzad-rabiei

.migrate

@@ -1,9 +1,13 @@
 {
-  "lastRun": "1738072787797-add-activated-field-to-modules.ts",
+  "lastRun": "1744651967487-add-modules.ts",
   "migrations": [
     {
       "title": "1738072787797-add-activated-field-to-modules.ts",
-      "timestamp": 1744199444528
+      "timestamp": 1744652563680
+    },
+    {
+      "title": "1744651967487-add-modules.ts",
+      "timestamp": 1744652563722
     }
   ]
 }

package-lock.json

@@ -28,7 +28,7 @@
     "@notionhq/client": "^2.2.3",
     "@sentry/node": "^7.50.0",
     "@temporalio/client": "^1.11.3",
-    "@togethercrew.dev/db": "^3.4.0",
+    "@togethercrew.dev/db": "^3.5.0",
     "@togethercrew.dev/tc-messagebroker": "^0.0.50",
     "@types/express-session": "^1.17.7",
     "@types/morgan": "^1.9.5",

package.json

@@ -0,0 +1,64 @@
+import 'dotenv/config';
+
+import mongoose from 'mongoose';
+
+import { Community, Module, ModuleNames } from '@togethercrew.dev/db';
+
+import config from '../../config';
+import logger from '../../config/logger';
+
+async function connectToMongoDB() {
+  try {
+    await mongoose.connect(config.mongoose.serverURL);
+    logger.info('Connected to MongoDB!');
+  } catch (error) {
+    logger.fatal('Failed to connect to MongoDB!');
+    throw error;
+  }
+}
+
+export const up = async () => {
+  await connectToMongoDB();
+
+  try {
+    const communities = await Community.find({}).exec();
+    logger.info(`Found ${communities.length} communities.`);
+
+    const newModuleNames = [ModuleNames.Announcements, ModuleNames.CommunityHealth, ModuleNames.CommunityInsights];
+
+    for (const community of communities) {
+      for (const moduleName of newModuleNames) {
+        const newModule = new Module({
+          name: moduleName,
+          community: community._id,
+          activated: true,
+          options: { platforms: [] },
+        });
+        await newModule.save();
+        logger.info(`Created module "${moduleName}" for community ${community._id}`);
+      }
+    }
+  } catch (error) {
+    logger.error('Error during migration up:', error);
+    throw error;
+  } finally {
+    await mongoose.connection.close();
+    logger.info('MongoDB connection closed.');
+  }
+};
+
+export const down = async () => {
+  await connectToMongoDB();
+
+  try {
+    const moduleNamesToDelete = [ModuleNames.Announcements, ModuleNames.CommunityHealth, ModuleNames.CommunityInsights];
+    const result = await Module.deleteMany({ name: { $in: moduleNamesToDelete } });
+    logger.info(`Migration down: deleted ${result.deletedCount} modules.`);
+  } catch (error) {
+    logger.error('Error during migration down:', error);
+    throw error;
+  } finally {
+    await mongoose.connection.close();
+    logger.info('MongoDB connection closed.');
+  }
+};