user invite

backend/core-api/src/connectionResolvers.ts

@@ -130,6 +130,15 @@ import {
   loadSegmentClass,
 } from './modules/segments/db/models/Segments';
 
+import {
+  IAutomationDocument,
+  IAutomationExecutionDocument,
+} from 'erxes-api-shared/core-modules';
+import {
+  IEmailDeliveryModel,
+  loadEmailDeliveryClass,
+} from '~/modules/organization/team-member/db/models/EmailDeliveries';
+import { IEmailDeliveriesDocument } from '~/modules/organization/team-member/types';
 import {
   IAutomationModel,
   loadClass as loadAutomationClass,
@@ -138,10 +147,6 @@ import {
   IExecutionModel,
   loadClass as loadExecutionClass,
 } from './modules/automations/db/models/Executions';
-import {
-  IAutomationDocument,
-  IAutomationExecutionDocument,
-} from 'erxes-api-shared/core-modules';
 import { ILogModel, loadLogsClass } from './modules/logs/db/models/Logs';
 
 export interface IModels {
@@ -176,6 +181,7 @@ export interface IModels {
   Documents: IDocumentModel;
   Automations: IAutomationModel;
   AutomationExecutions: IExecutionModel;
+  EmailDeliveries: IEmailDeliveryModel;
   Logs: ILogModel;
 }
 
@@ -326,6 +332,11 @@ export const loadClasses = (
     IExecutionModel
   >('automations_executions', loadExecutionClass(models));
 
+  models.EmailDeliveries = db.model<
+    IEmailDeliveriesDocument,
+    IEmailDeliveryModel
+  >('email_deliveries', loadEmailDeliveryClass(models));
+
   const db_name = db.name;
 
   const logDb = db.useDb(`${db_name}_logs`);

backend/core-api/src/modules/contacts/graphql/schemas/customer.ts

@@ -75,7 +75,7 @@ const queryParams = `
   segment: String
   type: String
   ids: [String]
-  excludeIds: Boolean
+  excludeIds: [String]
 
   tagIds: [String]
   excludeTagIds: [String]

backend/core-api/src/modules/contacts/utils.ts

@@ -13,7 +13,9 @@ export const generateFilter = async (params: any, models: IModels) => {
     brandIds,
     integrationIds,
     integrationTypes,
-    status
+    status,
+    ids,
+    excludeIds,
   } = params;
 
   const filter = {};
@@ -30,6 +32,19 @@ export const generateFilter = async (params: any, models: IModels) => {
     filter['searchText'] = { $regex: searchValue, $options: 'i' };
   }
 
+  if (ids?.length || excludeIds?.length) {
+    if (ids?.length && excludeIds?.length) {
+      filter['_id'] = {
+        $in: ids,
+        $nin: excludeIds,
+      };
+    } else if (ids?.length) {
+      filter['_id'] = { $in: ids };
+    } else if (excludeIds?.length) {
+      filter['_id'] = { $nin: excludeIds };
+    }
+  }
+
   if (brandIds || integrationIds || integrationTypes) {
     const relatedIntegrationIdSet = new Set();
 

backend/core-api/src/modules/organization/team-member/constants.ts

@@ -0,0 +1,5 @@
+export const EMAIL_DELIVERY_STATUS = {
+  PENDING: 'pending',
+  RECEIVED: 'received',
+  ALL: ['pending', 'received'],
+};

backend/core-api/src/modules/organization/team-member/db/definitions/emailDeliveries.ts

@@ -0,0 +1,19 @@
+import { mongooseStringRandomId } from 'erxes-api-shared/utils';
+import { Schema } from 'mongoose';
+import { EMAIL_DELIVERY_STATUS } from '~/modules/organization/team-member/constants';
+
+export const emailDeliveriesSchema = new Schema({
+  _id: mongooseStringRandomId,
+  subject: { type: String },
+  body: { type: String },
+  to: { type: [String] },
+  cc: { type: [String], optional: true },
+  bcc: { type: [String], optional: true },
+  attachments: { type: [Object] },
+  from: { type: String },
+  kind: { type: String },
+  customerId: { type: String },
+  userId: { type: String },
+  createdAt: { type: Date, default: Date.now },
+  status: { type: String, enum: EMAIL_DELIVERY_STATUS.ALL },
+});

backend/core-api/src/modules/organization/team-member/db/models/EmailDeliveries.ts

@@ -0,0 +1,33 @@
+import { Model } from 'mongoose';
+import { IModels } from '~/connectionResolvers';
+import { emailDeliveriesSchema } from '~/modules/organization/team-member/db/definitions/emailDeliveries';
+import {
+  IEmailDeliveries,
+  IEmailDeliveriesDocument,
+} from '~/modules/organization/team-member/types';
+
+export interface IEmailDeliveryModel extends Model<IEmailDeliveriesDocument> {
+  createEmailDelivery(doc: IEmailDeliveries): Promise<IEmailDeliveriesDocument>;
+  updateEmailDeliveryStatus(_id: string, status: string): Promise<void>;
+}
+
+export const loadEmailDeliveryClass = (models: IModels) => {
+  class EmailDelivery {
+    /**
+     * Create an EmailDelivery document
+     */
+    public static async createEmailDelivery(doc: IEmailDeliveries) {
+      return models.EmailDeliveries.create({
+        ...doc,
+      });
+    }
+
+    public static async updateEmailDeliveryStatus(_id: string, status: string) {
+      return models.EmailDeliveries.updateOne({ _id }, { $set: { status } });
+    }
+  }
+
+  emailDeliveriesSchema.loadClass(EmailDelivery);
+
+  return emailDeliveriesSchema;
+};

backend/core-api/src/modules/organization/team-member/db/models/Users.ts

@@ -1,26 +1,26 @@
 import * as bcrypt from 'bcryptjs';
+import * as crypto from 'crypto';
 import * as jwt from 'jsonwebtoken';
 import { Model } from 'mongoose';
-import * as crypto from 'crypto';
 
-import { redis } from 'erxes-api-shared/utils';
 import {
   USER_ROLES,
-  userSchema,
   userMovemmentSchema,
+  userSchema,
 } from 'erxes-api-shared/core-modules';
+import { redis } from 'erxes-api-shared/utils';
 
 import { saveValidatedToken } from '@/auth/utils';
-import { IModels } from '~/connectionResolvers';
 import {
-  IUser,
+  IAppDocument,
   IDetail,
+  IEmailSignature,
   ILink,
-  IUserMovementDocument,
+  IUser,
   IUserDocument,
-  IEmailSignature,
-  IAppDocument,
+  IUserMovementDocument,
 } from 'erxes-api-shared/core-types';
+import { IModels } from '~/connectionResolvers';
 
 import { USER_MOVEMENT_STATUSES } from 'erxes-api-shared/core-modules';
 
@@ -322,6 +322,10 @@ export const loadUserClass = (models: IModels) => {
       // Checking duplicated email
       await models.Users.checkDuplication({ email });
 
+      if (!(await models.UsersGroups.findOne({ _id: groupId }))) {
+        throw new Error('Invalid group');
+      }
+
       const { token, expires } = await User.generateToken();
 
       this.checkPassword(password);

backend/core-api/src/modules/organization/team-member/graphql/mutations.ts

@@ -1,10 +1,13 @@
-import { IContext } from '~/connectionResolvers';
 import {
-  IUser,
   IDetail,
-  ILink,
   IEmailSignature,
+  ILink,
+  IUser,
 } from 'erxes-api-shared/core-types';
+import { isEnabled, sendTRPCMessage } from 'erxes-api-shared/utils';
+import { IContext } from '~/connectionResolvers';
+import { sendInvitationEmail } from '~/modules/organization/team-member/utils';
+import { resetPermissionsCache } from '~/modules/permissions/utils';
 
 export interface IUsersEdit extends IUser {
   channelIds?: string[];
@@ -198,7 +201,7 @@ export const userMutations = {
         departmentId?: string;
       }>;
     },
-    { models }: IContext,
+    { models, subdomain }: IContext,
   ) {
     for (const entry of entries) {
       await models.Users.checkDuplication({ email: entry.email });
@@ -210,6 +213,8 @@ export const userMutations = {
       if (docModified?.scopeBrandIds?.length) {
         doc.brandIds = docModified.scopeBrandIds;
       }
+
+      const token = await models.Users.invite(doc);
       const createdUser = await models.Users.findOne({ email: entry.email });
 
       if (entry.branchId) {
@@ -229,7 +234,21 @@ export const userMutations = {
           },
         );
       }
+
+      if (entry.channelIds && (await isEnabled('frontline'))) {
+        sendTRPCMessage({
+          pluginName: 'frontline',
+          method: 'mutation',
+          module: 'inbox',
+          action: 'updateUserChannels',
+          input: { channelIds: entry.channelIds, userId: createdUser?._id },
+        });
+      }
+
+      sendInvitationEmail(models, subdomain, { email: entry.email, token });
     }
+
+    await resetPermissionsCache(models);
   },
 
   /*

backend/core-api/src/modules/organization/team-member/types.ts

@@ -0,0 +1,39 @@
+import { Document } from 'mongoose';
+
+export interface IAttachmentParams {
+  data: string;
+  filename: string;
+  size: number;
+  mimeType: string;
+}
+
+export interface IEmailDeliveries {
+  subject: string;
+  body: string;
+  to: string[];
+  cc?: string[];
+  bcc?: string[];
+  attachments?: IAttachmentParams[];
+  from: string;
+  kind: string;
+  userId?: string;
+  customerId?: string;
+  status?: string;
+}
+
+export interface IEmailDeliveriesDocument extends IEmailDeliveries, Document {
+  id: string;
+}
+
+export interface IEmailParams {
+  toEmails?: string[];
+  fromEmail?: string;
+  title?: string;
+  customHtml?: string;
+  customHtmlData?: any;
+  template?: { name?: string; data?: any };
+  attachments?: object[];
+  modifier?: (data: any, email: string) => void;
+  transportMethod?: string;
+  getOrganizationDetail?: ({ subdomain }: { subdomain: string }) => any;
+}