User Creates Scenario (via UI)
    ↓ source: 'user'
    ↓
Radar Creates Scenario (automated)
    ↓ source: 'radar'
    ↓
    ├─→ Next.js API Tool (createScenario)
    │       ↓
    ├─→ Lambda API Handler
    │   - Accepts source parameter
    │   - Stores in DynamoDB
    │   - Passes through SQS
    │       ↓
    └─→ Lambda Agent Processor
        - Processes scenario
        - Checks source field
        - If source == 'user': ✅ Send email
        - If source == 'radar': ❌ Skip email

inputSchema: z.object({
  question: z.string().describe('...'),
  source: z
    .enum(['user', 'radar'])
    .optional()
    .default('user')
    .describe('Source of the scenario: "user" for user-created, "radar" for automated radar generation'),
}),
execute: async ({ question, source = 'user' }) => {
  // Pass source to API
  const response = await axios.post(
    `${apiUrl}/consultations`,
    { question, source },
    { headers: { 'X-User-Id': clerkId } }
  );
}

**CRITICAL FOR SCENARIO ANALYSIS:**
When using the createScenario tool, ALWAYS pass source: 'radar' to indicate this is an automated radar-generated scenario.
This prevents sending email notifications for automated scenarios.
Example: createScenario({ question: "...", source: "radar" })

# Get optional source parameter (defaults to 'user' for backward compatibility)
source = body.get("source", "user")

consultation = {
    "userId": user_id,
    "consultationId": consultation_id,
    "title": title,
    "question": question,
    "source": source,  # NEW FIELD
    "status": "pending",
    "createdAt": now,
    "updatedAt": now,
}

# Pass to SQS
sqs.send_message(
    QueueUrl=queue_url,
    MessageBody=json.dumps({
        "consultationId": consultation_id,
        "userId": user_id,
        "question": question,
        "title": title,
        "source": source,  # PASS THROUGH
    })
)

def process_consultation(message):
    consultation_id = message["consultationId"]
    user_id = message["userId"]
    question = message["question"]
    source = message.get("source", "user")  # Default to 'user'
    
    # ... process scenario ...
    
    # Only send email if NOT from radar
    if source != "radar":
        send_completion_email(
            user_id=user_id,
            consultation_id=consultation_id,
            title=message.get("title", "Your Research Report"),
            question=question,
            chart_count=len(all_charts)
        )
    else:
        print(f"[process_consultation] Skipping email notification for radar-generated scenario {consultation_id}")