feat: onboard new api for klaviyo 15-06-2024

src/constants/destinationCanonicalNames.js

@@ -173,6 +173,7 @@ const DestCanonicalNames = {
     'Klaviyo Bulk Upload',
     'klaviyobulkupload',
   ],
+  Klaviyo: ['KLAVIYO', 'Klaviyo', 'klaviyo'],
   emarsys: ['EMARSYS', 'Emarsys', 'emarsys'],
   wunderkind: ['wunderkind', 'Wunderkind', 'WUNDERKIND'],
 };

src/v0/destinations/klaviyo/batchUtil.js

@@ -0,0 +1,202 @@
+const lodash = require('lodash');
+const {
+  defaultBatchRequestConfig,
+  getSuccessRespEvents,
+  isDefinedAndNotNull,
+} = require('../../util');
+const { JSON_MIME_TYPE } = require('../../util/constant');
+const { BASE_ENDPOINT, CONFIG_CATEGORIES, MAX_BATCH_SIZE, revision } = require('./config');
+const { buildRequest, getSubscriptionPayload } = require('./util');
+
+/**
+ * This function groups the subscription responses on list id
+ * @param {*} subscribeResponseList
+ * @returns
+ * Example subsribeResponseList =
+ * [
+ * { payload: {id:'list_id', profile: {}}, metadata:{} },
+ * { payload: {id:'list_id', profile: {}}, metadata:{} }
+ * ]
+ */
+const groupSubscribeResponsesUsingListIdV2 = (subscribeResponseList) => {
+  const subscribeEventGroups = lodash.groupBy(
+    subscribeResponseList,
+    (event) => event.payload.listId,
+  );
+  return subscribeEventGroups;
+};
+
+/**
+ * This function takes susbscription as input and batches them into a single request body
+ * @param {subscription}
+ * subscription= {listId, subscriptionProfileList}
+ */
+const generateBatchedSubscriptionRequest = (subscription, destination) => {
+  const batchEventResponse = defaultBatchRequestConfig();
+  // if( !isDefinedAndNotNull(subscription) )
+  // fetching listId from first event as listId is same for all the events
+  const profiles = []; // list of profiles to be subscribed
+  const { listId, subscriptionProfileList } = subscription;
+  subscriptionProfileList.forEach((profileList) => profiles.push(...profileList));
+  batchEventResponse.batchedRequest.body.JSON = getSubscriptionPayload(listId, profiles);
+  batchEventResponse.batchedRequest.endpoint = `${BASE_ENDPOINT}/api/profile-subscription-bulk-create-jobs`;
+  batchEventResponse.batchedRequest.headers = {
+    Authorization: `Klaviyo-API-Key ${destination.Config.privateApiKey}`,
+    'Content-Type': JSON_MIME_TYPE,
+    Accept: JSON_MIME_TYPE,
+    revision,
+  };
+  return batchEventResponse.batchedRequest;
+};
+
+/**
+ * This function updates batchedRequest with profile requests
+ * @param {*} profiles
+ * @param {*} batchedRequest
+ * @param {*} destination
+ */
+const updateBatchEventResponseWithProfileRequests = (profiles, batchedRequest, destination) => {
+  const profilesRequests = [];
+  profiles.forEach((profile) => {
+    profilesRequests.push(buildRequest(profile, destination, CONFIG_CATEGORIES.IDENTIFYV2));
+  });
+  // we are keeping profiles request prior to subscription ones as first profile creation and then subscription should happen
+  batchedRequest.unshift(...profilesRequests);
+};
+
+/**
+ * this function populates profileSubscriptionAndMetadataArr with respective profiles based upon common metadata
+ * @param {*} profileSubscriptionAndMetadataArr
+ * @param {*} metadataIndexMap
+ * @param {*} profiles
+ * @returns updated profileSubscriptionAndMetadataArr obj
+ */
+const populateArrWithRespectiveProfileData = (
+  profileSubscriptionAndMetadataArr,
+  metadataIndexMap,
+  profiles,
+) => {
+  const updatedPSMArr = profileSubscriptionAndMetadataArr;
+  profiles.forEach((profile) => {
+    const index = metadataIndexMap[profile.metadata.jobId];
+    if (isDefinedAndNotNull(index)) {
+      // using isDefinedAndNotNull as index can be 0
+      updatedPSMArr[index].profiles.push(profile.payload);
+    } else {
+      // in case there is no subscription for a given profile
+      updatedPSMArr.push({
+        profiles: [profile.payload],
+        metadataList: [profile.metadata],
+      });
+    }
+  });
+  return updatedPSMArr;
+};
+
+/**
+ * This function generates the final output batched payload for each object in profileSubscriptionAndMetadataArr
+ * ex: 
+ * profileSubscriptionAndMetadataArr = [
+      {
+        subscription: { subscriptionProfileList, listId1 },
+        metadataList1,
+        profiles: [respectiveProfiles for above metadata]
+      },
+      {
+        subscription: { subscriptionProfile List With No Profiles, listId2 },
+        metadataList2,
+      },
+      {
+        metadataList3,
+        profiles: [respectiveProfiles for above metadata with no subscription]
+      }
+  ]
+ * @param {*} profileSubscriptionAndMetadataArr 
+ * @param {*} destination 
+ * @returns 
+ */
+const buildRequestsForProfileSubscriptionAndMetadataArr = (
+  profileSubscriptionAndMetadataArr,
+  destination,
+) => {
+  const batchedResponseList = [];
+  profileSubscriptionAndMetadataArr.forEach((input) => {
+    const batchedRequest = [];
+    if (input.subscription) {
+      batchedRequest.push(generateBatchedSubscriptionRequest(input.subscription, destination));
+    }
+    updateBatchEventResponseWithProfileRequests(input.profiles, batchedRequest, destination);
+    batchedResponseList.push(
+      getSuccessRespEvents(batchedRequest, input.metadataList, destination, true),
+    );
+  });
+  return batchedResponseList;
+};
+
+const batchRequestV2 = (subscribeRespList, profileRespList, destination) => {
+  const subscribeEventGroups = groupSubscribeResponsesUsingListIdV2(subscribeRespList);
+  let profileSubscriptionAndMetadataArr = [];
+  const metadataIndexMap = {};
+  Object.keys(subscribeEventGroups).forEach((listId) => {
+    // eventChunks = [[e1,e2,e3,..batchSize],[e1,e2,e3,..batchSize]..]
+    const eventChunks = lodash.chunk(subscribeEventGroups[listId], MAX_BATCH_SIZE);
+    eventChunks.forEach((chunk, index) => {
+      // get subscriptionProfiles for the chunk
+      const subscriptionProfileList = chunk.map((event) => event.payload?.profile);
+      // get metadata for this chunk
+      const metadataList = chunk.map((event) => event.metadata);
+      // get list of jobIds from the above metdadata
+      const jobIdList = metadataList.map((metadata) => metadata.jobId);
+      // push the jobId: index to metadataIndex mapping which let us know the metadata respective payload index position in batched request
+      jobIdList.forEach((jobId) => {
+        metadataIndexMap[jobId] = index;
+      });
+      profileSubscriptionAndMetadataArr.push({
+        subscription: { subscriptionProfileList, listId },
+        metadataList,
+        profiles: [],
+      });
+    });
+  });
+  profileSubscriptionAndMetadataArr = populateArrWithRespectiveProfileData(
+    profileSubscriptionAndMetadataArr,
+    metadataIndexMap,
+    profileRespList,
+  );
+  /* Till this point I have a profileSubscriptionAndMetadataArr 
+  containing the the events in one object for which batching has to happen in following format
+  [
+      {
+        subscription: { subscriptionProfileList, listId1 },
+        metadataList1,
+        profiles: [respectiveProfiles for above metadata]
+      },
+      {
+        subscription: { subscriptionProfile List With No Profiles, listId2 },
+        metadataList2,
+      },
+      {
+        metadataList3,
+        profiles: [respectiveProfiles for above metadata with no subscription]
+      }
+  ]
+  */
+  return buildRequestsForProfileSubscriptionAndMetadataArr(
+    profileSubscriptionAndMetadataArr,
+    destination,
+  );
+  /* for identify calls with batching batched with identify with no batching
+  we will sonctruct O/P as:
+    [
+      [2 calls for identifywith batching],
+      [1 call identify calls with batching]
+    ] 
+  */
+};
+
+module.exports = {
+  groupSubscribeResponsesUsingListIdV2,
+  populateArrWithRespectiveProfileData,
+  generateBatchedSubscriptionRequest,
+  batchRequestV2,
+};

