AEM Events processing using Adobe I/O Runtime Action

async function needsAEMCallback(aemEvent) {
// create a Logger
const logger = Core.Logger('eventValidator', {
    level: 'info',
});

let isValid = false;

// verify the event is a Content Fragment Modified event
if (
    aemEvent
    && aemEvent.ContentType === 'contentFragment'
    && aemEvent.EventName === 'modified'
) {
    logger.info('Processing Content Fragment Modified Event');
    isValid = true;
}

return isValid;
}

module.exports = needsAEMCallback;

...
const auth = require('@adobe/jwt-auth');
...
// Get AEM Service Credentials aka Technical Account details.
// These are passed to the action as params and added in .env file.
const clientId = params.AEM_SERVICECREDENTIALS_TECHNICALACCOUNT_CLIENTID;
const technicalAccountId = params.AEM_SERVICECREDENTIALS_ID;
const orgId = params.AEM_SERVICECREDENTIALS_ORG;
const clientSecret = params.AEM_SERVICECREDENTIALS_TECHNICALACCOUNT_CLIENTSECRET;
// Private key is passed as a string with \n and \r characters escaped.
const privateKey = params.AEM_SERVICECREDENTIALS_PRIVATEKEY.replace(
    /\\n/g,
    '\n',
).replace(/\\r/g, '\r');
const metaScopes = params.AEM_SERVICECREDENTIALS_METASCOPES.split(',');
const ims = `https://${params.AEM_SERVICECREDENTIALS_IMSENDPOINT}`;

// Get the access token from IMS using Adobe I/O SDK
const { access_token } = await auth({
    clientId,
    technicalAccountId,
    orgId,
    clientSecret,
    privateKey,
    metaScopes,
    ims,
});
...
// Call AEM Author service to get the CF details using AEM Assets API
const res = await fetch(
    `${aemAuthorHost}${cfPath.replace('/content/dam/', '/api/assets/')}.json`,
{
  method: 'GET',
  headers: {
    'Content-Type': 'application/json',
    Authorization: `Bearer ${access_token}`,
  },
},
);

let newValuesOfCFPropertiesAddedOrModified = {};
// If the response is OK, get the values of the CF properties that were added or modified
if (res.ok) {
    logger.info('AEM Event Details loaded from AEM Author instance');
    const responseJSON = await res.json();

    // Get the values of the CF properties that were added or modified
    if (
    responseJSON
    && responseJSON.properties
    && responseJSON.properties.elements
    ) {
    const allCurrentCFProperties = responseJSON.properties.elements;

    newValuesOfCFPropertiesAddedOrModified = cfPropertiesAddedOrModified.map(
        (key) => ({
        key,
        value: allCurrentCFProperties[key],
        }),
    );
    }
}
...

...
const filesLib = require('@adobe/aio-lib-files');
...

const files = await filesLib.init();

const eventDataAsJSON = JSON.stringify({
    activity: activityMessage,
    aemEvent,
    aemEventDetails,
});

// store details in a folder named YYYY-MM-DD and a file named <eventID>.json
const bytesWritten = await files.write(
    `${formattedDate}/${aemEvent.getEventID()}.json`,
    eventDataAsJSON,
);
...