🚦 GA4 Traffic Source Monitor

GA4_PROPERTY_ID=123456789        # Your GA4 Property ID
ALERT_EMAIL=[email protected]      # Where to send alerts

const KEY_SOURCES = [
  // Paid campaigns
  { source: 'google', medium: 'cpc', name: 'Google Ads' },
  { source: 'facebook', medium: 'cpc', name: 'Facebook Ads' },
  { source: 'linkedin', medium: 'cpc', name: 'LinkedIn Ads' },

  // Organic
  { source: 'google', medium: 'organic', name: 'Google Organic' },

  // Direct
  { source: '(direct)', medium: '(none)', name: 'Direct Traffic' },

  // Email & Social
  { source: 'newsletter', medium: 'email', name: 'Email Newsletter' },
  { source: 'twitter', medium: 'social', name: 'Twitter/X' },

  // Partnerships
  { source: 'partner-site.com', medium: 'referral', name: 'Partner X' },
];

const WARNING_THRESHOLD = 25;  // Alert if sessions drop > 25%
const CRITICAL_THRESHOLD = 50; // Critical if sessions drop > 50%
const MIN_SESSIONS = 10;       // Ignore sources with < 10 daily sessions

# Daily at 9 AM (default)
0 9 * * *

# Daily at 8 AM
0 8 * * *

# Twice daily (9 AM and 5 PM)
0 9,17 * * *

# Weekdays only at 9 AM
0 9 * * 1-5

# Hourly during business hours
0 9-18 * * *

const MIN_SESSIONS = 10;  // Lower this for low-traffic sources