src/v0/destinations/klaviyo/batchUtil.test.js

@@ -0,0 +1,186 @@
+const {
+  groupSubscribeResponsesUsingListIdV2,
+  populateArrWithRespectiveProfileData,
+  generateBatchedSubscriptionRequest,
+} = require('./batchUtil');
+const { revision } = require('./config');
+
+describe('groupSubscribeResponsesUsingListIdV2', () => {
+  // Groups subscription responses by listId correctly
+  it('should group subscription responses by listId correctly when given a valid list', () => {
+    const subscribeResponseList = [
+      { payload: { listId: 'list_1', profile: {} }, metadata: {} },
+      { payload: { listId: 'list_1', profile: {} }, metadata: {} },
+      { payload: { listId: 'list_2', profile: {} }, metadata: {} },
+    ];
+
+    const expectedOutput = {
+      list_1: [
+        { payload: { listId: 'list_1', profile: {} }, metadata: {} },
+        { payload: { listId: 'list_1', profile: {} }, metadata: {} },
+      ],
+      list_2: [{ payload: { listId: 'list_2', profile: {} }, metadata: {} }],
+    };
+
+    const result = groupSubscribeResponsesUsingListIdV2(subscribeResponseList);
+
+    expect(result).toEqual(expectedOutput);
+  });
+
+  // Handles empty subscription response list
+  it('should return an empty object when given an empty subscription response list', () => {
+    const subscribeResponseList = [];
+
+    const expectedOutput = {};
+
+    const result = groupSubscribeResponsesUsingListIdV2(subscribeResponseList);
+
+    expect(result).toEqual(expectedOutput);
+  });
+});
+
+describe('populateArrWithRespectiveProfileData', () => {
+  // Correctly populates array when all profiles have corresponding metadata
+  it('should correctly populate array when all profiles have corresponding metadata', () => {
+    const profileSubscriptionAndMetadataArr = [
+      { profiles: [], metadataList: [{ jobId: '1' }], subscriptions: [] },
+      { profiles: [], metadataList: [{ jobId: '2' }], subscriptions: [] },
+    ];
+    const metadataIndexMap = { 1: 0, 2: 1 };
+    const profiles = [
+      { payload: { name: 'John' }, metadata: { jobId: '1' } },
+      { payload: { name: 'Doe' }, metadata: { jobId: '2' } },
+    ];
+
+    const result = populateArrWithRespectiveProfileData(
+      profileSubscriptionAndMetadataArr,
+      metadataIndexMap,
+      profiles,
+    );
+
+    expect(result[0].profiles).toEqual([{ name: 'John' }]);
+    expect(result[1].profiles).toEqual([{ name: 'Doe' }]);
+  });
+
+  // Handles empty profileSubscriptionAndMetadataArr input
+  it('should handle empty profileSubscriptionAndMetadataArr input', () => {
+    const profileSubscriptionAndMetadataArr = [];
+    const metadataIndexMap = {};
+    const profiles = [{ payload: { name: 'John' }, metadata: { jobId: '1' } }];
+
+    const result = populateArrWithRespectiveProfileData(
+      profileSubscriptionAndMetadataArr,
+      metadataIndexMap,
+      profiles,
+    );
+
+    expect(result).toEqual([
+      {
+        profiles: [{ name: 'John' }],
+        metadataList: [{ jobId: '1' }],
+      },
+    ]);
+  });
+});
+
+// Generated by CodiumAI
+
+describe('generateBatchedSubscriptionRequest', () => {
+  // Generates a batched subscription request with valid subscription and destination inputs
+  it('should generate a valid batched subscription request when given valid subscription and destination inputs', () => {
+    const subscription = {
+      listId: 'test-list-id',
+      subscriptionProfileList: [[{ id: 'profile1' }, { id: 'profile2' }], [{ id: 'profile3' }]],
+    };
+    const destination = {
+      Config: {
+        privateApiKey: 'test-api-key',
+      },
+    };
+    const expectedRequest = {
+      version: '1',
+      type: 'REST',
+      method: 'POST',
+      endpoint: 'https://a.klaviyo.com/api/profile-subscription-bulk-create-jobs',
+      headers: {
+        Authorization: 'Klaviyo-API-Key test-api-key',
+        'Content-Type': 'application/json',
+        Accept: 'application/json',
+        revision,
+      },
+      params: {},
+      body: {
+        JSON: {
+          data: {
+            type: 'profile-subscription-bulk-create-job',
+            attributes: {
+              profiles: { data: [{ id: 'profile1' }, { id: 'profile2' }, { id: 'profile3' }] },
+            },
+            relationships: {
+              list: {
+                data: {
+                  type: 'list',
+                  id: 'test-list-id',
+                },
+              },
+            },
+          },
+        },
+        JSON_ARRAY: {},
+        XML: {},
+        FORM: {},
+      },
+      files: {},
+    };
+    const result = generateBatchedSubscriptionRequest(subscription, destination);
+    expect(result).toEqual(expectedRequest);
+  });
+
+  // Handles empty subscriptionProfileList gracefully
+  it('should handle empty subscriptionProfileList gracefully', () => {
+    const subscription = {
+      listId: 'test-list-id',
+      subscriptionProfileList: [],
+    };
+    const destination = {
+      Config: {
+        privateApiKey: 'test-api-key',
+      },
+    };
+    const expectedRequest = {
+      version: '1',
+      type: 'REST',
+      method: 'POST',
+      endpoint: 'https://a.klaviyo.com/api/profile-subscription-bulk-create-jobs',
+      headers: {
+        Authorization: 'Klaviyo-API-Key test-api-key',
+        'Content-Type': 'application/json',
+        Accept: 'application/json',
+        revision,
+      },
+      params: {},
+      body: {
+        JSON: {
+          data: {
+            type: 'profile-subscription-bulk-create-job',
+            attributes: { profiles: { data: [] } },
+            relationships: {
+              list: {
+                data: {
+                  type: 'list',
+                  id: 'test-list-id',
+                },
+              },
+            },
+          },
+        },
+        JSON_ARRAY: {},
+        XML: {},
+        FORM: {},
+      },
+      files: {},
+    };
+    const result = generateBatchedSubscriptionRequest(subscription, destination);
+    expect(result).toEqual(expectedRequest);
+  });
+});