Add 5 more destinations to centralized versioning-info.ts

Added:
- customerio (v2) - utils for Track API
- salesforce-marketing-cloud (v1, v2) - Hub, Auth, and Data API versions
- responsys (v1.3) - Async API version
- rokt-audiences (v3) - Data API
- insider-audiences (v1) - Unification API

Co-authored-by: abhandage <174417010+abhandage@users.noreply.github.com>

Author: Copilot

packages/destination-actions/src/destinations/customerio/utils.ts

@@ -1,6 +1,7 @@
 import dayjs from '../../lib/dayjs'
 import isPlainObject from 'lodash/isPlainObject'
 import { fullFormats } from 'ajv-formats/dist/formats'
+import { CUSTOMERIO_TRACK_API_VERSION } from '../versioning-info'
 
 const isEmail = (value: string): boolean => {
   return (fullFormats.email as RegExp).test(value)
@@ -203,7 +204,7 @@ export const sendBatch = <Payload extends BasePayload>(request: Function, option
   const [{ settings }] = options
   const batch = options.map((opts) => buildPayload(opts))
 
-  return request(`${trackApiEndpoint(settings)}/api/v2/batch`, {
+  return request(`${trackApiEndpoint(settings)}/api/${CUSTOMERIO_TRACK_API_VERSION}/batch`, {
     method: 'post',
     json: {
       batch
@@ -213,7 +214,7 @@ export const sendBatch = <Payload extends BasePayload>(request: Function, option
 
 export const sendSingle = <Payload extends BasePayload>(request: Function, options: RequestPayload<Payload>) => {
   const json = buildPayload(options)
-  return request(`${trackApiEndpoint(options.settings)}/api/v2/entity`, {
+  return request(`${trackApiEndpoint(options.settings)}/api/${CUSTOMERIO_TRACK_API_VERSION}/entity`, {
     method: 'post',
     json
   })

packages/destination-actions/src/destinations/insider-audiences/insider-helpers.ts

@@ -1,9 +1,10 @@
 import { ModifiedResponse, RequestOptions } from '@segment/actions-core'
 import { Payload } from './insiderAudiences/generated-types'
+import { INSIDER_UNIFICATION_API_VERSION } from '../versioning-info'
 
 export const API_BASE = 'https://unification.useinsider.com/api/'
-export const UPSERT_ENDPOINT = 'user/v1/upsert'
-export const DELETE_ATTRIBUTE_ENDPOINT = 'user/v1/attribute/delete'
+export const UPSERT_ENDPOINT = `user/${INSIDER_UNIFICATION_API_VERSION}/upsert`
+export const DELETE_ATTRIBUTE_ENDPOINT = `user/${INSIDER_UNIFICATION_API_VERSION}/attribute/delete`
 const AUDIENCE_TYPE = 'audience'
 const IDENTIFY = 'identify'
 const TRACK = 'track'

packages/destination-actions/src/destinations/responsys/utils.ts

@@ -19,6 +19,8 @@ import {
   ModifiedResponse,
   createRequestClient
 } from '@segment/actions-core'
+import { RESPONSYS_ASYNC_API_VERSION } from '../versioning-info'
+} from '@segment/actions-core'
 import type { Settings } from './generated-types'
 
 // Rate limits per endpoint.
@@ -148,7 +150,7 @@ export const sendCustomTraits = async (
     matchColumnName1: settings.matchColumnName1,
     matchColumnName2: settings.matchColumnName2 || ''
   }
-  const path = `/rest/asyncApi/v1.3/lists/${settings.profileListName}/listExtensions/${settings.profileExtensionTable}/members`
+  const path = `/rest/asyncApi/${RESPONSYS_ASYNC_API_VERSION}/lists/${settings.profileListName}/listExtensions/${settings.profileExtensionTable}/members`
 
   const endpoint = new URL(path, settings.baseUrl)
 
@@ -232,7 +234,7 @@ export const upsertListMembers = async (
         mergeRule
       }
 
-      const path = `/rest/${usingAsyncApi ? 'asyncApi' : 'api'}/v1.3/lists/${settings.profileListName}/members`
+      const path = `/rest/${usingAsyncApi ? 'asyncApi' : 'api'}/${RESPONSYS_ASYNC_API_VERSION}/lists/${settings.profileListName}/members`
       const endpoint = new URL(path, settings.baseUrl)
 
       const headers = {
@@ -321,7 +323,7 @@ export const getAsyncResponse = async (
     }
   }
 
-  const operationResponseEndpoint = new URL(`/rest/asyncApi/v1.3/requests/${requestId}`, settings.baseUrl)
+  const operationResponseEndpoint = new URL(`/rest/asyncApi/${RESPONSYS_ASYNC_API_VERSION}/requests/${requestId}`, settings.baseUrl)
   const request = createRequestClient(headers)
   // Take a break.
   await new Promise((resolve) => setTimeout(resolve, getAsyncResponseWaitInterval))

packages/destination-actions/src/destinations/rokt-audiences/constants.ts

@@ -1,8 +1,10 @@
+import { ROKT_API_VERSION } from '../versioning-info'
+
 export const CONSTANTS = {
   // rokt
   INCLUDE: 'include',
   EXCLUDE: 'exclude',
-  ROKT_API_BASE_URL: 'https://data.rokt.com/v3',
+  ROKT_API_BASE_URL: `https://data.rokt.com/${ROKT_API_VERSION}`,
   ROKT_API_CUSTOM_AUDIENCE_ENDPOINT: '/import/suppression',
   ROKT_API_AUTH_ENDPOINT: '/auth-check',
 

packages/destination-actions/src/destinations/salesforce-marketing-cloud/sfmc-operations.ts

@@ -16,6 +16,11 @@ import { ErrorResponse, ErrorData } from './types'
 import { OnMappingSaveInputs } from './dataExtensionV2/generated-types'
 import { Settings } from './generated-types'
 import { xml2js } from 'xml-js'
+import {
+  SALESFORCE_MARKETING_CLOUD_HUB_API_VERSION,
+  SALESFORCE_MARKETING_CLOUD_AUTH_API_VERSION,
+  SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION
+} from '../versioning-info'
 
 function generateRows(payloads: payload_dataExtension[] | payload_contactDataExtension[]): Record<string, any>[] {
   const rows: Record<string, any>[] = []
@@ -52,12 +57,12 @@ export function upsertRows(
   }
   const rows = generateRows(payloads)
   if (key) {
-    return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/v1/dataevents/key:${key}/rowset`, {
+    return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/${SALESFORCE_MARKETING_CLOUD_HUB_API_VERSION}/dataevents/key:${key}/rowset`, {
       method: 'POST',
       json: rows
     })
   } else {
-    return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/v1/dataevents/${id}/rowset`, {
+    return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/${SALESFORCE_MARKETING_CLOUD_HUB_API_VERSION}/dataevents/${id}/rowset`, {
       method: 'POST',
       json: rows
     })
@@ -79,7 +84,7 @@ export function upsertRowsV2(
   }
 
   const rows = generateRows(payloads)
-  return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/v1/dataevents/${dataExtensionId}/rowset`, {
+  return request(`https://${subdomain}.rest.marketingcloudapis.com/hub/${SALESFORCE_MARKETING_CLOUD_HUB_API_VERSION}/dataevents/${dataExtensionId}/rowset`, {
     method: 'POST',
     json: rows
   })
@@ -239,7 +244,7 @@ const getAccessToken = async (
   request: RequestClient,
   settings: Settings
 ): Promise<{ accessToken: string; soapInstanceUrl: string }> => {
-  const baseUrl = `https://${settings.subdomain}.auth.marketingcloudapis.com/v2/token`
+  const baseUrl = `https://${settings.subdomain}.auth.marketingcloudapis.com/${SALESFORCE_MARKETING_CLOUD_AUTH_API_VERSION}/token`
   const res = await request<RefreshTokenResponse>(`${baseUrl}`, {
     method: 'POST',
     body: new URLSearchParams({
@@ -288,7 +293,7 @@ const dataExtensionRequest = async (
 
   try {
     const response = await request<DataExtensionCreationResponse>(
-      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/v1/customobjects`,
+      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/${SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION}/customobjects`,
       {
         method: 'POST',
         json: {
@@ -365,7 +370,7 @@ const selectDataExtensionRequest = async (
 
   try {
     const response = await request<DataExtensionSelectionResponse>(
-      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/v1/customobjects/${hookInputs.dataExtensionId}`,
+      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/${SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION}/customobjects/${hookInputs.dataExtensionId}`,
       {
         method: 'GET',
         headers: {
@@ -462,7 +467,7 @@ const getDataExtensionsRequest = async (
 ): Promise<{ results?: DynamicFieldItem[]; error?: DynamicFieldError }> => {
   try {
     const response = await request<DataExtensionSearchResponse>(
-      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/v1/customobjects`,
+      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/${SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION}/customobjects`,
       {
         method: 'get',
         searchParams: {
@@ -550,7 +555,7 @@ const getDataExtensionFieldsRequest = async (
 ): Promise<{ results?: DynamicFieldItem[]; error?: DynamicFieldError }> => {
   try {
     const response = await request<DataExtensionFieldsResponse>(
-      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/v1/customobjects/${dataExtensionId}/fields`,
+      `https://${auth.subdomain}.rest.marketingcloudapis.com/data/${SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION}/customobjects/${dataExtensionId}/fields`,
       {
         method: 'GET',
         headers: {

packages/destination-actions/src/destinations/versioning-info.ts

@@ -403,3 +403,38 @@ export const OUTFUNNEL_API_VERSION = 'v1'
  * Talon.One Segment integration API version
  */
 export const TALON_ONE_API_VERSION = 'v2'
+
+/**
+ * Customer.io Track API version
+ */
+export const CUSTOMERIO_TRACK_API_VERSION = 'v2'
+
+/**
+ * Salesforce Marketing Cloud Hub API version
+ */
+export const SALESFORCE_MARKETING_CLOUD_HUB_API_VERSION = 'v1'
+
+/**
+ * Salesforce Marketing Cloud Auth API version
+ */
+export const SALESFORCE_MARKETING_CLOUD_AUTH_API_VERSION = 'v2'
+
+/**
+ * Salesforce Marketing Cloud Data API version
+ */
+export const SALESFORCE_MARKETING_CLOUD_DATA_API_VERSION = 'v1'
+
+/**
+ * Responsys Async API version
+ */
+export const RESPONSYS_ASYNC_API_VERSION = 'v1.3'
+
+/**
+ * Rokt Data API version
+ */
+export const ROKT_API_VERSION = 'v3'
+
+/**
+ * Insider Unification API version
+ */
+export const INSIDER_UNIFICATION_API_VERSION = 'v1'