adding multistatus response

Author: joe-ayoub-segment

packages/destination-actions/src/destinations/taguchi/index.ts

@@ -29,7 +29,7 @@ const destination: DestinationDefinition<Settings> = {
         required: true
       }
     },
-    testAuthentication: (request) => {
+    testAuthentication: (request, {settings}) => {
       // Return a request that tests/validates the user's credentials.
       // If you do not have a way to validate the authentication fields safely,
       // you can remove the `testAuthentication` function, though discouraged.

packages/destination-actions/src/destinations/taguchi/syncAudience/index.ts

@@ -154,11 +154,11 @@ const action: ActionDefinition<Settings, Payload> = {
       default: { '@path': '$.timestamp' }
     }
   },
-  perform: (request, {payload, settings}) => {
-    send(request, [payload], settings)
+  perform: async (request, {payload, settings}) => {
+    await send(request, [payload], settings, false)
   },
-  performBatch: (request, { payload, settings }) => {
-    send(request, payload, settings)
+  performBatch: async (request, { payload, settings }) => {
+    await send(request, payload, settings, true)
   }
 }
 

packages/destination-actions/src/destinations/taguchi/syncAudience/utils.ts

@@ -1,6 +1,6 @@
 import { Payload } from './generated-types'
 import { Settings } from '../generated-types'
-import { RequestClient, PayloadValidationError } from '@segment/actions-core'
+import { RequestClient, PayloadValidationError, MultiStatusResponse, JSONLikeObject } from '@segment/actions-core'
 import { JSON, JSONItem, ResponseJSON } from './types'
 
 export function validate(payloads: Payload[]): Payload[]{
@@ -13,8 +13,10 @@ export function validate(payloads: Payload[]): Payload[]{
     return payloads
 }
 
-export async function send(request: RequestClient, payloads: Payload[], settings: Settings) {
+export async function send(request: RequestClient, payloads: Payload[], settings: Settings, isBatch: boolean) {
+
     validate(payloads)
+  
     const json: JSON = payloads.map(payload => buildJSON(payload, settings.organizationId))
 
     const response = await request<ResponseJSON>(`${settings.integrationURL}/subscriber`, {
@@ -25,6 +27,29 @@ export async function send(request: RequestClient, payloads: Payload[], settings
             'Authorization': `Bearer ${settings.apiKey}`
         }
     })
+
+    if(isBatch){
+        const multiStatusResponse = new MultiStatusResponse()
+        response.data.forEach((res, index) => {
+            if (res.code >= 200 && res.code < 300) {
+                multiStatusResponse.setSuccessResponseAtIndex(index, {
+                    status: res.code,
+                    sent: json[index] as unknown as JSONLikeObject,
+                    body: res as unknown as JSONLikeObject
+                });
+            } else {
+                multiStatusResponse.setErrorResponseAtIndex(index, {
+                    status: res.code,
+                    sent: json[index] as unknown as JSONLikeObject,
+                    body: res as unknown as JSONLikeObject,
+                    errormessage: res.description
+                })
+            }
+        })
+        return multiStatusResponse
+    }
+    
+    return response 
 }
 
 function buildJSON(payload: Payload, organizationId: string): JSONItem {