feat: add cwv suggestions task

src/support/utils.js

@@ -787,17 +787,15 @@ export const onboardSingleSite = async (
       log.info(`All audits are already enabled for site ${siteID}`);
     }
 
-    reportLine.audits = auditTypes.join(', ');
-    log.info(`Enabled the following audits for site ${siteID}: ${reportLine.audits}`);
-
-    await say(`:white_check_mark: *For site ${baseURL}*: Enabled imports: ${reportLine.imports} and audits: ${reportLine.audits}`);
+    // Refresh configuration to ensure we have the latest state for audit triggering
+    const currentConfiguration = await Configuration.findLatest();
 
     // trigger audit runs
     log.info(`Starting audits for site ${baseURL}. Audit list: ${auditTypes}`);
     await say(`:gear: Starting audits: ${auditTypes}`);
     for (const auditType of auditTypes) {
       /* eslint-disable no-await-in-loop */
-      if (!latestConfiguration.isHandlerEnabledForSite(auditType, site)) {
+      if (!currentConfiguration.isHandlerEnabledForSite(auditType, site)) {
         await say(`:x: Will not audit site '${baseURL}' because audits of type '${auditType}' are disabled for this site.`);
       } else {
         await triggerAuditForSite(
@@ -810,6 +808,11 @@ export const onboardSingleSite = async (
       }
     }
 
+    reportLine.audits = auditTypes.join(', ');
+    log.info(`Enabled the following audits for site ${siteID}: ${reportLine.audits}`);
+
+    await say(`:white_check_mark: *For site ${baseURL}*: Enabled imports: ${reportLine.imports} and audits: ${reportLine.audits}`);
+
     // Opportunity status job
     const opportunityStatusJob = {
       type: 'opportunity-status-processor',
@@ -859,15 +862,33 @@ export const onboardSingleSite = async (
       },
     };
 
+    // CWV Demo Suggestions job - add generic CWV suggestions to opportunities
+    const cwvDemoSuggestionsJob = {
+      type: 'cwv-demo-suggestions-processor',
+      siteId: siteID,
+      siteUrl: baseURL,
+      imsOrgId: imsOrgID,
+      organizationId,
+      taskContext: {
+        profile: profileName, // Pass the profile name for demo check
+        slackContext: {
+          channelId: slackContext.channelId,
+          threadTs: slackContext.threadTs,
+        },
+      },
+    };
+
     log.info(`Opportunity status job: ${JSON.stringify(opportunityStatusJob)}`);
     log.info(`Disable import and audit job: ${JSON.stringify(disableImportAndAuditJob)}`);
     log.info(`Demo URL job: ${JSON.stringify(demoURLJob)}`);
+    log.info(`CWV Demo Suggestions job: ${JSON.stringify(cwvDemoSuggestionsJob)}`);
 
     // Prepare and start step function workflow with the necessary parameters
     const workflowInput = {
       opportunityStatusJob,
       disableImportAndAuditJob,
       demoURLJob,
+      cwvDemoSuggestionsJob,
       workflowWaitTime: workflowWaitTime || env.WORKFLOW_WAIT_TIME_IN_SECONDS,
     };