Implementation Guide: Monitor industry news and regulatory changes relevant to client sectors and brief teams

# Azure CLI - Create resource group and VM
az group create --name rg-n8n-monitoring --location eastus
az vm create --resource-group rg-n8n-monitoring --name vm-n8n-prod --image Canonical:0001-com-ubuntu-server-jammy:22_04-lts-gen2:latest --size Standard_B2ms --admin-username n8nadmin --generate-ssh-keys --os-disk-size-gb 32 --public-ip-sku Standard

# Configure NSG rules
az network nsg rule create --resource-group rg-n8n-monitoring --nsg-name vm-n8n-prodNSG --name AllowHTTPS --priority 100 --destination-port-ranges 443 --protocol Tcp --access Allow
az network nsg rule create --resource-group rg-n8n-monitoring --nsg-name vm-n8n-prodNSG --name AllowSSH --priority 110 --destination-port-ranges 22 --protocol Tcp --source-address-prefixes <MSP_OFFICE_IP> --access Allow

# SSH into the VM
ssh n8nadmin@<VM_PUBLIC_IP>

# Update system packages
sudo apt update && sudo apt upgrade -y

# Install Docker
sudo apt install -y ca-certificates curl gnupg
sudo install -m 0755 -d /etc/apt/keyrings
curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /etc/apt/keyrings/docker.gpg
sudo chmod a+r /etc/apt/keyrings/docker.gpg
echo "deb [arch=$(dpkg --print-architecture) signed-by=/etc/apt/keyrings/docker.gpg] https://download.docker.com/linux/ubuntu $(. /etc/os-release && echo $VERSION_CODENAME) stable" | sudo tee /etc/apt/sources.list.d/docker.list > /dev/null
sudo apt update
sudo apt install -y docker-ce docker-ce-cli containerd.io docker-buildx-plugin docker-compose-plugin

# Add current user to docker group
sudo usermod -aG docker $USER
newgrp docker

# Verify installation
docker --version
docker compose version

# Create project directory
mkdir -p ~/n8n-deployment && cd ~/n8n-deployment

# Create Caddyfile
cat > Caddyfile << 'EOF'
n8n.yourdomain.com {
  reverse_proxy n8n:5678
  encode gzip
  header {
    Strict-Transport-Security "max-age=31536000; includeSubDomains"
    X-Content-Type-Options nosniff
    X-Frame-Options DENY
  }
}
EOF

# In your DNS provider, create an A record:
# n8n.yourdomain.com -> <VM_PUBLIC_IP>
# TTL: 300 seconds (5 minutes)

cd ~/n8n-deployment

# Create environment file
cat > .env << 'EOF'
# PostgreSQL
POSTGRES_USER=n8n_user
POSTGRES_PASSWORD=$(openssl rand -base64 32)
POSTGRES_DB=n8n_db

# n8n
N8N_HOST=n8n.yourdomain.com
N8N_PORT=5678
N8N_PROTOCOL=https
WEBHOOK_URL=https://n8n.yourdomain.com/
N8N_ENCRYPTION_KEY=$(openssl rand -hex 32)
N8N_BASIC_AUTH_ACTIVE=true
N8N_BASIC_AUTH_USER=mspadmin
N8N_BASIC_AUTH_PASSWORD=$(openssl rand -base64 24)
GENERIC_TIMEZONE=America/New_York

# Execution settings
EXECUTIONS_DATA_PRUNE=true
EXECUTIONS_DATA_MAX_AGE=168
EOF

# IMPORTANT: Record the generated passwords from .env
cat .env

