logs for onboard debugging

Author: tkotthakota-adobe

src/tasks/cwv-demo-suggestions-processor/handler.js

@@ -297,6 +297,15 @@ export async function runCwvDemoSuggestionsProcessor(message, context) {
     profile,
   });
 
+  // Debug: Check if slackContext is present
+  log.info('cwv-demo-suggestions-processor slackContext check:', {
+    hasSlackContext: !!slackContext,
+    hasChannelId: !!slackContext?.channelId,
+    hasThreadTs: !!slackContext?.threadTs,
+    channelId: slackContext?.channelId,
+    threadTs: slackContext?.threadTs,
+  });
+
   try {
     if (!profile || profile !== DEMO) {
       return {

src/tasks/demo-url-processor/handler.js

@@ -75,6 +75,15 @@ export async function runDemoUrlProcessor(message, context) {
     organizationId,
   });
 
+  // Debug: Check if slackContext is present
+  log.info('demo-url-processor slackContext check:', {
+    hasSlackContext: !!slackContext,
+    hasChannelId: !!slackContext?.channelId,
+    hasThreadTs: !!slackContext?.threadTs,
+    channelId: slackContext?.channelId,
+    threadTs: slackContext?.threadTs,
+  });
+
   let imsTenantId = context.env.DEFAULT_TENANT_ID;
   try {
     const organization = await Organization.findById(organizationId);
@@ -94,7 +103,15 @@ export async function runDemoUrlProcessor(message, context) {
   const slackMessage = `:white_check_mark: Onboarding setup completed successfully for the site ${siteUrl}!\nAccess your environment here: ${demoUrl}`;
 
   if (slackContext) {
+    log.info('Attempting to send Slack message:', {
+      channelId: slackContext.channelId,
+      threadTs: slackContext.threadTs,
+      messageLength: slackMessage.length,
+    });
     await say(env, log, slackContext, slackMessage);
+    log.info('Slack message sent successfully');
+  } else {
+    log.warn('Skipping Slack notification: slackContext is not defined');
   }
 
   log.info(`Onboarding setup completed successfully for the site ${siteUrl}! Access your environment here: ${demoUrl}`);

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

@@ -39,6 +39,15 @@ export async function runDisableImportAuditProcessor(message, context) {
     scheduledRun,
   });
 
+  // Debug: Check if slackContext is present
+  log.info('disable-import-audit-processor slackContext check:', {
+    hasSlackContext: !!slackContext,
+    hasChannelId: !!slackContext?.channelId,
+    hasThreadTs: !!slackContext?.threadTs,
+    channelId: slackContext?.channelId,
+    threadTs: slackContext?.threadTs,
+  });
+
   if (scheduledRun) {
     log.info(`Scheduled run detected - skipping disable of imports and audits for site: ${siteUrl}`);
     await say(env, log, slackContext, `:information_source: Scheduled run detected for site ${siteUrl} - skipping disable of imports and audits`);

src/tasks/opportunity-status-processor/handler.js

@@ -424,6 +424,15 @@ export async function runOpportunityStatusProcessor(message, context) {
     onboardStartTime: onboardStartTime ? new Date(onboardStartTime).toISOString() : undefined,
   });
 
+  // Debug: Check if slackContext is present
+  log.info('opportunity-status-processor slackContext check:', {
+    hasSlackContext: !!slackContext,
+    hasChannelId: !!slackContext?.channelId,
+    hasThreadTs: !!slackContext?.threadTs,
+    channelId: slackContext?.channelId,
+    threadTs: slackContext?.threadTs,
+  });
+
   try {
     // Get the site and its opportunities
     const site = await Site.findById(siteId);