using cloudeventv1 spec

Author: arnav777dev

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

@@ -39,14 +39,6 @@ interface SFMCAsyncStatus {
   resultMessages: string[]
 }
 
-/**
- * Interface for async upsert response
- */
-interface AsyncUpsertResponse {
-  requestId: string
-  resultMessages: string[]
-}
-
 /**
  * Interface for poll response
  */
@@ -153,7 +145,7 @@ export async function asyncUpsertRowsV2(
   subdomain: String,
   payloads: payload_dataExtension[] | payload_contactDataExtension[],
   dataExtensionId?: string
-): Promise<MultiStatusResponse> {
+) {
   if (!dataExtensionId) {
     throw new IntegrationError(
       `In order to send an event to a data extension Data Extension ID must be defined.`,
@@ -163,25 +155,14 @@ export async function asyncUpsertRowsV2(
   }
   // Use flattened rows for async API
   const rows = generateFlattenedRows(payloads)
-  const response = await request<AsyncUpsertResponse>(
+  const response = await request(
     `https://${subdomain}.rest.marketingcloudapis.com/data/v1/async/dataextensions/${dataExtensionId}/rows`,
     {
       method: 'PUT',
       json: { items: rows }
     }
   )
-  const multiStatusResponse = new MultiStatusResponse()
-  for (let i = 0; i < payloads.length; i++) {
-    multiStatusResponse.setSuccessResponseAtIndex(i, {
-      status: 202,
-      sent: rows[i] as Object as JSONLikeObject,
-      body: {
-        requestId: response.data.requestId,
-        resultMessages: response.data.resultMessages
-      }
-    })
-  }
-  return multiStatusResponse
+  return response
 }
 
 export function upsertRows(