MPDX-7987 Merge Contacts

pages/api/Schema/MergeContacts/mergeContacts.graphql

@@ -2,17 +2,14 @@ extend type Mutation {
   """
   Returns the ids of the winner
   """
-  mergeContacts(input: MergeContactsInput!): ID!
+  mergeContacts(input: MergeContactsInput!): [ID!]!
 }
 
-input MergeContactsInput {
-  """
-  The ids of the contacts to make the losers of the merge
-  """
-  loserContactIds: [ID!]!
+input WinnersAndLosers {
+  winnerId: ID!
+  loserId: ID!
+}
 
-  """
-  The id of the contact to make the winner of the merge
-  """
-  winnerContactId: ID!
+input MergeContactsInput {
+  winnersAndLosers: [WinnersAndLosers!]!
 }

pages/api/Schema/MergeContacts/resolvers.ts

@@ -4,13 +4,10 @@ const MergeContactsResolvers: Resolvers = {
   Mutation: {
     mergeContacts: (
       _source,
-      { input: { loserContactIds, winnerContactId } },
+      { input: { winnersAndLosers } },
       { dataSources },
     ) => {
-      return dataSources.mpdxRestApi.mergeContacts(
-        loserContactIds,
-        winnerContactId,
-      );
+      return dataSources.mpdxRestApi.mergeContacts(winnersAndLosers);
     },
   },
 };

pages/api/graphql-rest.page.ts

@@ -11,6 +11,7 @@ import {
   ExportFormatEnum,
   ExportLabelTypeEnum,
   ExportSortEnum,
+  MergeContactsInput,
 } from 'src/graphql/types.generated';
 import schema from './Schema';
 import { getAccountListAnalytics } from './Schema/AccountListAnalytics/dataHandler';
@@ -201,21 +202,23 @@ class MpdxRestApi extends RESTDataSource {
     return `${process.env.REST_API_URL}contacts/exports${pathAddition}/${data.id}.${format}`;
   }
 
-  async mergeContacts(loserContactIds: Array<string>, winnerContactId: string) {
+  async mergeContacts(
+    winnersAndLosers: MergeContactsInput['winnersAndLosers'],
+  ) {
     const response = await this.post('contacts/merges/bulk', {
-      data: loserContactIds.map((loserId) => ({
+      data: winnersAndLosers.map((contact) => ({
         data: {
           type: 'contacts',
           attributes: {
-            loser_id: loserId,
-            winner_id: winnerContactId,
+            loser_id: contact.loserId,
+            winner_id: contact.winnerId,
           },
         },
       })),
     });
 
-    // Return the id of the winner
-    return response[0].data.id;
+    // Return the id of the winners
+    return response.map((contact) => contact.data.id);
   }
 
   async getAccountListAnalytics(

src/components/Contacts/MassActions/Merge/MassActionsMerge.graphql

@@ -1,10 +1,5 @@
-mutation MassActionsMerge($loserContactIds: [ID!]!, $winnerContactId: ID!) {
-  mergeContacts(
-    input: {
-      loserContactIds: $loserContactIds
-      winnerContactId: $winnerContactId
-    }
-  )
+mutation MassActionsMerge($input: MergeContactsInput!) {
+  mergeContacts(input: $input)
 }
 
 query GetContactsForMerging(

src/components/Contacts/MassActions/Merge/MassActionsMergeModal.test.tsx

@@ -164,8 +164,14 @@ describe('MassActionsMergeModal', () => {
       .filter(({ operationName }) => operationName === 'MassActionsMerge');
     expect(mergeCalls).toHaveLength(1);
     expect(mergeCalls[0].variables).toEqual({
-      loserContactIds: ['contact-2'],
-      winnerContactId: 'contact-1',
+      input: {
+        winnersAndLosers: [
+          {
+            loserId: 'contact-2',
+            winnerId: 'contact-1',
+          },
+        ],
+      },
     });
   });
 

src/components/Contacts/MassActions/Merge/MassActionsMergeModal.tsx

@@ -63,16 +63,21 @@ export const MassActionsMergeModal: React.FC<MassActionsMergeModalProps> = ({
   });
 
   const mergeContacts = async () => {
-    const loserContactIds = ids.filter((id) => id !== primaryContactId);
+    const winnersAndLosers = ids
+      .filter((id) => id !== primaryContactId)
+      .map((id) => {
+        return { winnerId: primaryContactId, loserId: id };
+      });
     await contactsMerge({
       variables: {
-        loserContactIds,
-        winnerContactId: primaryContactId,
+        input: {
+          winnersAndLosers,
+        },
       },
       update: (cache) => {
         // Delete the loser contacts and remove dangling references to them
-        loserContactIds.forEach((id) => {
-          cache.evict({ id: `Contact:${id}` });
+        winnersAndLosers.forEach((contact) => {
+          cache.evict({ id: `Contact:${contact.loserId}` });
         });
         cache.gc();
       },