KSD-31: Improve email comparisons for profile deduplication (#250)

Author: andreshernandez-e2x

plugin/src/infrastructure/driven/klaviyo/KlaviyoSdkService.ts

@@ -114,7 +114,8 @@ export class KlaviyoSdkService extends KlaviyoService {
             // If multiple profiles exist with same email, return the first one
             // In practice, Klaviyo should prevent duplicates, but we handle edge case
             const profile = profiles?.body.data?.find(
-                (profile: GetProfileResponseData) => profile.attributes.email === email,
+                (profile: GetProfileResponseData) =>
+                    profile.attributes.email?.toLowerCase() === email.toLowerCase(),
             );
             if (profiles?.body.data && profiles.body.data.length > 1) {
                 logger.warn('Multiple profiles found for email. Using first match.');

plugin/src/test/e2e/postman/klaviyo-e2e-tests.postman_collection.json

@@ -366,7 +366,7 @@
 									"     pm.test(\"Profile was created in klaviyo\", function () {",
 									"          pm.response.to.have.status(expectedHttpStatus);",
 									"          pm.expect(jsonData.data.length).to.be.above(0);",
-									"          pm.expect(jsonData.data[0].attributes.email).to.eql(pm.environment.get(\"customer-email\"));",
+									"          pm.expect(jsonData.data[0].attributes.email.toLowerCase()).to.eql(pm.environment.get(\"customer-email\").toLowerCase());",
 									"     });",
 									"}",
 									""
@@ -1984,7 +1984,7 @@
 									"        pm.expect(jsonData.data.length).to.be.above(0);",
 									"    });",
 									"",
-									"    const profile = jsonData.data.find(p => p.attributes.email === pm.environment.get(\"dedup-customer-email\"));",
+									"    const profile = jsonData.data.find(p => p.attributes.email.toLowerCase() === pm.environment.get(\"dedup-customer-email\").toLowerCase());",
 									"    if (profile && profile.id) {",
 									"        pm.environment.set(\"existing-klaviyo-profile-id\", profile.id);",
 									"        console.log(\"Found existing profile with ID: \" + profile.id);",
@@ -2287,7 +2287,7 @@
 									"}",
 									"",
 									"const jsonData = pm.response.json();",
-									"const profile = jsonData.data ? jsonData.data.find(p => p.attributes.email === pm.environment.get(\"dedup-customer-email\")) : null;",
+									"const profile = jsonData.data ? jsonData.data.find(p => p.attributes.email.toLowerCase() === pm.environment.get(\"dedup-customer-email\").toLowerCase()) : null;",
 									"const profileFound = profile !== null && profile !== undefined;",
 									"const externalIdSet = profile && profile.attributes && profile.attributes.external_id === pm.environment.get(\"customer-id\");",
 									"const elapsedTime = Date.now() - parseInt(startTime, 10);",