#1921: add support for refreshing multi-step journeys via triggeredSends

Accenture · Dec 7, 2024 · 4a29420 · 4a29420
1 parent fb73d33
commit 4a29420
Show file tree

Hide file tree

Showing 3 changed files with 76 additions and 8 deletions.
diff --git a/@types/lib/metadataTypes/Journey.d.ts.map b/@types/lib/metadataTypes/Journey.d.ts.map
diff --git a/lib/metadataTypes/Journey.js b/lib/metadataTypes/Journey.js
@@ -2,6 +2,7 @@
 
 import MetadataType from './MetadataType.js';
 import TransactionalEmail from './TransactionalEmail.js';
+import TriggeredSend from './TriggeredSend.js';
 import Event from './Event.js';
 import { Util } from '../util/util.js';
 import cache from '../util/cache.js';
@@ -2612,9 +2613,74 @@ class Journey extends MetadataType {
                             }
                             break;
                         }
-                        // case 'Multistep': {
-                        // TODO
-                        // }
+                        case 'Multistep': {
+                            // find all published & paused versions
+                            const responseAllVersions = await this.client.rest.getBulk(
+                                '/interaction/v1/interactions/?id=' +
+                                    journeyCache.metadata[key]?.id +
+                                    '&mostRecentVersionOnly=false',
+                                this.definition.restPageSize || 500
+                            );
+                            if (responseAllVersions?.items?.length) {
+                                const allActiveVersions = responseAllVersions.items
+                                    .filter(
+                                        (item) =>
+                                            item.status === 'Paused' || item.status === 'Published'
+                                    )
+                                    .map((item) => item.version);
+                                if (allActiveVersions.length) {
+                                    Util.logger.info(
+                                        Util.getGrayMsg(
+                                            ` - Paused/Published version: ` +
+                                                allActiveVersions.join(', ')
+                                        )
+                                    );
+                                    // get TS keys from email activities of paused/published versions
+                                    const rateLimitActivities = pLimit(2);
+                                    const tsKeys = (
+                                        await Promise.all(
+                                            allActiveVersions.map((version) =>
+                                                rateLimitActivities(async () => {
+                                                    const journey = await this.client.rest.get(
+                                                        '/interaction/v1/interactions/' +
+                                                            journeyCache.metadata[key]?.id +
+                                                            '?extras=activities&versionNumber=' +
+                                                            version
+                                                    );
+                                                    // return all triggeredSends
+                                                    return journey.activities
+                                                        .filter(
+                                                            (activity) =>
+                                                                activity.type === 'EMAILV2' &&
+                                                                activity.configurationArguments
+                                                                    ?.triggeredSendKey
+                                                        )
+                                                        .map(
+                                                            (activity) =>
+                                                                activity.configurationArguments
+                                                                    ?.triggeredSendKey
+                                                        );
+                                                })
+                                            )
+                                        )
+                                    ).flat();
+
+                                    // refresh TriggeredSends
+                                    TriggeredSend.buObject = this.buObject;
+                                    TriggeredSend.client = this.client;
+                                    TriggeredSend.properties = this.properties;
+                                    const refreshedTsKeys = await TriggeredSend.refresh(tsKeys);
+                                    if (refreshedTsKeys.length === tsKeys.length) {
+                                        refreshedKeyArr.push(key);
+                                    }
+                                } else {
+                                    Util.logger.error(
+                                        ` ☇ skipping refresh of ${this.definition.type} ${key}: no published/paused versions found`
+                                    );
+                                }
+                            }
+                            break;
+                        }
                         default: {
                             Util.logger.error(
                                 ` - Refreshing ${this.definition.type} ${key} / ${journeyCache.metadata[key].name} failed: Unsupported definitionType '${journeyCache.metadata[key].definitionType}'`
@@ -2624,7 +2690,9 @@ class Journey extends MetadataType {
                 })
             )
         );
-        Util.logger.info(`Refreshed ${refreshedKeyArr.length} of ${keyArr.length}`);
+        Util.logger.info(
+            `Refreshed ${refreshedKeyArr.length} of ${keyArr.length} ${this.definition.type}`
+        );
         console.timeEnd('Time'); // eslint-disable-line no-console
         return refreshedKeyArr;
     }

diff --git a/lib/metadataTypes/TriggeredSend.js b/lib/metadataTypes/TriggeredSend.js
@@ -307,7 +307,6 @@ class TriggeredSend extends MetadataType {
      * @returns {Promise.<string[]>} Returns list of keys that were refreshed
      */
     static async refresh(keyArr, checkKey = true) {
-        console.time('Time'); // eslint-disable-line no-console
         if (!keyArr) {
             keyArr = await this.getKeysForValidTSDs((await this.findRefreshableItems()).metadata);
             checkKey = false;
@@ -327,8 +326,9 @@ class TriggeredSend extends MetadataType {
                 })
             )
         );
-        Util.logger.info(`Refreshed ${refreshedKeyArr.length} of ${keyArr.length}`);
-        console.timeEnd('Time'); // eslint-disable-line no-console
+        Util.logger.info(
+            `Refreshed ${refreshedKeyArr.length} of ${keyArr.length} ${this.definition.type}`
+        );
         return refreshedKeyArr;
     }