import "@grouparoo/spec-helper"; import { exportBatch } from "../../src/lib/export-objects/exportRecords"; import { destinationModel } from "../../src/lib/export-objects/model"; import { loadAppOptions, updater } from "../utils/nockHelper"; import { getModelHelpers } from "../utils/modelHelper"; import { helper } from "@grouparoo/spec-helper"; import { DestinationSyncModeData } from "@grouparoo/core/dist/models/Destination"; const { newNock } = helper.useNock(__filename, updater); const appOptions = loadAppOptions(newNock); const appId = "app_f3bb07d8-0c4f-49b5-ad42-545f2e8662e9"; const syncOperations = DestinationSyncModeData.sync.operations; const destinationOptions = { recordObject: "Contact", recordMatchField: "Email", groupObject: "Campaign", groupNameField: "Name", membershipObject: "CampaignMember", membershipRecordField: "ContactId", membershipGroupField: "CampaignId", recordReferenceField: "AccountId", recordReferenceObject: "Account", recordReferenceMatchField: "Name", }; const model = destinationModel(destinationOptions); const email1 = "brian@demo.com"; const id1 = "pro1"; const newEmail1 = "other@demo.com"; let userId1 = null; const email2 = "brian2@demo.com"; const id2 = "pro2"; let userId2 = null; const email3 = "brian3@demo.com"; const id3 = "pro3"; let userId3 = null; const group1 = "(test) High Value1"; let groupId1 = null; const group2 = "(test) Churned1"; let groupId2 = null; const account1 = "(test) Big Account1"; let accountId1 = null; const account2 = "(test) Small Account1"; let accountId2 = null; const deleteRecordValues = [email1, email2, email3, newEmail1]; const deleteGroupValues = [group1, group2]; const deleteReferenceValues = [account1, account2]; const { findId, getUser, findGroupId, getGroupMemberIds, cleanUp, findReferenceId, getReferencedUserIds, } = getModelHelpers({ appOptions, model, deleteRecordValues, deleteGroupValues, deleteReferenceValues, }); describe("salesforce/sales-cloud/export-records/email", () => { beforeAll(async () => { await cleanUp(false); }, helper.setupTime); afterAll(async () => { await cleanUp(true); }, helper.setupTime); beforeEach(async () => { jest.setTimeout(helper.mediumTime); }); test("can create record on Salesforce", async () => { userId1 = await findId(email1); expect(userId1).toBe(null); accountId1 = await findReferenceId(account1); expect(accountId1).toBe(null); const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: {}, newRecordProperties: { Email: email1, LastName: "Smith", "Account.Name": account1, number_field__c: 24, date_field__c: "1980-12-21", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); userId1 = await findId(email1); expect(userId1).toBeTruthy(); const user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.LastName).toBe("Smith"); expect(user.FirstName).toBe(null); expect(user.number_field__c).toBe(24); expect(user.date_field__c).toBe("1980-12-21"); accountId1 = await findReferenceId(account1); expect(accountId1).toBeTruthy(); expect(user.AccountId).toEqual(accountId1); const referenced = await getReferencedUserIds(accountId1); expect(referenced.sort()).toEqual([userId1].sort()); expect(user.AccountId).toEqual(accountId1); }); test("can add/edit user variables and do multiple users", async () => { userId2 = await findId(email2); expect(userId2).toBe(null); accountId2 = await findReferenceId(account2); expect(accountId2).toBe(null); const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Smith", "Account.Name": account1, number_field__c: 24, }, newRecordProperties: { Email: email1, FirstName: "John", LastName: "Jones", "Account.Name": account2, number_field__c: 0, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: {}, newRecordProperties: { Email: email2, LastName: "Jih", "Account.Name": account2, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); accountId2 = await findReferenceId(account2); expect(accountId2).toBeTruthy(); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.FirstName).toBe("John"); expect(user.LastName).toBe("Jones"); expect(user.number_field__c).toBe(0); expect(user.AccountId).toEqual(accountId2); expect(errors).toBeNull(); expect(success).toBe(true); userId2 = await findId(email2); expect(userId2).toBeTruthy(); user = await getUser(userId2); expect(user.Email).toBe(email2); expect(user.LastName).toBe("Jih"); expect(user.AccountId).toEqual(accountId2); let referenced; referenced = await getReferencedUserIds(accountId1); expect(referenced.sort()).toEqual([]); referenced = await getReferencedUserIds(accountId2); expect(referenced.sort()).toEqual([userId1, userId2].sort()); }); test("can clear user variables", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, FirstName: "John", LastName: "Jones", "Account.Name": account2, number_field__c: 0, }, newRecordProperties: { Email: email1, LastName: "Simpson", "Account.Name": null, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.FirstName).toBe(null); expect(user.LastName).toBe("Simpson"); expect(user.AccountId).toEqual(null); expect(user.number_field__c).toEqual(null); let referenced; referenced = await getReferencedUserIds(accountId2); expect(referenced.sort()).toEqual([userId2].sort()); }); test("it can change the email address", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Brian", "Account.Name": null, }, newRecordProperties: { Email: newEmail1, FirstName: "Brian", LastName: "Chang", "Account.Name": null, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jih", "Account.Name": account2, }, newRecordProperties: { Email: email2, LastName: "Test", "Account.Name": account2, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); let user; user = await getUser(userId1); expect(user.Email).toBe(newEmail1); expect(user.FirstName).toBe("Brian"); expect(user.LastName).toBe("Chang"); expect(await findId(email1)).toBeNull(); // changed! user = await getUser(userId2); expect(user.Email).toBe(email2); expect(user.LastName).toBe("Test"); }); test("can delete a user", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: newEmail1, FirstName: "Brian", LastName: "Chang", "Account.Name": null, }, newRecordProperties: { Email: email1, // changing back FirstName: "Brian", LastName: "Chang", "Account.Name": null, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Test", "Account.Name": account2, }, newRecordProperties: { Email: email2, LastName: "Test", "Account.Name": account2, }, oldGroups: [], newGroups: [], toDelete: true, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); let user; user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.FirstName).toBe("Brian"); expect(user.LastName).toBe("Chang"); // for types next time expect(user.checkbox_field__c).toEqual(false); // defaulted expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(await findId(newEmail1)).toBeNull(); // changed! expect(await findId(email2)).toBeNull(); expect(await getUser(userId2)).toBeNull(); let referenced = await getReferencedUserIds(accountId2); expect(referenced.sort()).toEqual([]); }); test("is ok (but gives error) to delete a user that doesn't exist", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id3, oldRecordProperties: { Email: email3, LastName: "None" }, newRecordProperties: { Email: email3, LastName: "None" }, oldGroups: [], newGroups: [], toDelete: true, record: null, }, ], }); expect(success).toBe(false); expect(errors).not.toBeNull(); expect(errors.length).toEqual(1); const error = errors[0]; expect(error.recordId).toEqual(id3); expect(error.message).toContain("not found to delete"); expect(await findId(email3)).toBeNull(); // not added }); test("can add back a user and many types", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: {}, newRecordProperties: { checkbox_field__c: true, datetime_field__c: new Date(1598766588 * 1000), number_field__c: 42, percent_field__c: 99, email_field__c: "field@grouparoo.com", phone_field__c: "(412) 555-1234", picklist_field__c: "Red", text_field__c: "short text", textarea_field__c: "longer text here", url_field__c: "https://www.grouparoo.com", currency_field__c: 34.66, Email: email2, LastName: "Parker", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); userId2 = await findId(email2); expect(userId2).toBeTruthy(); user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(true); expect(user.datetime_field__c).toEqual("2020-08-30T05:49:48.000+0000"); expect(user.number_field__c).toEqual(42); expect(user.percent_field__c).toEqual(99); expect(user.email_field__c).toEqual("field@grouparoo.com"); expect(user.phone_field__c).toEqual("(412) 555-1234"); expect(user.picklist_field__c).toEqual("Red"); expect(user.text_field__c).toEqual("short text"); expect(user.textarea_field__c).toEqual("longer text here"); expect(user.url_field__c).toEqual("https://www.grouparoo.com"); expect(user.currency_field__c).toEqual(34.66); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Parker"); }); test("can set all those fields to null", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: { checkbox_field__c: true, datetime_field__c: new Date(1598766588 * 1000), number_field__c: 42, percent_field__c: 99, email_field__c: "field@grouparoo.com", phone_field__c: "(412) 555-1234", picklist_field__c: "Red", text_field__c: "short text", textarea_field__c: "longer text here", url_field__c: "https://www.grouparoo.com", currency_field__c: 34.66, Email: email2, LastName: "Parker", }, newRecordProperties: { Email: email2, LastName: "Patil" }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(false); // defaulted expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(user.percent_field__c).toEqual(null); expect(user.email_field__c).toEqual(null); expect(user.phone_field__c).toEqual(null); expect(user.picklist_field__c).toEqual(null); expect(user.text_field__c).toEqual(null); expect(user.textarea_field__c).toEqual(null); expect(user.url_field__c).toEqual(null); expect(user.currency_field__c).toEqual(null); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Patil"); }); test("can add to and create groups", async () => { groupId1 = await findGroupId(group1); expect(groupId1).toBe(null); const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, FirstName: "Brian", LastName: "Chang", }, newRecordProperties: { Email: email1, LastName: "Smith", }, oldGroups: [], newGroups: [group1], toDelete: false, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); groupId1 = await findGroupId(group1); expect(groupId1).toBeTruthy(); const members = await getGroupMemberIds(groupId1); expect(members.sort()).toEqual([userId1].sort()); }); test("can add multiple users to lists", async () => { groupId2 = await findGroupId(group2); expect(groupId2).toBe(null); const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Smith" }, newRecordProperties: { Email: email1, LastName: "Smith" }, oldGroups: [group1], newGroups: [group1, group2], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Patil" }, newRecordProperties: { Email: email2, LastName: "Jones" }, oldGroups: [], newGroups: [group1], toDelete: false, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); groupId2 = await findGroupId(group2); expect(groupId2).toBeTruthy(); let members; members = await getGroupMemberIds(groupId1); expect(members.sort()).toEqual([userId1, userId2].sort()); members = await getGroupMemberIds(groupId2); expect(members.sort()).toEqual([userId1].sort()); let user; user = await getUser(userId2); expect(user.Email).toBe(email2); expect(user.LastName).toBe("Jones"); }); test("can remove users from lists including ones they aren't in", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Smith" }, newRecordProperties: { Email: email1, LastName: "Smith" }, oldGroups: [group1, group2], newGroups: [group1], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones" }, newRecordProperties: { Email: email2, LastName: "Jones" }, oldGroups: [group2], newGroups: [group1], toDelete: false, record: null, }, ], }); expect(errors).toBeNull(); expect(success).toBe(true); let members; members = await getGroupMemberIds(groupId1); expect(members.sort()).toEqual([userId1, userId2].sort()); members = await getGroupMemberIds(groupId2); expect(members.sort()).toEqual([]); }); test("can ignore case for an email address", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1.toUpperCase(), LastName: "Smith", }, newRecordProperties: { Email: email1.toUpperCase(), LastName: "MACRON", }, oldGroups: [group1], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.LastName).toBe("MACRON"); let members; members = await getGroupMemberIds(groupId1); expect(members.sort()).toEqual([userId2].sort()); members = await getGroupMemberIds(groupId2); expect(members.sort()).toEqual([]); }); test("can set back to lowercase", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1.toUpperCase(), LastName: "MACRON", }, newRecordProperties: { Email: email1, LastName: "Smith", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.LastName).toBe("Smith"); }); test("can handle unknown field", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Smith", }, newRecordProperties: { Email: email1, LastName: "Simpson", unknown_field: "here", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(errors).toBeNull(); expect(success).toBe(true); user = await getUser(userId1); expect(user.Email).toBe(email1); expect(user.LastName).toBe("Simpson"); }); test("can not (boo!) handle checkbox error", async () => { try { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones" }, newRecordProperties: { Email: email2, lastName: "Jones", checkbox_field__c: "other", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); } catch (error) { expect(error.message).toContain("boolean"); } let user; user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(false); // still defaulted expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(user.percent_field__c).toEqual(null); expect(user.email_field__c).toEqual(null); expect(user.phone_field__c).toEqual(null); expect(user.picklist_field__c).toEqual(null); expect(user.text_field__c).toEqual(null); expect(user.textarea_field__c).toEqual(null); expect(user.url_field__c).toEqual(null); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Jones"); }); test("can not (boo!) handle datetime error", async () => { try { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones" }, newRecordProperties: { Email: email2, lastName: "Jones", datetime_field__c: "yesterday", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); } catch (error) { expect(error.message).toContain("datetime"); } let user; user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(false); // still defaulted expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(user.percent_field__c).toEqual(null); expect(user.email_field__c).toEqual(null); expect(user.phone_field__c).toEqual(null); expect(user.picklist_field__c).toEqual(null); expect(user.text_field__c).toEqual(null); expect(user.textarea_field__c).toEqual(null); expect(user.url_field__c).toEqual(null); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Jones"); }); test("can handle email error", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones" }, newRecordProperties: { Email: email2, lastName: "Jones", email_field__c: "badmail", }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(success).toBe(false); expect(errors).not.toBeNull(); expect(errors.length).toEqual(1); const error = errors[0]; expect(error.recordId).toEqual(id2); expect(error.message).toContain("email"); user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(false); expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(user.percent_field__c).toEqual(null); expect(user.email_field__c).toEqual(null); expect(user.phone_field__c).toEqual(null); expect(user.picklist_field__c).toEqual(null); expect(user.text_field__c).toEqual(null); expect(user.textarea_field__c).toEqual(null); expect(user.url_field__c).toEqual(null); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Jones"); }); test("can handle picklist error", async () => { const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones" }, newRecordProperties: { Email: email2, lastName: "Jones", picklist_field__c: "Other", // not in list! }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(success).toBe(false); expect(errors).not.toBeNull(); expect(errors.length).toEqual(1); const error = errors[0]; expect(error.recordId).toEqual(id2); expect(error.message).toContain("picklist"); user = await getUser(userId2); expect(user.checkbox_field__c).toEqual(false); expect(user.datetime_field__c).toEqual(null); expect(user.number_field__c).toEqual(null); expect(user.percent_field__c).toEqual(null); expect(user.email_field__c).toEqual(null); expect(user.phone_field__c).toEqual(null); expect(user.picklist_field__c).toEqual(null); expect(user.text_field__c).toEqual(null); expect(user.textarea_field__c).toEqual(null); expect(user.url_field__c).toEqual(null); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Jones"); }); test("can handle some of them working, but not others", async () => { userId3 = await findId(email3); expect(userId3).toBe(null); const { success, errors } = await exportBatch({ appId, appOptions, destinationOptions, syncOperations, exports: [ { recordId: id1, oldRecordProperties: { Email: email1, LastName: "Simpson", }, newRecordProperties: { Email: email1, LastName: "Test", "Account.Name": account1, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, { recordId: id2, oldRecordProperties: { Email: email2, LastName: "Jones", }, newRecordProperties: { Email: email2, LastName: "Simpson", email_field__c: "badone", "Account.Name": account1, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, { recordId: id3, oldRecordProperties: {}, newRecordProperties: { Email: email3, LastName: "King", email_field__c: "valid@grouparoo.com", "Account.Name": account1, }, oldGroups: [], newGroups: [], toDelete: false, record: null, }, ], }); let user; expect(success).toBe(false); expect(errors).not.toBeNull(); expect(errors.length).toEqual(1); const error = errors[0]; expect(error.recordId).toEqual(id2); expect(error.message).toContain("email"); user = await getUser(userId1); expect(user.Email).toEqual(email1); expect(user.LastName).toEqual("Test"); expect(user.email_field__c).toEqual(null); expect(user.AccountId).toEqual(accountId1); user = await getUser(userId2); expect(user.Email).toEqual(email2); expect(user.LastName).toEqual("Jones"); // not updated expect(user.email_field__c).toEqual(null); expect(user.AccountId).toEqual(null); // not updated userId3 = await findId(email3); expect(userId3).toBeTruthy(); user = await getUser(userId3); expect(user.Email).toEqual(email3); expect(user.LastName).toEqual("King"); // created expect(user.email_field__c).toEqual("valid@grouparoo.com"); expect(user.AccountId).toEqual(accountId1); const referenced = await getReferencedUserIds(accountId1); expect(referenced.sort()).toEqual([userId1, userId3].sort()); }); });