# Create docker-compose.yml
cat > docker-compose.yml << 'YAML'
version: '3.8'
services:
  postgres:
    image: postgres:16-alpine
    restart: always
    environment:
      POSTGRES_USER: ${POSTGRES_USER}
      POSTGRES_PASSWORD: ${POSTGRES_PASSWORD}
      POSTGRES_DB: ${POSTGRES_DB}
    volumes:
      - postgres_data:/var/lib/postgresql/data
    healthcheck:
      test: ['CMD-SHELL', 'pg_isready -U ${POSTGRES_USER} -d ${POSTGRES_DB}']
      interval: 10s
      timeout: 5s
      retries: 5

  n8n:
    image: n8nio/n8n:latest
    restart: always
    depends_on:
      postgres:
        condition: service_healthy
    environment:
      DB_TYPE: postgresdb
      DB_POSTGRESDB_HOST: postgres
      DB_POSTGRESDB_PORT: 5432
      DB_POSTGRESDB_DATABASE: ${POSTGRES_DB}
      DB_POSTGRESDB_USER: ${POSTGRES_USER}
      DB_POSTGRESDB_PASSWORD: ${POSTGRES_PASSWORD}
      N8N_HOST: ${N8N_HOST}
      N8N_PORT: ${N8N_PORT}
      N8N_PROTOCOL: ${N8N_PROTOCOL}
      WEBHOOK_URL: ${WEBHOOK_URL}
      N8N_ENCRYPTION_KEY: ${N8N_ENCRYPTION_KEY}
      GENERIC_TIMEZONE: ${GENERIC_TIMEZONE}
      EXECUTIONS_DATA_PRUNE: ${EXECUTIONS_DATA_PRUNE}
      EXECUTIONS_DATA_MAX_AGE: ${EXECUTIONS_DATA_MAX_AGE}
    volumes:
      - n8n_data:/home/node/.n8n
    ports:
      - '5678:5678'

  caddy:
    image: caddy:2-alpine
    restart: always
    ports:
      - '80:80'
      - '443:443'
    volumes:
      - ./Caddyfile:/etc/caddy/Caddyfile
      - caddy_data:/data
      - caddy_config:/config

volumes:
  postgres_data:
  n8n_data:
  caddy_data:
  caddy_config:
YAML

# Launch the stack
docker compose up -d

# Verify all containers are running
docker compose ps

# Check n8n logs
docker compose logs n8n --tail 50

# Azure CLI commands (or use Azure Portal > Azure Active Directory > App Registrations)

# Login to Azure with client tenant credentials
az login --tenant <CLIENT_TENANT_ID>

# Create the app registration
az ad app create --display-name 'AI News Monitoring Agent' --sign-in-audience AzureADMyOrg

# Note the Application (client) ID from the output
# Create a client secret
az ad app credential reset --id <APPLICATION_ID> --append --years 2

# Note the password (client secret) from output - save securely

# Add required API permissions
az ad app permission add --id <APPLICATION_ID> --api 00000003-0000-0000-c000-000000000000 --api-permissions b633e1c5-b582-4048-a93e-9f11b44c7e96=Role
# (Mail.Send - Application)

az ad app permission add --id <APPLICATION_ID> --api 00000003-0000-0000-c000-000000000000 --api-permissions ebf0f66e-9fb1-49e4-a278-222f76911cf4=Role
# (ChannelMessage.Send - Application)

az ad app permission add --id <APPLICATION_ID> --api 00000003-0000-0000-c000-000000000000 --api-permissions 01d4f6040-6ad3-4460-a0e9-05c81d7e26e5=Role
# (Files.ReadWrite.All - Application)

az ad app permission add --id <APPLICATION_ID> --api 00000003-0000-0000-c000-000000000000 --api-permissions 9a5d68dd-52b0-4cc2-bd40-abcf44ac3a30=Role
# (Sites.ReadWrite.All - Application)

# Grant admin consent
az ad app permission admin-consent --id <APPLICATION_ID>

# Using Microsoft Graph API via PowerShell or manually in Teams Admin Center

# Option A: Manual creation in Microsoft Teams
# 1. Open Microsoft Teams as a Teams admin
# 2. Navigate to the designated Team (e.g., 'Industry Intelligence')
# 3. Create channels:
#    - #regulatory-updates (General regulatory changes)
#    - #sector-healthcare (Healthcare industry news)
#    - #sector-financial-services (Financial services news)
#    - #sector-technology (Technology sector news)
#    - #critical-alerts (High-priority items only)

