chore: improve indexes of the livechat contacts collection (#33991)

Co-authored-by: matheusbsilva137 <[email protected]>
Co-authored-by: Diego Sampaio <[email protected]>

Author: 3 people

apps/meteor/app/livechat/server/lib/contacts/ContactMerger.ts

@@ -295,6 +295,10 @@ export class ContactMerger {
 			...(allConflicts.length ? { conflictingFields: { $each: allConflicts } } : {}),
 		};
 
+		if (newChannels.length) {
+			dataToSet.preRegistration = false;
+		}
+
 		const updateData: UpdateFilter<ILivechatContact> = {
 			...(Object.keys(dataToSet).length ? { $set: dataToSet } : {}),
 			...(Object.keys(dataToAdd).length ? { $addToSet: dataToAdd } : {}),

apps/meteor/server/models/raw/LivechatContacts.ts

@@ -56,12 +56,24 @@ export class LivechatContactsRaw extends BaseRaw<ILivechatContact> implements IL
 					'channels.visitor.source.type': 1,
 					'channels.visitor.source.id': 1,
 				},
+				name: 'visitorAssociation',
 				unique: false,
 			},
 			{
 				key: {
-					channels: 1,
+					'channels.field': 1,
+					'channels.value': 1,
+					'channels.verified': 1,
 				},
+				partialFilterExpression: { 'channels.verified': true },
+				name: 'verificationKey',
+				unique: false,
+			},
+			{
+				key: {
+					preRegistration: 1,
+				},
+				sparse: true,
 				unique: false,
 			},
 		];
@@ -73,6 +85,7 @@ export class LivechatContactsRaw extends BaseRaw<ILivechatContact> implements IL
 		const result = await this.insertOne({
 			createdAt: new Date(),
 			...data,
+			preRegistration: !data.channels.length,
 		});
 
 		return result.insertedId;
@@ -81,7 +94,7 @@ export class LivechatContactsRaw extends BaseRaw<ILivechatContact> implements IL
 	async updateContact(contactId: string, data: Partial<ILivechatContact>, options?: FindOneAndUpdateOptions): Promise<ILivechatContact> {
 		const updatedValue = await this.findOneAndUpdate(
 			{ _id: contactId },
-			{ $set: { ...data, unknown: false } },
+			{ $set: { ...data, unknown: false, ...(data.channels && { preRegistration: !data.channels.length }) } },
 			{ returnDocument: 'after', ...options },
 		);
 		return updatedValue.value as ILivechatContact;
@@ -132,7 +145,7 @@ export class LivechatContactsRaw extends BaseRaw<ILivechatContact> implements IL
 					],
 				},
 				{
-					channels: [],
+					preRegistration: true,
 				},
 			],
 		};
@@ -164,7 +177,7 @@ export class LivechatContactsRaw extends BaseRaw<ILivechatContact> implements IL
 	}
 
 	async addChannel(contactId: string, channel: ILivechatContactChannel): Promise<void> {
-		await this.updateOne({ _id: contactId }, { $push: { channels: channel } });
+		await this.updateOne({ _id: contactId }, { $push: { channels: channel }, $set: { preRegistration: false } });
 	}
 
 	async updateLastChatById(

packages/core-typings/src/ILivechatContact.ts

@@ -45,4 +45,7 @@ export interface ILivechatContact extends IRocketChatRecord {
 		ts: Date;
 	};
 	importIds?: string[];
+	// When preRegistration is true, the contact was added by an admin and it doesn't have any visitor association yet
+	// This contact may then be linked to new visitors that use the same email address or phone number
+	preRegistration?: boolean;
 }