Feature/1681 reverse dependency lookup for deploy

lib/metadataTypes/Asset.js

@@ -848,21 +848,103 @@ class Asset extends MetadataType {
         if (Util.OPTIONS.refresh) {
             if (createdUpdated.updated) {
                 // only run this if assets were updated. for created assets we do not expect
-                await this._refreshTriggeredSend(metadata);
+                await this.refresh(Object.keys(metadata));
             } else {
                 Util.logger.warn(
                     'You set the --refresh flag but no updated assets found. Skipping refresh of triggeredSendDefinitions.'
                 );
             }
         }
     }
+    /**
+     * helper for {@link Asset}. finds active emails that reference the updated block
+     *
+     * @private
+     * @param {string[]} keys metadata keys
+     * @returns {Promise.<object[]>} - array of assets
+     */
+    static async _findEmailsUsingBlock(keys) {
+        const uri = '/asset/v1/content/assets/query';
+
+        const emailCondition = {
+            property: 'assetType.name',
+            simpleOperator: 'in',
+            value: this.definition.extendedSubTypes.message,
+        };
+
+        // Build metadata keys condition
+        // @ts-ignore
+        const metadataCondition = keys.reduce((acc, key, index) => {
+            const condition = {
+                property: 'content',
+                simpleOperator: 'mustContain',
+                value: key,
+            };
+
+            if (index === 0) {
+                return condition;
+            }
+
+            return {
+                leftOperand: acc,
+                logicalOperator: 'OR',
+                rightOperand: condition,
+            };
+        }, null);
+        const query = {
+            leftOperand: emailCondition,
+            logicalOperator: 'AND',
+            rightOperand: metadataCondition,
+        };
+        /** @type {AssetRequestParams} */
+        const payload = {
+            page: {
+                page: 1,
+                pageSize: 50,
+            },
+            // @ts-ignore
+            query: query,
+        };
+        let items = [];
+        let moreResults;
+        let lastPage = 0;
+        try {
+            do {
+                payload.page.page = lastPage + 1;
+                const response = await this.client.rest.post(uri, payload);
+                if (response?.items?.length) {
+                    // sometimes the api will return a payload without items
+                    // --> ensure we only add proper items-arrays here
+                    items = items.concat(response.items);
+                }
+                // check if any more records
+                if (response?.message?.includes('all shards failed')) {
+                    payload.query = {
+                        property: 'id',
+                        simpleOperator: 'greaterThan',
+                        value: items.at(-1).id,
+                    };
+                    lastPage = 0;
+                    moreResults = true;
+                } else if (response.page * response.pageSize < response.count) {
+                    moreResults = true;
+                    lastPage = Number(response.page);
+                } else {
+                    moreResults = false;
+                }
+            } while (moreResults);
+        } catch (ex) {
+            Util.logger.error(`An error occured while attempting to query assets. ${ex.message}`);
+        }
+        return Object.fromEntries(items.map((item) => [item.customerKey, item]));
+    }
 
     /**
      * helper for {@link Asset.postDeployTasks}. triggers a refresh of active triggerredSendDefinitions associated with the updated asset-message items. Gets executed if refresh option has been set.
      *
      * @private
      * @param {MetadataTypeMap} metadata metadata mapped by their keyField
-     * @returns {Promise.<void>} -
+     * @returns {Promise.<string[]>} Returns list of keys that were refreshed
      */
     static async _refreshTriggeredSend(metadata) {
         // get legacyData.legacyId from assets to compare to TSD's metadata.Email.ID to
@@ -900,7 +982,7 @@ class Asset extends MetadataType {
             // get keys of TSDs to refresh
             const keyArr = await TriggeredSend.getKeysForValidTSDs(tsdObj);
 
-            await TriggeredSend.refresh(keyArr);
+            return await TriggeredSend.refresh(keyArr);
         } catch {
             Util.logger.warn('Failed to refresh triggeredSendDefinition');
         }
@@ -2980,11 +3062,47 @@ class Asset extends MetadataType {
         }
         return cacheMatchedByName;
     }
