adjust message reading logic

Author: tkotthakota-adobe

src/audit-status-processor/handler.js

@@ -21,13 +21,13 @@ const AUDIT_TYPE = 'audit-status-processor';
  * @param {object} context - The context object
  * @returns {Promise<object>} The audit result
  */
-export async function runAuditStatusProcessor(auditStatusMessage, context) {
+export async function runAuditStatusProcessor(message, context) {
   const { log, env } = context;
   log.info('Running audit status processor');
-  const { siteId, auditContext } = auditStatusMessage;
+  const { siteId, organizationId, taskContext } = message;
   const {
-    organizationId, auditTypes, slackContext,
-  } = auditContext;
+    auditTypes, slackContext,
+  } = taskContext;
 
   log.info('Processing audit status for site:', {
     siteId,

src/demo-url-processor/handler.js

@@ -23,13 +23,13 @@ function prepareDemoUrl(experienceUrl, organizationId, siteId) {
  * @param {object} context - The context object
  * @returns {Promise<object>} The audit result
  */
-export async function runDemoUrlProcessor(demoUrlMessage, context) {
+export async function runDemoUrlProcessor(message, context) {
   const { log, env } = context;
   log.info('Running demo url processor');
-  const { siteId, demoUrlContext } = demoUrlMessage;
+  const { siteId, organizationId, taskContext } = message;
   const {
-    experienceUrl: siteUrl, organizationId, slackContext,
-  } = demoUrlContext;
+    experienceUrl: siteUrl, slackContext,
+  } = taskContext;
 
   log.info('Processing demo url for site:', {
     siteId,

src/disable-import-audit-processor/handler.js

@@ -23,11 +23,13 @@ const AUDIT_TYPE = 'disable-import-audit-processor';
  */
 export async function runDisableImportAuditProcessor(message, context) {
   const { log, env, dataAccess } = context;
-  const { siteId, siteUrl, auditContext } = message;
+  const {
+    siteId, siteUrl, organizationId, taskContext,
+  } = message;
   const { Configuration } = dataAccess;
   const {
-    organizationId, importTypes = [], auditTypes = [], slackContext,
-  } = auditContext;
+    importTypes = [], auditTypes = [], slackContext,
+  } = taskContext;
 
   log.info('Processing disable import and audit request:', {
     auditType: AUDIT_TYPE,