feat: trigger DRS prompt generation during LLMO onboarding (#1781)

## Summary

Adds a DRS client to trigger prompt generation jobs during LLMO
onboarding (LLMO-2656) and defers `llmo-customer-analysis` to DRS
completion (LLMO-1819).

- **DRS Client** (`src/support/drs-client.js`): HTTP client for
submitting prompt generation jobs to DRS
  - Submits jobs with provider `prompt_generation_base_url`
- Passes site metadata (site_id, imsOrgId, brand, base_url, region) and
`source: 'onboarding'`
- Fetches target audience from the site's brand profile, falls back to a
default if unavailable
- Non-blocking: onboarding completes successfully even if DRS submission
fails

- **Onboarding Integration**
(`src/controllers/llmo/llmo-onboarding.js`): Calls DRS after all
critical onboarding steps complete (org/site creation, entitlement,
SharePoint, audits). No longer triggers `llmo-customer-analysis`
directly — that is now triggered by the audit-worker when DRS completes.

### Full flow
```
api-service onboarding
  → submit DRS job (source: 'onboarding', site_id, brand, etc.)
  → DRS processes → SNS JOB_COMPLETED (presigned URL)
  → audit-worker: fetch → write JSON + parquet → trigger llmo-customer-analysis
```

### Environment Variables Required
```
DRS_API_URL=https://drs-api.example.com/api/v1
DRS_API_KEY=<from-ssm>
```

## Related PRs
- spacecat-audit-worker #2041: handler for DRS notifications + parquet
conversion
- spacecat-infrastructure #346: SNS → SQS subscription
- llmo-data-retrieval-service #756: add `source` field + presigned URL
in notifications

## Test plan
- [x] Unit tests for DRS client (7 tests)
- [x] Unit tests for onboarding integration with DRS (3 tests)
- [x] 100% branch coverage on changed files
- [ ] E2E: onboarding → DRS job created → completes → audit-worker
triggers llmo-customer-analysis

🤖 Generated with [Claude Code](https://claude.com/claude-code)

---------

Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>

Author: dzehnder

package.json

@@ -22,7 +22,7 @@
     "build": "hedy -v --test-bundle",
     "deploy": "hedy -v --deploy --aws-deploy-bucket=spacecat-prod-deploy --pkgVersion=latest",
     "deploy-stage": "hedy -v --deploy --aws-deploy-bucket=spacecat-stage-deploy --pkgVersion=latest",
-    "deploy-dev": "hedy -v --deploy --pkgVersion=latest$CI_BUILD_NUM -l latest --aws-deploy-bucket=spacecat-dev-deploy --cleanup-ci=24h",
+    "deploy-dev": "hedy -v --deploy --pkgVersion=latest$CI_BUILD_NUM -l dzehnder --aws-deploy-bucket=spacecat-dev-deploy --cleanup-ci=24h",
     "deploy-secrets": "hedy --aws-update-secrets --params-file=secrets/secrets.env",
     "docs": "npm run docs:lint && npm run docs:build",
     "docs:build": "npx @redocly/cli build-docs -o ./docs/index.html --config docs/openapi/redocly-config.yaml",

src/controllers/hooks.js

@@ -33,7 +33,6 @@ import { isHelixSite } from '../support/utils.js';
 import { getHlxConfigMessagePart } from '../utils/slack/base.js';
 
 const CDN_HOOK_SECRET_NAME = 'INCOMING_WEBHOOK_SECRET_CDN';
-
 export const BUTTON_LABELS = {
   APPROVE_CUSTOMER: 'As Customer',
   APPROVE_FRIENDS_FAMILY: 'As Friends/Family',

src/controllers/llmo/llmo-onboarding.js

@@ -19,6 +19,7 @@ import { composeBaseURL, tracingFetch as fetch, isNonEmptyArray } from '@adobe/s
 import AhrefsAPIClient from '@adobe/spacecat-shared-ahrefs-client';
 import { parse as parseDomain } from 'tldts';
 import { postSlackMessage } from '../../utils/slack/base.js';
+import DrsClient from '../../support/drs-client.js';
 
 // LLMO Constants
 const LLMO_PRODUCT_CODE = EntitlementModel.PRODUCT_CODES.LLMO;
@@ -1056,8 +1057,37 @@ export async function performLlmoOnboarding(params, context, say = () => {}) {
     site.setConfig(Config.toDynamoItem(siteConfig));
     await site.save();
 
-    // Trigger audits
-    await triggerAudits([...BASIC_AUDITS, 'llmo-customer-analysis', 'wikipedia-analysis'], context, site);
+    // Trigger audits (llmo-customer-analysis is NOT triggered here; it will be triggered
+    // after the DRS prompt generation job completes, via SNS → audit-worker. LLMO-1819)
+    await triggerAudits([...BASIC_AUDITS, 'wikipedia-analysis'], context, site);
+
+    // Submit DRS prompt generation job (non-blocking)
+    try {
+      const drsClient = DrsClient(context);
+      if (drsClient.isConfigured()) {
+        // Try to get audience from brand profile, fall back to default
+        const brandProfile = siteConfig.getBrandProfile?.();
+        const audience = brandProfile?.main_profile?.target_audience
+          || `General consumers interested in ${brandName} products and services`;
+
+        const drsJob = await drsClient.submitPromptGenerationJob({
+          baseUrl: baseURL,
+          brandName: brandName.trim(),
+          audience,
+          region: 'US',
+          numPrompts: 42,
+          siteId: site.getId(),
+          imsOrgId,
+        });
+        log.info(`Started DRS prompt generation: job=${drsJob.job_id}`);
+        say(`:robot_face: Started DRS prompt generation job: ${drsJob.job_id}`);
+      } else {
+        log.debug('DRS client not configured, skipping prompt generation');
+      }
+    } catch (drsError) {
+      log.error(`Failed to start DRS prompt generation: ${drsError.message}`);
+      say(':warning: Failed to start DRS prompt generation (will need manual trigger)');
+    }
 
     return {
       site,

src/support/drs-client.js

@@ -0,0 +1,116 @@
+/*
+ * Copyright 2026 Adobe. All rights reserved.
+ * This file is licensed to you under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License. You may obtain a copy
+ * of the License at http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under
+ * the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR REPRESENTATIONS
+ * OF ANY KIND, either express or implied. See the License for the specific language
+ * governing permissions and limitations under the License.
+ */
+
+import { tracingFetch as fetch } from '@adobe/spacecat-shared-utils';
+
+/**
+ * Client for interacting with the Data Retrieval Service (DRS) API.
+ * Used to submit prompt generation jobs for LLMO onboarding.
+ *
+ * @param {object} context - The request context
+ * @returns {object} DRS client with methods for submitting jobs
+ */
+export default function DrsClient(context) {
+  const { env, log } = context;
+  const drsApiUrl = env.DRS_API_URL;
+  const drsApiKey = env.DRS_API_KEY;
+
+  /**
+   * Checks if the DRS client is properly configured.
+   * @returns {boolean} True if DRS_API_URL and DRS_API_KEY are set
+   */
+  function isConfigured() {
+    return Boolean(drsApiUrl && drsApiKey);
+  }
+
+  /**
+   * Submits a prompt generation job to DRS.
+   *
+   * @param {object} params - Job parameters
+   * @param {string} params.baseUrl - The base URL of the site
+   * @param {string} params.brandName - The brand name
+   * @param {string} params.audience - Target audience description
+   * @param {string} [params.region='US'] - Geographic region for prompts
+   * @param {number} [params.numPrompts=42] - Number of prompts to generate
+   * @param {string} params.siteId - The SpaceCat site ID
+   * @param {string} params.imsOrgId - The Adobe IMS organization ID
+   * @returns {Promise<object>} Job submission result with job_id
+   * @throws {Error} If job submission fails or DRS is not configured
+   */
+  async function submitPromptGenerationJob({
+    baseUrl,
+    brandName,
+    audience,
+    region = 'US',
+    numPrompts = 42,
+    siteId,
+    imsOrgId,
+  }) {
+    if (!isConfigured()) {
+      throw new Error('DRS client is not configured. Set DRS_API_URL and DRS_API_KEY environment variables.');
+    }
+
+    const payload = {
+      provider_id: 'prompt_generation_base_url',
+      source: 'onboarding',
+      parameters: {
+        base_url: baseUrl,
+        brand_name: brandName,
+        audience,
+        region,
+        num_prompts: numPrompts,
+        model: 'gpt-5-nano',
+        metadata: {
+          site_id: siteId,
+          imsOrgId,
+          base_url: baseUrl,
+          brand: brandName,
+          region,
+        },
+      },
+    };
+
+    log.info(`Submitting DRS prompt generation job for site ${siteId}`, {
+      baseUrl,
+      brandName,
+      region,
+      numPrompts,
+    });
+
+    const response = await fetch(`${drsApiUrl}/jobs`, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        'x-api-key': drsApiKey,
+      },
+      body: JSON.stringify(payload),
+    });
+
+    if (!response.ok) {
+      const errorText = await response.text();
+      throw new Error(`DRS job submission failed: ${response.status} - ${errorText}`);
+    }
+
+    const result = await response.json();
+    log.info(`DRS job submitted successfully: ${result.job_id}`, {
+      siteId,
+      jobId: result.job_id,
+    });
+
+    return result;
+  }
+
+  return {
+    isConfigured,
+    submitPromptGenerationJob,
+  };
+}