feat: onboard sfmc with record event to support mirror mode

src/v0/destinations/sfmc/transform.js

@@ -283,29 +283,106 @@
   throw new ConfigurationError(`Event type '${category.type}' not supported`);
 };
 
+const addResponseBuilder = ({
+  traits,
+  destinationExternalId,
+  identifierType,
+  subDomain,
+  externalKey,
+  token,
+}) => {
+  const response = defaultRequestConfig();
+  response.method = defaultPutRequestConfig.requestMethod;
+  response.endpoint = `https://${subDomain}.${ENDPOINTS.INSERT_CONTACTS}${externalKey}/rows/${identifierType}:${destinationExternalId}`;
+  response.headers = {
+    'Content-Type': JSON_MIME_TYPE,
+    Authorization: `Bearer ${token}`,
+  };
+  response.body.JSON = {
+    values: {
+      ...traits,
+    },
+  };
+  return response;
+};
+
 const retlResponseBuilder = async (message, destination, metadata) => {
   const { clientId, clientSecret, subDomain, externalKey } = destination.Config;
   const token = await accessTokenCache.get(metadata.destinationId, () =>
     getToken(clientId, clientSecret, subDomain, metadata),
   );
+
   const { destinationExternalId, objectType, identifierType } = getDestinationExternalIDInfoForRetl(
     message,
     'SFMC',
   );
+
+  // This part will handle the mirror mode
+  const { type, action } = message;
+  if (type === 'record') {
+    if (action === 'insert') {
+      return addResponseBuilder({
+        traits: message.fields,
+        destinationExternalId: message.fields[identifierType],
+        identifierType,
+        subDomain,
+        externalKey,
+        token,
+      });
+    } else if (action === 'delete') {
+      let data = `<s:Envelope\n
+      xmlns:s="http://www.w3.org/2003/05/soap-envelope"\n
+      xmlns:a="http://schemas.xmlsoap.org/ws/2004/08/addressing"\n
+      xmlns:u="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd">\n    
+      <s:Header>\n        
+        <fueloauth>ACCESS_TOKEN</fueloauth>\n    
+      </s:Header>\n    
+      <s:Body\n
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"\n
+        xmlns:xsd="http://www.w3.org/2001/XMLSchema">\n        
+        <DeleteRequest
+          xmlns="http://exacttarget.com/wsdl/partnerAPI">\n            
+          <Objects xsi:type="DataExtensionObject">\n                
+            <CustomerKey>CUSTOMER_KEY</CustomerKey>\n                
+            <Keys>\n                    
+              <Key>\n                        
+                <Name>FIELD_NAME</Name>\n                        
+                <Value>FIELD_VALUE</Value>\n                    
+              </Key>\n                
+            </Keys>\n            
+          </Objects>\n        
+        </DeleteRequest>\n    
+      </s:Body>\n
+    </s:Envelope>`;
+      data = data.replace('ACCESS_TOKEN', token);
+      data = data.replace('CUSTOMER_KEY', externalKey);
+      data = data.replace('FIELD_NAME', destinationExternalId);
+      data = data.replace('FIELD_VALUE', message.fields[identifierType]);
+      const response = defaultRequestConfig();
+      response.method = defaultPostRequestConfig.requestMethod;
+      response.endpoint = `https://${subDomain}.soap.marketingcloudapis.com/Service.asmx`;
+      response.headers = {
+        soapaction: 'Delete',
+        'Content-Type': 'text/xml; charset="UTF-8"',
+      };
+      response.body.XML = {
+        payload: data,
+      };
+      return response;
+    }
+  }
+
+  // This part will handle the upsert mode
+
   if (objectType?.toLowerCase() === 'data extension') {
-    const response = defaultRequestConfig();
-    response.method = defaultPutRequestConfig.requestMethod;
-    response.endpoint = `https://${subDomain}.${ENDPOINTS.INSERT_CONTACTS}${externalKey}/rows/${identifierType}:${destinationExternalId}`;
-    response.headers = {
-      'Content-Type': JSON_MIME_TYPE,
-      Authorization: `Bearer ${token}`,
-    };
-    response.body.JSON = {
-      values: {
-        ...message.traits,
-      },
-    };
-    return response;
+    return addResponseBuilder({
+      traits: message.traits,
+      destinationExternalId,
+      identifierType,
+      subDomain,
+      externalKey,
+      token,
+    });
   }
   throw new PlatformError('Unsupported object type for rETL use case');
 };
@@ -344,6 +421,7 @@
 
 const processRouterDest = async (inputs, reqMetadata) => {
   const respList = await simpleProcessRouterDest(inputs, process, reqMetadata);
+  console.log(JSON.stringify(respList));
   return respList;
 };