feat: bot detection logic

package.json

@@ -76,18 +76,19 @@
     "@adobe/helix-status": "10.1.5",
     "@adobe/helix-universal": "5.4.0",
     "@adobe/helix-universal-logger": "3.0.28",
-    "@adobe/spacecat-shared-data-access": "2.100.1",
+    "@adobe/spacecat-shared-data-access": "2.104.0",
     "@adobe/spacecat-shared-google-client": "1.4.63",
     "@adobe/spacecat-shared-gpt-client": "1.6.16",
     "@adobe/spacecat-shared-http-utils": "1.19.4",
     "@adobe/spacecat-shared-ims-client": "1.11.9",
     "@adobe/spacecat-shared-rum-api-client": "2.40.6",
-    "@adobe/spacecat-shared-scrape-client": "2.3.7",
-    "@adobe/spacecat-shared-slack-client": "1.5.33",
-    "@adobe/spacecat-shared-utils": "1.90.1",
-    "@aws-sdk/client-cloudwatch-logs": "3.985.0",
+    "@adobe/spacecat-shared-scrape-client": "2.5.0",
+    "@adobe/spacecat-shared-slack-client": "1.6.0",
+    "@adobe/spacecat-shared-utils": "1.91.0",
     "@aws-sdk/client-lambda": "3.985.0",
     "@aws-sdk/client-sqs": "3.985.0",
+    "@aws-sdk/client-s3": "3.985.0",
+    "@aws-sdk/client-cloudwatch-logs": "3.985.0",
     "@aws-sdk/credential-provider-node": "3.972.6",
     "aws-xray-sdk": "3.12.0",
     "cheerio": "1.2.0",
@@ -98,7 +99,7 @@
   },
   "devDependencies": {
     "@adobe/eslint-config-helix": "3.0.17",
-    "@adobe/helix-deploy": "13.2.11",
+    "@adobe/helix-deploy": "13.2.12",
     "@adobe/helix-universal": "5.4.0",
     "@adobe/helix-universal-devserver": "1.1.145",
     "@adobe/semantic-release-coralogix": "1.1.40",
@@ -134,7 +135,7 @@
   },
   "overrides": {
     "@adobe/fetch": "4.2.3",
-    "@adobe/spacecat-shared-data-access": "2.100.1"
+    "@adobe/spacecat-shared-data-access": "2.104.0"
   },
   "lint-staged": {
     "*.js": "eslint",

src/index.js

@@ -20,7 +20,7 @@ import {
   badRequest,
 } from '@adobe/spacecat-shared-http-utils';
 import { imsClientWrapper } from '@adobe/spacecat-shared-ims-client';
-import { isNonEmptyObject, sqsEventAdapter } from '@adobe/spacecat-shared-utils';
+import { isNonEmptyObject, sqsEventAdapter, sqsWrapper } from '@adobe/spacecat-shared-utils';
 
 import { runOpportunityStatusProcessor as opportunityStatusProcessor } from './tasks/opportunity-status-processor/handler.js';
 import { runDisableImportAuditProcessor as disableImportAuditProcessor } from './tasks/disable-import-audit-processor/handler.js';
@@ -86,13 +86,15 @@ async function processTask(message, context) {
 
 const runSQS = wrap(processTask)
   .with(dataAccess)
+  .with(sqsWrapper)
   .with(sqsEventAdapter)
   .with(imsClientWrapper)
   .with(secrets, { name: getSecretName })
   .with(helixStatus);
 
 const runDirect = wrap(processTask)
   .with(dataAccess)
+  .with(sqsWrapper)
   .with(imsClientWrapper)
   .with(secrets, { name: getSecretName })
   .with(helixStatus);

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

@@ -13,6 +13,7 @@
 import fs from 'fs';
 import path from 'path';
 import { isNonEmptyArray } from '@adobe/spacecat-shared-utils';
+import { ok } from '@adobe/spacecat-shared-http-utils';
 
 import { say } from '../../utils/slack-utils.js';
 
@@ -299,32 +300,32 @@ export async function runCwvDemoSuggestionsProcessor(message, context) {
 
   try {
     if (!profile || profile !== DEMO) {
-      return {
+      return ok({
         message: 'CWV processing skipped - not a demo profile',
         reason: 'non-demo-profile',
         profile,
         suggestionsAdded: 0,
-      };
+      });
     }
 
     const site = await Site.findById(siteId);
     if (!site) {
       log.error(`Site not found for siteId: ${siteId}`);
-      return {
+      return ok({
         message: 'Site not found',
         suggestionsAdded: 0,
-      };
+      });
     }
 
     const opportunities = await site.getOpportunities();
     const cwvOpportunities = opportunities.filter((opp) => opp.getType() === 'cwv');
 
     if (cwvOpportunities.length === 0) {
       await say(env, log, slackContext, 'No CWV opportunities found for site, skipping generic suggestions');
-      return {
+      return ok({
         message: 'No CWV opportunities found',
         suggestionsAdded: 0,
-      };
+      });
     }
 
     const suggestionsUpdated = await processCWVOpportunity(
@@ -334,18 +335,18 @@ export async function runCwvDemoSuggestionsProcessor(message, context) {
       slackContext,
     );
 
-    return {
+    return ok({
       message: 'CWV demo suggestions processor completed',
       opportunitiesProcessed: 1,
       suggestionsAdded: suggestionsUpdated,
-    };
+    });
   } catch (error) {
     log.error('Error in CWV demo suggestions processor:', error);
-    return {
+    return ok({
       message: 'CWV demo suggestions processor completed with errors',
       error: error.message,
       suggestionsAdded: 0,
-    };
+    });
   }
 }
 

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

@@ -91,13 +91,13 @@ export async function runDemoUrlProcessor(message, context) {
   }
 
   const demoUrl = `${experienceUrl}?organizationId=${organizationId}#/@${imsTenantId}/sites-optimizer/sites/${siteId}/home`;
-  const slackMessage = `:white_check_mark: Onboarding setup completed successfully for the site ${siteUrl}!\nAccess your environment here: ${demoUrl}`;
+  const slackMessage = `:white_check_mark: Onboarding setup completed for the site ${siteUrl}!\nAccess your environment here: ${demoUrl}`;
 
   if (slackContext) {
     await say(env, log, slackContext, slackMessage);
   }
 
-  log.info(`Onboarding setup completed successfully for the site ${siteUrl}! Access your environment here: ${demoUrl}`);
+  log.info(`Onboarding setup completed for the site ${siteUrl}! Access your environment here: ${demoUrl}`);
 
   return ok({ message: 'Demo URL processor completed' });
 }