AEM Assets event for PIM integration

kind: "API"
version: "1.0"
metadata:
    envTypes: ["dev", "stage", "prod"]
data:
    allowedClientIDs:
        author:
        - "<ADC Project's OAuth Server-to-Server credential ClientID>"

/**
 * Mock PIM API to get the product data such as SKU, Supplier, etc.
 *
 * In a real-world scenario, this function would call the PIM API to get the product data.
 * For this example, we are returning mock data.
 *
 * @param {string} assetId - The assetId to get the product data.
 */
module.exports = {
    async getPIMData(assetId) {
        if (!assetId) {
        throw new Error('Invalid assetId');
        }
        // Mock response data for demo purposes
        const data = {
        SKUID: 'MockSKU 123',
        SupplierName: 'mock-supplier',
        // ... other product data
        };
        return data;
    },
};

const fetch = require('node-fetch');
...
/**
*  Get IMS Access Token using Client Credentials Flow
*
* @param {*} clientId - IMS Client ID from ADC project's OAuth Server-to-Server Integration
* @param {*} clientSecret - IMS Client Secret from ADC project's OAuth Server-to-Server Integration
* @param {*} scopes - IMS Meta Scopes from ADC project's OAuth Server-to-Server Integration as comma separated strings
* @returns {string} - Returns the IMS Access Token
*/
async function getIMSAccessToken(clientId, clientSecret, scopes) {
  const adobeIMSV3TokenEndpointURL = 'https://ims-na1.adobelogin.com/ims/token/v3';
  const options = {
    method: 'POST',
    headers: {
      'Content-Type': 'application/x-www-form-urlencoded',
    },
    body: `grant_type=client_credentials&client_id=${clientId}&client_secret=${clientSecret}&scope=${scopes}`,
  };
  const response = await fetch(adobeIMSV3TokenEndpointURL, options);
  const responseJSON = await response.json();
  return responseJSON.access_token;
}
async function updateAEMAssetMetadata(metadataDetails, aemAssetEvent, params) {
  ...
  // Transform the metadata details to JSON Patch format,
  // see https://developer.adobe.com/experience-cloud/experience-manager-apis/api/experimental/assets/author/#operation/patchAssetMetadata
  const transformedMetadata = Object.keys(metadataDetails).map((key) => ({
    op: 'add',
    path: `wknd-${key.toLowerCase()}`,
    value: metadataDetails[key],
  }));
  ...
  // Get ADC project's OAuth Server-to-Server Integration credentials
  const clientId = params.ADC_CECREDENTIALS_CLIENTID;
  const clientSecret = params.ADC_CECREDENTIALS_CLIENTSECRET;
  const scopes = params.ADC_CECREDENTIALS_METASCOPES;
  // Get IMS Access Token using Client Credentials Flow
  const access_token = await getIMSAccessToken(clientId, clientSecret, scopes);
  // Call AEM Author service to update the metadata using Assets Author API
  // See https://developer.adobe.com/experience-cloud/experience-manager-apis/api/experimental/assets/author/
  const res = await fetch(`${aemAuthorHost}/adobe/assets/${assetId}/metadata`, {
    method: 'PATCH',
    headers: {
      'Content-Type': 'application/json-patch+json',
      'If-Match': '*',
      'X-Adobe-Accept-Experimental': '1',
      'X-Api-Key': '12345676', // Use the `ClientID` value from the ADC Project's credentials section
      Authorization: `Bearer ${access_token}`,
    },
    body: JSON.stringify(transformedMetadata),
  });
  ...
}
module.exports = { updateAEMAssetMetadata };

...
let responseMsg;
// handle the challenge probe request, they are sent by I/O to verify the action is valid
if (params.challenge) {
  logger.info('Challenge probe request detected');
  responseMsg = JSON.stringify({ challenge: params.challenge });
} else {
  logger.info('AEM Asset Event request received');
  // create AEM Asset Event object from request parameters
  const aemAssetEvent = new AEMAssetEvent(params);
  // Call mock PIM API to get the product data such as SKU, Supplier, etc.
  const mockPIMData = await mockPIMAPI.getPIMData(
    aemAssetEvent.getAssetName(),
  );
  logger.info('Mock PIM API response', mockPIMData);
  // Update PIM received data in AEM as Asset metadata
  const aemUpdateStatus = await updateAEMAssetMetadata(
    mockPIMData,
    aemAssetEvent,
    params,
  );
  logger.info('AEM Asset metadata update status', aemUpdateStatus);
  if (aemUpdateStatus) {
    // create response message
    responseMsg = JSON.stringify({
      message:
        'AEM Asset Event processed successfully, updated the asset metadata with PIM data.',
      assetdata: {
        assetName: aemAssetEvent.getAssetName(),
        assetPath: aemAssetEvent.getAssetPath(),
        assetId: aemAssetEvent.getAssetId(),
        aemHost: aemAssetEvent.getAEMHost(),
        pimdata: mockPIMData,
      },
    });
  }
  // response object
  const response = {
    statusCode: 200,
    body: responseMsg,
  };
  // Return the response to the caller
  return response;
  ...
}

$ aio app deploy