Merge pull request #149 from TogetherCrew/feature/announcement-caseca…

…de-delete

Feature/announcement casecade delete

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@togethercrew.dev/db",
-  "version": "3.0.28",
+  "version": "3.0.29",
   "description": "All interactions with DB",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

src/models/schemas/Platform.schema.ts

@@ -34,10 +34,43 @@ const platformSchema = new Schema<IPlatform, PlatformModel>(
 platformSchema.plugin(toJSON);
 platformSchema.plugin(paginate);
 
+const announcementDeletion = async (platformId: any): Promise<void> => {
+  // ?in case the platformID (inputted platformID) of each item in the data array field matches, delete that announcement.
+  const announcementsWithAllDataOnSamePlatformIds = await Announcement.aggregate([
+    {
+      $match: {
+        'data.platform': platformId,
+      },
+    },
+    {
+      $project: {
+        allMatch: {
+          $not: [
+            {
+              $elemMatch: {
+                'data.platform': { $ne: platformId },
+              },
+            },
+          ],
+        },
+      },
+    },
+    {
+      $match: {
+        allMatch: true,
+      },
+    },
+  ]);
+  const idsToDelete = announcementsWithAllDataOnSamePlatformIds.map((announcement) => announcement._id);
+  await Announcement.deleteMany({ _id: { $in: idsToDelete } });
+
+  await Announcement.updateMany({ 'data.platform': platformId }, { $pull: { data: { platform: platformId } } });
+};
+
 platformSchema.pre('remove', async function (this: Document) {
   const platformId = this._id;
   await Community.updateOne({ platforms: platformId }, { $pull: { platforms: platformId } });
-  await Announcement.updateMany({ 'data.platform': platformId }, { $pull: { data: { platform: platformId } } });
+  await announcementDeletion(platformId);
 });
 
 export default platformSchema;