adjust slack messages

Author: tkotthakota-adobe

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

@@ -39,13 +39,14 @@ export async function runDemoUrlProcessor(message, context) {
     organizationId,
   });
 
-  await say(env, log, slackContext, ':information_source: *Preparing demo url*');
   try {
     // prepare demo url
     const demoUrl = prepareDemoUrl(siteUrl, organizationId, siteId);
-    log.info(`Setup complete! Access your demo environment here: ${demoUrl}`);
-    const slackMessage = `:white_check_mark: Setup complete! Access your demo environment here: ${demoUrl}`;
+    let slackMessage = ':white_check_mark: Setup complete!';
+    await say(env, log, slackContext, slackMessage);
+    slackMessage = `:information_source: Access your demo environment here: ${demoUrl}`;
     await say(env, log, slackContext, slackMessage);
+    log.info(`Setup complete! Access your demo environment here: ${demoUrl}`);
   } catch (error) {
     log.error('Error in preparing demo url:', {
       error: error.message,

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

@@ -62,7 +62,9 @@ export async function runDisableImportAuditProcessor(message, context) {
     await configuration.save();
     log.info('Database changes saved successfully');
 
-    const slackMessage = `:white_check_mark: Disabled imports ${JSON.stringify(importTypes)} and audits ${JSON.stringify(auditTypes)} for site ${siteId}`;
+    let slackMessage = `:white_check_mark: Disabled imports ${JSON.stringify(importTypes)} for site ${siteId}`;
+    await say(env, log, slackContext, slackMessage);
+    slackMessage = `:white_check_mark: Disabled audits ${JSON.stringify(auditTypes)} for site ${siteId}`;
     await say(env, log, slackContext, slackMessage);
   } catch (error) {
     log.error('Error in disable import and audit processor:', {

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

@@ -73,10 +73,22 @@ export async function runOpportunityStatusProcessor(message, context) {
     const opportunities = await site.getOpportunities();
     log.info(`Found ${opportunities.length} opportunities for site ${siteId}`);
 
+    // Track processed opportunity types to avoid duplicates
+    const processedTypes = new Set();
+
     // Process each opportunity
     for (const opportunity of opportunities) {
       const opportunityType = opportunity.getType();
 
+      // Skip if we've already processed this opportunity type
+      if (processedTypes.has(opportunityType)) {
+        // eslint-disable-next-line no-continue
+        continue;
+      }
+
+      // Mark this type as processed
+      processedTypes.add(opportunityType);
+
       // Get suggestions for this opportunity
       // eslint-disable-next-line no-await-in-loop
       const suggestions = await opportunity.getSuggestions();