{
  "channel": "#marketing-alerts",
  "text": "🚨 Traffic Alert: {{ $json.summary.issueCount }} sources dropping",
  "blocks": [
    {
      "type": "section",
      "text": {
        "type": "mrkdwn",
        "text": "*{{ $json.issues[0].source }}* dropped {{ $json.issues[0].variance }}"

{{ $json.summary.criticalCount > 0 }}

const properties = [
  { id: '123456789', name: 'Main Website' },
  { id: '987654321', name: 'Mobile App' }
];

return properties.map(prop => ({ json: prop }));

{ "metric": "totalRevenue" }

conversions: parseInt(item.conversions || 0),
revenue: parseFloat(item.totalRevenue || 0),  // Add this
engagementRate: parseFloat(item.engagementRate || 0)

<div class="metric-row">
  <span>Revenue:</span>
  <strong>$${issue.revenue.toFixed(2)}</strong>
</div>

0 9 * * 1-5  // Monday-Friday only

const today = new Date().getDay();
const isWeekend = today === 0 || today === 6;
return !isWeekend;

┌─────────────────────────────────────────────────────────────┐
│                    Schedule Trigger                          │
│                    (Daily 9 AM)                              │
└────────────────────┬────────────────────────────────────────┘
                     │
         ┌───────────┴───────────┐
         │                       │
         ▼                       ▼
┌──────────────────┐    ┌──────────────────┐
│ Get Yesterday's  │    │ Get 7-Day Avg    │
│ Traffic Sources  │    │ Traffic Sources  │
│ (GA4 API)        │    │ (GA4 API)        │
└────────┬─────────┘    └─────────┬────────┘
         │                        │
         └───────────┬────────────┘
                     │
                     ▼
         ┌───────────────────────┐
         │ Merge Both Datasets   │
         └───────────┬───────────┘
                     │
                     ▼
         ┌───────────────────────┐
         │ Analyze Traffic       │
         │ Sources (JavaScript)  │
         │ - Compare yesterday   │
         │   vs 7-day average    │
         │ - Calculate variance  │
         │ - Detect issues       │
         │ - Identify trends     │
         └───────────┬───────────┘
                     │
                     ▼
              ┌──────────┐
              │ Has      │
              │ Issues?  │
              └─────┬────┴────┐
                    │         │
              (Yes) │         │ (No)
                    │         │
         ┌──────────▼──┐   ┌──▼──────────┐
         │ Format      │   │ Format      │
         │ Alert Email │   │ OK Email    │
         │ (Red Theme) │   │ (Green)     │
         └──────┬──────┘   └──┬──────────┘
                │             │
         ┌──────▼──┐       ┌──▼──────┐
         │ Send    │       │ Send    │
         │ Alert   │       │ OK      │
         │ (Gmail) │       │ (Gmail) │
         └─────────┘       └─────────┘

// Week 1: Relaxed thresholds
WARNING_THRESHOLD = 35;
CRITICAL_THRESHOLD = 70;

// Week 2-3: Observe and adjust
// Week 4+: Tighten based on your patterns
WARNING_THRESHOLD = 25;
CRITICAL_THRESHOLD = 50;

const getThreshold = (sourceName) => {
  const thresholds = {
    'Google Organic': { warning: 20, critical: 40 },
    'Google Ads': { warning: 30, critical: 50 },
    'Direct Traffic': { warning: 40, critical: 70 }
  };
  return thresholds[sourceName] || { warning: 25, critical: 50 };
};

const isKnownLowDay = (date) => {
  const holidays = [
    '2024-12-25', // Christmas
    '2024-01-01', // New Year
    '2024-07-04'  // July 4th
  ];
  return holidays.includes(date);
};

// Adjust threshold or skip alert
if (isKnownLowDay(reportDate)) {
  // Don't alert on holidays
  return;
}

## Our Alert Thresholds

### Google Organic
-Warning: 20% (SEO changes slowly)
-Critical: 40%
-Rationale: Stable traffic, small drops meaningful

### Google Ads
-Warning: 30% (can fluctuate)
-Critical: 50%
-Rationale: Paid traffic varies with budget

### Email Newsletter
-Warning: 50% (sent periodically)
-Critical: 80%
-Rationale: Batch sends, high variance OK

{
  "name": "GA4 Traffic Source Monitor",
  "nodes": [
    {
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 9 * * *"
            }
          ]
        }
      },
      "id": "989df9b3-259a-4703-b9a5-dcb003d14765",
      "name": "Schedule Daily 9AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1.2,
      "position": [
        -576,
        80
      ]
    },
    {
      "parameters": {
        "propertyId": {
          "__rl": true,
          "value": "={{ $env.GA4_PROPERTY_ID }}",
          "mode": "id"
        },
        "dateRange": "yesterday",
        "metricsGA4": {
          "metricValues": [
            {
              "listName": "sessions"
            }
          ]
        },
        "dimensionsGA4": {
          "dimensionValues": [
            {
              "listName": "other",
              "name": "sessionSource"
            },
            {
              "listName": "other",
              "name": "sessionMedium"
            }
          ]
        },
        "additionalFields": {}
      },
      "id": "ba8610de-4787-4952-84f6-5bbc31a2371b",
      "name": "Get Yesterday's Traffic Sources",
      "type": "n8n-nodes-base.googleAnalytics",
      "typeVersion": 2,
      "position": [
        -352,
        -32
      ],
      "credentials": {
        "googleAnalyticsOAuth2": {
          "id": "YOUR_GA4_CREDENTIAL_ID",
          "name": "Google Analytics account"
        }
      }
    },
    {
      "parameters": {
        "propertyId": {
          "__rl": true,
          "value": "={{ $env.GA4_PROPERTY_ID }}",
          "mode": "id"
        },
        "dateRange": "last7Days",
        "metricsGA4": {
          "metricValues": [
            {
              "listName": "sessions"
            }
          ]
        },
        "dimensionsGA4": {
          "dimensionValues": [
            {
              "listName": "other",
              "name": "sessionSource"
            },
            {
              "listName": "other",
              "name": "sessionMedium"
            }
          ]
        },
        "additionalFields": {}
      },
      "id": "0933949f-2b5a-43d9-901e-22d3107a1ed5",
      "name": "Get 7-Day Avg Traffic Sources",
      "type": "n8n-nodes-base.googleAnalytics",
      "typeVersion": 2,
      "position": [
        -352,
        176
      ],
      "alwaysOutputData": true,
      "credentials": {
        "googleAnalyticsOAuth2": {
          "id": "YOUR_GA4_CREDENTIAL_ID",
          "name": "Google Analytics account"
        }
      }
    },
    {
      "parameters": {
        "mode": "combine",
        "combineBy": "combineAll",
        "options": {}
      },
      "id": "3b8d6515-c4d3-487f-98d5-ff128c8e70aa",
      "name": "Merge Source Data",
      "type": "n8n-nodes-base.merge",
      "typeVersion": 3,
      "position": [
        -128,
        80
      ]
    },
    {
      "parameters": {
        "jsCode": "// FLEXIBLE TRAFFIC SOURCE ANALYZER\n// Handles both date-based data AND source/medium data\n\n// Configuration: Define your key traffic sources to monitor\nconst KEY_SOURCES = [\n  { source: 'google', medium: 'organic', name: 'Google Organic' },\n  { source: 'google', medium: 'cpc', name: 'Google Ads' },\n  { source: 'facebook', medium: 'cpc', name: 'Facebook Ads' },\n  { source: 'linkedin', medium: 'cpc', name: 'LinkedIn Ads' },\n  { source: '(direct)', medium: '(none)', name: 'Direct Traffic' },\n  { source: '(direct)', medium: '(not set)', name: 'Direct Traffic' },\n  { source: 'bing', medium: 'organic', name: 'Bing Organic' },\n  { source: 'facebook.com', medium: 'referral', name: 'Facebook Organic' },\n];\n\n// Alert thresholds\nconst WARNING_THRESHOLD = 25;  // Alert if sessions drop > 25%\nconst CRITICAL_THRESHOLD = 50; // Critical if sessions drop > 50%\nconst MIN_SESSIONS = 10;       // Ignore sources with < 10 daily sessions\n\n// Get all merged data\nconst allItems = $input.all();\n\nconsole.log('=== DEBUG INFO ===');\nconsole.log('Total items received:', allItems.length);\nconsole.log('First item structure:', JSON.stringify(allItems[0]?.json, null, 2));\nconsole.log('Last item structure:', JSON.stringify(allItems[allItems.length - 1]?.json, null, 2));\n\n// Detect data format\nconst firstItem = allItems[0]?.json || {};\nconst hasSourceDimensions = 'sessionSource' in firstItem || 'firstUserSource' in firstItem;\nconst hasDateDimension = 'date' in firstItem;\n\nconsole.log('Has source dimensions:', hasSourceDimensions);\nconsole.log('Has date dimension:', hasDateDimension);\n\nif (!hasSourceDimensions && hasDateDimension) {\n  // ERROR: User has wrong dimensions configured\n  throw new Error(`\n    ❌ GA4 CONFIGURATION ERROR\n    \n    Your GA4 nodes are configured with \"date\" dimension, but they need \"sessionSource\" and \"sessionMedium\" dimensions.\n    \n    Current output structure:\n    ${JSON.stringify(firstItem, null, 2)}\n    \n    Expected output structure:\n    {\n      \"sessionSource\": \"google\",\n      \"sessionMedium\": \"organic\",\n      \"sessions\": \"5000\",\n      \"totalUsers\": \"3000\"\n    }\n    \n    HOW TO FIX:\n    1. Click on \"Get Yesterday's Traffic Sources\" node\n    2. Remove the \"date\" dimension\n    3. Add TWO dimensions:\n       - sessionSource\n       - sessionMedium\n    4. Repeat for \"Get 7-Day Avg Traffic Sources\" node\n    5. Save and test again\n    \n    See CORRECTED_GA4_Node_Config.md for detailed instructions.\n  `);\n}\n\n// Helper function to get source key\nconst getSourceKey = (item) => {\n  const source = (item.sessionSource || item.firstUserSource || '(not set)').toLowerCase();\n  const medium = (item.sessionMedium || item.firstUserMedium || '(not set)').toLowerCase();\n  return `${source}|${medium}`;\n};\n\n// Helper function to get display name\nconst getDisplayName = (source, medium) => {\n  // Check if matches a KEY_SOURCE\n  const keySource = KEY_SOURCES.find(\n    ks => ks.source.toLowerCase() === source.toLowerCase() && \n          ks.medium.toLowerCase() === medium.toLowerCase()\n  );\n  \n  if (keySource) return keySource.name;\n  \n  // Otherwise create readable name\n  return `${source}/${medium}`;\n};\n\n// Separate yesterday from 7-day average data\nconst midpoint = Math.floor(allItems.length / 2);\nconst yesterdayData = allItems.slice(0, midpoint).map(item => item.json);\nconst avg7dayData = allItems.slice(midpoint).map(item => item.json);\n\nconsole.log('Yesterday items:', yesterdayData.length);\nconsole.log('7-day items:', avg7dayData.length);\n\n// Build maps for quick lookup\nconst yesterdayMap = new Map();\nyesterdayData.forEach(item => {\n  const key = getSourceKey(item);\n  yesterdayMap.set(key, {\n    source: item.sessionSource || item.firstUserSource || '(not set)',\n    medium: item.sessionMedium || item.firstUserMedium || '(not set)',\n    sessions: parseInt(item.sessions || 0),\n    users: parseInt(item.totalUsers || 0),\n    conversions: parseInt(item.conversions || 0),\n    engagementRate: parseFloat(item.engagementRate || 0)\n  });\n});\n\n// Build 7-day average map\nconst avg7dayMap = new Map();\navg7dayData.forEach(item => {\n  const key = getSourceKey(item);\n  const existing = avg7dayMap.get(key) || { \n    source: item.sessionSource || item.firstUserSource || '(not set)',\n    medium: item.sessionMedium || item.firstUserMedium || '(not set)',\n    sessions: 0, \n    users: 0, \n    conversions: 0, \n    engagementRate: 0, \n    count: 0 \n  };\n  \n  avg7dayMap.set(key, {\n    source: existing.source,\n    medium: existing.medium,\n    sessions: existing.sessions + parseInt(item.sessions || 0),\n    users: existing.users + parseInt(item.totalUsers || 0),\n    conversions: existing.conversions + parseInt(item.conversions || 0),\n    engagementRate: existing.engagementRate + parseFloat(item.engagementRate || 0),\n    count: existing.count + 1\n  });\n});\n\n// Calculate 7-day averages\navg7dayMap.forEach((value, key) => {\n  const days = Math.max(value.count, 1);\n  avg7dayMap.set(key, {\n    source: value.source,\n    medium: value.medium,\n    sessions: Math.round(value.sessions / days),\n    users: Math.round(value.users / days),\n    conversions: Math.round(value.conversions / days),\n    engagementRate: value.engagementRate / value.count\n  });\n});\n\nconsole.log('Unique sources found (yesterday):', yesterdayMap.size);\nconsole.log('Unique sources found (7-day):', avg7dayMap.size);\n\n// Analyze each key source\nconst sourceIssues = [];\nconst sourceStatus = [];\n\n// Get all unique sources (from both maps)\nconst allSourceKeys = new Set([...yesterdayMap.keys(), ...avg7dayMap.keys()]);\n\nallSourceKeys.forEach(sourceKey => {\n  const yesterday = yesterdayMap.get(sourceKey);\n  const avg7day = avg7dayMap.get(sourceKey);\n  \n  const yesterdaySessions = yesterday?.sessions || 0;\n  const avg7daySessions = avg7day?.sessions || 0;\n  \n  // Get source/medium for display\n  const source = yesterday?.source || avg7day?.source || '(not set)';\n  const medium = yesterday?.medium || avg7day?.medium || '(not set)';\n  const displayName = getDisplayName(source, medium);\n  \n  // Skip if source has very low traffic\n  if (avg7daySessions < MIN_SESSIONS && yesterdaySessions < MIN_SESSIONS) {\n    return;\n  }\n  \n  // Calculate variance\n  const variance = avg7daySessions > 0 \n    ? ((yesterdaySessions - avg7daySessions) / avg7daySessions) * 100 \n    : 0;\n  \n  const status = {\n    source: displayName,\n    sourceKey: source,\n    mediumKey: medium,\n    yesterday: {\n      sessions: yesterdaySessions,\n      users: yesterday?.users || 0,\n      conversions: yesterday?.conversions || 0,\n      engagementRate: ((yesterday?.engagementRate || 0) * 100).toFixed(2) + '%'\n    },\n    avg7day: {\n      sessions: avg7daySessions,\n      users: avg7day?.users || 0,\n      conversions: avg7day?.conversions || 0,\n      engagementRate: ((avg7day?.engagementRate || 0) * 100).toFixed(2) + '%'\n    },\n    variance: variance.toFixed(2) + '%',\n    varianceNum: variance,\n    change: yesterdaySessions - avg7daySessions\n  };\n  \n  sourceStatus.push(status);\n  \n  // Check for issues (DROPS only, not increases)\n  if (variance < -CRITICAL_THRESHOLD) {\n    sourceIssues.push({\n      severity: 'CRITICAL',\n      source: displayName,\n      yesterday: yesterdaySessions,\n      avg7day: avg7daySessions,\n      variance: variance.toFixed(2) + '%',\n      change: yesterdaySessions - avg7daySessions,\n      message: `${displayName} dropped ${Math.abs(variance).toFixed(0)}% - investigate immediately!`\n    });\n  } else if (variance < -WARNING_THRESHOLD) {\n    sourceIssues.push({\n      severity: 'WARNING',\n      source: displayName,\n      yesterday: yesterdaySessions,\n      avg7day: avg7daySessions,\n      variance: variance.toFixed(2) + '%',\n      change: yesterdaySessions - avg7daySessions,\n      message: `${displayName} declined ${Math.abs(variance).toFixed(0)}% - monitor closely`\n    });\n  }\n});\n\n// Sort sources by variance (worst drops first)\nsourceStatus.sort((a, b) => a.varianceNum - b.varianceNum);\n\n// Get top growing sources\nconst topGrowing = sourceStatus\n  .filter(s => s.varianceNum > 0)\n  .sort((a, b) => b.varianceNum - a.varianceNum)\n  .slice(0, 3);\n\n// Get top declining sources\nconst topDeclining = sourceStatus\n  .filter(s => s.varianceNum < 0)\n  .sort((a, b) => a.varianceNum - b.varianceNum)\n  .slice(0, 5);\n\n// Calculate total traffic\nconst totalYesterday = Array.from(yesterdayMap.values())\n  .reduce((sum, item) => sum + item.sessions, 0);\n  \nconst totalAvg7day = Array.from(avg7dayMap.values())\n  .reduce((sum, item) => sum + item.sessions, 0);\n\nconst totalVariance = totalAvg7day > 0\n  ? ((totalYesterday - totalAvg7day) / totalAvg7day) * 100\n  : 0;\n\n// Get today's date\nconst today = new Date();\nconst yesterday_date = new Date(today);\nyesterday_date.setDate(today.getDate() - 1);\nconst reportDate = yesterday_date.toISOString().split('T')[0];\n\nconsole.log('=== ANALYSIS RESULTS ===');\nconsole.log('Total sources analyzed:', sourceStatus.length);\nconsole.log('Issues found:', sourceIssues.length);\nconsole.log('Total traffic variance:', totalVariance.toFixed(2) + '%');\n\n// Return comprehensive results\nreturn {\n  summary: {\n    date: reportDate,\n    hasIssues: sourceIssues.length > 0,\n    issueCount: sourceIssues.length,\n    criticalCount: sourceIssues.filter(i => i.severity === 'CRITICAL').length,\n    warningCount: sourceIssues.filter(i => i.severity === 'WARNING').length\n  },\n  traffic: {\n    totalYesterday: Math.round(totalYesterday),\n    totalAvg7day: Math.round(totalAvg7day),\n    totalVariance: totalVariance.toFixed(2) + '%'\n  },\n  issues: sourceIssues,\n  allSources: sourceStatus,\n  topGrowing: topGrowing,\n  topDeclining: topDeclining,\n  monitoredSourcesCount: KEY_SOURCES.length,\n  activeSourcesCount: sourceStatus.length,\n  debug: {\n    dataFormat: hasSourceDimensions ? 'source/medium' : 'date',\n    yesterdayItems: yesterdayData.length,\n    avg7dayItems: avg7dayData.length,\n    uniqueSources: allSourceKeys.size\n  }\n};"
      },
      "id": "3b180c1b-d9db-46c7-845e-0d088e0f7420",
      "name": "Analyze Traffic Sources",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        96,
        80
      ]
    },
    {
      "parameters": {
        "conditions": {
          "boolean": [
            {
              "value1": "={{ $json.summary.hasIssues }}",
              "value2": true
            }
          ]
        }
      },
      "id": "094067d2-03a6-43ee-aa32-ad0173b35c5d",
      "name": "Has Issues?",
      "type": "n8n-nodes-base.if",
      "typeVersion": 1,
      "position": [
        320,
        80
      ]
    },
    {
      "parameters": {
        "jsCode": "const data = $input.first().json;\n\nconst formatNumber = (num) => num.toString().replace(/\\B(?=(\\d{3})+(?!\\d))/g, ',');\n\nconst getChangeColor = (variance) => {\n  const num = parseFloat(variance);\n  if (num > 0) return '#10b981';\n  if (num < -25) return '#ef4444';\n  return '#f59e0b';\n};\n\nconst getChangeIcon = (variance) => {\n  const num = parseFloat(variance);\n  if (num > 0) return '📈';\n  if (num < 0) return '📉';\n  return '➡️';\n};\n\nconst html = `\n<!DOCTYPE html>\n<html>\n<head>\n  <meta charset=\"UTF-8\">\n  <style>\n    body { \n      font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, sans-serif; \n      line-height: 1.6; \n      color: #333; \n      max-width: 700px; \n      margin: 0 auto; \n      padding: 20px; \n      background: #f5f5f5; \n    }\n    .container { \n      background: white; \n      border-radius: 12px; \n      padding: 35px; \n      box-shadow: 0 4px 12px rgba(0,0,0,0.1); \n    }\n    .header { \n      background: linear-gradient(135deg, #dc3545 0%, #c82333 100%);\n      color: white; \n      padding: 25px; \n      border-radius: 8px; \n      margin-bottom: 25px;\n      text-align: center;\n    }\n    .header h1 { margin: 0; font-size: 24px; }\n    .header p { margin: 8px 0 0 0; opacity: 0.95; }\n    .badge { \n      display: inline-block; \n      padding: 5px 14px; \n      border-radius: 15px; \n      font-size: 12px; \n      font-weight: 600; \n      margin-top: 8px;\n    }\n    .badge-critical { background: #fff; color: #dc3545; }\n    .badge-warning { background: #fff3cd; color: #856404; }\n    .summary-grid { \n      display: grid; \n      grid-template-columns: repeat(3, 1fr); \n      gap: 12px; \n      margin: 20px 0;\n    }\n    .summary-card { \n      background: #f8fafc; \n      padding: 15px; \n      border-radius: 8px; \n      text-align: center;\n      border: 2px solid #e5e7eb;\n    }\n    .summary-card strong { \n      display: block; \n      font-size: 24px; \n      margin-bottom: 5px;\n    }\n    .summary-card span { \n      color: #64748b; \n      font-size: 13px;\n    }\n    .issue-card { \n      border-radius: 8px; \n      padding: 18px; \n      margin: 15px 0; \n      border-left: 5px solid;\n    }\n    .issue-critical { background: #fee2e2; border-left-color: #dc3545; }\n    .issue-warning { background: #fef3c7; border-left-color: #ffc107; }\n    .issue-card h4 { margin: 0 0 12px 0; font-size: 16px; }\n    .issue-critical h4 { color: #991b1b; }\n    .issue-warning h4 { color: #92400e; }\n    .metric-row { \n      display: flex; \n      justify-content: space-between; \n      padding: 5px 0; \n      font-size: 14px;\n    }\n    .section-title { \n      font-size: 18px; \n      font-weight: 700; \n      color: #1e40af; \n      margin: 25px 0 15px 0; \n      padding-bottom: 8px; \n      border-bottom: 2px solid #e0e7ff;\n    }\n    table { \n      width: 100%; \n      border-collapse: collapse; \n      margin: 15px 0;\n      font-size: 14px;\n    }\n    th { \n      background: #1e40af; \n      color: white; \n      padding: 12px 8px; \n      text-align: left; \n      font-weight: 600;\n      font-size: 13px;\n    }\n    td { \n      padding: 10px 8px; \n      border-bottom: 1px solid #e5e7eb;\n    }\n    tr:hover { background: #f9fafb; }\n    .footer { \n      margin-top: 30px; \n      padding-top: 20px; \n      border-top: 2px solid #e5e7eb; \n      font-size: 13px; \n      color: #6b7280; \n      text-align: center;\n    }\n  </style>\n</head>\n<body>\n  <div class=\"container\">\n    <div class=\"header\">\n      <h1>🚨 Traffic Source Alert</h1>\n      <p><strong>Date:</strong> ${data.summary.date}</p>\n      ${data.summary.criticalCount > 0 ? \n        `<span class=\"badge badge-critical\">${data.summary.criticalCount} CRITICAL</span>` : \n        `<span class=\"badge badge-warning\">${data.summary.warningCount} WARNING</span>`\n      }\n    </div>\n\n    <div class=\"summary-grid\">\n      <div class=\"summary-card\">\n        <strong>${formatNumber(data.traffic.totalYesterday)}</strong>\n        <span>Total Sessions</span>\n      </div>\n      <div class=\"summary-card\">\n        <strong style=\"color: ${getChangeColor(data.traffic.totalVariance)}\">\n          ${getChangeIcon(data.traffic.totalVariance)} ${data.traffic.totalVariance}\n        </strong>\n        <span>Total Change</span>\n      </div>\n      <div class=\"summary-card\">\n        <strong>${data.summary.issueCount}</strong>\n        <span>Sources Dropping</span>\n      </div>\n    </div>\n\n    <div class=\"section-title\">🔍 Traffic Source Issues</div>\n    ${data.issues.map(issue => `\n      <div class=\"issue-card ${issue.severity === 'CRITICAL' ? 'issue-critical' : 'issue-warning'}\">\n        <h4>${issue.severity === 'CRITICAL' ? '🔴' : '⚠️'} ${issue.source}</h4>\n        <div class=\"metric-row\">\n          <span>Yesterday:</span>\n          <strong>${formatNumber(issue.yesterday)} sessions</strong>\n        </div>\n        <div class=\"metric-row\">\n          <span>7-Day Average:</span>\n          <strong>${formatNumber(issue.avg7day)} sessions</strong>\n        </div>\n        <div class=\"metric-row\">\n          <span>Change:</span>\n          <strong style=\"color: #ef4444;\">${issue.variance} (${formatNumber(issue.change)})</strong>\n        </div>\n        <div style=\"margin-top: 10px; padding: 10px; background: white; border-radius: 4px; font-size: 13px;\">\n          <strong>Action:</strong> ${issue.message}\n        </div>\n      </div>\n    `).join('')}\n\n    ${data.topDeclining.length > 0 ? `\n      <div class=\"section-title\">📉 Top Declining Sources</div>\n      <table>\n        <thead>\n          <tr>\n            <th>Source</th>\n            <th style=\"text-align: right;\">Yesterday</th>\n            <th style=\"text-align: right;\">7-Day Avg</th>\n            <th style=\"text-align: right;\">Change</th>\n          </tr>\n        </thead>\n        <tbody>\n          ${data.topDeclining.map(source => `\n            <tr>\n              <td><strong>${source.source}</strong></td>\n              <td style=\"text-align: right;\">${formatNumber(source.yesterday.sessions)}</td>\n              <td style=\"text-align: right;\">${formatNumber(source.avg7day.sessions)}</td>\n              <td style=\"text-align: right; color: #ef4444; font-weight: 600;\">\n                ${source.variance}\n              </td>\n            </tr>\n          `).join('')}\n        </tbody>\n      </table>\n    ` : ''}\n\n    ${data.topGrowing.length > 0 ? `\n      <div class=\"section-title\">📈 Top Growing Sources (Good News!)</div>\n      <table>\n        <thead>\n          <tr>\n            <th>Source</th>\n            <th style=\"text-align: right;\">Yesterday</th>\n            <th style=\"text-align: right;\">7-Day Avg</th>\n            <th style=\"text-align: right;\">Growth</th>\n          </tr>\n        </thead>\n        <tbody>\n          ${data.topGrowing.map(source => `\n            <tr>\n              <td><strong>${source.source}</strong></td>\n              <td style=\"text-align: right;\">${formatNumber(source.yesterday.sessions)}</td>\n              <td style=\"text-align: right;\">${formatNumber(source.avg7day.sessions)}</td>\n              <td style=\"text-align: right; color: #10b981; font-weight: 600;\">\n                ${source.variance}\n              </td>\n            </tr>\n          `).join('')}\n        </tbody>\n      </table>\n    ` : ''}\n\n    <div class=\"footer\">\n      <p><strong>🤖 Automated Traffic Source Monitor</strong></p>\n      <p>Monitoring ${data.monitoredSourcesCount} key sources | ${data.activeSourcesCount} active</p>\n      <p style=\"margin-top: 10px; font-size: 12px;\">Generated ${new Date().toLocaleString()}</p>\n    </div>\n  </div>\n</body>\n</html>\n`;\n\nreturn { \n  html,\n  subject: `🚨 Traffic Alert: ${data.summary.issueCount} Source${data.summary.issueCount > 1 ? 's' : ''} Dropping - ${data.summary.date}`\n};"
      },
      "id": "fe26378c-4598-4735-bf8a-465e2ff3fbb4",
      "name": "Format Alert Email",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        528,
        -32
      ]
    },
    {
      "parameters": {
        "sendTo": "={{ $env.NOTIFICATION_EMAIL }}",
        "subject": "={{ $json.subject }}",
        "message": "={{ $json.html }}",
        "options": {}
      },
      "id": "723c09e2-dfcf-4d73-ab9c-3c33038a9e24",
      "name": "Send Alert Email",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2.1,
      "position": [
        752,
        -32
      ],
      "credentials": {
        "gmailOAuth2": {
          "id": "YOUR_GMAIL_CREDENTIAL_ID",
          "name": "Gmail account"
        }
      }
    },
    {
      "parameters": {
        "jsCode": "const data = $input.first().json;\n\nconst formatNumber = (num) => num.toString().replace(/\\B(?=(\\d{3})+(?!\\d))/g, ',');\n\nconst getChangeColor = (variance) => {\n  const num = parseFloat(variance);\n  if (num > 0) return '#10b981';\n  if (num < 0) return '#f59e0b';\n  return '#6b7280';\n};\n\nconst getChangeIcon = (variance) => {\n  const num = parseFloat(variance);\n  if (num > 10) return '📈';\n  if (num < -10) return '📉';\n  return '➡️';\n};\n\nconst html = `\n<!DOCTYPE html>\n<html>\n<head>\n  <meta charset=\"UTF-8\">\n  <style>\n    body { \n      font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, sans-serif; \n      line-height: 1.6; \n      color: #333; \n      max-width: 700px; \n      margin: 0 auto; \n      padding: 20px; \n      background: #f5f5f5; \n    }\n    .container { \n      background: white; \n      border-radius: 12px; \n      padding: 35px; \n      box-shadow: 0 4px 12px rgba(0,0,0,0.1); \n    }\n    .header { \n      background: linear-gradient(135deg, #10b981 0%, #059669 100%);\n      color: white; \n      padding: 25px; \n      border-radius: 8px; \n      margin-bottom: 25px;\n      text-align: center;\n    }\n    .header h1 { margin: 0; font-size: 24px; }\n    .header .badge { \n      display: inline-block; \n      padding: 5px 14px; \n      border-radius: 15px; \n      font-size: 12px; \n      font-weight: 600; \n      background: white;\n      color: #059669;\n      margin-top: 8px;\n    }\n    .summary-grid { \n      display: grid; \n      grid-template-columns: repeat(3, 1fr); \n      gap: 12px; \n      margin: 20px 0;\n    }\n    .summary-card { \n      background: #f8fafc; \n      padding: 15px; \n      border-radius: 8px; \n      text-align: center;\n      border: 2px solid #e5e7eb;\n    }\n    .summary-card strong { \n      display: block; \n      font-size: 24px; \n      margin-bottom: 5px;\n    }\n    .summary-card span { \n      color: #64748b; \n      font-size: 13px;\n    }\n    .section-title { \n      font-size: 18px; \n      font-weight: 700; \n      color: #1e40af; \n      margin: 25px 0 15px 0; \n      padding-bottom: 8px; \n      border-bottom: 2px solid #e0e7ff;\n    }\n    table { \n      width: 100%; \n      border-collapse: collapse; \n      margin: 15px 0;\n      font-size: 14px;\n    }\n    th { \n      background: #1e40af; \n      color: white; \n      padding: 12px 8px; \n      text-align: left; \n      font-weight: 600;\n      font-size: 13px;\n    }\n    td { \n      padding: 10px 8px; \n      border-bottom: 1px solid #e5e7eb;\n    }\n    tr:hover { background: #f9fafb; }\n    .ok-box { \n      background: #d1fae5; \n      border-left: 4px solid #10b981; \n      padding: 18px; \n      margin: 20px 0; \n      border-radius: 6px;\n    }\n    .ok-box h3 { \n      margin: 0 0 8px 0; \n      color: #065f46; \n    }\n    .ok-box p { \n      margin: 5px 0; \n      color: #047857; \n    }\n    .footer { \n      margin-top: 30px; \n      padding-top: 20px; \n      border-top: 2px solid #e5e7eb; \n      font-size: 13px; \n      color: #6b7280; \n      text-align: center;\n    }\n  </style>\n</head>\n<body>\n  <div class=\"container\">\n    <div class=\"header\">\n      <h1>✅ Traffic Sources Report</h1>\n      <p><strong>Date:</strong> ${data.summary.date}</p>\n      <span class=\"badge\">ALL SOURCES HEALTHY</span>\n    </div>\n\n    <div class=\"summary-grid\">\n      <div class=\"summary-card\">\n        <strong>${formatNumber(data.traffic.totalYesterday)}</strong>\n        <span>Total Sessions</span>\n      </div>\n      <div class=\"summary-card\">\n        <strong style=\"color: ${getChangeColor(data.traffic.totalVariance)}\">\n          ${getChangeIcon(data.traffic.totalVariance)} ${data.traffic.totalVariance}\n        </strong>\n        <span>Total Change</span>\n      </div>\n      <div class=\"summary-card\">\n        <strong style=\"color: #10b981;\">0</strong>\n        <span>Issues Detected</span>\n      </div>\n    </div>\n\n    <div class=\"ok-box\">\n      <h3>✓ All Key Sources Performing Normally</h3>\n      <p>All monitored traffic sources are within acceptable variance ranges.</p>\n      <p>No significant drops detected compared to 7-day average.</p>\n    </div>\n\n    ${data.topGrowing.length > 0 ? `\n      <div class=\"section-title\">📈 Top Growing Sources</div>\n      <table>\n        <thead>\n          <tr>\n            <th>Source</th>\n            <th style=\"text-align: right;\">Yesterday</th>\n            <th style=\"text-align: right;\">7-Day Avg</th>\n            <th style=\"text-align: right;\">Growth</th>\n          </tr>\n        </thead>\n        <tbody>\n          ${data.topGrowing.map(source => `\n            <tr>\n              <td><strong>${source.source}</strong></td>\n              <td style=\"text-align: right;\">${formatNumber(source.yesterday.sessions)}</td>\n              <td style=\"text-align: right;\">${formatNumber(source.avg7day.sessions)}</td>\n              <td style=\"text-align: right; color: #10b981; font-weight: 600;\">\n                ${source.variance}\n              </td>\n            </tr>\n          `).join('')}\n        </tbody>\n      </table>\n    ` : ''}\n\n    <div class=\"section-title\">📊 All Monitored Sources</div>\n    <table>\n      <thead>\n        <tr>\n          <th>Source</th>\n          <th style=\"text-align: right;\">Yesterday</th>\n          <th style=\"text-align: right;\">Change</th>\n        </tr>\n      </thead>\n      <tbody>\n        ${data.allSources.slice(0, 10).map(source => `\n          <tr>\n            <td><strong>${source.source}</strong></td>\n            <td style=\"text-align: right;\">${formatNumber(source.yesterday.sessions)}</td>\n            <td style=\"text-align: right; color: ${getChangeColor(source.variance)}; font-weight: 600;\">\n              ${getChangeIcon(source.variance)} ${source.variance}\n            </td>\n          </tr>\n        `).join('')}\n      </tbody>\n    </table>\n\n    <div class=\"footer\">\n      <p><strong>🤖 Automated Traffic Source Monitor</strong></p>\n      <p>Monitoring ${data.monitoredSourcesCount} key sources | ${data.activeSourcesCount} active</p>\n      <p style=\"margin-top: 10px; font-size: 12px;\">Generated ${new Date().toLocaleString()}</p>\n    </div>\n  </div>\n</body>\n</html>\n`;\n\nreturn { \n  html,\n  subject: `✅ Traffic Sources: All Healthy - ${data.summary.date}`\n};"
      },
      "id": "8d00f9da-013d-4cde-b81f-31999f933383",
      "name": "Format OK Email",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        528,
        176
      ]
    },
    {
      "parameters": {
        "sendTo": "={{ $env.NOTIFICATION_EMAIL }}",
        "subject": "={{ $json.subject }}",
        "message": "={{ $json.html }}",
        "options": {}
      },
      "id": "e4b14e42-754f-4e12-9184-06c6a8ec90cc",
      "name": "Send OK Email",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2.1,
      "position": [
        752,
        176
      ],
      "credentials": {
        "gmailOAuth2": {
          "id": "YOUR_GMAIL_CREDENTIAL_ID",
          "name": "Gmail account"
        }
      }
    }
  ],
  "pinData": {},
  "connections": {
    "Schedule Daily 9AM": {
      "main": [
        [
          {
            "node": "Get Yesterday's Traffic Sources",
            "type": "main",
            "index": 0
          },
          {
            "node": "Get 7-Day Avg Traffic Sources",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Get Yesterday's Traffic Sources": {
      "main": [
        [
          {
            "node": "Merge Source Data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Get 7-Day Avg Traffic Sources": {
      "main": [
        [
          {
            "node": "Merge Source Data",
            "type": "main",
            "index": 1
          }
        ]
      ]
    },
    "Merge Source Data": {
      "main": [
        [
          {
            "node": "Analyze Traffic Sources",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Analyze Traffic Sources": {
      "main": [
        [
          {
            "node": "Has Issues?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Has Issues?": {
      "main": [
        [
          {
            "node": "Format Alert Email",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Format OK Email",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Format Alert Email": {
      "main": [
        [
          {
            "node": "Send Alert Email",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Format OK Email": {
      "main": [
        [
          {
            "node": "Send OK Email",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "active": false,
  "settings": {
    "executionOrder": "v1"
  },
  "tags": []
}