fix/290: remove all comments after remove the source entry (#292)

Author: Kronos66

server/src/bootstrap.ts

@@ -1,6 +1,8 @@
 import { StrapiContext } from './@types';
 import { setupGQL } from './graphql';
 import permissions from './permissions';
+import { CONFIG_PARAMS } from './utils/constants';
+import { getPluginService } from './utils/getPluginService';
 
 export default async ({ strapi }: StrapiContext) => {
   if (strapi.plugin('graphql')) {
@@ -53,4 +55,20 @@ export default async ({ strapi }: StrapiContext) => {
   ];
 
   await strapi.admin.services.permission.actionProvider.registerMany(actions);
+
+  const commonService = getPluginService(strapi, 'common');
+  const enabledCollections = await commonService.getConfig(CONFIG_PARAMS.ENABLED_COLLECTIONS, []);
+
+  if (enabledCollections.length) {
+    strapi.db.lifecycles.subscribe({
+      models: enabledCollections,
+      afterDelete: async (event) => {
+        const uid = event.model.uid;
+        const { documentId, locale } = event.result;
+        const relation = [uid, documentId].join(':');
+        await commonService.perRemove(relation, locale);
+      },
+    });
+  }
+
 };

server/src/repositories/comment.repository.ts

@@ -34,6 +34,9 @@ export const getCommentRepositorySource = (strapi: CoreStrapi) => {
       return strapi.query(modelUid).delete(params)
                    .then(result => (result ? shouldValidateObject(isValidationEnabled, commentResultValidator.findOne)(result) : null));
     },
+    async deleteMany(params: Params) {
+      return strapi.query(modelUid).deleteMany(params)
+    },
     updateMany(params: Params) {
       return strapi.query(modelUid).updateMany(params);
     },

server/src/services/common.service.ts

@@ -161,7 +161,7 @@ const commonService = ({ strapi }: StrapiContext) => ({
       isAdmin = false,
       omit = [],
       locale,
-      limit
+      limit,
     }: clientValidator.FindAllInHierarchyValidatorSchema,
     relatedEntity?: any,
   ) {
@@ -342,6 +342,17 @@ const commonService = ({ strapi }: StrapiContext) => ({
     return content;
   },
 
+  async perRemove(related: string, locale?: string) {
+    const defaultLocale = await strapi.plugin('i18n')?.service('locales').getDefaultLocale() || null;
+    return getCommentRepository(strapi)
+    .deleteMany({
+      where: {
+        related,
+        $or: [{ locale }, defaultLocale === locale ? { locale: { $eq: null } } : null].filter(Boolean)
+      },
+    });
+  },
+
 
   registerLifecycleHook(/*{ callback, contentTypeName, hookName }*/) {
   },