# Option B: PowerShell with Microsoft Graph
Install-Module Microsoft.Graph -Scope CurrentUser
Connect-MgGraph -Scopes 'Channel.Create, Group.ReadWrite.All'

# Get the Team ID
$team = Get-MgGroup -Filter "displayName eq 'Industry Intelligence'"

# Create channels
New-MgTeamChannel -TeamId $team.Id -DisplayName 'Regulatory Updates' -Description 'AI-generated regulatory change alerts'
New-MgTeamChannel -TeamId $team.Id -DisplayName 'Sector - Healthcare' -Description 'Healthcare industry intelligence'
New-MgTeamChannel -TeamId $team.Id -DisplayName 'Critical Alerts' -Description 'High-priority regulatory changes requiring immediate attention'

GET https://graph.microsoft.com/v1.0/sites/{hostname}:/{site-path}
GET https://graph.microsoft.com/v1.0/sites/{site-id}/drives

# Verify timezone setting in n8n environment:
# GENERIC_TIMEZONE should be set to the client's timezone in docker-compose.yml

az monitor metrics alert create \
  --name 'n8n-vm-cpu-alert' \
  --resource-group rg-n8n-monitoring \
  --scopes /subscriptions/<sub-id>/resourceGroups/rg-n8n-monitoring/providers/Microsoft.Compute/virtualMachines/vm-n8n-prod \
  --condition 'avg Percentage CPU > 85' \
  --window-size 5m \
  --action-group <msp-alerts-action-group>

cat > ~/n8n-deployment/backup.sh << 'BASH'
#!/bin/bash
TIMESTAMP=$(date +%Y%m%d_%H%M%S)
BACKUP_DIR=/home/n8nadmin/backups
mkdir -p $BACKUP_DIR

# Backup PostgreSQL database
docker compose exec -T postgres pg_dump -U n8n_user n8n_db > $BACKUP_DIR/n8n_db_$TIMESTAMP.sql

# Backup n8n data volume
docker run --rm -v n8n-deployment_n8n_data:/data -v $BACKUP_DIR:/backup alpine tar czf /backup/n8n_data_$TIMESTAMP.tar.gz /data

# Upload to Azure Blob Storage (or S3)
az storage blob upload --account-name <storage_account> --container-name n8n-backups --file $BACKUP_DIR/n8n_db_$TIMESTAMP.sql --name db/$TIMESTAMP.sql
az storage blob upload --account-name <storage_account> --container-name n8n-backups --file $BACKUP_DIR/n8n_data_$TIMESTAMP.tar.gz --name data/$TIMESTAMP.tar.gz

# Cleanup local backups older than 7 days
find $BACKUP_DIR -mtime +7 -delete
echo "Backup completed: $TIMESTAMP"
BASH
chmod +x ~/n8n-deployment/backup.sh

(crontab -l 2>/dev/null; echo '0 2 * * * /home/n8nadmin/n8n-deployment/backup.sh >> /var/log/n8n-backup.log 2>&1') | crontab -

HTTP Request Node: 'Fetch News - Perplexity'
Method: POST
URL: https://api.perplexity.ai/chat/completions
Authentication: HTTP Header Auth (Perplexity credential)
Headers:
  Content-Type: application/json
Body (JSON):
{
  "model": "sonar",
  "messages": [
    {
      "role": "system",
      "content": "You are a regulatory and industry news research assistant for professional services firms. Return only factual, recent news items with source URLs."
    },
    {
      "role": "user",
      "content": "Find the most recent regulatory changes, proposed rules, enforcement actions, and significant industry news in the {{$node['Client Config'].json.current_sector}} sector from the past 24 hours. Focus on: {{$node['Client Config'].json.priority_keywords}}. For each item, provide: title, source URL, publication date, a 2-sentence summary, and the specific regulatory body or agency involved."
    }
  ],
  "max_tokens": 2000,
  "temperature": 0.1,
  "return_citations": true
}