+    /**
+     * Finds emails in running journeys, filters out the ones that reference the block (if it's a block) and refreshes related TSDs
+     *
+     * @param {string[]} [keyArr] metadata keys
+     * @returns {Promise.<string[]>} Returns list of keys that were refreshed
+     */
+    static async refresh(keyArr) {
+        const codeBlockKeys = [];
+        const toPublish = [];
+        Util.logger.info(' - Caching dependent Metadata: asset');
+        const assets = await this.retrieveForCache(undefined, null, undefined, false);
+        cache.mergeMetadata('asset', assets.metadata);
+        Util.logger.info(' - Caching dependent Metadata: shared-asset');
+        const sharedAssets = await this.retrieveForCache(undefined, null, undefined, true);
+        cache.mergeMetadata('asset', sharedAssets.metadata);
+        for (const key of keyArr) {
+            const item = cache.getByKey(this.definition.type, key);
+            if (!item) {
+                Util.logger.warn(` - Could not find asset in cache for key: ${key}, skipping`);
+                continue;
+            }
+            if (this.definition.extendedSubTypes.message.includes(item?.assetType?.name)) {
+                toPublish.push(item);
+                // refreshing code blocks referenced with ContentBlockBy
+            } else if (
+                this.definition.extendedSubTypes.block.includes(item?.assetType?.name) ||
+                this.definition.extendedSubTypes.other.includes(item?.assetType?.name)
+            ) {
+                codeBlockKeys.push(key);
+            }
+        }
+        if (codeBlockKeys.length > 0) {
+            toPublish.push(...Object.values(await this._findEmailsUsingBlock(codeBlockKeys)));
+        }
+        Util.logger.info(` - Found ${toPublish.length} assets to publish`);
+        return toPublish.length ? await this._refreshTriggeredSend(toPublish) : [];
+    }
 }
 
 // Assign definition to static attributes
 import MetadataTypeDefinitions from '../MetadataTypeDefinitions.js';
-
 Asset.definition = MetadataTypeDefinitions.asset;
 
 export default Asset;

test/mockRoot/deploy/testInstance/testBU/asset/block/testExisting_block_refresh.asset-block-meta.html

@@ -0,0 +1,15 @@
+<table
+    cellpadding="0"
+    cellspacing="0"
+    width="100%"
+    role="presentation"
+    style="min-width: 100%; "
+    class="stylingblock-content-wrapper"
+>
+    <tr>
+        <td class="stylingblock-content-wrapper camarker-inner">
+        <h1>Test Block</h1>
+            <div>This is a test block</div>
+</td>
+    </tr>
+</table>

test/mockRoot/deploy/testInstance/testBU/asset/block/testExisting_block_refresh.asset-block-meta.json

@@ -0,0 +1,30 @@
+{
+    "id": 334322,
+    "customerKey": "testExisting_block_refresh",
+    "objectID": "baf8348d-61d5-451f-948a-28045e41e50c",
+    "assetType": {
+        "id": 220,
+        "name": "codesnippetblock",
+        "displayName": "Code Snippet Block"
+    },
+    "name": "testExisting_block_refresh",
+    "createdDate": "2025-10-24T12:19:21.2-06:00",
+    "createdBy": {
+        "id": 724496218,
+        "email": "test@test.com",
+        "name": "Yuliia Likhytska",
+        "userId": "724496218"
+    },
+    "modifiedDate": "2026-03-15T11:37:51.38-06:00",
+    "modifiedBy": {
+        "id": 724496218,
+        "email": "test@test.com",
+        "name": "Yuliia Likhytska",
+        "userId": "724496218"
+    },
+    "category": {
+        "id": 370568
+    },
+    "modelVersion": 2,
+    "r__folder_Path": "Content Builder"
+}

test/resourceFactory.js

@@ -310,7 +310,7 @@ export const handleRESTRequest = async (config) => {
             : null;
 
         if (!testPathFilter && config.method === 'post' && config.data) {
-            const simpleOperators = { equal: '=', in: 'IN' };
+            const simpleOperators = { equal: '=', in: 'IN', mustContain: 'MUSTCONTAIN' };
             const data = JSON.parse(config.data);
             const myObj = data.query?.rightOperand || data.query;
             if (myObj) {