fest(Segment): add all new endpoints to segment

packages/destination-actions/src/destinations/talon-one/__tests__/__snapshots__/snapshot.test.ts.snap

@@ -59,6 +59,23 @@ Object {
 }
 `;
 
+exports[`Testing snapshot for actions-talon-one destination: trackEventV2 action - all fields 1`] = `
+Object {
+  "customerProfileId": "e)TF!ogVx#Nvh4",
+  "eventAttributes": Object {
+    "testType": "e)TF!ogVx#Nvh4",
+  },
+  "eventType": "e)TF!ogVx#Nvh4",
+}
+`;
+
+exports[`Testing snapshot for actions-talon-one destination: trackEventV2 action - required fields 1`] = `
+Object {
+  "customerProfileId": "e)TF!ogVx#Nvh4",
+  "eventType": "e)TF!ogVx#Nvh4",
+}
+`;
+
 exports[`Testing snapshot for actions-talon-one destination: updateAudience action - all fields 1`] = `
 Object {
   "audienceName": "y73nLJ!",
@@ -135,6 +152,29 @@ Object {
 }
 `;
 
+exports[`Testing snapshot for actions-talon-one destination: updateCustomerProfileV3 action - all fields 1`] = `
+Object {
+  "attributes": Object {
+    "testType": "GeWo@^$JGyRkK",
+  },
+  "audiencesChanges": Object {
+    "adds": Array [
+      525191390167040,
+    ],
+    "deletes": Array [
+      525191390167040,
+    ],
+  },
+  "runRuleEngine": false,
+}
+`;
+
+exports[`Testing snapshot for actions-talon-one destination: updateCustomerProfileV3 action - required fields 1`] = `
+Object {
+  "audiencesChanges": Object {},
+}
+`;
+
 exports[`Testing snapshot for actions-talon-one destination: updateCustomerProfilesAudiences action - all fields 1`] = `
 Object {
   "data": Array [
@@ -203,3 +243,55 @@ Object {
   "customerSession": Object {},
 }
 `;
+
+exports[`Testing snapshot for actions-talon-one destination: updateCustomerSessionV2 action - all fields 1`] = `
+Object {
+  "additionalCosts": Object {
+    "testType": "J(4saNJrsRd8Z]iG%36t",
+  },
+  "attributes": Object {
+    "testType": "J(4saNJrsRd8Z]iG%36t",
+  },
+  "cartItems": Array [
+    Object {
+      "additionalCosts": Object {
+        "testType": "J(4saNJrsRd8Z]iG%36t",
+      },
+      "attributes": Object {
+        "testType": "J(4saNJrsRd8Z]iG%36t",
+      },
+      "category": "J(4saNJrsRd8Z]iG%36t",
+      "height": "J(4saNJrsRd8Z]iG%36t",
+      "length": "J(4saNJrsRd8Z]iG%36t",
+      "name": "J(4saNJrsRd8Z]iG%36t",
+      "position": "J(4saNJrsRd8Z]iG%36t",
+      "price": 89572104743157.77,
+      "quantity": 89572104743157.77,
+      "remainingQuantity": "J(4saNJrsRd8Z]iG%36t",
+      "returnedQuantity": "J(4saNJrsRd8Z]iG%36t",
+      "sku": "J(4saNJrsRd8Z]iG%36t",
+      "weight": "J(4saNJrsRd8Z]iG%36t",
+    },
+  ],
+  "couponCodes": Array [
+    "J(4saNJrsRd8Z]iG%36t",
+  ],
+  "identifiers": Array [
+    "J(4saNJrsRd8Z]iG%36t",
+  ],
+  "loyaltyCards": Array [
+    "J(4saNJrsRd8Z]iG%36t",
+  ],
+  "profileId": "J(4saNJrsRd8Z]iG%36t",
+  "referralCode": "J(4saNJrsRd8Z]iG%36t",
+  "state": "cancelled",
+}
+`;
+
+exports[`Testing snapshot for actions-talon-one destination: updateCustomerSessionV2 action - required fields 1`] = `
+Object {
+  "identifiers": Array [
+    "J(4saNJrsRd8Z]iG%36t",
+  ],
+}
+`;

packages/destination-actions/src/destinations/talon-one/index.ts

@@ -9,6 +9,9 @@ import updateCustomerProfilesAudiences from './updateCustomerProfilesAudiences'
 import trackEvent from './trackEvent'
 import updateCustomerProfileV2 from './updateCustomerProfileV2'
 import updateCustomerSession from './updateCustomerSession'
+import trackEventV2 from './trackEventV2'
+import updateCustomerSessionV2 from './updateCustomerSessionV2'
+import updateCustomerProfileV3 from './updateCustomerProfileV3'
 
 const destination: DestinationDefinition<Settings> = {
   name: 'Talon.One (Actions)',
@@ -53,10 +56,13 @@ const destination: DestinationDefinition<Settings> = {
     updateAudience,
     deleteAudience,
     updateCustomerProfile,
+    updateCustomerProfileV2,
+    updateCustomerProfileV3,
     updateCustomerProfilesAudiences,
     trackEvent,
-    updateCustomerProfileV2,
-    updateCustomerSession
+    trackEventV2,
+    updateCustomerSession,
+    updateCustomerSessionV2
   }
 }
 

packages/destination-actions/src/destinations/talon-one/t1-properties.ts

@@ -225,3 +225,12 @@ export const cartItems: InputField = {
     }
   }
 }
+
+export const identifier: InputField = {
+  label: 'Identifier',
+  description:
+    'Session custom identifier that you can set limits on or use inside your rules. For example, you can use IP addresses as identifiers to potentially identify devices and limit discounts abuse in case of customers creating multiple accounts.',
+  type: 'string',
+  multiple: true,
+  required: false
+}

packages/destination-actions/src/destinations/talon-one/trackEvent/index.ts

@@ -6,8 +6,10 @@ import { attribute, customerProfileId } from '../t1-properties'
 const TARGET_EVENT_TYPE = 'string'
 
 const action: ActionDefinition<Settings, Payload> = {
-  title: 'Track Event',
-  description: 'This records a custom event in Talon.One.',
+  title: '[Deprecated] Track event',
+  description: `This records a custom event in Talon.One.
+
+  **Important:** This endpoint is deprecated. Use the current **Track event** endpoint instead.`,
   fields: {
     customerProfileId: {
       ...customerProfileId,

packages/destination-actions/src/destinations/talon-one/trackEventV2/__tests__/__snapshots__/snapshot.test.ts.snap

@@ -0,0 +1,18 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`Testing snapshot for TalonOne's trackEventV2 destination action: all fields 1`] = `
+Object {
+  "customerProfileId": "@*g0]#jUfAqZ28L86&D",
+  "eventAttributes": Object {
+    "testType": "@*g0]#jUfAqZ28L86&D",
+  },
+  "eventType": "@*g0]#jUfAqZ28L86&D",
+}
+`;
+
+exports[`Testing snapshot for TalonOne's trackEventV2 destination action: required fields 1`] = `
+Object {
+  "customerProfileId": "@*g0]#jUfAqZ28L86&D",
+  "eventType": "@*g0]#jUfAqZ28L86&D",
+}
+`;

packages/destination-actions/src/destinations/talon-one/trackEventV2/__tests__/index.test.ts

@@ -0,0 +1,73 @@
+import nock from 'nock'
+import { createTestIntegration } from '@segment/actions-core'
+import Destination from '../../index'
+
+const testDestination = createTestIntegration(Destination)
+
+describe('TalonOne.trackEventV2', () => {
+  it('misses customer profile ID', async () => {
+    try {
+      await testDestination.testAction('trackEventV2', {
+        settings: {
+          apiKey: 'some_api_key',
+          deployment: 'https://internal.europe-west1.talon.one'
+        }
+      })
+    } catch (err) {
+      expect(err.message).toContain("The root value is missing the required field 'customerProfileId'.")
+    }
+  })
+
+  it('misses event type', async () => {
+    try {
+      await testDestination.testAction('trackEvenV2', {
+        settings: {
+          apiKey: 'some_api_key',
+          deployment: 'https://internal.europe-west1.talon.one'
+        },
+        mapping: {
+          customerProfileId: 'some_customer_profile_id'
+        }
+      })
+    } catch (err) {
+      expect(err.message).toContain("The root value is missing the required field 'eventType'.")
+    }
+  })
+
+  it('should work', async () => {
+    nock('https://integration.talon.one')
+      .put('/segment/v2/events?skipNonExistingAttributes=true', {
+        customerProfileId: 'some_customer_profile_id',
+        eventType: 'event_type',
+        eventAttributes: {
+          favoriteProduct: 'fruits',
+          isDogLover: true,
+          stringAttribute: 'test',
+          booleanAttribute: 'true',
+          numberAttribute: '12345'
+        }
+      })
+      .matchHeader('Authorization', 'ApiKey-v1 some_api_key')
+      .matchHeader('destination-hostname', 'https://something.europe-west1.talon.one')
+      .reply(200)
+
+    await testDestination.testAction('trackEventV2', {
+      settings: {
+        apiKey: 'some_api_key',
+        deployment: 'https://something.europe-west1.talon.one'
+      },
+      mapping: {
+        customerProfileId: 'some_customer_profile_id',
+        skipNonExistingAttributes: true,
+        eventType: 'event_type',
+        attributes: {
+          favoriteProduct: 'fruits',
+          isDogLover: true,
+          stringAttribute: 'test',
+          booleanAttribute: 'true',
+          numberAttribute: '12345'
+        }
+      }
+    })
+  })
+})

packages/destination-actions/src/destinations/talon-one/trackEventV2/__tests__/snapshot.test.ts

@@ -0,0 +1,75 @@
+import { createTestEvent, createTestIntegration } from '@segment/actions-core'
+import { generateTestData } from '../../../../lib/test-data'
+import destination from '../../index'
+import nock from 'nock'
+
+const testDestination = createTestIntegration(destination)
+const actionSlug = 'trackEventV2'
+const destinationSlug = 'TalonOne'
+const seedName = `${destinationSlug}#${actionSlug}`
+
+describe(`Testing snapshot for ${destinationSlug}'s ${actionSlug} destination action:`, () => {
+  it('required fields', async () => {
+    const action = destination.actions[actionSlug]
+    const [eventData, settingsData] = generateTestData(seedName, destination, action, true)
+
+    nock(/.*/).persist().get(/.*/).reply(200)
+    nock(/.*/).persist().post(/.*/).reply(200)
+    nock(/.*/).persist().put(/.*/).reply(200)
+
+    const event = createTestEvent({
+      properties: eventData
+    })
+
+    const responses = await testDestination.testAction(actionSlug, {
+      event: event,
+      mapping: event.properties,
+      settings: settingsData,
+      auth: undefined
+    })
+
+    const request = responses[0].request
+    const rawBody = await request.text()
+
+    try {
+      const json = JSON.parse(rawBody)
+      expect(json).toMatchSnapshot()
+      return
+    } catch (err) {
+      expect(rawBody).toMatchSnapshot()
+    }
+
+    expect(request.headers).toMatchSnapshot()
+  })
+
+  it('all fields', async () => {
+    const action = destination.actions[actionSlug]
+    const [eventData, settingsData] = generateTestData(seedName, destination, action, false)
+
+    nock(/.*/).persist().get(/.*/).reply(200)
+    nock(/.*/).persist().post(/.*/).reply(200)
+    nock(/.*/).persist().put(/.*/).reply(200)
+
+    const event = createTestEvent({
+      properties: eventData
+    })
+
+    const responses = await testDestination.testAction(actionSlug, {
+      event: event,
+      mapping: event.properties,
+      settings: settingsData,
+      auth: undefined
+    })
+
+    const request = responses[0].request
+    const rawBody = await request.text()
+
+    try {
+      const json = JSON.parse(rawBody)
+      expect(json).toMatchSnapshot()
+      return
+    } catch (err) {
+      expect(rawBody).toMatchSnapshot()
+    }
+  })
+})