HTTP Request Node: 'Fetch News - Tavily'
Method: POST
URL: https://api.tavily.com/search
Authentication: HTTP Header Auth (Tavily credential)
Body (JSON):
{
  "query": "{{$node['Client Config'].json.current_sector}} regulatory changes new rules enforcement {{$node['Client Config'].json.current_date}}",
  "search_depth": "advanced",
  "include_domains": ["sec.gov", "federalregister.gov", "reuters.com", "law360.com", "accountingtoday.com", "compliance.com", "reginfo.gov", "congress.gov"],
  "max_results": 10,
  "include_raw_content": false,
  "include_answer": true
}

// URL-based deduplication across merged API results

// n8n Code node for deduplication
const items = $input.all();
const seen = new Map();
const unique = [];

for (const item of items) {
  const url = item.json.url || item.json.source_url;
  const normalizedUrl = url?.replace(/\/$/, '').replace(/^https?:\/\/www\./, 'https://');
  
  if (normalizedUrl && !seen.has(normalizedUrl)) {
    seen.set(normalizedUrl, true);
    unique.push(item);
  }
}

return unique;

<!DOCTYPE html>
<html>
<head>
<style>
  body { font-family: 'Segoe UI', Calibri, Arial, sans-serif; color: #333; max-width: 800px; margin: 0 auto; }
  .header { background: #1a365d; color: white; padding: 20px; border-radius: 8px 8px 0 0; }
  .header h1 { margin: 0; font-size: 22px; }
  .header .date { font-size: 14px; opacity: 0.8; margin-top: 4px; }
  .critical { border-left: 4px solid #e53e3e; background: #fff5f5; padding: 16px; margin: 12px 0; border-radius: 0 4px 4px 0; }
  .high { border-left: 4px solid #dd6b20; background: #fffaf0; padding: 16px; margin: 12px 0; border-radius: 0 4px 4px 0; }
  .medium { border-left: 4px solid #3182ce; background: #ebf8ff; padding: 16px; margin: 12px 0; border-radius: 0 4px 4px 0; }
  .item-header { font-size: 16px; font-weight: 600; margin: 0 0 8px 0; }
  .item-meta { font-size: 12px; color: #666; margin-bottom: 8px; }
  .badge { display: inline-block; padding: 2px 8px; border-radius: 12px; font-size: 11px; font-weight: 600; text-transform: uppercase; }
  .badge-critical { background: #e53e3e; color: white; }
  .badge-high { background: #dd6b20; color: white; }
  .badge-medium { background: #3182ce; color: white; }
  .badge-sector { background: #e2e8f0; color: #4a5568; }
  .actions { background: #f7fafc; padding: 12px; border-radius: 4px; margin-top: 8px; }
  .actions h4 { margin: 0 0 4px 0; font-size: 13px; color: #2d3748; }
  .actions ul { margin: 4px 0 0 0; padding-left: 20px; font-size: 13px; }
  .footer { text-align: center; padding: 16px; font-size: 12px; color: #999; border-top: 1px solid #eee; margin-top: 24px; }
  .disclaimer { font-style: italic; background: #f0f0f0; padding: 10px; border-radius: 4px; font-size: 11px; margin-top: 16px; }
</style>
</head>
<body>
<div class="header">
  <h1>📋 Industry Intelligence Briefing</h1>
  <div class="date">{{$json.date}} | {{$json.client_name}} | {{$json.total_items}} items across {{$json.sector_count}} sectors</div>
</div>

<div style="padding: 20px;">
  {{#each critical_items}}
  <div class="critical">
    <span class="badge badge-critical">⚠ Critical</span>
    <span class="badge badge-sector">{{this.sector}}</span>
    <h3 class="item-header">{{this.headline}}</h3>
    <div class="item-meta">{{this.regulatory_body}} | {{this.source_citation}}</div>
    <p>{{this.summary}}</p>
    <div class="actions">
      <h4>Recommended Actions:</h4>
      <ul>{{#each this.recommended_actions}}<li>{{this}}</li>{{/each}}</ul>
      {{#if this.compliance_deadline}}<p><strong>⏰ Deadline: {{this.compliance_deadline}}</strong></p>{{/if}}
    </div>
  </div>
  {{/each}}

  {{#each high_items}}
  <div class="high">
    <span class="badge badge-high">High</span>
    <span class="badge badge-sector">{{this.sector}}</span>
    <h3 class="item-header">{{this.headline}}</h3>
    <div class="item-meta">{{this.source_citation}}</div>
    <p>{{this.summary}}</p>
  </div>
  {{/each}}

  {{#each medium_items}}
  <div class="medium">
    <span class="badge badge-medium">Medium</span>
    <span class="badge badge-sector">{{this.sector}}</span>
    <h3 class="item-header">{{this.headline}}</h3>
    <div class="item-meta">{{this.source_citation}}</div>
    <p>{{this.summary}}</p>
  </div>
  {{/each}}

  <div class="disclaimer">
    🤖 This briefing was generated by AI-powered monitoring agents. All content is sourced from publicly available news and regulatory publications. This is not legal, financial, or compliance advice. Items should be reviewed by qualified professionals before any action is taken. Generated: {{$json.generated_timestamp}}
  </div>
</div>

<div class="footer">
  Managed by {{$json.msp_name}} | AI Industry Intelligence Service<br>
  To adjust monitored sectors or delivery preferences, contact your account manager.
</div>
</body>
</html>

{
  "type": "AdaptiveCard",
  "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
  "version": "1.5",
  "body": [
    {
      "type": "Container",
      "style": "emphasis",
      "items": [
        {
          "type": "ColumnSet",
          "columns": [
            {
              "type": "Column",
              "width": "auto",
              "items": [{"type": "TextBlock", "text": "📋", "size": "large"}]
            },
            {
              "type": "Column",
              "width": "stretch",
              "items": [
                {"type": "TextBlock", "text": "Industry Intelligence Update", "weight": "bolder", "size": "medium"},
                {"type": "TextBlock", "text": "{{DATE}}", "isSubtle": true, "spacing": "none"}
              ]
            }
          ]
        }
      ]
    },
    {
      "type": "Container",
      "items": [
        {"type": "TextBlock", "text": "{{HEADLINE}}", "weight": "bolder", "wrap": true},
        {"type": "FactSet", "facts": [
          {"title": "Priority", "value": "{{PRIORITY}}"},
          {"title": "Sector", "value": "{{SECTOR}}"},
          {"title": "Source", "value": "{{REGULATORY_BODY}}"}
        ]},
        {"type": "TextBlock", "text": "{{SUMMARY}}", "wrap": true},
        {"type": "TextBlock", "text": "**Recommended Actions:**", "weight": "bolder", "spacing": "medium"},
        {"type": "TextBlock", "text": "{{ACTIONS_LIST}}", "wrap": true}
      ]
    }
  ],
  "actions": [
    {"type": "Action.OpenUrl", "title": "Read Full Article", "url": "{{SOURCE_URL}}"},
    {"type": "Action.OpenUrl", "title": "View in SharePoint Archive", "url": "{{SHAREPOINT_URL}}"}
  ]
}

Method: POST
URL: https://graph.microsoft.com/v1.0/teams/{{$json.team_id}}/channels/{{$json.channel_id}}/messages
Authentication: Microsoft Graph OAuth2
Headers:
  Content-Type: application/json
Body:
{
  "body": {
    "contentType": "html",
    "content": "<attachment id='adaptive-card'></attachment>"
  },
  "attachments": [
    {
      "id": "adaptive-card",
      "contentType": "application/vnd.microsoft.card.adaptive",
      "content": "{{$json.adaptive_card_json}}"
    }
  ]
}

Method: PUT
URL: https://graph.microsoft.com/v1.0/drives/{{$json.drive_id}}/root:/AI Briefings Archive/Daily Digests/{{$json.filename}}:/content
Authentication: Microsoft Graph OAuth2
Headers:
  Content-Type: text/html
Body: {{$json.html_content}}

Method: POST
URL: https://api.openai.com/v1/chat/completions
Authentication: OpenAI credential
Body:
{
  "model": "gpt-4.1-2025-04-14",
  "temperature": 0.1,
  "max_tokens": 2000,
  "messages": [
    {
      "role": "system",
      "content": "You are a senior regulatory analyst preparing an urgent alert for a professional services firm's leadership team. This is a CRITICAL regulatory change that requires immediate attention. Provide a thorough analysis including:\n\n1. EXECUTIVE SUMMARY (2-3 sentences)\n2. DETAILED ANALYSIS (3-5 paragraphs covering: what changed, who is affected, timeline, penalties for non-compliance)\n3. AFFECTED PRACTICE AREAS (list specific practice areas within the firm)\n4. AFFECTED CLIENT SECTORS (which client industries are impacted)\n5. IMMEDIATE ACTIONS REQUIRED (numbered list of specific steps)\n6. KEY DATES AND DEADLINES\n7. SOURCES AND REFERENCES\n\nWrite in authoritative, professional tone. Be specific about regulatory citations (e.g., 'Section 302 of SOX', '17 CFR § 240.10b-5'). Note any ambiguities or pending clarifications."
    },
    {
      "role": "user",
      "content": "Analyze this critical regulatory development:\n\nTitle: {{$json.title}}\nSource: {{$json.url}}\nRegulatory Body: {{$json.regulatory_body}}\nChange Type: {{$json.change_type}}\nContent: {{$json.content}}"
    }
  ]
}

Method: POST
URL: https://graph.microsoft.com/v1.0/teams/{{team_id}}/channels/{{critical_channel_id}}/messages
Body: Adaptive Card with red emphasis container and @mention of relevant partners

Method: POST
URL: https://graph.microsoft.com/v1.0/users/{{service_account_email}}/sendMail
Body:
{
  "message": {
    "subject": "⚠️ CRITICAL REGULATORY ALERT: {{$json.headline}}",
    "body": {
      "contentType": "HTML",
      "content": "{{$json.alert_html}}"
    },
    "toRecipients": [
      {{#each digest_email_recipients}}
      { "emailAddress": { "address": "{{this}}" } }
      {{/each}}
    ],
    "importance": "high"
  }
}

# ConnectWise HTTP Request

Method: POST
URL: https://{{connectwise_url}}/v4_6_release/apis/3.0/service/tickets
Authentication: Basic (ConnectWise API keys)
Body:
{
  "summary": "[AI Alert] Critical Regulatory Change: {{$json.headline}}",
  "board": { "id": {{compliance_board_id}} },
  "company": { "id": {{client_company_id}} },
  "priority": { "id": 1 },
  "type": { "id": {{regulatory_alert_type_id}} },
  "initialDescription": "{{$json.analysis_text}}\n\nSource: {{$json.url}}\nGenerated by AI Monitoring Agent at {{$json.timestamp}}"
}

const logEntry = {
  timestamp: new Date().toISOString(),
  alert_type: 'critical',
  headline: $json.headline,
  sector: $json.sector,
  regulatory_body: $json.regulatory_body,
  delivery_channels: ['teams', 'email', 'sharepoint'],
  psa_ticket_created: $json.psa_ticket_id || null,
  execution_id: $execution.id
};

// This data is stored in n8n's execution log automatically
// Additional logging can be sent to an external system if needed
return [{ json: logEntry }];

0 7 * * 1

-- Retrieve classified items from the past 7 days (dedicated PostgreSQL
-- table)

SELECT 
  title, headline, summary, sector, priority, 
  regulatory_body, change_type, compliance_deadline,
  practice_implications, recommended_actions, source_url,
  classification_date
FROM classified_items
WHERE classification_date >= NOW() - INTERVAL '7 days'
ORDER BY priority DESC, classification_date DESC;

gotenberg:
  image: gotenberg/gotenberg:8
  restart: always
  ports:
    - '3000:3000'

Method: POST
URL: http://gotenberg:3000/forms/chromium/convert/html
Content-Type: multipart/form-data
Body:
  files: index.html (the rendered HTML briefing)
  marginTop: 0.5
  marginBottom: 0.5
  marginLeft: 0.5
  marginRight: 0.5

Method: PUT
URL: https://graph.microsoft.com/v1.0/drives/{{drive_id}}/root:/AI Briefings Archive/Weekly Summaries/Weekly_Briefing_{{week_start_date}}.pdf:/content
Headers:
  Content-Type: application/pdf
Body: {{$binary.data}}

# store in the n8n 'Client Config' Set node during client onboarding

{
  "client_id": "acme-ps-001",
  "client_name": "Acme Professional Services LLC",
  "timezone": "America/New_York",
  "delivery_schedule": {
    "critical_alerts": "immediate",
    "daily_digest": "0 8 * * 1-5",
    "weekly_summary": "0 8 * * 1"
  },
  "sectors": [
    {
      "sector_id": "healthcare",
      "display_name": "Healthcare & Life Sciences",
      "search_queries": [
        "HIPAA regulatory changes enforcement",
        "CMS Medicare Medicaid rule changes",
        "FDA regulatory updates pharmaceutical",
        "HHS healthcare compliance enforcement actions",
        "healthcare data privacy regulation updates",
        "No Surprises Act implementation updates",
        "healthcare antitrust enforcement FTC DOJ"
      ],
      "priority_keywords": ["HIPAA", "CMS", "FDA", "HHS", "OCR", "Medicare", "Medicaid", "PHI", "HITECH", "No Surprises Act", "340B", "Stark Law", "Anti-Kickback"],
      "regulatory_bodies": ["HHS", "CMS", "FDA", "OCR", "OIG", "FTC"],
      "include_domains": ["hhs.gov", "cms.gov", "fda.gov", "healthaffairs.org", "modernhealthcare.com", "beckershospitalreview.com", "fiercehealthcare.com"],
      "exclude_keywords": ["job posting", "stock price", "earnings call"],
      "teams_channel_id": "19:abc123@thread.tacv2",
      "min_relevance_score": 6
    },
    {
      "sector_id": "financial_services",
      "display_name": "Financial Services & Banking",
      "search_queries": [
        "SEC regulatory changes new rules",
        "FINRA enforcement actions guidance",
        "CFPB consumer finance regulation",
        "bank regulatory capital requirements changes",
        "anti-money laundering AML compliance updates",
        "FASB accounting standards updates",
        "cryptocurrency digital assets regulation SEC"
      ],
      "priority_keywords": ["SEC", "FINRA", "CFPB", "OCC", "FDIC", "SOX", "Dodd-Frank", "Basel", "AML", "BSA", "KYC", "ESG disclosure", "FASB", "PCAOB"],
      "regulatory_bodies": ["SEC", "FINRA", "CFPB", "OCC", "FDIC", "Federal Reserve", "PCAOB", "FASB"],
      "include_domains": ["sec.gov", "finra.org", "consumerfinance.gov", "reuters.com", "law360.com", "compliance.com"],
      "exclude_keywords": ["stock tip", "investment advice", "market prediction"],
      "teams_channel_id": "19:def456@thread.tacv2",
      "min_relevance_score": 6
    },
    {
      "sector_id": "real_estate",
      "display_name": "Real Estate & Construction",
      "search_queries": [
        "real estate regulation zoning changes",
        "CFPB mortgage lending rules",
        "HUD fair housing enforcement",
        "commercial real estate regulatory updates",
        "RESPA TILA regulatory changes",
        "environmental compliance real estate EPA",
        "property tax regulation changes state local"
      ],
      "priority_keywords": ["CFPB", "HUD", "RESPA", "TILA", "fair housing", "zoning", "EPA", "CERCLA", "1031 exchange", "opportunity zones", "FIRPTA"],
      "regulatory_bodies": ["CFPB", "HUD", "EPA", "IRS", "FHFA"],
      "include_domains": ["hud.gov", "consumerfinance.gov", "nar.realtor", "globest.com", "bisnow.com"],
      "exclude_keywords": ["home buying tips", "mortgage rates forecast", "best neighborhoods"],
      "teams_channel_id": "19:ghi789@thread.tacv2",
      "min_relevance_score": 6
    },
    {
      "sector_id": "technology",
      "display_name": "Technology & Data Privacy",
      "search_queries": [
        "data privacy regulation GDPR CCPA state laws",
        "AI artificial intelligence regulation policy",
        "FTC technology enforcement actions",
        "cybersecurity regulation SEC disclosure rules",
        "EU Digital Markets Act enforcement",
        "Section 230 technology regulation",
        "biometric data privacy regulation"
      ],
      "priority_keywords": ["GDPR", "CCPA", "CPRA", "AI Act", "FTC", "data breach", "Section 230", "DMA", "DSA", "CISA", "biometric", "BIPA", "transfer mechanism", "SCCs"],
      "regulatory_bodies": ["FTC", "EU Commission", "CISA", "state AGs", "ICO", "CNIL"],
      "include_domains": ["ftc.gov", "iapp.org", "techcrunch.com", "therecord.media", "euractiv.com"],
      "exclude_keywords": ["product review", "startup funding", "gadget"],
      "teams_channel_id": "19:jkl012@thread.tacv2",
      "min_relevance_score": 6
    }
  ],
  "delivery": {
    "email_recipients": [
      {"email": "managing.partner@acmeps.com", "sectors": ["all"], "frequency": ["daily", "weekly", "critical"]},
      {"email": "healthcare.lead@acmeps.com", "sectors": ["healthcare"], "frequency": ["daily", "critical"]},
      {"email": "finserv.lead@acmeps.com", "sectors": ["financial_services"], "frequency": ["daily", "critical"]}
    ],
    "teams_team_id": "team-uuid-here",
    "critical_channel_id": "19:critical-channel@thread.tacv2",
    "sharepoint_site_id": "site-uuid-here",
    "sharepoint_drive_id": "drive-uuid-here",
    "service_account_email": "ai-agent@acmeps.com"
  },
  "psa_integration": {
    "enabled": false,
    "platform": "connectwise",
    "api_url": "https://api-na.myconnectwise.net/v4_6_release/apis/3.0",
    "company_id": 12345,
    "board_id": 67,
    "type_id": 89,
    "create_tickets_for": ["critical"]
  }
}

GET https://graph.microsoft.com/v1.0/teams/{team-id}/channels/{channel-id}/messages?$filter=createdDateTime ge {last_check_time}&$expand=reactions

CREATE TABLE IF NOT EXISTS item_feedback (
  id SERIAL PRIMARY KEY,
  item_id VARCHAR(255),
  message_id VARCHAR(255),
  channel_id VARCHAR(255),
  thumbs_up INT DEFAULT 0,
  thumbs_down INT DEFAULT 0,
  stars INT DEFAULT 0,
  questions INT DEFAULT 0,
  collected_at TIMESTAMP DEFAULT NOW()
);

<div style="margin-top: 12px; font-size: 12px;">
  Rate this item: 
  <a href="https://n8n.yourdomain.com/webhook/feedback?item={{item_id}}&rating=useful">👍 Useful</a> | 
  <a href="https://n8n.yourdomain.com/webhook/feedback?item={{item_id}}&rating=not_useful">👎 Not Useful</a> | 
  <a href="https://n8n.yourdomain.com/webhook/feedback?item={{item_id}}&rating=need_more">🔍 Need More Detail</a>
</div>

SELECT 
  DATE_TRUNC('week', collected_at) as week,
  sector,
  COUNT(*) as total_items,
  SUM(thumbs_up) as positive_feedback,
  SUM(thumbs_down) as negative_feedback,
  ROUND(SUM(thumbs_up)::numeric / NULLIF(SUM(thumbs_up) + SUM(thumbs_down), 0) * 100, 1) as approval_rate
FROM item_feedback f
JOIN classified_items c ON f.item_id = c.id
WHERE collected_at >= NOW() - INTERVAL '30 days'
GROUP BY week, sector
ORDER BY week DESC, sector;

docker compose pull && docker compose up -d