feat(engage): introduce client portal notification type in engage plu…

…gin (#4915) * Added notification, cpId to engages * Updated push notification in campaign * Update engageUtils.ts --------- Co-authored-by: soyombo <e11iot.soko@gmail.com>
erxes · Jan 23, 2024 · c7999e8 · c7999e8
1 parent 433630d
commit c7999e8
Show file tree

Hide file tree

Showing 19 changed files with 725 additions and 101 deletions.
diff --git a/packages/plugin-clientportal-api/src/messageBroker.ts b/packages/plugin-clientportal-api/src/messageBroker.ts
@@ -50,6 +50,18 @@ export const initBroker = async () => {
     },
   );
 
+  consumeRPCQueue(
+    'clientportal:clientPortalUsers.getIds',
+    async ({ subdomain, data }) => {
+      const models = await generateModels(subdomain);
+
+      return {
+        status: 'success',
+        data: await models.ClientPortalUsers.find(data).distinct('_id'),
+      };
+    },
+  );
+
   consumeRPCQueue(
     'clientportal:clientPortalUsers.create',
     async ({ subdomain, data }) => {

diff --git a/packages/plugin-contacts-api/src/utils.ts b/packages/plugin-contacts-api/src/utils.ts
@@ -30,7 +30,6 @@ import { companySchema } from './models/definitions/companies';
 import { ICustomField, ILink } from '@erxes/api-utils/src/types';
 import { fetchEs } from '@erxes/api-utils/src/elasticsearch';
 import { customFieldsDataByFieldCode } from '@erxes/api-utils/src/fieldUtils';
-import { sendCommonMessage } from './messageBroker';
 
 const EXTEND_FIELDS = {
   CUSTOMER: [
@@ -535,7 +534,6 @@ export const prepareEngageCustomers = async (
     await editorAttributeUtil.getCustomerFields(emailContent);
 
   const exists = { $exists: true, $nin: [null, '', undefined] };
-
   // make sure email & phone are valid
   if (engageMessage.method === 'email') {
     customersSelector.primaryEmail = exists;

diff --git a/packages/plugin-engages-api/src/constants.ts b/packages/plugin-engages-api/src/constants.ts
@@ -133,7 +133,8 @@ export const CAMPAIGN_METHODS = {
   MESSENGER: 'messenger',
   EMAIL: 'email',
   SMS: 'sms',
-  ALL: ['messenger', 'email', 'sms']
+  NOTIFICATION: 'notification',
+  ALL: ['messenger', 'email', 'sms', 'notification']
 };
 
 export const MESSENGER_KINDS = {